Oracle OCCI的一个简单的包装类的实现

TOcci.h

#ifndef _OCCIDATABASE_H_
#define _OCCIDATABASE_H_

using namespace oracle::occi;
using namespace std;

class TOcciDatabase {
public: 　　
    static TOcciDatabase* getInstance(string usr, string passwd, string db); 　　
    int getConnectCount(){ return _Instance->count; }; 　　
    Connection* getConnect(){ count++;return _Instance->conn; }; 　　
    ~TOcciDatabase();
protected: 　　
    TOcciDatabase(){}; 　　
    TOcciDatabase(string usr, string passwd, string db);
private: 　　
    static TOcciDatabase* _Instance; 　　
    static int count; 　　
    Environment *env; 　　
    Connection *conn;
}

TOcciDatabase::TOcciDatabase(string usr, string passwd, string db)
{ 　　
try
    {
        env = Environment::createEnvironment (Environment::DEFAULT);
        conn = env->createConnection (usr, passwd, db);
     }
    catch(SQLException ex)
     {
        cout<<"Exception thrown for getConnect"<        cout<<"Error number: "<< ex.getErrorCode() << endl;
        cout<        throw ex;
    }
}

TOcciDatabase::~TOcciDatabase()
{
    try
    {
        env->terminateConnection (conn);
        Environment::terminateEnvironment (env);
    }
    catch(SQLException ex)
    {
        cout<<"Exception thrown for getConnect"<
        cout<<"Error number: "<< ex.getErrorCode() << endl;
        cout<        throw ex;
　　}
}

TOcciDatabase* TOcciDatabase::getInstance(string usr, string passwd, string db)
{
    if(_Instance == 0)
    {
        _Instance = new TOcciDatabase(usr,passwd,db);
    }
    return _Instance;
}
　　
class TOcciQuery
{
private:
    Connection *conn;
    Statement *stmt;
    bool isAutoCommit;
    TOcciQuery(){};
 public :
    TOcciQuery(Connection *connect){ conn = connect; };
    void beginTrans();
    void commit();
    void roolback();
    boolean getAutoCommit();
    ResultSet* executeQuery(string sql) ;
    void executeUpdate(string sql) ;
    void close() { if(stmt != NULL) conn->terminateStatement (stmt); };
    void close(ResultSet* rs);
} 　　

void TOcciQuery::close(ResultSet* rs)
{
    if(rs != NULL)
        stmt->closeResultSet (rs);
    if(stmt != NULL)
        conn->terminateStatement (stmt);
} 　　

void TOcciQuery::beginTrans()
{
    try
    {
        isAutoCommit = stmt->getAutoCommit();
        stmt->setAutoCommit(false);
    }
    catch(SQLException ex)
    {
        cout<<"Exception thrown for beginTrans"<        cout<<"Error number: "<< ex.getErrorCode() << endl;
        cout<        throw ex;
    }
} 　　

void TOcciQuery::commit()
{
    try
    {
        conn->commit();
        stmt->setAutoCommit(isAutoCommit);
    }
    catch(SQLException ex)
    {
        cout<<"Exception thrown for commit"        cout<<"Error number: "<< ex.getErrorCode() << endl;
        cout<        throw ex;
    }
}

void TOcciQuery::roolback()
 {
    try
    {
        conn->rollback();
        stmt->setAutoCommit(isAutoCommit);
    }
    catch(SQLException ex)
    {
        cout<<"Exception thrown for roolback"<        cout<<"Error number: "<< ex.getErrorCode() << endl;
        cout<        throw ex;
    }
}

boolean TOcciQuery::getAutoCommit()
 {
    boolean result = false;
    try
    {
        result = stmt->getAutoCommit();
    }
    catch(SQLException ex)
    {
        cout<<"Exception thrown for getAutoCommit"<        cout<<"Error number: "<< ex.getErrorCode() << endl;
        cout<        throw ex;
    }
    return result;
} 　　

ResultSet* TOcciQuery::executeQuery(string sql)
 {
    ResultSet*rs = NULL;
    try
    {
        stmt = conn->createStatement();
        rs = stmt->executeQuery(sql);
    }
    catch (SQLException ex)
    {
        cout<<"Exception thrown for executeQuery"<        cout<<"Error number: "<< ex.getErrorCode() << endl;
        cout<        throw ex;
    }
    return rs;
} 　　
void TOcciQuery::executeUpdate(string sql)
{
    try
    {
        stmt = conn->createStatement();
        stmt->executeUpdate(sql);
    }
    catch (SQLException ex)
    {
        cout<<"Exception thrown for executeUpdate"<        cout<<"Error number: "<< ex.getErrorCode() << endl;
        cout<        throw ex;
    }
} #endif /*_OCCIDATABASE_H_*/ 　　


测试程序main.cpp源码如下： // occi.cpp : 定义控制台应用程序的入口点。 // #include "stdafx.h" #include "TOcci.h"
int main(int argc, _TCHAR* argv[])
{
    using namespace happyever;
    TOcciQuery *query = new TOcciQuery(TOcciDatabase::getInstance("cal","cal","v2b76")->getConnect());
    string strSQL = "select count(*) from serv_value_total";
    ResultSet* rs = query->executeQuery(strSQL);
    while(rs->next())
    {
        std::cout<<"count = "    }
    query->close(rs);
    delete(query);
    return 1;
}