otl_cursor::direct_exec

              (

              g_db,

              szBuf,

              otl_exception::disabled // 禁用异常功能

              );

         g_db.commit();

     }

     catch(otl_exception& p)

     {                

         cerr<<p.msg<<endl; // print out error message 

         cerr<<p.stm_text<<endl; // print out SQL that caused the error 

         cerr<<p.sqlstate<<endl; // print out SQLSTATE message 

         cerr<<p.var_info<<endl; // print out the variable that caused the error       

         return 1;

     }

     printf("删除表:%s/n",sztb);

     return 0;

}

/************************************************************************/

/*普通存储过程

/************************************************************************/

void procedure_normal(void)

{

     printf(">>>普通存储过程/n");

     try{            

         //

         //创建存储过程        

         otl_cursor::direct_exec

              (

              g_db,

              "CREATE OR REPLACE Procedure procedure_normal(P1 In Number,P2 In Out Varchar2) Is/n"     //注意不要有/r，否则编译不过

              "Begin/n"         

              "P2 := P2 || P1;/n"             

              "End procedure_normal;"

              );

         g_db.commit();                  

         //

         //sql字符串

         char *szsql = "begin "

              "procedure_normal("

              ":1<int,in>,"         

              ":2<char[10240],inout>);"   //通知OTL流动态申请char[n]的缓冲，调用后释放(可换作char[1024*1024*1024/*1G*/]测试观察其内存变化)

                                          //在每次申请10241字节的情况下，循环调用此函数n次后内存都能够被及时回收

                                          //char[]的大小在输入输出时必须保证足够的空间

              "end;";

         //调用存储过程第一个参数为1

         otl_stream o(1,szsql,g_db);              

         int nPara1=999;

         char szPara2[10240] = "参数二";     

         //顺序给输入参数赋值(从左到右)

          o<<nPara1<<szPara2;

         //顺序取出输出参数(从左到右)

         o>>szPara2;

         printf("P1=%d/nP2=%s/n",nPara1,szPara2);

         printf("szPara2.Length=%d/n",strlen(szPara2));

     }

     catch(otl_exception& p)

     {                

         cerr<<p.msg<<endl; // print out error message 

         cerr<<p.stm_text<<endl; // print out SQL that caused the error 

         cerr<<p.sqlstate<<endl; // print out SQLSTATE message 

         cerr<<p.var_info<<endl; // print out the variable that caused the error       

     }

}

/************************************************************************/

/*更新记录

/************************************************************************/

void update(void)

{

     printf("更新记录/n");

     try{

         otl_stream 

              o(1, // buffer size

              "UPDATE test_tab "

              "SET f2=:f2<char[32]> "         

              "WHERE f1=:f1<int>",       

              g_db

              );

         o<<"f2 changed"<<0;

     }

     catch(otl_exception& p)

     {                

         cerr<<p.msg<<endl; // print out error message 

         cerr<<p.stm_text<<endl; // print out SQL that caused the error 

         cerr<<p.sqlstate<<endl; // print out SQLSTATE message 

         cerr<<p.var_info<<endl; // print out the variable that caused the error       

     }

}

/************************************************************************/

/*删除记录

/************************************************************************/

void del(void)

{

     printf("删除记录/n");

     try{

         otl_stream 

              o(1, // buffer size

              "Delete test_tab "              

              "WHERE f1=:f1<int>",       

              g_db

              );

         o<<1;

     }

     catch(otl_exception& p)

     {                

         cerr<<p.msg<<endl; // print out error message 

         cerr<<p.stm_text<<endl; // print out SQL that caused the error 

         cerr<<p.sqlstate<<endl; // print out SQLSTATE message 

         cerr<<p.var_info<<endl; // print out the variable that caused the error       

     }

}

/************************************************************************/

/*插入记录

/************************************************************************/

void insert(void)

{

     printf("插入数据/n");

     try{    

         //arr_size缓冲区可容纳的记录数,当缓冲满时无论是否调用o.set_flush(false)都将自动提交缓冲

         //缓冲分配得太大则otl需要一次分配很大的内存

         //太小的话缓冲每填满一次就要IO一次

         //也就是时间换空间的概念

         //"insert into test_tab values(:f1<int>,:f2<char[33]>)",

         //OTL将动态申请33字节的内存，调用完成后释放,在insert字符串时这里的char[]需要比数据库中的多一个字节(c/c++中需要有0结束,数据库则不需要0结束)

         otl_stream o(8,    //记录缓冲大小        

              "insert into test_tab values(:f1<int>,:f2<char[33]>)",  //注意这里不要分号

              g_db //数据库连接对象

              );      

         //o.set_flush(false);

         //设置不自动提交流的缓冲区

         //更简洁的做法是设置合理的缓冲区大小，让OTL在缓冲区满的时间自动刷新

         //不是满一条记录就刷新(arr_size=1,这样IO会过于频繁)

         //也不要等到缓冲很大的时候才提交(缓冲将需要动态申请很大的内存，且每次提交数量巨大),比如1024

         char szBuf[33];

         //arr_size=8,实际插入32，缓冲需要刷新4次

         for(int i=0;i<32;i++)

         {

              sprintf(szBuf,"string[%d]",i);

              o<<i<<szBuf;

         }       

         //o.flush()

         //刷新 otl_stream 的缓冲区(获取新的数据或者把数据写到数据库中)       

         //当缓冲区满的时候(缓冲中记录数大于等于otl_stream的第一个参数arr_size)

         //不论是否调用o.set_flush(false); otl_stream也会自动flush,保证数据不会丢失

          //注意sql语句的提交和缓冲区的刷新没有直接关系

         //1.设置了set_flush(false)

         //arr_size=1

         //则缓冲中每满足一条记录就自动刷新一次到数据库

         //若arr_size=1024,但输入输出的记录数只有512，则所有语句在输入到流后也不会自动提交

         //必须使用flush()手动刷新缓冲

         //2.设置自动刷新缓冲set_flush(true)默认

         //arr_size=2048,实际插入1024,则在1024条记录输入到流完成后OTL将自动刷新缓冲    

     }

     catch(otl_exception& p)

     {                

         cerr<<p.msg<<endl; // print out error message 

         cerr<<p.stm_text<<endl; // print out SQL that caused the error 

         cerr<<p.sqlstate<<endl; // print out SQLSTATE message 

         cerr<<p.var_info<<endl; // print out the variable that caused the error       

     }

}

/************************************************************************/

/*查询记录

/************************************************************************/

void select(void)

{

     printf("查询数据/n");

     try{

         otl_stream i(5, //stream buffer size can be > great 1 on SELECT.                        

              "select f1, f2 from test_tab",      

              g_db

              );

         int f1;

         char f2[32];      

         while(!i.eof())

         {

              i>>f1>>f2;

              printf("f1=%d/tf2=%s/n",f1,f2);                        

         }            

     }

     catch(otl_exception& p)

     {                

         cerr<<p.msg<<endl; // print out error message 

         cerr<<p.stm_text<<endl; // print out SQL that caused the error 

         cerr<<p.sqlstate<<endl; // print out SQLSTATE message 

         cerr<<p.var_info<<endl; // print out the variable that caused the error       

     }

}

/************************************************************************/

/*连接数据库

/************************************************************************/

int connect(const char *szConnectstring)

{

     //初始化

     //threaded_mode=1表示运行在多线程环境

     otl_connect::otl_initialize(1);

     try

     {                 

         //Oracle登陆字符串形如:username/password@servicename

         //0-sql不自动提交

         g_db.rlogon(szConnectstring,0);

     }

     catch(otl_exception& p)

     {         

         cerr<<"connect failed!"<<endl;

         cerr<<p.msg<<endl; // print out error message 

         cerr<<p.stm_text<<endl; // print out SQL that caused the error 

         cerr<<p.sqlstate<<endl; // print out SQLSTATE message 

         cerr<<p.var_info<<endl; // print out the variable that caused the error 

         return 1;

     }

     cout<<"数据库连接成功"<<endl;

     return 0;

}

/************************************************************************/

/*断开数据库

/************************************************************************/

void disconnect()

{   

     g_db.logoff();

     cout<<"连接断开"<<endl;

}

/************************************************************************/

/*

返回游标和字符串数组的存储过程                                         

关于使用otl调用返回游标的存储过程示例可参考

http://otl.sourceforge.net/otl4_ex153.htm

http://otl.sourceforge.net/otl4_ex150.htm

/************************************************************************/

void procedure_cursor()

{

     printf(">>>返回游标和字符串数组的存储过程/n");

     //

     // 创建包

     otl_cursor::direct_exec

         (g_db,

         "CREATE OR REPLACE PACKAGE my_pkg IS "

         " "

         "  TYPE my_cursor IS REF CURSOR; "             //定义游标类型

         "  TYPE my_tab IS TABLE OF VARCHAR2(100) INDEX BY BINARY_INTEGER;"    //定义表类型my_tab

         " "

         "  PROCEDURE my_proc "

         "    (f1_in IN NUMBER, "

         "     f2_in IN NUMBER, "

         "     str1 OUT my_tab, "

         "     cur1 OUT my_cursor, "

         "     cur2 OUT my_cursor); "

         " "

         "END; "

         );

     otl_cursor::direct_exec

         (g_db,

         "CREATE OR REPLACE PACKAGE BODY my_pkg IS "

         " "

         "  PROCEDURE my_proc "

         "    (f1_in IN NUMBER, "

         "     f2_in IN NUMBER, "

         "     str1 OUT my_tab, "

         "     cur1 OUT my_cursor, "

         "     cur2 OUT my_cursor) "

         "  IS "

         "    lv_cur1 my_cursor; "

         "    lv_cur2 my_cursor; "

         "  BEGIN "

         "    FOR i IN 1..7 LOOP "

         "      str1(i) := 'Line'||i; "

         "    END LOOP; "

         "    str1(8) := NULL; "

         "    OPEN lv_cur1 FOR "

         "      SELECT * FROM test_tab "

         "      WHERE f1>=f1_in  "

         "        AND f1<=f1_in*2; "

         "    OPEN lv_cur2 FOR "

         "      SELECT * FROM test_tab "

         "      WHERE f1>=f2_in  "

         "        AND f1<=f2_in*2; "

         "    cur1 := lv_cur1; "

         "    cur2 := lv_cur2; "

         "  END; "

         "   "

         "END; "

         );

     //

     otl_stream i(1, // buffer size

         "begin "

         " my_pkg.my_proc(:f1<int,in>,:f2<int,in>, "

         "         :str1<char[100],out[200]>, "//告诉otl申请内存的大小为char[200][100]

         // :str1 is an output PL/SQL table of strings parameter

         "         :cur1<refcur,out[50]>, "

         "         :cur2<refcur,out[50]>); "

         // :cur1, :cur2 are a bind variable names, refcur -- their types,

         // out -- output parameter, 50 -- the buffer size when this(otl_refcur_stream的记录缓冲数，满50即将流提交一次)

         // reference cursor will be attached to otl_refcur_stream

         "end;", // PL/SQL block that calls a stored procedure

         g_db // connect object

         );

     i.set_commit(0); // set stream "auto-commit" to OFF.

     otl_cstr_tab<200,101> str1; // PL/SQL table of char[200][101],用来存储返回记录的内存

     float f1;

     char f2[33];

     otl_refcur_stream s1, s2; // reference cursor streams for reading rows.

     i<<8<<4; // assigning :f1 = 8, :f2 = 4

     i>>str1; // reading :str1 from the stream

     i>>s1; // initializing the refeence cursor stream with the output

     // reference cursor :cur1

     i>>s2; // initializing the refeence cursor stream with the output

     // reference cursor :cur2

     cout<<"STR1_Len="<<str1.len()<<endl;

     for(int j=0;j<str1.len();++j)

         if(str1.is_null(j))

              cout<<"STR1["<<j<<"]=NULL"<<endl;

         else

              cout<<"STR1["<<j<<"]="<<str1.v[j]<<endl;

     cout<<"=====> Reading :cur1..."<<endl;

     while(!s1.eof()){ // while not end-of-data

         s1>>f1>>f2;

         cout<<"f1="<<f1<<", f2="<<f2<<endl;

     }

     cout<<"=====> Reading :cur2..."<<endl;

     while(!s2.eof()){ // while not end-of-data

         s2>>f1>>f2;

         cout<<"f1="<<f1<<", f2="<<f2<<endl;

     }

     s1.close(); // closing the reference cursor

     s2.close(); // closing the reference cursor

}

5.    参考资料

l         OTL官网：http://otl.sourceforge.net/

l         《OTL编程简介.doc》

l         《在跨平台的C++程序中使用OTL来操作不同的数据库》http://blog.csdn.net/roger_77/archive/2006/03/23/633132.aspx#965082

l         BrantDna的博客：http://blog.csdn.net/BrantDna/archive

"OTL资料简编"是由电脑编程网整理，请尊重作者权益，转载注明出处；

• Eclipse 常用快捷键
• Java新手的通病[5]：不了解JVM
• ActionMessage 与ActionErrors
• Windows下JDK环境变量的设置
• struts-config.xml配置文件
• XMLHttpRequest编写AJAX应用步骤
• 搜索文本内容——Java代码的简单实现(修改版)
• Openfire Connection Manager 配置
• 一个简单的实现不同权限的用户登录后看到不同的菜单设计的数据库表清单
• MySQL中文乱码问题解析
• Java编程那些事儿98——多线程问题及处理1
• 关于参数传递
• 在weblogic 8.x中快速部署工程
• MD5(Java版)
• c# 自定用户控件配置（两种情况）
• AfxGetApp用法
• XML Form Generator: 由Xml生成Form表单
• .NET StringBuilder跟String的区别
• DbCommand 参数
• 初窥SOCKET
• 不能在Validating时弹出有模式的对话框
• 纯C#打造WPF游戏引擎系列高级教程(WPF game course)之：(三)让物体动起来
• petshop4中profile的配置
• ASP.NET 数据绑定 Web 服务器控件概述
• 纯C#打造WPF游戏引擎系列高级教程(WPF game course)之：(六)完美移动
• [实践笔记]grub引导手工安装winPE到移动硬盘
• Head First C# 中文版 第九章 读写文件 page434
• 系统数据库灾难恢复
• 依赖自动统计对性能的影响
• EIR软件(高校版)--中国高校教育管理的首选软件