kDB::Repository::DatabaseInterface::PostgreSQL::SQLInterface Class Reference

Public Types
enum	LockMode {   AccessShare , RowShare , RowExclusive , ShareUpdateExclusive ,   Share , ShareRowExclusive , Exclusive , AccessExclusive }

Static Public Member Functions
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)
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)

Member Function Documentation

computeContentHash()

QByteArray SQLInterface::computeContentHash ( const QueryConnectionInfo & _connection_info, const QString & _triples_store_table_name )

static

Compute the hash of a triple store.

createRevision()

knowCore::ReturnValue< int > SQLInterface::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

Create a new revision

Parameters

revisionHash	is the combination of the content hash with the historicity
historicity	is defined as the number of non-merge delta on shortest path to root

deltaSignatures()

knowCore::ReturnValue< QList< kDB::Repository::VersionControl::Signature > > SQLInterface::deltaSignatures ( const QueryConnectionInfo & _connection_info, const QString & _triples_store_table_name, int _parent, int _child )

static

Returns

the list of signatures for a given delta

insertOrRemoveTriples()

knowCore::ReturnVoid SQLInterface::insertOrRemoveTriples ( bool _insert, const Transaction & _connection_info, const QList< knowRDF::Triple > & _triples, const QString & _table_to_model )

static

Create a temporary table with a list of triples (used for mass insertion/deletion).

Parameters

_table_to_model

the name of the table whose column to model

notifyNewRevision()

knowCore::ReturnVoid SQLInterface::notifyNewRevision ( const Transaction & _transaction, const QString & _triples_store_table_name, const QByteArray & _hash )

static

Send a notification through postgresql that a new revision is available

notifyRevisionTagsChanged()

knowCore::ReturnVoid SQLInterface::notifyRevisionTagsChanged ( const Transaction & _transaction, const QString & _triples_store_table_name, const QByteArray & _hash )

static

Send a notification through postgresql that the tags have been changed in a revision

removeRevision()

knowCore::ReturnVoid SQLInterface::removeRevision ( const Transaction & _transaction, const VersionControl::Revision & _revision )

static

Remove revision (and associated deltas) from the database, no check is made if this make some revisions unaccessible

revisionChildren()

QList< kDB::Repository::VersionControl::Revision > SQLInterface::revisionChildren ( const QueryConnectionInfo & _connection_info, const QString & _triples_store_table_name, int _revisionId )

static

Returns

the list of children for a given revision.

revisionId()

knowCore::ReturnValue< int > SQLInterface::revisionId ( const QueryConnectionInfo & _connection_info, const QString & _triples_store_table_name, const QByteArray & _hash )

static

Returns

the revision id for the given _hash

---

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

• kdb/kDB/Repository/DatabaseInterface/PostgreSQL/SQLInterface_p.h
• kdb/kDB/Repository/DatabaseInterface/PostgreSQL/SQLInterface.cpp