Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #include <iostream>
- #include "mongo/client/dbclient.h"
- using namespace std;
- void insert( mongo::DBClientConnection & conn , const char * name , int num ) {
- mongo::BSONObjBuilder obj;
- obj.append( "name" , name );
- obj.append( "num" , num );
- conn.insert( "test.people" , obj.obj() );
- }
- int main( int argc, const char **argv ) {
- const char *port = "27017";
- if ( argc != 1 ) {
- if ( argc != 3 )
- throw -12;
- port = argv[ 2 ];
- }
- mongo::DBClientConnection conn;
- string errmsg;
- if ( ! conn.connect( string( "127.0.0.1:" ) + port , errmsg ) ) {
- cout << "couldn't connect : " << errmsg << endl;
- throw -11;
- }
- {
- // clean up old data from any previous tests
- mongo::BSONObjBuilder query;
- conn.remove( "test.people" , query.obj() );
- }
- insert( conn, "a", 1 );
- insert( conn, "a", 2 );
- insert( conn, "a", 3 );
- insert( conn, "a", 4 );
- insert( conn, "a", 5 );
- insert( conn, "a", 6 );
- insert( conn, "a", 7 );
- insert( conn, "a", 8 );
- insert( conn, "a", 9 );
- insert( conn, "a", 10 );
- int test[2];
- test[0] = 5;
- test[1] = 1;
- test[2] = 3;
- mongo::BSONObjBuilder obj;
- obj.append( "name" , "wut");
- obj.appendBinData( "binTest",sizeof(test), BinDataGeneral, test);
- conn.insert( "test.people" , obj.obj() );
- {
- mongo::BSONObj query = BSON( "num" << BSON( "$nin" << BSON_ARRAY(1 << 5 << 10) ) );
- cout << query << endl;
- auto_ptr<mongo::DBClientCursor> cursor = conn.query( "test.people" , query );
- cout << "using cursor" << endl;
- while ( cursor->more() ) {
- mongo::BSONObj obj = cursor->next();
- cout << "\t" << obj.jsonString() << endl;
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement