找到一篇C++ OTL链接mysql的文章，不错

th234

找到一篇C++ OTL链接mysql的文章，不错
http://www.xuanyuan-soft.cn/lab/examples/122-cpp-otl-mysql

zhaohongjian000

轩辕高端 C++培训中心

==========================
可以删帖封号了似乎。

yulihua49

th234 发表于 2013-10-29 16:39
找到一篇C++ OTL链接mysql的文章，不错
http://www.xuanyuan-soft.cn/lab/examples/122-cpp-otl-mysql

还要写SQL语句？一般的包装器，insert是可以不写语句的。这点不如JAVA的Hibernate。
看看我这个包装器，C的，可以适用于MYSQL，ORACLE，DB2。称为DAU--Data Access Unit

1. 
   
2. #include <sqli.h>
   
3. #include <DAU.h>
   
4. 
   
5. #define trans_begin(sql) ___SQL_Transaction__((sql),TRANBEGIN)
   
6. #define trans_commit(sql) ___SQL_Transaction__((sql),TRANCOMMIT)
   
7. #define trans_rollback(sql) ___SQL_Transaction__((sql),TRANROLLBACK)
   
8. #define INTERVAL ((int)(now_usec() - now))
   
9. 
   
10. #include "mytab.tpl"
    
11. #include "mytab.stu"
    
12. 
    
13. static int processDB(T_SQL_Connect *SQL_Connect)
    
14. {
    
15. DAU my_DAU;
    
16. mytable_stu mytab;
    
17. char stmt[4096],tmp[1024],*p;
    
18. INT64 now;
    
19. int ret,i;
    
20. int today=rtoday();
    
21. char *rec=NULL;
    
22.         DAU_init(&my_DAU,SQL_Connect,NULL,&mytab,mytable_tpl);//使用mytable表
    
23. //test DAU_select
    
24.         p=mk_where("Name",stmt);
    
25.         strcpy(mytab.Name,"中国 123");
    
26. //      rjultostrfmt(mytab.beg_date,cvtdate("7.24",today),"yyyy\nmm\ndd");
    
27.         ret=DAU_select(&my_DAU,stmt,0);
    
28. printf("stmt=%s,ret=%d\n",stmt,ret);
    
29.         if(ret>0) while(!DAU_next(&my_DAU)) {
    
30.                 DAU_pack(&my_DAU,stmt);
    
31.                 printf("select:%s\n",stmt);
    
32.         }
    
33. 
    
34. //test prepare
    
35.         p=mk_where("ID",stmt);
    
36.         now=now_usec();
    
37.         for(i=0;i<46;i++) {
    
38.                 mytab.ID=i+1;
    
39.                 ret=DAU_prepare(&my_DAU,stmt);
    
40.                 if(ret) {
    
41.                         ShowLog(1,"%s:prepare fault ret=%d err=%d,%s",__FUNCTION__,ret,
    
42.                                 SQL_Connect->Errno,
    
43.                                 SQL_Connect->ErrMsg);
    
44.                         DAU_free(&my_DAU);
    
45.                         return ret;
    
46.                 }
    
47. 
    
48.                 while(!DAU_next(&my_DAU)) {
    
49.                         DAU_pack(&my_DAU,tmp);
    
50.                         printf("%s\n",tmp);
    
51.                 }
    
52.         }
    
53.         ShowLog(5,"%s:prepare i=%d,INTERVAL=%d",__FUNCTION__,i,INTERVAL);
    
54. 
    
55.         sprintf(stmt,"select max(ID) m from %s",my_DAU.srm.tabname);
    
56.         ret=___SQL_Select__(SQL_Connect,stmt,&rec,0);
    
57.         if(ret<=0) {
    
58.                 DAU_free(&my_DAU);
    
59.                 if(rec) free(rec);
    
60.                 return 1;
    
61.         }
    
62.         i=atoi(rec);
    
63.         free(rec);
    
64. //test update
    
65.         mytab.ID=i;
    
66.         rjultostrfmt(mytab.beg_date,rtoday(),YEAR_TO_DAY);
    
67.         trans_begin(SQL_Connect);
    
68.         mk_where("ID",stmt);
    
69.         ret=DAU_update(&my_DAU,stmt);
    
70.         trans_commit(SQL_Connect);
    
71.         printf("stmt=%s,ret=%d\n",stmt,ret);
    
72. 
    
73. //test delete
    
74.         mk_where("ID",stmt);
    
75.         ret=DAU_delete(&my_DAU,stmt);
    
76.         trans_commit(SQL_Connect);
    
77.         printf("stmt=%s,ret=%d\n",stmt,ret);
    
78. //test insert
    
79.         rjultostrfmt(mytab.beg_date,rtoday(),YEAR_TO_DAY);
    
80.         strcpy(mytab.Name,"中国               .");
    
81.         *stmt=0;//may be INSERT INTO table (a,b,c) VALUES (1,2,3) ON DUPLICATE KEY UPDATE c=c+1
    
82.         trans_begin(SQL_Connect);
    
83.         now=now_usec();
    
84.         ret=DAU_insert(&my_DAU,stmt);
    
85.         printf("stmt=%s,ret=%d,INTERVAL=%d\n",stmt,ret,INTERVAL);
    
86.         trans_commit(SQL_Connect);
    
87. 
    
88.         DAU_free(&my_DAU);
    
89.         return ret;
    
90. }
    
91. 
    
92. int main(int argc,char *argv[])
    
93. {
    
94. int ret=0;
    
95. T_SQL_Connect *SQL_Connect;
    
96. 
    
97.         tzset();
    
98.         if(argc>1) {
    
99.                 ret=envcfg(argv[1]); //打开哪个数据库，在配置文件里。
    
100.                 if(ret) printf("envcfg=%d\n",ret);
     
101.         }
     
102. 
     
103.         ret=init_DB_pool();
     
104.         if(ret) {
     
105.                 ShowLog(1,"%s:open DBpool fault,err=%d!",argv[0],ret);
     
106.                 return 1;
     
107.         }
     
108. 
     
109.         ret=get_DB_connect(&SQL_Connect,0);
     
110.         if(ret) {
     
111.                 ShowLog(1,"get_DB_connect error %d",ret);
     
112.                 free_DB_pool();
     
113.                 return 2;
     
114.         }
     
115.         ret=mysql_thread_safe();
     
116.         printf("mysql_thread_safe=%d\n",ret);
     
117.         ret=processDB(SQL_Connect);
     
118.         release_DB_connect(&SQL_Connect,0);
     
119.         free_DB_pool();
     
120.         return 0;
     
121. }
     

复制代码

yulihua49

yulihua49 发表于 2013-11-01 10:10
还要写SQL语句？一般的包装器，insert是可以不写语句的。这点不如JAVA的Hibernate。
看看我这个包装器 ...

它所操作的表结构，下列文件含两个表，例子里用的第一个：
#include "mytab.tpl"
cat mytab.tpl

T_PkgType mytable_tpl[]={
        {CH_INT,sizeof(int),"ID",0,-1},
        {CH_CHAR,61,"Name","gbk fixlength"},
        {CH_DATE,YEAR_TO_DAY_LEN,"beg_date",YEAR_TO_DAY},
        {-1,0,"mytable",0}
};

T_PkgType mytab_tpl[]={
        {CH_INT,sizeof(int),"ID",0,-1},
        {CH_CHAR,61,"Name","gbk fixlength"},
        {CH_CHAR,21,"node"},
        {CH_DATE,YEAR_TO_DAY_LEN,"beg_date",YEAR_TO_DAY},
        {CH_DATE,YEAR_TO_SEC_LEN,"on_time",YEAR_TO_SEC},
        {CH_INT64,sizeof(INT64),"Val"},
        {CH_DOUBLE,sizeof(double),"fval"},
        {CH_CHAR,9,"off_time","HH24:MI:SS"},
        {CH_BYTE,256,"map","tinyblob"},
        {CH_CHAR,5,"my_year"},
        {CH_INT,sizeof(int),"num"},
        {-1,0,"mytab",0}
};


#include "mytab.stu"

cat mytab.stu

extern T_PkgType mytable_tpl[];
typedef struct {
        int ID;
        char Name[61];
        char beg_date[YEAR_TO_DAY_LEN];
} mytable_stu;

extern T_PkgType mytab_tpl[];
typedef struct {
        int ID;
        char Name[61];
        char node[21];
        char beg_date[YEAR_TO_DAY_LEN];
        char on_time[YEAR_TO_SEC_LEN];
        unsigned INT64 Val;
        double fval;
        char off_time[9];
        char map[256];
        char my_year[5];
        int num;
} mytab_stu;

yulihua49

yulihua49 发表于 2013-11-01 10:23
它所操作的表结构，下列文件含两个表，例子里用的第一个：
#include "mytab.tpl"
cat mytab.tpl

前些日子我还发帖，问OTL的事，今天回答了，表示感谢。
但是从技术上看，它的包装不深，还需要自己写SQL和绑定变量，而且是间接绑定，效率稍逊。

我这个呢，是把表映射成结构，类似于JAVA的ORM。