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

生物技术

开发平台:

C/C++

  1. /*
  2.  * ===========================================================================
  3.  * PRODUCTION $Log: lang_cmd.cpp,v $
  4.  * PRODUCTION Revision 1000.2  2004/06/01 19:21:29  gouriano
  5.  * PRODUCTION PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R1.9
  6.  * PRODUCTION
  7.  * ===========================================================================
  8.  */
  9. /* $Id: lang_cmd.cpp,v 1000.2 2004/06/01 19:21:29 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:  Anton Butanayev
  35.  *
  36.  * File Description
  37.  *    Driver for MySQL server
  38.  *
  39.  */
  40. #include <ncbi_pch.hpp>
  41. #include <dbapi/driver/mysql/interfaces.hpp>
  42. BEGIN_NCBI_SCOPE
  43. CMySQL_LangCmd::CMySQL_LangCmd(CMySQL_Connection* conn,
  44.                                const string&      lang_query,
  45.                                unsigned int       /*nof_params*/)
  46.     : m_Connect(conn),
  47.       m_Query(lang_query),
  48.       m_HasResults(false)
  49. {
  50. }
  51. CMySQL_LangCmd::~CMySQL_LangCmd()
  52. {
  53. }
  54. bool CMySQL_LangCmd::More(const string& query_text)
  55. {
  56.     m_Query += query_text;
  57.     return true;
  58. }
  59. bool CMySQL_LangCmd::BindParam(const string& /*param_name*/,
  60.                                CDB_Object*   /*param_ptr*/)
  61. {
  62.     return false;
  63. }
  64. bool CMySQL_LangCmd::SetParam(const string& /*param_name*/,
  65.                               CDB_Object*   /*param_ptr*/)
  66. {
  67.     return false;
  68. }
  69. bool CMySQL_LangCmd::Send()
  70. {
  71.     if (mysql_real_query
  72.         (&m_Connect->m_MySQL, m_Query.c_str(), m_Query.length()) != 0) {
  73.         throw CDB_ClientEx(eDB_Warning, 800003,
  74.                            "CMySQL_LangCmd::Send",
  75.                            "Failed: mysql_real_query");
  76.     }
  77.     
  78.     int nof_Rows = mysql_affected_rows(&this->m_Connect->m_MySQL);
  79.     m_HasResults = nof_Rows == -1 || nof_Rows > 0;
  80.     return true;
  81. }
  82. bool CMySQL_LangCmd::WasSent() const
  83. {
  84.     return false;
  85. }
  86. bool CMySQL_LangCmd::Cancel()
  87. {
  88.     return false;
  89. }
  90. bool CMySQL_LangCmd::WasCanceled() const
  91. {
  92.     return false;
  93. }
  94. CDB_Result *CMySQL_LangCmd::Result()
  95. {
  96.     m_HasResults = false;
  97.     return Create_Result(*new CMySQL_RowResult(m_Connect));
  98. }
  99. bool CMySQL_LangCmd::HasMoreResults() const
  100. {
  101.     return m_HasResults;
  102. }
  103. void CMySQL_LangCmd::DumpResults()
  104. {
  105.     CDB_Result* dbres;
  106.     while(m_HasResults) {
  107.         dbres= Result();
  108.         if(dbres) {
  109.             if(m_Connect->m_ResProc) {
  110.                 m_Connect->m_ResProc->ProcessResult(*dbres);
  111.             }
  112.             else {
  113.                 while(dbres->Fetch());
  114.             }
  115.             delete dbres;
  116.         }
  117.     }
  118. }
  119. bool CMySQL_LangCmd::HasFailed() const
  120. {
  121.     if(mysql_errno(&m_Connect->m_MySQL) == 0) 
  122.       return false;
  123.     return true;
  124. }
  125. void CMySQL_LangCmd::Release()
  126. {
  127. }
  128. int CMySQL_LangCmd::LastInsertId() const
  129. {
  130.   return mysql_insert_id(&this->m_Connect->m_MySQL);
  131. }
  132. int CMySQL_LangCmd::RowCount() const
  133. {
  134.   return mysql_affected_rows(&this->m_Connect->m_MySQL);
  135. }
  136. string CMySQL_LangCmd::EscapeString(const char* str, unsigned long len)
  137. {
  138.     std::auto_ptr<char> buff( new char[len*2 + 1]);
  139.     mysql_real_escape_string(&this->m_Connect->m_MySQL, buff.get(), str, len);
  140.     return buff.get();
  141. }
  142. END_NCBI_SCOPE
  143. /*
  144.  * ===========================================================================
  145.  * $Log: lang_cmd.cpp,v $
  146.  * Revision 1000.2  2004/06/01 19:21:29  gouriano
  147.  * PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R1.9
  148.  *
  149.  * Revision 1.9  2004/05/17 21:15:34  gorelenk
  150.  * Added include of PCH ncbi_pch.hpp
  151.  *
  152.  * Revision 1.8  2004/03/24 19:46:53  vysokolo
  153.  * addaed support of blob
  154.  *
  155.  * Revision 1.7  2003/06/06 16:02:53  butanaev
  156.  * Fixed return value of Send - it should return true.
  157.  *
  158.  * Revision 1.6  2003/06/05 16:02:48  soussov
  159.  * adds code for DumpResults and for the dumped results processing
  160.  *
  161.  * Revision 1.5  2003/05/29 21:42:25  butanaev
  162.  * Fixed Send, HasFailed functions.
  163.  *
  164.  * Revision 1.4  2003/05/29 21:25:47  butanaev
  165.  * Added function to return last insert id, fixed RowCount, Send,
  166.  * added call to RowCount in sample app.
  167.  *
  168.  * Revision 1.3  2003/01/06 20:30:26  vakatov
  169.  * Get rid of some redundant header(s).
  170.  * Formally reformatted to closer meet C++ Toolkit/DBAPI style.
  171.  *
  172.  * Revision 1.2  2002/08/28 17:18:20  butanaev
  173.  * Improved error handling, demo app.
  174.  *
  175.  * Revision 1.1  2002/08/13 20:23:14  butanaev
  176.  * The beginning.
  177.  *
  178.  * ===========================================================================
  179.  */