/extra/work/state-dev/src/sul/sul_peers.h

/* ----------------------------------------------------------------------------
 * $Id: sul_peers.h,v 1.10 2004/04/05 20:58:10 jlewalle Exp $
 *
 * --------------------------------------------------------------------------*/
#if !defined(_INCLUDED_SUL_PEERS_H_HEADER__)
#define _INCLUDED_SUL_PEERS_H_HEADER__

typedef void* sul_objectptr_t;

typedef enum sul_field_key_type_e
{
  SUL_FIELD_KT_NONE = -1,
  SUL_FIELD_KT_ID = 0,
  SUL_FIELD_KT_NAME,
  SUL_FIELD_KT_IP,
  SUL_FIELD_KT_LAST
} sul_field_key_type_e;

typedef enum sul_field_flags_e
{
  SUL_FIELD_FLAG_NONE = 0,
  SUL_FIELD_FLAG_PK,
  SUL_FIELD_FLAG_FK
} sul_field_flags_e;

typedef enum sul_field_type_e
{
  SUL_FIELD_TYPE_NULL = 0,
  SUL_FIELD_TYPE_STRING,
  SUL_FIELD_TYPE_INTEGER,
  SUL_FIELD_TYPE_BOOLEAN,
  SUL_FIELD_TYPE_FK,
  SUL_FIELD_TYPE_REAL,
  SUL_FIELD_TYPE_TIMESTAMP,
  SUL_FIELD_TYPE_TIME,
  SUL_FIELD_TYPE_DATE
} sul_field_type_e;

typedef struct sul_objfield_t
{
  char *name;
  sul_field_type_e type;
  size_t off;
  apr_int16_t flags;
  sul_field_key_type_e key_type;
} sul_objfield_t;

typedef struct sul_objpeer_t
{
  char *name;
  char *table;
  char *seq;
  apr_int32_t objsz;
  sul_objfield_t* fields;
  sul_objfield_t* pkey;
  sul_boolean_t ready;
} sul_objpeer_t;

#define SUL_PEER_NAME(table) peer_##table##_peer

#define SUL_PEER_PTR(table)  &(SUL_PEER_NAME(table))

#define SUL_PEER_DECLARE(table) \
  extern sul_objpeer_t SUL_PEER_NAME(table)

#define SUL_PEER_IMPLEMENT(type, table) \
  sul_objpeer_t SUL_PEER_NAME(table) = { \
    #type, \
    #table, \
    #table "_id", \
    sizeof(type), \
    peer_##table##_fields, \
    FALSE \
  }

#define SUL_PEER_IMPLEMENT_SEQ(type, table, seq) \
  sul_objpeer_t SUL_PEER_NAME(table) = { \
    #type, \
    #table, \
    #seq, \
    sizeof(type), \
    peer_##table##_fields, \
    FALSE \
  }

#define SUL_PEER_FIELDS_BEGIN(table) sul_objfield_t peer_##table##_fields[] = {

#define SUL_PEER_FIELDS_FIELD(name, type) { name, type, 0, SUL_FIELD_FLAG_NONE, SUL_FIELD_KT_NONE }

#define SUL_PEER_FIELDS_FIELD_KEY(name, type, id) { name, type, 0, SUL_FIELD_FLAG_NONE, id }

#define SUL_PEER_FIELDS_PKFLD(name, type) { name, type, 0, SUL_FIELD_FLAG_PK, SUL_FIELD_KT_ID }

#define SUL_PEER_FIELDS_FKFLD(name, type) { name, type, 0, SUL_FIELD_FLAG_FK, SUL_FIELD_KT_NONE }

#define SUL_PEER_FIELDS_END() { NULL, SUL_FIELD_TYPE_NULL, 0, 0, 0 } }

typedef struct sul_peer_query_t
{
  apr_pool_t *pool;
  char *sql;
  sul_dbc_t *dbc;
  sul_dbr_t *res;
  sul_objpeer_t *peer;
} sul_peer_query_t;

typedef struct sul_dataobj_header_t
{
  char bnew : 1;
  char modified : 7;
} sul_dataobj_header_t;

typedef struct sul_peer_record_t
{
  sul_objpeer_t *peer;
  apr_thread_rwlock_t *lock;
} sul_peer_record_t;

SUL_DECLARE(sul_error_t *)
sul_peer_initialize(sul_objpeer_t *peer);

SUL_DECLARE(sul_error_t *)
sul_peer_query_execute(sul_peer_query_t **query, sul_objpeer_t *peer,
                       sul_dbc_t *dbc, apr_pool_t *pool,
                       const char *sql, ...);

SUL_DECLARE(apr_size_t)
sul_peer_query_size(sul_peer_query_t *query);

SUL_DECLARE(sul_error_t *)
sul_peer_generate_array(apr_array_header_t **arrayp,
                        sul_peer_query_t *query, apr_pool_t *pool);

SUL_DECLARE(sul_error_t *)
sul_peer_generate_single(sul_objectptr_t *ptr, sul_peer_query_t *query,
                         apr_pool_t *pool);

SUL_DECLARE(apr_size_t)
sul_peer_type_size(sul_field_type_e type);

SUL_DECLARE(sul_error_t *)
sul_peer_field_to_sql(sul_stringbuf_t *sql, sul_objpeer_t *peer,
                      sul_objectptr_t ptr, apr_size_t fldi,
                      apr_pool_t *pool);

SUL_DECLARE(char *)
sul_peer_sql_query(sul_objpeer_t *peer, apr_pool_t *pool);

SUL_DECLARE(char *)
sul_peer_sql_add(sul_objpeer_t *peer, sul_objectptr_t ptr, apr_pool_t *pool);

SUL_DECLARE(char *)
sul_peer_sql_update(sul_objpeer_t *peer, sul_objectptr_t ptr, 
                    apr_pool_t *pool);

SUL_DECLARE(char *)
sul_peer_sql_delete(sul_objpeer_t *peer, sul_objectptr_t ptr,
                    apr_pool_t *pool);

SUL_DECLARE(sul_key_t)
sul_peer_object_key_get(sul_objpeer_t *peer, sul_objectptr_t ptr);

SUL_DECLARE(sul_key_t)
sul_peer_object_key_set(sul_objpeer_t *peer, sul_objectptr_t ptr,
                        sul_key_t key);

SUL_DECLARE(sul_error_t *)
sul_peer_populate(sul_objectptr_t ptr, sul_peer_query_t *query,
                  apr_size_t row, apr_pool_t *pool);

SUL_DECLARE(sul_error_t *)
sul_peer_save(sul_objpeer_t *peer, sul_objectptr_t ptr,
              sul_dbc_t *dbc, apr_pool_t *pool);

SUL_DECLARE(sul_error_t *)
sul_peer_add(sul_objpeer_t *peer, sul_objectptr_t ptr,
             sul_dbc_t *dbc, apr_pool_t *pool);

SUL_DECLARE(sul_error_t *)
sul_peer_delete(sul_objpeer_t *peer, sul_objectptr_t ptr,
                sul_dbc_t *dbc, apr_pool_t *pool);

SUL_DECLARE(signed)
sul_parse_time(apr_time_exp_t *tm, const char *str);

#endif

---