mysql_lang.cpp

ncbi源码

/*
 * ===========================================================================
 * PRODUCTION $Log: mysql_lang.cpp,v $
 * PRODUCTION Revision 1000.2  2004/06/01 19:21:35  gouriano
 * PRODUCTION PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R1.8
 * PRODUCTION
 * ===========================================================================
 */

/* $Id: mysql_lang.cpp,v 1000.2 2004/06/01 19:21:35 gouriano Exp $
 * ===========================================================================
 *
 *                            PUBLIC DOMAIN NOTICE
 *               National Center for Biotechnology Information
 *
 *  This software/database is a "United States Government Work" under the
 *  terms of the United States Copyright Act.  It was written as part of
 *  the author's official duties as a United States Government employee and
 *  thus cannot be copyrighted.  This software/database is freely available
 *  to the public for use. The National Library of Medicine and the U.S.
 *  Government have not placed any restriction on its use or reproduction.
 *
 *  Although all reasonable efforts have been taken to ensure the accuracy
 *  and reliability of the software and data, the NLM and the U.S.
 *  Government do not and cannot warrant the performance or results that
 *  may be obtained by using this software or data. The NLM and the U.S.
 *  Government disclaim all warranties, express or implied, including
 *  warranties of performance, merchantability or fitness for any particular
 *  purpose.
 *
 *  Please cite the author in any work or product based on this material.
 *
 * ===========================================================================
 *
 * Author:  Anton Butanayev
 *
 * This simple program illustrates how to use the language command
 *
 */

#include <ncbi_pch.hpp>
#include <dbapi/driver/exception.hpp>
#include <dbapi/driver/mysql/interfaces.hpp>

#include <memory>

USING_NCBI_SCOPE;

int main(int argc, char **argv)
{
  if(argc != 5)
  {
    cerr << "Usage: " << argv[0] << " host database user_name passwd" << endl;
    return 1;
  }

  try
  {
    CMySQLContext my_context;
    auto_ptr<CDB_Connection> con(my_context.Connect(argv[1], argv[3], argv[4], 0));

    // changing database
    {
      auto_ptr<CDB_LangCmd>
        lcmd(con->LangCmd(string("use ") + argv[2]));
      lcmd->Send();
      cout << "Database changed" << endl;
    }

    // creating table
    {
      auto_ptr<CDB_LangCmd>
        lcmd(con->LangCmd(
                          "create temporary table tmp_t1("
                          "a int,"
                          "b datetime,"
                          "c varchar(100),"
                          "d text,"
                          "e double,"
                          "bl BLOB)"
                         ));
      lcmd->Send();
      cout << "Table created" << endl;
    }

    int nBlobSize = 0xffff;
    auto_ptr<char> buff( new char[nBlobSize]);
    
    // inserting data
    {
      char* p = buff.get();
      for( int i = 0; i < nBlobSize; i++)
        *(p++) = i;

      auto_ptr<CDB_LangCmd>
        lcmd(con->LangCmd(
                          "insert into tmp_t1 values"
                          "(1, '2002-11-25 12:45:59', 'Hello, world', 'SOME TEXT', 3.1415, '"
                         ));
      lcmd->More( reinterpret_cast<CMySQL_LangCmd*>(lcmd.get())->EscapeString( buff.get(), nBlobSize));
      lcmd->More( "')");
      lcmd->Send();
      cout << "Data inserted " << lcmd->RowCount() << " row(s) affected" << endl;
    }

    // selecting data
    {
      auto_ptr<CDB_LangCmd> lcmd(con->LangCmd("select * from tmp_t1"));
      lcmd->Send();
      while (lcmd->HasMoreResults())
      {
        auto_ptr<CDB_Result> r(lcmd->Result());
        while (r->Fetch())
        {
          CDB_Int a;
          CDB_DateTime b;
          CDB_VarChar c;
          CDB_VarChar d;
          CDB_Double e;
          CDB_Image blob;

          r->GetItem(&a);
          r->GetItem(&b);
          r->GetItem(&c);
          r->GetItem(&d);
          r->GetItem(&e);
          r->GetItem(&blob);

	  auto_ptr<char> buff2( new char[blob.Size()]);
	  blob.Read( buff2.get(), blob.Size());
          int correct = memcmp( buff2.get(), buff.get(), nBlobSize);
          
          cout
            << "a=" << a.Value() << endl
            << "b=" << b.Value().AsString() << endl
            << "c=" << c.Value() << endl
            << "d=" << d.Value() << endl
            << "e=" << e.Value() << endl
            << "blob size is " << nBlobSize << " blob data is " << (!correct ? "correct" : "not correct") << endl;
        }
      }
    }

    // selecting data as strings
    {
      auto_ptr<CDB_LangCmd> lcmd(con->LangCmd("select * from tmp_t1"));
      lcmd->Send();
      while (lcmd->HasMoreResults())
      {
        auto_ptr<CDB_Result> r(lcmd->Result());
        for(unsigned i = 0; i < r->NofItems(); ++i)
          cout << "[" << r->ItemName(i) << "]";
        cout << endl;

        while (r->Fetch())
        {
          for(unsigned i = 0; i < r->NofItems(); ++i)
          {
            CDB_VarChar field;
            r->GetItem(&field);
            if(! field.IsNULL())
              cout << field.Value() << endl;
            else
              cout << "NULL\n";

          }
        }
      }
    }
  }
  catch (CDB_Exception& e)
  {
    CDB_UserHandler_Stream myExHandler(&cerr);
    myExHandler.HandleIt(&e);
    return 1;
  }
  return 0;
}

/*
 * ===========================================================================
 * $Log: mysql_lang.cpp,v $
 * Revision 1000.2  2004/06/01 19:21:35  gouriano
 * PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R1.8
 *
 * Revision 1.8  2004/05/17 21:15:48  gorelenk
 * Added include of PCH ncbi_pch.hpp
 *
 * Revision 1.7  2004/03/24 19:45:16  vysokolo
 * Added blob support
 *
 * Revision 1.6  2003/05/29 21:25:47  butanaev
 * Added function to return last insert id, fixed RowCount, Send,
 * added call to RowCount in sample app.
 *
 * Revision 1.5  2003/02/19 16:16:13  ucko
 * +<memory> for auto_ptr<>
 *
 * Revision 1.4  2002/08/29 15:41:44  butanaev
 * Command line interface improved.
 *
 * Revision 1.3  2002/08/28 17:18:20  butanaev
 * Improved error handling, demo app.
 *
 * Revision 1.2  2002/08/13 20:30:24  butanaev
 * Username/password changed.
 *
 * Revision 1.1  2002/08/13 20:23:14  butanaev
 * The beginning.
 *
 * ===========================================================================
 */