oracle OCCI 的一个简单的包装类的实现-入门基础-Oracle频道-中国IT实验室

以下是引用片段：
　　TOcci.h
　　#ifndef _OCCIDATABASE_H_
　　#define _OCCIDATABASE_H_
　　#include 
　　#include 
　　#include 
　　using namespace oracle::occi;
　　using namespace std;
　　namespace happyever
　　{
　　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;
　　};
　　int TOcciDatabase::count = 0;
　　TOcciDatabase* TOcciDatabase::_Instance = 0;
　　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 _tmain(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;
　　}
--------------------next---------------------