#include <Database.h>

Public Member Functions
	Database (mongoc_client_pool_t *pool, std::string_view db_name)

	~Database ()

mongoc_database_t *	db ()

bool	create_index (const char *coll_name, const std::vector< IndexKey > &indexes)

	Database (mongoc_client_pool_t *pool, std::string_view db_name)

	~Database ()

mongoc_database_t *	db ()

bool	create_index (const char *coll_name, const std::vector< IndexKey > &indexes)

Detailed Description

A named database in a Mongo DB instance.

Definition at line 19 of file Database.h.

Constructor & Destructor Documentation

◆ Database() [1/2]

Database::Database	(	mongoc_client_pool_t *	pool,
		std::string_view	db_name
	)

Definition at line 11 of file Database.cpp.

         : pool_(pool) {
     client_ = mongoc_client_pool_pop(pool_);
     db_ = mongoc_client_get_database(client_, db_name.data());
 }

◆ ~Database() [1/2]

Database::~Database ( )

Definition at line 17 of file Database.cpp.

                     {
     mongoc_database_destroy(db_);
     mongoc_client_pool_push(pool_, client_);
 }

◆ Database() [2/2]

knowrob::mongo::Database::Database	(	mongoc_client_pool_t *	pool,
		std::string_view	db_name
	)

◆ ~Database() [2/2]

knowrob::mongo::Database::~Database ( )

Member Function Documentation

◆ create_index() [1/2]

bool Database::create_index	(	const char *	coll_name,
		const std::vector< IndexKey > &	indexes
	)

Definition at line 22 of file Database.cpp.

                                                                                      {
     bson_t reply;
     bson_error_t err;
     bson_t keys;
     //
     bson_init(&keys);
     for (auto &is : indexes) {
         BSON_APPEND_INT32(&keys, is.value.c_str(), (int)is.type);
     }
     char *index_name = mongoc_collection_keys_to_index_string(&keys);
     //
     bson_t *cmd = BCON_NEW ("createIndexes", BCON_UTF8(coll_name),
                             "indexes", "[", "{",
                             "key", BCON_DOCUMENT(&keys),
                             "name", BCON_UTF8(index_name),
                             "}", "]"
     );
     bool success = mongoc_database_write_command_with_opts(
             db_, cmd, nullptr /* opts */, &reply, &err);
     bson_free(index_name);
     bson_destroy(&reply);
     bson_destroy(cmd);
     if (!success) {
         throw MongoException("create_index_failed", err);
     }
     return success;
 }

◆ create_index() [2/2]

bool knowrob::mongo::Database::create_index	(	const char *	coll_name,
		const std::vector< IndexKey > &	indexes
	)

◆ db() [1/2]

mongoc_database_t* knowrob::mongo::Database::db ( )

inline

Definition at line 24 of file Database.h.

24 { return db_; }

◆ db() [2/2]