epee::ado_db_helper::per_thread_connection_pool Class Reference

#include <ado_db_helper.h>

Public Member Functions
bool	init (const std::string &connection_string, const std::string &login, const std::string &pass)
ADODB::_ConnectionPtr &	get_db_connection ()
bool	check_status ()

Detailed Description

Definition at line 931 of file ado_db_helper.h.

Member Function Documentation

check_status()

bool epee::ado_db_helper::per_thread_connection_pool::check_status ( )

inline

Definition at line 984 of file ado_db_helper.h.

            {
                ADODB::_ConnectionPtr& rconn = get_db_connection();
                if(!ado_db_helper::execute_helper(rconn, "SET CLIENT_ENCODING TO 'SQL_ASCII'"))
                {
 
                    try{
                        HRESULT res = rconn->Close();
                    }
                    catch(...)
                    {
 
                    };
                    BEGIN_TRY_SECTION();
 
                    HRESULT res = rconn->Open(_bstr_t(m_connection_string.c_str()), _bstr_t(m_login.c_str()), _bstr_t(m_password.c_str()), NULL);
                    if(res != S_OK) 
                    {
                        LOG_PRINT("Failed to restore connection to local AI DB", LOG_LEVEL_1);
                        return false;
                    }
                    CATCH_TRY_SECTION(false);
                }
 
                return true;
            }

Here is the call graph for this function:

get_db_connection()

ADODB::_ConnectionPtr & epee::ado_db_helper::per_thread_connection_pool::get_db_connection ( )

inline

Definition at line 945 of file ado_db_helper.h.

            {
 
                //soci::session 
 
                m_db_connections_lock.lock();
                boost::shared_ptr<ADODB::_ConnectionPtr>& conn_ptr = m_db_connections[::GetCurrentThreadId()];
                m_db_connections_lock.unlock();
                if(!conn_ptr.get())
                {
                    conn_ptr.reset(new ADODB::_ConnectionPtr());
                    ADODB::_ConnectionPtr& conn = *conn_ptr.get();
                    //init new connection
 
                    BEGIN_TRY_SECTION();
                    //_bstr_t str = _bstr_t("Provider=SQLOLEDB;Data Source=SRV1;Integrated Security=SSPI;Initial Catalog=dispatcher;");
 
                    if(S_OK != conn.CreateInstance(__uuidof(ADODB::Connection)))
                    {
                        LOG_ERROR("Failed to Create, instance, was CoInitialize called ???!");
                        return conn;
                    }
 
                    HRESULT res = conn->Open(_bstr_t(m_connection_string.c_str()), _bstr_t(m_login.c_str()), _bstr_t(m_password.c_str()), NULL);
                    if(res != S_OK) 
                    {
                        LOG_ERROR("Failed to connect do DB, connection str:" << m_connection_string);
                        return conn;
                    }
                    CATCH_TRY_SECTION_MESS(conn, "while creating another connection");
                    LOG_PRINT("New DB Connection added for threadid=" << ::GetCurrentThreadId(), LOG_LEVEL_0);
                    ado_db_helper::execute_helper(conn, "set enable_seqscan=false;");
                    return conn;
                }
 
                return *conn_ptr.get();
            }

Here is the call graph for this function:

Here is the caller graph for this function:

init()

bool epee::ado_db_helper::per_thread_connection_pool::init ( const std::string & connection_string, const std::string & login, const std::string & pass )

inline

Definition at line 934 of file ado_db_helper.h.

            {
                m_connection_string = connection_string;
                m_login = login;
                m_password = pass;
                if(!get_db_connection().GetInterfacePtr())
                    return false;
 
                return true;
            }

Here is the call graph for this function:

---

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

• /home/abuild/rpmbuild/BUILD/electroneum-5.1.3.1-build/electroneum-5.1.3.1/contrib/epee/include/ado_db_helper.h