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;

}