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

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

生物技术

开发平台：

C/C++

connection.cpp：源码内容
  1. /*
  2.  * ===========================================================================
  3.  * PRODUCTION $Log: connection.cpp,v $
  4.  * PRODUCTION Revision 1000.1  2004/06/01 19:21:40  gouriano
  5.  * PRODUCTION PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R1.5
  6.  * PRODUCTION
  7.  * ===========================================================================
  8.  */
  10. /* $Id: connection.cpp,v 1000.1 2004/06/01 19:21:40 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.  * Author:  Vladimir Soussov
  36.  *
  37.  * File Description:  ODBC connection
  38.  *
  39.  */
  41. #include <ncbi_pch.hpp>
  42. #include <dbapi/driver/odbc/interfaces.hpp>
  43. #include <string.h>
  44. #ifdef HAVE_ODBCSS_H
  45. #include <odbcss.h>
  46. #endif
  49. BEGIN_NCBI_SCOPE
  51. static bool ODBC_xSendDataPrepare(SQLHSTMT cmd, CDB_ITDescriptor& descr_in,
  52.                                   SQLINTEGER size, bool is_text, bool logit, 
  53.           SQLPOINTER id, CODBC_Reporter& rep);
  54. static bool ODBC_xSendDataGetId(SQLHSTMT cmd, SQLPOINTER* id, 
  55.                                 CODBC_Reporter& rep);
  57. CODBC_Connection::CODBC_Connection(CODBCContext* cntx, SQLHDBC con,
  58.                                    bool reusable, const string& pool_name):
  59.     m_Reporter(0, SQL_HANDLE_DBC, con)
  60. {
  61.     m_Link     = con;
  62.     m_Context  = cntx;
  63.     m_Reusable = reusable;
  64.     m_Pool     = pool_name;
  65.     m_Reporter.SetHandlerStack(&m_MsgHandlers);
  66. }
  69. bool CODBC_Connection::IsAlive()
  70. {
  71.     SQLINTEGER status;
  72.     SQLRETURN r= SQLGetConnectAttr(m_Link, SQL_ATTR_CONNECTION_DEAD, &status, SQL_IS_INTEGER, 0);
  74.     return ((r == SQL_SUCCESS || r == SQL_SUCCESS_WITH_INFO) && (status == SQL_CD_FALSE));
  75. }
  78. CODBC_LangCmd* CODBC_Connection::xLangCmd(const string& lang_query,
  79.                                           unsigned int  nof_params)
  80. {
  81.     SQLHSTMT cmd;
  82.     SQLRETURN r= SQLAllocHandle(SQL_HANDLE_STMT, m_Link, &cmd);
  84.     if(r == SQL_ERROR) {
  85.         m_Reporter.ReportErrors();
  86.     }
  88.     CODBC_LangCmd* lcmd = new CODBC_LangCmd(this, cmd, lang_query, nof_params);
  89.     m_CMDs.Add(lcmd);
  90.     return lcmd;
  91. }
  93. CDB_LangCmd* CODBC_Connection::LangCmd(const string& lang_query,
  94.                                      unsigned int  nof_params)
  95. {
  96.     return Create_LangCmd(*(xLangCmd(lang_query, nof_params)));
  97. }
  100. CDB_RPCCmd* CODBC_Connection::RPC(const string& rpc_name,
  101.                                 unsigned int  nof_args)
  102. {
  103. #if 0
  104.     return 0;
  105. #else
  106.     SQLHSTMT cmd;
  107.     SQLRETURN r= SQLAllocHandle(SQL_HANDLE_STMT, m_Link, &cmd);
  109.     if(r == SQL_ERROR) {
  110.         m_Reporter.ReportErrors();
  111.     }
  113.     CODBC_RPCCmd* rcmd = new CODBC_RPCCmd(this, cmd, rpc_name, nof_args);
  114.     m_CMDs.Add(rcmd);
  115.     return Create_RPCCmd(*rcmd);
  116. #endif
  117. }
  120. CDB_BCPInCmd* CODBC_Connection::BCPIn(const string& table_name,
  121.                                     unsigned int  nof_columns)
  122. {
  123. #ifdef NCBI_OS_UNIX
  124.     return 0; // not implemented
  125. #else
  126.     if (!m_BCPable) {
  127.         throw CDB_ClientEx(eDB_Error, 410003, "CODBC_Connection::BCPIn",
  128.                            "No bcp on this connection");
  129.     }
  131.     CODBC_BCPInCmd* bcmd = new CODBC_BCPInCmd(this, m_Link, table_name, nof_columns);
  132.     m_CMDs.Add(bcmd);
  133.     return Create_BCPInCmd(*bcmd);
  134. #endif
  135. }
  138. CDB_CursorCmd* CODBC_Connection::Cursor(const string& cursor_name,
  139.                                       const string& query,
  140.                                       unsigned int  nof_params,
  141.                                       unsigned int  batch_size)
  142. {
  143. #if 0
  144.     return 0;
  145. #else
  146.     SQLHSTMT cmd;
  147.     SQLRETURN r= SQLAllocHandle(SQL_HANDLE_STMT, m_Link, &cmd);
  149.     if(r == SQL_ERROR) {
  150.         m_Reporter.ReportErrors();
  151.     }
  153.     CODBC_CursorCmd* ccmd = new CODBC_CursorCmd(this, cmd, cursor_name, query,
  154.                                                 nof_params);
  155.     m_CMDs.Add(ccmd);
  156.     return Create_CursorCmd(*ccmd);
  157. #endif
  158. }
  161. CDB_SendDataCmd* CODBC_Connection::SendDataCmd(I_ITDescriptor& descr_in,
  162.                                                size_t data_size, bool log_it)
  163. {
  164.     SQLHSTMT cmd;
  165.     SQLRETURN r= SQLAllocHandle(SQL_HANDLE_STMT, m_Link, &cmd);
  167.     if(r == SQL_ERROR) {
  168.         m_Reporter.ReportErrors();
  169.     }
  171.     CODBC_SendDataCmd* sd_cmd = 
  172.         new CODBC_SendDataCmd(this, cmd, 
  173.                               (CDB_ITDescriptor&)descr_in,  
  174.                               data_size, log_it);
  175.     m_CMDs.Add(sd_cmd);
  176.     return Create_SendDataCmd(*sd_cmd);
  177. }
  180. bool CODBC_Connection::SendData(I_ITDescriptor& desc, CDB_Image& img, bool log_it)
  181. {
  182.     SQLHSTMT cmd;
  183.     SQLRETURN r= SQLAllocHandle(SQL_HANDLE_STMT, m_Link, &cmd);
  185.     if(r == SQL_ERROR) {
  186.         m_Reporter.ReportErrors();
  187.     }
  189.     CODBC_Reporter lrep(&m_MsgHandlers, SQL_HANDLE_STMT, cmd);
  190.     SQLPOINTER p= (SQLPOINTER)2;
  191.     SQLINTEGER s= img.Size();
  193.     if((!ODBC_xSendDataPrepare(cmd, (CDB_ITDescriptor&)desc, s, false, log_it, p, lrep)) ||
  194.        (!ODBC_xSendDataGetId(cmd, &p, lrep))) {
  195.         throw CDB_ClientEx(eDB_Error, 410035, "CODBC_Connection::SendData",
  196.                            "can not prepare a command");
  197.     }
  199.     return x_SendData(cmd, img, lrep);
  200.     
  201. }
  204. bool CODBC_Connection::SendData(I_ITDescriptor& desc, CDB_Text& txt, bool log_it)
  205. {
  206.     SQLHSTMT cmd;
  207.     SQLRETURN r= SQLAllocHandle(SQL_HANDLE_STMT, m_Link, &cmd);
  209.     if(r == SQL_ERROR) {
  210.         m_Reporter.ReportErrors();
  211.     }
  214.     CODBC_Reporter lrep(&m_MsgHandlers, SQL_HANDLE_STMT, cmd);
  215.     SQLPOINTER p= (SQLPOINTER)2;
  216.     SQLINTEGER s= txt.Size();
  218.     if((!ODBC_xSendDataPrepare(cmd, (CDB_ITDescriptor&)desc, s, true, log_it, p, lrep)) ||
  219.        (!ODBC_xSendDataGetId(cmd, &p, lrep))) {
  220.         throw CDB_ClientEx(eDB_Error, 410035, "CODBC_Connection::SendData",
  221.                            "can not prepare a command");
  222.     }
  224.     return x_SendData(cmd, txt, lrep);
  225. }
  228. bool CODBC_Connection::Refresh()
  229. {
  230.     // close all commands first
  231.     while(m_CMDs.NofItems() > 0) {
  232.         CDB_BaseEnt* pCmd = static_cast<CDB_BaseEnt*> (m_CMDs.Get(0));
  233.         delete pCmd;
  234.         m_CMDs.Remove((int) 0);
  235.     }
  237.     return IsAlive();
  238. }
  241. const string& CODBC_Connection::ServerName() const
  242. {
  243.     return m_Server;
  244. }
  247. const string& CODBC_Connection::UserName() const
  248. {
  249.     return m_User;
  250. }
  253. const string& CODBC_Connection::Password() const
  254. {
  255.     return m_Passwd;
  256. }
  259. I_DriverContext::TConnectionMode CODBC_Connection::ConnectMode() const
  260. {
  261.     I_DriverContext::TConnectionMode mode = 0;
  262.     if ( m_BCPable ) {
  263.         mode |= I_DriverContext::fBcpIn;
  264.     }
  265.     if ( m_SecureLogin ) {
  266.         mode |= I_DriverContext::fPasswordEncrypted;
  267.     }
  268.     return mode;
  269. }
  272. bool CODBC_Connection::IsReusable() const
  273. {
  274.     return m_Reusable;
  275. }
  278. const string& CODBC_Connection::PoolName() const
  279. {
  280.     return m_Pool;
  281. }
  284. I_DriverContext* CODBC_Connection::Context() const
  285. {
  286.     return const_cast<CODBCContext*> (m_Context);
  287. }
  290. void CODBC_Connection::PushMsgHandler(CDB_UserHandler* h)
  291. {
  292.     m_MsgHandlers.Push(h);
  293. }
  296. void CODBC_Connection::PopMsgHandler(CDB_UserHandler* h)
  297. {
  298.     m_MsgHandlers.Pop(h);
  299. }
  301. CDB_ResultProcessor* CODBC_Connection::SetResultProcessor(CDB_ResultProcessor* rp)
  302. {
  303.     CDB_ResultProcessor* r= m_ResProc;
  304.     m_ResProc= rp;
  305.     return r;
  306. }
  308. void CODBC_Connection::Release()
  309. {
  310.     m_BR = 0;
  311.     // close all commands first
  312.     while(m_CMDs.NofItems() > 0) {
  313.         CDB_BaseEnt* pCmd = static_cast<CDB_BaseEnt*> (m_CMDs.Get(0));
  314.         delete pCmd;
  315.         m_CMDs.Remove((int) 0);
  316.     }
  317. }
  320. CODBC_Connection::~CODBC_Connection()
  321. {
  322.     if (Refresh()) {
  323.         switch(SQLDisconnect(m_Link)) {
  324.         case SQL_SUCCESS_WITH_INFO:
  325.         case SQL_ERROR:
  326.             m_Reporter.ReportErrors();
  327.         case SQL_SUCCESS:
  328.             break;
  329.         default:
  330.             throw CDB_ClientEx(eDB_Error, 410009, "CODBC_Connection::~CODBC_Connection",
  331.                                "SQLDisconnect failed (memory corruption suspected)");
  332.             
  333.         }
  334.     }
  335.     if(SQLFreeHandle(SQL_HANDLE_DBC, m_Link) == SQL_ERROR) {
  336.         m_Reporter.ReportErrors();
  337.     }
  338.         
  339. }
  342. void CODBC_Connection::DropCmd(CDB_BaseEnt& cmd)
  343. {
  344.     m_CMDs.Remove(static_cast<TPotItem> (&cmd));
  345. }
  348. static bool ODBC_xSendDataPrepare(SQLHSTMT cmd, CDB_ITDescriptor& descr_in,
  349.                                   SQLINTEGER size, bool is_text, bool logit, 
  350.           SQLPOINTER id, CODBC_Reporter& rep)
  351. {
  352.     string q= "update ";
  353.     q+= descr_in.TableName();
  354.     q+= " set ";
  355.     q+= descr_in.ColumnName();
  356.     q+= "=? where ";
  357.     q+= descr_in.SearchConditions();
  358.     //q+= " ;nset rowcount 0";
  360. #ifdef SQL_TEXTPTR_LOGGING
  361. if(!logit) {
  362. switch(SQLSetStmtAttr(cmd, SQL_TEXTPTR_LOGGING, /*SQL_SOPT_SS_TEXTPTR_LOGGING,*/
  363. (SQLPOINTER)SQL_TL_OFF, SQL_IS_INTEGER)) {
  364. case SQL_SUCCESS_WITH_INFO:
  365. case SQL_ERROR:
  366. rep.ReportErrors();
  367. default: break;
  368. }
  369. }
  370. #endif
  372. switch(SQLPrepare(cmd, (SQLCHAR*)q.c_str(), SQL_NTS)) {
  373. case SQL_SUCCESS_WITH_INFO:
  374. rep.ReportErrors();
  375. case SQL_SUCCESS: break;
  376. case SQL_ERROR:
  377. rep.ReportErrors();
  378. default: return false;
  379. }
  381. SQLSMALLINT par_type, par_dig, par_null;
  382.     SQLUINTEGER par_size;
  384. #if 0
  385. switch(SQLNumParams(cmd, &par_dig)) {
  386. case SQL_SUCCESS: break;
  387. case SQL_SUCCESS_WITH_INFO:
  388. case SQL_ERROR:
  389. rep.ReportErrors();
  390. default: return false;
  391. }
  392. #endif
  394. switch(SQLDescribeParam(cmd, 1, &par_type, &par_size, &par_dig, &par_null)){
  395. case SQL_SUCCESS_WITH_INFO:
  396. rep.ReportErrors();
  397. case SQL_SUCCESS: break;
  398. case SQL_ERROR:
  399. rep.ReportErrors();
  400. default: return false;
  401. }
  403.     SQLINTEGER p= SQL_LEN_DATA_AT_EXEC(size);
  405.     switch(SQLBindParameter(cmd, 1, SQL_PARAM_INPUT, 
  406.                      is_text? SQL_C_CHAR : SQL_C_BINARY, par_type,
  407.                      // is_text? SQL_LONGVARCHAR : SQL_LONGVARBINARY,
  408.                      size, 0, id, 0, &p)) {
  409. case SQL_SUCCESS_WITH_INFO:
  410. rep.ReportErrors();
  411. case SQL_SUCCESS: break;
  412. case SQL_ERROR:
  413. rep.ReportErrors();
  414. default: return false;
  415. }
  418.     
  419.     switch(SQLExecute(cmd)) {
  420.     case SQL_NEED_DATA:
  421.         return true;
  422.     case SQL_SUCCESS_WITH_INFO:
  423.     case SQL_ERROR:
  424.         rep.ReportErrors();
  425.     default:
  426.         return false;
  427.     }
  428. }
  430. static bool ODBC_xSendDataGetId(SQLHSTMT cmd, SQLPOINTER* id, 
  431.                                 CODBC_Reporter& rep)
  432. {
  433.     switch(SQLParamData(cmd, id)) {
  434.     case SQL_NEED_DATA:
  435.         return true;
  436.     case SQL_SUCCESS_WITH_INFO:
  437.     case SQL_ERROR:
  438.         rep.ReportErrors();
  439.     default:
  440.         return false;
  441.     }
  442. }
  444. bool CODBC_Connection::x_SendData(SQLHSTMT cmd, CDB_Stream& stream, CODBC_Reporter& rep)
  445. {
  446.     char buff[1801];
  447.     size_t s;
  449.     while((s= stream.Read(buff, sizeof(buff))) != 0) {
  450.         switch(SQLPutData(cmd, (SQLPOINTER)buff, (SQLINTEGER)s)) {
  451.         case SQL_SUCCESS_WITH_INFO:
  452.             rep.ReportErrors();
  453.         case SQL_NEED_DATA:
  454. continue;
  455.         case SQL_NO_DATA:
  456. return true;
  457.         case SQL_SUCCESS:
  458.             break;
  459.         case SQL_ERROR:
  460.             rep.ReportErrors();
  461.         default:
  462.             return false;
  463.         }
  464.     }
  465.     switch(SQLParamData(cmd, (SQLPOINTER*)&s)) {
  466. case SQL_SUCCESS_WITH_INFO: rep.ReportErrors();
  467.     case SQL_SUCCESS:           break;
  468. case SQL_NO_DATA:           return true;
  469.     case SQL_NEED_DATA: 
  470.     throw CDB_ClientEx(eDB_Error, 410044, "CODBC_Connection::SendData",
  471.                                "Not all the data were sent");
  472. case SQL_ERROR:             rep.ReportErrors();
  473. default:
  474. throw CDB_ClientEx(eDB_Error, 410045, "CODBC_Connection::SendData",
  475.                            "SQLParamData failed");
  476. }
  478.     for(;;) {
  479.         switch(SQLMoreResults(cmd)) {
  480.         case SQL_SUCCESS_WITH_INFO: rep.ReportErrors();
  481.         case SQL_SUCCESS:           continue;
  482.         case SQL_NO_DATA:           break;
  483.         case SQL_ERROR:             
  484.             rep.ReportErrors();
  485.             throw CDB_ClientEx(eDB_Error, 410014, "CODBC_Connection::SendData",
  486.                                "SQLMoreResults failed");
  487.         default:
  488.             throw CDB_ClientEx(eDB_Error, 410015, "CODBC_Connection::SendData",
  489.                                "SQLMoreResults failed (memory corruption suspected)");
  490.         }
  491. break;
  492.     }
  493.     return true;
  494. }
  495.         
  496. void CODBC_Connection::ODBC_SetTimeout(SQLUINTEGER nof_secs) {}
  497. void CODBC_Connection::ODBC_SetTextImageSize(SQLUINTEGER nof_bytes) {}
  500. /////////////////////////////////////////////////////////////////////////////
  501. //
  502. //  CODBC_SendDataCmd::
  503. //
  505. CODBC_SendDataCmd::CODBC_SendDataCmd(CODBC_Connection* conn, 
  506.                                      SQLHSTMT cmd, 
  507.                                      CDB_ITDescriptor& descr,
  508.                                      size_t nof_bytes, bool logit) :
  509.     m_Connect(conn), m_Cmd(cmd), m_Bytes2go(nof_bytes),
  510.     m_Reporter(&conn->m_MsgHandlers, SQL_HANDLE_STMT, cmd)
  511. {
  512.     SQLPOINTER p= (SQLPOINTER)1;
  513.     if((!ODBC_xSendDataPrepare(cmd, descr, (SQLINTEGER)nof_bytes,
  514.                               false, logit, p, m_Reporter)) ||
  515.        (!ODBC_xSendDataGetId(cmd, &p, m_Reporter))) {
  516.         throw CDB_ClientEx(eDB_Error, 410035, "CODBC_SendDataCmd::CODBC_SendDataCm",
  517.                            "can not prepare a command");
  518.     }   
  519. }
  521. size_t CODBC_SendDataCmd::SendChunk(const void* chunk_ptr, size_t nof_bytes)
  522. {
  523.     if(nof_bytes > m_Bytes2go) nof_bytes= m_Bytes2go;
  524.     if(nof_bytes < 1) return 0;
  526.     switch(SQLPutData(m_Cmd, (SQLPOINTER)chunk_ptr, (SQLINTEGER)nof_bytes)) {
  527.     case SQL_SUCCESS_WITH_INFO:
  528.         m_Reporter.ReportErrors();
  529.     case SQL_NEED_DATA:
  530.     case SQL_NO_DATA:
  531.     case SQL_SUCCESS:
  532.         m_Bytes2go-= nof_bytes;
  533.         if(m_Bytes2go == 0) break;
  534.         return nof_bytes;
  535.     case SQL_ERROR:
  536.         m_Reporter.ReportErrors();
  537.     default:
  538.         return 0;
  539.     }
  541.     size_t s;
  542.     switch(SQLParamData(m_Cmd, (SQLPOINTER*)&s)) {
  543. case SQL_SUCCESS_WITH_INFO: m_Reporter.ReportErrors();
  544.     case SQL_SUCCESS:           break;
  545. case SQL_NO_DATA:           break;
  546.     case SQL_NEED_DATA: 
  547.     throw CDB_ClientEx(eDB_Error, 410044, "CODBC_Connection::SendChunk",
  548.                                "Not all the data were sent");
  549. case SQL_ERROR:             m_Reporter.ReportErrors();
  550. default:
  551. throw CDB_ClientEx(eDB_Error, 410045, "CODBC_Connection::SendChunk",
  552.                            "SQLParamData failed");
  553. }
  555.     for(;;) {
  556.         switch(SQLMoreResults(m_Cmd)) {
  557.         case SQL_SUCCESS_WITH_INFO: m_Reporter.ReportErrors();
  558.         case SQL_SUCCESS:           continue;
  559.         case SQL_NO_DATA:           break;
  560.         case SQL_ERROR:             
  561.             m_Reporter.ReportErrors();
  562.             throw CDB_ClientEx(eDB_Error, 410014, "CODBC_SendDataCmd::SendChunk",
  563.                                "SQLMoreResults failed");
  564.         default:
  565.             throw CDB_ClientEx(eDB_Error, 410015, "CODBC_SendDataCmd::SendChunk",
  566.                                "SQLMoreResults failed (memory corruption suspected)");
  567.         }
  568. break;
  569.     }
  570.     return nof_bytes;
  571. }
  573. void CODBC_SendDataCmd::Release()
  574. {
  575.     m_BR = 0;
  576.     if (m_Bytes2go > 0) {
  577.         xCancel();
  578.         m_Bytes2go = 0;
  579.     }
  580.     m_Connect->DropCmd(*this);
  581.     delete this;
  582. }
  585. CODBC_SendDataCmd::~CODBC_SendDataCmd()
  586. {
  587.     if (m_Bytes2go > 0)
  588.         xCancel();
  589.     if (m_BR)
  590.         *m_BR = 0;
  591.     SQLFreeHandle(SQL_HANDLE_STMT, m_Cmd);
  592. }
  594. void CODBC_SendDataCmd::xCancel()
  595. {
  596.     switch(SQLFreeStmt(m_Cmd, SQL_CLOSE)) {
  597.     case SQL_SUCCESS_WITH_INFO: m_Reporter.ReportErrors();
  598.     case SQL_SUCCESS:           break;
  599.     case SQL_ERROR:             m_Reporter.ReportErrors();
  600.     default:                    return;
  601.     }
  602.     SQLFreeStmt(m_Cmd, SQL_RESET_PARAMS);
  603. }
  605. END_NCBI_SCOPE
  609. /*
  610.  * ===========================================================================
  611.  * $Log: connection.cpp,v $
  612.  * Revision 1000.1  2004/06/01 19:21:40  gouriano
  613.  * PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R1.5
  614.  *
  615.  * Revision 1.5  2004/05/17 21:16:05  gorelenk
  616.  * Added include of PCH ncbi_pch.hpp
  617.  *
  618.  * Revision 1.4  2003/06/05 16:02:04  soussov
  619.  * adds code for DumpResults and for the dumped results processing
  620.  *
  621.  * Revision 1.3  2003/05/05 20:47:45  ucko
  622.  * Check HAVE_ODBCSS_H; regardless, disable BCP on Unix, since even
  623.  * DataDirect's implementation lacks the relevant bcp_* functions.
  624.  *
  625.  * Revision 1.2  2002/07/05 20:47:56  soussov
  626.  * fixes bug in SendData
  627.  *
  628.  *
  629.  * ===========================================================================
  630.  */