[转帖]Tuxedo Quick Start 13 TUXEDO与数据库编程（续）_MQ, Tuxedo及OLTP讨论区_Weblogic技术|Tuxedo技术|中间件技术|Oracle论坛|JAVA论坛|Linux/Unix技术|hadoop论坛_联动北方技术论坛  
网站首页 | 关于我们 | 服务中心 | 经验交流 | 公司荣誉 | 成功案例 | 合作伙伴 | 联系我们 |
联动北方技术论坛-国内领先的Weblogic、Tuxedo中间件技术论坛
联动北方-国内领先的云技术服务提供商
»  游客             当前位置：  论坛首页 »  自由讨论区 »  MQ, Tuxedo及OLTP讨论区 »
总帖数
1
每页帖数
101/1页1
返回列表
0
发起投票  发起投票 发新帖子
查看: 5150 | 回复: 0   主题： [转帖]Tuxedo Quick Start 13 TUXEDO与数据库编程（续）        下一篇 
鲲鹏展翅
注册用户
等级：少校
经验：1148
发帖：79
精华：9
注册：2012-11-19
状态：离线
发送短消息息给鲲鹏展翅 加好友    发送短消息息给鲲鹏展翅 发消息
发表于： IP：您无权察看 2012-11-26 9:27:28 | [全部帖] [楼主帖] 楼主

在编写TUXEDO的服务端程序时，大部分的工作是进行数据库方面的编程工作，用数据库提供的嵌入SQL语言的编程接口，如ORACLE的PROC，INFORMIX的ESQL等编写TUXEDO的服务端程序，下面我们以PROC为例，介绍数据库服务端的编程技巧一些经验及应注意的地方。

例子程序：

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <sqlda.h>
#include <sqlcpr.h>
EXEC SQL INCLUDE sqlca;
/*RELEASE_CURSOR=YES 使PROC 在执行完后释放与嵌入SQL有关资源*/
EXEC ORACLE OPTION (RELEASE_CURSOR = YES);
EXEC SQL BEGIN DECLARE SECTION;
varchar vc_user[20];
long al_empno=0;
char ac_ename[11]="";
char ac_hiredate[20]="";
double af_sal=0;
EXEC SQL VAR ac_ename IS STRING(11);
EXEC SQL VAR ac_hiredate IS STRING(20);
EXEC SQL END DECLARE SECTION;
/*错误处理函数*/
void sql_error(char *msg)
{
      printf("\n%s,%ld,%s\n", msg,sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
      EXEC SQL ROLLBACK RELEASE;
      exit(-1);
}
main()
{
EXEC SQL WHENEVER SQLERROR DO sql_error("ORACLE ERROR: ");
/*连接数据库*/
strcpy(vc_user.arr,"scott/tiger@DEMO");
vc_user.len=16;
exec sql connect :vc_user;
EXEC SQL DECLARE cur_emp CURSOR FOR
SELECT EMPNO, ENAME,to_char(HIREDATE,'yyyy/mm/dd hh24:mi:ss'),SAL FROM EMP;
EXEC SQL OPEN cur_emp;
while(1)
{
      al_empno=0;
      strcpy(ac_ename,"");
      strcpy(ac_hiredate,"");
      af_sal=0;
      EXEC SQL FETCH cur_emp
      INTO :al_empno, :ac_ename:ename_ind, :ac_hiredate:hiredate_ind, :af_sal:sal_ind;
      if( sqlca.sqlcode == 1403)
      {
            break;
      } printf("empno=%ld,ename=%s,hiredate=%s,sal=%lf\n",al_empno,ac_ename,ac_hiredate,af_sal);
}
EXEC SQL CLOSE cur_emp;
EXEC SQL ROLLBACK WORK RELEASE;
}


1、宿主变量的声明
   在PROC中,在SQL语句中用到的变量称为宿主变量。他们应在EXEC SQL BEGIN DECLARE
SECTION;与EXEC SQL EDN DECLARE SECTION;之间声明，如上面所示.在声明宿主变量
时应注意以下几点：
(1)        在数据库表中定义为VARCHAR2，VARCHAR，CHAR的字段，在PROC中可声明为CHAR，
但长度应为它们在表中定义的长度加1，因为PROC中CHAR型变量用’\0’做结尾。
       如：ENAME在表中的定义为ename  varchar2(10)，在PROC中可定义为：

 EXEC SQL BEGIN DECLARE SECTION;
char ename[11];
EXEC SQL END DECLARE SECTION;


        常见错误说明:
        如果插入的字符串长度大于10，如：
EXEC SQL INSERT INTO EMP(ENAME) VALUES('12345678901');会出现以下错误:
        error:ORA-01480: STR 赋值变量缺少空后缀。

        如果定义为:

 EXEC SQL BEGIN DECLARE SECTION;
char ename[15];
EXEC SQL END DECLARE SECTION;


        当插入的字符串长度大于10，小于15时,如：
EXEC SQL INSERT INTO EMP(ENAME) VALUES('12345678901');会出现以下错误:
        error:ORA-01401: 插入的值对于列过大。
        当插入的字符串长度大于15，如：
EXEC SQL INSERT INTO EMP(ENAME) VALUES('12345678901234');会出现以下错误:
        error:ORA-01401:STR 赋值变量缺少空后缀。

(2) 从SQL语句中取字段的值到宿主变量中时，PROC不会自动给宿主变量去掉右空格。
而是以在DECLARE SECTION 中定义的长度为准(与表中定义的无关)不足补右空格.如果不注意这一点，在PROC中进行字符串操作时（如比较相等）会出错。如:

 EXEC SQL BEGIN DECLARE SECTION;
char ename[10];
EXEC SQL END DECLARE SECTION;


    如果ENAME在表中的值为'abc',则取出的值为'abc       ';
    可用语句EXEC SQL VAR重定义CHAR型变量。这样宿主变量会自动去掉右空格。如下:       

 EXEC SQL BEGIN DECLARE SECTION;
char ename[11];
EXEC SQL VAR  ac_ename                 IS STRING(11);
EXEC SQL END DECLARE SECTION;


        如果ENAME在表中的值为'abc',则取出的值为'abc';
      
(3) 对浮点型的变量，为保证精度，最好是声明成DOUBLE型的.因为DOUBLE型的精度比
FLOAT型高很多.
(4) 整型可声明为LONG型(对较长的整型,而且所用的平台支持的话,如在SUN平台上,可声
明为LONG LONG型).
(5) DATE型的处理：DATE型一般声明为CHAR(20)。
往表中插入DATE型数据时,一般用TO_DATE()函数进行类型转换,取出值时一般用
TO_CHAR()函数进行类型转换.

EXEC SQL select to_char(hiredate,'yyyy/mm/dd hh24:mi:ss')
into :ac_hire_date from EMP where empno=1234;
EXEC SQL insert into
EMP(EMPNO,HIREDATE)
values(123,to_date(:ac_hiredate,'yyyy/mm/dd hh24:mi:ss');


2、宿主变量的作用范围
   如果宿主变量在所有的函数之外声明，则他们是全局变量。在使用之前要注意把变量的
值初始化，宿主变量也可以在某个函数的内部定义。   这时他们是局部变量。一般都
习惯把宿主变量声明为全局变量。

3、数据库的连接与断开
   数据库的连接有以下两种方法：
   (1)

 strcpy(vc_user.arr,"scott/tiger");
vc_user.len=11;
exec sql connect :vc_user;
(2)
strcpy(user,"scott");
strcpy(pass,"tiger");
exec sql connect :user identified by :pass;


   注意：在有些平台上两种都可以,在有些平台上只能用第一种方法.
   在PROC程序中，要记住用EXEC SQL ROLLBACK WORK RELEASE;断开与数据库的连接,并
释放相关的数据库资源。

4、PROC中的NULL值的处理
   如果某一字段取出的值是NULL,会报:
sqlcode=-1405, sqlerr=ORA-01405: 读取的列值为 NULL
并且相应的宿主变量的值不会被改变,为执行该SQL语句之前的值. 常用的处理NULL值的方法有：
(1)        采用指示器变量,此时不会有-1405错误,当必须是所以为NULL的字段都有相应的指
示器变量,如果某一字段没有指示器变量,但取出的值为NULL值,则仍然会有-1405
错误.当取出的值是NULL时，相应的指示器变量变量为-1，可根据指示器变量的值
做相应的处理。
(2)        如果字段较多,可取字段到一个结构体中及与该结构体对应的指示器结构体中.如上
面的例子中可定义结构体：

 struct str_emp{
      long al_empno;
      char ac_ename;
      char ac_hiredate;
      double af_sal;
};
struct str_emp_ind{
long al_empno;
char ac_ename;
char ac_hiredate;
double af_sal;
};
struct str_emp str_emp;
strcut str_emp_ind str_emp_ind;


在取之���可用memset(&str_emp,0,sizeof(str_emp)).清空该结构体,这样如果是字
符型的NULL,会为"",整型的NULL会为0,浮点型的会为0.00。此时不会有-1405错误。
   (3) 也可采用NVL()函数:举例如下：

 EXEC SQL DECLARE authors CURSOR FOR
SELECT EMPNO, NVL(ENAME,chr(0)),
nvl(to_char(HIREDATE,'yyyy/mm/dd hh24:mi:ss'),chr(0)),NVL(SAL,0)
FROM EMP;


      这样也不会有-1405错误不,当取出的值是NULL时,自动用NVL()中指定的值代替.
      CHR(0)也可直接用''代替,如下:

SELECT EMPNO, NVL(ENAME,''),
nvl(to_char(HIREDATE,'yyyy/mm/dd hh24:mi:ss'),''),NVL(SAL,0)
FROM EMP;


5、PROC中的错误的处理
   所有的SQL语句都有可能出错.所以都要加以判断,但每个SQL语句后都加错误判断,太麻
烦,可用一个函数如sql_error()来进行错误处理,
   方法:
    (1)定义ql_error()函数。
（2）在开头加上EXEC SQL WHENEVER SQLERROR DO sql_error();这样当发生
sqlca.sqlcode <0 的错误时,程序自动转到sql_error()中执行.      
注意:对sqlca.sqlcode >0的错误如 sqlca.sqlcode =1403 是不会转到sql_error()
中执行的.
另外:在UNIX下，可以用OERR 来查找错误的描述。如： ora ORA -1405 查找错误号
为-1405的描述.

6、PROC中调用存储过程的方法
   要把存储过程放在EXEC SQL EXECUTE 和 END-EXEC;之间，如下所示：
   其中：al_empno,ac_ename 为输入参数,l_return,l_errno,c_errtext 为输出参数。

 al_empno=8888;
strcpy(ac_ename,"ABCD");
EXEC SQL EXECUTE
BEGIN
up_db_emp(:al_empno,:ac_ename,:l_return,:l_errno,:c_errtext);
END;
END-EXEC;
if (l_return != 0)
{
      printf("call up_db_emp fail,errno=%ld,errtext=%s\n",l_errno,c_errtext);
}


7、PROC的命令行选项：
PROC编译器有很多的命令行选项，在命令行下直接不带参数运行PROC，会列出所有的命令行选项来，并有说明。
   (1)储存过程:编译储存过程是要带上用户名及密码

 proc USERID=scott/tiger sqlcheck=SEMANTICS ireclen=512 iname=test.cpp


   (2)PARSE=NONE 对非SQL代码不进行语法分析，默认对非SQL代码也进行语法分析.
     在RED HAD6.3上的ORACLE8.1.5中用PROC时,会提示:/USR/INCLUDE/STDIO.H 及其他的.H文件中有错. 可把PARSE=NONE加上,就好了.

8、注意加上：EXEC ORACLE OPTION (RELEASE_CURSOR = YES);
   RELEASE_CURSOR=YES 使PROC 在执行完后释放与嵌入SQL有关资源，保证在该PROC程
序执行完后，ORACLE不会锁住数据库资源，如锁表等。
   如果在PROC中用到ORACA，还要在程序头加上：

 EXEC ORACLE OPTION (ORACA=YES);


9、PROC中的类型转换
   一、在C语言中:
   (1)字符型到整型可用ATOI() ATOL(),SSCANF()
   (2)整型,浮点型到字符型,可用SPRINTF()
   (3)字符型到浮点型用ATOF()不行,最好用SSCANF(),举例如下:

EXEC SQL BEGIN DECLARE SECTION;
double d_demo;
float  f_demo;
char  ac_text[20]="222";
EXEC SQL END DECLARE SECTION;
(1)sscanf(ac_text, "%f", &d_demo);
printf("ac_text=%s,d_demo=%f\n",ac_text,d_demo);
(2)sscanf(ac_text, "%lf", &d_demo);
printf("ac_text=%s,d_demo=%f\n",ac_text,d_demo);
(3)sscanf(ac_text, "%f", &d_demo);
printf("ac_text=%s,d_demo=%lf\n",ac_text,d_demo);
(4)sscanf(ac_text, "%lf", &d_demo);
printf("ac_text=%s,d_demo=%lf\n",ac_text,d_demo);
printf("*******************\n");
(5)sscanf(ac_text, "%f", &f_demo);
printf("ac_text=%s,f_demo=%f\n",ac_text,f_demo);
(6)sscanf(ac_text, "%lf", &f_demo);
printf("ac_text=%s,f_demo=%f\n",ac_text,f_demo);
(7)sscanf(ac_text, "%f", &f_demo);
printf("ac_text=%s,f_demo=%lf\n",ac_text,f_demo);
(8)sscanf(ac_text, "%lf", &f_demo);
printf("ac_text=%s,f_demo=%lf\n",ac_text,f_demo);


       输出的结果:                                                               

 ac_text=222.00,d_demo=0.000000
ac_text=222.00,d_demo=222.000000
ac_text=222.00,d_demo=222.000032
ac_text=222.00,d_demo=222.000000
*******************
ac_text=222.00,f_demo=222.000000
ac_text=222.00,f_demo=0.000000
ac_text=222.00,f_demo=222.000000
ac_text=222.00,f_demo=0.000000
d_demo=atof(ac_text);
printf("ac_text=%s,atof(ac_text)=%f\n",ac_text,d_demo);
d_demo=atof(ac_text);
printf("ac_text=%s,atof(ac_text)=%lf\n",ac_text,d_demo);
f_demo=atof(ac_text);
printf("ac_text=%s,atof(ac_text)=%f\n",ac_text,f_demo);
f_demo=atof(ac_text);
printf("ac_text=%s,atof(ac_text)=%lf\n",ac_text,f_demo);


        输出的结果:  

 ac_text=222.00,atof(ac_text)=1243288.000000
ac_text=222.00,atof(ac_text)=1243288.000000
ac_text=222.00,atof(ac_text)=1243288.000000
ac_text=222.00,atof(ac_text)=1243288.000000


    从上面的结果可见:
DOUBLE型应采用sscanf(ac_app_capcity, "%lf", &d_app); 打印用"%lf","%f" 都可
以. (2),(4)正确
FLOAT型应采用sscanf(ac_app_capcity, "%f", &d_app); 打印用"%lf","%f" 都可以.
(5),(7)正确
    采用ATOF()转换的结果都是错的,所以不要用它。

   二、写表或从表中取数据时:
    (1)字符型与整型之间可不用转换,采用默认方式。
    (2)字符型与浮点型之间可不用转换,采用默认方式。
    (3)日期型与字符型之间可用TO_CHAR(),TO_DATE()。

10、PROC中的4种动态SQL简介
(1)动态SQL1: 不能是查询(SELECT)语句,并且没有宿主变量.
    用法:拼一串动态SQL语句,并用EXECUTE IMMEDIATE执行,如:

 EXEC SQL EXECUTE IMMEDIATE "CREATE TABLE dyn1 (col1 VARCHAR2(4))";


(2)动态SQL2: 不能是查询(SELECT)语句,并且输入的宿主变量数目是知道的,
     用法:拼一串动态SQL语句,用PREPARE,EXECUTE语句执行.

 strcpy(c_sql, "DELETE FROM EMP WHERE EMPNO = :?");
EXEC SQL PREPARE sql_stmt FROM :c_sql;
EXEC SQL EXECUTE sql_stmt USING :emp_number;


(3)动态SQL3: 用于创建动态查询,  并且要查询的字段及输入的宿主变量数目是知道的
     用法: 拼一串动态SQL语句,用PREPARE分析该语句,并要定义一个CURSOR进行取值
     如:如要查询的数据按一年12月放到12张表中。表名为user_fee_1mon, user_fee_2mon,....可采用动态SQL3来进行查询

strcpy(c_sql,"select c_user_id,c_user_name,
to_char(t_date,'yyyy/mm/dd hh:mi:ss'),n_fee\n");
strcat(c_sql,"from USER_FEE_");
strcat(c_sql,ac_mon);
strcat(c_sql," \n where c_user_id = :v1");
EXEC SQL PREPARE s FROM :c_sql;
EXEC SQL DECLARE cur_user_fee CURSOR FOR s;
EXEC SQL OPEN cur_user_fee USING :ac_user_id;
while(1)
{
      EXEC SQL FETCH cur_user_fee into :c_user_id,:c_user_name,:c_date,:n_fee);
      if (sqlca.sqlcode < 0)
      {
            /*FETCH CURSOR失败*/
            printf("fetch cursor cur_user_fee \
            fail,sqlcode=%ld,sqlserr=%s",sqlca.sqlcode,sqlca.sqlerrm.sqlerrmc);
      }
      if( sqlca.sqlcode == SQLNOTFOUND)
      {
            break;
      }
}
EXEC SQL CLOSE cur_user_fee;


  (4)动态SQL4:要处理的字段及输入的宿主变量数目和主变量的类型事先是不知道的,如：

 INSERT INTO EMP (<unknown>) VALUES (<unknown>)


     是最复杂的动态SQL,很少用,在此不做介绍。

11、SQLCA：


SQL是ORACLE的一个结构体，它的域用于最近的一条SQL语句执行后的一些信息，如错误号，错误描述，警告，状态等。常用的域介绍如下:
    SQLCA.sqlcode:错误号,=0正确,=1403没取到数据
    SQLCA.sqlserrm.sqlerrmc:错误描述
SQLCA.sqlerrd[3]:最近的一条SQL语句所处理的行数,如果该语句处理失败,则它的值
是不定的,如果错误在一个CURSOR操作中发生,则
它的值指已成功处理的行数.在DELETE,UPDATE中,它不包含因外键约束而删除,更新的
那些行,

 DELETE FROM EMP WHERE DEPT='SALE';


在表EMP中删除20行,但如果表EMP与表ADDRESS有外键约束,导致表ADDRESS也被删
除20行,则SQLCA.sqlerrd[3]=20,而不是40。

12、其他方面
因为PROC编程实际时在C语言中嵌入SQL语句，所以应注意C语言编程的一些常见错误，如缓冲区溢出，数组越界，内存泄露等问题。而这些错误可能会使所在的进程死掉，或耗光系统的内存，并且它们不容易在测试中发现，所以要特别注意。
如下面的程序,因为ac_ename声明的长度为11，最多只能给它10个字符，而程序中给它赋18个字符，会造成越界。

 EXEC SQL BEGIN DECLARE SECTION;
char ac_ename[11]="";
EXEC SQL VAR  ac_ename                 IS STRING(11);
EXEC SQL END DECLARE SECTION;
strcpy(ac_ename,"123456789123456789");


   下面的程序，指针str1没有进行初始化，就给它赋值，会造成缓冲区溢出错误。

 char *str1;
strcpy(str,"111111111111111");


   正确的用法是：

 char *str1;
str1=(char *)malloc(100);
strcpy(str,"111111111111111");


    另外在程序中用malloc()等分配的内存，一定要记住用free()释放掉，否则会造成内存泄露。

事务处理应注意的一些问题
1. 不要嵌套事务
如下面的程序在(a)处用tpbegin发起一个全局事务之后,在(b(和(c)处又发起一个事务,
一般的数据库是不允许做事务当中嵌套事务这样的操作。在编程中应注意避免这种情况。

DEMO(TPSVRINFO *rqst)
{
      ……
      tpbegin( ); /*发起一个全局事务*/ (a)
      if(...)
      {
            EXEC SQL begin; /*又发起一个局部的事务)   (b)
         ……
           EXEC SQL update  
                   ……
                   if(sqlcode)   
                      EXEC SQL  commit;/*提交*/
            else
            EXEC SQL roback; /*回滚*/
            ……
      }
      else
      {
            tpbegin(); /*又发起一个全局的事务)  */ (c)
            ......
            tpcommit();/*提交*/
            ......
      }
      If(tpcommit( )==-1)
      {/*提交*/
            ….
            Tpabort( ); /*回滚*/
            …..
      }
      …….
      tpreturn(TPSUCCESS, …..);
}


2. 最好不要在客户端开始一个事务
可以在客户端,包括本地CLENT与远程CLEINT,开始一个事务,也可以在服务端开始一个事务.在客户端开始一个事务的
做法一般如下,

....
tpbegin()
tpcall(service1)
tpcall(service2)
....
tpcommit()
..


在客户端开始的事务,不能象在服务端开始事务那样在程序中直接嵌入SQL语句对数据库进行操作,它只能通过调用SERVICE.
在SERVICE中数据库进行操作.
通常的做法是尽量在服务端开始事务,因为在客户端处理事务有很多缺点.
1.        客户端与服务端之间的网络通讯要花很多时间,而且如果网络不可靠时.
2.        如果在CLIENT开始一个事务,并且处理该事务的过程中要与用户进行交互,如果用户离开或并继续往下走,那么该事务就悬挂在那里.
3.        把事务控制放在客户端,会使客户端的程序与业务相关,与3层结构的设计思想相矛盾.
4.        把事务放在客户端,会使系统对并发的事务数失去控制,如: 原来有50个SERVER,那么最多可能有50个事务存在,如果该系统同时可以有2000个CLIENT连到TUXEDO SERVER上,那么最多可能会启动2000个事务,会超出系统的限制.
5.        客户端的机器不可靠.在处理事务过程中可能死机等.

3. 跨越多个资源管理器的事务处理
在TUXEDO中,资源管理器与GROUP使一一对应关系,所以如果一个全局事务要跨越多个资源管理器,那么它必然也要跨越多个GROUP,而一个SERVER只能

1. 在客户端开始该事务,在tpbegin()与tpcommit()之间调用这些SERVICE

....
tpbegin()
tpcall(service1) /*在GROUP1上,与资源管理器1连接*/
tpcall(service2) /*在GROUP2上,与资源管理器2连接*/
tpcall(service3) /*在GROUP3上,与资源管理器3连接*/
....
tpcommit()
..


2.在服务端开始该事务

SERVICE1(TPSVCINFO *rqst)
{....
      tpbegin()
      tpcall(service1) /*在GROUP1上,与资源管理器1连接*/
      tpcall(service2) /*在GROUP2上,与资源管理器2连接*/
      tpcall(service3) /*在GROUP3上,与资源管理器3连接*/
      ....
      tpcommit()
      ..
}


在客户端调用SERVICE1

事务的超时时间的设置
在数据库编程中要合理的设置超时时间，下面通过例子来说明。

例子的UBBCONFIG文件内容为：

*RESOURCES
IPCKEY                123456
DOMAINID        simpapp
MASTER                simple
MAXACCESSERS        30
MAXSERVERS        5
MAXSERVICES        10
MODEL                SHM
LDBAL                N
SCANUNIT        10
SANITYSCAN        1
BLOCKTIME          4
*MACHINES
MYSERVER                LMID=simple
APPDIR="d:\simpdb"
TUXCONFIG="d:\simpdb\tuxconfig"
TUXDIR="d:\tuxedo65"
TLOGDEVICE = "d:\simpdb\TLOG"
TLOGNAME=TLOG
TLOGSIZE=100
MAXWSCLIENTS=5
*GROUPS
GROUP1
LMID=simple        GRPNO=1
OPENINFO="Oracle_XA:Oracle_XA+Acc=P/scott/tiger+SesTm=600+MaxCur=5+LogDir=."
TMSNAME="TMS_ORA8i"        TMSCOUNT=2
*SERVERS
DEFAULT:
CLOPT="-A"
test                SRVGRP=GROUP1 SRVID=1
WSL                SRVGRP=GROUP1 SRVID=12
CLOPT="-A -- -n //XCJ:8888 -m 5 -M 10 -x 8"
*SERVICES


客户端的程序为testcli.c的内容为:

#include <stdio.h>
#include "atmi.h"
int main(int argc, char *argv[])
{
      char *sendbuf;
      long rcvlen;
      int ret;
      if (tpinit((TPINIT *) NULL) == -1) {
            (void) fprintf(stderr, "Tpinit failed\n");
            exit(1);
      }
      if((sendbuf = (char *) tpalloc("STRING", NULL, 1000)) == NULL) {
            (void) fprintf(stderr,"Error allocating send buffer\n");
            tpterm();
            exit(1);
      }
      ret = tpcall("TEST", (char *)sendbuf, 0, (char **)&sendbuf, &rcvlen, TPNOBLOCK);
      if(ret == -1)
      {
            printf("tperrno=%ld,tpstrerr=%s\n",tperrno,tpstrerror(tperrno));
            tpfree(sendbuf);
            tpterm();
            exit(1);
      }
      tpfree(sendbuf);
      tpterm();
      return(0);
}


(1)        如果服务端test.cpp的内容为：

TEST(TPSVCINFO *rqst)
{
      if(tpbegin(60,0)==-1)
      {
            printf("tpbegin() fail\n");
            tux_return(sendbuf,"update emp fail",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
      }
      EXEC SQL update emp set ename=:ename where empno=7369;
      if (sqlca.sqlcode != 0)
      {
            tux_return(sendbuf,"update emp fail",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
      }
      if(tpcommit(0) == -1)
      {
            printf("tpcommit() fail=%s\n",tpstrerror(tperrno));
            exit(1);
      }
      userlog("*****************begin sleep\n");
      sleep(150);
      userlog("*****************end sleep\n");
      tpreturn( TPSUCCESS, 0, (char *)sendbuf, 0, 0 );
}


1．如果testcli.c 中的tpcall()的flag的值为:TPNOBLOCK, 那么
客户端的输出为:

The current time is: 11:27:51.54
D:\tuxdemo\simpdb>testcli
tpcall failed: tperrno=13,tpstrerror=TPETIME - timeout occured
The current time is: 11:28:32.70


服务端的ULOG文件中的输出为:

112751.XCJ!test.1376: *****************begin sleep
113021.XCJ!test.1376: *****************end sleep


结论:
客户端从调用TPCALL()开始,过了约40秒,客户端超时出错,但服务端的TEST将继续
执行.所以数据库的更新是成功的,但该客户端在本次调用中无法知道这一结果.

2．如果testcli.c 中的tpcall()的flag的值为:TPNOTIME，那么
客户端的输出为:

The current time is: 11:33:49.54
D:\tuxdemo\simpdb>testcli fdf
The current time is: 11:36:30.89


服务端的ULOG文件中的输出为:

113400.XCJ!test.1376: *****************begin sleep
113630.XCJ!test.1376: *****************end sleep


结论:
该客户端将不管系统的超时设置,阻塞在 tpcall()调用上,只到该服务端有结果返回为
止.该客户端在本次调用中知道数据库更新操作的结果.

（1）如果服务端test.cpp的内容为：

TEST(TPSVCINFO *rqst)
{
      if(tpbegin(60,0)==-1)
      {
            printf("tpbegin() fail\n");
            exit(1);
      }
      userlog("*****************begin sleep\n");
      sleep(150);
      userlog("*****************end sleep\n");
      EXEC SQL update emp set ename=:ename where empno=7369;
      if (sqlca.sqlcode != 0)
      {
            tux_return(sendbuf,"update emp fail",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
      }
      if(tpcommit(0) == -1)
      {
            printf("tpcommit() fail=%s\n",tpstrerror(tperrno));
            exit(1);
      }
      tpreturn( TPSUCCESS, 0, (char *)sendbuf, 0, 0 );
}


1．testcli.c ���的tpcall()的flag的值为:TPNOBLOCK，那么
客户端的输出为:

The current time is: 20:59:51.30
D:\simpdb>testcli
tperrno=13,tpstrerr=TPETIME - timeout occured
The current time is: 21:00:32.97


服务端的ULOG文件中的输出为:
205951.XCJ!test.1456: 全局事务rid x0 x3c8b46f6 x5:        *****************begin sleep
210221.XCJ!test.1456: 全局事务rid x0 x3c8b46f6 x5:        *****************end sleep

210221.XCJ!test.1456: tpcommit() fail=TPEABORT - transaction cannot commit


结论:
客户端从调用TPCALL()开始,过了约40秒,客户端超时出错,当服务端的TEST将继续
执行.在tpbegin()中为该事务设置的超时为60秒,但过了150秒之后才开始进行数据库操
作,那么该事务将因为超时而回滚，从ULOG的输出可以看到这一点.所以数据库的更新
是失败的,该客户端在本次调用中无法知道这一结果.
    如果把在tpbegin()中为该事务设置的超时为160秒,那么数据库的更新操作将时成功的.

2．testcli.c 中的tpcall()的flag的值为:TPNOTIME，那么
客户端的输出为:

The current time is: 21:05:09.94
D:\simpdb>testcli
tperrno=11,tpstrerr=TPESVCFAIL - application level service failure
The current time is: 21:07:40.77


服务端的ULOG文件中的输出为:
210510.XCJ!test.1456: 全局事务rid x0 x3c8b46f6 x6:        *****************begin sleep
210740.XCJ!test.1456: 全局事务rid x0 x3c8b46f6 x6:        *****************end sleep

210740.XCJ!test.1456: tpcommit() fail=TPEABORT - transaction cannot commit


结论:
客户端从调用TPCALL()开始,过了约150秒,服务端的SERVICE:TEST死掉.该客户
端出错退出,服务端的结果和上面的一样。

从上面的例子可以看出：
（1）tpbegin()中设置的超时时间一定要大于该事务的实际处理实际，否则该事务将因为���
时而回滚，
（2）客户端的超时时间一定要大于事务的处理时间，否则该客户端在服务端的处理结果还
         没有返回之前就会超时出错，无法知道服务端事务的处理结果


赞(0)    操作        顶端 
总帖数
1
每页帖数
101/1页1
返回列表
发新帖子
请输入验证码： 点击刷新验证码
您需要登录后才可以回帖 登录 | 注册
技术讨论

Weblogic中间件技术论坛

 |

Tuxedo中间件技术论坛

 |

数据库论坛

 |

Java论坛

 |

Linux/unix论坛

 |

网站地图


Powered by LandingBJ     @ 2008-2018     联动北方   
京ICP证号090597    京ICP备案09017624号    京公网安备110112000093号    
400-810-2327     Email：service@landingbj.com   

Powered by landingbj @ 2008-2015 联动北方
京ICP证号090597 京ICP备案09017624号 京公网安备110112000093号
86-27-87056338 Email：service@landingbj.com