sq_query_helper.c File Reference

helper functions for queries More...

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

Include dependency graph for sq_query_helper.c:

Go to the source code of this file.

Functions
static int	bind_fixed_blob (void *cls, const void *data, size_t data_len, sqlite3_stmt *stmt, unsigned int off)
	Function called to convert input argument into SQL parameters. More...
struct GNUNET_SQ_QueryParam	GNUNET_SQ_query_param_fixed_size (const void *ptr, size_t ptr_size)
	Generate query parameter for a buffer ptr of ptr_size bytes. More...
static int	bind_string (void *cls, const void *data, size_t data_len, sqlite3_stmt *stmt, unsigned int off)
	Function called to convert input argument into SQL parameters. More...
struct GNUNET_SQ_QueryParam	GNUNET_SQ_query_param_string (const char *ptr)
	Generate query parameter for a string. More...
static int	bind_rsa_pub (void *cls, const void *data, size_t data_len, sqlite3_stmt *stmt, unsigned int off)
	Function called to convert input argument into SQL parameters. More...
struct GNUNET_SQ_QueryParam	GNUNET_SQ_query_param_rsa_public_key (const struct GNUNET_CRYPTO_RsaPublicKey *x)
	Generate query parameter for an RSA public key. More...
static int	bind_rsa_sig (void *cls, const void *data, size_t data_len, sqlite3_stmt *stmt, unsigned int off)
	Function called to convert input argument into SQL parameters. More...
struct GNUNET_SQ_QueryParam	GNUNET_SQ_query_param_rsa_signature (const struct GNUNET_CRYPTO_RsaSignature *x)
	Generate query parameter for an RSA signature. More...
static int	bind_abstime (void *cls, const void *data, size_t data_len, sqlite3_stmt *stmt, unsigned int off)
	Function called to convert input argument into SQL parameters. More...
struct GNUNET_SQ_QueryParam	GNUNET_SQ_query_param_absolute_time (const struct GNUNET_TIME_Absolute *x)
	Generate query parameter for an absolute time value. More...
static int	bind_nbotime (void *cls, const void *data, size_t data_len, sqlite3_stmt *stmt, unsigned int off)
	Function called to convert input argument into SQL parameters. More...
struct GNUNET_SQ_QueryParam	GNUNET_SQ_query_param_absolute_time_nbo (const struct GNUNET_TIME_AbsoluteNBO *x)
	Generate query parameter for an absolute time value. More...
static int	bind_u16 (void *cls, const void *data, size_t data_len, sqlite3_stmt *stmt, unsigned int off)
	Function called to convert input argument into SQL parameters. More...
struct GNUNET_SQ_QueryParam	GNUNET_SQ_query_param_uint16 (const uint16_t *x)
	Generate query parameter for an uint16_t in host byte order. More...
static int	bind_u32 (void *cls, const void *data, size_t data_len, sqlite3_stmt *stmt, unsigned int off)
	Function called to convert input argument into SQL parameters. More...
struct GNUNET_SQ_QueryParam	GNUNET_SQ_query_param_uint32 (const uint32_t *x)
	Generate query parameter for an uint32_t in host byte order. More...
static int	bind_u64 (void *cls, const void *data, size_t data_len, sqlite3_stmt *stmt, unsigned int off)
	Function called to convert input argument into SQL parameters. More...
struct GNUNET_SQ_QueryParam	GNUNET_SQ_query_param_uint64 (const uint64_t *x)
	Generate query parameter for an uint16_t in host byte order. More...

Detailed Description

helper functions for queries

Author

Christian Grothoff

Definition in file sq_query_helper.c.

Function Documentation

bind_fixed_blob()

static int bind_fixed_blob ( void *  cls, const void *  data, size_t  data_len, sqlite3_stmt *  stmt, unsigned int  off  )

static

Function called to convert input argument into SQL parameters.

Parameters

cls	closure
data	pointer to input argument
data_len	number of bytes in data (if applicable)
stmt	sqlite statement to bind parameters for
off	offset of the argument to bind in stmt, numbered from 1, so immediately suitable for passing to sqlite3_bind-functions.

Returns

GNUNET_SYSERR on error, GNUNET_OK on success

Definition at line 41 of file sq_query_helper.c.

{
  if (SQLITE_OK !=
      sqlite3_bind_blob64 (stmt,
                           (int) off,
                           data,
                           (sqlite3_uint64) data_len,
                           SQLITE_TRANSIENT))
    return GNUNET_SYSERR;
  return GNUNET_OK;
}

References data, GNUNET_OK, and GNUNET_SYSERR.

GNUNET_SQ_query_param_fixed_size()

struct GNUNET_SQ_QueryParam GNUNET_SQ_query_param_fixed_size	(	const void *	ptr,
		size_t	ptr_size
	)

Generate query parameter for a buffer ptr of ptr_size bytes.

Parameters

ptr	pointer to the query parameter to pass
ptr_size	number of bytes in ptr

Definition at line 41 of file sq_query_helper.c.

{
  struct GNUNET_SQ_QueryParam qp = {
    .conv = &bind_fixed_blob,
    .data = ptr,
    .size = ptr_size,
    .num_params = 1
  };
 
  return qp;
}

Referenced by namecache_sqlite_cache_block(), peerstore_sqlite_store_record(), sqlite_plugin_put(), and sqlite_plugin_remove_key().

Here is the caller graph for this function:

bind_string()

static int bind_string ( void *  cls, const void *  data, size_t  data_len, sqlite3_stmt *  stmt, unsigned int  off  )

static

Function called to convert input argument into SQL parameters.

Parameters

cls	closure
data	pointer to input argument
data_len	number of bytes in data (if applicable)
stmt	sqlite statement to bind parameters for
off	offset of the argument to bind in stmt, numbered from 1, so immediately suitable for passing to sqlite3_bind-functions.

Returns

GNUNET_SYSERR on error, GNUNET_OK on success

Definition at line 92 of file sq_query_helper.c.

{
  if (NULL == data)
  {
    if (SQLITE_OK !=
        sqlite3_bind_null (stmt,
                           (int) off))
      return GNUNET_SYSERR;
    return GNUNET_OK;
  }
  if (SQLITE_OK !=
      sqlite3_bind_text (stmt,
                         (int) off,
                         (const char *) data,
                         -1,
                         SQLITE_TRANSIENT))
    return GNUNET_SYSERR;
  return GNUNET_OK;
}

References data, GNUNET_OK, and GNUNET_SYSERR.

GNUNET_SQ_query_param_string()

struct GNUNET_SQ_QueryParam GNUNET_SQ_query_param_string

(

const char *

ptr

)

Generate query parameter for a string.

Parameters

ptr	pointer to the string query parameter to pass

Definition at line 92 of file sq_query_helper.c.

{
  struct GNUNET_SQ_QueryParam qp = {
    .conv = &bind_string,
    .data = ptr,
    .num_params = 1
  };
 
  return qp;
}

Referenced by peerstore_sqlite_delete_records(), peerstore_sqlite_iterate_records(), and peerstore_sqlite_store_record().

Here is the caller graph for this function:

bind_rsa_pub()

static int bind_rsa_pub ( void *  cls, const void *  data, size_t  data_len, sqlite3_stmt *  stmt, unsigned int  off  )

static

Function called to convert input argument into SQL parameters.

Parameters

cls	closure
data	pointer to input argument
data_len	number of bytes in data (if applicable)
stmt	sqlite statement to bind parameters for
off	offset of the argument to bind in stmt, numbered from 1, so immediately suitable for passing to sqlite3_bind-functions.

Returns

GNUNET_SYSERR on error, GNUNET_OK on success

Definition at line 147 of file sq_query_helper.c.

{
  const struct GNUNET_CRYPTO_RsaPublicKey *rsa = data;
  void *buf;
  size_t buf_size;
 
  GNUNET_break (NULL == cls);
  buf_size = GNUNET_CRYPTO_rsa_public_key_encode (rsa,
                                                  &buf);
  if (SQLITE_OK !=
      sqlite3_bind_blob64 (stmt,
                           (int) off,
                           buf,
                           (sqlite3_uint64) buf_size,
                           SQLITE_TRANSIENT))
  {
    GNUNET_free (buf);
    return GNUNET_SYSERR;
  }
  GNUNET_free (buf);
  return GNUNET_OK;
}

References buf, data, GNUNET_break, GNUNET_CRYPTO_rsa_public_key_encode(), GNUNET_free, GNUNET_OK, and GNUNET_SYSERR.

Here is the call graph for this function:

GNUNET_SQ_query_param_rsa_public_key()

struct GNUNET_SQ_QueryParam GNUNET_SQ_query_param_rsa_public_key

(

const struct GNUNET_CRYPTO_RsaPublicKey *

x

)

Generate query parameter for an RSA public key.

The database must contain a BLOB type in the respective position.

Parameters

x	the query parameter to pass.

Definition at line 147 of file sq_query_helper.c.

{
  struct GNUNET_SQ_QueryParam qp = {
    .conv = &bind_rsa_pub,
    .data = x,
    .num_params = 1
  };
 
  return qp;
}

bind_rsa_sig()

static int bind_rsa_sig ( void *  cls, const void *  data, size_t  data_len, sqlite3_stmt *  stmt, unsigned int  off  )

static

Function called to convert input argument into SQL parameters.

Parameters

cls	closure
data	pointer to input argument
data_len	number of bytes in data (if applicable)
stmt	sqlite statement to bind parameters for
off	offset of the argument to bind in stmt, numbered from 1, so immediately suitable for passing to sqlite3_bind-functions.

Returns

GNUNET_SYSERR on error, GNUNET_OK on success

Definition at line 207 of file sq_query_helper.c.

{
  const struct GNUNET_CRYPTO_RsaSignature *sig = data;
  void *buf;
  size_t buf_size;
 
  GNUNET_break (NULL == cls);
  buf_size = GNUNET_CRYPTO_rsa_signature_encode (sig,
                                                 &buf);
  if (SQLITE_OK !=
      sqlite3_bind_blob64 (stmt,
                           (int) off,
                           buf,
                           (sqlite3_uint64) buf_size,
                           SQLITE_TRANSIENT))
  {
    GNUNET_free (buf);
    return GNUNET_SYSERR;
  }
  GNUNET_free (buf);
  return GNUNET_OK;
}

References buf, data, GNUNET_break, GNUNET_CRYPTO_rsa_signature_encode(), GNUNET_free, GNUNET_OK, and GNUNET_SYSERR.

Here is the call graph for this function:

GNUNET_SQ_query_param_rsa_signature()

struct GNUNET_SQ_QueryParam GNUNET_SQ_query_param_rsa_signature

(

const struct GNUNET_CRYPTO_RsaSignature *

x

)

Generate query parameter for an RSA signature.

The database must contain a BLOB type in the respective position.

Parameters

x	the query parameter to pass

Definition at line 207 of file sq_query_helper.c.

{
  struct GNUNET_SQ_QueryParam qp = {
    .conv = &bind_rsa_sig,
    .data = x,
    .num_params = 1
  };
 
  return qp;
}

bind_abstime()

static int bind_abstime ( void *  cls, const void *  data, size_t  data_len, sqlite3_stmt *  stmt, unsigned int  off  )

static

Function called to convert input argument into SQL parameters.

Parameters

cls	closure
data	pointer to input argument
data_len	number of bytes in data (if applicable)
stmt	sqlite statement to bind parameters for
off	offset of the argument to bind in stmt, numbered from 1, so immediately suitable for passing to sqlite3_bind-functions.

Returns

GNUNET_SYSERR on error, GNUNET_OK on success

Definition at line 266 of file sq_query_helper.c.

{
  const struct GNUNET_TIME_Absolute *u = data;
  struct GNUNET_TIME_Absolute abs;
 
  abs = *u;
  if (abs.abs_value_us > INT64_MAX)
    abs.abs_value_us = INT64_MAX;
  GNUNET_assert (sizeof(uint64_t) == data_len);
  if (SQLITE_OK !=
      sqlite3_bind_int64 (stmt,
                          (int) off,
                          (sqlite3_int64) abs.abs_value_us))
    return GNUNET_SYSERR;
  return GNUNET_OK;
}

References GNUNET_TIME_Absolute::abs_value_us, data, GNUNET_assert, GNUNET_OK, and GNUNET_SYSERR.

GNUNET_SQ_query_param_absolute_time()

struct GNUNET_SQ_QueryParam GNUNET_SQ_query_param_absolute_time

(

const struct GNUNET_TIME_Absolute *

x

)

Generate query parameter for an absolute time value.

The database must store a 64-bit integer.

Parameters

x	pointer to the query parameter to pass

Definition at line 266 of file sq_query_helper.c.

{
  struct GNUNET_SQ_QueryParam qp = {
    .conv = &bind_abstime,
    .data = x,
    .size = sizeof(struct GNUNET_TIME_Absolute),
    .num_params = 1
  };
 
  return qp;
}

Referenced by get_any(), get_typed(), namecache_sqlite_cache_block(), namecache_sqlite_expire_blocks(), peerstore_sqlite_expire_records(), peerstore_sqlite_store_record(), sqlite_plugin_get_closest(), sqlite_plugin_get_expiration(), and sqlite_plugin_put().

Here is the caller graph for this function:

bind_nbotime()

static int bind_nbotime ( void *  cls, const void *  data, size_t  data_len, sqlite3_stmt *  stmt, unsigned int  off  )

static

Function called to convert input argument into SQL parameters.

Parameters

cls	closure
data	pointer to input argument
data_len	number of bytes in data (if applicable)
stmt	sqlite statement to bind parameters for
off	offset of the argument to bind in stmt, numbered from 1, so immediately suitable for passing to sqlite3_bind-functions.

Returns

GNUNET_SYSERR on error, GNUNET_OK on success

Definition at line 320 of file sq_query_helper.c.

{
  const struct GNUNET_TIME_AbsoluteNBO *u = data;
  struct GNUNET_TIME_Absolute abs;
 
  abs = GNUNET_TIME_absolute_ntoh (*u);
  if (abs.abs_value_us > INT64_MAX)
    abs.abs_value_us = INT64_MAX;
  GNUNET_assert (sizeof(uint64_t) == data_len);
  if (SQLITE_OK !=
      sqlite3_bind_int64 (stmt,
                          (int) off,
                          (sqlite3_int64) abs.abs_value_us))
    return GNUNET_SYSERR;
  return GNUNET_OK;
}

References GNUNET_TIME_Absolute::abs_value_us, data, GNUNET_assert, GNUNET_OK, GNUNET_SYSERR, and GNUNET_TIME_absolute_ntoh().

Here is the call graph for this function:

GNUNET_SQ_query_param_absolute_time_nbo()

struct GNUNET_SQ_QueryParam GNUNET_SQ_query_param_absolute_time_nbo

(

const struct GNUNET_TIME_AbsoluteNBO *

x

)

Generate query parameter for an absolute time value.

The database must store a 64-bit integer.

Parameters

x	pointer to the query parameter to pass

Definition at line 320 of file sq_query_helper.c.

{
  struct GNUNET_SQ_QueryParam qp = {
    .conv = &bind_nbotime,
    .data = x,
    .size = sizeof(struct GNUNET_TIME_AbsoluteNBO),
    .num_params = 1
  };
 
  return qp;
}

bind_u16()

static int bind_u16 ( void *  cls, const void *  data, size_t  data_len, sqlite3_stmt *  stmt, unsigned int  off  )

static

Function called to convert input argument into SQL parameters.

Parameters

cls	closure
data	pointer to input argument
data_len	number of bytes in data (if applicable)
stmt	sqlite statement to bind parameters for
off	offset of the argument to bind in stmt, numbered from 1, so immediately suitable for passing to sqlite3_bind-functions.

Returns

GNUNET_SYSERR on error, GNUNET_OK on success

Definition at line 375 of file sq_query_helper.c.

{
  const uint16_t *u = data;
 
  GNUNET_assert (sizeof(uint16_t) == data_len);
  if (SQLITE_OK !=
      sqlite3_bind_int (stmt,
                        (int) off,
                        (int) *u))
    return GNUNET_SYSERR;
  return GNUNET_OK;
}

References data, GNUNET_assert, GNUNET_OK, and GNUNET_SYSERR.

GNUNET_SQ_query_param_uint16()

struct GNUNET_SQ_QueryParam GNUNET_SQ_query_param_uint16

(

const uint16_t *

x

)

Generate query parameter for an uint16_t in host byte order.

Parameters

x	pointer to the query parameter to pass

Definition at line 375 of file sq_query_helper.c.

{
  struct GNUNET_SQ_QueryParam qp = {
    .conv = &bind_u16,
    .data = x,
    .size = sizeof(uint16_t),
    .num_params = 1
  };
 
  return qp;
}

bind_u32()

static int bind_u32 ( void *  cls, const void *  data, size_t  data_len, sqlite3_stmt *  stmt, unsigned int  off  )

static

Function called to convert input argument into SQL parameters.

Parameters

cls	closure
data	pointer to input argument
data_len	number of bytes in data (if applicable)
stmt	sqlite statement to bind parameters for
off	offset of the argument to bind in stmt, numbered from 1, so immediately suitable for passing to sqlite3_bind-functions.

Returns

GNUNET_SYSERR on error, GNUNET_OK on success

Definition at line 424 of file sq_query_helper.c.

{
  const uint32_t *u = data;
 
  GNUNET_assert (sizeof(uint32_t) == data_len);
  if (SQLITE_OK !=
      sqlite3_bind_int64 (stmt,
                          (int) off,
                          (sqlite3_int64) * u))
    return GNUNET_SYSERR;
  return GNUNET_OK;
}

References data, GNUNET_assert, GNUNET_OK, and GNUNET_SYSERR.

GNUNET_SQ_query_param_uint32()

struct GNUNET_SQ_QueryParam GNUNET_SQ_query_param_uint32

(

const uint32_t *

x

)

Generate query parameter for an uint32_t in host byte order.

Parameters

x	pointer to the query parameter to pass

Definition at line 424 of file sq_query_helper.c.

{
  struct GNUNET_SQ_QueryParam qp = {
    .conv = &bind_u32,
    .data = x,
    .size = sizeof(uint32_t),
    .num_params = 1
  };
 
  return qp;
}

Referenced by get_any(), get_typed(), sqlite_plugin_get_closest(), sqlite_plugin_get_key(), sqlite_plugin_get_replication(), sqlite_plugin_get_zero_anonymity(), and sqlite_plugin_put().

Here is the caller graph for this function:

bind_u64()

static int bind_u64 ( void *  cls, const void *  data, size_t  data_len, sqlite3_stmt *  stmt, unsigned int  off  )

static

Function called to convert input argument into SQL parameters.

Parameters

cls	closure
data	pointer to input argument
data_len	number of bytes in data (if applicable)
stmt	sqlite statement to bind parameters for
off	offset of the argument to bind in stmt, numbered from 1, so immediately suitable for passing to sqlite3_bind-functions.

Returns

GNUNET_SYSERR on error, GNUNET_OK on success

Definition at line 473 of file sq_query_helper.c.

{
  const uint64_t *u = data;
 
  GNUNET_assert (sizeof(uint64_t) == data_len);
  if (SQLITE_OK !=
      sqlite3_bind_int64 (stmt,
                          (int) off,
                          (sqlite3_int64) * u))
    return GNUNET_SYSERR;
  return GNUNET_OK;
}

References data, GNUNET_assert, GNUNET_OK, and GNUNET_SYSERR.

GNUNET_SQ_query_param_uint64()

struct GNUNET_SQ_QueryParam GNUNET_SQ_query_param_uint64

(

const uint64_t *

x

)

Generate query parameter for an uint16_t in host byte order.

Parameters

x	pointer to the query parameter to pass

Definition at line 473 of file sq_query_helper.c.

{
  struct GNUNET_SQ_QueryParam qp = {
    .conv = &bind_u64,
    .data = x,
    .size = sizeof(uint64_t),
    .num_params = 1
  };
 
  return qp;
}

Referenced by delete_by_rowid(), sqlite_plugin_get_key(), sqlite_plugin_get_replication(), sqlite_plugin_get_zero_anonymity(), and sqlite_plugin_put().

Here is the caller graph for this function: