Mongo mongo;
	
	mongo.connect("notification", "notifyqueue");
	
//			mongo.addQuery_Int32GT("sequence", 390000 ); //sequence );
//	mongo.addQuery_Int32GTAndCharOrChar( "sequence", 300000, "token", "all", "token", "0bc1db8f5ce1873a528510c636d4ee6f" );
	mongo.addQuery_CharOrChar( "token", "58af74c34d94887d0b8b4861", "token", "ALL" );

	
	printf( "Connect Query: %s\n", mongo.returnQuery().c_str() );
	
//	printf("mongo.find() success:  %d records\n", (int)mongo.count() );
	
	printf("Doing mongo.find()\n");
	if( mongo.find() )
	{
		printf( "Mongo Error: %s\n", mongo.lastErrorMessage().c_str() );

		printf("mongo.find() success:  %d records\n", (int)mongo.count() );
		while( mongo.nextRecord() )
//		{
			printf("Mongo Next Record");
//			std::string out = mongo.recordAsString();
//			printf("Record: %s\n--------\n", out.c_str() );
//		}
		printf("Finished Mongo Find\n");

	} else {
		printf( "Mongo Error: %s\n", mongo.lastErrorMessage().c_str() );
	}

	printf("Disconnect Mongo Connection\n");
	mongo.disconnect();

void Mongo::addQuery_CharOrChar( const char * fieldname1, const char * value1, const char * fieldname2, const char * value2 )
{
// eg.  { $or:[ {fieldname: value}, {fieldname: value} ] }
	if( !query ) query = BSON_CREATE();
	
	bson_t child, child1, child2;

	
	if( BSON_APPEND_ARRAY_BEGIN( query, "$or", &child ) )
	{
		if( BSON_APPEND_DOCUMENT_BEGIN( &child, "", &child1 ) )
		{
			BSON_APPEND_UTF8 ( &child1, fieldname1, value1);
			bson_append_document_end( &child, &child1 );
		}

		if( BSON_APPEND_DOCUMENT_BEGIN( &child, "", &child2 ) )
		{
			BSON_APPEND_UTF8 ( &child2, fieldname2, value2);
			bson_append_document_end( &child, &child2 );
		}

		bson_append_array_end( query, &child );
	}

}




void Mongo::disconnect( void )
{
	try {
		doc = NULL;
		opts = BSON_DESTROY(opts);
		query = BSON_DESTROY(query);

		printf("mongoc_cursor_destroy: %d\n", (int)(cursor != NULL) );
		if( cursor ) 		mongoc_cursor_destroy (cursor);				cursor = NULL;

		printf("mongoc_collection_destroy: %d\n", (int)(collection != NULL) );
		if( collection )	mongoc_collection_destroy (collection);		collection = NULL;
		
		printf("mongoc_client_destroy: %d\n", (int)(client != NULL) );
		if( client )		mongoc_client_destroy (client);				client = NULL;
		
		
		
	} catch (...) {
		log_write("Mongo::disconnect try...catch error");
	}
}

void Mongo::connect( const char * theDatabase, const char * theCollection )
{
	try {
		if( setup() )
		{
			// clean up if already connected to a different table / collection.
			if( cursor ) 		mongoc_cursor_destroy (cursor);				cursor = NULL;
			if( collection )	mongoc_collection_destroy (collection);		collection = NULL;
			opts = BSON_DESTROY(opts);
			query = BSON_DESTROY(query);
			

			// Connect to the new table
			collection = mongoc_client_get_collection (client, theDatabase, theCollection );


			// Initialise default options and query parameters
//			opts = BSON_CREATE();
//			query = BSON_CREATE();
			doc = NULL;

		}
	} catch (...) {
		log_write("Mongo::connect try...catch error");
	}
}



bool Mongo::find( void )
{
	bool success = false;
	
	try {
		if( !setup() )			return false;		// Not connected to Mongo Database
		if( !collection )		return false;		// Haven't connected to database / collection
	

		if( cursor )		mongoc_cursor_destroy (cursor);
	
		if( !opts )			bson_init (opts);
		if( !query )		bson_init (query);
		doc = NULL;
	
		cursor = mongoc_collection_find_with_opts (collection, query, opts, read_prefs);
		success = (cursor != NULL);
		
	} catch (...) {
		log_write("Error: Mongo::find try...catch");
	}
	
	return success;
}

uint64_t Mongo::count( void )
{
	uint64_t count = -1;
	if( collection )
	{
		try {
			count = mongoc_collection_count (collection, MONGOC_QUERY_SLAVE_OK, query, 0, 0, read_prefs, &error);
		} catch(...) {
			log_write("Error: Mongo::recordCount try...catch");
		}
	}
	
	return count;
}