libfossdbmanagerclass.cc

Go to the documentation of this file.

/*
 Author: Johannes Najjar, Cedric Bodet, Andreas Wuerl, Daniele Fognini
 SPDX-FileCopyrightText: © 2014 Siemens AG
 
 SPDX-License-Identifier: GPL-2.0-only
*/
 
#include "libfossdbmanagerclass.hpp"
 
extern "C" {
#include "libfossscheduler.h"
#include "libfossagent.h"
}
 
using namespace fo;
 
static fo_dbManager* doConnect(int* argc, char** argv) {
  fo_dbManager* _dbManager;
  fo_scheduler_connect_dbMan(argc, argv, &_dbManager);
  return _dbManager;
}
 
static inline unptr::shared_ptr<fo_dbManager> makeShared(fo_dbManager * p)
{
  return unptr::shared_ptr<fo_dbManager>(p, DbManagerStructDeleter());
}
 
DbManager::DbManager(int* argc, char** argv) :
  dbManager(makeShared(doConnect(argc, argv)))
{
}
 
DbManager::DbManager(fo_dbManager* _dbManager) :
  dbManager(makeShared(_dbManager))
{
}
 
PGconn* DbManager::getConnection() const
{
  return fo_dbManager_getWrappedConnection(getStruct_dbManager());
}
 
DbManager DbManager::spawn() const
{
  return DbManager(fo_dbManager_fork(getStruct_dbManager()));
}
 
fo_dbManager* DbManager::getStruct_dbManager() const
{
  return dbManager.get();
}
 
bool DbManager::tableExists(const char* tableName) const
{
  return fo_dbManager_tableExists(getStruct_dbManager(), tableName) != 0;
}
 
bool DbManager::sequenceExists(const char* name) const
{
  return fo_dbManager_exists(getStruct_dbManager(), "sequence", name) != 0;
}
 
bool DbManager::begin() const
{
  return fo_dbManager_begin(getStruct_dbManager()) != 0;
}
 
bool DbManager::commit() const
{
  return fo_dbManager_commit(getStruct_dbManager()) != 0;
}
 
bool DbManager::rollback() const
{
  return fo_dbManager_rollback(getStruct_dbManager()) != 0;
}
 
QueryResult DbManager::queryPrintf(const char* queryFormat, ...) const
{
  va_list args;
  va_start(args, queryFormat);
  char* queryString = g_strdup_vprintf(queryFormat, args);
  va_end(args);
 
  QueryResult result(fo_dbManager_Exec_printf(getStruct_dbManager(), queryString));
 
  g_free(queryString);
  return result;
}
 
QueryResult DbManager::execPrepared(fo_dbManager_PreparedStatement* stmt, ...) const
{
  va_list args;
  va_start(args, stmt);
  PGresult* pgResult = fo_dbManager_ExecPreparedv(stmt, args);
  va_end(args);
 
  return QueryResult(pgResult);
}
 
void DbManager::ignoreWarnings(bool b) const
{
  fo_dbManager_ignoreWarnings(getStruct_dbManager(), b);
}