sq_exec.c File Reference

helper functions for executing SQL statements More...

#include "platform.h"
#include "gnunet_sq_lib.h"

Include dependency graph for sq_exec.c:

Go to the source code of this file.

Functions
struct GNUNET_SQ_ExecuteStatement	GNUNET_SQ_make_execute (const char *sql)
	Create a struct GNUNET_SQ_ExecuteStatement where errors are fatal. More...
struct GNUNET_SQ_ExecuteStatement	GNUNET_SQ_make_try_execute (const char *sql)
	Create a struct GNUNET_SQ_ExecuteStatement where errors should be tolerated. More...
enum GNUNET_GenericReturnValue	GNUNET_SQ_exec_statements (sqlite3 *dbh, const struct GNUNET_SQ_ExecuteStatement *es)
	Request execution of an array of statements es from Postgres. More...

Detailed Description

helper functions for executing SQL statements

Author

Christian Grothoff

Definition in file sq_exec.c.

Function Documentation

GNUNET_SQ_make_execute()

struct GNUNET_SQ_ExecuteStatement GNUNET_SQ_make_execute

(

const char *

sql

)

Create a struct GNUNET_SQ_ExecuteStatement where errors are fatal.

Parameters

sql	actual SQL statement

Returns

initialized struct

Definition at line 1 of file sq_exec.c.

{
  struct GNUNET_SQ_ExecuteStatement es = {
    .sql = sql,
    .ignore_errors = GNUNET_NO
  };
 
  return es;
}

Referenced by database_setup().

Here is the caller graph for this function:

GNUNET_SQ_make_try_execute()

struct GNUNET_SQ_ExecuteStatement GNUNET_SQ_make_try_execute

(

const char *

sql

)

Create a struct GNUNET_SQ_ExecuteStatement where errors should be tolerated.

Parameters

sql	actual SQL statement

Returns

initialized struct

Definition at line 1 of file sq_exec.c.

{
  struct GNUNET_SQ_ExecuteStatement es = {
    .sql = sql,
    .ignore_errors = GNUNET_YES
  };
 
  return es;
}

Referenced by database_setup().

Here is the caller graph for this function:

GNUNET_SQ_exec_statements()

enum GNUNET_GenericReturnValue GNUNET_SQ_exec_statements	(	sqlite3 *	dbh,
		const struct GNUNET_SQ_ExecuteStatement *	es
	)

Request execution of an array of statements es from Postgres.

Parameters

dbh	database to execute the statements over
es	GNUNET_PQ_PREPARED_STATEMENT_END-terminated array of prepared statements.

Returns

GNUNET_OK on success (modulo statements where errors can be ignored) GNUNET_SYSERR on error

Definition at line 1 of file sq_exec.c.

{
  for (unsigned int i = 0; NULL != es[i].sql; i++)
  {
    char *emsg = NULL;
 
    if (SQLITE_OK !=
        sqlite3_exec (dbh,
                      es[i].sql,
                      NULL,
                      NULL,
                      &emsg))
    {
      if (es[i].ignore_errors)
      {
        GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                    "Failed to run SQL `%s': %s\n",
                    es[i].sql,
                    emsg);
      }
      else
      {
        GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                    "Failed to run SQL `%s': %s\n",
                    es[i].sql,
                    emsg);
        sqlite3_free (emsg);
        return GNUNET_SYSERR;
      }
      sqlite3_free (emsg);
    }
  }
  return GNUNET_OK;
}

References GNUNET_NO, and GNUNET_SQ_ExecuteStatement::sql.

Referenced by database_setup().

Here is the caller graph for this function: