knowrob::mongo Namespace Reference

Classes
class	BindingsCursor
struct	bson_wrapper
struct	bson_wrapper_ptr
class	BulkOperation
class	ChangeStream
class	Collection
struct	Connection
class	Cursor
class	Database
class	Document
struct	IndexKey
class	MongoException
class	MongoInterface
class	MongoTaxonomy
class	MongoTerm
class	MongoTriple
class	MongoTriplePattern
struct	TripleLookupData
class	Pipeline
class	QueryWatch
class	TripleCursor
struct	TripleStore

Typedefs
using	BindingsCursorPtr = std::shared_ptr< BindingsCursor >
using	ChangeStreamCallback = std::function< void(const bson_wrapper_ptr &)>

Enumerations
enum class	IndexType { ASCENDING = 1 , DESCENDING = -1 , ASCENDING = 1 , DESCENDING = -1 }
enum class	IndexType { ASCENDING = 1 , DESCENDING = -1 , ASCENDING = 1 , DESCENDING = -1 }

Functions
std::optional< double >	bson_iterOptionalDouble (const bson_iter_t *iter)
void	lookupTriple (Pipeline &pipeline, const TripleStore &tripleStore, const TripleLookupData &lookupData)

Typedef Documentation

BindingsCursorPtr

typedef std::shared_ptr< BindingsCursor > knowrob::mongo::BindingsCursorPtr

Definition at line 37 of file BindingsCursor.h.

ChangeStreamCallback

typedef std::function< void(const bson_wrapper_ptr &)> knowrob::mongo::ChangeStreamCallback

Called for each result of a change stream.

Definition at line 21 of file ChangeStream.h.

Enumeration Type Documentation

IndexType [1/2]

enum knowrob::mongo::IndexType

strong

The type of an index.

Enumerator
ASCENDING
DESCENDING
ASCENDING
DESCENDING

Definition at line 13 of file Index.h.

                         {
        ASCENDING = 1,
        DESCENDING = -1,
    };

IndexType [2/2]

enum knowrob::mongo::IndexType

strong

The type of an index.

Enumerator
ASCENDING
DESCENDING
ASCENDING
DESCENDING

Definition at line 13 of file Index.h.

                         {
        ASCENDING = 1,
        DESCENDING = -1,
    };

Function Documentation

bson_iterOptionalDouble()

std::optional< double > knowrob::mongo::bson_iterOptionalDouble

(

const bson_iter_t *

iter

)

Parameters

iter	a bson iterator

Returns

the double value of iter or null opt if none.

Definition at line 10 of file bson-helper.cpp.

                                                                         {
        auto iterType = bson_iter_type(iter);
        if (iterType == BSON_TYPE_DECIMAL128) {
            bson_decimal128_t decimal;
            bson_iter_decimal128(iter, &decimal);
            if (decimal.high == 0x7800000000000000 || decimal.high == 0xf800000000000000) {
                // infinity
                return std::nullopt;
            } else {
                char buffer[BSON_DECIMAL128_STRING];
                bson_decimal128_to_string(&decimal, buffer);
                setlocale(LC_NUMERIC, "C");
                auto val = atof(buffer);
                setlocale(LC_NUMERIC, "");
                return val;
            }
        } else if (iterType == BSON_TYPE_DOUBLE) {
            return bson_iter_double(iter);
        } else {
            return std::nullopt;
        }
    }

lookupTriple()

void knowrob::mongo::lookupTriple	(	Pipeline &	pipeline,
		const TripleStore &	tripleStore,
		const TripleLookupData &	lookupData
	)

Definition at line 569 of file MongoTriplePattern.cpp.

                                                                                                               {
    semweb::PropertyPtr definedProperty;
    if (lookupData.expr->propertyTerm() && lookupData.expr->propertyTerm()->termType() == TermType::ATOMIC) {
        auto propertyTerm = std::static_pointer_cast<Atomic>(lookupData.expr->propertyTerm());
        definedProperty = tripleStore.vocabulary->getDefinedProperty(propertyTerm->stringForm());
    }
 
    bool b_isTransitiveProperty = (definedProperty && definedProperty->hasFlag(
            semweb::PropertyFlag::TRANSITIVE_PROPERTY));
    if (b_isTransitiveProperty)
        transitiveLookup(pipeline, tripleStore, lookupData, definedProperty);
    else
        nonTransitiveLookup(pipeline, tripleStore, lookupData, definedProperty);
}