libfossdbmanager.h

/*
Author: Daniele Fognini
Copyright (C) 2014-2015, Siemens AG

This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
version 2 as published by the Free Software Foundation.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License along
with this program; if not, write to the Free Software Foundation, Inc.,
51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
*/

#ifndef LIBFOSSDBMANAGER_H
#define LIBFOSSDBMANAGER_H

#include <libpq-fe.h>
#include <stdarg.h>
#include <glib.h>

typedef struct fo_dbmanager_preparedstatement fo_dbManager_PreparedStatement;
typedef struct fo_dbmanager fo_dbManager;

fo_dbManager* fo_dbManager_new(PGconn* dbConnection);
fo_dbManager* fo_dbManager_new_withConf(PGconn* dbConnection, const char* dbConf);
PGconn* fo_dbManager_getWrappedConnection(fo_dbManager* dbManager);
fo_dbManager* fo_dbManager_fork(fo_dbManager* dbManager);
void fo_dbManager_free(fo_dbManager* dbManager);
void fo_dbManager_finish(fo_dbManager* dbManager);
int fo_dbManager_setLogFile(fo_dbManager* dbManager, const char* logFileName);
void fo_dbManager_ignoreWarnings(fo_dbManager* dbManager, int ignoreWarns);
char* fo_dbManager_StringEscape(fo_dbManager* dbManager, const char* string);
int fo_dbManager_begin(fo_dbManager* dbManager);
int fo_dbManager_commit(fo_dbManager* dbManager);
int fo_dbManager_rollback(fo_dbManager* dbManager);
PGresult* fo_dbManager_Exec_printf(fo_dbManager* dbManager, const char* sqlQueryStringFormat, ...);

#define fo_dbManager_PrepareStamement(dbManager, name, query, ...) \
fo_dbManager_PrepareStamement_str(dbManager, \
  name, \
  query, \
  #__VA_ARGS__\
)

fo_dbManager_PreparedStatement* fo_dbManager_PrepareStamement_str(fo_dbManager* dbManager, const char* name, const char* query, const char* paramtypes);

PGresult* fo_dbManager_ExecPrepared(fo_dbManager_PreparedStatement* preparedStatement, ...);
PGresult* fo_dbManager_ExecPreparedv(fo_dbManager_PreparedStatement* preparedStatement, va_list args);

int fo_dbManager_tableExists(fo_dbManager* dbManager, const char* tableName);
int fo_dbManager_exists(fo_dbManager* dbManager, const char* type, const char* name);

// visible for testing
int fo_dbManager_parseParamStr(const char* paramtypes, GArray** params);
char* fo_dbManager_printStatement(fo_dbManager_PreparedStatement* preparedStatement);

#endif  /* LIBFOSSDBMANAGER_H */