请问如何在动态语句中使用 load、 unload 功能

ljmmail

现在需要设计一个支持 load、unload 功能的函数，程序将需要处理数据传输到一个 prepare 语句中进行处理，但是程序却连连报错：

1. 
   
2. int sql_run(str)
   
3. char *str;
   
4. {
   
5.   strcpy(sqlstring,str);
   
6.   EXEC SQL PREPARE s_comm FROM :sqlstring;
   
7.   if (sqlca.sqlcode) {
   
8.     errcall(ERROR, "%d", sqlca.sqlcode);
   
9.     return (sqlca.sqlcode);
   
10.   }
    
11.   // 程序报  201 错误，不知为何该语句无法处理 unload或load 语句
    
12.   EXEC SQL EXECUTE s_comm;
    
13.   //  程序报  410 错误，提示 prepare 句柄没有准备好。
    
14.   return(sqlca.sqlcode);
    
15. }
    
16. 
    
17. 
    
18.   sprintf(buff,  "unload   to   /tmp/dfmx.txt   select  *  from dfmx");
    
19.   sql_run(buff);
    
20.   // 程序不能执行该数据下载
    
21. 
    
22.   sprintf(buff, "load  from  /tmp/dfmx.txt   insert into   dfmx ");
    
23.    sql_run(buff);
    
24.    // 程序加载 0 条记录。
    
25. 
    
26. 
    
27. 
    
28. 
    
29.    请问包含 load 、unload 语句应该如何传递给一个动态 esql/c 语句呢？
    
30. 
    
31. 
    
32.    
    

复制代码

    谢谢！！！！！

ljmmail

我在别人的程序中见到了动态语句使用 load 和 unload 的例子，但是我在借鉴这些程序的时候，程序可以编译通过，但是程序就是无法正确执行，请版主关注本问题，谢谢！！！！

john_student

ec中SQL语句不支持unload，load吧，
除非用system（）或类似方法调用。

你所见的例子可以贴出来吗？

ljmmail

以下就是一个使用 load 功能的程序

1. 
   
2. 
   
3. /*******************************************************
   
4. *        数据备份与恢复(backup_proc,rescovery_proc)
   
5. *
   
6. * 最后修改：        周国祥 2001/08/18
   
7. *******************************************************/
   
8. #include <stdio.h>;
   
9. #include <curses.h>;
   
10. #include <varargs.h>;
    
11. #include <sys/types.h>;
    
12. #include <sys/timeb.h>;
    
13. #include <time.h>;
    
14. 
    
15. #include "all.h"
    
16. #include "macro_def.h"
    
17. #include "tool.h"
    
18. 
    
19. $include "db_struct.h";
    
20. $include sqlca;
    
21. 
    
22. #define WD        getenv ( "WORKDIR" )
    
23. #define  COL_LEE        2
    
24. 
    
25. void error_handler ();
    
26. void warning_handler ();
    
27. void notfound_handler ();
    
28. 
    
29. /*
    
30. extern WINDOW *my_win;
    
31. */
    
32. WINDOW *my_win;
    
33. 
    
34. EXEC SQL WHENEVER SQLERROR CALL error_handler;
    
35. EXEC SQL WHENEVER SQLWARNING CALL warning_handler;
    
36. EXEC SQL WHENEVER NOT FOUND CALL notfound_handler;
    
37. 
    
38. char        backup_table[100][40] = {
    
39.                 "cur_tran_ls",
    
40.                 "his_tran_ls",
    
41.                 "err_tran_ls",
    
42.                 "cur_settle_ls",
    
43.                 "his_settle_ls",
    
44.                 "saf_ls",
    
45.                 "cur_hand_ls",
    
46.                 "his_hand_ls",
    
47.        
    
48.                 "",
    
49.                 NULL,
    
50. };
    
51. 
    
52. int backup_ls ()
    
53. {
    
54.         char buff[1024];
    
55.         int ret;
    
56.         int i = 0;
    
57.        
    
58.         while (backup_table[i] != NULL && backup_table[i][0] != '\0') {
    
59. #ifdef Wubin_mod_20020509
    
60.                 sprintf ( buff ,\
    
61.                         "dbaccess - - 2>;/dev/null 1>;/dev/null <<!\ndatabase %s;\nunload to \"%s/backup/%s\" select * from %s;\n!", getenv("DBNAME"), getenv("WORKDIR"), backup_table[i], backup_table[i] );
    
62.                 ret = system ( buff );
    
63.        
    
64.                 if ( ret ) {
    
65.                         errcall ( ERROR , "Unable unload %s!", backup_table[i]);
    
66.                         return -1;
    
67.                 }
    
68. #else
    
69.                 sprintf ( buff ,\
    
70.                         "unload to %s/backup/%s select * from %s ", getenv("WORKDIR"), backup_table[i], backup_table[i] );
    
71.                 ret = sql_run(buff);
    
72.        
    
73.                 if (ret < 0) {
    
74.                         errcall ( ERROR , "Unable unload %s! failed![%d]", backup_table[i], ret);
    
75.                         return -1;
    
76.                 }
    
77. #endif       
    
78. 
    
79.         }
    
80. 
    
81.         return 0;
    
82. }
    
83. 
    
84. int recovery_ls ()
    
85. {
    
86.         char buff[1024];
    
87.         int ret;
    
88.        
    
89.         int i = 0;
    
90.        
    
91.         while (backup_table[i] != NULL && backup_table[i][0] != '\0') {
    
92. #ifdef Wubin_mod_20020509
    
93.                 sprintf ( buff ,\
    
94.                         "dbaccess - - 2>;/dev/null 1>;/dev/null <<!\ndatabase %s;\nload from \"%s/backup/%s\" insert into %s;\n!", getenv("DBNAME"), getenv("WORKDIR"), backup_table[i], backup_table[i]);
    
95.                 ret=system ( buff );
    
96.        
    
97.                 if ( ret ) {
    
98.                         errcall ( ERROR , "Unable load %s!", backup_table[i] );
    
99.                         return -1;
    
100.                 }
     
101. #else
     
102.                 sprintf ( buff ,\
     
103.                         "load from %s/backup/%s insert into %s ", getenv("WORKDIR"), backup_table[i], backup_table[i]);
     
104.                 ret = sql_run(buff);
     
105.        
     
106.                 if (ret < 0) {
     
107.                         errcall ( ERROR , "Unable load %s! failed![%d]", backup_table[i], ret );
     
108.                         return -1;
     
109.                 }
     
110. #endif       
     
111.         }
     
112. 
     
113.         return 0;
     
114. }
     
115. 
     
116. int backup_proc ()
     
117. {
     
118.         char        filename[250], tmp[81];
     
119.         int                ch, line, ret;
     
120.         char        cmd[300], fileout[128], backup_date[9];
     
121. 
     
122.         tmp[0] = backup_date[0] = 0;       
     
123.         ch = ret = 0;
     
124. 
     
125.         sprintf(filename, "/tmp/.backup_proc.%d", getpid());
     
126.         scr_dump(filename);
     
127.        
     
128.         DispBelow("数据备份处理");
     
129.         clear_wline(stdscr, LINES-1);
     
130.         my_win = newwin(19, 80, 3, 0);
     
131.         mvwprintw(my_win, 0, 0, "━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
     
132.         wrefresh(my_win);
     
133. 
     
134.         line = COL_LEE;
     
135. 
     
136.         if ( yorn(my_win, line++, "    是否进行数据备份处理?", "1.是", "0.否", 1, 0)) {
     
137.                 goto end;
     
138.         }
     
139. 
     
140.         strcpy(fileout, " 磁带 ");
     
141.         ch = strlen(fileout) + 1;
     
142.         strcpy(fileout + ch, " 硬盘 ");
     
143.         ch += strlen(fileout + ch) + 1;
     
144.         strcpy(fileout + ch, " 取消 ");
     
145.         ch = multi_select(my_win, 1, "    请选择备份存储设备:", fileout, 3, 1, 0, 0);
     
146. 
     
147.         if (ch == 2) {
     
148.                 goto end;
     
149.         }
     
150. 
     
151.         if (ch == 1) {
     
152.                 getdatef(backup_date,"");
     
153.                 mvwprintw(my_win, 2, 4, "请输入备份日期(YYYYMMDD): [%s]", backup_date);
     
154.                 if (in_item(my_win, "", 2, 31, backup_date, 8, NULL, NULL, 0, 0) != ENTER) {
     
155.                         goto end;
     
156.                 }
     
157.                 mvwprintw(my_win, 2, 4, "                                                               ");
     
158. 
     
159.                 strcpy(fileout, " 交易流水 ");
     
160.                 ch = strlen(fileout) + 1;
     
161.                 strcpy(fileout + ch, " 所有路由 ");
     
162.                 ch += strlen(fileout + ch) + 1;
     
163.                 strcpy(fileout + ch, " 基本资料 ");
     
164.                 ch += strlen(fileout + ch) + 1;
     
165.                 strcpy(fileout + ch, " 取消 ");
     
166.                 ch = multi_select(my_win, 1, "    请选择需要备份的数据:", fileout, 4, 3, 0, 0);
     
167. 
     
168.                 switch (ch) {
     
169.                     case 0:
     
170.                         strcpy(tmp, "TRAN_LS");
     
171.                         break;
     
172.                            case 1:
     
173.                         strcpy(tmp, "ROUTE");
     
174.                         break;
     
175.                            case 2:
     
176.                         strcpy(tmp, "INFOMATION");
     
177.                         break;
     
178.                            case 3:
     
179.                         goto end;
     
180.                         break;
     
181. 
     
182.                             default:
     
183.                         goto end;
     
184.                         break;
     
185.                 }
     
186. 
     
187. /*                 daylog(DEBUG, "正在生成备份数据, 备份日期: %s, 请稍候 ...", backup_date);                 */
     
188.                 mvwprintw(my_win, 4, 4, "正在生成备份数据, 请稍候 ...");
     
189.                 wrefresh(my_win);
     
190. 
     
191.                 ret = backup_db(tmp, backup_date);
     
192.                
     
193.                 if (ret == 0) {
     
194.                         sprintf ( cmd , "备份数据成功, 按任一键继续... [%s/backup/%s]", getenv("WORKDIR"), backup_date);
     
195. /*                         sprintf ( cmd , "备份数据成功, 按任一键继续..."); */
     
196.                         mvwaddstr ( my_win , 17 , 4 , cmd );
     
197.                         wgetch ( my_win );
     
198.                         goto end;
     
199.                 } else {
     
200.                         errcall ( ERROR , "Unable backup ls !\n" );
     
201.                         sprintf ( cmd , "备份数据失败, 按任一键继续... [%s/backup/%s]", getenv("WORKDIR"), backup_date);
     
202.                         sprintf ( cmd , "备份数据失败, 按任一键继续...");
     
203.                         mvwaddstr ( my_win , 17 , 4 , cmd );
     
204.                         wgetch ( my_win );
     
205. 
     
206.                         delwin(my_win);
     
207.                         scr_restore(filename);
     
208.                         unlink(filename);
     
209.                         return -1;
     
210.                 }
     
211.         }
     
212. 
     
213.         sprintf ( cmd , "rm -f %s/backup/*" , WD );
     
214.         system ( cmd );
     
215. 
     
216.         if ( backup_ls () < 0 ) {
     
217.                 errcall ( ERROR , "Unable backup ls !\n" );
     
218.                 sprintf ( cmd , "备份数据失败, 按任一键继续...");
     
219.                 mvwaddstr ( my_win , 17 , 4 , cmd );
     
220.                 wgetch ( my_win );
     
221. 
     
222.                 delwin(my_win);
     
223.                 scr_restore(filename);
     
224.                 unlink(filename);
     
225.                 return -1;
     
226.         }
     
227.        
     
228.         if ( yorn(my_win, line++,
     
229.                 "    是否将数据倒入磁带?", "1.是", "0.否", 1, 0)) {
     
230.                 delwin(my_win);
     
231.                 scr_restore(filename);
     
232.                 unlink(filename);
     
233.                 return(0);
     
234.         }
     
235. 
     
236.         sprintf(cmd,
     
237.         "tar cv8 2>;/dev/null 1>;/dev/null %s/etc %s/install %s/backup %s/box",
     
238.                 WD , WD , WD , WD );
     
239.         if ( system ( cmd ) != 0 ) {
     
240.                 wrefresh( my_win );
     
241.                 sprintf ( cmd , "备份数据失败, 按任一键继续...");
     
242.                 mvwaddstr ( my_win , 17 , 4 , cmd );
     
243.                 wgetch ( my_win );
     
244.         } else {
     
245.                 sprintf ( cmd , "备份数据成功, 按任一键继续...");
     
246.                 mvwaddstr ( my_win , 17 , 4 , cmd );
     
247.                 wgetch ( my_win );
     
248.         }
     
249. 
     
250. end:
     
251.         delwin(my_win);
     
252.         scr_restore(filename);
     
253.         unlink(filename);
     
254.        
     
255.         return 0;
     
256. }
     
257. 
     
258. int recovery_proc ()
     
259. {
     
260.         char        filename[250], tmp[81], backup_date[9];
     
261.         int                ch, line, ret;
     
262.         char        cmd[300], fileout[128];
     
263. 
     
264.         ret = 0;        tmp[0] = backup_date[0] = 0;       
     
265.         ch = ret = 0;
     
266. 
     
267.         sprintf(filename, "/tmp/.recovery_proc.%d", getpid());
     
268.         scr_dump(filename);
     
269.        
     
270.         DispBelow("数据恢复处理");
     
271.         clear_wline(stdscr, LINES-1);
     
272.         my_win = newwin(19, 80, 3, 0);
     
273.         mvwprintw(my_win, 0, 0, "━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
     
274.         wrefresh(my_win);
     
275.        
     
276.         line = COL_LEE;
     
277.        
     
278.         if (yorn(my_win, line++, " 注意: 如果恢复数据将覆盖当前数据库中的数据, 是否进行数据恢复?", "1.是", "0.否", 1, 0)) {
     
279.                 goto end;
     
280.         }
     
281. 
     
282.         strcpy(fileout, " 磁带 ");
     
283.         ch = strlen(fileout) + 1;
     
284.         strcpy(fileout + ch, " 硬盘 ");
     
285.         ch += strlen(fileout + ch) + 1;
     
286.         strcpy(fileout + ch, " 取消 ");
     
287.         ch = multi_select(my_win, 1, "    请选择存储恢复数据的设备:", fileout, 3, 2, 0, 0);
     
288. 
     
289.         if (ch == 2) {
     
290.                 goto end;
     
291.         }
     
292. 
     
293.         if (ch == 1) {
     
294.                 strcpy(backup_date,"        ");
     
295.                 mvwprintw(my_win, 2, 4, "请输入恢复数据日期(YYYYMMDD): [%s]", backup_date);
     
296.                 if (in_item(my_win, "", 2, 35, backup_date, 8, NULL, NULL, 0, 0) != ENTER) {
     
297.                         goto end;
     
298.                 }
     
299.         sprintf(tmp, "cd %s/backup/%s >;/dev/null 2>;&1", getenv("WORKDIR"), backup_date);
     
300.         ret = system(tmp);
     
301.         if ( ret ) {
     
302.                 errcall ( ERROR , "Not found %s/backup/%s", getenv("WORKDIR"), backup_date);
     
303.                         sprintf ( cmd , "需要恢复的数据[%s/backup/%s]不存在", getenv("WORKDIR"), backup_date);
     
304.                         mvwaddstr ( my_win , 17 , 4 , cmd );
     
305.                         wgetch ( my_win );
     
306. 
     
307.                         delwin(my_win);
     
308.                         scr_restore(filename);
     
309.                         unlink(filename);
     
310.                         return -1;
     
311.                 }
     
312. 
     
313.                 mvwprintw(my_win, 2, 4, "                                                               ");
     
314. 
     
315.                 strcpy(fileout, " 交易流水 ");
     
316.                 ch = strlen(fileout) + 1;
     
317.                 strcpy(fileout + ch, " 所有路由 ");
     
318.                 ch += strlen(fileout + ch) + 1;
     
319.                 strcpy(fileout + ch, " 基本资料 ");
     
320.                 ch += strlen(fileout + ch) + 1;
     
321.                 strcpy(fileout + ch, " 取消 ");
     
322.                 ch = multi_select(my_win, 1, "    请选择需要恢复的数据:", fileout, 4, 3, 0, 0);
     
323. 
     
324.                 if (ch == 3)
     
325.                          goto end;
     
326.                 if (yorn(my_win, line++, " 注意: 数据恢复将覆盖当前数据库中的数据, 是否进行数据恢复?", "1.是", "0.否", 1, 0)) {
     
327.                         goto end;
     
328.                 }
     
329. 
     
330.                 switch (ch) {
     
331.                     case 0:
     
332.                         strcpy(tmp, "TRAN_LS");
     
333.                         break;
     
334.                            case 1:
     
335.                         strcpy(tmp, "ROUTE");
     
336.                         break;
     
337.                            case 2:
     
338.                         strcpy(tmp, "INFOMATION");
     
339.                         break;
     
340.                            case 3:
     
341.                         goto end;
     
342.                         break;
     
343. 
     
344.                             default:
     
345.                         goto end;
     
346.                         break;
     
347.                 }
     
348. 
     
349.                 mvwprintw(my_win, 4, 4, "正在向数据库中恢复数据, 请稍候 ...");
     
350.                 wrefresh(my_win);
     
351. 
     
352.                 ret = recovery_db(tmp, backup_date);
     
353.                
     
354.                 if (ret == 0) {
     
355.                         sprintf ( cmd , "恢复数据成功, 按任一键继续...");
     
356.                         mvwaddstr ( my_win , 17 , 4 , cmd );
     
357.                         wgetch ( my_win );
     
358.                         goto end;
     
359.                 } else {
     
360.                         errcall ( ERROR , "Unable recovery ls !\n" );
     
361.                         sprintf ( cmd , "恢复数据失败, 按任一键继续...");
     
362.                         mvwaddstr ( my_win , 17 , 4 , cmd );
     
363.                         wgetch ( my_win );
     
364. 
     
365.                         delwin(my_win);
     
366.                         scr_restore(filename);
     
367.                         unlink(filename);
     
368.                         return -1;
     
369.                 }
     
370.         }
     
371. 
     
372.         if (yorn(my_win, line++, "    是否从磁带装入数据?", "1.是", "0.否", 1, 0))
     
373.                 goto end;
     
374.         else {
     
375.                 sprintf ( cmd , "rm -f %s/backup/* >;/dev/null 2>;&1" , WD );
     
376.                 system ( cmd );
     
377. 
     
378.                 sprintf ( cmd , "tar xv8 >;/dev/null 2>;&1" );
     
379.                 ret = system ( cmd );
     
380.                 if ( ret ) {
     
381.                         errcall ( ERROR , "Execute error!(%s) ", cmd);
     
382.                         sprintf ( cmd , "读写磁带设备失败, 请确认磁带设备是否正常 按任一键继续...");
     
383.                         mvwaddstr ( my_win , 17 , 4 , cmd );
     
384.                         wgetch ( my_win );
     
385. 
     
386.                         delwin(my_win);
     
387.                         scr_restore(filename);
     
388.                         unlink(filename);
     
389.                         return -1;
     
390.                 }
     
391.         }
     
392. 
     
393.        
     
394.         if ( recovery_ls () < 0 ) {
     
395.                 errcall ( ERROR , "Unable recovery ls !\n" );
     
396.                 sprintf ( cmd , "恢复数据失败, 按任一键继续...");
     
397.                 mvwaddstr ( my_win , 17 , 4 , cmd );
     
398.                 wgetch ( my_win );
     
399. 
     
400.                 delwin(my_win);
     
401.                 scr_restore(filename);
     
402.                 unlink(filename);
     
403.                 return -1;
     
404.         }
     
405.        
     
406.         sprintf ( cmd , "恢复数据成功, 按任一键继续...");
     
407.         mvwaddstr ( my_win , 17 , 4 , cmd );
     
408.         wgetch ( my_win );
     
409. 
     
410. end:
     
411.         delwin(my_win);
     
412.         scr_restore(filename);
     
413.         unlink(filename);
     
414.        
     
415.         return 0;
     
416. }
     
417. 
     
418. 
     
419. /*================== WuBin 2001-9-8 15:33 ======Start==============
     
420. 根据库表名备份数据到相应日期的目录
     
421. ===========================2001-9-8 15:33=======End==============*/
     
422. 
     
423. int backup_db (char *table_name, char *backup_date)
     
424. {
     
425.         $char buff[1024], tmp[150];
     
426.         int ret, i;
     
427.         struct table_arry_st table_arry[50];        /* 目标数组名 */
     
428.        
     
429.         memset(table_arry, '\0', sizeof(table_arry));
     
430.         i = ret = 0;
     
431.        
     
432.         sprintf(buff, "mkdir %s/backup/%s >;/dev/null 2>;&1", getenv("WORKDIR"), backup_date);
     
433.         system(buff);
     
434. 
     
435.         sprintf(tmp, "%s/etc/backup_table", getenv("WORKDIR"));
     
436.         ret = readtab2arry(tmp, table_name, table_arry);
     
437. 
     
438.         if ( ret ) {
     
439.                         errcall ( ERROR , "Read %s Error! ", tmp);
     
440.                         return -1;
     
441.         }
     
442. 
     
443.         while (table_arry[i].table_name[0] != 0 ) {
     
444.                 sprintf(buff, "rm -f %s/backup/%s/%s >;/dev/null 2>;&1", getenv("WORKDIR"), backup_date, table_arry[i].table_name);
     
445.                 system(buff);
     
446.                 i++;
     
447.         }
     
448.         i = 0;
     
449.         while (table_arry[i].table_name[0] != 0) {
     
450.                 memset(buff, 0, sizeof(buff));
     
451. #ifdef Wubin_mod_20020509
     
452.                 sprintf ( buff , "dbaccess - - 2>;/dev/null 1>;/dev/null <<!\ndatabase %s;\nunload to \"%s/backup/%s/%s\" select * from %s;\n!", getenv("DBNAME"), getenv("WORKDIR"), backup_date, table_arry[i].table_name, table_arry[i].table_name );
     
453.                 ret = system ( buff );
     
454.                 if ( ret ) {
     
455.                         errcall ( ERROR , "Unable unload %s! [ret =  %d]", table_arry[i].table_name, ret);
     
456.                         return -1;
     
457.                 }
     
458. #else
     
459.                 sprintf ( buff , "unload to %s/backup/%s/%s select * from %s ", getenv("WORKDIR"), backup_date, table_arry[i].table_name, table_arry[i].table_name );
     
460. 
     
461.                 ret = sql_run(buff);
     
462.        
     
463.                 if (ret < 0) {
     
464.                         errcall(ERROR, "Unable unload %s! failed![%d]", table_arry[i].table_name, ret);
     
465.                         return -1;
     
466.                 }
     
467. #endif
     
468.                 i++;
     
469.         }
     
470.         return 0;
     
471. }
     
472. 
     
473. 
     
474. 
     
475. /*================== WuBin 2001-9-8 15:33 ======Start==============
     
476. 根据库表名恢复数据从相应日期的目录
     
477. ===========================2001-9-8 15:33=======End==============*/
     
478. int recovery_db (char *table_name, char *backup_date)
     
479. {
     
480.         char buff[1024], tmp[150];
     
481.         int ret, i;
     
482.         struct table_arry_st rc_table_arry[50];        /* 目标数组名 */
     
483.        
     
484.         memset(rc_table_arry, '\0', sizeof(rc_table_arry));
     
485.         i = ret = 0;
     
486.        
     
487.         sprintf(buff, "cd %s/backup/%s >;/dev/null 2>;&1", getenv("WORKDIR"), backup_date);
     
488.         ret = system(buff);
     
489.         if ( ret ) {
     
490.                         errcall ( ERROR , "Not found %s", buff);
     
491.                         return -1;
     
492.                 }
     
493. 
     
494.         sprintf(tmp, "%s/etc/backup_table", getenv("WORKDIR"));
     
495.         ret = readtab2arry(tmp, table_name, rc_table_arry);
     
496. 
     
497.         if ( ret ) {
     
498.                         errcall ( ERROR , "Read %s Error!", tmp);
     
499.                         return -1;
     
500.         }
     
501.        
     
502.         while (rc_table_arry[i].table_name[0] != 0 ) {
     
503.                 sprintf(buff, "ls %s/backup/%s/%s >;/dev/null 2>;&1", getenv("WORKDIR"), backup_date, rc_table_arry[i].table_name);
     
504.                 ret = system(buff);
     
505.                 if ( ret ) {
     
506.                         errcall ( ERROR , "Read %s Error!", rc_table_arry[i].table_name);
     
507.                         return -1;
     
508.                 }
     
509.                 i++;
     
510.         }
     
511.         i = 0;
     
512.         while (rc_table_arry[i].table_name[0] != 0) {
     
513. #ifdef Wubin_mod_20020509
     
514.                 sprintf ( buff , "dbaccess - - 2>;/dev/null 1>;/dev/null <<!\ndatabase %s;\ndelete from %s;\n!", getenv("DBNAME"), rc_table_arry[i].table_name );
     
515.                 ret = system ( buff );
     
516.                 if ( ret ) {
     
517.                         errcall ( ERROR , "Unable delete %s [ret = %d]!", rc_table_arry[i].table_name, ret);
     
518.                         return -1;
     
519.                 }
     
520. #else
     
521.                 sprintf ( buff , "delete from %s;\n!", rc_table_arry[i].table_name );
     
522.                 ret = sql_run(buff);
     
523.        
     
524.                 if (ret < 0) {
     
525.                         errcall ( ERROR , "Unable delete %s failed![%d]", rc_table_arry[i].table_name, ret);
     
526.                         return -1;
     
527.                 }
     
528. #endif
     
529. 
     
530. #ifdef Wubin_mod_20020509
     
531.                 sprintf ( buff , "dbaccess - - 2>;/dev/null 1>;/dev/null <<!\ndatabase %s;\nload from \"%s/backup/%s/%s\" insert into %s;\n!", getenv("DBNAME"), getenv("WORKDIR"), backup_date, rc_table_arry[i].table_name, rc_table_arry[i].table_name );
     
532.                 ret = system ( buff );
     
533.                 if ( ret ) {
     
534.                         errcall ( ERROR , "Unable load %s [ret = %d]!", rc_table_arry[i].table_name, ret);
     
535.                         return -1;
     
536.                 }
     
537. #else
     
538.                 sprintf ( buff , "dload from %s/backup/%s/%s insert into %s ", getenv("WORKDIR"), backup_date, rc_table_arry[i].table_name, rc_table_arry[i].table_name );
     
539.                 ret = sql_run(buff);
     
540.        
     
541.                 if (ret < 0) {
     
542.                         errcall ( ERROR , "Unable load %s failed![%d]", rc_table_arry[i].table_name, ret);
     
543.                         return -1;
     
544.                 }
     
545. #endif
     
546.                 i++;
     
547.         }
     
548. 
     
549.         return 0;
     
550. }
     
551. 
     
552. 
     

复制代码

以下是 sql_run 功能的实现

1. 
   
2. 
   
3. /**************************************************************
   
4. * 功能:                 数据库处理公共函数 public.ec
   
5. * 最后修改日期:       
   
6. *
   
7. * 周国祥        2002/04/09 从dbprg/public.ec中分离过来
   
8. **************************************************************/
   
9. 
   
10. #include <stdio.h>;
    
11. #include <curses.h>;
    
12. #include "mytools.h"
    
13. 
    
14. EXEC SQL INCLUDE sqlca;
    
15. EXEC SQL WHENEVER SQLERROR CALL error_handler;
    
16. EXEC SQL WHENEVER SQLWARNING CALL warning_handler;
    
17. EXEC SQL WHENEVER NOT FOUND CALL notfound_handler;
    
18. 
    
19. $char sqlstring[2000];
    
20. 
    
21. $include "db_struct.h";
    
22. 
    
23. int sql_run(str)
    
24. char *str;
    
25. {
    
26.         strcpy(sqlstring,str);
    
27.         EXEC SQL PREPARE s_comm FROM :sqlstring;
    
28.         if (sqlca.sqlcode) {
    
29.                 errcall(ERROR, "%d", sqlca.sqlcode);
    
30.                 return (sqlca.sqlcode);
    
31.         }
    
32.         EXEC SQL EXECUTE s_comm;
    
33.         return(sqlca.sqlcode);
    
34. }
    
35. 
    
36. int query_count(str)
    
37. char *str;
    
38. {
    
39.         $int counts;
    
40.         $short indi;
    
41. 
    
42.         strcpy(sqlstring,str);
    
43.         EXEC SQL PREPARE q_comm_1 FROM :sqlstring;
    
44.         if (sqlca.sqlcode) {
    
45.                 errcall(ERROR, "PREPARE [%s] failed (%d)",
    
46.                         sqlstring, sqlca.sqlcode);
    
47.                 return -1;
    
48.         }
    
49. 
    
50.         EXEC SQL DECLARE query_cur CURSOR FOR q_comm_1;
    
51.         if (sqlca.sqlcode) {
    
52.                 errcall(ERROR, "DECLARE [%s] failed (%d)",
    
53.                         sqlstring, sqlca.sqlcode);
    
54.                 return -1;
    
55.         }
    
56.         EXEC SQL OPEN query_cur;
    
57.         if (sqlca.sqlcode) {
    
58.                 errcall(ERROR, "OPEN [%s] failed (%d)",
    
59.                         sqlstring, sqlca.sqlcode);
    
60.                 return -1;
    
61.         }
    
62.         EXEC SQL FETCH query_cur INTO :counts:indi;
    
63.         if (sqlca.sqlcode && sqlca.sqlcode == 100) {
    
64.                 errcall(ERROR, "FETCH failed (%d)",
    
65.                         sqlca.sqlcode);
    
66.                 return -1;
    
67.         }
    
68.         if ((indi == -1) || sqlca.sqlcode) counts = 0;
    
69.         EXEC SQL CLOSE query_cur;
    
70. 
    
71.         return(counts);
    
72. }
    
73. 
    
74. long calc_long(str)
    
75. char *str;
    
76. {
    
77.         $long total;
    
78.         $short indi;
    
79. 
    
80.         strcpy(sqlstring,str);
    
81.         EXEC SQL PREPARE q_comm_2 FROM :sqlstring;
    
82.         EXEC SQL DECLARE calcl_cur CURSOR FOR q_comm_2;
    
83.         EXEC SQL OPEN calcl_cur;
    
84.         EXEC SQL FETCH calcl_cur INTO :total:indi;
    
85.         if ((indi == -1) || sqlca.sqlcode) total = 0;
    
86.         EXEC SQL CLOSE calcl_cur;
    
87.         return(total);
    
88. }
    
89. 
    
90. double calc_double(str)
    
91. char *str;
    
92. {
    
93.         $double total;
    
94.         $short indi;
    
95. 
    
96.         strcpy(sqlstring,str);
    
97.         EXEC SQL PREPARE q_comm_3 FROM :sqlstring;
    
98.         EXEC SQL DECLARE calcd_cur CURSOR FOR q_comm_3;
    
99.         EXEC SQL OPEN calcd_cur;
    
100.         EXEC SQL FETCH calcd_cur INTO :total:indi;
     
101.         if ((indi == -1) || sqlca.sqlcode) total = 0;
     
102.         EXEC SQL CLOSE calcd_cur;
     
103.         return(total);
     
104. }
     
105. 
     
106. int get_title(char *title_name)
     
107. {
     
108.         $char center_name[41];
     
109.         $short indi;
     
110.         $char        bankid[12], hostid[3];
     
111. 
     
112.         title_name[0] = 0;
     
113.         EXEC SQL SELECT bank_id, host_id
     
114.                 INTO :bankid, :hostid
     
115.                 FROM sys_param;
     
116.         if (sqlca.sqlcode)
     
117.                 return(sqlca.sqlcode);
     
118.         DelSpace(bankid);
     
119.         DelSpace(hostid);
     
120. 
     
121.         EXEC SQL SELECT bank_name
     
122.                 INTO :center_name
     
123.                 FROM bank_info
     
124.                 WHERE bank_id = :bankid and host_id = :hostid;
     
125.         if (!sqlca.sqlcode)
     
126.                 strcpy(title_name, center_name);
     
127.         return(sqlca.sqlcode);
     
128. }
     
129. 
     
130. /*
     
131. * 获取bankid之IP地址
     
132. */
     
133. int        get_ipaddr( id_in, hid_in, ip_in )
     
134. char        id_in[12], hid_in[3], ip_in[21];
     
135. {
     
136.         $char id[12], ip[21];
     
137.         int        len;
     
138. 
     
139.         memcpy(id, id_in, 12);
     
140.         memcpy(ip, ip_in, 21);
     
141. 
     
142.         EXEC SQL DECLARE addr_cur CURSOR FOR
     
143.         SELECT tran_ip_addr1
     
144.         FROM        bank_base
     
145.         WHERE        bank_id = :id;
     
146. 
     
147.         EXEC SQL OPEN addr_cur;
     
148.         EXEC SQL FETCH addr_cur INTO :ip;
     
149.         if (sqlca.sqlcode)
     
150.                 return(sqlca.sqlcode);
     
151. 
     
152.         DelSpace(ip);
     
153.         strcpy(ip_in, ip);
     
154.        
     
155.         return (0);
     
156. }
     
157. 
     
158. int get_master(card, t)
     
159. char *card;
     
160. $parameter S_card_acct *t;
     
161. {
     
162.         $char m_card_no[19];
     
163.        
     
164.         sprintf(m_card_no,"%12.12s?00?",card);
     
165. /*================== WuBin 2001-4-9 21:02 ======Start==============
     
166.         EXEC SQL SELECT T41_card_no, T41_c_amt, T41_auth_cnt, T41_auth_amt,
     
167.                         T41_auth_total, T41_balance, T41_deposit_cnt,
     
168.                         T41_deposit_amt
     
169.                  INTO :t->;T41_master_card_no, :t->;T41_c_amt, :t->;T41_auth_cnt,
     
170.                       :t->;T41_auth_amt, :t->;T41_auth_total, :t->;T41_balance,
     
171.                       :t->;T41_deposit_cnt, :t->;T41_deposit_amt
     
172.                  FROM card_acct
     
173.                  WHERE T41_card_no MATCHES :m_card_no;
     
174. ===========================2001-4-9 21:02=======End==============*/
     
175.         EXEC SQL SELECT card_no, card_amt, auth_cnt, auth_amt,
     
176.                         auth_total, balance, deposit_cnt,
     
177.                         deposit_amt
     
178.                  INTO :t->;card_no, :t->;card_amt, :t->;auth_cnt,
     
179.                       :t->;auth_amt, :t->;auth_total, :t->;balance,
     
180.                       :t->;deposit_cnt, :t->;deposit_amt
     
181.                  FROM card_acct
     
182.                  WHERE card_no MATCHES :m_card_no;
     
183. 
     
184. 
     
185.         return(sqlca.sqlcode);
     
186. }
     
187. 
     
188. 
     
189. int get_master_cardno(char *card, char *master)
     
190. {
     
191.         $char card_no[19],master_cardno[19],acc[13];
     
192.        
     
193.         strcpy(card_no,card);
     
194.         memcpy(acc,card_no,12);
     
195.         acc[12]='\0';
     
196. 
     
197. /*================== WuBin 2001-4-9 21:14 ======Start==============
     
198.         EXEC SQL SELECT MAX(T41_card_no) INTO :master_cardno
     
199.                  FROM card_t
     
200.                  WHERE T41_card_no[1,12] =:acc AND  
     
201.                        T41_card_no[14,15]="00";
     
202. ===========================2001-4-9 21:14=======End==============*/
     
203.         EXEC SQL SELECT MAX(card_no) INTO :master_cardno
     
204.                  FROM card_acct
     
205.                  WHERE card_no[1,12] =:acc AND  
     
206.                        card_no[14,15]="00";
     
207. 
     
208.         memcpy(master,master_cardno,19);
     
209. 
     
210.         if(SQLCODE)  errcall(ERROR,"get_master_cardno error! [%d]",SQLCODE);
     
211. 
     
212.         return(sqlca.sqlcode);
     
213. }
     
214. 
     
215. /* 获取主卡帐户状态 */
     
216. int get_master_accstat(char *card, char *stat)
     
217. {
     
218.         $char a_stat[2],master[19];
     
219.         char card_no[19];
     
220.         int ret;
     
221.        
     
222.         strcpy(card_no,card);
     
223. 
     
224.         ret=get_master_cardno(card_no,master);
     
225.         if(ret) return(ret);
     
226. 
     
227. /*================== WuBin 2001-4-9 21:16 ======Start==============
     
228.         EXEC SQL SELECT T41_a_stat INTO :a_stat
     
229.                  FROM card_acct
     
230.                  WHERE T41_card_no = :master;
     
231. ===========================2001-4-9 21:16=======End==============*/
     
232.         EXEC SQL SELECT master_stat INTO :a_stat
     
233.                  FROM card_acct
     
234.                  WHERE card_no = :master;
     
235. 
     
236.         memcpy(stat,a_stat,1);
     
237. 
     
238.         if(SQLCODE<0)  errcall(ERROR,"get_master_accstat error! [%d]",SQLCODE);
     
239.         return(sqlca.sqlcode);
     
240. }
     
241. 
     
242. 
     
243. int get_master_accno(char *card, char *no)
     
244. {
     
245.         $char acc_no[22],master[19];
     
246.         char card_no[19];
     
247.         int ret;
     
248.        
     
249.         strcpy(card_no,card);
     
250. 
     
251.         ret=get_master_cardno(card_no,master);
     
252.         if(ret) return(ret);
     
253. 
     
254. /*================== WuBin 2001-4-9 21:17 ======Start==============
     
255.         EXEC SQL SELECT T41_acc_no INTO :acc_no
     
256.                  FROM card_acct
     
257.                  WHERE T41_card_no = :master;
     
258. ===========================2001-4-9 21:17=======End==============*/
     
259.         EXEC SQL SELECT acct_no INTO :acc_no
     
260.                  FROM card_acct
     
261.                  WHERE card_no = :master;
     
262. 
     
263.         memcpy(no,acc_no,12); /* 帐户号现只用12位 */
     
264. 
     
265.         if(SQLCODE)  errcall(ERROR,"get_master_accno error! [%d]",SQLCODE);
     
266.         return(sqlca.sqlcode);
     
267. }
     
268. 
     
269. /*
     
270. * 根据商户号获取签约行行号及主机号
     
271. */
     
272. int get_sign_bank(merchantid, bankid, hostid)
     
273. char        *merchantid, *bankid, *hostid;
     
274. {
     
275.         $char        merchant_id[16], bank_id[12], host_id[3];
     
276. 
     
277.         strcpy(merchant_id, merchantid);
     
278.         DelSpace(merchant_id);
     
279.         $select sign_bank_id, sign_host_id
     
280.         into $bank_id, $host_id
     
281.         from merchant_base
     
282.         where merchant_id = $merchant_id;
     
283. 
     
284.         if (SQLCODE) {
     
285.                 errcall(ERROR, "get_sign_bank(%s) select eerror(%d)!", merchant_id, SQLCODE);
     
286.                 bankid[0] = '\0';
     
287.                 hostid[0] = '\0';
     
288.                 return(-1);
     
289.         }
     
290.         DelSpace(bank_id);
     
291.         DelSpace(host_id);
     
292.         strcpy(bankid, bank_id);
     
293.         strcpy(hostid, host_id);
     
294.         return(0);
     
295. }
     
296. 
     
297. /*
     
298. *        根据货币代码获取货币的中文名称 ADD Wubin
     
299. */
     
300. 
     
301. int get_ccy_name(char *id, char *name)
     
302. {
     
303.         $char ccy_id[16], cn_name[31];
     
304. 
     
305.         cn_name[0] = 0;
     
306. 
     
307.         strcpy(ccy_id, id);
     
308. 
     
309.         EXEC SQL SELECT ccy_name INTO :cn_name FROM ccy_type WHERE ccy_type = :ccy_id;
     
310. 
     
311.         if (sqlca.sqlcode == 0) {
     
312.                 rm_tail_space(cn_name);
     
313.                 strcpy(name, cn_name);
     
314.         }
     
315. 
     
316.         return(sqlca.sqlcode);
     
317. }
     
318. 
     
319. $ifdef wyz020509_mod;
     
320. $else;
     
321. /*
     
322. int creat_prt_dir(bankid)
     
323. char        bankid[12];
     
324. {
     
325.         $char        sqlstr[512];
     
326.         $char        tmp_bankid[12];
     
327.         char        filename[128];
     
328. 
     
329.         sprintf(sqlstr, "SELECT bank_id from bank_info        \
     
330.                 where adm_bank_id = \'%s\'                \
     
331.                 or bank_id = \'%s\'",
     
332.                 bankid, bankid);
     
333. 
     
334.         EXEC SQL PREPARE sel_bank_id FROM :sqlstr;
     
335.         if( SQLCODE<0 ) {
     
336.                 errcall(ERROR, "PREPARE FAILED[%ld][%s]", SQLCODE, sqlstr);
     
337.                 return -1;
     
338.         }
     
339. 
     
340.         EXEC SQL DECLARE cur_sel_bank CURSOR WITH HOLD FOR sel_bank_id;
     
341.         if( SQLCODE<0 ) {
     
342.                 errcall(ERROR, "DECLARE FAILED[%ld][%s]", SQLCODE, sqlstr);
     
343.                 return -1;
     
344.         }
     
345. 
     
346.         EXEC SQL OPEN cur_sel_bank;
     
347.         if( SQLCODE<0 ) {
     
348.                 errcall(ERROR, "OPEN FAILED[%ld]", SQLCODE);
     
349.                 return -1;
     
350.         }
     
351. 
     
352.         while(1) {
     
353.                 EXEC SQL FETCH cur_sel_bank INTO :tmp_bankid;
     
354.                 if (SQLCODE < 0) {
     
355.                         errcall(ERROR, "FETCH FAILED(%d)", SQLCODE);
     
356.                         return -1;
     
357.                 }
     
358.                 else if (SQLCODE == 100)
     
359.                         break;
     
360. 
     
361.                 DelSpace(tmp_bankid);
     
362.                 sprintf(filename, "prt/%s", tmp_bankid);
     
363.                 if (create_tmp_file(filename) < 0) {
     
364.                         errcall(ERROR, "create_tmp_file(%s) failed", filename);
     
365.                 }
     
366.         }
     
367. 
     
368.         return 0;
     
369. }
     
370. */
     
371. $endif;
     
372. 
     

复制代码

上面的程序原理我也清楚，这些程序就是在我的 informix online 5.0 环境下没法执行。

fush76

这和你说的是两码事。
这是用shell实现load/unload,你是EC中是不可能用prepare实现的。

ljmmail

1. 
   
2. #ifdef Wubin_mod_20020509
   
3.       sprintf ( buff ,\
   
4.          "dbaccess - - 2>;/dev/null 1>;/dev/null <<!\ndatabase %s;\nload from \"%s/backup/%s\" insert into %s;\n!", getenv("DBNAME"), getenv("WORKDIR"), backup_table[i], backup_table[i]);
   
5.       ret=system ( buff );
   
6.    
   
7.       if ( ret ) {
   
8.          errcall ( ERROR , "Unable load %s!", backup_table[i] );
   
9.          return -1;
   
10.       }
    
11. #else
    
12.       sprintf ( buff ,\
    
13.          "load from %s/backup/%s insert into %s ", getenv("WORKDIR"), backup_table[i], backup_table[i]);
    
14.       ret = sql_run(buff);
    
15.    
    
16.       if (ret < 0) {
    
17.          errcall ( ERROR , "Unable load %s! failed![%d]", backup_table[i], ret );
    
18.          return -1;
    
19.            }
    
20. #endif   
    

复制代码

实际上我说的是上面的第二种条件编译的情况，你看在源程序中使用的 load from ..... 程序，然后它调用了 sql_run 进行装配执行，为何这样的程序在我的运行环境中就无法执行了？？

hiccb

哥们，你看看程序里明明在使用unload或者是unload的时候用的是system（buff） 呀？  只用在用insert或delete的时候才用sql_run(buff) 的  所以在ec里是不支持load和unload的：（

ljmmail

sprintf ( buff ,\
         "load from %s/backup/%s insert into %s ", getenv("WORKDIR", backup_table, backup_table);
      ret = sql_run(buff);

    你看清楚，我说的是以上语句的执行，这是一个 load 语句，程序就是在调用 sql_run 在执行吗！！！

fush76

TO: ljmmail.

我只能对你说三个字：


I　　服了  U.

wwwjek

TO: ljmmail.{:3_205:}

咱能不.....