开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数值算法/人工智能 > 生物技术 > 查看源码
dbapi_cursor_util.cpp
资源名称：ncbi_cxx_win--Jul_08_2004.zip　[点击查看]
上传用户：yhdzpy8989
上传日期：2007-06-13
资源大小：13604k
文件大小：13k
源码类别：

生物技术

开发平台：

C/C++

dbapi_cursor_util.cpp：源码内容
  1. /*
  2.  * ===========================================================================
  3.  * PRODUCTION $Log: dbapi_cursor_util.cpp,v $
  4.  * PRODUCTION Revision 1000.1  2004/06/01 19:22:21  gouriano
  5.  * PRODUCTION PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R1.6
  6.  * PRODUCTION
  7.  * ===========================================================================
  8.  */
  10. /*  $Id: dbapi_cursor_util.cpp,v 1000.1 2004/06/01 19:22:21 gouriano Exp $
  11. * ===========================================================================
  12. *
  13. *                            PUBLIC DOMAIN NOTICE
  14. *               National Center for Biotechnology Information
  15. *
  16. *  This software/database is a "United States Government Work" under the
  17. *  terms of the United States Copyright Act.  It was written as part of
  18. *  the author's official duties as a United States Government employee and
  19. *  thus cannot be copyrighted.  This software/database is freely available
  20. *  to the public for use. The National Library of Medicine and the U.S.
  21. *  Government have not placed any restriction on its use or reproduction.
  22. *
  23. *  Although all reasonable efforts have been taken to ensure the accuracy
  24. *  and reliability of the software and data, the NLM and the U.S.
  25. *  Government do not and cannot warrant the performance or results that
  26. *  may be obtained by using this software or data. The NLM and the U.S.
  27. *  Government disclaim all warranties, express or implied, including
  28. *  warranties of performance, merchantability or fitness for any particular
  29. *  purpose.
  30. *
  31. *  Please cite the author in any work or product based on this material.
  32. *
  33. * ===========================================================================
  34. *
  35. * File Name:  $Id: dbapi_cursor_util.cpp,v 1000.1 2004/06/01 19:22:21 gouriano Exp $
  36. *
  37. * File Description: Implementation of dbapi bcp
  38. * $Log: dbapi_cursor_util.cpp,v $
  39. * Revision 1000.1  2004/06/01 19:22:21  gouriano
  40. * PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R1.6
  41. *
  42. * Revision 1.6  2004/05/17 21:17:16  gorelenk
  43. * Added include of PCH ncbi_pch.hpp
  44. *
  45. * Revision 1.5  2003/02/27 20:21:35  starchen
  46. * correct a lang call
  47. *
  48. * Revision 1.4  2002/12/09 16:25:21  starchen
  49. * remove the text files from samples
  50. *
  51. * Revision 1.3  2002/09/04 22:20:40  vakatov
  52. * Get rid of comp.warnings
  53. *
  54. * Revision 1.2  2002/07/18 19:51:04  starchen
  55. * fixed some error
  56. *
  57. * Revision 1.1  2002/07/18 15:47:42  starchen
  58. * first entry
  59. *
  60. * Revision 1.1  2002/07/18 15:18:02  starchen
  61. * first entry
  62. *
  63. *
  64. *============================================================================
  65. */
  67. #include <ncbi_pch.hpp>
  68. #include "dbapi_cursor.hpp"
  70. const char*  file_name[] = {
  71.     "../test1.txt",
  72.     "../test2.txt",
  73.     "../test3.txt",
  74.     "../test4.txt",
  75.     "../test5.txt",
  76.     ""
  77. };
  81.  const char* prnType(EDB_Type t)
  82. {
  83.     switch(t) {
  84.     case eDB_Int: return "Int4";
  85.     case eDB_SmallInt: return "Int2";
  86.     case eDB_TinyInt:  return "Uint1";
  87.     case eDB_BigInt:   return "Int8";
  88.     case eDB_VarChar : return "VarChar";
  89.     case eDB_Char:     return "Char";
  90.     case eDB_VarBinary: return "VarBinary";
  91.     case eDB_Binary :   return "Binary";
  92.     case eDB_Float : return "Float";
  93.     case eDB_Double: return "Double";
  94.     case eDB_DateTime : return "DateTime";
  95.     case eDB_SmallDateTime : return "SmallDateTime";
  96.     case eDB_Text : return "Text";
  97.     case eDB_Image : return "Image";
  98.     case eDB_Bit : return "Bit";
  99.     case eDB_Numeric : return "Numeric";
  100.     default: return "Unsupported";
  101.     }
  102. }
  104.  const char* prnSeverity(EDB_Severity s) 
  105. {
  106.     switch(s) {
  107.     case eDB_Info:    return "Info";
  108.     case eDB_Warning: return "Warning";
  109.     case eDB_Error:   return "Error";
  110.     case eDB_Fatal:   return "Fatal Error";
  111.     default:          return "Unknown severity";
  112.     }
  113. }
  115.  void prnDSEx(CDB_DSEx* ex)
  116. {
  117.     cerr << "Sybase " << prnSeverity(ex->Severity()) << " Message: Err.code=" << ex->ErrCode() <<
  118. " Data source: " << ex->OriginatedFrom() << " t| <" << ex->Message() << ">" << endl;
  119. }
  121. static void prnRPCEx(CDB_RPCEx* ex)
  122. {
  123.     cerr << "Sybase " << prnSeverity(ex->Severity()) << " Message: Err code=" << ex->ErrCode() <<
  124. " SQL/Open server: " << ex->OriginatedFrom() << " Procedure: " << ex->ProcName() << " Line: " << ex->ProcLine() <<
  125. " t| <" << ex->Message() << ">" << endl;
  126. }
  128. static void prnSQLEx(CDB_SQLEx* ex)
  129. {
  130.     cerr << "Sybase " << prnSeverity(ex->Severity()) << " Message: Err code=" << ex->ErrCode() <<
  131. " SQL server: " << ex->OriginatedFrom() << " SQL: " << ex->SqlState() << " Line: " << ex->BatchLine() <<
  132. " t| <" << ex->Message() << ">" << endl;
  133. }
  135. static void prnDeadlockEx(CDB_DeadlockEx* ex)
  136. {
  137.     cerr << "Sybase " << prnSeverity(ex->Severity()) << " Message: SQL server: " << ex->OriginatedFrom() << 
  138. " t| <" << ex->Message() << ">" << endl;
  139. }
  141. static void prnTimeoutEx(CDB_TimeoutEx* ex)
  142. {
  143.     cerr << "Sybase " << prnSeverity(ex->Severity()) << " Message: SQL server: " << ex->OriginatedFrom() << 
  144. " t| <" << ex->Message() << ">" << endl;
  145. }
  147. static void prnCliEx(CDB_ClientEx* ex)
  148. {
  149.     cerr << "Sybase " << prnSeverity(ex->Severity()) << " Message: (Err.code=" << ex->ErrCode() <<
  150. ") tSource: " << ex->OriginatedFrom() << " n <<<" << ex->Message() << ">>>" << endl;
  151. }
  153.  bool HandleIt(const CDB_Exception* ex) 
  154. {
  155.     switch(ex->Type()) {
  156.     case CDB_Exception::eDS :
  157. prnDSEx((CDB_DSEx*)ex);
  158. break;
  159.     case CDB_Exception::eRPC :
  160. prnRPCEx((CDB_RPCEx*)ex);
  161. break;
  162.     case CDB_Exception::eSQL :
  163. prnSQLEx((CDB_SQLEx*)ex);
  164. break;
  165.     case CDB_Exception::eDeadlock :
  166. prnDeadlockEx((CDB_DeadlockEx*)ex);
  167. break;
  168.     case CDB_Exception::eTimeout :
  169. prnTimeoutEx((CDB_TimeoutEx*)ex);
  170. break;
  171.     case CDB_Exception::eClient :
  172. prnCliEx((CDB_ClientEx*)ex);
  173. break;
  174.     default:
  175. cerr << "Sybase " << prnSeverity(ex->Severity()) << " message: Error code=" << ex->ErrCode() << " t| <" <<
  176.     ex->what() << ">" << endl;
  178.     }
  179.     return true;
  180. }
  184. // getParam is reading arguments from the command line
  186.  char* getParam(char tag, int argc, char* argv[], bool* flag)
  187. {
  188.     for(int i= 1; i < argc; i++) {
  189.         if(((*argv[i] == '-') || (*argv[i] == '/')) && 
  190.            (*(argv[i]+1) == tag)) { // tag found
  191.             if(flag) *flag= true;
  192.             if(*(argv[i]+2) == '')  { // tag is a separate arg
  193.                 if(i == argc - 1) return 0;
  194.                 if(*argv[i+1] != *argv[i]) return argv[i+1];
  195.                 else return 0;
  196.             }
  197.             else return argv[i]+2;
  198.         }
  199.     }
  200.     if(flag) *flag= false;
  201.     return 0;
  202. }
  204. // function CreateTable is creating table in the database
  205. //   and populate it by using BCP
  207. int CreateTable (CDB_Connection* con)
  208. {
  209.    CDB_BCPInCmd* bcp;
  211.    try {
  212.  
  213.        CDB_LangCmd* lcmd = con->LangCmd ( 
  214.                      " IF EXISTS(select * from sysobjects WHERE name = 'CursorSample'"
  215.                        " AND   type = 'U') begin "
  216.                        " DROP TABLE CursorSample end ");
  217.        lcmd->Send();
  219.        while (lcmd->HasMoreResults()) {
  220.             CDB_Result* r = lcmd->Result();
  221.             if (!r) {
  222.                 continue;
  223.             }
  224.             delete r;
  225.         }
  226.         delete lcmd;
  228.         lcmd = con->LangCmd (  " create table CursorSample"
  229.                      " (int_val int not null,fl_val real not null,"
  230.                      " date_val datetime not null ,str_val varchar(255) null,"
  231.                      " text_val text null, primary key clustered(int_val))");
  232.         lcmd->Send();
  234.         while (lcmd->HasMoreResults()) {
  235.             CDB_Result* r = lcmd->Result();
  236.             if (!r) {
  237.                 continue;
  238.             }
  239.             delete r;
  240.         }
  241.         delete lcmd;
  242.      bcp = con->BCPIn("CursorSample", 5);
  244.         CDB_Int int_val;
  245.         CDB_Float fl_val;
  246.         CDB_DateTime date_val;
  247.         CDB_VarChar str_val;
  248.         CDB_Text pTxt;
  249.      int i;
  250.         pTxt.Append("This is a test string.");
  252.         // Bind data from a program variables  
  253.         bcp->Bind(0, &int_val);
  254.         bcp->Bind(1, &fl_val);
  255.         bcp->Bind(2, &date_val);
  256.         bcp->Bind(3, &str_val);
  257.         bcp->Bind(4, &pTxt);
  259.      for(i= 0; *file_name[i] != ''; i++) {
  260.             int_val = i;
  261.             fl_val = i + 0.999;
  262.             date_val = date_val.Value();
  263.             str_val= file_name[i];
  264.             pTxt.MoveTo(0);
  265.        
  266.          bcp->SendRow();
  267.          
  268.      }
  269.         bcp->CompleteBCP();
  270.      delete bcp;  
  271.    }  catch (CDB_Exception& e) {
  272.    HandleIt(&e);
  273.       return 1;
  274.    }
  275.    return 0;
  276. }
  278. //ShowResults is printing resuts on screen
  280. int ShowResults (CDB_Connection* con)
  281. {
  282.     char* txt_buf = NULL ;
  283.     long len_txt = 0;
  286.     try {   
  287.         string query = "select int_val,fl_val,date_val,str_val,text_val from CursorSample";
  288.         CDB_LangCmd* lcmd = con->LangCmd(query);
  289.         lcmd->Send();
  291.         //    Fetching  results:
  293.         while (lcmd->HasMoreResults()) {
  294.             CDB_Result* r = lcmd->Result();
  295.             if (!r) continue;
  296.             
  297.             if (r->ResultType() == eDB_RowResult) {
  298.                 while (r->Fetch()) {
  299.                    cout << "<ROW>"<< endl;
  300.                    for (unsigned int j = 0;  j < r->NofItems(); j++) {
  302.                      //    Determination of data type:
  303.                      EDB_Type rt = r->ItemDataType(j);
  304.                      const char* iname= r->ItemName(j);
  306.                      //    Printing to stdout:
  307.                      if(iname == 0) iname= "";
  308.                      cout  << iname << '=';
  310.                      if (rt == eDB_Char || rt == eDB_VarChar) {
  311.                          CDB_VarChar str_val;
  312.                          r->GetItem(&str_val);
  313.                          cout << (str_val.IsNULL()? "{NULL}" : str_val.Value()) << endl << endl ;
  315.                      } else if (rt == eDB_Int ||
  316.                                 rt == eDB_SmallInt ||
  317.                                 rt == eDB_TinyInt) {
  319.                          CDB_Int int_val;
  320.                          r->GetItem(&int_val);
  321.                          if (int_val.IsNULL()) {
  322.                              cout << "{NULL}";
  323.                          } else {
  324.                              cout << int_val.Value() << endl << endl ;
  325.                          }
  326.                       } else if (rt == eDB_Float) {
  328.                             CDB_Float fl_val;
  329.                             r->GetItem(&fl_val);
  330.                             if(fl_val.IsNULL()) {
  331.                                 cout << "{NULL}";
  332.                             } else {
  333.                                 cout << fl_val.Value() << endl<< endl ;
  334.                             }
  335.                       } else if (rt == eDB_Double) {
  337.                             CDB_Double fl_val;
  338.                             r->GetItem(&fl_val);
  339.                             if(fl_val.IsNULL()) {
  340.                                 cout << "{NULL}";
  341.                             } else {
  342.                                 cout << fl_val.Value() << endl<< endl ;
  343.                             }
  344.                        } else if (rt == eDB_DateTime ||
  345.                                   rt == eDB_SmallDateTime) {
  347.                             CDB_DateTime date_val;
  348.                             r->GetItem(&date_val);
  349.                             if(date_val.IsNULL()) {
  350.                                 cout << "{NULL}";
  351.                             } else {
  352.                                 cout << date_val.Value().AsString() << endl<< endl ;
  353.                             }
  354.                         } else if (rt == eDB_Text){
  356.                             CDB_Text text_val;
  357.                             r->GetItem(&text_val);
  359.                             if(text_val.IsNULL()) {
  360.                                 cout << "{NULL}";
  361.                             } else {
  362.                                 txt_buf = ( char*) malloc (text_val.Size()+1);
  363.                                 len_txt = text_val.Read (( char*)txt_buf, text_val.Size());
  364.                                 txt_buf[text_val.Size()] = ''; 
  365.                                 cout << txt_buf << endl << endl ;
  366.                             }
  367.                         } else {
  368.                             r->SkipItem();
  369.                             cout << "{unprintable}";
  370.                         }
  371.                     }
  372.                     cout << "</ROW>" << endl << endl;
  373.                 }
  374.                 delete r;
  375.             }
  376.         }
  377.         delete lcmd;
  378.     } catch (CDB_Exception& e) {
  379.    HandleIt(&e);
  380.       return 1;
  381.     }
  382.     return 0;
  383. }
  385. //DeleteTable is destroying a table after program finished to work with it
  386. int DeleteTable (CDB_Connection* con)
  387. {
  388.     try {
  389.         CDB_LangCmd* lcmd = con->LangCmd("drop table CursorSample");
  390.         lcmd->Send();
  392.         while (lcmd->HasMoreResults()) {
  393.             CDB_Result* r = lcmd->Result();
  394.             if (!r) {
  395.                 continue;
  396.             }
  397.             delete r;
  398.         }
  399.         delete lcmd;
  400.      } catch (CDB_Exception& e) {
  401.    HandleIt(&e);
  402.       return 1;
  403.      }
  404.     return 0;
  405. }