1 #ifndef _CONN_IMPL_HPP_
2 #define _CONN_IMPL_HPP_
62 virtual void Connect(
const string& user,
63 const string& password,
71 const string& password,
CRef< CToMultiExHandler > m_multiExH
virtual string GetErrorInfo()
Returns all error messages as a single string.
virtual void Action(const CDbapiEvent &e)
virtual CDB_MultiEx * GetErrorAsEx()
Returns all error messages as a CDB_MultiEx object.
virtual ICursor * GetCursor(const string &name, const string &sql, int batchSize)
Get cursor object.
CDB_Connection * m_connection
virtual ICallableStatement * PrepareCall(const string &proc)
Get callable statement object for stored procedures.
virtual void SetMode(EConnMode mode)
Set connection mode.
virtual void SetDatabase(const string &name)
Set current database.
unique_ptr< CVersionInfo > m_versionInfo
virtual ICursor * CreateCursor(const string &name, const string &sql, int batchSize)
Get cursor object.
virtual void Abort()
Abort connection.
virtual void MsgToEx(bool v)
If enabled, redirects all error messages to CDB_MultiEx object (see below).
virtual ICallableStatement * GetCallableStatement(const string &proc)
Get callable statement object for stored procedures.
virtual IConnection * CloneConnection(EOwnership ownership)
Clone existing connection.
virtual IDataSource * GetDataSource()
Get parent datasource object.
virtual unsigned int GetModeMask()
Get mode mask.
void SetDbName(const string &name, CDB_Connection *conn=0)
virtual IBulkInsert * CreateBulkInsert(const string &table_name)
Create bulk insert object.
virtual void Close()
Close connecti.
virtual IStatement * GetStatement()
Get statement object for regular SQL queries.
CDB_Connection * CloneCDB_Conn()
CConnection * GetAuxConn()
virtual void SetTimeout(size_t nof_secs)
Set connection timeout.
virtual const CVersionInfo & GetVersionInfo() const
virtual void ResetMode(EConnMode mode)
Reset connection mode.
virtual void ForceSingle(bool enable)
Force single connection mode, default false.
virtual IBulkInsert * GetBulkInsert(const string &table_name)
Create bulk insert object.
virtual IStatement * CreateStatement()
Get statement object for regular SQL queries.
CConnection(CDataSource *ds, EOwnership ownership)
virtual void ConnectValidated(IConnValidator &validator, const string &user, const string &password, const string &server, const string &database=kEmptyStr)
Connect to a database using connect validator.
virtual string GetDatabase()
Get current database.
virtual CDB_Connection * GetCDB_Connection()
Returns the internal driver connection object.
virtual void SetCancelTimeout(size_t nof_secs)
Set timeout for command cancellation and connection closing.
virtual bool IsAlive()
Check if the connection is alive.
virtual void Connect(const string &user, const string &password, const string &server, const string &database=kEmptyStr)
Connect to a database.
void x_SendXactAbort(void)
class CToMultiExHandler * GetHandler()
Defines the database API innterfaces for a variety of DBMS.
static CS_CONNECTION * conn
static const char table_name[]
EConnMode
Which connection mode.
#define END_NCBI_SCOPE
End previously defined NCBI scope.
#define BEGIN_NCBI_SCOPE
Define ncbi namespace.
enum ENcbiOwnership EOwnership
Ownership relations between objects.
use only n Cassandra database for the lookups</td > n</tr > n< tr > n< td > yes</td > n< td > do not use tables BIOSEQ_INFO and BLOB_PROP in the Cassandra database