《TUXEDO系统经典-经乾》——8.4tuxedo的DTP实例 源代码 完整版

2380阅读　0评论2013-03-29　fangang001
分类：C/C++

TLR.ec:

点击(此处)折叠或打开

  1. #include<stdio.h>
  2. #include<stdlib.h>
  3. #include"atmi.h"
  4. #include"fml.h"
  5. #include"account.fml.h"
  6. #include"math.h"
  7. #include"userlog.h"


  10. //int account_id;
  11. //float amts,amt,acct_bal;

  13. //add by myself
  14. EXEC SQL BEGIN DECLARE SECTION;
  15. char userid[20]="owner/abc1234";
  16. char remoteDB[20]="mydb";
  17. char data[2];
  18. int account_id;
  19. int amt,acct_bal;
  20. char amts[10];
  21. EXEC SQL END DECLARE SECTION;

  23. EXEC SQL INCLUDE sqlca;

  25. void sqlerror();

  27. void DEPOSIT(TPSVCINFO *transb){
  28.     FBFR *transf=(FBFR*)transb->data;
  29.     account_id=Fvall(transf,ACCOUNT_ID,0);//函数的具体作用


  32.     Fget(transf,SAMOUNT,0,amts,0);//此函数的作用
  33.     sscanf(amts,"%f",&amt);

  35.     //add by myself
  36.     EXEC SQL WHENEVER SQLERROR DO sqlerror();
  37.     //此处不需要指定连接，由tuxedo通过GROUP的OPENINFO进行连接
  38.     //EXEC SQL CONNECT :userid USING :remoteDB;

  40.     EXEC SQL DECLARE dacur CURSOR FOR
  41.         SELECT BALANCE
  42.         FROM ACCOUNT
  43.         WHERE ACCOUNT_ID=:account_id;
  44.     EXEC SQL OPEN dacur;
  45.     EXEC SQL FETCH dacur INTO :acct_bal;

  47.     acct_bal+=amt;
  48.     EXEC SQL update ACCOUNT set BALANCE = :acct_bal
  49.         where ACCOUNT_ID = :account_id;
  50.     EXEC SQL close dacur;
  51.     //add by myself
  52.     //EXEC SQL COMMIT WORK RELEASE;

  54.     sprintf(amts,"$%d",acct_bal);
  55.     Fchg(transf,SBALANCE,0,amts,(FLDLEN)0);//

  57.     tpreturn(TPSUCCESS,0,transb->data,0L,0);
  58. }


  61. void WITHDRAWAL(TPSVCINFO *transb){
  62.     FBFR *transf=(FBFR*)transb->data;
  63.     account_id=Fvall(transf,ACCOUNT_ID,0);
  64.     Fget(transf,SAMOUNT,0,amts,0);
  65.     sscanf(amts,"%f",&amt);

  67.     //add by myself
  68.     EXEC SQL WHENEVER SQLERROR DO sqlerror();
  69.     //EXEC SQL CONNECT :userid USING :remoteDB;

  71.     EXEC SQL declare wacur cursor for
  72.         select BALANCE from ACCOUNT where ACCOUNT_ID= :account_id;
  73.     EXEC SQL open wacur;
  74.     EXEC SQL fetch wacur into :acct_bal;
  75.     //EXEC SQL close wacur;
  76.     if(amt>acct_bal){
  77.         if(fabs(acct_bal-amt)>0.01){
  78.             Fchg(transf,STATLIN,0,"Account overdraft",(FLDLEN)0);
  79.             EXEC SQL close wacur;
  80.             tpreturn(TPFAIL,0,transb->data,0L,0);
  81.         }
  82.         amt=acct_bal;
  83.     }
  84.     acct_bal-=amt;
  85.     EXEC SQL update ACCOUNT set BALANCE = :acct_bal
  86.         where ACCOUNT_ID = :account_id;
  87.     EXEC SQL close wacur;
  88.     //add by myself
  89.     //EXEC SQL COMMIT WORK RELEASE;

  91.     sprintf(amts,"$%d",acct_bal);
  92.     Fchg(transf,SBALANCE,0,amts,(FLDLEN)0);

  94.     tpreturn(TPSUCCESS,0,transb->data,0L,0);
  95. }

  97. void INQUERY(TPSVCINFO *transb){
  98.     userlog("INQUERY receive request from client!\n");

  100.     FBFR *transf=(FBFR*)transb->data;
  101.     account_id=Fvall(transf,ACCOUNT_ID,0);



  105.     //add by myself
  106.     EXEC SQL WHENEVER SQLERROR DO sqlerror();
  107.     //EXEC SQL CONNECT :userid USING :remoteDB;

  109.     //EXEC SQL declare icur cursor for
  110.     //    select BALANCE from ACCOUNT where ACCOUNT_ID = :account_id;

  112.     //EXEC SQL open icur;
  113.     //EXEC SQL fetch icur into :acct_bal;
  114.     //EXEC SQL close icur;

  116.     EXEC SQL select BALANCE into :acct_bal from ACCOUNT where ACCOUNT_ID=:account_id;
  117.     if(sqlca.sqlcode!=0){
  118.         userlog("select from EMP failure,sqlcode=%ld, sqlerr=%s\n",sqlca.sqlcode,(char *)sqlca.sqlerrm.sqlerrmc);
  119.         tpreturn(TPFAIL,0,NULL,0L,0);
  120.     }
  121.     userlog("BALANCE=%d",acct_bal);

  123.     //add by myself
  124.     //EXEC SQL COMMIT WORK RELEASE;

  126.     sprintf(amts,"$%d",acct_bal);//%.2f不能进行有效转换，所以amts为0.0
  127.     //userlog("amts=%s",amts);
  128.     Fchg(transf,SBALANCE,0,amts,(FLDLEN)0);
  129.     Fchg(transf,FORMNAM,0,"CBLANCE",(FLDLEN)0);

  131.     tpreturn(TPSUCCESS,0,transb->data,0L,0);
  132. }


  135. void sqlerror(){
  136.     EXEC SQL WHENEVER SQLERROR CONTINUE;
  137.     EXEC SQL ROLLBACK WORK RELEASE;
  138.     printf("-----pro*c connect error!----n");
  139.     exit(-1);
  140. }

XFER.c

点击(此处)折叠或打开

  1. #include<stdio.h>
  2. #include<stdlib.h>
  3. #include"atmi.h"
  4. #include"tx.h"
  5. #include"account.fml.h"
  6. #include"fml.h"

  8. long db_id,cr_id;
  9. //char t_amts[10];

  11. #ifdef TRANSACTION_MODE
  12. void TRANSFER_XA(TPSVCINFO *transb){
  13. #else
  14. void TRANSFER_NOXA(TPSVCINFO *transb){
  15. #endif
  16.     long olen;
  17.     FBFR *transf=(FBFR*)transb->data;

  19.     db_id=Fvall(transf,ACCOUNT_ID,0);
  20.     cr_id=Fvall(transf,ACCOUNT_ID,1);
  21.     //Fget(transf,SAMOUNT,0,t_amts,0);
  22.     //sscanf(amts,"%f",&amt);

  24.     //构造参数
  25.     //FBFR *inbuf=(FBFR*)tpalloc("FML",NULL,1024);
  26.     //Fchg(inbuf,SAMOUNT,0,(char*)t_amts,(FLDLEN)0);

  28. #ifdef TRANSACTION_MODE
  29.     tpbegin(60,0);
  30. #endif
  31.     Fchg(transf,ACCOUNT_ID,0,(char*)db_id,(FLDLEN)0);
  32.     //取款
  33.     int ret1=tpcall("WITHDRAWAL",(char*)transf,0,(char**)&transf,(long*)&olen,0);
  34.     //system("do shutdown");
  35.     //存款
  36.     Fchg(transf,ACCOUNT_ID,0,(char*)cr_id,(FLDLEN)0);
  37.     int ret2=tpcall("DEPOST",(char*)transf,0,(char**)&transf,(long*)&olen,0);
  38.     //system("do boot");
  39.     if((ret1==0)&&(ret2==0)){
  40. #ifdef TRANSACTION_MODE
  41.         tpcommit(0);
  42. #endif
  43.         tpreturn(TPSUCCESS,0,transb->data,0L,0);
  44.     }else{
  45. #ifdef TRANSACTION_MODE
  46.         tpabort(0);
  47. #endif
  48.         tpreturn(TPFAIL,0,transb->data,0L,0);
  49.     }
  50. }

bankclt.c

点击(此处)折叠或打开

  1. #include<stdio.h>
  2. #include<stdlib.h>
  3. #include"atmi.h"
  4. #include"fml.h"
  5. #include"account.fml.h"

  7. int Balance(long accountid);

  9. int main(int argc,char *argv[]){
  10.     long aid1,aid2,samount,olen;
  11.     aid1=10000;
  12.     aid2=20000;
  13.     samount=10;//转账金额


  16.     if(tpinit((TPINIT*)NULL)==-1){
  17.         fprintf(stderr,"tpinit failed!\n");
  18.         exit(-1);
  19.     }
  20.     //申请缓冲区
  21.     FBFR *fbfr=(FBFR*)tpalloc("FML",NULL,1024);
  22.     if(fbfr==NULL){
  23.         fprintf(stderr,"tpalloc failed!\n");
  24.         tpterm();
  25.         exit(-1);
  26.     }

  28. #ifdef TRANSACTION_MODE
  29.     fprintf(stdout,"\nRun under Transaction Mode...\n");
  30. #else
  31.     fprintf(stdout,"\nRun under NON-Transaction Mode...\n");
  32. #endif

  34.     fprintf(stdout,"\nBalance of account before transfer\n");
  35.     fprintf(stdout,"--------------------------------------\n");
  36.     Balance(10000);
  37.     Balance(20000);

  39.     fprintf(stdout,"\nTransfer $10 from account 10000 to 20000...\n");
  40.     fprintf(stdout,"-----------------------------------------------\n");

  42.     //构造入参
  43.     Fchg(fbfr,ACCOUNT_ID,0,(char*)&aid1,(FLDLEN)0);
  44.     Fchg(fbfr,ACCOUNT_ID,1,(char*)&aid2,(FLDLEN)0);
  45.     Fchg(fbfr,SAMOUNT,0,(char*)&samount,(FLDLEN)0);

  47. #ifdef TRANSACTION_MODE
  48.     int ret1=tpcall("TRANSFER_XA",(char*)fbfr,0,(char**)&fbfr,(long*)&olen,0);
  49. #else
  50.     int ret1=tpcall("TRANSFER_NOXA",(char*)fbfr,0,(char**)&fbfr,(long*)&olen,0);
  51. #endif

  53.     if(ret1==-1)
  54.         fprintf(stdout,"\nTransfer Failed!\n");
  55.     else
  56.         fprintf(stdout,"\nTransfer Successful!\n");

  58.     
  59.     fprintf(stdout,"\nBalance of account after transfer\n");
  60.     fprintf(stdout,"--------------------------------------\n");
  61.     Balance(aid1);
  62.     Balance(aid2);

  64.     return 0;
  65. }

  67. int Balance(long account_id){
  68.     long olen;
  69.     FBFR *fbfr=(FBFR*)tpalloc("FML",NULL,1024);
  70.     if(fbfr==NULL){
  71.         fprintf(stderr,"tpalloc failed!\n");
  72.         tpterm();
  73.         exit(-1);
  74.     }
  75.     Fchg(fbfr,ACCOUNT_ID,0,(char*)&account_id,0);
  76.     if(tpcall("INQUERY",(char*)fbfr,0L,(char**)&fbfr,(long*)&olen,0)==-1){
  77.         fprintf(stderr,"Can not send request to service INQUERY\n");
  78.         tpfree((char*)fbfr);
  79.         tpterm();
  80.         exit(1);
  81.     }
  82.     fprintf(stdout,"Account_id=%d,Account_Balance=%s\n",account_id,(char*)Ffind(fbfr,SBALANCE,0,0));
  83.     return 0;
  84. }

编译服务器端程序用到的Makefile：

点击(此处)折叠或打开

  1. ORACLE_HOME=/u01/app/oracle/product/10.2.0/db_1
  2. INCLDIR= -I. -I$ORACLE_HOME/precomp/public -I$ORACLE_HOME/rdbms/public -I$ORACLE_HOME/rdbms/demo -I$ORACLE_HOME/plsql/public -I$ORACLE_HOME/network/public
  3. DFLAGS= -DPRECOMP -DLINUX -D_GNU_SOURCE -DSLTS_ENABLE -DSLMXMX_ENABLE -D_REENTRANT -DNS_THREADS
  4. CFLAGS= -O3
  5. LIBPATH= -L/u01/oracle/product/8.1.7/lib/
  6. LIBS=-lclntsh -ldl -lm

  8. conn:TLR_ORA.pc
  9.     proc parse=no iname=TLR_ORA.pc include=$(ORACLE_HOME)/precomp/public

  11.     buildserver -r Oracle_XA -o depositserver -f TLR_ORA.c -s DEPOSIT:DEPOSIT
  12.     buildserver -r Oracle_XA -o withdrawalserver -f TLR_ORA.c -s WITHDRAWAL:WITHDRAWAL
  13.     buildserver -r Oracle_XA -o inqueryserver -f TLR_ORA.c -s INQUERY:INQUERY
  14. clean:    
  15.     rm *.lis tp*

编译XFER和客户端命令：

点击(此处)折叠或打开

  1. buildclient -o bankclient -f bankclt.c -w
  2. buildserver -s TRANSFER_XA -o XFERserver -f XFER.c

运行结果：

点击(此处)折叠或打开

  1. [tuxapp@localhost TLR]$ ./bankclient

  3. Run under Transaction Mode...

  5. Balance of account before transfer
  6. --------------------------------------
  7. Account_id=10000,Account_Balance=$610
  8. Account_id=20000,Account_Balance=$990

  10. Transfer $10 from account 10000 to 20000...
  11. -----------------------------------------------

  13. Transfer

  15. Balance of account after transfer
  16. --------------------------------------
  17. Account_id=10000,Account_Balance=$610
  18. Account_id=20000,Account_Balance=$990



点击(此处)折叠或打开

注：以上内容属于个人学习总结，转载请注明出处
上一篇：转载：Bash命令行处理流程详解
下一篇：tuxedo 多机(MP)配置 报错解决