granicus.if.org Git - icinga2/blob - lib/pgsql_shim/pgsqlinterface.cpp

   1 /* Icinga 2 | (c) 2012 Icinga GmbH | GPLv2+ */
   2
   3 #include "pgsql_shim/pgsqlinterface.hpp"
   4
   5 using namespace icinga;
   6
   7 struct PgsqlInterfaceImpl final : public PgsqlInterface
   8 {
   9         void Destroy() override
  10         {
  11                 delete this;
  12         }
  13
  14         void clear(PGresult *res) const override
  15         {
  16                 PQclear(res);
  17         }
  18
  19         char *cmdTuples(PGresult *res) const override
  20         {
  21                 return PQcmdTuples(res);
  22         }
  23
  24         char *errorMessage(const PGconn *conn) const override
  25         {
  26                 return PQerrorMessage(conn);
  27         }
  28
  29         size_t escapeStringConn(PGconn *conn, char *to, const char *from, size_t length, int *error) const override
  30         {
  31                 return PQescapeStringConn(conn, to, from, length, error);
  32         }
  33
  34         PGresult *exec(PGconn *conn, const char *query) const override
  35         {
  36                 return PQexec(conn, query);
  37         }
  38
  39         void finish(PGconn *conn) const override
  40         {
  41                 PQfinish(conn);
  42         }
  43
  44         char *fname(const PGresult *res, int field_num) const override
  45         {
  46                 return PQfname(res, field_num);
  47         }
  48
  49         int getisnull(const PGresult *res, int tup_num, int field_num) const override
  50         {
  51                 return PQgetisnull(res, tup_num, field_num);
  52         }
  53
  54         char *getvalue(const PGresult *res, int tup_num, int field_num) const override
  55         {
  56                 return PQgetvalue(res, tup_num, field_num);
  57         }
  58
  59         int isthreadsafe() const override
  60         {
  61                 return PQisthreadsafe();
  62         }
  63
  64         int nfields(const PGresult *res) const override
  65         {
  66                 return PQnfields(res);
  67         }
  68
  69         int ntuples(const PGresult *res) const override
  70         {
  71                 return PQntuples(res);
  72         }
  73
  74         char *resultErrorMessage(const PGresult *res) const override
  75         {
  76                 return PQresultErrorMessage(res);
  77         }
  78
  79         ExecStatusType resultStatus(const PGresult *res) const override
  80         {
  81                 return PQresultStatus(res);
  82         }
  83
  84         int serverVersion(const PGconn *conn) const override
  85         {
  86                 return PQserverVersion(conn);
  87         }
  88
  89         PGconn *setdbLogin(const char *pghost, const char *pgport, const char *pgoptions, const char *pgtty, const char *dbName, const char *login, const char *pwd) const override
  90         {
  91                 return PQsetdbLogin(pghost, pgport, pgoptions, pgtty, dbName, login, pwd);
  92         }
  93
  94         PGconn *connectdb(const char *conninfo) const override
  95         {
  96                 return PQconnectdb(conninfo);
  97         }
  98
  99         ConnStatusType status(const PGconn *conn) const override
 100         {
 101                 return PQstatus(conn);
 102         }
 103 };
 104
 105 PgsqlInterface *create_pgsql_shim()
 106 {
 107         return new PgsqlInterfaceImpl();
 108 }