侃一下关于程序的“柔性”

yulihua49

原帖由 yulihua49 于 2011-8-24 15:26 发表

一个客户端的例子：

1. 
   
2. #include "sqlcli.h"
   
3. 
   
4. //测试分页查询
   
5. int testpage(T_Connect *conn,T_NetHead *nethead)
   
6. {
   
7. JSON_OBJECT json,val;
   
8. int cc,event;
   
9. T_CLI_Var *clip=(T_CLI_Var *)conn->Var;
   
10. log_s *log=(log_s *)clip->var;
    
11. INT64 now;
    
12. 
    
13.         val=json_object_new_object();
    
14.         add_string_to_json(val,"trn_no","G7154");//绑定值
    
15. 
    
16.         json=json_object_new_object();
    
17.         add_string_to_json(json,"tablename","trn_mmnt");//所需要的表名
    
18.         add_string_to_json(json,"where","where trn_no=:trn_no order by stn_no");//条件，有绑定变量
    
19.         add_string_to_json(json,"page_size","10");
    
20.         add_string_to_json(json,"page_idx","0");//可以改“1”
    
21.         json_object_object_add(json,"values",val);
    
22. 
    
23.         nethead->PROTO_NUM=get_srv_no(clip,"page_select");
    
24.         nethead->data=(char *)json_object_to_json_string(json);
    
25.         nethead->PKG_LEN=strlen(nethead->data);
    
26.         nethead->ERRNO1=nethead->ERRNO2=nethead->PKG_REC_NUM=0;
    
27.         nethead->O_NODE=LocalAddr(conn->Socket,0);
    
28. now=now_usec();
    
29.         cc=SendPack(conn,nethead);
    
30. if(isatty(0)) printf("send=%s\n",nethead->data);
    
31.         json_object_put(json);
    
32. 
    
33.         cc=RecvPack(conn,nethead);
    
34.         if(cc<0||nethead->ERRNO1!=0) {
    
35.                 ShowLog(1,"page_select cc=%d net err %d,%s,TCB=%d",
    
36.                         cc,errno,strerror(errno),log->TCB);
    
37.                 return -1;
    
38.         } else {
    
39. ShowLog(2,"测试分页功能:RecvPack %d,t_len=%d,len=%d,ERRNO2=%d,data=%s,TIMEVAL=%ld",cc,
    
40.         nethead->T_LEN,nethead->PKG_LEN,nethead->ERRNO2,nethead->data,now_usec()-now);
    
41.                 event=nethead->PROTO_NUM&65535; //准备返回事件
    
42.                 if(event)  EventCatch(conn,event);
    
43. /*
    
44.                 printf("page_select errno2=%d,data=%s\n",nethead->ERRNO2,nethead->data);
    
45.                 json=json_tokener_parse(nethead->data);
    
46.                 if(json) {
    
47.                         printf("%s\n",json_object_to_json_string(json));
    
48.                         json_object_put(json);
    
49.                 } else printf("page_select return=%s\n",nethead->data);
    
50. */
    
51.         }
    
52.         return 0;
    
53. }
    
54. 
    

复制代码

[ 本帖最后由 yulihua49 于 2011-8-24 17:17 编辑 ]

yulihua49

原帖由 yulihua49 于 2011-8-24 15:29 发表

一个客户端的例子：

执行结果：
2 ./sqlcli:1318 08/24 14:24'55 测试分页功能:RecvPack 0,t_len=352,len=1447,ERRNO2=0,data=[ { "trn_no": "G7154", "stn_no": "1", "stn_name": "上海虹桥", "trn_lvr": "高速", "arrive_time": "", "departure_time": "12:05", "days": "0", "run_minuts": "0", "stop_minuts": "0" }, { "trn_no": "G7154", "stn_no": "2", "stn_name": "昆山南", "trn_lvr": "高速", "arrive_time": "12:23", "departure_time": "12:24", "days": "0", "run_minuts": "18", "stop_minuts": "1" }, { "trn_no": "G7154", "stn_no": "3", "stn_name": "无锡", "trn_lvr": "高速", "arrive_time": "12:46", "departure_time": "12:48", "days": "0", "run_minuts": "41", "stop_minuts": "2" }, { "trn_no": "G7154", "stn_no": "4", "stn_name": "常州", "trn_lvr": "高速", "arrive_time": "13:01", "departure_time": "13:02", "days": "0", "run_minuts": "56", "stop_minuts": "1" }, { "trn_no": "G7154", "stn_no": "5", "stn_name": "丹阳", "trn_lvr": "高速", "arrive_time": "13:17", "departure_time": "13:18", "days": "0", "run_minuts": "72", "stop_minuts": "1" }, { "trn_no": "G7154", "stn_no": "6", "stn_name": "丹徒", "trn_lvr": "高速", "arrive_time": "13:28", "departure_time": "13:29", "days": "0", "run_minuts": "83", "stop_minuts": "1" }, { "trn_no": "G7154", "stn_no": "7", "stn_name": "镇江", "trn_lvr": "高速", "arrive_time": "13:37", "departure_time": "13:38", "days": "0", "run_minuts": "92", "stop_minuts": "1" }, { "trn_no": "G7154", "stn_no": "8", "stn_name": "南京", "trn_lvr": "高速", "arrive_time": "13:59", "departure_time": "", "days": "0", "run_minuts": "114", "stop_minuts": "-1" } ],TIMEVAL=8066

生成的SQL语句：
getpage:ret=8,stmt=SELECT trn_no,stn_no,stn_name,trn_lvr,arrive_time,departure_time,days,run_minuts,stop_minuts FROM TICKET.trn_mmnt where trn_no=:1 order by stn_no

如果page_index改1，生成如下语句：
getpage:ret=8,stmt=select * FROM (select A.*,ROWNUM RN FROM (SELECT trn_no,stn_no,stn_name,trn_lvr,arrive_time,departure_time,days,run_minuts,stop_minuts FROM TICKET.trn_mmnt where trn_no=:1 order by stn_no) A WHERE ROWNUM <= 10) WHERE RN > 0

至于要编写存储过程完成之，可以在生成语句的地方改成生成存储过程。
也可以彻底一些，json解析完了就可以调存储过程了，存储过程返回后，结果集如何打包你要给我一个办法。

[ 本帖最后由 yulihua49 于 2011-8-24 19:33 编辑 ]

yulihua49

原帖由 newkid 于 2011-8-23 22:22 发表

看这里：
http://www.itpub.net/viewthread.php?tid=1088197&highlight=

楼主在这里的发帖大多数少不了要推荐他做的“包装器”，我能理解他的落寞之情，毕竟这东西离开了他的单位就没有人用，茫茫人海知音难觅。不管他怎么敝帚自珍我都没意见，但是只要踩PLSQL我这个ORACLE卫道士就要跳出来。

哈哈，ORACLE的原教旨主义者。
你的签名也很有意思，它使我想起一位古代哲人的名言：
世界上只有两种书：1是其内容古兰经里已经有了。2是其内容古兰经里没有。后边不说了。

[ 本帖最后由 yulihua49 于 2011-8-24 19:29 编辑 ]

nannan5000

菜鸟请教个问题

如果是设计复杂的表连接的查询、或者更新

有中间件了怎么处理？

yulihua49

原帖由 nannan5000 于 2011-8-24 19:00 发表
菜鸟请教个问题

如果是设计复杂的表连接的查询、或者更新

有中间件了怎么处理？

这时需要手写模板或使用元数据生成模板。完成一个数据结构与多个表的对应关系。

nannan5000

请教yulihua49

有如下sql
select  dept_no,f_findname(emp_id) from dept,emp
这样的sql

用数据模板怎么生成？

就是类似 select 中的列 需要 有 处理的 sql

yulihua49

原帖由 nannan5000 于 2011-8-24 19:33 发表
请教yulihua49

有如下sql
select  dept_no,f_findname(emp_id) from dept,emp
这样的sql

用数据模板怎么生成？

就是类似 select 中的列 需要 有 处理的 sql

直接法：
T_PkgType dept_emp_tpl[]={
      {CH_INT,sizeof(int),"dept_no",0,-1},
      {CH_CHAR,21,"f_findname(emp_id) fname"},
      {-1,0,"dept,emp","主键"}
};

typedef struct {
      int dept_no;
      char fname[21];
} dept_emp_stu;

另一种是元数据方法，写一个文件，就叫dept_emp.meta吧：

TEMPLATE dept_emp 2
dept_no:=CH_INT
f_findname(emp_id) fname:=CH_CHAR 21
dept,emp\t主键

通过mktpl生成上述内容。

[ 本帖最后由 yulihua49 于 2011-8-24 19:43 编辑 ]

nannan5000

如果要实现 sum(emp_id)
是用 sql 实现呢？
还是 中间件把数据都读一遍 自己sum呢？

菜鸟，问题比较幼稚，请见谅~

[ 本帖最后由 nannan5000 于 2011-8-24 19:45 编辑 ]

yulihua49

原帖由 nannan5000 于 2011-8-24 19:43 发表
如果要实现 sum(emp_id)
是用 sql 实现呢？
还是 中间件把数据都读一遍 自己sum呢？

菜鸟，问题比较幼稚，请见谅~

客户端提出请求，服务器解释这个请求。这个请求的数据事先制备模板，程序就很简单了，执行完SQL，结果按约定格式返回客户端。
分析函数、子查询都可以做在模板里。尽可能让数据库干。

TEMPLATE dept_emp 3
dept_no:=CH_INT
f_findname(emp_id) fname:=CH_CHAR 21
sum(emp_id) e_sum:=CH_INT
dept,emp\t主键

每个列的格式：
列表达式 伪列名:=类型 长度 数据格式
列表达式：所有SQL合法的表示都可以。如果是子查询，可以绑定变量。

[ 本帖最后由 yulihua49 于 2011-8-24 20:04 编辑 ]

nannan5000

原帖由 yulihua49 于 2011-8-24 19:48 发表

客户端提出请求，服务器解释这个请求。这个请求的数据事先制备模板，程序就很简单了，执行完SQL，结果按约定格式返回客户端。
分析函数、子查询都可以做在模板里。尽可能让数据库干。

TEMPLATE dept_emp 3
dept_no:=CH_INT
f_findname(emp_id) fname:=CH_CHAR 21
sum(emp_id) sum:CH_INT
dept,emp\t主键

正在看您和newkid之前的讨论。
我简单总结下

您是用DTO这类的机制实现了映射标准SQL，然后放到数据库去执行。 中间由中间件或MQ来传递格式化的数据。
前台处理的是struct。


newkid是相当于把struct每个属性都传到存储过程，存储过程来处理最后的业务逻辑(就是取票、锁定票之类的)。



yulihua49 我觉得您的系统完全可以跑在文件系统上，类似自己写个数据库。应该比Oracle能高效。貌似用Oracle挺贵的，用MySQL也能存数。

请指点，谢谢前辈！

您写的包装器很牛，望其项背，像您致敬！