C++ Oracle occi 编程

转自：http://blog.sina.com.cn/s/blog_53a72add01015zj4.html

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
#include //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<getString(3)<                 }
                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)”)

其中：:一、: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类包含如下方法：

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

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

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

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

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

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

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

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

九、 setNull();设置为空。
4.9. Number类

Number类包含如下经常使用方法：

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

二、 floor();向下取整。

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

2二、             setNull();设置为空。

2三、             trunk();取整。
5.  附录：代码示例
5.1. 查询流程处理示例

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

 

#include

#include

 

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

#include

 

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

#include

 

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 !"<

       //cout<<"getMaxIterations = "<getMaxIterations()<

       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 <

    

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

       }

       

       cout<<"getMaxIterations ="<getMaxIterations()<

      

           cout<<"setsuccess"<

           inum = m_stmt->executeUpdate();

           m_conn->commit();

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

    }catch (SQLException ex) {

           inum = m_stmt->getUpdateCount();

           cout << "ON" <

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

           cout << ex.getMessage() <

           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

#include

 

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 <

          

           while (rs->next(numrows)) {

                  isnum = rs->getNumArrayRows();

               cout << " isnum = "<< isnum <

                 

                  for(i=0;i

              {

                  vsno[ipos] = isno[i];

                  vsname[ipos] = sname[i];

                  ipos = ipos+1;

              }

           }

       ilnum = rs->getNumArrayRows();

           cout << " ilnum = "<< ilnum <

           for(i=0;i

       {

           vsno[ipos] = isno[i];

           vsname[ipos] = sname[i];

           ipos = ipos+1;

       }

       

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

       for(i=0;i

       {

           cout<

       }

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

          

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

    }catch (SQLException ex) {

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

           cout << ex.getMessage() <

    }

   

   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

#include

 

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 !"<

       //cout<<"getMaxIterations = "<getMaxIterations()<

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

       {

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

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

    

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

       }

       

       cout<<"getMaxParamSize = "<getMaxParamSize(2)<

       cout<<"getMaxIterations ="<getMaxIterations()<

 

           cout<<"setsuccess"<

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

           conn->commit();

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

    }catch (SQLException ex) {

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

           cout << ex.getMessage() <

           conn->rollback();

    }

   

   conn->terminateStatement(stmt);

   env->terminateConnection(conn);

   Environment::terminateEnvironment(env);

   

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

   return 1;

}