rs_impl.hpp
上传用户:yhdzpy8989
上传日期:2007-06-13
资源大小:13604k
文件大小:6k
源码类别:

生物技术

开发平台:

C/C++

  1. /*
  2.  * ===========================================================================
  3.  * PRODUCTION $Log: rs_impl.hpp,v $
  4.  * PRODUCTION Revision 1000.1  2004/04/21 14:48:13  gouriano
  5.  * PRODUCTION PRODUCTION: UPGRADED [CATCHUP_003] Dev-tree R1.15
  6.  * PRODUCTION
  7.  * ===========================================================================
  8.  */
  9. #ifndef _RS_IMPL_HPP_
  10. #define _RS_IMPL_HPP_
  11. /* $Id: rs_impl.hpp,v 1000.1 2004/04/21 14:48:13 gouriano Exp $
  12. * ===========================================================================
  13. *
  14. *                            PUBLIC DOMAIN NOTICE                          
  15. *               National Center for Biotechnology Information
  16. *                                                                          
  17. *  This software/database is a "United States Government Work" under the   
  18. *  terms of the United States Copyright Act.  It was written as part of    
  19. *  the author's official duties as a United States Government employee and 
  20. *  thus cannot be copyrighted.  This software/database is freely available 
  21. *  to the public for use. The National Library of Medicine and the U.S.    
  22. *  Government have not placed any restriction on its use or reproduction.  
  23. *                                                                          
  24. *  Although all reasonable efforts have been taken to ensure the accuracy  
  25. *  and reliability of the software and data, the NLM and the U.S.          
  26. *  Government do not and cannot warrant the performance or results that    
  27. *  may be obtained by using this software or data. The NLM and the U.S.    
  28. *  Government disclaim all warranties, express or implied, including       
  29. *  warranties of performance, merchantability or fitness for any particular
  30. *  purpose.                                                                
  31. *                                                                          
  32. *  Please cite the author in any work or product based on this material.   
  33. *
  34. * ===========================================================================
  35. *
  36. * File Name:  $Id: rs_impl.hpp,v 1000.1 2004/04/21 14:48:13 gouriano Exp $
  37. *
  38. * Author:  Michael Kholodov
  39. *   
  40. * File Description:  Resultset implementation
  41. *
  42. *
  43. * $Log: rs_impl.hpp,v $
  44. * Revision 1000.1  2004/04/21 14:48:13  gouriano
  45. * PRODUCTION: UPGRADED [CATCHUP_003] Dev-tree R1.15
  46. *
  47. * Revision 1.15  2004/04/12 14:25:33  kholodov
  48. * Modified: resultset caching scheme, fixed single connection handling
  49. *
  50. * Revision 1.14  2004/04/08 15:56:58  kholodov
  51. * Multiple bug fixes and optimizations
  52. *
  53. * Revision 1.13  2003/02/12 15:52:32  kholodov
  54. * Added: WasNull() method
  55. *
  56. * Revision 1.12  2002/12/16 18:56:50  kholodov
  57. * Fixed: memory leak in CStatement object
  58. *
  59. * Revision 1.11  2002/11/25 15:15:50  kholodov
  60. * Removed: dynamic array module (array.hpp, array.cpp), using
  61. * STL vector instead to keep bound column data.
  62. *
  63. * Revision 1.10  2002/10/31 22:37:05  kholodov
  64. * Added: DisableBind(), GetColumnNo(), GetTotalColumns() methods
  65. * Fixed: minor errors, diagnostic messages
  66. *
  67. * Revision 1.9  2002/10/21 20:38:08  kholodov
  68. * Added: GetParentConn() method to get the parent connection from IStatement,
  69. * ICallableStatement and ICursor objects.
  70. * Fixed: Minor fixes
  71. *
  72. * Revision 1.8  2002/09/18 18:49:27  kholodov
  73. * Modified: class declaration and Action method to reflect
  74. * direct inheritance of CActiveObject from IEventListener
  75. *
  76. * Revision 1.7  2002/09/16 19:34:41  kholodov
  77. * Added: bulk insert support
  78. *
  79. * Revision 1.6  2002/08/26 15:35:56  kholodov
  80. * Added possibility to disable transaction log
  81. * while updating BLOBs
  82. *
  83. * Revision 1.5  2002/07/08 16:08:19  kholodov
  84. * Modified: moved initialization code to Init() method
  85. *
  86. * Revision 1.4  2002/06/11 16:22:53  kholodov
  87. * Fixed the incorrect declaration of GetMetaData() method
  88. *
  89. * Revision 1.3  2002/05/14 19:53:17  kholodov
  90. * Modified: Read() returns 0 to signal end of column
  91. *
  92. * Revision 1.2  2002/04/05 19:29:50  kholodov
  93. * Modified: GetBlobIStream() returns one and the same object, which is created
  94. * on the first call.
  95. * Added: GetVariant(const string& colName) to retrieve column value by
  96. * column name
  97. *
  98. * Revision 1.1  2002/01/30 14:51:23  kholodov
  99. * User DBAPI implementation, first commit
  100. *
  101. *
  102. *
  103. */
  104. //#include <vector>
  105. #include <dbapi/dbapi.hpp>
  106. #include "active_obj.hpp"
  107. //#include "array.hpp"
  108. //#include "dbexception.hpp"
  109. #include "blobstream.hpp"
  110. #include <vector>
  111. BEGIN_NCBI_SCOPE
  112. class CResultSet : public CActiveObject, 
  113.                    public IResultSet
  114. {
  115. public:
  116.     CResultSet(class CConnection* conn, CDB_Result *rs);
  117.     virtual ~CResultSet();
  118.   
  119.     void Init();
  120.     virtual EDB_ResType GetResultType();
  121.     virtual bool Next();
  122.     virtual const CVariant& GetVariant(unsigned int idx);
  123.     virtual const CVariant& GetVariant(const string& colName);
  124.     virtual void DisableBind(bool b);
  125.     virtual void BindBlobToVariant(bool b);
  126.   
  127.     virtual size_t Read(void* buf, size_t size);
  128.     virtual bool WasNull();
  129.     virtual int GetColumnNo();
  130.     virtual unsigned int GetTotalColumns();
  131.     virtual void Close();
  132.     virtual const IResultSetMetaData* GetMetaData();
  133.     virtual istream& GetBlobIStream(size_t buf_size);
  134.     virtual ostream& GetBlobOStream(size_t blob_size, 
  135.                                     EAllowLog log_it,
  136.                                     size_t buf_size);
  137.     // Interface IEventListener implementation
  138.     virtual void Action(const CDbapiEvent& e);
  139.     CDB_Result* GetCDB_Result() {
  140.         return m_rs;
  141.     }
  142.     void Invalidate() {
  143.         delete m_rs;
  144.         m_rs = 0;
  145.     }
  146. protected:
  147.     
  148.     int GetColNum(const string& name);
  149.     void CheckIdx(unsigned int idx);
  150.     bool IsBindBlob() {
  151.         return m_bindBlob;
  152.     }
  153.     bool IsDisableBind() {
  154.         return m_disableBind;
  155.     }
  156.     void FreeResources();
  157. private:
  158.     
  159.     class CConnection* m_conn;
  160.     CDB_Result *m_rs;
  161.     //CResultSetMetaDataImpl *m_metaData;
  162.     vector<CVariant> m_data;
  163.     CBlobIStream *m_istr;
  164.     CBlobOStream *m_ostr;
  165.     int m_column;
  166.     bool m_bindBlob;
  167.     bool m_disableBind;
  168.     bool m_wasNull;
  169. };
  170. //====================================================================
  171. END_NCBI_SCOPE
  172. #endif // _RS_IMPL_HPP_