/home/bes3soft/bes3soft/Boss/7.0.2/dist/7.0.2/Calibration/rdbModel/rdbModel-00-01-01/rdbModel/Db/MysqlConnection.h

Go to the documentation of this file.

// $Header: /bes/bes/BossCvs/Calibration/rdbModel/rdbModel/Db/MysqlConnection.h,v 1.3 2009/03/18 02:01:02 huangb Exp $
#ifndef RDBMODEL_MYSQLCONNECTION_H
#define RDBMODEL_MYSQLCONNECTION_H

#include "rdbModel/Db/Connection.h"
#include "rdbModel/Tables/Assertion.h"
#include "rdbModel/Management/Visitor.h"
#include <map>
#include <iostream>

typedef struct st_mysql MYSQL;
typedef struct st_mysql_res MYSQL_RES;

namespace rdbModel{

  class MysqlResults;
  class Datatype;
  class MysqlConnection : public virtual Connection, public Visitor {
  public:
    MysqlConnection(std::ostream* out=0, std::ostream* errOut=0);
    virtual ~MysqlConnection();
    virtual bool open(const std::string& host, const std::string& userid,
                      const std::string& password,
                      const std::string& dbName);
                      //                      ,unsigned int       port=0);

     virtual bool open(const std::string& parms);

    virtual bool close();

    virtual bool isConnected() {return m_connected;}

    std::ostream* getOut() const {return m_out;}
    std::ostream* getErrOut() const {return m_err;}
    virtual MATCH matchSchema(Rdb *rdb, bool matchDbName=true);

    virtual bool insertRow(const std::string& tableName, 
                           const StringVector& colNames, 
                           const StringVector& values,
                           int* auto_value=0,
                           const StringVector* nullCols = 0);

    virtual unsigned int update(const std::string& tableName, 
                                const StringVector& colNames, 
                                const StringVector& values,
                                const Assertion* where=0,
                                const StringVector* nullCols = 0);

    virtual ResultHandle* select(const std::string& tableName,
                                 const StringVector& getCols,
                                 const StringVector& orderCols,
                                 const Assertion* where=0,
                                 int   rowLimit=0,
                                 int   rowOffset=0);

    virtual ResultHandle* dbRequest(const std::string& request);


    virtual bool 
    compileAssertion(const Assertion* a, std::string& sqlString) const;

    virtual void disableModify(bool disable) {m_writeDisabled=disable;}

    // Needed to satisfy Visitor interface:
    virtual Visitor::VisitorState visitRdb(Rdb*);
    virtual Visitor::VisitorState visitTable(Table*);
    virtual Visitor::VisitorState visitColumn(Column*);
    virtual Visitor::VisitorState visitIndex(Index*);
    virtual Visitor::VisitorState visitAssertion(Assertion*);

    virtual VisitorState visitInsertNew(InsertNew*);
    virtual VisitorState visitSupersede(Supersede*);
    virtual VisitorState visitQuery(Query*);
    virtual VisitorState visitSet(Set*);
    virtual VisitorState visitInterRow(InterRow*);
      



  private:
    enum VISITOR {
      VISITORundefined,
      VISITORmatch
    };

    MYSQL* m_mysql;
    bool   m_connected;

    std::string m_dbName;
    std::ostream* m_out;
    std::ostream* m_err;

    // Following collection of data members is only of interest while 
    // visit is in progress.

    VISITOR m_visitorType;
    bool    m_matchDbName;

    MATCH   m_matchReturn;

    Rdb*   m_rdb;

    std::vector<Column* >  m_ourCols;

    MYSQL_RES* m_tempRes;

    std::map<std::string, unsigned int> m_colIx;

    std::string m_primColName;

    static bool   m_compileInit;
    bool          m_writeDisabled;

    static void compileInit();
    static bool compileComparison(Assertion::Operator* op, 
                                  std::string& sqlString);
    static bool compileOperator(Assertion::Operator* op, 
                                std::string &sqlString);

    bool checkDType(Datatype* dtype, const std::string& sqlType);

   //huangb add to store the database information
    std::string m_host;
    std::string m_user;
    std::string m_password; 
//    std::string m_dbName;
 };

}  // end namespace rdbModel
#endif

---