pq_connect.c File Reference

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

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_pq_lib.h"

Include dependency graph for pq_connect.c:

Go to the source code of this file.

Functions
static void	pq_notice_receiver_cb (void *arg, const PGresult *res)
	Function called by libpq whenever it wants to log something. More...
static void	pq_notice_processor_cb (void *arg, const char *message)
	Function called by libpq whenever it wants to log something. More...
PGconn *	GNUNET_PQ_connect (const char *config_str)
	Create a connection to the Postgres database using config_str for the configuration. More...
PGconn *	GNUNET_PQ_connect_with_cfg (const struct GNUNET_CONFIGURATION_Handle *cfg, const char *section)
	Connect to a postgres database using the configuration option "CONFIG" in section. More...

Detailed Description

functions to connect to libpq (PostGres)

Author

Christian Grothoff

Definition in file pq_connect.c.

Function Documentation

pq_notice_receiver_cb()

static void pq_notice_receiver_cb ( void *  arg, const PGresult *  res  )

static

Function called by libpq whenever it wants to log something.

We already log whenever we care, so this function does nothing and merely exists to silence the libpq logging.

Parameters

arg	the SQL connection that was used
res	information about some libpq event

Definition at line 39 of file pq_connect.c.

Referenced by GNUNET_PQ_connect().

{
  /* do nothing, intentionally */
}

Here is the caller graph for this function:

pq_notice_processor_cb()

static void pq_notice_processor_cb ( void *  arg, const char *  message  )

static

Function called by libpq whenever it wants to log something.

We log those using the Taler logger.

Parameters

arg	the SQL connection that was used
message	information about some libpq event

Definition at line 54 of file pq_connect.c.

References GNUNET_ERROR_TYPE_INFO, and GNUNET_log_from.

Referenced by GNUNET_PQ_connect().

{
  GNUNET_log_from(GNUNET_ERROR_TYPE_INFO,
                  "pq",
                  "%s",
                  message);
}

Here is the caller graph for this function:

GNUNET_PQ_connect()

PGconn* GNUNET_PQ_connect

(

const char *

config_str

)

Create a connection to the Postgres database using config_str for the configuration.

Initialize logging via GNUnet's log routines and disable Postgres's logger.

Parameters

config_str

configuration to use

Returns

NULL on error

Definition at line 73 of file pq_connect.c.

References GNUNET_ERROR_TYPE_ERROR, GNUNET_log_from, pq_notice_processor_cb(), and pq_notice_receiver_cb().

Referenced by GNUNET_PQ_connect_with_cfg().

{
  PGconn *conn;

  conn = PQconnectdb(config_str);
  if ((NULL == conn) ||
      (CONNECTION_OK !=
       PQstatus(conn)))
    {
      GNUNET_log_from(GNUNET_ERROR_TYPE_ERROR,
                      "pq",
                      "Database connection to '%s' failed: %s\n",
                      config_str,
                      (NULL != conn) ?
                      PQerrorMessage(conn)
                      : "PQconnectdb returned NULL");
      if (NULL != conn)
        PQfinish(conn);
      return NULL;
    }
  PQsetNoticeReceiver(conn,
                      &pq_notice_receiver_cb,
                      conn);
  PQsetNoticeProcessor(conn,
                       &pq_notice_processor_cb,
                       conn);
  return conn;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_connect_with_cfg()

PGconn* GNUNET_PQ_connect_with_cfg	(	const struct GNUNET_CONFIGURATION_Handle *	cfg,
		const char *	section
	)

Connect to a postgres database using the configuration option "CONFIG" in section.

Parameters

cfg	configuration
section	configuration section to use to get Postgres configuration options

Returns

the postgres handle, NULL on error

Definition at line 112 of file pq_connect.c.

References GNUNET_CONFIGURATION_get_value_string(), GNUNET_free_non_null, GNUNET_OK, and GNUNET_PQ_connect().

Referenced by database_setup(), and init_connection().

{
  PGconn *dbh;
  char *conninfo;

  /* Open database and precompile statements */
  if (GNUNET_OK !=
      GNUNET_CONFIGURATION_get_value_string(cfg,
                                            section,
                                            "CONFIG",
                                            &conninfo))
    conninfo = NULL;
  dbh = GNUNET_PQ_connect(conninfo == NULL ? "" : conninfo);
  GNUNET_free_non_null(conninfo);
  return dbh;
}

Here is the call graph for this function:

Here is the caller graph for this function: