通過OCCI連接oracle（C++）

OCCI介紹

OCCI：Oracle C++調用接口（OCCI），即Oracle的C++API，允許你使用面向對象的特性、本地類、C++語言的方法來訪問Oracle數據庫。

 

OCCI優勢

基於標准C++和面向對象的設計；

效率較高；

適合開發C/S模式的程序，軟件中間層；

OCCI特性

完整支持SQL/PLSQL

為不斷增長的用戶和請求提供了彈性選項

為使用用戶自定義類型，如C中的類，提供了無縫接口

支持所有的Oracle數據類型以及LOB types

可以訪問數據庫元數據

OCCI頭文件及動態鏈接庫

OCCI 頭文件

•occi.h

•occiCommon.h

•occiControl.h

•occiData.h

•occiObjects.h

OCCI庫

•libocci.so/libocci.a/oraocci9.dll

構建應用程序

步驟1：初始化

OCCI通過創建一個Environment的對象完成初始化工作。

可以通過Environment創建數據庫連接，從而進行其它的操作

要創建Environment，應該調用Environment類的靜態方法 createEnvironment()

示例：

<span style="color:#000000;">//include 1 header file for all OCCI classes/interfaces
#include <occi.h>

//create Environment
Environment *env = Environment::createEnvironment();//創建連接對象指針
//use the Environment instance to create connections,
//database access
…

//terminate Environment by calling static method
//Environment::terminateEnvironment
Environment::terminateEnvironment(env);//關閉</span>

步驟二：連接數據庫

連接數據庫通過Connection類的對象實例實現

調用Environment類的 createConnection()方法可以創建一個Connection對象；

 

Connection *Environment::createConnection( const string &userName,const string &password, const string &connectString )

 

連接數據庫成功后，可以用它來訪問數據，執行SQL語句；

使用 Environment::terminateConnection()斷開連接；

示例：

//First need Environment
Environment *env = Environment::createEnvironment();

Connection *conn=env->createConnection(“scott”,”tiger”,””);
//3rd parameter is db name/TNS alias

..//database access – use the Connection object
..
..
//logoff and terminate connection
env->terminateConnection(conn);//斷開連接

步驟三：執行SQL/PLSQL

Statement類用於執行SQL/PLSQL語句,並獲取返回結果。

ResultSet 類用於處理SELECT 查詢的結果。

對於所有類型的數據的綁定或者獲取，OCCI都提供了統一的方法

  - setXXX  方法用於Statement

  - getXXX 方法用於Statement & ResultSet

OCCI會自動處理類型之間的轉換。

使用方法：

使用Connection:: createStatement()創建Statement對象

指定 SQL 命令(DDL/DML/query)作為參數

   Connection::createStatement(string &sql);

   Statement::setSQL(string &sql);

  Statement::execute(string &sql); - can be used for any SQL, returnsstatus

   Statement::executeUpdate(string &sql); - returns Insert/Update/Delete count

   Statement::executeQuery(string &sql); - returns ResultSet（結果集）

使用 setXXX 方法傳遞要綁定用於輸入的值

使用合適的execute方法執行SQL

對於SELECT 查詢, 使用ResultSet 對象處理返回結果

簡單的DML Insert示例：

//createStatement() on Connection class gives a Statement
//instance
Statement *stmt = conn->createStatement(“ insert into Dept(Deptno,Dname, Loc) values (1, ‘ACCOUNTS’, ‘ZONE1’ ”);
//executeUpdate for all INSERT/UPDATE/DELETE
stmt->executeUpdate();
conn->terminateStatement(stmt);

使用綁定參數的DML示例：

Statement *stmt = conn->createStatement(“ insert into
Emp(EmpNo,Ename) values(:1, :2) ”);
//1 and 2 are bind placeholders
int empno = 2;
string empname = “JOHN W”;
//first parameter is bind position, second is value
stmt->setInt(1, empno);
stmt->setString(2, empname);
stmt->executeUpdate();

執行SELECT查詢並處理結果：

Statement *stmt = conn->createStatement(“ select Empno,
Ename, Sal from Emp where Hiredate >= :1”);

//automatically converted to Date
stmt->setString(1, “01-JAN-1987”);

//executeQuery returns a ResultSet
ResultSet *rs = stmt->executeQuery();

//ResultSet::next fetches rows and returns FALSE
//when no more rows
while (rs->next() == true)
{
   //get values using the getXXX methods of ResultSet
   empno = rs->getInt(1);
   empname = rs->getString(2);
   empsalary = rs->getFloat(3);
}
stmt->closeResultSet(rs);//to free resources

執行PL/SQL：

 

 

要執行PL/SQL，應該在創建Statement的時候指定PL/SQL塊

使用setXXX將所有的輸入參數(IN andIN/OUT)傳給PLSQL函數或者過程

使用Statement::registerOutParam來指定OUT參數，參數的大小通過Statement::setMaxParamSize指定

使用Statement::execute()執行PL/SQL

使用getXXX方法來獲取函數執行的結果及OUT/IN OUT參數

示例：Calling PL/SQL function/procedure

 

 

//PLSQL function : functionCalculateBonus(EmpNo INNumber,
//                           EmpStatus IN OUT VARCHAR2,
//                           Bonus OUT Number)RETURN VARCHAR2
//call function usinganonymous block
Statement *stmt = conn->createStatement(“ begin :1 := CalculateBonus(
            :2, :3, :4); end;”);
//bind position 1 is thefunction’s return value
stmt->setInt(2, 100); //IN parameter
stmt->setString(3, “Active”); //IN OUT parameter
//call registerOutParam for each OUT parameter
stmt->registerOutParam(1, OCCISTRING, 1000);//function’sreturn value
stmt->setMaxParamSize(1, 100);//setMaxParamSize for STRING types
stmt->registerOutParam(4, OCCIFLOAT);
stmt->execute();
//use getXXX methods of Statement to get OUTparameters, return value
string msg = stmt->getString(1);//function return value
string newstatus = stmt->getString(3);//IN OUT parameter
float bonus = stmt->getFloat(4); //OUT parameter

 

步驟四：錯誤處理

OCCI使用C++異常機制來返回所有的錯誤信息

應用程序中應該使用try-catch結構來處理異常

拋出的異常屬於SQLException類型，該類型繼承自標准C++中的exception類

可以使用getErrorCode和getMessage方法來獲取Oracle的錯誤信息

示例：

分別處理Oracle和C++ STL錯誤

 

 

try
{
   ResultSet *rs = stmt->executeQuery();
   while (rs->next())
   ……….
}
catch (SQLException &oraex) //Oracle/OCCI errors
{
  int errno = oraex->getErrorCode();//returns the ORA number
  string errmsg = oraex->getMessage();
  //more application error handling
}
catch (exception &ex) //any other C++/STL error
{
  cout << “Error “ << ex.what() << endl;
}