TriplesStore.h

#pragma once
 
#include <functional>
 
#include <QList>
#include <QSharedPointer>
 
#include <knowCore/ReturnValue.h>
 
#include "RDFDataset.h"
#include "Transaction.h"
 
class TestTripleStore;
 
namespace kDB::Repository
{
  class TriplesStore : public RDFDataset
  {
    friend class ::TestTripleStore;
    friend class GraphsManager;
    friend class VersionControl::Manager;
    friend class VersionControl::Transaction;
    friend class DatabaseInterface::PostgreSQL::SQLInterface;
    friend class VersionControl::Utils::MetaVersion;
  public:
    enum class Option : quint32
    {
      None          = 0x0,
      Versioning    = 0x1,
      Notifications = 0x2
    };
    Q_DECLARE_FLAGS(Options, Option)
  private:
    struct Definition;
    TriplesStore(const kDB::Repository::Connection& _connection, QSharedPointer<Definition> _definition);
  public:
    TriplesStore();
    TriplesStore(const TriplesStore& _rhs);
    TriplesStore& operator=(const TriplesStore& _rhs);
    ~TriplesStore();
    TriplesStore detach() const;
    QString tablename() const;
    Options options() const;
    template<typename _ObjectType_>
    knowCore::ReturnVoid insert(const knowRDF::Subject& _subject, const knowCore::Uri& _predicateBase, const QString& _predicateSuffix, const _ObjectType_& _object, const Transaction& _transaction = Transaction())
    {
      return insert(_subject, knowCore::Uri(_predicateBase, _predicateSuffix), _object, _transaction);
    }
    template<typename _TUri_>
    requires knowCore::Uris::IsUriDefinition<_TUri_>::value
    knowCore::ReturnVoid insert(const knowRDF::Subject& _subject, const knowCore::Uri& _predicate, const _TUri_& _value, const Transaction& _transaction = Transaction());
    knowCore::ReturnVoid insert(const knowRDF::Subject& _subject, const knowCore::Uri& _predicate, const knowCore::Uri& _value, const Transaction& _transaction = Transaction());
    knowCore::ReturnVoid insert(const knowRDF::Subject& _subject, const knowCore::Uri& _predicate, const knowRDF::Object& _object, const Transaction& _transaction = Transaction());
    knowCore::ReturnVoid insert(const knowRDF::Subject& _subject, const knowCore::Uri& _predicate, const knowCore::Uri& _type, const knowCore::Value& _value, const QString& _lang = QString(), const Transaction& _transaction = Transaction());
    knowCore::ReturnVoid insert(const knowRDF::Subject& _subject, const knowCore::Uri& _predicate, const knowRDF::BlankNode& _value, const Transaction& _transaction = Transaction());
    template<typename _TPredicate_0_, typename _TObject_0_, typename... _TPredicteObjects_>
    knowCore::ReturnVoid insert(const knowRDF::Subject& _subject, const knowCore::Uri& _predicate, const std::tuple<_TPredicate_0_, _TObject_0_, _TPredicteObjects_...>& _objects, const Transaction& _transaction);
    knowCore::ReturnVoid insert(const knowRDF::Triple& _triple, const Transaction& _transaction = Transaction());
    knowCore::ReturnVoid insert(const QList<knowRDF::Triple>& _triple, const Transaction& _transaction = Transaction());
    
    template<typename _TObject_, typename... _TArgs_>
    knowCore::ReturnVoid insert(const Transaction& _transaction,
        const knowRDF::Subject& _subject, const knowCore::Uri& _predicate, const _TObject_& _object,
        const _TArgs_&...);
    template<typename _TObject_, typename... _TArgs_>
    inline knowCore::ReturnVoid insert(
        const knowRDF::Subject& _subject, const knowCore::Uri& _predicate, const _TObject_& _object,
        const knowCore::Uri& _predicate_next, const _TArgs_&... _args);
  private:
    // Thiss functions is only used as part of the end recursion for the variadic insert above
    knowCore::ReturnVoid insert(const Transaction&,
        const knowRDF::Subject&);
  public:
    knowCore::ReturnValue<bool> hasTriple(const knowRDF::Triple& _triple, const Transaction& _transaction = Transaction());
    
    knowCore::ReturnVoid remove(const knowRDF::Subject& _subject, const knowCore::Uri& _predicate, const knowCore::Uri& _value, const Transaction& _transaction = Transaction());
    knowCore::ReturnVoid remove(const knowRDF::Subject& _subject, const knowCore::Uri& _predicate, const knowRDF::Object& _object, const Transaction& _transaction = Transaction());
    knowCore::ReturnVoid remove(const knowRDF::Subject& _subject, const knowCore::Uri& _predicate, const knowCore::Uri& _type, const knowCore::Value& _value, const QString& _lang = QString(), const Transaction& _transaction = Transaction());
    knowCore::ReturnVoid remove(const knowRDF::Subject& _subject, const knowCore::Uri& _predicate, const knowRDF::BlankNode& _value, const Transaction& _transaction = Transaction());
    knowCore::ReturnVoid remove(const knowRDF::Triple& _triple, const Transaction& _transaction = Transaction());
    knowCore::ReturnVoid remove(const QList<knowRDF::Triple>& _triple, const Transaction& _transaction = Transaction());
    
    QList<knowRDF::Triple> triples() const;
    knowCore::ReturnValue<QList<knowRDF::Triple>> triples2() const;
    
    knowRDF::Triple triple(std::size_t _r) const;
    
    std::size_t triplesCount() const;
    QString generateInsertDataQuery(bool _blankNodeAsUri = false) const;
    
    knowCore::ReturnVoid clear(const Transaction& _transaction = Transaction());
    
    knowCore::ReturnVoid enableVersioning();
    knowCore::ReturnVoid disableVersioning();
    
    knowCore::ReturnVoid enableNotifications();
    knowCore::ReturnVoid disableNotifications();
    
    QMetaObject::Connection listen(const QObject *receiver, const char *member, Qt::ConnectionType _type = Qt::AutoConnection);
    QMetaObject::Connection listen(const std::function<void(const QByteArray&)>& _receiver);
    
    QMetaObject::Connection listenOptionsChanged(const QObject *receiver, const char *member, Qt::ConnectionType _type = Qt::AutoConnection);
    QMetaObject::Connection listenOptionsChanged(const std::function<void()>& _receiver);
    
    QMetaObject::Connection listenMetaChanged(const QObject *receiver, const char *member, Qt::ConnectionType _type = Qt::AutoConnection);
    QMetaObject::Connection listenMetaChanged(const std::function<void()>& _receiver);
    
    bool unlisten(QMetaObject::Connection _connection);
    
    VersionControl::Manager* versionControlManager();
    const VersionControl::Manager* versionControlManager() const;
 
    QByteArray contentHash() const;
    QByteArray contentHash(const Transaction& _transaction) const; // TODO merge with previous function
  private:
    struct TSTemporaryTransaction;
    KNOWCORE_D_DECL();
  };
  inline knowCore::ReturnVoid TriplesStore::insert(const Transaction&, const knowRDF::Subject&)
  {
    return kCrvSuccess();
  }
  template<typename _TUri_>
  requires knowCore::Uris::IsUriDefinition<_TUri_>::value
  inline knowCore::ReturnVoid TriplesStore::insert(const knowRDF::Subject& _subject, const knowCore::Uri& _predicate, const _TUri_& _value, const Transaction& _transaction)
  {
    return insert(_subject, _predicate, knowCore::Uri(_value), _transaction);
  }
 
  template<typename _TObject_, typename... _TArgs_>
  inline knowCore::ReturnVoid TriplesStore::insert(const Transaction& _transaction,
      const knowRDF::Subject& _subject, const knowCore::Uri& _predicate, const _TObject_& _object,
      const _TArgs_&... _args)
  {
    KNOWCORE_RETURN_VALUE_TRY_VOID(insert(_subject, _predicate, _object, _transaction));
    return insert(_transaction, _subject, _args...);
  }
  template<typename _TObject_, typename... _TArgs_>
  inline knowCore::ReturnVoid TriplesStore::insert(
      const knowRDF::Subject& _subject, const knowCore::Uri& _predicate, const _TObject_& _object,
      const knowCore::Uri& _predicate_next, const _TArgs_&... _args)
  {
    Transaction t(connection());
    KNOWCORE_RETURN_VALUE_TRY_VOID(insert(t, _subject, knowCore::Uri(_predicate), _object, _predicate_next, _args...));
    return t.commit();
  }
  template<typename _TPredicate_0_, typename _TObject_0_, typename... _TPredicteObjects_>
  knowCore::ReturnVoid TriplesStore::insert(const knowRDF::Subject& _subject, const knowCore::Uri& _predicate, const std::tuple<_TPredicate_0_, _TObject_0_, _TPredicteObjects_...>& _objects, const Transaction& _transaction)
  {
    knowRDF::BlankNode bn;
    KNOWCORE_RETURN_VALUE_TRY_VOID(insert(_subject, _predicate, bn, _transaction));
    using IFT =  knowCore::ReturnVoid (TriplesStore::*)(const Transaction&,
      const knowRDF::Subject&, const knowCore::Uri&, const _TObject_0_&,
      const _TPredicteObjects_&...);
    return std::apply(static_cast<IFT>(&TriplesStore::insert<_TObject_0_, _TPredicteObjects_...>),
      std::tuple_cat(std::make_tuple(this, _transaction, bn), _objects));
  }
 
}
 
Q_DECLARE_OPERATORS_FOR_FLAGS(kDB::Repository::TriplesStore::Options)