Transaction.h

Go to the documentation of this file.

/*
 * This file is part of KnowRob, please consult
 * https://github.com/knowrob/knowrob for license details.
 */
 
#ifndef KNOWROB_TRANSACTION_H
#define KNOWROB_TRANSACTION_H
 
#include "memory"
#include "knowrob/ThreadPool.h"
#include "knowrob/storage/Storage.h"
#include "knowrob/semweb/TripleContainer.h"
#include "QueryableStorage.h"
#include "knowrob/storage/ReificationContainer.h"
 
namespace knowrob::transaction {
    class Transaction {
    public:
        Transaction(const std::shared_ptr<QueryableStorage> &queryable,
                    const std::shared_ptr<Vocabulary> &vocabulary,
                    bool isRemoval)
                : vocabulary_(vocabulary),
                  queryable_(queryable),
                  isRemoval_(isRemoval) {}
 
        virtual ~Transaction() = default;
 
        void addBackend(const std::shared_ptr<NamedBackend> &backend) { backends_.push_back(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:
        std::shared_ptr<Vocabulary> vocabulary_;
        std::shared_ptr<QueryableStorage> queryable_;
        std::vector<std::shared_ptr<NamedBackend>> backends_;
        bool isRemoval_;
 
        bool commitProtected(const TripleContainerPtr &triple, const StoragePtr &backend);
 
        virtual bool doCommit(const Triple &triple, const StoragePtr &backend) = 0;
 
        virtual bool doCommit(const TripleContainerPtr &triples, const StoragePtr &backend) = 0;
 
        virtual void updateVocabulary(const Triple &triple) = 0;
 
        static std::shared_ptr<ThreadPool::Runner> createTripleWorker(
                const TripleContainerPtr &triples,
                const std::function<void(const TriplePtr &)> &fn);
 
        IRIAtomPtr queryReifiedName(const Triple &triple);
    };
 
    class Insert : public Transaction {
    public:
        Insert(const std::shared_ptr<QueryableStorage> &queryable, const std::shared_ptr<Vocabulary> &vocabulary)
                : Transaction(queryable, vocabulary, false) {}
 
    protected:
        bool doCommit(const Triple &triple, const StoragePtr &backend) override;
 
        bool doCommit(const TripleContainerPtr &triples, const StoragePtr &backend) override;
 
        void updateVocabulary(const Triple &triple) override;
    };
 
    class Remove : public Transaction {
    public:
        Remove(const std::shared_ptr<QueryableStorage> &queryable, const std::shared_ptr<Vocabulary> &vocabulary)
                : Transaction(queryable, vocabulary, true) {}
 
    protected:
        bool doCommit(const Triple &triple, const StoragePtr &backend) override;
 
        bool doCommit(const TripleContainerPtr &triples, const StoragePtr &backend) override;
 
        void updateVocabulary(const Triple &triple) override;
    };
}
 
#endif //KNOWROB_TRANSACTION_H