knowrob::mongo::MongoTriple Class Reference

#include <MongoTriple.h>

Collaboration diagram for knowrob::mongo::MongoTriple:

Public Member Functions
	MongoTriple (const VocabularyPtr &vocabulary, const Triple &tripleData, const std::string &fallbackOrigin, bool isTaxonomic)
auto &	document () const
	MongoTriple (const VocabularyPtr &vocabulary, const Triple &tripleData, const std::string &fallbackOrigin, bool isTaxonomic)
auto &	document () const

Static Protected Member Functions
static bson_t *	createDocument (const VocabularyPtr &vocabulary, const Triple &tripleData, const std::string &fallbackOrigin, bool isTaxonomic)
static bson_t *	createDocument (const VocabularyPtr &vocabulary, const Triple &tripleData, const std::string &fallbackOrigin, bool isTaxonomic)

Protected Attributes
Document	document_

Detailed Description

Transforms a triple into a MongoDB document.

Definition at line 17 of file MongoTriple.h.

Constructor & Destructor Documentation

MongoTriple() [1/2]

MongoTriple::MongoTriple	(	const VocabularyPtr &	vocabulary,
		const Triple &	tripleData,
		const std::string &	fallbackOrigin,
		bool	isTaxonomic
	)

Definition at line 11 of file MongoTriple.cpp.

        : document_(createDocument(vocabulary, tripleData, fallbackOrigin, isTaxonomic)) {
}

MongoTriple() [2/2]

knowrob::mongo::MongoTriple::MongoTriple	(	const VocabularyPtr &	vocabulary,
		const Triple &	tripleData,
		const std::string &	fallbackOrigin,
		bool	isTaxonomic
	)

Member Function Documentation

createDocument() [1/2]

bson_t * MongoTriple::createDocument ( const VocabularyPtr &  vocabulary, const Triple &  tripleData, const std::string &  fallbackOrigin, bool  isTaxonomic  )

staticprotected

Definition at line 57 of file MongoTriple.cpp.

                          {
    bson_t parentsArray;
    uint32_t arrIndex = 0;
    auto counterPtr = &arrIndex;
 
    bson_t *tripleDoc = bson_new();
    BSON_APPEND_UTF8(tripleDoc, "s", tripleData.subject().data());
    BSON_APPEND_UTF8(tripleDoc, "p", tripleData.predicate().data());
 
    if (isTaxonomic) {
        if (tripleData.isObjectIRI() || tripleData.isObjectBlank()) {
            auto objectIRI = tripleData.valueAsString();
            BSON_APPEND_UTF8(tripleDoc, "o", objectIRI.data());
            // also create a field "o*" with the parents of the object
            BSON_APPEND_ARRAY_BEGIN(tripleDoc, "o*", &parentsArray);
            auto parentsPtr = &parentsArray;
            if (vocabulary->isDefinedProperty(objectIRI)) {
                vocabulary->getDefinedProperty(objectIRI)->forallParents(
                        [parentsPtr, counterPtr](const auto &parent) {
                            auto counterKey = std::to_string((*counterPtr)++);
                            BSON_APPEND_UTF8(parentsPtr, counterKey.c_str(), parent.iri().data());
                        });
            } else if (vocabulary->isDefinedClass(objectIRI)) {
                // read parents array
                vocabulary->getDefinedClass(objectIRI)->forallParents(
                        [parentsPtr, counterPtr](const auto &parent) {
                            auto counterKey = std::to_string((*counterPtr)++);
                            BSON_APPEND_UTF8(parentsPtr, counterKey.c_str(), parent.iri().data());
                        });
            } else {
                BSON_APPEND_UTF8(&parentsArray, "0", objectIRI.data());
            }
            bson_append_array_end(tripleDoc, &parentsArray);
        } else {
            appendXSDLiteral(tripleDoc, tripleData);
        }
    } else {
        if (tripleData.isObjectIRI() || tripleData.isObjectBlank()) {
            BSON_APPEND_UTF8(tripleDoc, "o", tripleData.valueAsString().data());
        } else {
            appendXSDLiteral(tripleDoc, tripleData);
        }
        // read parents array
        BSON_APPEND_ARRAY_BEGIN(tripleDoc, "p*", &parentsArray);
        auto parentsPtr = &parentsArray;
        vocabulary->defineProperty(tripleData.predicate())->forallParents(
                [parentsPtr, counterPtr](const auto &parent) {
                    auto counterKey = std::to_string((*counterPtr)++);
                    BSON_APPEND_UTF8(parentsPtr, counterKey.c_str(), parent.iri().data());
                });
        bson_append_array_end(tripleDoc, &parentsArray);
    }
 
    if (tripleData.graph()) {
        BSON_APPEND_UTF8(tripleDoc, "graph", tripleData.graph().value().data());
    } else {
        BSON_APPEND_UTF8(tripleDoc, "graph", fallbackOrigin.c_str());
    }
 
    if (tripleData.perspective())
        BSON_APPEND_UTF8(tripleDoc, "agent", tripleData.perspective().value().data());
 
    bool isBelief;
    if (tripleData.confidence().has_value()) {
        BSON_APPEND_DOUBLE(tripleDoc, "confidence", tripleData.confidence().value());
        isBelief = true;
    } else {
        isBelief = tripleData.isUncertain();
    }
    if (isBelief) {
        // flag the statement as "uncertain"
        BSON_APPEND_BOOL(tripleDoc, "uncertain", true);
    }
 
    if (tripleData.isOccasional()) {
        // flag the statement as "occasional", meaning it is only known that it was true at some past instants
        BSON_APPEND_BOOL(tripleDoc, "occasional", true);
    }
 
    if (tripleData.begin().has_value() || tripleData.end().has_value()) {
        bson_t scopeDoc, timeDoc;
        BSON_APPEND_DOCUMENT_BEGIN(tripleDoc, "scope", &scopeDoc);
        BSON_APPEND_DOCUMENT_BEGIN(&scopeDoc, "time", &timeDoc);
        if (tripleData.begin().has_value()) BSON_APPEND_DOUBLE(&timeDoc, "since", tripleData.begin().value());
        if (tripleData.end().has_value()) BSON_APPEND_DOUBLE(&timeDoc, "until", tripleData.end().value());
        bson_append_document_end(&scopeDoc, &timeDoc);
        bson_append_document_end(tripleDoc, &scopeDoc);
    }
 
    return tripleDoc;
}

createDocument() [2/2]

static bson_t* knowrob::mongo::MongoTriple::createDocument ( const VocabularyPtr &  vocabulary, const Triple &  tripleData, const std::string &  fallbackOrigin, bool  isTaxonomic  )

staticprotected

document() [1/2]

auto& knowrob::mongo::MongoTriple::document ( ) const

inline

Returns

the document.

Definition at line 27 of file MongoTriple.h.

{ return document_; }

document() [2/2]

auto& knowrob::mongo::MongoTriple::document ( ) const

inline

Returns

the document.

Definition at line 27 of file MongoTriple.h.

{ return document_; }

Member Data Documentation

document_

Document knowrob::mongo::MongoTriple::document_

protected

Definition at line 30 of file MongoTriple.h.

---

The documentation for this class was generated from the following files:

• build/_CPack_Packages/Linux/DEB/knowrob-2.1.0-Linux/usr/include/knowrob/storage/mongo/MongoTriple.h
• src/storage/mongo/MongoTriple.cpp