MySQLDBConnection.h

Go to the documentation of this file.

#ifndef CARMA_DBMS_MYSQLDBCONNECTION_H
#define CARMA_DBMS_MYSQLDBCONNECTION_H

#include <iostream>
// putting #include "mysql/mysql.h" before #include "carma/dbms/DBConnection.h"
// causes build failures when using mysql 4.1, but not when using 4.0
#include "mysql/mysql_version.h"
#include "carma/dbms/DBConnection.h"
#include "mysql/mysql.h"

namespace carma {
namespace dbms {

class MySQLDBConnection : public DBConnection {

public:

    static const std::string DBUSER;
    static const std::string RDBMS;
    static const std::string ODBC_DATASRC;
    static const std::string TEST_ODBC_DATASRC;

    MySQLDBConnection(const DBConfigurator *dbconf);

    //~MySQLDBConnection();


    void loadDataFromFile
        (const std::string& filename, const std::string& table,
         const bool& useTransactions, const int& linesToIgnore=0,
         const std::string& columnDelimiter="\t") const;


    void loadDataFromFiles
        (const file2TableMap& file2Table, const bool& useTransactions,
        const int& linesToIgnore=0, const std::string& columnDelimiter="\t") 
        const;

    void beginTransaction() const;

    virtual void rollBackTransaction() const;

    virtual void commitTransaction() const;

    virtual bool inTransaction() const;

    virtual std::string createMonitorDataTable(
                                    const MonitorAverageType& averageType,
                                    const MonitorAggregateType& aggType,
                                    const std::string& tag, 
                                    const std::string *const location) const;

    virtual void monitorDataTableHasBeenPopulated(const std::string& tableName,
                                  const MonitorAverageType& averageType) 
        const;

    virtual unsigned maxTablesPerJoin() const;

    virtual unsigned maxColumnsPerTable() const;

    std::string virtual caseSensitiveSearchModifier() const { 
        return "BINARY "; 
    }

    virtual void repairMonitorDataTable(const std::string& tableName) const;



private:
    // MYSQL *sock_, mysql_;
};


}}
#endif // CARMA_DBMS_MYSQLDBCONNECTION_H