occi 连接池 连接失效
服务器长时间运行，难免会连接池失效。当连接实效会导致进程卡死，好多才能入库城成功，或是抛出异常。考虑过定期检测连接有效性，无效则重新创建。但occi 貌似没有提供类似检测的接口。 只有和oracle 交互才能检测。 但交互势必又要在连接池中获取连接，依旧可能获取无效连接。 求教这该如何是好。
这是class
class OraConnPool
{
protected:
OraConnPool();
public:
bool createConnPool(const std::string& username, const std::string& passwd, const std::string& connectString, int maxCon, int minCon, int incrCon);
bool reCreateConnPool();
void destroyConnPool();
string getErrData(void);
Connection * getConnection();
void freeConnection(Connection*);
static OraConnPool* getInstance();
bool checkConnect();
~OraConnPool();
private:
Environment * env;
StatelessConnectionPool * scp;
string sErrInfo;
static OraConnPool* _instance;
std::string username;
std::string password;
std::string connstring;
int maxCon;
int minCon;
int incrCon;
};
bool OraConnPool::createConnPool(const std::string& username, const std::string& passwd, const std::string& connectString, int maxCon, int minCon, int incrCon)
{
this->username = username;
this->password = passwd;
this->connstring = connectString;
this->maxCon = maxCon;
this->minCon = minCon;
this->incrCon = incrCon;
setenv("NLS_LANG", "SIMPLIFIED CHINESE_CHINA.ZHS32GB18030", 1);
//setenv("NLS_LANG", "american_america.AL32UTF8", 1);
sErrInfo="";
try
{
//env = Environment::createEnvironment(Environment::DEFAULT);
env = Environment::createEnvironment(Environment::Mode(Environment::OBJECT|Environment::THREADED_MUTEXED));
if (env == NULL)
{
sErrInfo="CreateConnpool Error!";
return false;
}
scp = env->createStatelessConnectionPool(username.c_str(), passwd.c_str(), connectString.c_str(), maxCon, minCon, incrCon, StatelessConnectionPool::HOMOGENEOUS);
scp ->setTimeOut(10000);
if (scp == NULL)
{
Environment::terminateEnvironment(env);
sErrInfo="Connection oracle error!";
return false;
}
sErrInfo="CreateConnpool success! ";
return true;
}
catch(SQLException ex)
{
sErrInfo=ex.getMessage().c_str();
}
return false;
}
Connection* OraConnPool::getConnection()
{
Connection * pConn = NULL;
pConn = scp->getConnection();
return pConn;
}
int DBOperator::connectionKeepAlive() {
//DBManager<DBOracle> m_db_manager(g_db, g_user, g_passwd, g_host, 1, g_log_level);
//Connection_Guard<DBOracle> connGuard(&m_db_manager);
Connection_Guard<DBOracle> connGuard( _p_dbm.get() );
oracle::Connection* p_conn = connGuard.getConnection();
if ( !p_conn ) {
return -1;
}
try
{
ACE_Auto_Ptr< oracle::Statement > statementPtr( p_conn->createStatement( "SELECT sysdate from DUAL" ) );
// ACE_DEBUG( ( LM_INFO, "[%D %T] [INFO] (%N:%l)\tDBOperator::connectionKeepAlive() SQL: SELECT sysdate from DUAL\n") );
ACE_Auto_Ptr< oracle::Resultset > resultSet( statementPtr->executeQuery() );
if (!resultSet->next() ) {
return -1;
}
}catch ( oracle::SQLException& ex )
{
ACE_DEBUG( ( LM_ERROR, "[%D %T] [ERROR] (%N:%l)\tDBOperator::connectionKeepAlive() SQL Exception : %s\n", ex.getMsg().c_str() ) );
return -3;
}
return 0;
}
int BizCtrlManager::svc()
{
int cnt;
ACE_DEBUG( ( LM_INFO, "[%D %T] [INFO] (%N:%l)\tKeepALiveThread::svc() Thread Begin !!! \n") );
ACE_Message_Block *mb;
ACE_Time_Value now ;
ACE_Time_Value interval(IMSERVERCONFIGAPP->getBizCtrlKeepLiveTime() );
setLoopFlag( true );
cnt=0;
while (1) {
ACE_DEBUG( ( LM_ERROR, "[%D %T] [INFO] (%N:%l)\t ***** [KeepALiveThread::svc()] Client Number IS %d !!! \n",IMCLIENTHDLERMAPMANAGERAPP->getClientNumber() ) );
cnt++;
if (cnt>=10) {
cnt=0;
int res = IMSERVERDBAPP->connectionKeepAlive();
ACE_DEBUG( ( LM_INFO, "[%D %T] [INFO] (%N:%l)\tBizCtrlManager::svc() connectionKeepAlive() Return %d \n",res ) );
}
now = ACE_OS::gettimeofday();
if ( getq( mb, &( now + interval) ) != -1 ) {
Message_Block_Guard message_block_guard (mb);
char *c_data = mb->base();
if ( c_data ) {
void *v_data = (void *)c_data;
unsigned int *message = ( unsigned int * )v_data;
if ( BIZCTRL_EXIT == *message ) {
delete message;
ACE_DEBUG( ( LM_INFO, "[%D %T] [INFO] (%N:%l)\tKeepALiveThread::svc() Get Exit Message !!! \n") );
break;//
} else {
if ( BIZCTRL_RECONNECT == *message ) {
delete message;
ACE_DEBUG( ( LM_ERROR, "[%D %T] [ERROR] (%N:%l)\tKeepALiveThread::svc() Get ReConnect BizCtrl Message Close All Client Handler !!! \n" ) );
IMCLIENTHDLERMAPMANAGERAPP->closeAllClientHandle();
while ( !imSRegister() && getLoopFlag() ) {
ACE_DEBUG( ( LM_ERROR, "[%D %T] [ERROR] (%N:%l)\tKeepALiveThread::svc() ReConnect BizCtrl Error Retry !!! \n" ) );
ACE_OS::sleep( ACE_Time_Value( 10 ) );
}
//setRegisterFlag( true );
continue;
}
}
}
}
if ( !imSKeepAlive() ) {
IMCLIENTHDLERMAPMANAGERAPP->closeAllClientHandle();
}
}
_thrIsALive = false;
ACE_DEBUG( ( LM_INFO, "[%D %T] [INFO] (%N:%l)\tKeepALiveThread::svc() Keep ALive Thread Exit!!!\n" ) );
return 0;
}