PostgreSQLInterface.h

#ifndef _Belle2_PostgreSQLInterface_hh
#define _Belle2_PostgreSQLInterface_hh
 
#include "daq/slc/database/DBInterface.h"
#include "daq/slc/system/Mutex.h"
 
typedef struct pg_conn PGconn;
typedef struct pg_result PGresult;
 
namespace Belle2 {
  class PostgreSQLInterface : public DBInterface {
 
  public:
    PostgreSQLInterface(const std::string& host,
                        const std::string& database,
                        const std::string& user,
                        const std::string& password,
                        int port);
    PostgreSQLInterface();
    virtual ~PostgreSQLInterface() {}
 
  public:
    virtual void connect();
    virtual bool isConnected();
    virtual void execute_imp(const char* command);
    virtual void close();
    virtual void clear();
    virtual DBRecordList loadRecords();
    virtual bool checkTable(const std::string& tablename);
    virtual DBFieldTypeList getTableContents(const std::string& tablename);
 
  private:
    PGconn* m_sq_conn;
    PGresult* m_sq_result;
    Mutex m_mutex;
 
  };
 
}
 
#endif