knowrob::transaction::Insert Class Reference

#include <Transaction.h>

Inheritance diagram for knowrob::transaction::Insert:

Collaboration diagram for knowrob::transaction::Insert:

Public Member Functions
	Insert (const std::shared_ptr< QueryableStorage > &queryable, const std::shared_ptr< Vocabulary > &vocabulary)
	Insert (const std::shared_ptr< QueryableStorage > &queryable, const std::shared_ptr< Vocabulary > &vocabulary)
Public Member Functions inherited from knowrob::transaction::Transaction
	Transaction (const std::shared_ptr< QueryableStorage > &queryable, const std::shared_ptr< Vocabulary > &vocabulary, bool isRemoval)
virtual	~Transaction ()=default
void	addBackend (const std::shared_ptr< NamedBackend > &backend)
bool	commit (const Triple &triple)
bool	commit (const Triple &triple, const IRIAtomPtr &reifiedName)
bool	commit (const TripleContainerPtr &triples)
bool	commit (const TripleContainerPtr &triples, const ReifiedNames &reifiedNames)
	Transaction (const std::shared_ptr< QueryableStorage > &queryable, const std::shared_ptr< Vocabulary > &vocabulary, bool isRemoval)
virtual	~Transaction ()=default
void	addBackend (const std::shared_ptr< NamedBackend > &backend)
bool	commit (const Triple &triple)
bool	commit (const Triple &triple, const IRIAtomPtr &reifiedName)
bool	commit (const TripleContainerPtr &triples)
bool	commit (const TripleContainerPtr &triples, const ReifiedNames &reifiedNames)

Protected Member Functions
bool	doCommit (const Triple &triple, const StoragePtr &backend) override
bool	doCommit (const TripleContainerPtr &triples, const StoragePtr &backend) override
void	updateVocabulary (const Triple &triple) override
bool	doCommit (const Triple &triple, const StoragePtr &backend) override
bool	doCommit (const TripleContainerPtr &triples, const StoragePtr &backend) override
void	updateVocabulary (const Triple &triple) override
Protected Member Functions inherited from knowrob::transaction::Transaction
bool	commitProtected (const TripleContainerPtr &triple, const StoragePtr &backend)
IRIAtomPtr	queryReifiedName (const Triple &triple)
bool	commitProtected (const TripleContainerPtr &triple, const StoragePtr &backend)
IRIAtomPtr	queryReifiedName (const Triple &triple)

Additional Inherited Members
Static Protected Member Functions inherited from knowrob::transaction::Transaction
static std::shared_ptr< ThreadPool::Runner >	createTripleWorker (const TripleContainerPtr &triples, const std::function< void(const TriplePtr &)> &fn)
static std::shared_ptr< ThreadPool::Runner >	createTripleWorker (const TripleContainerPtr &triples, const std::function< void(const TriplePtr &)> &fn)
Protected Attributes inherited from knowrob::transaction::Transaction
std::shared_ptr< Vocabulary >	vocabulary_
std::shared_ptr< QueryableStorage >	queryable_
std::vector< std::shared_ptr< NamedBackend > >	backends_
bool	isRemoval_

Detailed Description

A data insertion transaction.

Definition at line 94 of file Transaction.h.

Constructor & Destructor Documentation

Insert() [1/2]

knowrob::transaction::Insert::Insert ( const std::shared_ptr< QueryableStorage > &  queryable, const std::shared_ptr< Vocabulary > &  vocabulary  )

inline

Definition at line 96 of file Transaction.h.

                : Transaction(queryable, vocabulary, false) {}

Insert() [2/2]

knowrob::transaction::Insert::Insert ( const std::shared_ptr< QueryableStorage > &  queryable, const std::shared_ptr< Vocabulary > &  vocabulary  )

inline

Definition at line 96 of file Transaction.h.

                : Transaction(queryable, vocabulary, false) {}

Member Function Documentation

doCommit() [1/4]

bool Insert::doCommit ( const Triple &  triple, const StoragePtr &  backend  )

overrideprotectedvirtual

Implements knowrob::transaction::Transaction.

Definition at line 185 of file Transaction.cpp.

                                                                     {
    return backend->insertOne(triple);
}

doCommit() [2/4]

bool knowrob::transaction::Insert::doCommit ( const Triple &  triple, const StoragePtr &  backend  )

overrideprotectedvirtual

Implements knowrob::transaction::Transaction.

doCommit() [3/4]

bool Insert::doCommit ( const TripleContainerPtr &  triples, const StoragePtr &  backend  )

overrideprotectedvirtual

Implements knowrob::transaction::Transaction.

Definition at line 193 of file Transaction.cpp.

                                                                                         {
    return backend->insertAll(triples);
}

doCommit() [4/4]

bool knowrob::transaction::Insert::doCommit ( const TripleContainerPtr &  triples, const StoragePtr &  backend  )

overrideprotectedvirtual

Implements knowrob::transaction::Transaction.

updateVocabulary() [1/2]

void Insert::updateVocabulary ( const Triple &  triple )

overrideprotectedvirtual

Implements knowrob::transaction::Transaction.

Definition at line 201 of file Transaction.cpp.

                                                  {
    // keep track of imports, subclasses, and subproperties
    if (isSubClassOfIRI(triple.predicate())) {
        auto sub = vocabulary_->defineClass(triple.subject());
        auto sup = vocabulary_->defineClass(triple.valueAsString());
        sub->addDirectParent(sup, triple.graph());
        vocabulary_->increaseFrequency(rdfs::subClassOf->stringForm());
    } else if (isSubPropertyOfIRI(triple.predicate())) {
        auto sub = vocabulary_->defineProperty(triple.subject());
        auto sup = vocabulary_->defineProperty(triple.valueAsString());
        sub->addDirectParent(sup, triple.graph());
        vocabulary_->increaseFrequency(rdfs::subPropertyOf->stringForm());
    } else if (isTypeIRI(triple.predicate())) {
        vocabulary_->addResourceType(triple.subject(), triple.valueAsString());
        // increase frequency in vocabulary
        static std::set<std::string_view> skippedTypes = {
                owl::Class->stringForm(),
                owl::Restriction->stringForm(),
                owl::NamedIndividual->stringForm(),
                owl::AnnotationProperty->stringForm(),
                owl::ObjectProperty->stringForm(),
                owl::DatatypeProperty->stringForm(),
                rdfs::Class->stringForm(),
                rdf::Property->stringForm()
        };
        if (vocabulary_->isDefinedClass(triple.valueAsString()) &&
            !skippedTypes.count(triple.valueAsString())) {
            vocabulary_->increaseFrequency(triple.valueAsString());
        }
        vocabulary_->increaseFrequency(rdf::type->stringForm());
    } else if (isInverseOfIRI(triple.predicate())) {
        auto p = vocabulary_->defineProperty(triple.subject());
        auto q = vocabulary_->defineProperty(triple.valueAsString());
        p->setInverse(q);
        q->setInverse(p);
        vocabulary_->increaseFrequency(owl::inverseOf->stringForm());
    } else if (owl::imports->stringForm() == triple.predicate()) {
        auto resolvedImport = URI::resolve(triple.valueAsString());
        auto importedGraph = DataSource::getNameFromURI(resolvedImport);
        if (triple.graph()) {
            vocabulary_->importHierarchy()->addDirectImport(triple.graph().value(), importedGraph);
        } else {
            KB_WARN("import statement without graph");
        }
    } else if (vocabulary_->isObjectProperty(triple.predicate()) ||
               vocabulary_->isDatatypeProperty(triple.predicate())) {
        // increase frequency of property in vocabulary
        vocabulary_->increaseFrequency(triple.predicate());
    }
}

updateVocabulary() [2/2]

void knowrob::transaction::Insert::updateVocabulary ( const Triple &  triple )

overrideprotectedvirtual

Implements knowrob::transaction::Transaction.

---

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/Transaction.h
• src/storage/Transaction.cpp