IOManagerDB.h

#ifndef SCTARCHIVE_IOMANAGERDB_H
#define SCTARCHIVE_IOMANAGERDB_H

#include "Sct/Archive/IOManagerArchive.h"
#include "Sct/IoExceptions.h"
#include "Sct/LogicErrors.h"
#include "SctData/ResultHeader.h"
#include <mysql.h>
#include "CalibrationController/IS/TestData.h"

#include <boost/date_time/posix_time/posix_time.hpp>
//#include "sqlplus.hh"

class Sct::Serializable;
//class MysqlQuery;

namespace SctArchiving {
class MysqlException : public Sct::IoException{
public:
  MysqlException(const string& msg, const string& file, int line);
  MysqlException(const string& msg, const string& query, const string& file, int line);
  ~MysqlException() throw();
private:
  MysqlException();
  std::string query;
};

class ZlibStringCompressor;
class IOManagerDB : public Sct::Archive::IOManagerArchive {
public:
  static IOManagerDB& instance();
  virtual void write(const Sct::Serializable& ob, const Sct::IOParams* params = 0) const;
  virtual shared_ptr<Sct::Serializable> read(const string& name, const Sct::IOParams* params = 0) const;
  virtual ~IOManagerDB();
  virtual std::string status() const;
  virtual void addRun(unsigned long runNumber, bool trash) const;

  virtual void addTest(const TestData& testdata, bool alsoAddScans) const;

  virtual void addScan(const TestData& testdata, unsigned scanNumber) const;

  virtual void addModule(const std::string& layerName,
                         const std::string& LMTnr,
                         const std::string& poistionNumber,
                         const std::string& moduleNumber) const;

  virtual void addRawDataRecord(const std::string& moduleId, const std::string& scanId) const;

  virtual void addRawDataBlob(const std::string& moduleId, const std::string& scanId,
                              const char *chBuf, const long bufSize) const;

  virtual std::string getRawDataBlob(const std::string& moduleId,
                                     const std::string& scanId) const;

  virtual std::string getDataSetName() const;

  virtual void setDataSetName(const std::string& dataSetName);

  static std::string convertToMysqlDateTimeFormat(const std::string& isotime);

  std::string getDataSetID() const;
  std::string getTestTypeID(const std::string& testName) const;
  std::string getRunID(const unsigned runNumber) const;
  std::string getTestID(const std::string& runId, const unsigned startScanNumber) const;
  std::string getScanID(const std::string& testId, const unsigned scanNumber) const;
  std::string getLayerID(const std::string& layerName) const;
  std::string getRowID(const std::string& layerId, const std::string& LMTnr) const;
  std::string getPositionID(const std::string& rowId, const std::string& positionNumber) const;
  std::string getModuleID(const std::string& moduleNumber) const;
 private:
  void checkForMySqlErrors(const string& msg, const string& file, int line) const;

  void checkForMySqlErrors(const string& msg, const string& query, const string& file, int line) const;

  IOManagerDB();  
  //MysqlQuery getQuery() const; ///< get a null query.
  static IOManagerDB* s_man; 

  boost::shared_ptr<ZlibStringCompressor> m_compressor;
  //AJB ONLY FOR MYSQL++ boost::shared_ptr<Connection> m_connection; ///< pointer to the database connection

  MYSQL* m_mysql; 
  
  static const SctData::ResultHeader& getHeader( const Sct::Serializable& ob);
  //void prepareInsertion(const Sct::Serializable& ob, MysqlQuery& q) const;
  //static std::string getQueryMatching(const string& name);
  static std::string getTable(const Sct::Serializable& ob);
  std::string m_dataSetName;
  boost::shared_ptr<MYSQL_RES> getResult() const;

  mutable boost::recursive_mutex timingAccess;
  
  mutable unsigned m_nRead; 
  mutable unsigned m_nWrite; 
  mutable unsigned m_nCompress; 
  mutable unsigned m_nDecompress; 
  mutable unsigned m_nBlobAdd; 
  mutable unsigned m_nQueries; 

  mutable boost::posix_time::time_duration read_time; 
  mutable boost::posix_time::time_duration write_time; 
  mutable boost::posix_time::time_duration compress_time; 
  mutable boost::posix_time::time_duration decompress_time; 
  mutable boost::posix_time::time_duration blob_add_time; 
  mutable boost::posix_time::time_duration query_time; 
  mutable boost::posix_time::time_duration ostream_time; 
  mutable boost::posix_time::time_duration istream_time; 


  class MySqlFreeResultDeleter{
  public:
    void operator() (MYSQL_RES*) throw();
  };  
  std::string executeQueryReturnID(std::string query) const;
  void executeQuery(std::string query) const;
};
}
#endif

---