Inheritance diagram for PostgreSQLInterface:

Public Member Functions
	PostgreSQLInterface (const std::string &host, const std::string &database, const std::string &user, const std::string &password, int port)

void	connect () override

bool	isConnected () override

void	execute_imp (const char *command) override

void	close () override

void	clear () override

DBRecordList	loadRecords () override

bool	checkTable (const std::string &tablename) override

DBFieldTypeList	getTableContents (const std::string &tablename) override

void	execute (const char *command,...)

void	execute (const std::string &command)

void	clearRecords ()

DBRecordList &	getRecords ()

const std::string &	getHostName () const

const std::string &	getDatabase () const

const std::string &	getUserName () const

const std::string &	getPassword () const

int	getPort () const

Protected Member Functions
void	init (const std::string &host, const std::string &database, const std::string &user, const std::string &password, int port)

Protected Attributes
DBRecordList	m_record_v

std::string	m_host

std::string	m_database

std::string	m_user

std::string	m_password

int	m_port

Private Attributes
PGconn *	m_sq_conn

PGresult *	m_sq_result

Mutex	m_mutex

char *	m_buf

Static Private Attributes
static const int	m_buf_size = 1024 * 1000

Detailed Description

Definition at line 23 of file PostgreSQLInterface.h.

Constructor & Destructor Documentation

◆ PostgreSQLInterface() [1/2]

PostgreSQLInterface	(	const std::string &	host,
		const std::string &	database,
		const std::string &	user,
		const std::string &	password,
		int	port
	)

Definition at line 22 of file PostgreSQLInterface.cc.

{
  init(host, database, user, password, port);
  m_sq_conn = NULL;
  m_sq_result = NULL;
}

◆ PostgreSQLInterface() [2/2]

PostgreSQLInterface ( )

Definition at line 33 of file PostgreSQLInterface.cc.

{
  ConfigFile config("slowcontrol");
  init(config.get("database.host"),
       config.get("database.dbname"),
       config.get("database.user"),
       config.get("database.password"),
       config.getInt("database.port"));
  m_sq_conn = NULL;
  m_sq_result = NULL;
}

◆ ~PostgreSQLInterface()

virtual ~PostgreSQLInterface ( )

inlinevirtual

Definition at line 32 of file PostgreSQLInterface.h.

32{}

Member Function Documentation

◆ checkTable()

bool checkTable ( const std::string & tablename )

overridevirtual

Implements DBInterface.

Definition at line 164 of file PostgreSQLInterface.cc.

{
#ifndef NOT_USE_PSQL
  execute("select relname from pg_stat_user_tables where relname='%s';",
          tablename.c_str());
  DBRecordList ret(loadRecords());
  return ret.size() > 0;
#else
  throw (DBHandlerException("libpg is not available"));
#endif
}

◆ clear()

void clear ( )

overridevirtual

Implements DBInterface.

Definition at line 137 of file PostgreSQLInterface.cc.

{
#ifndef NOT_USE_PSQL
  LockGuard lockGuard(m_mutex);
  if (m_sq_result != NULL) {
    PQclear(m_sq_result);
    m_sq_result = NULL;
  }
#else
  throw (DBHandlerException("libpg is not available"));
#endif
}

◆ clearRecords()

void clearRecords ( )

inlineinherited

Definition at line 47 of file DBInterface.h.

47{ m_record_v.resize(0); }

◆ close()

void close ( )

overridevirtual

Implements DBInterface.

Definition at line 150 of file PostgreSQLInterface.cc.

{
  clear();
#ifndef NOT_USE_PSQL
  LockGuard lockGuard(m_mutex);
  if (m_sq_conn != NULL) {
    PQfinish(m_sq_conn);
    m_sq_conn = NULL;
  }
#else
  throw (DBHandlerException("libpg is not available"));
#endif
}

◆ connect()

void connect ( )

overridevirtual

Implements DBInterface.

Definition at line 45 of file PostgreSQLInterface.cc.

{
#ifndef NOT_USE_PSQL
  if (isConnected()) return;
 
  {
    LockGuard lockGuard(m_mutex);
    m_sq_conn = PQconnectdb(StringUtil::form("host=%s dbname=%s user=%s password=%s port=%d",
                                             m_host.c_str(), m_database.c_str(),
                                             m_user.c_str(), m_password.c_str(),
                                             m_port).c_str());
  }
 
  if (PQstatus(m_sq_conn) == CONNECTION_BAD) {
    DBHandlerException exception("Failed to connect to the database : %s",
                                 PQerrorMessage(m_sq_conn));
    close();
    throw exception;
  }
#else
  throw (DBHandlerException("PGLIB is not available"));
#endif
}

◆ execute() [1/2]

void execute	(	const char *	command,
			...
	)

inherited

Definition at line 45 of file DBInterface.cc.

{
  StringList s;
 
  {
    LockGuard lockGuard(m_mutex);
 
    va_list ap;
    va_start(ap, text);
    vsnprintf(m_buf, m_buf_size, text, ap);
    va_end(ap);
    //std::cout << m_buf << std::endl;
    //execute_imp(m_buf);
    s = StringUtil::split(m_buf, ';');
  }
 
  for (size_t i = 0; i < s.size(); i++)
    execute_imp(s[i].c_str());
}

◆ execute() [2/2]

void execute ( const std::string & command )

inherited

Definition at line 65 of file DBInterface.cc.

{
  //std::cout << text << std::endl;
  StringList s = StringUtil::split(text, ';');
  for (size_t i = 0; i < s.size(); i++)
    execute_imp(s[i].c_str());
}

◆ execute_imp()

void execute_imp ( const char * command )

overridevirtual

Implements DBInterface.

Definition at line 80 of file PostgreSQLInterface.cc.

{
  clear();
#ifndef NOT_USE_PSQL
  LockGuard lockGuard(m_mutex);
  m_sq_result = PQexec(m_sq_conn, command);
  ExecStatusType status = PQresultStatus(m_sq_result);
  if (status == PGRES_FATAL_ERROR) {
    // Need to pre-generate exception to avoid data race
    // on PQerrorMessage.
    DBHandlerException exception("Failed to execute command : %s (%s)",
                                 command, PQerrorMessage(m_sq_conn));
    throw (exception);
  }
#else
  throw (DBHandlerException("libpg is not available"));
#endif
}

◆ getDatabase()

const std::string & getDatabase ( ) const

inlineinherited

Definition at line 50 of file DBInterface.h.

50{ return m_database; }

◆ getHostName()

const std::string & getHostName ( ) const

inlineinherited

Definition at line 49 of file DBInterface.h.

49{ return m_host; }

◆ getPassword()

const std::string & getPassword ( ) const

inlineinherited

Definition at line 52 of file DBInterface.h.

52{ return m_password; }

◆ getPort()

int getPort ( ) const

inlineinherited

Definition at line 53 of file DBInterface.h.

53{ return m_port; }

◆ getRecords()

DBRecordList & getRecords ( )

inlineinherited

Definition at line 48 of file DBInterface.h.

48{ return m_record_v; }

◆ getTableContents()

DBFieldTypeList getTableContents ( const std::string & tablename )

overridevirtual

Implements DBInterface.

Definition at line 176 of file PostgreSQLInterface.cc.

{
#ifndef NOT_USE_PSQL
  DBFieldTypeList name_m;
  execute("select attname, typname from pg_class, pg_attribute, pg_type "
          "where relkind ='r'and relname = '%s' and attrelid = relfilenode "
          "and attnum > 0 and pg_type.oid = atttypid;", tablename.c_str());
  DBRecordList ret(loadRecords());
  for (size_t i = 0; i < ret.size(); i++) {
    name_m.insert(DBFieldTypeList::value_type(ret[i].get("attname"),
                                              ret[i].get("typname")));
  }
  return name_m;
#else
  throw (DBHandlerException("libpg is not available"));
#endif
}

◆ getUserName()

const std::string & getUserName ( ) const

inlineinherited

Definition at line 51 of file DBInterface.h.

51{ return m_user; }

◆ init()

void init	(	const std::string &	host,
		const std::string &	database,
		const std::string &	user,
		const std::string &	password,
		int	port
	)

protectedinherited

Definition at line 32 of file DBInterface.cc.

{
  m_host = host;
  m_database = database;
  m_user = user;
  m_password = password;
  m_port = port;
  m_buf = new char[m_buf_size];
}

◆ isConnected()

bool isConnected ( )

overridevirtual

Implements DBInterface.

Definition at line 69 of file PostgreSQLInterface.cc.

{
#ifndef NOT_USE_PSQL
  LockGuard lockGuard(m_mutex);
  bool connected = m_sq_conn != NULL && PQstatus(m_sq_conn) == CONNECTION_OK;
  return connected;
#else
  return false;
#endif
}

◆ loadRecords()

DBRecordList loadRecords ( )

overridevirtual

Implements DBInterface.

Definition at line 99 of file PostgreSQLInterface.cc.

{
#ifndef NOT_USE_PSQL
  LockGuard lockGuard(m_mutex);
  if (PQresultStatus(m_sq_result) != PGRES_TUPLES_OK) {
    throw (DBHandlerException("DB records are not ready for reading"));
  }
  const size_t nrecords = PQntuples(m_sq_result);
  const size_t nfields = PQnfields(m_sq_result);
  m_record_v = DBRecordList();
  std::vector<std::string> name_v;
  for (size_t ifield = 0; ifield < nfields; ifield++) {
    const char* name = PQfname(m_sq_result, ifield);
    if (name != NULL) name_v.push_back(name);
  }
  for (size_t irecord = 0; irecord < nrecords; irecord++) {
    DBRecord record;
    for (size_t ifield = 0; ifield < nfields; ifield++) {
      if (!PQgetisnull(m_sq_result, irecord, ifield)) {
        const char* value = PQgetvalue(m_sq_result, irecord, ifield);
        if (value != NULL) {
          record.add(name_v[ifield], value);
        }
      }
    }
    m_record_v.push_back(record);
  }
 
  // Vector copy must be done before mutex release,
  // otherwise data race is introduced.
  DBRecordList ret(m_record_v);
 
  return ret;
#else
  throw (DBHandlerException("libpg is not available"));
#endif
}

Member Data Documentation

◆ m_buf

char* m_buf

privateinherited

Definition at line 74 of file DBInterface.h.

◆ m_buf_size

const int m_buf_size = 1024 * 1000

staticprivateinherited

Definition at line 73 of file DBInterface.h.

◆ m_database

std::string m_database

protectedinherited

Definition at line 66 of file DBInterface.h.

◆ m_host

std::string m_host

protectedinherited

Definition at line 65 of file DBInterface.h.

◆ m_mutex

Mutex m_mutex

private

Definition at line 47 of file PostgreSQLInterface.h.

◆ m_password

std::string m_password

protectedinherited

Definition at line 68 of file DBInterface.h.

◆ m_port

int m_port

protectedinherited

Definition at line 69 of file DBInterface.h.

◆ m_record_v

DBRecordList m_record_v

protectedinherited

Definition at line 64 of file DBInterface.h.

◆ m_sq_conn

PGconn* m_sq_conn

private

Definition at line 45 of file PostgreSQLInterface.h.

◆ m_sq_result

PGresult* m_sq_result

private

Definition at line 46 of file PostgreSQLInterface.h.

◆ m_user

std::string m_user

protectedinherited

Definition at line 67 of file DBInterface.h.

The documentation for this class was generated from the following files:

daq/slc/psql/include/PostgreSQLInterface.h
daq/slc/psql/src/PostgreSQLInterface.cc

Public Member Functions

Protected Member Functions

Protected Attributes

Private Attributes

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ PostgreSQLInterface() [1/2]

◆ PostgreSQLInterface() [2/2]

◆ ~PostgreSQLInterface()

Member Function Documentation

◆ checkTable()

◆ clear()

◆ clearRecords()

◆ close()

◆ connect()

◆ execute() [1/2]

◆ execute() [2/2]

◆ execute_imp()

◆ getDatabase()

◆ getHostName()

◆ getPassword()

◆ getPort()

◆ getRecords()

◆ getTableContents()

◆ getUserName()

◆ init()

◆ isConnected()

◆ loadRecords()

Member Data Documentation

◆ m_buf

◆ m_buf_size

◆ m_database

◆ m_host

◆ m_mutex

◆ m_password

◆ m_port

◆ m_record_v

◆ m_sq_conn

◆ m_sq_result

◆ m_user