Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from http://www.ncbi.nlm.nih.gov/IEB/ToolBox/CPP_DOC/doxyhtml/python__ncbi__dbapi_8cpp_source.html below:

NCBI C++ ToolKit: src/dbapi/lang_bind/python/python_ncbi_dbapi.cpp Source File

NCBI_PACKAGE_VERSION

PyObject*

(PyObject *

, PyObject *args);

(

) = 0;

(

);

: m_ResType(other.GetResultType())

, m_ColumsNum(other.GetTotalColumns())

(other.

()) {

TRecordSet::reference record =

.back();

(

col = 1; col <=

; ++col) {

(

);

(

)

;

(

)

;

(

.HasMoreResults()) {

(

.HasRows()) {

unique_ptr<IResultSet> rs(

.GetResultSet());

: m_UserFmt(user_fmt)

string::size_type pos = 0;

string::size_type prev_pos = pos;

((pos =

.find(

, pos)) != string::npos) {

(pos != string::npos) {

tmp_stmt +=

.substr(prev_pos, pos - prev_pos);

string::size_type pos = 0;

string::size_type prev_pos = pos;

((pos =

.find(

, pos)) != string::npos) {

(pos != string::npos) {

tmp_stmt +=

.substr(prev_pos, pos - prev_pos);

string::size_type pos = 0;

string::size_type prev_pos = pos;

(pos != string::npos) {

tmp_stmt +=

.substr(prev_pos, pos - prev_pos);

prev_pos = pos + param_len;

string::size_type pos = 0;

string::size_type prev_pos = pos;

(pos != string::npos) {

tmp_stmt +=

.substr(prev_pos, pos - prev_pos);

prev_pos = pos + param_len;

string::size_type pos = 0;

string::size_type prev_pos = pos;

(pos != string::npos) {

param_name =

.substr(pos + 1, param_len - 1);

tmp_stmt +=

.substr(prev_pos, pos - prev_pos);

name_map_t::iterator it = name2num.find(param_name);

(it == name2num.end()) {

it = name2num.insert(

tmp_stmt += it->second;

prev_pos = pos + param_len;

string::size_type pos = 0;

string::size_type prev_pos = pos;

(pos != string::npos) {

param_name =

.substr(pos + 1, param_len - 1);

tmp_stmt +=

.substr(prev_pos, pos - prev_pos);

tmp_stmt +=

+ param_name;

prev_pos = pos + param_len;

string::size_type pos = 0;

string::size_type prev_pos = pos;

(pos != string::npos) {

tmp_stmt +=

.substr(prev_pos, pos - prev_pos);

prev_pos = pos + param_len;

string::size_type pos = 0;

string::size_type prev_pos = pos;

(pos != string::npos) {

param_name =

.substr(pos + 1, param_len - 1);

tmp_stmt +=

.substr(prev_pos, pos - prev_pos);

name_map_t::iterator it = name2num.find(param_name);

(it == name2num.end()) {

it = name2num.insert(

tmp_stmt += it->second;

prev_pos = pos + param_len;

string::size_type pos = 0;

string::size_type prev_pos = pos;

(pos != string::npos) {

param_name =

.substr(pos + 1, param_len - 1);

tmp_stmt +=

.substr(prev_pos, pos - prev_pos);

tmp_stmt +=

+ param_name;

prev_pos = pos + param_len;

err =

;

err +=

;

string::size_type

,

string::size_type pos = 0;

* num_characters =

;

((pos != string::npos) && (pos + 1 != string::npos)) {

string::size_type tmp_pos = 0;

tmp_pos =

.find_first_not_of(num_characters, pos + 1);

(tmp_pos != string::npos) {

param_len = tmp_pos - pos;

}

(

.find_first_of(num_characters, pos + 1) == pos + 1) {

param_len =

.size() - pos;

string::size_type

,

string::size_type pos = 0;

* sep_characters =

;

((pos != string::npos) && (pos + 1 != string::npos)) {

string::size_type tmp_pos = 0;

tmp_pos =

.find_first_of(sep_characters, pos + 1);

(tmp_pos != string::npos) {

param_len = tmp_pos - pos;

}

((

[pos + 1] >=

&&

[pos + 1] <=

) ||

(

[pos + 1] >=

&&

[pos + 1] <=

)

param_len =

.size() - pos;

string::size_type

,

string::size_type pos = 0;

* sep_characters =

;

((pos != string::npos) && (pos + 1 != string::npos)) {

string::size_type tmp_pos = 0;

tmp_pos =

.find_first_of(sep_characters, pos + 1);

(tmp_pos != string::npos) {

param_len = tmp_pos - pos;

}

((

[pos + 1] >=

&&

[pos + 1] <=

) ||

(

[pos + 1] >=

&&

[pos + 1] <=

)

param_len =

.size() - pos;

struct DataSourceDeleter

static void Delete(ncbi::IDataSource* const object)

CDriverManager::DeleteDs( object );

class CDataSourcePool

CDataSourcePool(void);

~CDataSourcePool(void);

static CDataSourcePool& GetInstance(void);

IDataSource& GetDataSource(

const string& driver_name,

const TPluginManagerParamTree* const params = NULL);

typedef CPluginManager<I_DriverContext> TContextManager;

typedef CPluginManagerGetter<I_DriverContext> TContextManagerStore;

typedef map<string, AutoPtr<IDataSource, DataSourceDeleter> > TDSMap;

CRef<TContextManager> m_ContextManager;

TDSMap m_DataSourceMap;

CDataSourcePool::CDataSourcePool(void)

m_ContextManager.Reset( TContextManagerStore::Get() );

_ASSERT( m_ContextManager );

#if defined(NCBI_OS_MSWIN)

// Add an additional search path ...

CDataSourcePool::~CDataSourcePool(void)

DataSourceCleanup(void* ptr)

CDriverManager::DeleteDs( static_cast<ncbi::IDataSource *const>(ptr) );

CDataSourcePool::GetInstance(void)

static CSafeStatic<CDataSourcePool> ds_pool;

CDataSourcePool::GetDataSource(

const string& driver_name,

const TPluginManagerParamTree* const params)

TDSMap::const_iterator citer = m_DataSourceMap.find( driver_name );

if ( citer != m_DataSourceMap.end() ) {

return *citer->second;

// Build a new context ...

I_DriverContext* drv = NULL;

drv = m_ContextManager->CreateInstance(

NCBI_INTERFACE_VERSION(I_DriverContext),

catch( const CPluginManagerException& e ) {

throw CDatabaseError( e.what() );

catch ( const exception& e ) {

throw CDatabaseError( driver_name + " is not available :: " + e.what() );

throw CDatabaseError( driver_name + " was unable to load due an unknown error" );

IDataSource* ds = CDriverManager::CreateDs( drv );

m_DataSourceMap[driver_name] = ds;

buff_size = 1024;

buff[buff_size];

* module_name =

;

MEMORY_BASIC_INFORMATION mbi;

( cur_size = GetModuleFileNameA( mh, buff, buff_size ) ) {

( cur_size < buff_size ) {

(::dladdr(method_ptr, &dli) != 0) {

NCBI_NORETURN

(it != sc_SybaseErrCodes.end()) {

(dbe->GetErrCode()) {

(it != sc_SybaseErrCodes.end()) {

& driver_name,

& db_type,

& server_name,

& db_name,

& user_name,

& user_pswd,

support_standard_interface,

: m_DefParams(server_name, user_name, user_pswd)

, m_Params(m_DefParams)

, m_DefTransaction(

)

db_type_uc = db_type;

( db_type_uc ==

|| db_type_uc ==

) {

}

( db_type_uc ==

) {

}

( db_type_uc ==

||

db_type_uc ==

||

db_type_uc ==

)

( PyDict_Next(extra_params, &

, &

, &

) ) {

(*citer)->close(args);

: m_Transaction(trans)

, m_PoolSize(

)

(

);

: m_Transaction( trans )

, m_NumOfActive( 0 )

, m_Started(

)

, m_TransType( trans_type )

(

);

: m_ParentConnection(

)

, m_SelectConnPool( this )

, m_ConnectionMode( conn_mode )

( citer = tmp_CursorList.

(); citer != cend; ++citer ) {

(*citer)->CloseInternal();

string::size_type pos =

.find_first_not_of(

);

(pos != string::npos)

string::size_type pos_end =

.find_first_of(

, pos);

(pos_end == string::npos)

pos_end =

.size();

output_clause_possible =

;

output_clause_possible =

;

output_clause_possible =

;

output_clause_possible =

;

output_clause_possible =

;

&& output_clause_possible) {

(pos + 7 <

.size()

: m_ParentTransaction( trans )

, m_Executed(

)

, m_ResultStatus( 0 )

, m_ResultStatusAvailable(

)

, m_UserHandler(

)

: m_ParentTransaction( trans )

, m_Executed(

)

, m_ResultStatus( 0 )

, m_ResultStatusAvailable(

)

, m_UserHandler(

)

(

->HasMoreResults() ) {

(

->HasRows() ) {

->GetParentConn()->GetCDB_Connection()->PushMsgHandler(

);

->ClearParamList();

param_name = name;

( param_name.size() > 0) {

( param_name[0] !=

) {

param_name =

+ param_name;

->SetParam(

,

(index) );

(

bad_cast&) {

(

);

(

exception&) {

(

);

->GetRowCount();

(

);

(

);

(

);

(

->HasMoreResults() ) {

(

->HasRows() ) {

=

->GetTotalColumns();

(

= 1;

<=

; ++

) {

(

->GetType(

)) {

descr.

(col_list);

: m_ParentTransaction( trans )

, m_Executed(

)

, m_ResultStatus( 0 )

, m_ResultStatusAvailable(

)

, m_UserHandler(

)

: m_ParentTransaction( trans )

, m_Executed(

)

, m_ResultStatus( 0 )

, m_ResultStatusAvailable(

)

, m_UserHandler(

)

->GetParentConn()->GetCDB_Connection()->PushMsgHandler(

);

param_name = name;

( param_name.size() > 0) {

( param_name[0] !=

) {

param_name =

+ param_name;

output_param =

;

(

.IsNull()) {

->SetOutputParam( temp_val, param_name );

output_param =

;

ind =

(index);

output_param =

;

(

.IsNull()) {

->SetOutputParam( temp_val, ind );

output_param =

;

(cache_results) {

(

bad_cast&) {

(

);

(

exception&) {

(

);

->GetRowCount();

(

);

(

);

(

);

->GetReturnStatus();

(

);

(

);

(

.IsNull() ) {

(

.GetType() ) {

( !

.IsNull() ) {

(PyDateTime_FromTimestamp(args.

()));

lob_size =

.GetBlobSize();

tmp_str.resize(lob_size);

.Read( (

*)tmp_str.data(), lob_size );

(

= 0;

< col_num; ++

) {

(

= 0;

< col_num; ++

) {

unique_ptr<pythonpp::CCalable> error_handler;

}

(

!=

) {

(error_handler.get() !=

) {

PyErr_Fetch(&

, &

, &traceback);

PyObject_CallObject(error_handler->Get(), args.

());

Py_XDECREF(

);

Py_XDECREF(traceback);

: m_PythonConnection( &trans->GetParentConnection() )

, m_PythonTransaction( trans )

, m_ParentTransaction( trans )

, m_UserHandler( this, m_PythonConnection )

, m_StmtHelper( trans )

, m_CallableStmtHelper( trans )

, m_ErrorHandler( m_PythonConnection.GetAttr(

) )

, m_AllDataFetched(

)

, m_AllSetsFetched(

)

( trans ==

) {

args_size = args.

();

vector<size_t> out_params;

( args_size == 0 ) {

(

);

}

( args_size > 0 ) {

(

);

( args_size > 1 ) {

out_params.push_back(0);

(args_size > 1 && out_params.size() != 0) {

output_args.

(args[1]);

( rs.

() ) {

(

= 0;

< col_num; ++

) {

param_name = md.

(

+ 1);

PyObject * it = PyDict_GetItemString(kwargs.

(),

);

(it ==

) {

}

(PyObject_IsTrue(it)) {

args_size = args.

();

( args_size == 0 ) {

(

);

}

( args_size > 0 ) {

(

);

( args_size > 1 ) {

( PyDict_Next(dict, &

, &

, &

) ) {

sz = seq.

();

(

= 0;

< sz; ++

) {

output_param =

;

( PyDict_Next(dict, &

, &

, &

) ) {

vector<size_t>* out_params)

sz = seq.

();

(

= 0;

< sz; ++

) {

output_param =

;

out_params->push_back(

);

tzinfo = PyDateTime_DATE_GET_TZINFO(dt.

());

tzinfo = dt.

(

);

( !PyTZInfo_Check(tzinfo.

()) ) {

days = PyDateTime_DELTA_GET_DAYS(

.Get()),

seconds = PyDateTime_DELTA_GET_SECONDS(

.Get());

days * 24 * 60 + seconds / 60;

std_str(python_str);

( !

.IsNull() ) {

args_size = args.

();

( args_size == 0 ) {

(

);

}

( args_size > 0 ) {

(

);

( args_size > 1 ) {

( citer = params.

(); citer != cend; ++citer ) {

(

);

(

);

( rs.

() ) {

( rs.

() ) {

( args.

() > 0 ) {

(

);

( ;

< array_size && rs.

(); ++

) {

(

< array_size ) {

( ;

< array_size && rs.

(); ++

) {

(

< array_size ) {

( rs.

() ) {

( rs.

() ) {

(

);

(

);

: m_PythonCursor(cursor),

(; cur_exception; cur_exception = cur_exception->

()) {

srv_msg = cur_exception->

();

PyObject *exc_ob =

;

PyObject *errno_ob =

;

PyObject *msg_ob =

;

errno_ob = PyLong_FromLong(db_errno);

errno_ob = PyInt_FromLong(db_errno);

(errno_ob ==

) {

msg_ob = PyUnicode_FromStringAndSize(db_msg.data(), db_msg.size());

msg_ob = PyString_FromStringAndSize(db_msg.data(), db_msg.size());

(errno_ob ==

) {

Py_DECREF(errno_ob);

exc_ob = PyObject_CallFunction(err_type, (

*)

, (

*)

.c_str());

(exc_ob ==

)

Py_DECREF(errno_ob);

(PyObject_SetAttrString(exc_ob, (

*)

, errno_ob) == -1)

Py_DECREF(errno_ob);

Py_DECREF(errno_ob);

(PyObject_SetAttrString(exc_ob, (

*)

, msg_ob) == -1)

PyErr_SetObject(err_type, exc_ob);

// Future development ...

class CModuleDBAPI : public pythonpp::CExtModule<CModuleDBAPI>

CModuleDBAPI(const char* name, const char* descr = 0)

: pythonpp::CExtModule<CModuleDBAPI>(name, descr)

PrepareForPython(this);

// connect(driver_name, db_type, db_name, user_name, user_pswd)

pythonpp::CObject connect(const pythonpp::CTuple& args);

pythonpp::CObject Binary(const pythonpp::CTuple& args);

pythonpp::CObject TimestampFromTicks(const pythonpp::CTuple& args);

pythonpp::CObject TimeFromTicks(const pythonpp::CTuple& args);

pythonpp::CObject DateFromTicks(const pythonpp::CTuple& args);

pythonpp::CObject Timestamp(const pythonpp::CTuple& args);

pythonpp::CObject Time(const pythonpp::CTuple& args);

pythonpp::CObject Date(const pythonpp::CTuple& args);

CModuleDBAPI::connect(const pythonpp::CTuple& args)

const pythonpp::CTuple func_args(args);

driver_name = pythonpp::CString(func_args[0]);

db_type = pythonpp::CString(func_args[1]);

server_name = pythonpp::CString(func_args[2]);

db_name = pythonpp::CString(func_args[3]);

user_name = pythonpp::CString(func_args[4]);

user_pswd = pythonpp::CString(func_args[5]);

} catch (const pythonpp::CError&) {

throw CProgrammingError("Invalid parameters within 'connect' function");

CConnection* conn = new CConnection( CConnParam(

// Feef the object to the Python interpreter ...

return pythonpp::CObject(conn, pythonpp::eTakeOwnership);

catch (const CException& e) {

s_ThrowDatabaseError(e);

// Return a dummy object ...

return pythonpp::CNone();

// This function constructs an object holding a date value.

// Date(year,month,day)

CModuleDBAPI::Date(const pythonpp::CTuple& args)

const pythonpp::CTuple func_args(args);

year = pythonpp::CInt(func_args[0]);

month = pythonpp::CInt(func_args[1]);

day = pythonpp::CInt(func_args[2]);

} catch (const pythonpp::CError&) {

throw CProgrammingError("Invalid parameters within 'Date' function");

// Feef the object to the Python interpreter ...

return pythonpp::CDate(year, month, day);

catch (const CDB_Exception& e) {

s_ThrowDatabaseError(e);

catch (const CException& e) {

pythonpp::CError::SetString(e.what());

// Return a dummy object ...

return pythonpp::CNone();

// This function constructs an object holding a time value.

// Time(hour,minute,second)

CModuleDBAPI::Time(const pythonpp::CTuple& args)

const pythonpp::CTuple func_args(args);

hour = pythonpp::CInt(func_args[0]);

minute = pythonpp::CInt(func_args[1]);

second = pythonpp::CInt(func_args[2]);

} catch (const pythonpp::CError&) {

throw CProgrammingError("Invalid parameters within 'Time' function");

// Feef the object to the Python interpreter ...

return pythonpp::CTime(hour, minute, second, 0);

catch (const CDB_Exception& e) {

s_ThrowDatabaseError(e);

catch (const CException& e) {

pythonpp::CError::SetString(e.what());

// Return a dummy object ...

return pythonpp::CNone();

// This function constructs an object holding a time stamp

// Timestamp(year,month,day,hour,minute,second)

CModuleDBAPI::Timestamp(const pythonpp::CTuple& args)

const pythonpp::CTuple func_args(args);

year = pythonpp::CInt(func_args[0]);

month = pythonpp::CInt(func_args[1]);

day = pythonpp::CInt(func_args[2]);

hour = pythonpp::CInt(func_args[3]);

minute = pythonpp::CInt(func_args[4]);

second = pythonpp::CInt(func_args[5]);

} catch (const pythonpp::CError&) {

throw CProgrammingError("Invalid parameters within 'Timestamp' function");

// Feef the object to the Python interpreter ...

return pythonpp::CDateTime(year, month, day, hour, minute, second, 0);

catch (const CDB_Exception& e) {

s_ThrowDatabaseError(e);

catch (const CException& e) {

pythonpp::CError::SetString(e.what());

// Return a dummy object ...

return pythonpp::CNone();

// This function constructs an object holding a date value

// from the given ticks value (number of seconds since the

// epoch; see the documentation of the standard Python time

// module for details).

// DateFromTicks(ticks)

CModuleDBAPI::DateFromTicks(const pythonpp::CTuple& args)

catch (const CDB_Exception& e) {

s_ThrowDatabaseError(e);

catch (const CException& e) {

pythonpp::CError::SetString(e.what());

// Return a dummy object ...

return pythonpp::CNone();

// This function constructs an object holding a time value

// from the given ticks value (number of seconds since the

// epoch; see the documentation of the standard Python time

// module for details).

// TimeFromTicks(ticks)

CModuleDBAPI::TimeFromTicks(const pythonpp::CTuple& args)

catch (const CDB_Exception& e) {

s_ThrowDatabaseError(e);

catch (const CException& e) {

pythonpp::CError::SetString(e.what());

// Return a dummy object ...

return pythonpp::CNone();

// This function constructs an object holding a time stamp

// value from the given ticks value (number of seconds since

// the epoch; see the documentation of the standard Python

// time module for details).

// TimestampFromTicks(ticks)

CModuleDBAPI::TimestampFromTicks(const pythonpp::CTuple& args)

catch (const CDB_Exception& e) {

s_ThrowDatabaseError(e);

catch (const CException& e) {

pythonpp::CError::SetString(e.what());

// Return a dummy object ...

return pythonpp::CNone();

// This function constructs an object capable of holding a

// binary (long) string value.

CModuleDBAPI::Binary(const pythonpp::CTuple& args)

const pythonpp::CTuple func_args(args);

value = pythonpp::CString(func_args[0]);

} catch (const pythonpp::CError&) {

throw CProgrammingError("Invalid parameters within 'Binary' function");

CBinaryType* obj = new CBinaryType(

// Feef the object to the Python interpreter ...

return pythonpp::CObject(obj, pythonpp::eTakeOwnership);

catch (const CDB_Exception& e) {

s_ThrowDatabaseError(e);

catch (const CException& e) {

pythonpp::CError::SetString(e.what());

return pythonpp::CNone();

(

);

(PyObject *

, PyObject *args, PyObject *kwargs)

*

kwnames[] = {

,

,

,

,

,

,

,

,

PyObject *py_driver_name;

PyObject *py_db_type;

PyObject *py_server_name;

PyObject *py_db_name;

PyObject *py_user_name;

PyObject *py_user_pswd;

PyObject *py_support_standard_interface =

;

PyObject *py_extra_params =

;

status = PyArg_ParseTupleAndKeywords

(args, kwargs,

, (

**) kwnames,

&py_driver_name, &py_db_type, &py_server_name, &py_db_name,

&py_user_name, &py_user_pswd, &py_support_standard_interface,

driver_name = py_driver_name;

db_type = py_db_type;

server_name = py_server_name;

db_name = py_db_name;

user_name = py_user_name;

user_pswd = py_user_pswd;

(py_extra_params !=

) {

extra_params = py_extra_params;

(py_support_standard_interface !=

) {

support_standard_interface = py_support_standard_interface;

}

(py_support_standard_interface !=

) {

(func_args.

() > 6

extra_params = py_support_standard_interface;

support_standard_interface = py_support_standard_interface;

support_standard_interface,

(PyObject *

, PyObject *args)

(PyObject *

, PyObject *args)

(

* name, PyMethodDef* methods);

PyModuleDef m_ModuleDef;

PyModuleDef_HEAD_INIT,

m_ModuleDef.m_name = name;

m_ModuleDef.m_methods = methods;

= PyModule_Create(&m_ModuleDef);

= Py_InitModule(

*

(name), methods);

METH_VARARGS | METH_KEYWORDS, (

*)

(

*)

{(

*)

, (PyCFunction)

, METH_VARARGS, (

*)

},

{(

*)

, (PyCFunction)

, METH_VARARGS, (

*)

},

{(

*)

, (PyCFunction)

, METH_VARARGS, (

*)

},

{(

*)

, (PyCFunction)

, METH_VARARGS, (

*)

},

{(

*)

, (PyCFunction)

, METH_VARARGS, (

*)

},

{(

*)

, (PyCFunction)

, METH_VARARGS, (

*)

},

: m_LoggingModule(PyImport_ImportModule(

))

, m_LoggingDict(m_LoggingModule.GetDict()), m_Logger(1)

, m_LoggerClass(m_LoggingDict.GetItem(

))

#

PY_VERSION_HEX >= 0x03020000

, m_HasHandlers(m_LoggerClass.GetAttr(

))

, m_IsConfigured(

)

root_logger = get_logger.

();

( !m_IsConfigured ) {

m_IsConfigured = m_HasHandlers.Apply(

);

( !m_IsConfigured ) {

s.erase(0, s.find_first_not_of(

, s.find_first_of(

) + 1));

+

);

name(

);

(

)

{

0; }

s_app->FlushDiag(

);

connection_name(module_name +

);

transaction_name(module_name +

);

cursor_name(module_name +

);

cursor_iter_name(module_name +

);

(PyModule_AddObject(module,

*

(

),

( PyModule_AddObject(module,

*

(

), (PyObject*)&

() ) == -1 ) {

( PyModule_AddObject(module,

*

(

), (PyObject*)&

() ) == -1 ) {

str_class[] =

;

str_errorhandler[] =

;

PyMemberDef conn_members[] = {

{str_class, T_OBJECT_EX, 0, READONLY,

},

{str_errorhandler, T_OBJECT_EX, 0, 0,

},

extt->tp_members = conn_members;

( PyType_Ready(extt) == -1 ) {

( PyModule_AddObject(module,

*

(

), (PyObject*)extt ) == -1 ) {

extt->tp_members = conn_members;

( PyType_Ready(extt) == -1 ) {

( PyModule_AddObject(module,

*

(

), (PyObject*)extt ) == -1 ) {

str_rowcount[] =

;

str_messages[] =

;

str_description[] =

;

PyMemberDef members[] = {

{str_rowcount, T_LONG, 0, READONLY,

},

{str_messages, T_OBJECT_EX, 0, READONLY,

},

{str_description, T_OBJECT_EX, 0, READONLY,

},

{str_errorhandler, T_OBJECT_EX, 0, 0,

},

{str_class, T_OBJECT_EX, 0, READONLY,

},

extt->tp_members = members;

( PyType_Ready(extt) == -1 ) {

( PyModule_AddObject(module,

*

(

), (PyObject*)extt ) == -1 ) {

( PyType_Ready(extt) == -1 ) {

( PyModule_AddObject(module,

*

(

), (PyObject*)extt ) == -1 ) {

void SetDriverName(const string &name)

void SetDatabaseName(const string &name)

void SetParam(const string &key, const string &value)

void SetServerType(EServerType type)

void SetEncoding(EEncoding encoding)

virtual TSvrRef GetServer(const string &service)

Map a service to a server.

int Run(void) override

Run the application.

static CNcbiApplication * Instance(void)

Singleton method.

static SSystemFastMutex & GetMutex(void)

vector< pythonpp::CCalable > m_LoggingFunctions

pythonpp::CTuple m_Logger

void Post(const SDiagMessage &mess) override

Post message to handler.

pythonpp::CModule m_LoggingModule

pythonpp::CObject m_LoggerClass

pythonpp::CDict m_LoggingDict

void SetLogger(pythonpp::CObject logger)

class CStaticArrayMap<> provides access to a static array in much the same way as CStaticArraySet<>,...

TBase::const_iterator const_iterator

CTempString implements a light-weight string on top of a storage buffer whose lifetime management is ...

virtual const IResultSetMetaData & GetMetaData(void) const

Get Metadata.

virtual bool Next(void)

Get next row.

CCachedResultSet(IResultSet &other)

virtual ~CCachedResultSet(void)

virtual const CVariant & GetVariant(const CDBParamVariant &param)

Retrieve a CVariant class describing the data stored in a given column.

deque< CVariant > TRecord

virtual unsigned int GetTotalColumns(void)

Get total columns.

const EDB_ResType m_ResType

virtual EDB_ResType GetResultType(void)

Get result type.

unique_ptr< const IResultSetMetaData > m_MetaData

deque< TRecord > TRecordSet

const unsigned int m_ColumsNum

CTransaction *const m_ParentTransaction

CCallableStmtHelper(CTransaction *trans)

int GetReturnStatus(void)

long GetRowCount(void) const

unique_ptr< ICallableStatement > m_Stmt

unique_ptr< CResultSetProxy > m_RSProxy

void SetStr(const CStmtStr &stmt, CDB_UserHandler *handler)

void SetParam(const string &name, const CVariant &value, bool &output_param)

void CreateStmt(CDB_UserHandler *handler)

CDB_UserHandler * m_UserHandler

~CCallableStmtHelper(void)

void FillDescription(pythonpp::CList &descr)

void Execute(bool cache_results=false)

CVariantSet & GetRS(void)

bool m_ResultStatusAvailable

CCPPToolkitConnParams m_Params

CTransaction * CreateTransaction(void)

void DestroyTransaction(CTransaction *trans)

EConnectionMode m_ConnectionMode

pythonpp::CObject __enter__(const pythonpp::CTuple &args)

CDBDefaultConnParams m_DefParams

pythonpp::CObject m_ErrorHandler

pythonpp::CObject commit(const pythonpp::CTuple &args)

CConnection(const string &driver_name, const string &db_type, const string &server_name, const string &db_name, const string &user_name, const string &user_pswd, bool support_standard_interface, const pythonpp::CDict &extra_params)

IConnection * MakeDBConnection(void) const

pythonpp::CObject close(const pythonpp::CTuple &args)

pythonpp::CObject rollback(const pythonpp::CTuple &args)

CTransaction * m_DefTransaction

CTransaction & GetDefaultTransaction(void)

pythonpp::CObject cursor(const pythonpp::CTuple &args)

pythonpp::CObject transaction(const pythonpp::CTuple &args)

CCursorIter(CCursor *cursor)

pythonpp::CObject fetchmany(const pythonpp::CTuple &args)

Fetch the next set of rows of a query result, returning a sequence of sequences (e....

pythonpp::CList m_InfoMessages

pythonpp::CObject __enter__(const pythonpp::CTuple &args)

pythonpp::CList m_DescrList

void AddInfoMessage(const string &message)

pythonpp::CObject m_Description

pythonpp::CObject fetchall(const pythonpp::CTuple &args)

Fetch all (remaining) rows of a query result, returning them as a sequence of sequences (e....

PyObject * CreateIter(void)

bool NextSetInternal(void)

CCursor(CTransaction *trans)

pythonpp::CObject setinputsizes(const pythonpp::CTuple &args)

This can be used before a call to executeXXX() to predefine memory areas for the operation's paramete...

pythonpp::CObject close(const pythonpp::CTuple &args)

Close the cursor now (rather than whenever __del__ is called).

pythonpp::CObject fetchone(const pythonpp::CTuple &args)

Fetch the next row of a query result set, returning a single sequence, or None when no more data is a...

pythonpp::CObject get_proc_return_status(const pythonpp::CTuple &args)

CCallableStmtHelper m_CallableStmtHelper

CUserHandler m_UserHandler

pythonpp::CObject execute(const pythonpp::CTuple &args, const pythonpp::CDict &kwargs)

Prepare and execute a database operation (query or command).

pythonpp::CObject m_ErrorHandler

void SetupParameters(const pythonpp::CDict &dict, CStmtHelper &stmt)

pythonpp::CObject callproc(const pythonpp::CTuple &args)

Call a stored database procedure with the given name.

CVariant GetCVariant(const pythonpp::CObject &obj) const

pythonpp::CObject setoutputsize(const pythonpp::CTuple &args)

Set a column buffer size for fetches of large columns (e.g.

pythonpp::CObject executemany(const pythonpp::CTuple &args, const pythonpp::CDict &kwargs)

Prepare a database operation (query or command) and then execute it against all parameter sequences o...

CTransaction & GetTransaction(void)

pythonpp::CObject nextset(const pythonpp::CTuple &args)

This method will make the cursor skip to the next available set, discarding any remaining rows from t...

static void Declare(const char *name, PyMethodDef *methods)

static PyObject * m_Module

CDMLConnPool(CTransaction *trans, ETransType trans_type=eImplicitTrans)

void rollback(void) const

const ETransType m_TransType

IStatement & GetLocalStmt(void) const

unique_ptr< IStatement > m_LocalStmt

const CConnection & GetConnection(void) const

IConnection * Create(void)

void Destroy(IConnection *db_conn)

unique_ptr< IConnection > m_DMLConnection

void x_Init(const CDB_Exception &e, PyObject *err_type)

TFormat GetDriverFmt(void) const

static const char * GetName(TFormat fmt)

TFormat GetUserFmt(void) const

CParamFmt(TFormat user_fmt=eTSQL, TFormat drv_fmt=eTSQL)

virtual unsigned int GetTotalColumns(void)

Get total columns.

virtual const CVariant & GetVariant(const CDBParamVariant &param)

Retrieve a CVariant class describing the data stored in a given column.

virtual EDB_ResType GetResultType(void)

Get result type.

CRealResultSet(IResultSet *other)

virtual bool Next(void)

Get next row.

virtual ~CRealResultSet(void)

virtual const IResultSetMetaData & GetMetaData(void) const

Get Metadata.

virtual bool MoveToLastRS(void)

virtual ~CRealSetProxy(void)

virtual bool HasRS(void) const

virtual CVariantSet & GetRS(void)

unique_ptr< CVariantSet > m_VariantSet

virtual bool MoveToNextRS(void)

CRealSetProxy(ICallableStatement &stmt)

ICallableStatement * m_Stmt

virtual void DumpResult(void)

const CConnection & GetConnection(void) const

TConnectionList m_ConnPool

void Destroy(IConnection *db_conn)

IConnection * Create(void)

CSelectConnPool(CTransaction *trans, size_t size=3)

TConnectionList m_ConnList

int GetReturnStatus(void)

void FillDescription(pythonpp::CList &descr)

CDB_UserHandler * m_UserHandler

void SetParam(const string &name, const CVariant &value)

unique_ptr< IResultSet > m_RS

CStmtHelper(CTransaction *trans)

void SetStr(const CStmtStr &stmt, CDB_UserHandler *handler)

long GetRowCount(void) const

CTransaction *const m_ParentTransaction

unique_ptr< IStatement > m_Stmt

void CreateStmt(CDB_UserHandler *handler)

bool m_ResultStatusAvailable

string::size_type find_named(const string &str, string::size_type offset, int &param_len)

EStatementType GetType(void) const

void SetStr(const string &str, EStatementType default_type=estSelect, const CParamFmt &fmt=CParamFmt(), ETriState output_expected=eTriState_Unknown)

string::size_type find_numeric(const string &str, string::size_type offset, int &param_len)

string::size_type find_TSQL(const string &str, string::size_type offset, int &param_len)

string GetStr(void) const

CDMLConnPool m_DMLConnPool

pythonpp::CObject __enter__(const pythonpp::CTuple &args)

void CloseOpenCursors(void)

IConnection * CreateSelectConnection(void)

pythonpp::CObject commit(const pythonpp::CTuple &args)

pythonpp::CObject rollback(const pythonpp::CTuple &args)

CTransaction(CConnection *conn, pythonpp::EOwnershipFuture ownnership=pythonpp::eOwned, EConnectionMode conn_mode=eSimpleMode)

const CConnection & GetParentConnection(void) const

IConnection * CreateDMLConnection(void)

void RollbackInternal(void) const

CSelectConnPool m_SelectConnPool

CCursor * CreateCursor(void)

pythonpp::CObject close(const pythonpp::CTuple &args)

void DestroyCursor(CCursor *cursor)

void DestroySelectConnection(IConnection *db_conn)

void CommitInternal(void) const

void DestroyDMLConnection(IConnection *db_conn)

const EConnectionMode m_ConnectionMode

pythonpp::CObject m_PythonConnection

pythonpp::CObject cursor(const pythonpp::CTuple &args)

virtual bool HandleIt(CDB_Exception *ex)

Handle the exceptions resulting from a native API call, one-by-one.

pythonpp::CObject m_PythonConnection

virtual ~CVariantSetProxy(void)

virtual bool MoveToNextRS(void)

virtual bool MoveToLastRS(void)

CRef< CVariantSet > m_CurResultSet

CVariantSetProxy(ICallableStatement &stmt)

deque< CRef< CVariantSet > > TCachedSet

virtual bool HasRS(void) const

virtual CVariantSet & GetRS(void)

virtual void DumpResult(void)

virtual const IResultSetMetaData & GetMetaData(void) const =0

Get Metadata.

virtual EDB_ResType GetResultType(void)=0

Get result type.

virtual bool Next(void)=0

Get next row.

virtual const CVariant & GetVariant(const CDBParamVariant &param)=0

Retrieve a CVariant class describing the data stored in a given column.

virtual unsigned int GetTotalColumns(void)=0

Get total columns.

virtual ~CVariantSet(void)

Destructor.

void Cleanup(CVariant &value)

CWarning(const string &msg)

static bool HasSameType(PyObject *obj)

static bool HasExactSameType(PyObject *obj)

CObject Apply(void) const

Call.

static bool HasSameType(PyObject *obj)

int GetMicroSecond(void) const

int GetMinute(void) const

int GetSecond(void) const

static bool HasSameType(PyObject *obj)

void SetItem(const string &key, const CObject &obj)

CObject GetItem(const string &s) const

static bool HasSameType(PyObject *obj)

static void SetString(const string &msg)

void RWAttr(const string &name, long &value)

static void Declare(const char *name, const char *descr=0, PyTypeObject *base=&PyBaseObject_Type)

void ROAttr(const string &name, long &value)

static CExtType & GetType(void)

static void PrepareForPython(CExtObject< CBinaryType > *self)

static CClass< 1 > Def(const char *name, TMethodVarArgsFunc func, const char *doc=0)

static CObject & GetTypeObject(void)

void SetName(const char *name)

static bool HasSameType(PyObject *obj)

static bool HasSameType(PyObject *obj)

void SetItem(int offset, const CObject &obj)

void Append(const CObject &obj)

static bool HasSameType(PyObject *obj)

static bool HasSameType(PyObject *obj)

static void AddConst(const string &name, const string &value)

static void Declare(const string &name, PyMethodDef *methods, inquiry cleanup_hook=NULL)

static PyObject * GetPyModule(void)

static bool HasExactSameType(PyObject *obj)

static bool HasSameType(PyObject *obj)

void Set(PyObject *obj, EOwnership ownership)

Not exception-safe this time.

PyTypeObject * GetObjType(void) const

PyObject * Get(void) const

CObject GetAttr(const std::string &name) const

virtual size_type size() const

static bool HasSameType(PyObject *obj)

CThreadingGuard – "Anti-guard" for Python's global interpreter lock, which it temporarily releases to...

static void SetMayRelease(bool may_release)

int GetMinute(void) const

int GetSecond(void) const

int GetMicroSecond(void) const

static bool HasSameType(PyObject *obj)

void SetItem(int offset, const CObject &obj)

void SetItemFast(int offset, PyObject *obj)

size_type size(void) const

static bool HasSameType(PyObject *obj)

CObject GetItem(int offset) const

static void Declare(const string &name)

iterator_bool insert(const value_type &val)

const_iterator begin() const

const_iterator end() const

parent_type::const_iterator const_iterator

void(*)(CSeq_entry_Handle seh, IWorkbench *wb, const CSerialObject &obj) handler

#define DBLB_INSTALL_DEFAULT()

Easy-to-use macro to install the default DBAPI service mapper.

static CS_CONNECTION * conn

static const char * str(char *buf, int n)

ETriState

Enumeration to represent a tristate value.

virtual bool LoadConfig(CNcbiRegistry &reg, const string *conf, CNcbiRegistry::TFlags reg_flags)

Load settings from the configuration file to the registry.

CNcbiRegistry & GetRWConfig(void)

Get the application's cached configuration parameters, accessible for read-write for an application's...

@ eTriState_False

The value is equivalent to false/no.

@ eTriState_True

The value is equivalent to true/yes.

@ eTriState_Unknown

The value is indeterminate.

@ eTakeOwnership

An object can take ownership of another.

@ eNoOwnership

No ownership is assumed.

virtual bool Next()=0

Get next row.

virtual string GetName(const CDBParamVariant &param) const =0

Get name of column.

virtual IResultSet * GetResultSet()=0

Get resulset.

virtual bool HasMoreResults()=0

Check for more results available.

virtual const IResultSetMetaData * GetMetaData(EOwnership ownership=eNoOwnership)=0

Get Metadata.

virtual CDB_Connection * GetCDB_Connection()=0

Returns the internal driver connection object.

virtual EDB_ResType GetResultType()=0

Get result type.

virtual IStatement * GetStatement()=0

Get statement object for regular SQL queries.

virtual unsigned int GetTotalColumns()=0

Get total columns.

virtual const CVariant & GetVariant(const CDBParamVariant &param)=0

Retrieve a CVariant class describing the data stored in a given column.

virtual I_DriverContext * GetDriverContext()=0

Returns the pointer to the general driver interface.

virtual ICallableStatement * GetCallableStatement(const string &proc)=0

Get callable statement object for stored procedures.

virtual void Connect(const string &user, const string &password, const string &server, const string &database=kEmptyStr)=0

Connect to a database.

virtual bool HasRows()=0

Check if resultset has rows.

virtual void ExecuteUpdate(const string &sql)=0

Executes SQL statement with no results returned.

virtual IConnection * CreateConnection(EOwnership ownership=eNoOwnership)=0

IDataSource * MakeDs(const CDBConnParams &params, const string &tag=kEmptyStr)

static CDriverManager & GetInstance()

void AddDllSearchPath(const string &path)

Add path for the DLL lookup.

int GetDBErrCode(void) const

int GetSybaseSeverity(void) const

bool IsPositional(void) const

virtual void PushDefConnMsgHandler(CDB_UserHandler *h, EOwnership ownership=eNoOwnership)=0

Add `per-connection' err.message handler "h" to the stack of default handlers which are inherited by ...

virtual void PushCntxMsgHandler(CDB_UserHandler *h, EOwnership ownership=eNoOwnership)=0

Add message handler "h" to process 'context-wide' (not bound to any particular connection) error mess...

unsigned int GetPosition(void) const

EDB_ResType

EDB_ResType::

virtual void PushMsgHandler(CDB_UserHandler *h, EOwnership ownership=eNoOwnership)

Put the message handler into message handler stack.

@ eDateTimeOffset

DATETIMEOFFSET (MS); no Sybase equivalent.

static CVariant VarBinary(const void *p, size_t len)

void Write(string &str, TDiagWriteFlags flags=fNone) const

Binary OR of "EDiagWriteFlags".

TExtraArgs m_ExtraArgs

If event type is "extra", contains the list of arguments.

static bool IsSetOldPostFormat(void)

Check old/new format flag (for compatibility only)

const char * m_Buffer

Not guaranteed to be '\0'-terminated!

EDiagSev m_Severity

Severity level.

#define NCBI_CURRENT_FUNCTION

Get current function name.

int CompareDiagPostLevel(EDiagSev sev1, EDiagSev sev2)

Compare two severities.

CDiagHandler * GetDiagHandler(bool take_ownership=false, bool *current_ownership=0)

Get the currently set diagnostic handler class.

size_t m_BufferLen

Length of m_Buffer.

void SetDiagHandler(CDiagHandler *handler, bool can_delete=true)

Set the diagnostic handler using the specified diagnostic handler class.

static void SetOldPostFormat(bool value)

Set old/new format flag.

@ fNoEndl

No end of line.

@ fNoPrefix

No std prefix.

@ eDiag_Trace

Trace message.

@ eDiag_Info

Informational message.

@ eDiag_Error

Error message.

@ eDiag_Warning

Warning message.

@ eDiag_Fatal

Fatal error – guarantees exit(or abort)

@ eDiag_Critical

Critical error message.

@ eDiagSevMax

Verbosity level for max. severity.

#define NCBI_CATCH_ALL_X(err_subcode, message)

const string & GetMsg(void) const

Get message string.

virtual const char * what(void) const noexcept

Standard report (includes full backlog).

const CException * GetPredecessor(void) const

Get "previous" exception from the backlog.

int64_t Int8

8-byte (64-bit) signed integer

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

static SIZE_TYPE FindNoCase(const CTempString str, const CTempString pattern, SIZE_TYPE start, SIZE_TYPE end, EOccurrence which=eFirst)

Find the pattern in the specified range of a string using a case insensitive search.

static string IntToString(int value, TNumToStringFlags flags=0, int base=10)

Convert int to string.

static string & Replace(const string &src, const string &search, const string &replace, string &dst, SIZE_TYPE start_pos=0, SIZE_TYPE max_replace=0, SIZE_TYPE *num_replace=0)

Replace occurrences of a substring within a string.

static bool EqualNocase(const CTempString s1, SIZE_TYPE pos, SIZE_TYPE n, const char *s2)

Case-insensitive equality of a substring with another string.

size_type find(const CTempString match, size_type pos=0) const

Find the first instance of the entire matching string within the current string, beginning at an opti...

static string & ToUpper(string &str)

Convert string to upper case – string& version.

static const size_type npos

int Minute(void) const

Get minute.

void SetMinute(int minute)

Set minute.

TSeconds TimeZoneOffset(void) const

Get difference between local timezone for current time object and UTC in seconds.

void SetSecond(int second)

Set second.

void SetMicroSecond(long microsecond)

Set microseconds.

long NanoSecond(void) const

Get nano-seconds.

int Year(void) const

Get year.

void SetHour(int hour)

Set hour.

time_t GetTimeT(void) const

Get time in time_t format.

int Day(void) const

Get day.

int Hour(void) const

Get hour.

int Second(void) const

Get second.

int Month(void) const

Get month.

@ eCurrent

Use current time. See also CCurrentTime.

Definition of all error codes used in dbapi libraries (dbapi_driver.lib and others).

The blob sat and sat key Both must be positive integers</td > n< td > Non empty string The interpretation of the blob id depends on a processor Cassandra n processor expects the following format

if(yy_accept[yy_current_state])

double value_type

The numeric datatype used by the parser.

const struct ncbi::grid::netcache::search::fields::SIZE size

const struct ncbi::grid::netcache::search::fields::KEY key

static string RetrieveModuleFileName(void)

PyObject * s_GetCursorIter(PyObject *curs_obj)

static void s_FillDescription(pythonpp::CList &descr, const IResultSetMetaData *data)

static PyObject * Binary(PyObject *self, PyObject *args)

static PyObject * Timestamp(PyObject *self, PyObject *args)

static PyObject * ReturnStrsAsUnicode(PyObject *self, PyObject *args)

static CNullable< short > x_GetUTCOffset(const pythonpp::CDateTime &dt)

EStatementType RetrieveStatementType(const string &stmt, EStatementType default_type, ETriState output_expected)

SStaticPair< int, FRethrow > TDBErrCodePair

static PyObject * TimeFromTicks(PyObject *self, PyObject *args)

PyObject * s_CursorIterNext(PyObject *iter_obj)

PyObject * s_GetCursorIterFromIter(PyObject *iter_obj)

static const TDBErrCodePair kClientErrCodes[]

static PyObject * DateFromTicks(PyObject *self, PyObject *args)

static PyObject * SetLogger(PyObject *self, PyObject *args)

static PyObject * ReleaseGlobalLock(PyObject *self, PyObject *args)

static PyObject * Time(PyObject *self, PyObject *args)

void(* FRethrow)(const CDB_Exception &)

static PyObject * Connect(PyObject *self, PyObject *args, PyObject *kwargs)

static PyObject * TimestampFromTicks(PyObject *self, PyObject *args)

DEFINE_STATIC_ARRAY_MAP(TDBErrCodeMap, sc_ClientErrCodes, kClientErrCodes)

static ETriState s_IsOutputExpected(const pythonpp::CDict &kwargs)

pythonpp::CTuple MakeTupleFromResult(IResultSet &rs)

pythonpp::CObject ConvertCVariant2PCObject(const CVariant &value)

static PyObject * Date(PyObject *self, PyObject *args)

static const TDBErrCodePair kSybaseErrCodes[]

CStaticArrayMap< int, FRethrow > TDBErrCodeMap

static void s_ThrowDatabaseError(const CException &e)

PyObject * DecRefCount(PyObject *obj)

PyObject * IncRefCount(PyObject *obj)

const GenericPointer< typename T::ValueType > T2 value

#define NCBI_PACKAGE_VERSION

Static variables safety - create on demand, destroy on application termination.

Defines the CNcbiApplication and CAppException classes for creating NCBI applications.

Defines access to miscellaneous global configuration settings.

const char * NCBI_GetDefaultRunpath(void)

Get default run path.

Int4 delta(size_t dimension_, const Int4 *score_)

#define DB_ERR_CODE(value, type)

static void s_RestoreOrigDiagHandler(void)

static struct PyMethodDef python_ncbi_dbapi_methods[]

static PyObject * init_common(const string &module_name)

static int s_OnClear(PyObject *)

#define PYDBAPI_MODINIT_FUNC(name)

#define PYDBAPI_SUPPORT_DIR

#define PYDBAPI_MOD_RETURN

static bool s_WasUsingOldPostFormat

bool g_PythonStrDefToUnicode

Flag showing whether all pythonpp::CString objects should be created as Python unicode strings (TRUE ...

static CDiagHandler * s_OrigDiagHandler

static SLJIT_INLINE sljit_ins msg(sljit_gpr r, sljit_s32 d, sljit_gpr x, sljit_gpr b)

#define row(bind, expected)

Template structure SStaticPair is simlified replacement of STL pair<> Main reason of introducing this...

static const char * type_name(CS_INT value)

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4