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

生物技术

开发平台:

C/C++

  1. /*
  2.  * ===========================================================================
  3.  * PRODUCTION $Log: ds_impl.cpp,v $
  4.  * PRODUCTION Revision 1000.2  2004/06/01 19:18:36  gouriano
  5.  * PRODUCTION PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R1.13
  6.  * PRODUCTION
  7.  * ===========================================================================
  8.  */
  9. /* $Id: ds_impl.cpp,v 1000.2 2004/06/01 19:18:36 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. * Author:  Michael Kholodov
  35. *   
  36. * File Description:
  37. *   DataSource implementation
  38. *
  39. */
  40. #include <ncbi_pch.hpp>
  41. #include "ds_impl.hpp"
  42. #include "conn_impl.hpp"
  43. #include "err_handler.hpp"
  44. BEGIN_NCBI_SCOPE
  45. CDataSource::CDataSource(I_DriverContext *ctx)
  46.     : m_loginTimeout(30), m_context(ctx), m_poolUsed(false),
  47.       m_multiExH(0)
  48. {
  49.     SetIdent("CDataSource");
  50. }
  51. CDataSource::~CDataSource()
  52. {
  53.     _TRACE("Deleting " << GetIdent() << " " << (void*)this); 
  54.     Notify(CDbapiDeletedEvent(this));
  55.     delete m_context;
  56.     delete m_multiExH;
  57.     _TRACE(GetIdent() << " " << (void*)this << " deleted."); 
  58. }
  59. void CDataSource::SetLoginTimeout(unsigned int i) 
  60. {
  61.     m_loginTimeout = i;
  62.     if( m_context != 0 ) {
  63.         m_context->SetLoginTimeout(i);
  64.     }
  65. }
  66. void CDataSource::SetLogStream(CNcbiOstream* out) 
  67. {
  68.     if( out != 0 ) {
  69.         // Clear the previous handlers if present
  70.         if( m_multiExH != 0 ) {
  71.             m_context->PopCntxMsgHandler(m_multiExH);
  72.             m_context->PopDefConnMsgHandler(m_multiExH);
  73.             delete m_multiExH;
  74.             m_multiExH = 0;
  75.         }
  76.             
  77.         CDB_UserHandler *newH = new CDB_UserHandler_Stream(out);
  78.         CDB_UserHandler *h = CDB_UserHandler::SetDefault(newH);
  79.         delete h;
  80.     }
  81.     else {
  82.         if( m_multiExH == 0 ) {
  83.             m_multiExH = new CToMultiExHandler;
  84.             m_context->PushCntxMsgHandler(m_multiExH);
  85.             m_context->PushDefConnMsgHandler(m_multiExH);
  86.         }
  87.     }
  88. }
  89. CToMultiExHandler* CDataSource::GetHandler()
  90. {
  91.     return m_multiExH;
  92. }
  93.     
  94. CDB_MultiEx* CDataSource::GetErrorAsEx()
  95. {
  96.     return GetHandler() == 0 ? 0 : GetHandler()->GetMultiEx();
  97. }
  98. string CDataSource::GetErrorInfo()
  99. {
  100.     if( GetHandler() != 0 ) {
  101.         CNcbiOstrstream out;
  102.         CDB_UserHandler_Stream h(&out);
  103.         h.HandleIt(GetHandler()->GetMultiEx());
  104.         return CNcbiOstrstreamToString(out);
  105.     }
  106.     else
  107.         return kEmptyStr;
  108. }
  109. I_DriverContext* CDataSource::GetDriverContext() {
  110.     if( m_context == 0 )
  111.       throw CDbapiException("CDataSource::GetDriverContext(): no valid context");
  112.     return m_context;
  113.   }
  114. IConnection* CDataSource::CreateConnection()
  115. {
  116.     CConnection *conn = new CConnection(this);
  117.     AddListener(conn);
  118.     conn->AddListener(this);
  119.     return conn;
  120. }
  121. void CDataSource::Action(const CDbapiEvent& e) 
  122. {
  123.     _TRACE(GetIdent() << " " << (void*)this << ": '" << e.GetName() 
  124.            << "' from " << e.GetSource()->GetIdent());
  125.     if( dynamic_cast<const CDbapiDeletedEvent*>(&e) != 0 ) {
  126.         RemoveListener(e.GetSource());
  127.     }
  128. }
  129. END_NCBI_SCOPE
  130. /*
  131.  * ===========================================================================
  132.  * $Log: ds_impl.cpp,v $
  133.  * Revision 1000.2  2004/06/01 19:18:36  gouriano
  134.  * PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R1.13
  135.  *
  136.  * Revision 1.13  2004/05/17 21:10:28  gorelenk
  137.  * Added include of PCH ncbi_pch.hpp
  138.  *
  139.  * Revision 1.12  2003/11/04 21:36:02  vakatov
  140.  * Minor style fixes
  141.  *
  142.  * Revision 1.11  2002/11/27 17:09:52  kholodov
  143.  * Fixed: Resolved version conflict.
  144.  *
  145.  * Revision 1.10  2002/11/27 16:59:38  ucko
  146.  * Drop definitions of CToMultiExHandler methods now found in err_handler.cpp.
  147.  *
  148.  * Revision 1.9  2002/10/03 18:50:00  kholodov
  149.  * Added: additional TRACE diagnostics about object deletion
  150.  * Fixed: setting parameters in IStatement object is fully supported
  151.  * Added: IStatement::ExecuteLast() to execute the last statement with
  152.  * different parameters if any
  153.  *
  154.  * Revision 1.8  2002/09/30 19:16:27  kholodov
  155.  * Added: public GetHandler() method
  156.  *
  157.  * Revision 1.7  2002/09/23 18:35:24  kholodov
  158.  * Added: GetErrorInfo() and GetErrorAsEx() methods.
  159.  *
  160.  * Revision 1.6  2002/09/18 18:49:27  kholodov
  161.  * Modified: class declaration and Action method to reflect
  162.  * direct inheritance of CActiveObject from IEventListener
  163.  *
  164.  * Revision 1.5  2002/09/09 20:48:57  kholodov
  165.  * Added: Additional trace output about object life cycle
  166.  * Added: CStatement::Failed() method to check command status
  167.  *
  168.  * Revision 1.4  2002/04/15 19:11:42  kholodov
  169.  * Changed GetContext() -> GetDriverContext
  170.  *
  171.  * Revision 1.3  2002/02/08 17:38:26  kholodov
  172.  * Moved listener registration to parent objects
  173.  *
  174.  * Revision 1.2  2002/02/06 22:21:57  kholodov
  175.  * Reformatted the source code
  176.  *
  177.  * Revision 1.1  2002/01/30 14:51:21  kholodov
  178.  * User DBAPI implementation, first commit
  179.  * ===========================================================================
  180.  */