GNUnet  0.20.0
pq_prepare.c File Reference

functions to connect to libpq (PostGres) More...

#include "platform.h"
#include "pq.h"
Include dependency graph for pq_prepare.c:

Go to the source code of this file.

Functions

struct GNUNET_PQ_PreparedStatement GNUNET_PQ_make_prepare (const char *name, const char *sql)
 Create a struct GNUNET_PQ_PreparedStatement. More...
 
enum GNUNET_GenericReturnValue GNUNET_PQ_prepare_once (struct GNUNET_PQ_Context *db, const struct GNUNET_PQ_PreparedStatement *ps)
 Request creation of prepared statements ps from Postgres, but do not automatically re-prepare the statement if we are disconnected from the database. More...
 
enum GNUNET_GenericReturnValue GNUNET_PQ_prepare_statements (struct GNUNET_PQ_Context *db, const struct GNUNET_PQ_PreparedStatement *ps)
 Request creation of prepared statements ps from Postgres. More...
 

Detailed Description

functions to connect to libpq (PostGres)

Author
Christian Grothoff

Definition in file pq_prepare.c.

Function Documentation

◆ GNUNET_PQ_make_prepare()

struct GNUNET_PQ_PreparedStatement GNUNET_PQ_make_prepare ( const char *  name,
const char *  sql 
)

Create a struct GNUNET_PQ_PreparedStatement.

Parameters
namename of the statement
sqlactual SQL statement
Returns
initialized struct

Definition at line 1 of file pq_prepare.c.

32 {
33  struct GNUNET_PQ_PreparedStatement ps = {
34  .name = name,
35  .sql = sql
36  };
37 
38  return ps;
39 }
const char * name
Information needed to prepare a list of SQL statements using GNUNET_PQ_prepare_statements().
const char * name
Name of the statement.
const char * sql
Actual SQL statement.

References name, GNUNET_PQ_PreparedStatement::name, and GNUNET_PQ_PreparedStatement::sql.

◆ GNUNET_PQ_prepare_once()

enum GNUNET_GenericReturnValue GNUNET_PQ_prepare_once ( struct GNUNET_PQ_Context db,
const struct GNUNET_PQ_PreparedStatement ps 
)

Request creation of prepared statements ps from Postgres, but do not automatically re-prepare the statement if we are disconnected from the database.

Parameters
dbdatabase to prepare the statements for
psGNUNET_PQ_PREPARED_STATEMENT_END-terminated array of prepared statements.
Returns
GNUNET_OK on success, GNUNET_SYSERR on error

Definition at line 1 of file pq_prepare.c.

45 {
46  for (unsigned int i = 0; NULL != ps[i].name; i++)
47  {
48  PGresult *ret;
49 
51  "pq",
52  "Preparing SQL statement `%s' as `%s'\n",
53  ps[i].sql,
54  ps[i].name);
55  ret = PQprepare (db->conn,
56  ps[i].name,
57  ps[i].sql,
58  0,
59  NULL);
60  if (PGRES_COMMAND_OK != PQresultStatus (ret))
61  {
63  "pq",
64  "PQprepare (`%s' as `%s') failed with error: %s\n",
65  ps[i].sql,
66  ps[i].name,
67  PQerrorMessage (db->conn));
68  PQclear (ret);
69  ret = PQdescribePrepared (db->conn,
70  ps[i].name);
71  if (PGRES_COMMAND_OK != PQresultStatus (ret))
72  {
73  PQclear (ret);
74  return GNUNET_SYSERR;
75  }
77  "pq",
78  "Statement `%s' already known. Ignoring the issue in the hope that you are using connection pooling...\n",
79  ps[i].name);
80  }
81  PQclear (ret);
82  }
83  return GNUNET_OK;
84 }
static int ret
Return value of the commandline.
Definition: gnunet-abd.c:81
static struct GNUNET_FS_DirectoryBuilder * db
Definition: gnunet-search.c:97
#define GNUNET_log_from(kind, comp,...)
@ GNUNET_OK
@ GNUNET_SYSERR
@ GNUNET_ERROR_TYPE_ERROR
@ GNUNET_ERROR_TYPE_BULK
@ GNUNET_ERROR_TYPE_DEBUG

◆ GNUNET_PQ_prepare_statements()

enum GNUNET_GenericReturnValue GNUNET_PQ_prepare_statements ( struct GNUNET_PQ_Context db,
const struct GNUNET_PQ_PreparedStatement ps 
)

Request creation of prepared statements ps from Postgres.

Parameters
dbdatabase to prepare the statements for
psGNUNET_PQ_PREPARED_STATEMENT_END-terminated array of prepared statements.
Returns
GNUNET_OK on success, GNUNET_SYSERR on error

Definition at line 1 of file pq_prepare.c.

90 {
91  if (db->ps != ps)
92  {
93  /* add 'ps' to list db->ps of prepared statements to run on reconnect! */
94  unsigned int nlen = 0; /* length of 'ps' array */
95  unsigned int xlen;
96  struct GNUNET_PQ_PreparedStatement *rps; /* combined array */
97 
98  while (NULL != ps[nlen].name)
99  nlen++;
100  xlen = nlen + db->ps_off;
101  if (xlen > db->ps_len)
102  {
103  xlen = 2 * xlen + 1;
104  rps = GNUNET_new_array (xlen,
106  if (NULL != db->ps)
107  memcpy (rps,
108  db->ps,
109  db->ps_off * sizeof (struct GNUNET_PQ_PreparedStatement));
110  GNUNET_free (db->ps);
111  db->ps_len = xlen;
112  db->ps = rps;
113  }
114  memcpy (&db->ps[db->ps_off],
115  ps,
116  nlen * sizeof (struct GNUNET_PQ_PreparedStatement));
117  db->ps_off += nlen;
118  }
119 
120  return GNUNET_PQ_prepare_once (db,
121  ps);
122 }
#define GNUNET_new_array(n, type)
Allocate a size n array with structs or unions of the given type.
#define GNUNET_free(ptr)
Wrapper around free.
enum GNUNET_GenericReturnValue GNUNET_PQ_prepare_once(struct GNUNET_PQ_Context *db, const struct GNUNET_PQ_PreparedStatement *ps)
Request creation of prepared statements ps from Postgres, but do not automatically re-prepare the sta...
Definition: pq_prepare.c:43

Referenced by GNUNET_PQ_reconnect().

Here is the caller graph for this function: