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

生物技术

开发平台:

C/C++

  1. /*
  2.  * ===========================================================================
  3.  * PRODUCTION $Log: blobstream.cpp,v $
  4.  * PRODUCTION Revision 1000.2  2004/06/01 19:18:06  gouriano
  5.  * PRODUCTION PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R1.7
  6.  * PRODUCTION
  7.  * ===========================================================================
  8.  */
  9. /* $Id: blobstream.cpp,v 1000.2 2004/06/01 19:18:06 gouriano Exp $
  10. * ===========================================================================
  11. *
  12. *                            PUBLIC DOMAIN NOTICE                          
  13. *               National Center for Biotechnology Information
  14. *                                                                          
  15. *  This software/database is a "United States Government Work" under the   
  16. *  terms of the United States Copyright Act.  It was written as part of    
  17. *  the author's official duties as a United States Government employee and 
  18. *  thus cannot be copyrighted.  This software/database is freely available 
  19. *  to the public for use. The National Library of Medicine and the U.S.    
  20. *  Government have not placed any restriction on its use or reproduction.  
  21. *                                                                          
  22. *  Although all reasonable efforts have been taken to ensure the accuracy  
  23. *  and reliability of the software and data, the NLM and the U.S.          
  24. *  Government do not and cannot warrant the performance or results that    
  25. *  may be obtained by using this software or data. The NLM and the U.S.    
  26. *  Government disclaim all warranties, express or implied, including       
  27. *  warranties of performance, merchantability or fitness for any particular
  28. *  purpose.                                                                
  29. *                                                                          
  30. *  Please cite the author in any work or product based on this material.   
  31. *
  32. * ===========================================================================
  33. *
  34. * File Name:  $Id: blobstream.cpp,v 1000.2 2004/06/01 19:18:06 gouriano Exp $
  35. *
  36. * Author:  Michael Kholodov
  37. *   
  38. * File Description: stream implementation for reading and writing BLOBs
  39. *
  40. *
  41. * $Log: blobstream.cpp,v $
  42. * Revision 1000.2  2004/06/01 19:18:06  gouriano
  43. * PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R1.7
  44. *
  45. * Revision 1.7  2004/05/17 21:10:28  gorelenk
  46. * Added include of PCH ncbi_pch.hpp
  47. *
  48. * Revision 1.6  2004/03/12 16:27:09  sponomar
  49. * correct nested querys
  50. *
  51. * Revision 1.4  2002/08/26 15:35:56  kholodov
  52. * Added possibility to disable transaction log
  53. * while updating BLOBs
  54. *
  55. * Revision 1.3  2002/07/08 16:04:15  kholodov
  56. * Reformatted
  57. *
  58. * Revision 1.2  2002/05/13 19:08:44  kholodov
  59. * Modified: source code is included in NCBI namespace
  60. *
  61. * Revision 1.1  2002/01/30 14:51:20  kholodov
  62. * User DBAPI implementation, first commit
  63. *
  64. *
  65. *
  66. *
  67. */
  68. #include <ncbi_pch.hpp>
  69. #include "blobstream.hpp"
  70. #include <dbapi/driver/exception.hpp>
  71. #include <dbapi/driver/interfaces.hpp>
  72. #include <dbapi/driver/public.hpp>
  73. BEGIN_NCBI_SCOPE
  74. CBlobIStream::CBlobIStream(CDB_Result* rs, streamsize bufsize)
  75. : istream(new CByteStreamBuf(bufsize))
  76. {
  77.     ((CByteStreamBuf*)rdbuf())->SetRs(rs);
  78. }
  79. CBlobIStream::~CBlobIStream()
  80. {
  81.     delete rdbuf();
  82. }
  83. CBlobOStream::CBlobOStream(CDB_Connection* connAux,
  84.                            I_ITDescriptor* desc,
  85.                            size_t datasize, 
  86.                            streamsize bufsize,
  87.                            bool log_it)
  88.                            : ostream(new CByteStreamBuf(bufsize)), m_desc(desc), m_conn(connAux)
  89. {
  90.     if( log_it ) {
  91.         _TRACE("CBlobOStream::ctor(): Transaction log enabled");
  92.     }
  93.     else {
  94.         _TRACE("CBlobOStream::ctor(): Transaction log disabled");
  95.     }
  96.     ((CByteStreamBuf*)rdbuf())->SetCmd(m_conn->SendDataCmd(*m_desc, datasize, log_it));
  97. }
  98. CBlobOStream::CBlobOStream(CDB_CursorCmd* curCmd,
  99.                            unsigned int item_num,
  100.                            size_t datasize, 
  101.                            streamsize bufsize,
  102.                            bool log_it)
  103.                            : ostream(new CByteStreamBuf(bufsize)), m_desc(0), m_conn(0)
  104. {
  105.     if( log_it ) {
  106.         _TRACE("CBlobOStream::ctor(): Transaction log enabled");
  107.     }
  108.     else {
  109.         _TRACE("CBlobOStream::ctor(): Transaction log disabled");
  110.     }
  111.     ((CByteStreamBuf*)rdbuf())->SetCmd(curCmd->SendDataCmd(item_num, datasize, log_it));
  112. }
  113. CBlobOStream::~CBlobOStream()
  114. {
  115.     delete rdbuf();
  116.     delete m_desc;
  117.     delete m_conn;
  118. }
  119. END_NCBI_SCOPE