首页 > 代码库 > 通过OCCI连接oracle（C++）

通过OCCI连接oracle（C++）

2024-07-06 05:35:30   228人阅读

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()
示例：
[cpp] view plaincopy
 
  1. <span style="color:#000000;">//include 1 header file for all OCCI classes/interfaces  
  2. #include <occi.h>  
  3.   
  4. //create Environment  
  5. Environment *env = Environment::createEnvironment();//创建连接对象指针  
  6. //use the Environment instance to create connections,  
  7. //database access  
  8. …  
  9.   
  10. //terminate Environment by calling static method  
  11. //Environment::terminateEnvironment  
  12. Environment::terminateEnvironment(env);//关闭</span>  
步骤二：连接数据库
连接数据库通过Connection类的对象实例实现
调用Environment类的createConnection()方法可以创建一个Connection对象；

 

[cpp] view plaincopy
 
  1. Connection *Environment::createConnection( const string &userName,const string &password, const string &connectString )  

 

连接数据库成功后，可以用它来访问数据，执行SQL语句；
使用Environment::terminateConnection()断开连接；
示例：
[cpp] view plaincopy
 
  1. //First need Environment  
  2. Environment *env = Environment::createEnvironment();  
  3.   
  4. Connection *conn=env->createConnection(“scott”,”tiger”,””);  
  5. //3rd parameter is db name/TNS alias  
  6.   
  7. ..//database access – use the Connection object  
  8. ..  
  9. ..  
  10. //logoff and terminate connection  
  11. 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示例：
[cpp] view plaincopy
 
  1. //createStatement() on Connection class gives a Statement  
  2. //instance  
  3. Statement *stmt = conn->createStatement(“ insert into Dept(Deptno,Dname, Loc) values (1, ‘ACCOUNTS’, ‘ZONE1’ ”);  
  4. //executeUpdate for all INSERT/UPDATE/DELETE  
  5. stmt->executeUpdate();  
  6. conn->terminateStatement(stmt);  
使用绑定参数的DML示例：
[cpp] view plaincopy
 
  1. Statement *stmt = conn->createStatement(“ insert into  
  2. Emp(EmpNo,Ename) values(:1, :2) ”);  
  3. //1 and 2 are bind placeholders  
  4. int empno = 2;  
  5. string empname = “JOHN W”;  
  6. //first parameter is bind position, second is value  
  7. stmt->setInt(1, empno);   
  8. stmt->setString(2, empname);  
  9. stmt->executeUpdate();  
[cpp] view plaincopy
 
  1.   
执行SELECT查询并处理结果：
[cpp] view plaincopy
 
  1. Statement *stmt = conn->createStatement(“ select Empno,   
  2. Ename, Sal from Emp where Hiredate >= :1”);  
  3.   
  4. //automatically converted to Date  
  5. stmt->setString(1, “01-JAN-1987”);  
  6.   
  7. //executeQuery returns a ResultSet  
  8. ResultSet *rs = stmt->executeQuery();   
  9.   
  10. //ResultSet::next fetches rows and returns FALSE   
  11. //when no more rows  
  12. while (rs->next() == true)  
  13. {  
  14.    //get values using the getXXX methods of ResultSet  
  15.    empno = rs->getInt(1);  
  16.    empname = rs->getString(2);  
  17.    empsalary = rs->getFloat(3);  
  18. }  
  19. 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

 

 

[cpp] view plaincopy
 
  1. //PLSQL function : functionCalculateBonus(EmpNo INNumber,  
  2. //                           EmpStatus IN OUT VARCHAR2,  
  3. //                           Bonus OUT Number)RETURN VARCHAR2  
  4. //call function usinganonymous block  
  5. Statement *stmt = conn->createStatement(“ begin :1 := CalculateBonus(  
  6.             :2, :3, :4); end;”);  
  7. //bind position 1 is thefunction’s return value  
  8. stmt->setInt(2, 100); //IN parameter  
  9. stmt->setString(3, “Active”); //IN OUT parameter  
  10. //call registerOutParam for each OUT parameter  
  11. stmt->registerOutParam(1, OCCISTRING, 1000);//function’sreturn value  
  12. stmt->setMaxParamSize(1, 100);//setMaxParamSize for STRING types  
  13. stmt->registerOutParam(4, OCCIFLOAT);  
  14. stmt->execute();  
  15. //use getXXX methods of Statement to get OUTparameters, return value  
  16. string msg = stmt->getString(1);//function return value  
  17. string newstatus = stmt->getString(3);//IN OUT parameter  
  18. float bonus = stmt->getFloat(4); //OUT parameter  

 

步骤四：错误处理
OCCI使用C++异常机制来返回所有的错误信息
应用程序中应该使用try-catch结构来处理异常
抛出的异常属于SQLException类型，该类型继承自标准C++中的exception类
可以使用getErrorCode和getMessage方法来获取Oracle的错误信息

示例：

分别处理Oracle和C++ STL错误

 

 

[cpp] view plaincopy
 
  1. try  
  2. {  
  3.    ResultSet *rs = stmt->executeQuery();  
  4.    while (rs->next())  
  5.    ……….  
  6. }  
  7. catch (SQLException &oraex) //Oracle/OCCI errors  
  8. {  
  9.   int errno = oraex->getErrorCode();//returns the ORA number  
  10.   string errmsg = oraex->getMessage();  
  11.   //more application error handling  
  12. }  
  13. catch (exception &ex) //any other C++/STL error  
  14. {  
  15.   cout << “Error “ << ex.what() << endl;  
  16. }  


联系
我们