dbmgrtest.cxx

来自「vovida的软交换」· CXX 代码 · 共 58 行

#include "ConnectionManager.hxx"
#include "DBConnThread.hxx"
#include "DBResultset.hxx"
#include "DBConnection.hxx"
#include "PGSQLConnection.hxx"
#include "DBInfo.h"

#include <unistd.h>


int main (void){

    int  i;

    //Connection Manager to handle connection to databases
    ConnectionManager *myDBManager = ConnectionManager::getInstance();
    DBConnThread *dbthread = new DBConnThread(myDBManager);
    dbthread->run();
      
    DBConnection* dbconn[10] = {NULL};
    DBResultset* results;
    
    DBInfo dbInfo;
    
    dbInfo.dbBackend = "PGSQL";
    dbInfo.database = "vocal";
    dbInfo.host = "127.0.0.1";
    dbInfo.user = "vocal";
    dbInfo.password = "vocal";
    
    for(i = 0; i < 10; i++){
        dbconn[i] = myDBManager->searchDBConPool(dbInfo);
        cout << "\n" << "Pool Size : " << myDBManager->dbPoolSize() << "\n";
    
        results = dbconn[i]->DBSQLSelect((string) "SELECT alias FROM ALIASES;");
        
        ResultTabletype recs = results->GetRecords();
        cout << "Record Table Size :" << recs.size() <<"\n";
        
        for(ResultTabletype::iterator j = recs.begin(); j != recs.end(); j++){
                cout << (*((*j).begin())).c_str() << "\n";
        }
        
        delete results;
    }    
    
    for(i = 0; i < 4; i++){
        myDBManager->returnDBCon(dbconn[i]);
    }
 
    while(true){
        cout << "\n" << "Pool Size : " << myDBManager->dbPoolSize() << "\n";
        sleep (5);    
    }      
                         
    return 0;                      
}