kDB: Knowledge DataBase
Loading...
Searching...
No Matches
kDB::Repository::Connection Class Reference

Classes

struct  Private
 

Public Member Functions

template<typename _T_ >
requires std::same_as<_T_, Connection>
 Connection (const knowCore::WeakReference< _T_ > &_d)
 
 Connection (const Connection &_rhs)
 
Connectionoperator= (const Connection &_rhs)
 
bool operator== (const Connection &_rhs) const
 
bool operator!= (const Connection &_rhs) const
 
bool isValid () const
 
void disconnect ()
 
knowCore::ReturnVoid connect (bool _initialise_database=false)
 
bool isConnected () const
 
GraphsManagergraphsManager () const
 
NotificationsManagernotificationsManager ()
 
SPARQLFunctionsManagersparqlFunctionsManager () const
 
knowCore::ReturnVoid executeQueryFromFile (const QString &_fileName) const
 
knowCore::ReturnVoid executeQuery (const QString &_query) const
 
TriplesStore defaultTripleStore () const
 
TriplesStore infoTripleStore () const
 
QUuid serverUuid () const
 
knowCore::Uri serverUri () const
 
Cyqlops::Crypto::RSAAlgorithm rsaAlgorithm () const
 
quint64 oid (const QString &_type) const
 
knowCore::ReturnVoid enableExtension (const QString &_extension)
 
bool isExtensionEnabled (const QString &_extension) const
 
QUuid connectionUuid () const
 
QUuid executeDisconnection (const std::function< void()> &_function) const
 
void removeExecuteDisconnection (const QUuid &_uuid) const
 
QUuid executeConnection (const std::function< void(const Connection &)> &_function) const
 
void removeExecuteConnection (const QUuid &_uuid) const
 
knowDBC::Query createSQLQuery (const QString &_query=QString(), const knowCore::ValueHash &_bindings=knowCore::ValueHash(), const knowCore::ValueHash &_options=knowCore::ValueHash()) const
 
knowDBC::Query createSPARQLQuery (const RDFEnvironment &_environment=RDFEnvironment(), const QString &_query=QString(), const knowCore::ValueHash &_bindings=knowCore::ValueHash(), const knowCore::ValueHash &_options=knowCore::ValueHash()) const
 
template<typename _T_ >
_T_ * extensionObject () const
 
template<typename _T_ >
void createExtensionObject ()
 
krQuery::EnginekrQueryEngine () const
 

Static Public Member Functions

static Connection create (const QString &_host, int _port, const QString &_database="kDB")
 

Friends

template<typename _T_ >
class knowCore::WeakReference
 
class ConnectionHandle
 
class GraphsManager
 
class QueryConnectionInfo
 
class SPARQLQuery
 
class SPARQLFunctionsManager
 
class Transaction
 
class TriplesStore
 
class TriplesView
 
class DatabaseInterface::PostgreSQL::BinaryMarshalsRegistry
 
class DatabaseInterface::PostgreSQL::RDFValueBinaryMarshal
 
class DatabaseInterface::PostgreSQL::RDFTermBinaryMarshal
 
class DatabaseInterface::PostgreSQL::SQLCopyData
 
class DatabaseInterface::PostgreSQL::SQLInterface
 
class DatabaseInterface::PostgreSQL::SQLQueryExecutor
 
class DatabaseInterface::PostgreSQL::SQLResult
 
class SPARQLExecution::QueryExecutorVisitor
 
class SPARQLExecution::SPARQLAlgebraToPostgresSQL
 
struct SPARQLExecution::SPARQLAlgebraToPostgresSQLVisitor
 

Member Function Documentation

◆ connect()

knowCore::ReturnVoid Connection::connect ( bool _initialise_database = false)

Attempt to connect to the server

Returns
false if connection fails, or if it is already connected

◆ connectionUuid()

QUuid Connection::connectionUuid ( ) const
Returns
the UUID to the connection

◆ createExtensionObject()

template<typename _T_ >
void kDB::Repository::Connection::createExtensionObject ( )

Register an extension object with this connection. Connection take ownership of the object. The object is deleted upon disconnection and should hold a knowCore::WeakReference<Connection> to avoid circular reference.

This function is intended to be use by an initaĺisation function of an extension.

◆ createSPARQLQuery()

knowDBC::Query Connection::createSPARQLQuery ( const RDFEnvironment & _environment = RDFEnvironment(),
const QString & _query = QString(),
const knowCore::ValueHash & _bindings = knowCore::ValueHash(),
const knowCore::ValueHash & _options = knowCore::ValueHash() ) const

Create an SPARQL query for this connection

◆ createSQLQuery()

knowDBC::Query Connection::createSQLQuery ( const QString & _query = QString(),
const knowCore::ValueHash & _bindings = knowCore::ValueHash(),
const knowCore::ValueHash & _options = knowCore::ValueHash() ) const

Create an SQL query for this connection

◆ disconnect()

void Connection::disconnect ( )

Disconnect this connection from the server (this propagage to all the copy of this object!)

◆ enableExtension()

knowCore::ReturnVoid Connection::enableExtension ( const QString & _extension)

Enable an extension

Returns
true if extension is successfully enabled

◆ executeConnection()

QUuid Connection::executeConnection ( const std::function< void(const Connection &)> & _function) const

Called a function after connection is completed.

◆ executeDisconnection()

QUuid Connection::executeDisconnection ( const std::function< void()> & _function) const

Called a function when disconnected (warning, cannot use connection as disconnection can occurs during deletion, and should not hold a reference to connection to avoid leaks).

◆ extensionObject()

template<typename _T_ >
_T_ * kDB::Repository::Connection::extensionObject ( ) const
Returns
the extension object associated with this connection

◆ isConnected()

bool Connection::isConnected ( ) const
Returns
true if connected to the server

◆ isExtensionEnabled()

bool Connection::isExtensionEnabled ( const QString & _extension) const

Enable an extension

Returns
true if an extension is enabled

◆ isValid()

bool Connection::isValid ( ) const
Returns
true if this is a valid connection (ie created with create for instance Connection().isValid() return false)

◆ krQueryEngine()

krQuery::Engine * Connection::krQueryEngine ( ) const
Returns
the query engine associated with this connection.

◆ oid()

quint64 Connection::oid ( const QString & _type) const
Returns
the postgresql Oid type associated with the _type

◆ rsaAlgorithm()

Cyqlops::Crypto::RSAAlgorithm Connection::rsaAlgorithm ( ) const

This function gives access to the RSA key used by the server for signing.

◆ serverUri()

knowCore::Uri Connection::serverUri ( ) const
Returns
a URI uniquely identifying this server (based on the UUID)

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