来源：http://blog.csdn.net/gumingyaotangwei/article/details/7337893

OCCI数据库Oracle编程步骤
1．配置环境
（1） Occi访问数据库需要occi.h头文件，此文件在oracle安装目录下，必须有oracle库的支持。安装oracle服务端或客户端；
（2）配置NLS_LANG环境变量，必须与数据库的字符编码一致，否则可能出现中文乱码；
（3）配置环境变量，使客户端支持中文显示；
（4）安装C++编程工具和g++编译工具。
2．编写C++程序
（1） Environment类创建occi环境变量；
（2） Environment类下的createConnection方法创建连接数据库的Connection对象；
（3） Statement类创建对象，由数据库连接对象调用createStatement方法创建；
（4） Statement类创建对象调用setSQL（）准备SQL语句；
（5） Statement类创建对象调用execute()或executeUpdate（）或executeQurey()或executeArrayUpdate（）方法执行查询，如果是查询的，创建ResultSet对象接收数据集；如果是数据更新回插入：Statement:: setAutoCommit (TRUE); 设置自动提交；Statement::setAutoCommit(FALSE); 设置手动提交，手动提交：Connection::commit();Connection::rollback();
（6） Statement类创建对象调用getxxx()方法获取字段数据；
（7） terminateStatement()终止Statement对象；
（8） terminateConnection()断开数据库连接；
（9） Environment::terminateEnvironment()终止环境变量。

#include <iostream>
#include <occi.h>//occi头文件
//声明命名空间
using namespace oracle::occi;
using namespace std;int main ()
{Environment *env; Connection *conn; Statement *stmt;ResultSet *rs;string username = "system";//用户名string password = "st1234";//密码string connstring = "orcl";//数据库连接字符串string sql,strname;int isno;env = Environment::createEnvironment();//创建环境变量conn = env->createConnection(username,password,connstring); //创建数据库连接对象stmt = conn->createStatement();//创Statement对象sql = " SELECT u_id,u_name,to_char(u_date,'yyyy-mm-dd hh24:mi:ss') FROM student";stmt->setSQL(sql);//准备SQL语句try{rs =  stmt->executeQuery();//执行SQL语句，返回结果集while (rs->next()) //取数据{isno = rs->getInt(1);strname=rs->getString(2); cout<< isno << "  AND  " << strname << endl;cout<<rs->getString(3)<<endl;}cout <<"SELECT  SUCCESS" << endl;} catch(SQLException ex) //异常处理{cout << " Error Number "<< ex.getErrorCode() << endl;cout << ex.getMessage() << endl;}conn->terminateStatement(stmt);//终止Statement对象env->terminateConnection(conn);//断开数据库连接Environment::terminateEnvironment(env);// 终止环境变量return 1;
}

3．编写makefile文件
Makefile:
includepath=${ORACLE_HOME}/rdbms/public
libpath=${ORACLE_HOME}/lib
libfile=-L ${libpath} -locci -lclntsh /usr/lib/libstdc++.so.5
incfile=-I ${includepath}

occiselect:select.cpp
g++ -o occiselect select.cpp ${libfile} ${incfile}
clean:
rm occiselect
4．编译程序
Make occiselect.

1. OCCI编程模式

1.1. 总体流程图

编写OCCI程序的总体流程图，如下所示：

1.2. 执行SQL语句的流程图

在OCCI中处理SELECT语句跟处理INSERT、UPDATE、CREATE等语句的方法是不一样的，其中SELECT语句是有返回结果，其它语句没有返回结果，所以必须区分SQL语句是否为查询语句，然后按照各自的流程处理。流程图如下所示：

注：标*号的过程为可选项

2. 流程图具体说明

2.1. 创建与终止OCCI环境变量

创建OCCI环境变量

Environment类是OCCI程序的基础类，所有的OCCI对象的建立都是依计Environment对象来创建的，所以Environment对象的建立必须放在第一位，而且也必须是最后一个被终止的。例如：首先创建一个Environment对象env，然后通过env创建一个Connection对象conn，conn是连接了数据库的对象；终止时，却反过来先终止对象conn，再终止对象env。具体Environment对象的创建方法如下所示：

Environment *env = Environment::createEnvironment();

注意：createEnvironment()方法有以下几个参数模式：

1．在线程环境中运行分为互斥线程(THREADEC_MUTEXED)、并行线程(THREADEC_UMMUTEXED)。

2．使用对象（OBJECT）。

3．利用共享数据结构（SHARED）。

终止OCCI环境变量

Environment对象的终止必须是放在最后一位，即等所有其它OCCI对象被终止完后再终止Environment对象。终止Environment对象的方法如下所示：

Environment::terminateEnvironment(env);

2.2. 连接与断开数据库

连接数据库

创建完一个Environment对象env后，可以调用Environment类下的方法createConnection()来创建一个Connection对象conn；通过createConnection()方法我们可以连接到任意一个数据库中。连接数据库的具体方法如下所示：

Connection *conn = env->createConnection(usename,password,[connectionstring]);

参数说明：usename是登录数据库的用户名；

password是登录数据库用户的密码；

connectstingr是数据库的连接串(可选)。

断开数据库

当对数据库操作完成之后，我们必须断开程序与数据库的连接，断开数据库的连接方法与创建的方法一样来自Environment类下的terminateConnection()函数。方法如下所示：

env->terminateConnection(conn);

2.3. 创建与断开连接池

创建连接池

对于很多共享服务器或中间层应用程序而言，数据库的连接必须要能被许多线程所使用，如果为每个线程都开一个数据库连接的话，当数量一大效率会明显的降低，所以我们通过创建连接池来处理这样的情况。创建完一个Environment对象env后，可以调用Environment类下的方法createConnectionPool()来创建一个Connection对象connPool；通过createConnectionPool()方法我们可以连接到任意一个数据库中。连接池创建的具体方法如下所示：

ConnectionPool *connPool= env->createConnectionPool(

const string &poolUseName,

const string &poolPassWord,

const string &connectstring,

unsigned int minConn,

unsigned int maxConn,

unsigned int incrConn);

参数说明：poolUseName是连接池的用户名；

poolPassWord是连接数据库的密码；

connectstring是数据库连接串；

minConn是最小连接数；

maxConn是最大连接数；

incrConn是指所有已连接数处于繁忙中且小于最大连接数时，每次增加的连接数。

断开连接池

当对数据库操作完成之后，我们必须断开程序与数据库的连接，断开数据库的连接方法与创建的方法一样来自Environment类下的terminateConnectPool()函数。方法如下所示：

env->terminateConnectPool(connPoll);

2.4. 创建与终止Statement对象

2.4.1. 创建Statement对象

Statement类包含了执行SQL语句的所有方法，是对数据库操作的具体实现。Statement对象stmt的创建是通过调用Connection类下的createStatement()函数实现，所以Statement对象的创建必须是在Connection对象创建之后。createStatement()函数可以带参数或不带参数，如果带参数的话，参数必须是一个SQL语句；如果没有带参数，则在后面必须用Statement类下setSQL()函数为Statement对象赋一个SQL语句。Statement对象的创建方法如下所示：

Statement *stmt = conn->createStatement();

终止Statement对象

当对数据库的操作完成时，我们必须先终止Statement对象，再断开Connection对象。终止Statement对象的方法如下所示：

Conn->terminateStatement(stmt);

3. 执行SQL语句（Statement类）

3.1. 执行SQL语句的方法

执行SQL的所有方法都包含在Statement类下。SQL语句按返回结果分，可以分为两种：一种是有返回值的（查询语句），另外一种是没有返回值的（非查询语句）。一般情况下，在执行查询SQL语句我们使用executeQurey()函数，在执行非查询SQL语句时我们使用executeUpdate()函数。

1． stmt->execute();执行所有非特殊声明的SQL语句。

2． stmt->executeUpdate();执行所有DDL和DML（一条记录）的SQL语句。

3． stmt->executeQurey();执行所有查询SQL语句。

4． stmt->executeArrayUpdate();执行多记录的DML的SQL语句。

例如：

stmt->executeUpdate(“createtable student (sno number(10),sname varchar2)”)；

stmt->executeUpdate(“insertinto student (sno,sname) values(1,’ZHANGSAN’)”);

stmt->executeQurey(“select sno from student ”);

3.2. 执行非查询语句

当我们创建了一个Statement对象stmt后，可以通过Statement类下的方法setSQL()为stmt设置不同的SQL语句。

3.2.1. 准备SQL语句

stmt->setSQL(string &sql)；

例如：

stmt->setSQL(“insertinto student (sno,sname) values(:1,:2)”)

其中：:1、:2是参数，通过给参数赋不同的值来实现。

与之对应的函数getSQL()是取出当前对象对应的SQL语句。

3.2.2. 绑定输入参数值

在Statement类中包含了所有参数的赋值方法，赋值方法set×××(unsignedint paramindex,type values),其中paramindex参数是代表所赋值参数在SQL语句中的第几个参数，×××与type代表中所赋值的类型，values是所赋的值。×××可以是Int、String、Date等等。

例如：

stmt->setString(1,’zhangsan’)；指把’zhangsan’赋值给第一个参数，参数类型为字符串型。

stmt->setInt(2,1009);指把1009赋值给第二个参数，参数类型为整型。

3.2.3. 执行非查询语句

当SQL语句准备好后，就可以执行SQL语句了，方法如下所示：

stmt->executeUpdate();

3.3. 执行查询语句（SELECT）

在执行查询语句时有返回查询结果（可能是一条，也可能是多条），我们必须创建一个ResultSet对象来处理，通过使用ResultSet对象的next()方法我们可以一条一条（或批量）地处理结果集。具体使用如下所示：

3.3.1. 准备SQL语句

详见3.2.1。

3.3.2. 绑定输入参数值

详见3.2.2。

3.3.3. 执行查询语句

ResultSet *rs = stmt->executeQuery();

3.3.4. 定义输出变量

根据SELECT语句查询的列的类型定义对应的变量，此变量用于存储SELECT查询的结果集。

3.3.5. 推进或处理数据

如果结果集为多条记录，我们可以批量或者一条条处理数据，使用ResultSet类下的方法next(unsigned int numRows)。

在Statement类中包含了所有参数的取值方法。取值方法get×××（unsignedint paramindex），其中paramindex参数是代表所取值列在SQL语句中的第几列，×××代表该列对应的类型。×××可以是Int、String、Date等等。

例如：

rs->next(unsignedint numRows);//其中numRows为批量处理的记录行数。

stmt->getInt(paramindex);获取整型参数值,其中paramindex为参数所在的位置；

stmt->getString(paramindex);获取字符型参数值其中paramindex为参数所在的位置；

3.4. 输出参数声明

在调用存储过程时，有时候有返回参数，这些返回参数都必须在调用之前先用Statement类下的registerOutParam()方法声明，声明方法的使用如下所示：

stmt->registerOutParam(paramName,paramType,paramSize);

其中：paramName是参数名或者参数所在位置；

paramType是参数类型（比如：TYPE::OCCIINT）；

paramSize是参数的大小。

3.5. 事务提交

3.5.1. 手动提交

当事务的提交设置为手动时，每完成一个事务我们都必须调用Connection类下的commit()或rollback()方法来提交一个事务。使用方法如下所示：

手动提交必须调用以下函数：

Connection::commit();

Connection::rollback();

3.5.2. 自动提交

在对数据库进行操作的过程中，一个事务的提交是用手动还是自动，我们可以调用Statement类下的setAutoCommit()方法来设置。使用方法如下所示：

设置自动提交：

Statement:: setAutoCommit (TRUE);

设置手动提交：

Statement::setAutoCommit(FALSE);

4. OCCI常用类简要介绍

4.1. Environment类

Environment类提供了管理OCCI对象的内存及其它资源的一个环境,包含以下方法：

1． createConnection(const stringusename,const string password,const string connstring);指与数据库建立一个连接。

2． createConnectionPoll(

const string &poolUseName,

const string &poolPassWord,

const string &connectstring,

unsigned int minConn,

unsigned int maxConn,

unsigned int incrConn); 创建连接池。

参数说明：poolUseName是连接池的用户名；

poolPassWord是连接数据库的密码；

connectstring是数据库连接串；

minConn是最小连接数；

maxConn是最大连接数；

incrConn是指所有已连接数处于繁忙中且小于最大连接数时，每次增加的连接数。

3． createEnironment(Mode mode );创建一个环境对象，其中mode是模式（可选DEFAULT、THREADED_MUTEXED、THREADED_UN-MUTEXED、OBJECT、SHARED值）。

4． getCurrentHeapSize();指在同一环境下已经分配的内存数。

5． getOCIEnironment();返回一个OCI环境指针。

6． terminateConnection(Connection*conn);断开与数据库的连接。

7． terminateConnection(ConnectionPool*poolconn);断开与数据库的连接池。

8． terminateEnironment(Einironment *env);终止OCCI环境变量。

4.2. Connection类

Connection类提供了C++程序与指定数据库的连接，包含以下方法：

1． changePassword(const string&user,const string &oldPassword,const string &newPassword);改变当前用户的密码。

2． Commit();提交事务。

3． createStatement(const string&sql=””);创建一个Statement对象。

4． flushCache();

5． rollback();事务的回滚。

6． terminateStatement(Statement*stmt).终止一个Statement对象，并释放它占有的所有资源。

4.3. ConnectionPool类

ConnectionPoll类提供了C++程序与指定数据库间的连接池，包含以下方法：

1． createConnection(const string&username,const string &password);创建一个连接。

2． getBusyConnections();返回连接池中被占用的连接数量。

3． getMaxConnections();返回连接池的最大连接数。

4． getMinConnections();返回连接池的最小连接数。

5． getOpenConnections();返回连接池中已经被打开的连接数。

6． getPollName();返回连接池的名称。

7． getTimeOut();返回连接池的超时时间。

8． setErrorOnBusy();设置异常，当连接池处于繁忙或达到最大连接数后。

9． serPoolSize(unsigned intminConn,unsigned int maxConn,unsigned int incrConn);设置连接池的大小，其中参数minConn是最小连接数，maxConn是最大连接数，incrConn是递增连接数。

10． setTimeOut();设置超时时间。

11． terminateConnection(Connection *conn);断开连接。

4.4. Statement类

Statement对象主要被用来执行SQL语句，它可以运行一个查询语句返回一个结果集也可以运行UPDATE、DELETE等SQL语句。

1． addIteration();增加一个循环。

2． closeResultSet(ResultSet *rs);关闭一个结果集。

3． closeStream(Stream *stream);关闭一个已定义的流。

4． execute(const string &sql =“”);执行一个SQL语句，如果前面使用的setSQL()方法，则参数sql可以为空。

5． executeArrayUpdate(unsigned intarrayLength);同时修改多条记录，前面必须使用了setDataBuffer()方法设置一个数量或设置了一个流（stream）。

6． executeQuery();执行一个查询语句。

7． executeUpdate();执行DDL、DML语句，如：INSERT、UPDATE、DELETE、CREATE等等。

8． getAutoCommit();返回是否事务自动提交。

9． getDate(unsigned int paramindex);返回DATE型数据。

10． getDouble(unsigned intparamindex);返回DOUBLE型数据。

11． getFloat(unsigned int paramindex);返回FLOAT型数据。

12． getInt(unsigned intparamindex);返回INT型数据。

13． getNumber(unsigned intparamindex);返回NUMBER型数据。

14． getRef(unsigned intparamindex);返回REF参数值。

15． getResultSet();得到一个结果集（ResultSet）。

16． getSQL();返回当前的SQL语句。

17． getString(unsigned intparamindex);返回STRING型数据。

18． getUpdateCount();返回被更新的数量。

19． isNull(unsigned intparamindex);判断第X个值是否为空。

20． isTruncated(unsigned intparamindex);判断第X个值是否被截取。

21． setAutoCommit(bool autocommit);设置事务是否自动提交。

22． setDouble(unsigned intparamindex,double x);赋一个double型的值。

23． setFloat(unsigned intparamindex,float x);赋一个float型的值。

24． setInt(unsigned intparamindex,int x);赋一个INT型的值。

25． setNull(unsigned intparamindex,TYPE type);某参数设置为空。

26． setNumber(unsigned intparamindex,const number &x);赋一个Number型的值。

27． setObject(unsigned intparamindex,PObject *x);赋一个PObject型的值。

28． setString(unsigned intparamindex,const string &x);赋一个string型的值。

29． setSQL(const string &sql);设置一个SQL语句。

30． Status();返回当前的状态。

4.5. ResultSet类

ResultSet类是查询数据表的结果集，它包含以下方法：

1． cancel();取消结果集。

2． closeStream(Stream *stream);关闭一个流。

3． getDouble(unsigned intcolIndex);返回double型的值。

4． getFloat(unsigned intcolIndex);返回float型的值。

5． getInt(unsigned int colIndex);返回int型的值。

6． getMaxColumnSize(unsigned intcolIndex);返回某列包含的数据量。

7． getNumber(unsigned intcolIndex);返回number型的数据。

8． getPObject(unsigned intcolIndex);返回PObject型的数据。

9． getRowid(unsigned intcolIndex);返回rowid值。

10． getString(unsigned intcolIndex);返回string型的数据。

11． isNull(unsigned int colIndex);判断值是否为空。

12． isTruncated(unsigned intcolIndex);判断值是否被删。

13． next(unsigned int numRows);取下numRows条记录。

14． status();返回当前状态。

4.6. PObject类

PObject类包含以下方法：

1． fush();

2． Connection *getConnection();从一个实例化的永久对象中返回连接。

3． isLocked();判断永久对象是否被锁（TRUE或FALSE）。

4． isNull();判断永久对象是否为空（TRUE或FALSE）。

5． Lock(PObject::LockOption lock_option);在数据库中锁住一个对象，其中lock_option取值为OCCI_LOCK_WAIT、OCCI_LOCK_NOWAIT。

6． markDelete();删除数据库中的永久对象。

7． markModified();修改永久对象。

8． PObject &operator(constPObject &obj);赋值（对象）。

9． operator delete(void*obj,size_t size);删除对象，但不能删除数据库中的对象。

10． *operator new(size_t size);创建临时对象。

11． *operator new(size_t size,constConnection *x,const string &tablename,const char *type_name);创建永久对象。

12． pin();

13． setNull();设置对象为空。

14． unmark();不标记永久对象为删除或修改。

15． unpin(UnpinOption mode);其中，mode的取值为OCCI_PINCOUNT_RESET、OCCI_PINCOUNT_DECR。

4.7. SQLException类

SQLException类提供错误代码及其错误信息，包含以下方法：

1． getErrorCode();返回数据库中的错误编码。

2． getMessage();返回错误信息，没有则为空。

4.8. Date类

Date类包含以下方法：

1、 addDays(int i);返回增加i天后的日期。

2、 addMonths(int i);返回增加i个月后的日期。

3、 intervalDS daysBetween(constDate &d);返回与d相差的天数。

4、 getDate(int &year,unsignedint &month,unsigned int &day,unsigned int &hour,unsigned int&minute,unsigned int &second );返回分年月日小时分秒格式。

5、 getSystemDate(const Environment*env);返回系统日期。

6、 isNull();判断是否为空；

7、 lastDay();返回当月的最后一天日期。

8、 setDate(int&year=1,unsigned int &month=1,unsigned int &day=1,unsigned int&hour=0,unsigned int &minute=0,unsigned int &second=0);设置日期值。

9、 setNull();设置为空。

4.9. Number类

Number类包含以下常用方法：

1、 abs();返回绝对值。

2、 floor();向下取整。

3、 isNull();判断是否为空。

4、 operator+(const Number&a,const Number &b);两数相加。

5、 operator-( const Number&a,const Number &b);两数相减（a-b）。

6、 operator*(const Number&a,const Number &b);两数相乘。

7、 operator/(const Number&a,const Number &b);两数相除。

8、 operator%(const Number&a,const Number &b);求余。

9、 operator<(const Number&a,const Number &b);a是否小于b。

10、 operator<=(const Number&a,const Number &b);a是否小于等于b。

11、 operator>(const Number&a,const Number &b);a是否大于b。

12、 operator>=(const Number&a,const Number &b);a是否大于等于b。

13、 operator==(const Number&a,const Number &b);a与b是否相等。

14、 operator!=(const Number&a,const Number &b);判断a是否不等于b。

15、 operator char();将number型转化为char型。

16、 operator signed char();将number型转化为有符号char型。

17、 operator double();将number型转化为double型。

18、 operator float();将number型转化为float型。

19、 operator int();将number型转化为int型。

20、 operator long();将number型转化为long型。

21、 operator short();将number型转化为short int型。

22、 setNull();设置为空。

23、 trunk();取整。

5. 附录：代码示例

5.1. 查询流程处理示例

下面给出了一个查询的例子qrystudent.cpp，通过使用OCCI接口函数查询数据库表student的信息（学号，学生姓名）。

#include <iostream>

#include <occi.h>

using namespace oracle::occi;

using namespace std;

int main ()

{

Environment *env;

Connection *conn;

Statement *stmt;

ResultSet *rs;

string username = “ipd”;

string password = “ipd”;

string connstring = “ora9i”;

string sql,strname;

int isno;

env = Environment::createEnvironment(); //创建一个环境变量

conn = env->createConnection(username,password,connstring);//创建一个数据库连接对象

stmt = conn->createStatement(); //创建一个Statement对象

sql = “ SELECT sno,sname FROM student “; //拼接一个SQL语句

stmt->setSQL(sql); //设置SQL语句到Statement对象中

try {

rs= stmt->executeQuery();//执行SQL语句

while(rs->next()) { //用循环，一条一条地取得查询的结果记录

isno= rs->getInt(1);//取出第一列的值（对应为int型）

strname=rs->getString(2);//取出第二列的值（对应为string型）

cout<< isno << “ AND “ << strname << endl;

}

cout<< “SELECT ―― SUCCESS”<< endl;

} catch (SQLException ex) {

cout<< “ Error Number : “<< ex.getErrorCode() << endl; //取出异常代码

cout<< ex.getMessage() << endl; //取出异常信息

}

conn->terminateStatement(stmt); //终止Statement对象

env->terminateConnection(conn); //断开数据库连接

Environment::terminateEnvironment(env); //终止环境变量

return 1;

}

5.2. 非查询流程处理示例

下面给出了一个insert例子inserttab.cpp，通过使用OCCI接口函数往数据库表student中插入信息（学号，学生姓名）。

#include <iostream>

#include <occi.h>

using namespace oracle::occi;

using namespace std;

int main ()

{

Environment *env;

Connection *conn;

Statement *stmt;

string username = “ipd”;

string password = “ipd”;

string connstring = “ora9i”;

string sql;

env = Environment::createEnvironment(); //创建一个环境变量

conn =env->createConnection(username,password,connstring); //创建一个数据库连接对象

stmt = conn->createStatement(); //创建一个Statement对象

sql = “ INSERT INTO student(sno,sname) VALUES ( :x,:y) “; //拼接SQL语句

stmt->setSQL(sql); //设置SQL语句到Statement对象中

try {

stmt->setInt(1,10001);//给第一个参数x赋值

stmt->setString(2,”zhangsan”);//给第二个参数y赋值

stmt->executeUpdate();//执行SQL语句

cout<< “INSERT ―― SUCCESS”<< endl;

} catch (SQLException ex) {

cout<< “ Error Number : “<< ex.getErrorCode() << endl; //获得异常代码

cout<< ex.getMessage() << endl; //获得异常信息

}

conn->terminateStatement(stmt); //终止Statement对象

env->terminateConnection(conn); //断开数据库连接

Environment::terminateEnvironment(env); //终止环境变量

return 1;

}

5.3. 批量处理非查询语句

在批量处理非查询语句时，首先必须使用m_stmt->setMaxIterations(unsigned int maxnum)方法设置最大的批处理数；然后使用setMaxParamSize(unsignedint paramindex,int paramsize)方法设置对应参数的大小，对于有固定长度的参数可以不必重新设置，如int,double；最后循环绑定参数使用set×××()方法，每循环一次必须使用addIteration()方法再进行下一次循环，直到最后一次。例子如下所示：

#include <iostream>

#include <occi.h>

using namespace oracle::occi;

using namespace std;

int main ()

{

Environment *env;

Connection *conn;

Statement *stmt;

string username = "bill";

string password = "bill";

string connstring = "jftest";

string sql;

intisno[2]={21,22},i,iage[2]={18,19};

stringcsname[2]={"namea","nameb"};

try {

env = Environment::createEnvironment();

conn = env->createConnection(username,password,connstring);

stmt = conn->createStatement();

stmt->setAutoCommit(false);

sql = " INSERT INTO student (sno,sname,age) VALUES (:x,:y,:z) ";

m_stmt->setSQL(sql);

m_stmt->setMaxIterations(2);

m_stmt->setMaxParamSize(1,sizeof(int));

m_stmt->setMaxParamSize(2,sizeof(string));

m_stmt->setMaxParamSize(3,sizeof(int));

cout<<"setMaxIterations success !"<<endl;

//cout<<"getMaxIterations = "<<m_stmt->getMaxIterations()<<endl;

for (i=0;i<2;i++)

{

m_stmt->setInt(1,isno[i]);

m_stmt->setString(2,csname[i]);

m_stmt->setInt(3,iage[i]);

//cout <<isno[i]<< " and " <<csname[i]<< " and " << iage[i] <<endl;

if (i!=1) m_stmt->addIteration();

}

cout<<"getMaxIterations ="<<m_stmt->getMaxIterations()<<endl;

cout<<"setsuccess"<<endl;

inum = m_stmt->executeUpdate();

m_conn->commit();

cout << "INSERT ¨D¨DSUCCESS" << endl;

}catch (SQLException ex) {

inum = m_stmt->getUpdateCount();

cout << "ON" <<inum+1 << " shi fail !" << endl;

cout << " INSERT Error Number: "<< ex.getErrorCode() << endl;

cout << ex.getMessage() <<endl;

m_conn->rollback();

return 0;

}

conn->terminateStatement(stmt);

env->terminateConnection(conn);

Environment::terminateEnvironment(env);

cout << "PROGRAM IS END ." << endl;

return 1;

}

5.4. 查询语句中批量取数

在批量取数时，使用setDataBuffer（）方法来设置接收数据缓冲区大小，例子如下所示：

#include <iostream>

#include <occi.h>

using namespace oracle::occi;

using namespace std;

int main ()

{

Environment *env;

Connection *conn;

Statement *stmt;

ResultSet *rs;

string username = "bill";

string password = "bill";

string connstring = "jftest";

string sql;

int i,numrows=5,isnum,ilnum,ipos=0;

int isno[5],vsno[20],ii=0,x[20];

ub2 isnolen[5],snamelen[5];

char sname[5][20],vsname[20][20];

for (i=0;i<20;i++)

{

isnolen[i]=sizeof(isno[i]);

snamelen[i]=strlen(sname[i]+1);

}

cout << "PROGRAM START ..." << endl;

try {

env = Environment::createEnvironment();

conn = env->createConnection(username,password,connstring);

stmt = conn->createStatement();

sql = " SELECT sno,sname FROM student ";

stmt->setSQL(sql);

rs = stmt->executeQuery();

rs->setDataBuffer(1,isno,OCCIINT,sizeof(int));

rs->setDataBuffer(2,sname,OCCI_SQLT_STR,sizeof(sname[0]),snamelen);

ilnum = rs->getNumArrayRows();

cout << " ilnum = "<< ilnum <<endl;

while (rs->next(numrows)) {

isnum = rs->getNumArrayRows();

cout << " isnum = "<< isnum <<endl;

for(i=0;i<numrows;i++)

{

vsno[ipos] = isno[i];

vsname[ipos] = sname[i];

ipos = ipos+1;

}

ilnum = rs->getNumArrayRows();

cout << " ilnum = "<< ilnum <<endl;

for(i=0;i<ilnum-isnum;i++)

{

vsno[ipos] = isno[i];

vsname[ipos] = sname[i];

ipos = ipos+1;

}

cout << "SELECT RESULT IS ..." << endl;

for(i=0;i<ilnum;i++)

{

cout<<vsno[i]<<" AND"<<vsname[i]<<endl;

}

cout << "SELECT RESULT END !" << endl;

cout << "SELECT ¨D¨DSUCCESS" << endl;

}catch (SQLException ex) {

cout << " Error Number :"<< ex.getErrorCode() << endl;

cout << ex.getMessage() <<endl;

}

conn->terminateStatement(stmt);

env->terminateConnection(conn);

Environment::terminateEnvironment(env);

cout << "PROGRAM END !" << endl;

return 1;

}

5.5. MERGE语句的使用

在使用MEGER语句时，USING部分的取值应该使用表或者SELECT param1,param2FROM DUAL,其中param1,param2是常量值，可以通过数组赋值，并且每列值都应该取别名，在后面的使用中就只用别名。例子如下所示：

#include <iostream>

#include <occi.h>

using namespace oracle::occi;

using namespace std;

int main ()

{

Environment *env;

Connection *conn;

Statement *stmt;

string username = "bill";

string password = "bill";

string connstring = "jftest";

string sql;

int isno[2]={21,22},i,iage[2]={18,19};

try {

env = Environment::createEnvironment();

conn = env->createConnection(username,password,connstring);

stmt = conn->createStatement();

stmt->setAutoCommit(false);

sql = " merge into student a ";

sql += " using (select :xbid,:y bage from dual) b ";

sql += " on (a.sno =b.bid) ";

sql += " when matched then";

sql += " update set a.age=a.age+b.bage ";

sql += " when not matchedthen ";

sql += " insert(a.sno,a.age) ";

sql += " values(b.bid,b.bage) ";

stmt->setSQL(sql);

stmt->setMaxIterations(2);

stmt->setMaxParamSize(1,sizeof(int));

//stmt->setMaxParamSize(2,sizeof(string));

cout<<"setMaxIterations success !"<<endl;

//cout<<"getMaxIterations = "<<stmt->getMaxIterations()<<endl;

for (i=0;i<2;i++)

{

stmt->setInt(1,isno[i]);

stmt->setInt(2,iage[i]);

if (i!=1) stmt->addIteration();

}

cout<<"getMaxParamSize = "<<stmt->getMaxParamSize(2)<<endl;

cout<<"getMaxIterations ="<<stmt->getMaxIterations()<<endl;

cout<<"setsuccess"<<endl;

stmt->executeUpdate(); //Ö´ÐÐSQLÓï¾ä

conn->commit();

cout << "INSERT ¨D¨DSUCCESS" << endl;

}catch (SQLException ex) {

cout << " Error Number :"<< ex.getErrorCode() << endl;

cout << ex.getMessage() <<endl;

conn->rollback();

}

conn->terminateStatement(stmt);

env->terminateConnection(conn);

Environment::terminateEnvironment(env);

cout << "PROGRAM IS END ." << endl;

return 1;

}

c++ Oracle OCCI 编程相关推荐

oracle 初始化出错,OCCI编程时，初始化Date种出错
OCCI编程时,初始化Date类出错使用的是Oracle 9i & VC6 下面Date类初始化,在运行时出错,是什么问题 #include #include #include #inclu ...
oracle proc 定义宿主,oracle proc 编程基础及最小化案例
oracle proc 编程是在我的概念中是非常陌生的,学习了一天下来发现这东西真的好古老,但是依然健壮.稳定,其中间是编辑一个 .pc 的文件使用 proc 进行预处理,预处理后生成一个真正的.c文 ...
Oracle学习笔记：oracle的编程接口
不断整理更新中..... 编程接口 OCI:oracle的最底层.最基础.最高效.最复杂的 C++ 编程接口.基础等级为:1(数字越大表示层次越高,通常也越简单.越低效) JDBC:java编程接口. ...
计算机科学与编程基础,国外经典教材·计算机科学与技术：Oracle 10g编程基础
作为Oracle编程基础教材,<国外经典教材·计算机科学与技术:Oracle10g编程基础>力求言简意赅,重点突出.全书共分三部分:第Ⅰ部分引导读者对关系模型的基础知识进行回顾,并介绍Or ...
oracle分区表编程,Oracle分区表详解
当前位置:我的异常网» 编程 » Oracle分区表详解 Oracle分区表详解 www.myexceptions.net 网友分享于:2013-10-28 浏览:25次 Oracle分区表详解 ...
Oracle occi 抓包,instantclient 32下载-instantclient-basic(轻量级数据库)32位 11.2.0.4.0 官方版 - 河东下载站...
instantclient-basic(轻量级数据库)32位是款完全免费的数据库客户端:提高这款软件,您可以不用进行安装标准的客户端,就可以支持您使用OCCI.ODBC程序等,还不要进行修改,就可以正 ...
oracle proc编程 fetch,Oracle Proc编程性能优化经验
Proc 是Oracle提供的一种数据库操做的AP.它是基于ESql技术的,须要预编译后才能够变成普通c代码,很是不直观,使用起来不太方便,阅读也存在困难.程序员由于这些问题致使程序员平时开发中会出 ...
oracle实战编程,Oracle Databa se 11g PL/SQL编程实战_IT教程网
资源名称:Oracle Database 11g PL/SQL编程实战内容简介: <oracle database 11gpl/sql编程实战>通过动手练习.大量的示例以及实际的项目帮助 ...
qt4如何读oracle,Qt4编程的控制MPlayer
本文的重点如何在QT来在GUI控制MPlayer MPlayer 的特殊用法 1.1 通过管道播放视频 mkfifo /tmp/media // 建立管道文件 cat xxx.mpeg &g ...

c++ Oracle OCCI 编程

1. OCCI编程模式

1.1. 总体流程图

1.2. 执行SQL语句的流程图

2. 流程图具体说明

2.1. 创建与终止OCCI环境变量

创建OCCI环境变量

终止OCCI环境变量

2.2. 连接与断开数据库

连接数据库

断开数据库

2.3. 创建与断开连接池

创建连接池

断开连接池

2.4. 创建与终止Statement对象

2.4.1. 创建Statement对象

终止Statement对象

3. 执行SQL语句（Statement类）

3.1. 执行SQL语句的方法

3.2. 执行非查询语句

3.2.1. 准备SQL语句

3.2.2. 绑定输入参数值

3.2.3. 执行非查询语句

3.3. 执行查询语句（SELECT）

3.3.1. 准备SQL语句

3.3.2. 绑定输入参数值

3.3.3. 执行查询语句

3.3.4. 定义输出变量

3.3.5. 推进或处理数据

3.4. 输出参数声明

3.5. 事务提交

3.5.1. 手动提交

3.5.2. 自动提交

4. OCCI常用类简要介绍

4.1. Environment类

4.2. Connection类

4.3. ConnectionPool类

4.4. Statement类

4.5. ResultSet类

4.6. PObject类

4.7. SQLException类

4.8. Date类

4.9. Number类

5. 附录：代码示例

5.1. 查询流程处理示例

5.2. 非查询流程处理示例

5.3. 批量处理非查询语句

5.4. 查询语句中批量取数

5.5. MERGE语句的使用

c++ Oracle OCCI 编程相关推荐

最新文章

热门文章