免费注册 查看新帖 |

Chinaunix

  平台 论坛 博客 文库
› 论坛 › 程序设计 › C/C++ › 请问各位老鸟能不能提供一个和ORACLE数据库打交道得程序 ...
最近访问板块 发新帖
查看: 2121 | 回复: 7
打印 上一主题 下一主题

请问各位老鸟能不能提供一个和ORACLE数据库打交道得程序呢? [复制链接]

猫

论坛徽章:
0
跳转到指定楼层
1楼 [收藏(0)] [报告]
发表于 2003-02-23 16:14 |只看该作者 |倒序浏览
请问能不能提供一个和ORACLE打交道得程序呀,包括连接,执行SQL语句,和断开得,谢谢各位了
littletiger

论坛徽章:
0
2楼 [报告]
发表于 2003-02-23 16:41 |只看该作者

请问各位老鸟能不能提供一个和ORACLE数据库打交道得程序呢?

up  最好有测试oracle 的负载的代码   ：（
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
mengwg

论坛徽章:
0
3楼 [报告]
发表于 2003-02-23 19:41 |只看该作者

请问各位老鸟能不能提供一个和ORACLE数据库打交道得程序呢?

下面这个够复杂的，不过功能比较强大。
摘自：如何跨越数据库平台。
全文： http://cwqu.3322.org/itf_db.htm



  3. #include <itf_db.h>;
  4. #include <stdio.h>;
  5. #include <tbase.h>;

  7. #include <sqlca.h>;
  8. #include <sqlda.h>;
  9. #include <oraca.h>;

  11. EXEC ORACLE OPTION (ORACA=YES);

  13. #include <ctype.h>;
  14. #include <unistd.h>;

  16. int vabs(int id)
  17. {
  18.   if(id<0) return 0-id;
  19.   else
  20.   return id;
  21. }

  23. typedef struct
  24. {
  25.   int  Initlized;
  26.   char DbName[100];
  27.   char UserName[100];
  28.   char PassWord[100];
  29. }DbMgrStru;

  31. extern "C"
  32. {
  33.   void sqlclu(SQLDA*);
  34.   struct SQLDA * sqlald(int, unsigned int, unsigned int);
  35.   void sqlnul(unsigned short*, unsigned short*, int*);
  36. };

  38. DbMgrStru DbMgr={0};

  40. int _ShowRunSql_Switch=1;

  42. /* 连接数据库 */
  43. int DbConnect(char * dbname,char * username,char * password)
  44. {
  45. EXEC SQL BEGIN DECLARE SECTION;
  46.   char * pusername=username;
  47.   char * ppassword=password;
  48. EXEC SQL END DECLARE SECTION;

  50.   strcpy(DbMgr.UserName,pusername);
  51.   strcpy(DbMgr.PassWord,ppassword);
  52.   EXEC SQL CONNECT :pusername IDENTIFIED BY :ppassword;
  53.   if(sqlca.sqlcode!=0)
  54.     printf("connect to database error : sqlcode is %d u: %s p: %s\n",sqlca.sqlcode,pusername,ppassword);
  55.   puts("\n");
  56.   puts("**************************************************************");
  57.   printf("             SIG ORA ITF IS STARTING: MaxConnection: %d\n",1);
  58.   puts("**************************************************************");
  59.   puts("\n");
  60.   return 1;
  61. }

  63. int DbBeginTran(DBDataMgr * ddm)
  64. {
  65.   DbExecuteSql(ddm,"begintran");
  66.   return 1;
  67. }

  69. int DbCommit(DBDataMgr * ddm)
  70. {
  71.   DbExecuteSql(ddm,"commit");
  72.   return 1;
  73. }

  75. int DbRollback(DBDataMgr * ddm)
  76. {
  77.   DbExecuteSql(ddm,"rollback");
  78.   return 1;
  79. }

  81. int DbDisconnect()
  82. {
  83.   DbExecuteSql(NULL,"commit");
  84.   EXEC SQL COMMIT WORK RELEASE;
  85.   return 1;
  86. }

  88. #define MAX_ITEMS         140
  89. #define MAX_VNAME_LEN     130
  90. #define MAX_INAME_LEN     130

  92. char * GetErrorMsg()
  93. {
  94. static char buf[1024];
  95.         sprintf(buf,"\n%.*s\n", sqlca.sqlerrm.sqlerrml,
  96.                                                  sqlca.sqlerrm.sqlerrmc);
  97.   return buf;
  98. }

  100. int DbShowError()
  101. {
  102.   printf("sqlerr: sqlcode is '%d' errmsg: '%s'\n",
  103.     sqlca.sqlcode,GetErrorMsg());
  104.   return 0;
  105. };

  107. int DbBatchInsert(DBDataMgr * ddm)
  108. {
  109. SQLDA * bind_dp=NULL;
  110. SQLDA * select_dp=NULL;
  111. int     id;
  112. char    value[120];
  113. int     preallocateflag=1;
  114. char    sqlcmd[2048];
  115. int     haveerror=0;

  117. EXEC SQL BEGIN DECLARE SECTION;
  118.   int     mtsid=0;
  119.   char *  psqlcmd=sqlcmd;
  120. EXEC SQL END DECLARE SECTION;

  122. struct   RowListStru * row,* next;
  123. ColListStru * col;
  124. char     info[120];
  125. int      valsize;

  127.   sprintf(sqlcmd,"insert into %s( ",ddm->;TableName);
  128.   for(id=0;id<ddm->;FieldCount;id++)
  129.   {
  130.     strcat(sqlcmd,ddm->;FieldName[id]);
  131.     if(id!=ddm->;FieldCount-1)
  132.       strcat(sqlcmd,", ");
  133.   };
  134.   strcat(sqlcmd,") values(");
  135.   for(id=0;id<ddm->;FieldCount;id++)
  136.   {
  137.     sprintf(value,":v%d",id);
  138.     strcat(sqlcmd,value);
  139.     if(id!=ddm->;FieldCount-1)
  140.       strcat(sqlcmd,", ");
  141.   };
  142.   strcat(sqlcmd,")");
  143.   printf("To run sqlcmd is '%s'\n",sqlcmd);

  145.   if(ddm!=NULL)
  146.     DD_SetSqlCode(ddm,0,"");
  147.   if ((bind_dp=sqlald(MAX_ITEMS,MAX_VNAME_LEN,MAX_INAME_LEN)) == (SQLDA *) 0)
  148.   {
  149.     printf("Cannot allocate memory for bind descriptor.");
  150.     if(ddm!=NULL)
  151.       DD_SetSqlCode(ddm,-2001,"Cannot allocate memory for bind descriptor.");
  152.     haveerror=1;
  153.     goto err_ret_lab;
  154.   }
  155.   for (id = 0; id < MAX_ITEMS; id++)
  156.   {
  157.     bind_dp->;I[id] = NULL;
  158.     bind_dp->;V[id] = NULL;
  159.   }
  160.   if ((select_dp=sqlald (MAX_ITEMS,MAX_VNAME_LEN,MAX_INAME_LEN)) == (SQLDA *) 0)
  161.   {
  162.     printf("Cannot allocate memory for select descriptor.");
  163.     if(ddm!=NULL)
  164.       DD_SetSqlCode(ddm,-2001,"Cannot allocate memory for select descriptor.");
  165.     haveerror=1;
  166.     goto err_ret_lab;
  167.   }

  169.   select_dp->;N = MAX_ITEMS;
  170.   for (id = 0; id < MAX_ITEMS; id++)
  171.   {
  172.     bind_dp->;I[id] = (short *) IMem.Malloc(sizeof(short));
  173.     bind_dp->;V[id] = (char *) IMem.Malloc(1);

  175.     select_dp->;I[id] = (short *) IMem.Malloc(sizeof(short));
  176.     select_dp->;V[id] = (char *) IMem.Malloc(1);
  177.   }
  178.   bind_dp->;N = MAX_ITEMS;
  179.   EXEC SQL PREPARE S1 FROM :psqlcmd;

  181.   if(sqlca.sqlcode!=0)
  182.   {
  183.     if(ddm!=NULL)
  184.       DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  185.     haveerror=1;
  186.     goto err_ret_lab;
  187.   };

  189.   EXEC SQL DECLARE C1 CURSOR FOR S1;
  190.   if(sqlca.sqlcode!=0)
  191.   {
  192.     if(ddm!=NULL)
  193.       DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  194.     haveerror=1;
  195.     goto err_ret_lab;
  196.   };
  197.   EXEC SQL DESCRIBE BIND VARIABLES FOR S1 INTO bind_dp;
  198.   if(sqlca.sqlcode!=0)
  199.   {
  200.     if(ddm!=NULL)
  201.       DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  202.     haveerror=1;
  203.     goto err_ret_lab;
  204.   };
  205.   if (bind_dp->;F < 0)
  206.   {
  207.     printf ("\nToo many bind variables (%d), maximum is %d\n.",-bind_dp->;F, MAX_ITEMS);
  208.     if(ddm!=NULL)
  209.       DD_SetSqlCode(ddm,-2001,"Too many bind variables ");
  210.     haveerror=1;
  211.     goto err_ret_lab;
  212.   }
  213.   bind_dp->;N = bind_dp->;F;
  214.   row = ddm->;Head;
  215.   while(1)
  216.   {
  217.     if(row==NULL)
  218.       break;
  219.     for(id=0;id<ddm->;FieldCount;id++)
  220.     {
  221.       col=row->;Col + id;
  222.       valsize = (int)strlen(col->;Value);
  223.       bind_dp->;L[id] = valsize;
  224.       IMem.Free(bind_dp->;V[id]);

  226.       bind_dp->;V[id] = (char *) IMem.Malloc((bind_dp->;L[id] + 1));
  227.       strncpy(bind_dp->;V[id], col->;Value, valsize);
  228.       if ((strncmp(bind_dp->;V[id], "NULL", 4) == 0) ||
  229.          (strncmp(bind_dp->;V[id], "null", 4) == 0) || valsize==0)
  230.         *bind_dp->;I[id] = -1;
  231.       else
  232.         *bind_dp->;I[id] = 0;
  233.       bind_dp->;T[id] = 1;
  234.     };
  235.     EXEC SQL OPEN C1 USING DESCRIPTOR bind_dp;
  236.     if(sqlca.sqlcode!=0)
  237.     {
  238.       if(ddm!=NULL)
  239.         DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  240.       printf("sqlerr: sqlcode is '%d' errmsg: '%s'\n",sqlca.sqlcode,GetErrorMsg());
  241.       for(id=0;id<ddm->;FieldCount;id++)
  242.       {
  243.         col=row->;Col + id;
  244.         valsize = (int)strlen(col->;Value);
  245.         printf("id: %2d col: '%s' size: %d value: '%s'\n",id,ddm->;FieldName[id],valsize,col->;Value);
  246.       };
  247.       EXEC SQL ROLLBACK;
  248.       haveerror=1;
  249.       goto err_ret_lab;
  250.       //return 0;
  251.     };
  252.     next = row->;Next;
  253.     row = next;
  254.   };
  255.   EXEC SQL CLOSE C1;

  257. err_ret_lab:
  258.   for (id = 0; id < MAX_ITEMS; id++)
  259.   {
  260.     if (bind_dp->;V[id] != NULL)
  261.       IMem.Free(bind_dp->;V[id]);
  262.     if(bind_dp->;I[id] !=NULL)
  263.       IMem.Free(bind_dp->;I[id]);
  264.     if (select_dp->;V[id] != NULL)
  265.       IMem.Free(select_dp->;V[id]);
  266.     if(select_dp->;I[id] != NULL)
  267.       IMem.Free(select_dp->;I[id]);
  268.   }
  269.   if(bind_dp!=NULL)
  270.     sqlclu(bind_dp);

  272.   if(select_dp!=NULL)
  273.     sqlclu(select_dp);

  275.   if(haveerror)
  276.     return 0;

  278.   return 1;
  279. }

  281. int DbExecuteSql(DBDataMgr * ddm,char * sqlcmd)
  282. {
  283. SQLDA * bind_dp=NULL;
  284. SQLDA * select_dp=NULL;
  285. int     id;
  286. int     null_ok, precision, scale;
  287. char    value[8192],fname[120],head[300],fieldtype;
  288. int     mtsid=0,preallocateflag=1,fieldsize=0,fielddecsize=0;
  289. EXEC SQL BEGIN DECLARE SECTION;
  290.   char *  psqlcmd=sqlcmd;
  291. EXEC SQL END DECLARE SECTION;
  292. int haveerror=0;
  293. int isnumber[200];

  295.   if(ddm!=NULL)
  296.   {
  297.     DD_Free(ddm);
  298.     DD_Initlize(ddm);
  299.   };

  301.   if(_ShowRunSql_Switch)
  302.     printf("want to run sql: '%s'\n",sqlcmd);
  303.   sscanf(sqlcmd,"%s",head);
  304.   scale = (int)strlen(head);
  305.   IString.Allt(head);

  307.   for(id=0;id<scale;id++)
  308.     head[id]=toupper(head[id]);

  310.   if(!strcmp(head,"BEGINTRAN"))
  311.     return 1;

  313.   DD_SetSqlCode(ddm,0,"");

  315.   if ((strncmp(head,"SELECT",6)!=0))
  316.   {
  317.     DD_SetRecordCount(ddm,0);
  318.     DD_SetFieldCount(ddm,0);

  320.     EXEC SQL EXECUTE IMMEDIATE :psqlcmd;

  322.     if(vabs(sqlca.sqlcode)==1403) sqlca.sqlcode=0;
  323.     if(vabs(sqlca.sqlcode)==1405) sqlca.sqlcode=0;

  325.     DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());

  327.     if(sqlca.sqlcode!=0)
  328.       DbShowError();

  330.     return 1;
  331.   };

  333.   if ((bind_dp=sqlald(MAX_ITEMS,MAX_VNAME_LEN,MAX_INAME_LEN)) == (SQLDA *) 0)
  334.   {
  335.     printf("Cannot allocate memory for bind descriptor.");
  336.     DD_SetSqlCode(ddm,-2001,"Cannot allocate memory for bind descriptor.");
  337.     haveerror=1;
  338.     goto err_ret_lab_sql;
  339.   }
  340.   for (id = 0; id < MAX_ITEMS; id++)
  341.   {
  342.     bind_dp->;I[id] = NULL;
  343.     bind_dp->;V[id] = NULL;
  344.   };
  345.   if ((select_dp=sqlald (MAX_ITEMS,MAX_VNAME_LEN,MAX_INAME_LEN)) == (SQLDA *) 0)
  346.   {
  347.     printf("Cannot allocate memory for select descriptor.");
  348.     DD_SetSqlCode(ddm,-2001,"Cannot allocate memory for select descriptor.");
  349.     haveerror=1;
  350.     goto err_ret_lab_sql;
  351.   }
  352.   select_dp->;N = MAX_ITEMS;
  353.   for (id = 0; id < MAX_ITEMS; id++)
  354.   {
  355.     bind_dp->;I[id] = (short *) IMem.Malloc(sizeof(short),"binddp_i");
  356.     bind_dp->;V[id] = (char *) IMem.Malloc(1,"binddp_v");
  357.     select_dp->;I[id] = (short *) IMem.Malloc(sizeof(short),"selectdp_i");
  358.     select_dp->;V[id] = (char *) IMem.Malloc(1,"selectdp_v");
  359.   }
  360.   bind_dp->;N = MAX_ITEMS;
  361.   EXEC SQL PREPARE S0 FROM :psqlcmd;
  362.   if(sqlca.sqlcode!=0)
  363.   {
  364.     printf("prepare error %d\n",sqlca.sqlcode);
  365.     DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  366.     haveerror=1;
  367.     goto err_ret_lab_sql;
  368.   };
  369.   EXEC SQL DECLARE C0 CURSOR FOR S0;
  370.   if(sqlca.sqlcode!=0)
  371.   {
  372.     printf("declare error %d\n",sqlca.sqlcode);
  373.     DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  374.     haveerror=1;
  375.     goto err_ret_lab_sql;
  376.   };
  377.   EXEC SQL DESCRIBE BIND VARIABLES FOR S0 INTO bind_dp;
  378.   if(sqlca.sqlcode!=0)
  379.   {
  380.     printf("describe error %d\n",sqlca.sqlcode);
  381.     DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  382.     haveerror=1;
  383.     goto err_ret_lab_sql;
  384.   };
  385.   if (bind_dp->;F < 0)
  386.   {
  387.     printf ("\nToo many bind variables (%d), maximum is %d\n.",-bind_dp->;F, MAX_ITEMS);
  388.     DD_SetSqlCode(ddm,-2001,"Too many bind variables ");
  389.     haveerror=1;
  390.     goto err_ret_lab_sql;
  391.   }
  392.   bind_dp->;N = bind_dp->;F;
  393.   EXEC SQL OPEN C0 USING DESCRIPTOR bind_dp;

  395.   /* 无记录 */
  396.   if(vabs(sqlca.sqlcode)==1403) sqlca.sqlcode=0;

  398.   /* 提取的值为空 */
  399.   if(vabs(sqlca.sqlcode)==1405) sqlca.sqlcode=0;

  401.   if(sqlca.sqlcode!=0)
  402.   {
  403.     printf("open error %d\n",sqlca.sqlcode);
  404.     DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  405.     haveerror=1;
  406.     goto err_ret_lab_sql;
  407.   };

  409.   select_dp->;N = MAX_ITEMS;
  410.   EXEC SQL DESCRIBE SELECT LIST FOR S0 INTO select_dp;

  412.   if (select_dp->;F < 0)
  413.   {
  414.     printf ("\nToo many select - list items (%d), maximum is %d\n",
  415.              -(select_dp->;F), MAX_ITEMS);
  416.     DD_SetSqlCode(ddm,-2001,"Too many select - list items");
  417.     haveerror=1;
  418.     goto err_ret_lab_sql;
  419.   }
  420.   if(sqlca.sqlcode!=0)
  421.   {
  422.     printf("describe select list error %d\n",sqlca.sqlcode);
  423.     DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  424.     haveerror=1;
  425.     goto err_ret_lab_sql;
  426.   };
  427.   DD_SetRecordCount(ddm,0);
  428.   DD_SetFieldCount(ddm,select_dp->;F);
  429.   select_dp->;N = select_dp->;F;
  430.   for (id = 0; id < select_dp->;F; id++)
  431.   {
  432.     isnumber[id]=0;
  433.     sqlnul ((unsigned short *)&(select_dp->;T[id]), (unsigned short *)&(select_dp->;T[id]), &null_ok);
  434.     switch (select_dp->;T[id])
  435.     {
  436.       /* 这里是字符类型 */
  437.       case  1 :
  438.         break;

  440.       /* 这里是数值类型，要确定小数点,强行转为字符型了 */
  441.       case  2 :
  442.         isnumber[id]=1;
  443.         select_dp->;T[id] = 1;
  444.         select_dp->;L[id] = 100;
  445.         precision = 50;
  446.         scale = 6;
  447.         #ifdef MODIFIED_BY_PROGRAM_NOTE
  448.           sqlprc (&(select_dp->;L[id]), &precision, &scale);
  449.           if (precision == 0) precision = 40;
  450.           if (scale >; 0)
  451.             select_dp->;L[id] = sizeof(float);
  452.           else
  453.             select_dp->;L[id] = sizeof(int);
  454.         #endif
  455.         break;

  457.       /* LONG类型 */
  458.       case  8 :
  459.         select_dp->;L[id] = 240;
  460.         break;

  462.       /* ROWID 类型 */
  463.       case 11 :
  464.         select_dp->;L[id] = 18;
  465.         break;

  467.       /* 日期类型 */
  468.       case 12 :
  469.         select_dp->;L[id] = 9;
  470.         break;

  472.       /* RAW 类型 */
  473.       case 23 :
  474.         break;

  476.       /* LONG RAW 类型 */
  477.       case 24 :
  478.         select_dp->;L[id] = 240;
  479.         break;
  480.     }
  481.     if (select_dp->;T[id] != 2)    /* 不是数字类型 */
  482.     {
  483.       fieldtype = 'C';
  484.       IMem.Free(select_dp->;V[id]);
  485.       select_dp->;V[id] = (char *) IMem.Malloc(select_dp->;L[id] + 1,"selectdp_vrel");
  486.       //select_dp->;V[id] = (char *) realloc(select_dp->;V[id],select_dp->;L[id] + 1);
  487.     }
  488.     else
  489.     {
  490.       fieldtype = 'N';
  491.       IMem.Free(select_dp->;V[id]);

  493.       select_dp->;V[id] = (char *) IMem.Malloc(select_dp->;L[id] + 1,"selectdp_vrel");
  494.       //select_dp->;V[id] = (char *) realloc(select_dp->;V[id],select_dp->;L[id]);
  495.     };

  497.     /* 不是LONGRAW 与数字类型,均转为字符类型 */
  498.     if (select_dp->;T[id] != 24 && select_dp->;T[id] != 2)
  499.       select_dp->;T[id] = 1;

  501.     /* 数字类型，判断小数点 */
  502.     if (select_dp->;T[id] == 2)
  503.       if (scale >; 0)
  504.         select_dp->;T[id] = 4;
  505.       else
  506.         select_dp->;T[id] = 3;

  508.     /* 字段名称长度要限制 */
  509.     if((int)strlen(select_dp->;S[id])>;4096)
  510.       *(select_dp->;S[id] + 4096) = 0;

  512.     /* 取字段名称 */
  513.     strcpy(value,select_dp->;S[id]);
  514.     IString.Allt(value);
  515.     sscanf(value,"%s",fname);
  516.     /*
  517.     printf("Field %d is '%s' type %d\n",id,fname,select_dp->;T[id]);
  518.     */
  519.     DD_SetFieldName(ddm,id,fname);
  520.     DD_SetFieldType(ddm,id,fieldtype);
  521.     DD_SetFieldSize(ddm,id,123);
  522.     DD_SetFieldDecSize(ddm,id,789);
  523.   }
  524.   while(1)
  525.   {
  526.     if(sqlca.sqlcode!=0)
  527.     {
  528.       DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  529.       DbShowError();
  530.       break;
  531.     };
  532.     EXEC SQL FETCH C0 USING DESCRIPTOR select_dp;
  533.     /* 无记录了 */
  534.     if(vabs(sqlca.sqlcode)==1403)
  535.       break;
  536.     /* 提取的值为空 */
  537.     if(vabs(sqlca.sqlcode)==1405) sqlca.sqlcode=0;
  538.     /* 有错误了 */
  539.     if(vabs(sqlca.sqlcode)!=0)
  540.     {
  541.       DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  542.       DbShowError();
  543.       break;
  544.     };
  545.     /* printf("select_dp_F is %d\n",select_dp->;F); */
  546.     DD_AddRow(ddm);
  547.     for (id = 0; id < select_dp->;F; id++)
  548.     {
  549.       if (*select_dp->;I[id] < 0)
  550.       {
  551.         if (select_dp->;T[id] == 4)
  552.         {
  553.           sprintf (value,"%-*c ",(int)select_dp->;L[id]+3, ' ');
  554.         }
  555.         else
  556.         {
  557.           sprintf (value,"%-*c ",(int)select_dp->;L[id], ' ');
  558.         };
  559.       }
  560.       else
  561.       {
  562.         if (select_dp->;T[id] == 3)
  563.         {
  564.           sprintf (value,"%*d ", (int)select_dp->;L[id],*(int *)select_dp->;V[id]);
  565.         }
  566.         else
  567.           if (select_dp->;T[id] == 4)
  568.           {
  569.             sprintf (value,"%*.2f ", (int)select_dp->;L[id],*(float *)select_dp->;V[id]);
  570.           }
  571.           else
  572.           {
  573.             if(select_dp->;L[id]>;1500)
  574.             {
  575.               memcpy(value,select_dp->;V[id],1500);
  576.               value[1500]=0;
  577.             }
  578.             else
  579.               sprintf (value,"%-*.*s ", (int)select_dp->;L[id],(int)select_dp->;L[id], select_dp->;V[id]);
  580.           }
  581.       };
  582.       if(isnumber[id])
  583.         IString.Allt(value);
  584.       else
  585.         IString.AlltRight(value);
  586.       DD_SetValue(ddm,id,value);
  587.       /*
  588.       printf("field %2d type: %d value is '%s' - mtsid: %d - %d\n",
  589.         id,select_dp->;T[id],value,mtsid,thr_self());
  590.       */
  591.     }
  592.   }
  593.   EXEC SQL CLOSE C0;

  595. err_ret_lab_sql:

  597.   for (id = 0; id < MAX_ITEMS; id++)
  598.   {
  599.     if (bind_dp->;V[id] != NULL)
  600.       IMem.Free(bind_dp->;V[id]);

  602.     if (bind_dp->;I[id] != NULL)
  603.       IMem.Free(bind_dp->;I[id]);

  605.     if (select_dp->;V[id] != NULL)
  606.       IMem.Free(select_dp->;V[id]);

  608.     if(select_dp->;I[id] != NULL)
  609.       IMem.Free(select_dp->;I[id]);
  610.   }
  611.   if(bind_dp!=NULL)
  612.     sqlclu(bind_dp);
  613.   if(select_dp!=NULL)
  614.     sqlclu(select_dp);

  616.   if(haveerror)
  617.     return 0;

  619.   return 1;
  620. }

  622. int DbSelectRow(DBDataMgr * ddm,char * sqlcmd,int (* data_handle)(void *,void *),void * dbioptr,void * ass_ptr)
  623. {
  624. SQLDA * bind_dp;
  625. SQLDA * select_dp;
  626. int     id;
  627. int     null_ok, precision, scale;
  628. char    value[8192],fname[120],head[300];
  629. int     mtsid=0,preallocateflag=1;
  630. EXEC SQL BEGIN DECLARE SECTION;
  631.   char *  psqlcmd=sqlcmd;
  632. EXEC SQL END DECLARE SECTION;
  633. int isnumber[200];

  635.   if(ddm!=NULL)
  636.   {
  637.     DD_Free(ddm);
  638.     DD_Initlize(ddm);
  639.   };
  640.   if(_ShowRunSql_Switch)
  641.     printf("want to run sql: '%s'\n",sqlcmd);

  643.   sscanf(sqlcmd,"%s",head);
  644.   scale = (int)strlen(head);
  645.   IString.Allt(head);
  646.   for(id=0;id<scale;id++)
  647.     head[id]=toupper(head[id]);
  648.   if(!strcmp(head,"BEGINTRAN"))
  649.     return 1;

  651.   DD_SetSqlCode(ddm,0,"");

  653.   if ((strncmp(head,"SELECT",6)!=0))
  654.     return 0;

  656.   if ((bind_dp=sqlald(MAX_ITEMS,MAX_VNAME_LEN,MAX_INAME_LEN)) == (SQLDA *) 0)
  657.   {
  658.     printf("Cannot allocate memory for bind descriptor.");
  659.     DD_SetSqlCode(ddm,-2001,"Cannot allocate memory for bind descriptor.");
  660.     return 0;
  661.   }
  662.   if ((select_dp=sqlald (MAX_ITEMS,MAX_VNAME_LEN,MAX_INAME_LEN)) == (SQLDA *) 0)
  663.   {
  664.     printf("Cannot allocate memory for select descriptor.");
  665.     DD_SetSqlCode(ddm,-2001,"Cannot allocate memory for select descriptor.");
  666.     return 0;
  667.   }
  668.   select_dp->;N = MAX_ITEMS;
  669.   for (id = 0; id < MAX_ITEMS; id++)
  670.   {
  671.     bind_dp->;I[id] = (short *) IMem.Malloc(sizeof(short));
  672.     bind_dp->;V[id] = (char *) IMem.Malloc(1);
  673.     select_dp->;I[id] = (short *) IMem.Malloc(sizeof(short));
  674.     select_dp->;V[id] = (char *) IMem.Malloc(1);
  675.   }
  676.   bind_dp->;N = MAX_ITEMS;
  677.   EXEC SQL PREPARE S0 FROM :psqlcmd;
  678.   if(sqlca.sqlcode!=0)
  679.   {
  680.     printf("prepare error %d\n",sqlca.sqlcode);
  681.     DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  682.     return 0;
  683.   };
  684.   EXEC SQL DECLARE C5 CURSOR FOR S0;
  685.   if(sqlca.sqlcode!=0)
  686.   {
  687.     printf("declare error %d\n",sqlca.sqlcode);
  688.     DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  689.     return 0;
  690.   };
  691.   EXEC SQL DESCRIBE BIND VARIABLES FOR S0 INTO bind_dp;
  692.   if(sqlca.sqlcode!=0)
  693.   {
  694.     printf("describe error %d\n",sqlca.sqlcode);
  695.     DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  696.     return 0;
  697.   };
  698.   if (bind_dp->;F < 0)
  699.   {
  700.     printf ("\nToo many bind variables (%d), maximum is %d\n.",-bind_dp->;F, MAX_ITEMS);
  701.     DD_SetSqlCode(ddm,-2001,"Too many bind variables ");
  702.     return 0;
  703.   }
  704.   bind_dp->;N = bind_dp->;F;
  705.   EXEC SQL OPEN C5 USING DESCRIPTOR bind_dp;

  707.   /* 无记录 */
  708.   if(vabs(sqlca.sqlcode)==1403) sqlca.sqlcode=0;

  710.   /* 提取的值为空 */
  711.   if(vabs(sqlca.sqlcode)==1405) sqlca.sqlcode=0;

  713.   if(sqlca.sqlcode!=0)
  714.   {
  715.     printf("open error %d\n",sqlca.sqlcode);
  716.     DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  717.     return 0;
  718.   };

  720.   select_dp->;N = MAX_ITEMS;
  721.   EXEC SQL DESCRIBE SELECT LIST FOR S0 INTO select_dp;

  723.   if (select_dp->;F < 0)
  724.   {
  725.     printf ("\nToo many select - list items (%d), maximum is %d\n",
  726.              -(select_dp->;F), MAX_ITEMS);
  727.     DD_SetSqlCode(ddm,-2001,"Too many select - list items");
  728.     return 0;
  729.   }
  730.   if(sqlca.sqlcode!=0)
  731.   {
  732.     printf("describe select list error %d\n",sqlca.sqlcode);
  733.     DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  734.     return 0;
  735.   };
  736.   DD_SetRecordCount(ddm,0);
  737.   DD_SetFieldCount(ddm,select_dp->;F);
  738.   select_dp->;N = select_dp->;F;
  739.   for (id = 0; id < select_dp->;F; id++)
  740.   {
  741.     sqlnul ((unsigned short *)&(select_dp->;T[id]), (unsigned short *)&(select_dp->;T[id]), &null_ok);
  742.     isnumber[id]=0;
  743.     switch (select_dp->;T[id])
  744.     {
  745.       /* 这里是字符类型 */
  746.       case  1 :
  747.         break;

  749.       /* 这里是数值类型，要确定小数点,强行转为字符型了 */
  750.       case  2 :
  751.         isnumber[id]=1;
  752.         select_dp->;T[id] = 1;
  753.         select_dp->;L[id] = 100;
  754.         precision = 50;
  755.         scale = 6;
  756.         #ifdef MODIFIED_BY_PROGRAM_NOTE
  757.           sqlprc (&(select_dp->;L[id]), &precision, &scale);
  758.           if (precision == 0) precision = 40;
  759.           if (scale >; 0)
  760.             select_dp->;L[id] = sizeof(float);
  761.           else
  762.             select_dp->;L[id] = sizeof(int);
  763.         #endif
  764.         break;

  766.       /* LONG类型 */
  767.       case  8 :
  768.         select_dp->;L[id] = 240;
  769.         break;

  771.       /* ROWID 类型 */
  772.       case 11 :
  773.         select_dp->;L[id] = 18;
  774.         break;

  776.       /* 日期类型 */
  777.       case 12 :
  778.         select_dp->;L[id] = 9;
  779.         break;

  781.       /* RAW 类型 */
  782.       case 23 :
  783.         break;

  785.       /* LONG RAW 类型 */
  786.       case 24 :
  787.         select_dp->;L[id] = 240;
  788.         break;
  789.     }
  790.     IMem.Free(select_dp->;V[id]);
  791.     if (select_dp->;T[id] != 2)    /* 不是数字类型 */
  792.       select_dp->;V[id] = (char *) IMem.Malloc(select_dp->;L[id] + 1);
  793.     else
  794.       select_dp->;V[id] = (char *) IMem.Malloc(select_dp->;L[id]);

  796.     /* 不是LONGRAW 与数字类型,均转为字符类型 */
  797.     if (select_dp->;T[id] != 24 && select_dp->;T[id] != 2)
  798.       select_dp->;T[id] = 1;

  800.     /* 数字类型，判断小数点 */
  801.     if (select_dp->;T[id] == 2)
  802.       if (scale >; 0)
  803.         select_dp->;T[id] = 4;
  804.       else
  805.         select_dp->;T[id] = 3;

  807.     /* 字段名称长度要限制 */
  808.     if((int)strlen(select_dp->;S[id])>;4096)
  809.       *(select_dp->;S[id] + 4096) = 0;

  811.     /* 取字段名称 */
  812.     strcpy(value,select_dp->;S[id]);
  813.     if(isnumber[id])
  814.       IString.Allt(value);
  815.     else
  816.       IString.AlltRight(value);

  818.     sscanf(value,"%s",fname);
  819.     /*
  820.     printf("Field %d is '%s' type %d\n",id,fname,select_dp->;T[id]);
  821.     */
  822.     DD_SetFieldName(ddm,id,fname);
  823.   }
  824.   while(1)
  825.   {
  826.     if(sqlca.sqlcode!=0)
  827.     {
  828.       printf("1-sqlcode is %d\n",sqlca.sqlcode);
  829.       DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  830.       break;
  831.     };
  832.     EXEC SQL FETCH C5 USING DESCRIPTOR select_dp;
  833.     /* 无记录了 */
  834.     if(vabs(sqlca.sqlcode)==1403)
  835.       break;
  836.     /* 提取的值为空 */
  837.     if(vabs(sqlca.sqlcode)==1405) sqlca.sqlcode=0;
  838.     /* 有错误了 */
  839.     if(vabs(sqlca.sqlcode)!=0)
  840.     {
  841.       DD_SetSqlCode(ddm,sqlca.sqlcode,GetErrorMsg());
  842.       printf("2-sqlcode is %d\n",sqlca.sqlcode);
  843.       break;
  844.     };
  845.     /* printf("select_dp_F is %d\n",select_dp->;F); */
  846.     if(ddm->;RecordCount==0)
  847.       DD_AddRow(ddm);
  848.     for (id = 0; id < select_dp->;F; id++)
  849.     {
  850.       if (*select_dp->;I[id] < 0)
  851.       {
  852.         if (select_dp->;T[id] == 4)
  853.         {
  854.           sprintf (value,"%-*c ",(int)select_dp->;L[id]+3, ' ');
  855.         }
  856.         else
  857.         {
  858.           sprintf (value,"%-*c ",(int)select_dp->;L[id], ' ');
  859.         };
  860.       }
  861.       else
  862.       {
  863.         if (select_dp->;T[id] == 3)
  864.         {
  865.           sprintf (value,"%*d ", (int)select_dp->;L[id],*(int *)select_dp->;V[id]);
  866.         }
  867.         else
  868.           if (select_dp->;T[id] == 4)
  869.           {
  870.             sprintf (value,"%*.2f ", (int)select_dp->;L[id],*(float *)select_dp->;V[id]);
  871.           }
  872.           else
  873.           {
  874.             if(select_dp->;L[id]>;1500)
  875.             {
  876.               memcpy(value,select_dp->;V[id],1500);
  877.               value[1500]=0;
  878.             }
  879.             else
  880.               sprintf (value,"%-*.*s ", (int)select_dp->;L[id],(int)select_dp->;L[id], select_dp->;V[id]);
  881.           }
  882.       };
  883.       IString.Allt(value);
  884.       DD_SetValue(ddm,id,value);
  885.     }
  886.     if(data_handle!=NULL)
  887.       if(!data_handle(dbioptr,ass_ptr)) break;
  888.   }
  889.   EXEC SQL CLOSE C5;
  890.   for (id = 0; id < MAX_ITEMS; id++)
  891.   {
  892.     if (bind_dp->;V[id] != (char *) 0)
  893.       IMem.Free(bind_dp->;V[id]);
  894.     IMem.Free(bind_dp->;I[id]);
  895.     if (select_dp->;V[id] != (char *) 0)
  896.       IMem.Free(select_dp->;V[id]);
  897.     IMem.Free(select_dp->;I[id]);
  898.   }
  899.   sqlclu(bind_dp);
  900.   sqlclu(select_dp);
  901.   return 1;
  902. }
复制代码
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
yikaikai

论坛徽章:
0
4楼 [报告]
发表于 2003-02-23 20:52 |只看该作者

请问各位老鸟能不能提供一个和ORACLE数据库打交道得程序呢?

pro*C
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
liupch

论坛徽章:
0
5楼 [报告]
发表于 2003-02-24 10:13 |只看该作者

请问各位老鸟能不能提供一个和ORACLE数据库打交道得程序呢?

看看以前的贴子，我曾经发过一篇介绍UNIX环境下如何使用PRO*C进行ORACLE数据库编程的文章，里面有详细的介绍，还有step by step得例子
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
无双

论坛徽章:
0
6楼 [报告]
发表于 2003-02-24 10:13 |只看该作者

请问各位老鸟能不能提供一个和ORACLE数据库打交道得程序呢?

使用pro*c比较简单
前几天有多人问pRO*C问题
并且写上源码
你可以自己看看
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
stanleylei

论坛徽章:
0
7楼 [报告]
发表于 2003-02-24 10:23 |只看该作者

请问各位老鸟能不能提供一个和ORACLE数据库打交道得程序呢?

我用过OCI，想过还不错
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
无双

论坛徽章:
0
8楼 [报告]
发表于 2003-02-24 10:57 |只看该作者

请问各位老鸟能不能提供一个和ORACLE数据库打交道得程序呢?

oci的性能应该是会比pro*c好

但是使用pro*c会更简单
使用pro*c后oracle的编译器会把pro*c编译成oci
不用那么复杂的语法
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则 发表回复

  

北京盛拓优讯信息技术有限公司. 版权所有 京ICP备16024965号-6 北京市公安局海淀分局网监中心备案编号：11010802020122 niuxiaotong@pcpop.com 17352615567
未成年举报专区
中国互联网协会会员  联系我们：huangweiwei@itpub.net
感谢所有关心和支持过ChinaUnix的朋友们 转载本站内容请注明原作者名及出处

清除 Cookies - ChinaUnix - Archiver - WAP - TOP