SQLInterface_p.h

#include <QList>
#include <QPair>
#include <QString>
#include <QSharedPointer>
 
#include <kDB/Repository/TriplesStore.h>
 
class QVariant;
 
namespace kDB::Repository::DatabaseInterface::PostgreSQL
{
  class SQLInterface
  {
    SQLInterface(const SQLInterface& _rhs);
    SQLInterface& operator=(const SQLInterface& _rhs);
    SQLInterface();
    ~SQLInterface();
  public:
    
    enum LockMode
    {
      AccessShare, RowShare, RowExclusive, ShareUpdateExclusive, Share, ShareRowExclusive, Exclusive, AccessExclusive
    };
    static knowCore::ReturnVoid lock(const Transaction& _transaction, const QString& _tablename, LockMode _lockMode);
    static knowCore::ReturnVoid lockTriplesStore(const Transaction& _transaction, const QString& _tablename, bool _lock_versioning);
    
    static QString subjectString(const knowRDF::Subject& _subject);
    
    static knowCore::ReturnVoid dropView(const QueryConnectionInfo& _connection_info, const QString& _name);
    
    static QString viewTableName(const Connection& _connection, const QString& _name);
    
    static QString persistentDatasetsUnionTableName(const Connection& _connection, const QString& _name);
    static knowCore::ReturnVoid updateUnionView(const QueryConnectionInfo& _connection_info, bool _temporary, const QString& _name, const QList<RDFDataset>& _documents);
    static knowCore::ReturnVoid addToUnion(const QueryConnectionInfo& _connection_info, const knowCore::Uri& _union_name, const knowCore::Uri& _dataset_name);
    static knowCore::ReturnVoid removeFromUnion(const QueryConnectionInfo& _connection_info, const knowCore::Uri& _union_name, const knowCore::Uri& _dataset_name);
    static knowCore::ReturnVoid clearUnion(const QueryConnectionInfo& _connection_info, const knowCore::Uri& _union_name);
    static QHash<QString, QStringList> getUnions(const QueryConnectionInfo& _connection_info);
    
    static knowCore::ReturnVoid setDefinition(const QueryConnectionInfo& _connection_info, const RDFView::ViewDefinition& _definition);
    static knowCore::ReturnVoid removeViewDefinition(const QueryConnectionInfo& _connection_info, const knowCore::Uri& _name);
    static QList<RDFView::ViewDefinition> getDefinitions(const QueryConnectionInfo& _connection_info);
    
    static knowCore::ReturnValue<QString> createTriplesStore(const Transaction& _transaction, const knowCore::Uri& _name);
    static knowCore::ReturnVoid removeTriplesStore(const Transaction& _transaction, const knowCore::Uri& _name);
    static knowCore::ReturnVoid createIndex(const Transaction& _transaction, const TriplesStore& _store, const QString& _field);
    
    static knowCore::ReturnVoid enableNotifications(const QueryConnectionInfo& _connection_info, const TriplesStore& _store);
    static knowCore::ReturnVoid disableNotifications(const QueryConnectionInfo& _connection_info, const TriplesStore& _store);
    static QString notificationsChannel(const TriplesStore& _store);
    
    static knowCore::ReturnVoid enableVersioning(const Transaction& _transaction, const TriplesStore& _store);
    static knowCore::ReturnVoid disableVersioning(const QueryConnectionInfo& _connection_info, const TriplesStore& _store);
    
    static knowCore::ReturnVoid startListeningChanges(const Transaction& _transaction, const TriplesStore& _store);
    static knowCore::ReturnVoid stopListeningChanges(const Transaction& _transaction, const TriplesStore& _store);
    static QList<std::tuple<QString, knowRDF::Triple>> retrieveChanges(const Transaction& _transaction, const TriplesStore& _store);
    
    static QByteArray computeContentHash(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name);
    static knowCore::ReturnValue<int> createRevision(const Transaction& _transaction, const QString& _triples_store_table_name, const QByteArray& _revision_hash, const QByteArray& _content_hash, int _historicity , int _tags, int _distance_to_root);
    static knowCore::ReturnVoid removeRevision(const Transaction& _transaction, const VersionControl::Revision& _revision);
    static knowCore::ReturnVoid recordDelta(const Transaction& _transaction, const QString& _triples_store_table_name, int _parent, int _child, const QByteArray& _hash, const QByteArray& _delta);
    static knowCore::ReturnVoid recordDeltaSignature(const Transaction& _transaction, const QString& _triples_store_table_name, int _parent, int _child, const QByteArray& _author, const knowCore::Timestamp& _timestamp, const QByteArray& _signature);
    static knowCore::ReturnVoid setRevisionHash(const Transaction& _transaction, const QString& _triples_store_table_name, int _revision, const QByteArray& _hash, const QByteArray& _content_hash);
    static knowCore::ReturnVoid setRevisionTags(const Transaction& _transaction, const QString& _triples_store_table_name, const VersionControl::Revision& _revision, int _tags);
    static knowCore::ReturnVoid notifyNewRevision(const Transaction& _transaction, const QString& _triples_store_table_name, const QByteArray& _hash);
    static knowCore::ReturnVoid notifyRevisionTagsChanged(const Transaction& _transaction, const QString& _triples_store_table_name, const QByteArray& _hash);
    
    static QList<VersionControl::Delta> deltas(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name, int _revisionId);
    static knowCore::ReturnValue<VersionControl::Delta> delta(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name, int _parent, int _child);
    static knowCore::ReturnValue<VersionControl::Delta> delta(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name, const VersionControl::Revision& _parent, const VersionControl::Revision& _child);
    static knowCore::ReturnValue<bool> hasDelta(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name, const QByteArray& _parent, const QByteArray& _child);
    static knowCore::ReturnValue<bool> hasDelta(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name, int _parent, int _child);
    
    static knowCore::ReturnValue<QList<VersionControl::Signature>> deltaSignatures(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name, int _parent, int _child);
 
    static knowCore::ReturnVoid setUnitConversionFactors(const QueryConnectionInfo& _connection_info);
 
  private:
    static QList<VersionControl::Revision> queryToRevisions(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name, knowDBC::Query& _query);
  public:
    static QList<VersionControl::Revision> revisions(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name);
    static QList<VersionControl::Revision> revisionChildren(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name, int _revisionId);
    static QList<VersionControl::Revision> heads(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name);
    static knowCore::ReturnValue<int> revisionId(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name, const QByteArray& _hash);
    static knowCore::ReturnValue<kDB::Repository::VersionControl::Revision> revision(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name, const QByteArray& _hash);
    static knowCore::ReturnValue<kDB::Repository::VersionControl::Revision> revision(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name, int _revisionId);
    static knowCore::ReturnValue<kDB::Repository::VersionControl::Revision> revision(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name, const QByteArray& _content_hash, int _minimum_historicity);
    static knowCore::ReturnValue<bool> hasRevision(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name, const QByteArray& _hash);
    
    static QList<qint32> forwardRevisionPath(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name, const QByteArray&  _source_hash, const QByteArray& _destination_hash);
    static QList<qint32> forwardRevisionPath(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name, int  _source_id, int _destination_id);
    static QPair<QList<qint32>, QList<qint32>> revisionPath(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name, const QByteArray&  _source_hash, const QByteArray& _destination_hash);
    static knowCore::ReturnValue<QList<QList<qint32>>> revisionPath(const QueryConnectionInfo& _connection_info, const QString& _triples_store_table_name, const QList<QByteArray>&  _revisions);
 
    static knowCore::ReturnValue<knowCore::Value> parseMeta(const QJsonValue& _value);
    static knowCore::ReturnValue<knowCore::Value> getMeta(const QueryConnectionInfo& _connection_info, const QString& _store, const QStringList& _path);
    static knowCore::ReturnVoid setMeta(const QueryConnectionInfo& _connection_info, const QString& _store, const QStringList& _path, const knowCore::Value& _value);
 
    static knowCore::ReturnVoid dropMeta(const QueryConnectionInfo& _connection_info, const QString& _store, const QStringList& _path);
    
    static QList<knowCore::Uri> getGraphUris(const Transaction& _transaction, const QString& _tablename, const QString& _field);
    static knowCore::ReturnVoid removeTriples(const Transaction& _transaction, TriplesStore* _store, const knowCore::Uri& _store_uri);
    static knowCore::ReturnVoid insertTriples(const Transaction& _transaction, TriplesStore* _store, const knowCore::Uri& _store_uri);
    
    static knowRDF::Triple getTriple(const Connection& _connection, const knowDBC::Result& _result, int _tuple, int _subject, int _predicate, int _object, bool _blank_as_uri);
    
    static knowCore::ReturnVoid insertOrRemoveTriples(bool _insert, const Transaction& _connection_info, const QList<knowRDF::Triple>& _triples, const QString& _table_to_model);
  private:
    bool insertValue(const QueryConnectionInfo& _connection_info, const QString& _tablename, const QVariant& _variant);
  };
}