/* XXX FIXME: ptr alignment is fubar here. */
if (key != NULL && key->data != NULL) {
- fprintf(stderr, " key 0x%x[%d]", *(long *)key->data, key->size);
+ fprintf(stderr, " key 0x%x[%d]", *(unsigned int *)key->data, key->size);
if (dbi->dbi_rpmtag == RPMTAG_NAME)
fprintf(stderr, " \"%s\"", (const char *)key->data);
}
if (data != NULL && data->data != NULL)
- fprintf(stderr, " data 0x%x[%d]", *(long *)data->data, data->size);
+ fprintf(stderr, " data 0x%x[%d]", *(unsigned int *)data->data, data->size);
fprintf(stderr, "\n");
}
static int sql_startTransaction(dbiIndex dbi)
/*@*/
{
- DB * db = dbi->dbi_db;
- SQL_DB * sqldb = (SQL_DB *)db->app_private;
+ SQL_DB * sqldb = (SQL_DB *) dbi->dbi_db;
int rc = 0;
/* XXX: Transaction Support */
static int sql_endTransaction(dbiIndex dbi)
/*@*/
{
- DB * db = dbi->dbi_db;
- SQL_DB * sqldb = (SQL_DB *)db->app_private;
+ SQL_DB * sqldb = (SQL_DB *) dbi->dbi_db;
int rc=0;
/* XXX: Transaction Support */
static int sql_commitTransaction(dbiIndex dbi, int flag)
/*@*/
{
- DB * db = dbi->dbi_db;
- SQL_DB * sqldb = (SQL_DB *)db->app_private;
+ SQL_DB * sqldb = (SQL_DB *) dbi->dbi_db;
int rc = 0;
/* XXX: Transactions */
static void * allocTempBuffer(DBC * dbcursor, size_t len)
/*@*/
{
- DB * db = dbcursor->dbp;
- SQL_DB * sqldb = (SQL_DB *)db->app_private;
SCP_t scp = (SCP_t)dbcursor;
SQL_MEM * item;
static int sql_initDB(dbiIndex dbi)
/*@*/
{
- DB * db = dbi->dbi_db;
- SQL_DB * sqldb = (SQL_DB *)db->app_private;
+ SQL_DB * sqldb = (SQL_DB *) dbi->dbi_db;
SCP_t scp = scpNew();
int rc = 0;
/*@globals fileSystem @*/
/*@modifies dbi, *dbcursor, fileSystem @*/
{
- DB * db = dbi->dbi_db;
-/*@i@*/ SQL_DB * sqldb = (SQL_DB *)db->app_private;
+/*@i@*/ SQL_DB * sqldb = (SQL_DB *) dbi->dbi_db;
SCP_t scp = (SCP_t)dbcursor;
- SCP_t prev = NULL;
int rc = 0;
assert(sqldb->db != NULL);
/*@globals fileSystem @*/
/*@modifies dbi, fileSystem @*/
{
- DB * db = dbi->dbi_db;
- SQL_DB * sqldb;
+ SQL_DB * sqldb = (SQL_DB *) dbi->dbi_db;
int rc = 0;
- if (db) {
- sqldb = (SQL_DB *)db->app_private;
+ if (sqldb) {
/* Commit, don't open a new one */
rc = sql_commitTransaction(dbi, 1);
/* They're the same so only free one! */
dbi->dbi_subfile = _free(dbi->dbi_subfile);
#endif
- dbi->dbi_db->app_private = _free(dbi->dbi_db->app_private); /* sqldb */
dbi->dbi_db = _free(dbi->dbi_db);
}
size_t len;
dbiIndex dbi = NULL;
- DB * db = NULL;
SQL_DB * sqldb;
dbfname, dbi->dbi_subfile, dbi->dbi_mode);
/* Open the Database */
- db = xcalloc(1, sizeof(*db));
sqldb = xcalloc(1,sizeof(*sqldb));
sql_errcode = NULL;
sqldb->transaction = 0; /* Initialize no current transactions */
- db->app_private = sqldb;
- dbi->dbi_db = db;
+ dbi->dbi_db = (DB *)sqldb;
if (sql_errcode != NULL) {
rpmMessage(RPMMESS_DEBUG, "Unable to open database: %s\n", sql_errcode);
/*@globals fileSystem @*/
/*@modifies fileSystem @*/
{
- DB * db = dbi->dbi_db;
-/*@i@*/ SQL_DB * sqldb = (SQL_DB *)db->app_private;
int rc = 0;
-assert(sqldb->db != NULL);
-
#ifndef SQL_FAST_DB
rc = sql_commitTransaction(dbi, 0);
#endif
/*@globals fileSystem @*/
/*@modifies dbi, *txnid, *dbcp, fileSystem @*/
{
- DB * db = dbi->dbi_db;
-/*@i@*/ SQL_DB * sqldb = (SQL_DB *)db->app_private;
DBC * dbcursor;
- SCP_t scp;
+ SCP_t scp = scpNew();
int rc = 0;
-assert(sqldb->db != NULL);
-
- scp = scpNew();
if (_debug)
fprintf(stderr, "==> %s(%s) tag %d type %d scp %p\n", __FUNCTION__, tagName(dbi->dbi_rpmtag), dbi->dbi_rpmtag, tagType(dbi->dbi_rpmtag), scp);
dbcursor = (DBC *)scp;
- dbcursor->dbp = db;
+ dbcursor->dbp = dbi->dbi_db;
/* If we're going to write, start a transaction (lock the DB) */
if (flags == DB_WRITECURSOR) {
/*@globals fileSystem @*/
/*@modifies *dbcursor, fileSystem @*/
{
- DB * db = dbi->dbi_db;
-/*@i@*/ SQL_DB * sqldb = (SQL_DB *)db->app_private;
+/*@i@*/ SQL_DB * sqldb = (SQL_DB *) dbi->dbi_db;
SCP_t scp = scpNew();
int rc = 0;
-assert(sqldb->db != NULL);
-
dbg_keyval(__FUNCTION__, dbi, dbcursor, key, data, flags);
scp->cmd = sqlite3_mprintf("DELETE FROM '%q' WHERE key=? AND value=?;",
/*@globals fileSystem @*/
/*@modifies dbi, dbcursor, *key, *data, fileSystem @*/
{
- DB * db = dbi->dbi_db;
-/*@i@*/ SQL_DB * sqldb = (SQL_DB *)db->app_private;
+/*@i@*/ SQL_DB * sqldb = (SQL_DB *) dbi->dbi_db;
SCP_t scp;
int rc = 0;
if (_debug)
fprintf(stderr, "\tcget(%s) size 0 key 0x%x[%d] flags %d\n",
dbi->dbi_subfile,
- key->data == NULL ? 0 : *(long *)key->data, key->size,
+ key->data == NULL ? 0 : *(unsigned int *)key->data, key->size,
flags);
/* Key's MUST be in order for the PACKAGES db! */
/* XXX FIXME: ptr alignment is fubar here. */
if (_debug)
fprintf(stderr, "\tcget(%s) default key 0x%x[%d], flags %d\n", dbi->dbi_subfile,
- key->data == NULL ? 0 : *(long *)key->data, key->size, flags);
+ key->data == NULL ? 0 : *(unsigned int *)key->data, key->size, flags);
switch (dbi->dbi_rpmtag) {
default:
/* XXX FIXME: ptr alignment is fubar here. */
if (_debug)
fprintf(stderr, "\tcget(%s) found key 0x%x (%d)\n", dbi->dbi_subfile,
- key->data == NULL ? 0 : *(long *)key->data, key->size);
+ key->data == NULL ? 0 : *(unsigned int *)key->data, key->size);
if (_debug)
fprintf(stderr, "\tcget(%s) found data 0x%x (%d)\n", dbi->dbi_subfile,
- key->data == NULL ? 0 : *(long *)data->data, data->size);
+ key->data == NULL ? 0 : *(unsigned int *)data->data, data->size);
}
}
/*@globals fileSystem @*/
/*@modifies *dbcursor, fileSystem @*/
{
- DB * db = dbi->dbi_db;
-/*@i@*/ SQL_DB * sqldb = (SQL_DB *)db->app_private;
+/*@i@*/ SQL_DB * sqldb = (SQL_DB *) dbi->dbi_db;
SCP_t scp = scpNew();
int rc = 0;
/*@globals fileSystem @*/
/*@modifies fileSystem @*/
{
- DB * db = dbi->dbi_db;
- SQL_DB * sqldb = (SQL_DB *)db->app_private;
+ SQL_DB * sqldb = (SQL_DB *) dbi->dbi_db;
SCP_t scp = scpNew();
int sql_rc, rc = 0;
union _dbswap db_endian;
/*@globals fileSystem @*/
/*@modifies dbi, fileSystem @*/
{
- DB * db = dbi->dbi_db;
-/*@i@*/ SQL_DB * sqldb = (SQL_DB *)db->app_private;
+/*@i@*/ SQL_DB * sqldb = (SQL_DB *) dbi->dbi_db;
SCP_t scp = scpNew();
int rc = 0;
long nkeys = -1;