DbDriverMySqlHelper.hpp

gehe zur Dokumentation dieser Datei

#ifndef BOERN_PSFA_MYSQL_HELPER_HPP
#define BOERN_PSFA_MYSQL_HELPER_HPP
// Copyright (C) 2004 Bernhard Assmann <bernie@tuxomania.net>
//  
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation; either version 2 of the License, or
// (at your option) any later version.
//  
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.
//  
// You should have received a copy of the GNU General Public License
// along with this program; if not, write to the Free Software
// Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
//  

#include <string>
#include <iostream>
#include <iosfwd>
#include <mysqlcppapi/mysqlcppapi.h>


namespace psfa 
{

  class DbDriverMySqlHelper 
  {
  public:

    bool
    connect();

    bool
    disconnect();  

    mysqlcppapi::Result_NoData
    executeSql( const std::ostringstream& sql );

    void
    queryDb( const std::ostringstream& sql,
        mysqlcppapi::Result_Store& store );
    
    int
    getNextId( const std::string table, const std::string idField );
  
    const std::string
    getSingleValueString( const std::ostringstream& sql );

    int
    calculateFilePosition( int line, int column, int fileId );
    
    int
    getSingleValueInt( const std::ostringstream& sql );
  
    template< class T >
    void
    getValueVector( const std::ostringstream& sql, T& vec )
    {
      try {
   mysqlcppapi::Query query = con_.create_Query();
   query << sql.str();
   mysqlcppapi::Result_Store res = query.store();
   if( res.size() != 0 ) {
     vec.reserve( res.size() );
     mysqlcppapi::Result_Store::iterator i;
     mysqlcppapi::Result_Store::iterator iEnd = res.end();
     for ( i = res.begin(); i != iEnd; ++i) {
       mysqlcppapi::Row row = *i;
       vec.push_back( row[0] );
     }
   }
      }
      catch(mysqlcppapi::ex_BadQuery& er) {
   return;
      }
      catch(mysqlcppapi::ex_BadConversion& er) {
   return;
      }
      return;
    }

    template< class T >
    void
    getValueStream( const std::ostringstream& sql,
          T& outStream,
          const std::string delim )
    {
      try {
   mysqlcppapi::Query query = con_.create_Query();
   query << sql.str();
   mysqlcppapi::Result_Store res = query.store();
   if( res.size() != 0 ) {
     mysqlcppapi::Result_Store::iterator i    = res.begin();
     mysqlcppapi::Result_Store::iterator iEnd = res.end();
     for ( ; i != iEnd; ++i) {
       mysqlcppapi::Row row = *i;
       if( (i + 1) == iEnd ) {
         outStream << row[0];
         continue;
       }
       outStream << row[0] << delim;
     }
   }
      }
      catch(mysqlcppapi::ex_BadQuery& er) {
   return;
      }
      catch(mysqlcppapi::ex_BadConversion& er) {
   return;
      }
      return;
    }
    
  private:

    mysqlcppapi::Connection con_; 
    static int fileId_;    
    static int overhead_;     
    static std::vector< int > lengths_; 
  };
}
#endif

---