#include <MongoInterface.h>

Public Member Functions
std::shared_ptr< Database >	connect (const PlTerm &dbTerm)

std::shared_ptr< Collection >	connect (const PlTerm &dbTerm, const char *collectionName)

std::shared_ptr< Collection >	connect (const char db_uri, const char db_name, const char *collectionName)

std::shared_ptr< Cursor >	cursor_create (const PlTerm &db_term, const char *coll_name)

void	cursor_destroy (const char *curser_id)

std::shared_ptr< Cursor >	cursor (const char *curser_id)

std::shared_ptr< Database >	connect (const PlTerm &dbTerm)

std::shared_ptr< Collection >	connect (const PlTerm &dbTerm, const char *collectionName)

std::shared_ptr< Collection >	connect (const char db_uri, const char db_name, const char *collectionName)

std::shared_ptr< Cursor >	cursor_create (const PlTerm &db_term, const char *coll_name)

void	cursor_destroy (const char *curser_id)

std::shared_ptr< Cursor >	cursor (const char *curser_id)

Static Public Member Functions
static MongoInterface &	get ()

static MongoInterface &	get ()

Detailed Description

Definition at line 29 of file MongoInterface.h.

Member Function Documentation

◆ connect() [1/6]

std::shared_ptr< Collection > MongoInterface::connect	(	const char *	db_uri,
		const char *	db_name,
		const char *	collectionName
	)

Definition at line 47 of file MongoInterface.cpp.

                                                                                            {
     auto dbConnection = getOrCreateConnection(db_uri);
     return std::make_shared<Collection>(dbConnection, db_name, collectionName);
 }

◆ connect() [2/6]

std::shared_ptr<Collection> knowrob::mongo::MongoInterface::connect	(	const char *	db_uri,
		const char *	db_name,
		const char *	collectionName
	)

◆ connect() [3/6]

std::shared_ptr< Database > MongoInterface::connect ( const PlTerm & dbTerm )

Definition at line 37 of file MongoInterface.cpp.

                                                                     {
     auto dbConnection = getOrCreateConnection((char *) dbTerm[1]);
     return std::make_shared<Database>(dbConnection->pool_, (char *) dbTerm[2]);
 }

◆ connect() [4/6]

std::shared_ptr<Database> knowrob::mongo::MongoInterface::connect ( const PlTerm & dbTerm )

◆ connect() [5/6]

std::shared_ptr< Collection > MongoInterface::connect	(	const PlTerm &	dbTerm,
		const char *	collectionName
	)

Definition at line 42 of file MongoInterface.cpp.

                                                                                                   {
     return connect((char *) dbTerm[1], (char *) dbTerm[2], collectionName);
 }

◆ connect() [6/6]

std::shared_ptr<Collection> knowrob::mongo::MongoInterface::connect	(	const PlTerm &	dbTerm,
		const char *	collectionName
	)

◆ cursor() [1/2]

std::shared_ptr< Cursor > MongoInterface::cursor ( const char * curser_id )

Definition at line 66 of file MongoInterface.cpp.

                                                                   {
     std::lock_guard<std::mutex> scoped_lock(mongo_mutex_);
     return cursors_[std::string(curser_id)];
 }

◆ cursor() [2/2]

std::shared_ptr<Cursor> knowrob::mongo::MongoInterface::cursor ( const char * curser_id )

◆ cursor_create() [1/2]

std::shared_ptr< Cursor > MongoInterface::cursor_create	(	const PlTerm &	db_term,
		const char *	coll_name
	)

Definition at line 53 of file MongoInterface.cpp.

                                                                                                 {
     auto coll = connect(db_term, coll_name);
     auto c = std::make_shared<Cursor>(coll);
     std::lock_guard<std::mutex> scoped_lock(mongo_mutex_);
     cursors_[c->id()] = c;
     return c;
 }

◆ cursor_create() [2/2]

std::shared_ptr<Cursor> knowrob::mongo::MongoInterface::cursor_create	(	const PlTerm &	db_term,
		const char *	coll_name
	)

◆ cursor_destroy() [1/2]

void MongoInterface::cursor_destroy ( const char * curser_id )

Definition at line 61 of file MongoInterface.cpp.

                                                          {
     std::lock_guard<std::mutex> scoped_lock(mongo_mutex_);
     cursors_.erase(curser_id);
 }

◆ cursor_destroy() [2/2]

void knowrob::mongo::MongoInterface::cursor_destroy ( const char * curser_id )

◆ get() [1/2]

MongoInterface & MongoInterface::get ( )

static

Definition at line 19 of file MongoInterface.cpp.

                                     {
     static MongoInterface singleton;
     return singleton;
 }

◆ get() [2/2]

static MongoInterface& knowrob::mongo::MongoInterface::get ( )