C++插入ORACLE数据库失败,提示DB_E_ERRORSINCOMMAND错误
[问题点数：80分，结帖人r5311620]
本版专家分：0
结帖率 50%
CSDN今日推荐
本版专家分：0
本版专家分：369999
2017年 总版技术专家分年内排行榜第一
2014年 总版技术专家分年内排行榜第二
2013年 总版技术专家分年内排行榜第三
2012年 总版技术专家分年内排行榜第七
本版专家分：92
2015年12月 VC/MFC大版内专家分月排行榜第二2015年10月 VC/MFC大版内专家分月排行榜第二
本版专家分：0
本版专家分：369999
2017年 总版技术专家分年内排行榜第一
2014年 总版技术专家分年内排行榜第二
2013年 总版技术专家分年内排行榜第三
2012年 总版技术专家分年内排行榜第七
本版专家分：0
匿名用户不能发表回复！
其他相关推荐转自：http://blog.sina.com.cn/s/blog_53a72add01015zj4.htmlOCCI数据库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::int main (){&&&&&&& Environment *&&&&&&& Connection *&&&&&&& Statement *&&&&&&& ResultSet *&&&&&&& string username = "system";//用户名&&&&&&& string password = "st1234";//密码&&&&&&& string connstring = "orcl";//数据库连接字符串&&&&&&& string sql,&&&&&&&&&&&&&& 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 &&&&&&&&&&&&&&&&&&&&&&&&& cout&getString(3)&&&&&&&&&&&&&&&&& }&&&&&&&&&&&&&&& cout &&"SELECT& SUCCESS" &&&&&&&&& }&&&&&&& catch(SQLException ex) //异常处理&&&&&&& {&&&&&&&&&&&&&&& cout && " Error Number "&& ex.getErrorCode() &&&&&&&&&&&&&&&&& cout && ex.getMessage() &&&&&&&&& }&&&&&&& conn-&terminateStatement(stmt);//终止Statement对象&&&&&&& env-&terminateConnection(conn);//断开数据库连接&&&&&&& Environment::terminateEnvironment(env);// 终止环境变量&&&&&&& return 1;}3． 编写makefile文件Makefile:includepath=${ORACLE_HOME}/rdbms/publiclibpath=${ORACLE_HOME}/liblibfile=-L ${libpath} -locci -lclntsh /usr/lib/libstdc++.so.5incfile=-I ${includepath}occiselect:select.cpp&&&&&&& g++ -o occiselect select.cpp& ${libfile} ${incfile}clean:&&&&&&& rm occiselect4． 编译程序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#include&using namespace oracle::&int main (){Environment *Connection *Statement *ResultSet *&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 = “ 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 &&&&&&&& }&&&&&& cout&& “SELECT ―― SUCCESS”&&} catch (SQLException ex) {&&&&&& cout&& “ Error Number : “&& ex.getErrorCode() && //取出异常代码&&&&&& cout&& ex.getMessage() && //取出异常信息}&conn-&terminateStatement(stmt); //终止Statement对象env-&terminateConnection(conn); //断开数据库连接Environment::terminateEnvironment(env); //终止环境变量&return 1;}5.2. 非查询流程处理示例下面给出了一个insert例子inserttab.cpp，通过使用OCCI接口函数往数据库表student中插入信息（学号，学生姓名）。&#include#include&using namespace oracle::&int main (){Environment *Connection *Statement *&string username = “ipd”;string password = “ipd”;string connstring = “ora9i”;&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”&&} catch (SQLException ex) {&&&&&& cout&& “ Error Number : “&& ex.getErrorCode() && //获得异常代码&&&&&& cout&& ex.getMessage() && //获得异常信息}&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::&int main (){&& Environment *&& Connection *&& Statement *& &&& string username = "bill";&& string password = "bill";&& string connstring = "jftest";&&&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" &&&&& }catch (SQLException ex) {&&&&&&&&&& inum = m_stmt-&getUpdateCount();&&&&&&&&&& cout && "ON" &&&&&&&&&&& cout && " INSERT Error Number: "&& ex.getErrorCode() &&&&&&&&&&&& cout && ex.getMessage() &&&&&&&&&&& m_conn-&rollback();&&&&&&&&&& return 0;&&& }& &&& conn-&terminateStatement(stmt);&& env-&terminateConnection(conn);&& Environment::terminateEnvironment(env);& &&& cout && "PROGRAM IS END ." &&&& return 1;}5.4. 查询语句中批量取数在批量取数时，使用setDataBuffer（）方法来设置接收数据缓冲区大小，例子如下所示：#include#include&using namespace oracle::&int main (){&& Environment *&& Connection *&& Statement *&& ResultSet *& &&& string username = "bill";&& string password = "bill";&& string connstring = "jftest";&&&& 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 ..." &&& &&& 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 ..." &&&&&&&& for(i=0;i&&&&&& {&&&&&&&&&& cout&&&&&&& }&&&&&& cout && "SELECT RESULT END !" &&&&&&&&&& &&&&&&&&&&& cout && "SELECT ¨D¨DSUCCESS" &&&&& }catch (SQLException ex) {&&&&&&&&&& cout && " Error Number :"&& ex.getErrorCode() &&&&&&&&&&&& cout && ex.getMessage() &&&& }& &&& conn-&terminateStatement(stmt);&& env-&terminateConnection(conn);&& Environment::terminateEnvironment(env);& &&& cout && "PROGRAM END !" &&&& return 1;}5.5. MERGE语句的使用在使用MEGER语句时，USING部分的取值应该使用表或者SELECT param1,param2FROM DUAL,其中param1,param2是常量值，可以通过数组赋值，并且每列值都应该取别名，在后面的使用中就只用别名。例子如下所示：#include#include&using namespace oracle::&int main (){&& Environment *&& Connection *&& Statement *& &&& string username = "bill";&& string password = "bill";&& string connstring = "jftest";&&&&& 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?? 3/4 ?&&&&&&&&&& conn-&commit();&&&&&&&&&& cout && "INSERT ¨D¨DSUCCESS" &&&&& }catch (SQLException ex) {&&&&&&&&&& cout && " Error Number :"&& ex.getErrorCode() &&&&&&&&&&&& cout && ex.getMessage() &&&&&&&&&&& conn-&rollback();&&& }& &&& conn-&terminateStatement(stmt);&& env-&terminateConnection(conn);&& Environment::terminateEnvironment(env);& &&& cout && "PROGRAM IS END ." &&&& return 1;}
阅读(...) 评论()}