src/sqlite.c - master - niceSOFT/createrepo_c

src/sqlite.c
1 724 строки47 KB
Aleš Matěj
Internally use package_internal.h to access cr_package fields
26 июн 2026, 17:40
26 июн 2026, 17:403a39893
/* createrepo_c - Library of routines for manipulation with repodata
 * Copyright (C) 2012      Tomas Mlcoch
 * Copyright (C) 2008-2011 James Antill
 * Copyright (C) 2006-2007 James Bowes
 * Copyright (C) 2006-2007 Paul Nasrat
 * Copyright (C) 2006      Tambet Ingo
 * Copyright (C) 2006-2010 Seth Vidal
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * as published by the Free Software Foundation; either version 2
 * of the License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301,
 * USA.
 */

#include <glib.h>
#include <assert.h>
#include <string.h>
#include <stdlib.h>
#include <sys/stat.h>
#include <errno.h>
#include <libxml/encoding.h>
#include <libxml/xmlstring.h>
#include "misc.h"
#include "sqlite.h"
#include "package_internal.h"
#include "error.h"
#include "xml_dump.h"

#define ERR_DOMAIN                  CREATEREPO_C_ERROR
#define ENCODED_PACKAGE_FILE_FILES  2048
#define ENCODED_PACKAGE_FILE_TYPES  60

struct _DbPrimaryStatements {
    sqlite3 *db;
    sqlite3_stmt *pkg_handle;
    sqlite3_stmt *provides_handle;
    sqlite3_stmt *conflicts_handle;
    sqlite3_stmt *obsoletes_handle;
    sqlite3_stmt *requires_handle;
    sqlite3_stmt *suggests_handle;
    sqlite3_stmt *enhances_handle;
    sqlite3_stmt *recommends_handle;
    sqlite3_stmt *supplements_handle;
    sqlite3_stmt *files_handle;
};

struct _DbFilelistsStatements {
    sqlite3 *db;
    sqlite3_stmt *package_id_handle;
    sqlite3_stmt *filelists_handle;
};

struct _DbOtherStatements {
    sqlite3 *db;
    sqlite3_stmt *package_id_handle;
    sqlite3_stmt *changelog_handle;
};

static inline int cr_sqlite3_bind_text(sqlite3_stmt *stmt, int i,
                                       const char *orig_content, int len,
                                       void(*desctructor)(void *))
{
    int ret;
    int free_content = 0;
    unsigned char *content;

    if (!orig_content) {
        content = (unsigned char *) orig_content;
    } else if (xmlCheckUTF8((const unsigned char *) orig_content)
               && !cr_hascontrollchars((const unsigned char *) orig_content)) {
        content = (unsigned char *) orig_content;
    } else {
        desctructor = SQLITE_TRANSIENT;
        size_t llen = strlen((const char *) orig_content);
        content = malloc(sizeof(unsigned char)*llen*2 + 1);
        cr_latin1_to_utf8((const unsigned char *) orig_content, content);
        free_content = 1;
    }

    ret = sqlite3_bind_text(stmt, i, (char *) content, len, desctructor);

    if (free_content)
        free(content);

    return ret;
}

/*
 * Base DB operation
 *  - Open db
 *  - Creation of tables
 *  - Tweaking of db settings
 *  - Creation of info table
 *  - Creation of index
 *  - Close db
 */

static sqlite3 *
open_sqlite_db(const char *path, GError **err)
{
    int rc;
    sqlite3 *db = NULL;

    assert(!err || *err == NULL);

    rc = sqlite3_open_v2(path, &db,
            SQLITE_OPEN_READWRITE|SQLITE_OPEN_CREATE|SQLITE_OPEN_SHAREDCACHE,
            NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                    "Can not open SQL database: %s", sqlite3_errmsg(db));
        sqlite3_close(db);
        db = NULL;
    }

    return db;
}


static void
db_create_dbinfo_table(sqlite3 *db, GError **err)
{
    int rc;
    const char *sql;

    assert(!err || *err == NULL);

    sql = "CREATE TABLE db_info (dbversion INTEGER, checksum TEXT)";
    rc = sqlite3_exec(db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                    "Can not create db_info table: %s",
                     sqlite3_errmsg (db));
    }
}


static void
db_create_primary_tables(sqlite3 *db, GError **err)
{
    int rc;
    const char *sql;

    assert(!err || *err == NULL);

    sql =
        "CREATE TABLE packages ("
        "  pkgKey INTEGER PRIMARY KEY,"
        "  pkgId TEXT,"
        "  name TEXT,"
        "  arch TEXT,"
        "  version TEXT,"
        "  epoch TEXT,"
        "  release TEXT,"
        "  summary TEXT,"
        "  description TEXT,"
        "  url TEXT,"
        "  time_file INTEGER,"
        "  time_build INTEGER,"
        "  rpm_license TEXT,"
        "  rpm_vendor TEXT,"
        "  rpm_group TEXT,"
        "  rpm_buildhost TEXT,"
        "  rpm_sourcerpm TEXT,"
        "  rpm_header_start INTEGER,"
        "  rpm_header_end INTEGER,"
        "  rpm_packager TEXT,"
        "  size_package INTEGER,"
        "  size_installed INTEGER,"
        "  size_archive INTEGER,"
        "  location_href TEXT,"
        "  location_base TEXT,"
        "  checksum_type TEXT)";

    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create packages table: %s",
                     sqlite3_errmsg (db));
        return;
    }

    sql =
        "CREATE TABLE files ("
        "  name TEXT,"
        "  type TEXT,"
        "  pkgKey INTEGER)";
    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create files table: %s",
                     sqlite3_errmsg (db));
        return;
    }

    sql =
        "CREATE TABLE %s ("
        "  name TEXT,"
        "  flags TEXT,"
        "  epoch TEXT,"
        "  version TEXT,"
        "  release TEXT,"
        "  pkgKey INTEGER %s)";

    const char *deps[] = { "requires", "provides", "conflicts", "obsoletes",
                            "suggests", "enhances", "recommends", "supplements",
                            NULL };
    int i;

    for (i = 0; deps[i]; i++) {
        const char *prereq;
        char *query;

        if (!strcmp(deps[i], "requires")) {
            prereq = ", pre BOOLEAN DEFAULT FALSE";
        } else
            prereq = "";

        query = g_strdup_printf (sql, deps[i], prereq);
        rc = sqlite3_exec (db, query, NULL, NULL, NULL);
        g_free (query);

        if (rc != SQLITE_OK) {
            g_set_error(err, ERR_DOMAIN, CRE_DB,
                         "Can not create %s table: %s",
                         deps[i], sqlite3_errmsg (db));
            return;
        }
    }

    sql =
        "CREATE TRIGGER removals AFTER DELETE ON packages"
        "  BEGIN"
        "    DELETE FROM files WHERE pkgKey = old.pkgKey;"
        "    DELETE FROM requires WHERE pkgKey = old.pkgKey;"
        "    DELETE FROM provides WHERE pkgKey = old.pkgKey;"
        "    DELETE FROM conflicts WHERE pkgKey = old.pkgKey;"
        "    DELETE FROM obsoletes WHERE pkgKey = old.pkgKey;"
        "    DELETE FROM suggests WHERE pkgKey = old.pkgKey;"
        "    DELETE FROM enhances WHERE pkgKey = old.pkgKey;"
        "    DELETE FROM recommends WHERE pkgKey = old.pkgKey;"
        "    DELETE FROM supplements WHERE pkgKey = old.pkgKey;"
        "  END;";

    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create removals trigger: %s",
                     sqlite3_errmsg (db));
        return;
    }
}


static void
db_create_filelists_tables(sqlite3 *db, GError **err)
{
    int rc;
    const char *sql;

    assert(!err || *err == NULL);

    sql =
        "CREATE TABLE packages ("
        "  pkgKey INTEGER PRIMARY KEY,"
        "  pkgId TEXT)";
    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create packages table: %s",
                     sqlite3_errmsg (db));
        return;
    }

    sql =
        "CREATE TABLE filelist ("
        "  pkgKey INTEGER,"
        "  dirname TEXT,"
        "  filenames TEXT,"
        "  filetypes TEXT)";
    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create filelist table: %s",
                     sqlite3_errmsg (db));
        return;
    }

    sql =
        "CREATE TRIGGER remove_filelist AFTER DELETE ON packages"
        "  BEGIN"
        "    DELETE FROM filelist WHERE pkgKey = old.pkgKey;"
        "  END;";

    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create remove_filelist trigger: %s",
                     sqlite3_errmsg (db));
        return;
    }
}


static void
db_create_other_tables (sqlite3 *db, GError **err)
{
    int rc;
    const char *sql;

    assert(!err || *err == NULL);

    sql =
        "CREATE TABLE packages ("
        "  pkgKey INTEGER PRIMARY KEY,"
        "  pkgId TEXT)";
    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create packages table: %s",
                     sqlite3_errmsg (db));
        return;
    }

    sql =
        "CREATE TABLE changelog ("
        "  pkgKey INTEGER,"
        "  author TEXT,"
        "  date INTEGER,"
        "  changelog TEXT)";
    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create changelog table: %s",
                     sqlite3_errmsg (db));
        return;
    }

    sql =
        "CREATE TRIGGER remove_changelogs AFTER DELETE ON packages"
        "  BEGIN"
        "    DELETE FROM changelog WHERE pkgKey = old.pkgKey;"
        "  END;";

    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create remove_changelogs trigger: %s",
                     sqlite3_errmsg (db));
        return;
    }
}


static void
db_tweak(sqlite3 *db, G_GNUC_UNUSED GError **err)
{
    assert(!err || *err == NULL);

    // Do not wait for disk writes to be fully
    // written to disk before continuing

    sqlite3_exec (db, "PRAGMA synchronous = OFF", NULL, NULL, NULL);

    sqlite3_exec (db, "PRAGMA journal_mode = MEMORY", NULL, NULL, NULL);

    sqlite3_exec (db, "PRAGMA temp_store = MEMORY", NULL, NULL, NULL);
}


static void
db_index_primary_tables (sqlite3 *db, GError **err)
{
    int rc;
    const char *sql;

    assert(!err || *err == NULL);

    sql = "CREATE INDEX IF NOT EXISTS packagename ON packages (name)";
    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create packagename index: %s",
                     sqlite3_errmsg (db));
        return;
    }

    sql = "CREATE INDEX IF NOT EXISTS packageId ON packages (pkgId)";
    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create packageId index: %s",
                     sqlite3_errmsg (db));
        return;
    }

    sql = "CREATE INDEX IF NOT EXISTS filenames ON files (name)";
    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create filenames index: %s",
                     sqlite3_errmsg (db));
        return;
    }

    sql = "CREATE INDEX IF NOT EXISTS pkgfiles ON files (pkgKey)";
    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create index on files table: %s",
                     sqlite3_errmsg (db));
        return;
    }

    int i;
    const char *deps[] = { "requires",
                           "provides",
                           "conflicts",
                           "obsoletes",
                           "suggests",
                           "enhances",
                           "recommends",
                           "supplements",
                           NULL
                         };

    const char *pkgindexsql = "CREATE INDEX IF NOT EXISTS pkg%s on %s (pkgKey)";
    const char *nameindexsql = "CREATE INDEX IF NOT EXISTS %sname ON %s (name)";

    for (i = 0; deps[i]; i++) {
        char *query;

        query = g_strdup_printf(pkgindexsql, deps[i], deps[i]);
        rc = sqlite3_exec (db, query, NULL, NULL, NULL);
        g_free (query);

        if (rc != SQLITE_OK) {
            g_set_error(err, ERR_DOMAIN, CRE_DB,
                         "Can not create index on %s table: %s",
                         deps[i], sqlite3_errmsg (db));
            return;
        }

        if (i < 2) {
            query = g_strdup_printf(nameindexsql, deps[i], deps[i]);
            rc = sqlite3_exec (db, query, NULL, NULL, NULL);
            g_free(query);
            if (rc != SQLITE_OK) {
                g_set_error(err, ERR_DOMAIN, CRE_DB,
                             "Can not create %sname index: %s",
                             deps[i], sqlite3_errmsg (db));
                return;
            }
        }
    }
}


static void
db_index_filelists_tables (sqlite3 *db, GError **err)
{
    int rc;
    const char *sql;

    assert(!err || *err == NULL);

    sql = "CREATE INDEX IF NOT EXISTS keyfile ON filelist (pkgKey)";
    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create keyfile index: %s",
                     sqlite3_errmsg (db));
        return;
    }

    sql = "CREATE INDEX IF NOT EXISTS pkgId ON packages (pkgId)";
    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create pkgId index: %s",
                     sqlite3_errmsg (db));
        return;
    }

    sql = "CREATE INDEX IF NOT EXISTS dirnames ON filelist (dirname)";
    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create dirnames index: %s",
                     sqlite3_errmsg (db));
        return;
    }
}


static void
db_index_other_tables (sqlite3 *db, GError **err)
{
    int rc;
    const char *sql;

    assert(!err || *err == NULL);

    sql = "CREATE INDEX IF NOT EXISTS keychange ON changelog (pkgKey)";
    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create keychange index: %s",
                     sqlite3_errmsg (db));
        return;
    }

    sql = "CREATE INDEX IF NOT EXISTS pkgId ON packages (pkgId)";
    rc = sqlite3_exec (db, sql, NULL, NULL, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not create pkgId index: %s",
                     sqlite3_errmsg (db));
        return;
    }
}


/*
 * Package insertion stuff
 */


int
cr_db_dbinfo_update(cr_SqliteDb *sqlitedb, const char *checksum, GError **err)
{
    int rc;
    sqlite3_stmt *handle;
    const char *query = "INSERT INTO db_info (dbversion, checksum) VALUES (?, ?)";

    assert(sqlitedb);
    assert(!err || *err == NULL);

    /* Prepare insert statement */
    rc = sqlite3_prepare_v2(sqlitedb->db, query, -1, &handle, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                    "Cannot prepare db_info update: %s",
                    sqlite3_errmsg(sqlitedb->db));
        g_critical("%s: Cannot prepare db_info update statement: %s",
                   __func__, sqlite3_errmsg(sqlitedb->db));
        sqlite3_finalize(handle);
        return CRE_DB;
    }

    /* Delete all previous content of db_info */
    sqlite3_exec(sqlitedb->db, "DELETE FROM db_info", NULL, NULL, NULL);

    /* Perform insert */
    sqlite3_bind_int(handle, 1, CR_DB_CACHE_DBVERSION);
    cr_sqlite3_bind_text(handle, 2, checksum, -1, SQLITE_STATIC);

    rc = sqlite3_step(handle);
    if (rc != SQLITE_DONE) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                      "Cannot update dbinfo table: %s",
                       sqlite3_errmsg (sqlitedb->db));
        g_critical("%s: Cannot update dbinfo table: %s",
                    __func__, sqlite3_errmsg(sqlitedb->db));
        return CRE_DB;
    }

    rc = sqlite3_finalize(handle);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                      "Cannot update dbinfo table: %s",
                       sqlite3_errmsg (sqlitedb->db));
        g_critical("%s: Cannot update dbinfo table: %s",
                    __func__, sqlite3_errmsg(sqlitedb->db));
        return CRE_DB;
    }

    return CRE_OK;
}


/*
 * primary.sqlite
 */


static sqlite3_stmt *
db_package_prepare (sqlite3 *db, GError **err)
{
    int rc;
    sqlite3_stmt *handle = NULL;
    const char *query;

    assert(!err || *err == NULL);

    query =
        "INSERT INTO packages ("
        "  pkgId, name, arch, version, epoch, release, summary, description,"
        "  url, time_file, time_build, rpm_license, rpm_vendor, rpm_group,"
        "  rpm_buildhost, rpm_sourcerpm, rpm_header_start, rpm_header_end,"
        "  rpm_packager, size_package, size_installed, size_archive,"
        "  location_href, location_base, checksum_type) "
        "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?,"
        "  ?, ?, ?, ?, ?, ?, ?)";

    rc = sqlite3_prepare_v2 (db, query, -1, &handle, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Cannot prepare packages insertion: %s",
                     sqlite3_errmsg (db));
        sqlite3_finalize (handle);
        handle = NULL;
    }

    return handle;
}


static inline const char *
prevent_null(const char *str)
{
    if (!str)
        return "";
    else
        return str;
}

static inline const char *
force_null(const char *str)
{
    if (!str || str[0] == '\0')
        return NULL;
    else
        return str;
}

static void
db_package_write (sqlite3 *db,
                  sqlite3_stmt *handle,
                  cr_Package *p,
                  GError **err)
{
    int rc;

    assert(!err || *err == NULL);

    cr_sqlite3_bind_text (handle, 1,  p->pkgId, -1, SQLITE_STATIC);
    cr_sqlite3_bind_text (handle, 2,  p->name, -1, SQLITE_STATIC);
    cr_sqlite3_bind_text (handle, 3,  p->arch, -1, SQLITE_STATIC);
    cr_sqlite3_bind_text (handle, 4,  p->version, -1, SQLITE_STATIC);
    cr_sqlite3_bind_text (handle, 5,  p->epoch, -1, SQLITE_STATIC);
    cr_sqlite3_bind_text (handle, 6,  p->release, -1, SQLITE_STATIC);
    cr_sqlite3_bind_text (handle, 7,  p->summary, -1, SQLITE_STATIC);
    cr_sqlite3_bind_text (handle, 8,  p->description, -1, SQLITE_STATIC);
    cr_sqlite3_bind_text (handle, 9,  force_null(p->url), -1, SQLITE_STATIC);  // {null}
    sqlite3_bind_int  (handle, 10, p->time_file);
    sqlite3_bind_int  (handle, 11, p->time_build);
    cr_sqlite3_bind_text (handle, 12, p->rpm_license, -1, SQLITE_STATIC);
    cr_sqlite3_bind_text (handle, 13, prevent_null(p->rpm_vendor), -1, SQLITE_STATIC);  // ""
    cr_sqlite3_bind_text (handle, 14, p->rpm_group, -1, SQLITE_STATIC);
    cr_sqlite3_bind_text (handle, 15, p->rpm_buildhost, -1, SQLITE_STATIC);
    cr_sqlite3_bind_text (handle, 16, prevent_null(p->rpm_sourcerpm), -1, SQLITE_STATIC); // ""
    sqlite3_bind_int  (handle, 17, p->rpm_header_start);
    sqlite3_bind_int  (handle, 18, p->rpm_header_end);
    cr_sqlite3_bind_text (handle, 19, force_null(p->rpm_packager), -1, SQLITE_STATIC);  // {null}
    sqlite3_bind_int64(handle, 20, p->size_package);
    sqlite3_bind_int64(handle, 21, p->size_installed);
    sqlite3_bind_int64(handle, 22, p->size_archive);
    cr_sqlite3_bind_text (handle, 23, p->location_href, -1, SQLITE_STATIC);
    cr_sqlite3_bind_text (handle, 24, force_null(p->location_base), -1, SQLITE_STATIC);  // {null}
    cr_sqlite3_bind_text (handle, 25, p->checksum_type, -1, SQLITE_STATIC);

    rc = sqlite3_step (handle);
    sqlite3_reset (handle);

    if (rc == SQLITE_DONE) {
        p->pkgKey = sqlite3_last_insert_rowid (db);
    } else {
        g_critical ("Error adding package to db: %s",
                    sqlite3_errmsg(db));
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                    "Error adding package to db: %s",
                    sqlite3_errmsg(db));
    }
}


static sqlite3_stmt *
db_dependency_prepare (sqlite3 *db, const char *table, GError **err)
{
    int rc;
    sqlite3_stmt *handle = NULL;
    char *query;

    const char *pre_name = "";
    const char *pre_value = "";

    assert(!err || *err == NULL);

    if (!strcmp (table, "requires")) {
        pre_name = ", pre";
        pre_value = ", ?";
    }

    query = g_strdup_printf
        ("INSERT INTO %s (name, flags, epoch, version, release, pkgKey%s) "
         "VALUES (?, ?, ?, ?, ?, ?%s)", table, pre_name, pre_value);

    rc = sqlite3_prepare_v2 (db, query, -1, &handle, NULL);
    g_free (query);

    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Cannot prepare dependency insertion: %s",
                     sqlite3_errmsg (db));
        sqlite3_finalize (handle);
        handle = NULL;
    }

    return handle;
}

static void
db_dependency_write (sqlite3 *db,
                     sqlite3_stmt *handle,
                     gint64 pkgKey,
                     cr_Dependency *dep,
                     gboolean isRequirement,
                     GError **err)
{
    int rc;

    assert(!err || *err == NULL);

    cr_sqlite3_bind_text (handle, 1, dep->name,    -1, SQLITE_STATIC);
    cr_sqlite3_bind_text (handle, 2, dep->flags,   -1, SQLITE_STATIC);
    cr_sqlite3_bind_text (handle, 3, dep->epoch,   -1, SQLITE_STATIC);
    cr_sqlite3_bind_text (handle, 4, dep->version, -1, SQLITE_STATIC);
    cr_sqlite3_bind_text (handle, 5, dep->release, -1, SQLITE_STATIC);
    sqlite3_bind_int  (handle, 6, pkgKey);

    if (isRequirement) {
        if (dep->pre)
            cr_sqlite3_bind_text (handle, 7, "TRUE", -1, SQLITE_TRANSIENT);
        else
            cr_sqlite3_bind_text (handle, 7, "FALSE", -1, SQLITE_TRANSIENT);
    }

    rc = sqlite3_step (handle);
    sqlite3_reset (handle);

    if (rc != SQLITE_DONE) {
        g_critical ("Error adding package dependency to db: %s",
                    sqlite3_errmsg (db));
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                    "Error adding package dependency to db: %s",
                    sqlite3_errmsg(db));
    }
}

static sqlite3_stmt *
db_file_prepare (sqlite3 *db, GError **err)
{
    int rc;
    sqlite3_stmt *handle = NULL;
    const char *query;

    assert(!err || *err == NULL);

    query = "INSERT INTO files (name, type, pkgKey) VALUES (?, ?, ?)";

    rc = sqlite3_prepare_v2 (db, query, -1, &handle, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not prepare file insertion: %s",
                     sqlite3_errmsg (db));
        sqlite3_finalize (handle);
        handle = NULL;
    }

    return handle;

}

static void
db_file_write (sqlite3 *db,
               sqlite3_stmt *handle,
               gint64 pkgKey,
               cr_PackageFile *file,
               GError **err)
{
    int rc;

    assert(!err || *err == NULL);

    gchar *fullpath = g_strconcat(file->path, file->name, NULL);
    if (!fullpath)
        return; // Nothing to do

    if (!cr_is_primary(fullpath)) {
        g_free(fullpath);
        return;
    }

    const char* file_type = file->type;
    if (!file_type || file_type[0] == '\0') {
        file_type = "file";
    }

    cr_sqlite3_bind_text (handle, 1, fullpath, -1, SQLITE_TRANSIENT);
    g_free(fullpath);
    cr_sqlite3_bind_text (handle, 2, file_type, -1, SQLITE_STATIC);
    sqlite3_bind_int  (handle, 3, pkgKey);

    rc = sqlite3_step (handle);
    sqlite3_reset (handle);

    if (rc != SQLITE_DONE) {
        g_critical ("Error adding package file to db: %s",
                    sqlite3_errmsg (db));
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                    "Error adding package file to db: %s",
                    sqlite3_errmsg(db));
    }
}


/*
 * filelists.sqlite
 */


static sqlite3_stmt *
db_filelists_prepare (sqlite3 *db, GError **err)
{
    int rc;
    sqlite3_stmt *handle = NULL;
    const char *query;

    assert(!err || *err == NULL);

    query =
        "INSERT INTO filelist (pkgKey, dirname, filenames, filetypes) "
        " VALUES (?, ?, ?, ?)";

    rc = sqlite3_prepare_v2 (db, query, -1, &handle, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not prepare filelist insertion: %s",
                     sqlite3_errmsg (db));
        sqlite3_finalize (handle);
        handle = NULL;
    }

    return handle;
}


typedef struct {
    GString *files;
    GString *types;
} EncodedPackageFile;


static EncodedPackageFile *
encoded_package_file_new (void)
{
    EncodedPackageFile *enc;

    enc = g_new0 (EncodedPackageFile, 1);
    enc->files = g_string_sized_new (ENCODED_PACKAGE_FILE_FILES);
    enc->types = g_string_sized_new (ENCODED_PACKAGE_FILE_TYPES);

    return enc;
}


static void
encoded_package_file_free (EncodedPackageFile *file)
{
    g_string_free (file->files, TRUE);
    g_string_free (file->types, TRUE);
    g_free (file);
}


static GHashTable *
package_files_to_hash (GSList *files)
{
    GHashTable *hash;
    GSList *iter;

    hash = g_hash_table_new_full (g_str_hash, g_str_equal,
                                  NULL,
                                  (GDestroyNotify) encoded_package_file_free);

    for (iter = files; iter; iter = iter->next) {
        cr_PackageFile *file;
        EncodedPackageFile *enc;
        char *dir;
        char *name;

        file = (cr_PackageFile *) iter->data;

        dir = file->path;
        name = file->name;

        enc = (EncodedPackageFile *) g_hash_table_lookup (hash, dir);
        if (!enc) {
            enc = encoded_package_file_new ();
            g_hash_table_insert (hash, dir, enc);
        }

        if (enc->files->len)
            g_string_append_c (enc->files, '/');

        if (!name || name[0] == '\0')
            // Root directory '/' has empty name
            g_string_append_c (enc->files, '/');
        else
            g_string_append (enc->files, name);


        if (!(file->type) || file->type[0] == '\0' || !strcmp (file->type, "file"))
            g_string_append_c (enc->types, 'f');
        else if (!strcmp (file->type, "dir"))
            g_string_append_c (enc->types, 'd');
        else if (!strcmp (file->type, "ghost"))
            g_string_append_c (enc->types, 'g');
    }

    return hash;
}


static void
cr_db_write_file (sqlite3 *db,
                  sqlite3_stmt *handle,
                  gint64 pkgKey,
                  gpointer key,
                  gpointer value,
                  GError **err)
{
    // key is a path to directory eg. "/etc/X11/xinit/xinitrc.d"
    // value is a struct eg. { .files="foo/bar/dir", .types="ffd"}

    int rc;
    size_t key_len;
    EncodedPackageFile *file = (EncodedPackageFile *) value;

    assert(!err || *err == NULL);

    key_len = strlen((const char *) key);
    while (key_len > 1 && ((char *) key)[key_len-1] == '/') {
        // Remove trailing '/' char(s)
        // If there are only '/' symbols leave only the first one
        key_len--;
    }

    if (key_len == 0) {
        // Same directory is represented by '.' in database
        key = ".";
        key_len = 1;
    }

    sqlite3_bind_int (handle, 1, pkgKey);
    cr_sqlite3_bind_text(handle, 2, (const char *) key, (int) key_len, SQLITE_STATIC);
    cr_sqlite3_bind_text(handle, 3, file->files->str, -1, SQLITE_STATIC);
    cr_sqlite3_bind_text(handle, 4, file->types->str, -1, SQLITE_STATIC);

    rc = sqlite3_step (handle);
    sqlite3_reset (handle);

    if (rc != SQLITE_DONE) {
        g_critical ("Error adding file records to db: %s",
                    sqlite3_errmsg (db));
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                    "Error adding file records to db : %s",
                     sqlite3_errmsg(db));
    }
}


/*
 * other.sqlite
 */


static sqlite3_stmt *
db_changelog_prepare (sqlite3 *db, GError **err)
{
    int rc;
    sqlite3_stmt *handle = NULL;
    const char *query;

    assert(!err || *err == NULL);

    query =
        "INSERT INTO changelog (pkgKey, author, date, changelog) "
        " VALUES (?, ?, ?, ?)";

    rc = sqlite3_prepare_v2 (db, query, -1, &handle, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not prepare changelog insertion: %s",
                     sqlite3_errmsg (db));
        sqlite3_finalize (handle);
        handle = NULL;
    }

    return handle;
}


// Stuff common for both filelists.sqlite and other.sqlite


static sqlite3_stmt *
db_package_ids_prepare(sqlite3 *db, GError **err)
{
    int rc;
    sqlite3_stmt *handle = NULL;
    const char *query;

    assert(!err || *err == NULL);

    query = "INSERT INTO packages (pkgId) VALUES (?)";
    rc = sqlite3_prepare_v2 (db, query, -1, &handle, NULL);
    if (rc != SQLITE_OK) {
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                     "Can not prepare package ids insertion: %s",
                      sqlite3_errmsg (db));
        sqlite3_finalize (handle);
        handle = NULL;
    }
    return handle;
}


static void
db_package_ids_write(sqlite3 *db,
                     sqlite3_stmt *handle,
                     cr_Package *pkg,
                     GError **err)
{
    int rc;

    assert(!err || *err == NULL);

    cr_sqlite3_bind_text (handle, 1,  pkg->pkgId, -1, SQLITE_STATIC);
    rc = sqlite3_step (handle);
    sqlite3_reset (handle);

    if (rc == SQLITE_DONE) {
        pkg->pkgKey = sqlite3_last_insert_rowid (db);
    } else {
        g_critical("Error adding package to db: %s",
                   sqlite3_errmsg(db));
        g_set_error(err, ERR_DOMAIN, CRE_DB,
                    "Error adding package to db: %s",
                    sqlite3_errmsg(db));
    }
}

/*
 * Module interface
 */


// Primary.sqlite interface

void
cr_db_destroy_primary_statements(cr_DbPrimaryStatements stmts)
{
    if (!stmts)
        return;

    if (stmts->pkg_handle)
        sqlite3_finalize(stmts->pkg_handle);
    if (stmts->provides_handle)
        sqlite3_finalize(stmts->provides_handle);
    if (stmts->conflicts_handle)
        sqlite3_finalize(stmts->conflicts_handle);
    if (stmts->obsoletes_handle)
        sqlite3_finalize(stmts->obsoletes_handle);
    if (stmts->requires_handle)
        sqlite3_finalize(stmts->requires_handle);
    if (stmts->suggests_handle)
        sqlite3_finalize(stmts->suggests_handle);
    if (stmts->enhances_handle)
        sqlite3_finalize(stmts->enhances_handle);
    if (stmts->recommends_handle)
        sqlite3_finalize(stmts->recommends_handle);
    if (stmts->supplements_handle)
        sqlite3_finalize(stmts->supplements_handle);
    if (stmts->files_handle)
        sqlite3_finalize(stmts->files_handle);
    free(stmts);
}


cr_DbPrimaryStatements
cr_db_prepare_primary_statements(sqlite3 *db, GError **err)
{
    assert(!err || *err == NULL);

    GError *tmp_err = NULL;
    cr_DbPrimaryStatements ret = malloc(sizeof(*ret));

    ret->db                 = db;
    ret->pkg_handle         = NULL;
    ret->provides_handle    = NULL;
    ret->conflicts_handle   = NULL;
    ret->obsoletes_handle   = NULL;
    ret->requires_handle    = NULL;
    ret->suggests_handle    = NULL;
    ret->enhances_handle    = NULL;
    ret->recommends_handle  = NULL;
    ret->supplements_handle = NULL;
    ret->files_handle       = NULL;

    ret->pkg_handle = db_package_prepare(db, &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        goto error;
    }

    ret->provides_handle = db_dependency_prepare(db, "provides", &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        goto error;
    }

    ret->conflicts_handle = db_dependency_prepare(db, "conflicts", &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        goto error;
    }

    ret->obsoletes_handle = db_dependency_prepare(db, "obsoletes", &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        goto error;
    }

    ret->requires_handle = db_dependency_prepare(db, "requires", &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        goto error;
    }

    ret->suggests_handle = db_dependency_prepare(db, "suggests", &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        goto error;
    }

    ret->enhances_handle = db_dependency_prepare(db, "enhances", &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        goto error;
    }

    ret->recommends_handle = db_dependency_prepare(db, "recommends", &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        goto error;
    }

    ret->supplements_handle = db_dependency_prepare(db, "supplements", &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        goto error;
    }

    ret->files_handle = db_file_prepare(db, &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        goto error;
    }

    return ret;

error:
    cr_db_destroy_primary_statements(ret);
    return NULL;
}


void
cr_db_add_primary_pkg(cr_DbPrimaryStatements stmts,
                      cr_Package *pkg,
                      GError **err)
{
    GError *tmp_err = NULL;
    GSList *iter;

    assert(!err || *err == NULL);

    db_package_write(stmts->db, stmts->pkg_handle, pkg, &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        return;
    }

    for (iter = pkg->provides; iter; iter = iter->next) {
        db_dependency_write(stmts->db,
                            stmts->provides_handle,
                            pkg->pkgKey,
                            (cr_Dependency *) iter->data,
                            FALSE,
                            &tmp_err);
        if (tmp_err) {
            g_propagate_error(err, tmp_err);
            return;
        }
    }

    for (iter = pkg->conflicts; iter; iter = iter->next) {
        db_dependency_write(stmts->db,
                            stmts->conflicts_handle,
                            pkg->pkgKey,
                            (cr_Dependency *) iter->data,
                            FALSE,
                            &tmp_err);
        if (tmp_err) {
            g_propagate_error(err, tmp_err);
            return;
        }
    }

    for (iter = pkg->obsoletes; iter; iter = iter->next) {
        db_dependency_write(stmts->db,
                            stmts->obsoletes_handle,
                            pkg->pkgKey,
                            (cr_Dependency *) iter->data,
                            FALSE,
                            &tmp_err);
        if (tmp_err) {
            g_propagate_error(err, tmp_err);
            return;
        }
    }

    for (iter = pkg->requires; iter; iter = iter->next) {
        db_dependency_write(stmts->db,
                            stmts->requires_handle,
                            pkg->pkgKey,
                            (cr_Dependency *) iter->data,
                            TRUE,
                            &tmp_err);
        if (tmp_err) {
            g_propagate_error(err, tmp_err);
            return;
        }
    }

    for (iter = pkg->suggests; iter; iter = iter->next) {
        db_dependency_write(stmts->db,
                            stmts->suggests_handle,
                            pkg->pkgKey,
                            (cr_Dependency *) iter->data,
                            TRUE,
                            &tmp_err);
        if (tmp_err) {
            g_propagate_error(err, tmp_err);
            return;
        }
    }

    for (iter = pkg->enhances; iter; iter = iter->next) {
        db_dependency_write(stmts->db,
                            stmts->enhances_handle,
                            pkg->pkgKey,
                            (cr_Dependency *) iter->data,
                            TRUE,
                            &tmp_err);
        if (tmp_err) {
            g_propagate_error(err, tmp_err);
            return;
        }
    }

    for (iter = pkg->recommends; iter; iter = iter->next) {
        db_dependency_write(stmts->db,
                            stmts->recommends_handle,
                            pkg->pkgKey,
                            (cr_Dependency *) iter->data,
                            TRUE,
                            &tmp_err);
        if (tmp_err) {
            g_propagate_error(err, tmp_err);
            return;
        }
    }

    for (iter = pkg->supplements; iter; iter = iter->next) {
        db_dependency_write(stmts->db,
                            stmts->supplements_handle,
                            pkg->pkgKey,
                            (cr_Dependency *) iter->data,
                            TRUE,
                            &tmp_err);
        if (tmp_err) {
            g_propagate_error(err, tmp_err);
            return;
        }
    }

    for (iter = pkg->files; iter; iter = iter->next) {
        db_file_write(stmts->db, stmts->files_handle, pkg->pkgKey,
                      (cr_PackageFile *) iter->data, &tmp_err);
        if (tmp_err) {
            g_propagate_error(err, tmp_err);
            return;
        }
    }
}


// filelists.sqlite interface


void
cr_db_destroy_filelists_statements(cr_DbFilelistsStatements stmts)
{
    if (!stmts)
        return;

    if (stmts->package_id_handle)
        sqlite3_finalize(stmts->package_id_handle);
    if (stmts->filelists_handle)
        sqlite3_finalize(stmts->filelists_handle);
    free(stmts);
}


cr_DbFilelistsStatements
cr_db_prepare_filelists_statements(sqlite3 *db, GError **err)
{
    GError *tmp_err = NULL;
    cr_DbFilelistsStatements ret = malloc(sizeof(*ret));

    assert(!err || *err == NULL);

    ret->db                = db;
    ret->package_id_handle = NULL;
    ret->filelists_handle  = NULL;

    ret->package_id_handle = db_package_ids_prepare(db, &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        goto error;
    }

    ret->filelists_handle = db_filelists_prepare(db, &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        goto error;
    }

    return ret;

error:
    cr_db_destroy_filelists_statements(ret);
    return NULL;
}


void
cr_db_add_filelists_pkg(cr_DbFilelistsStatements stmts,
                        cr_Package *pkg,
                        GError **err)
{
    GError *tmp_err = NULL;

    assert(!err || *err == NULL);

    // Add record into the package table
    db_package_ids_write(stmts->db, stmts->package_id_handle, pkg, &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        return;
    }

    // Add records into the filelist table
    GHashTable *hash;
    GHashTableIter iter;
    gpointer key, value;

    // Create a hashtable where:
    // key is a path to directory eg. "/etc/X11/xinit/xinitrc.d"
    // value is a struct eg. { .files="foo/bar/dir", .types="ffd"}
    hash = package_files_to_hash(pkg->files);
    g_hash_table_iter_init(&iter, hash);
    while (g_hash_table_iter_next (&iter, &key, &value)) {
        cr_db_write_file(stmts->db, stmts->filelists_handle, pkg->pkgKey, key, value, &tmp_err);
        if (tmp_err) {
            g_propagate_error(err, tmp_err);
            break;
        }
    }

    g_hash_table_destroy(hash);
}


// other.sqlite interface


void
cr_db_destroy_other_statements(cr_DbOtherStatements stmts)
{
    if (!stmts)
        return;

    if (stmts->package_id_handle)
        sqlite3_finalize(stmts->package_id_handle);
    if (stmts->changelog_handle)
        sqlite3_finalize(stmts->changelog_handle);
    free(stmts);
}


cr_DbOtherStatements
cr_db_prepare_other_statements(sqlite3 *db, GError **err)
{
    GError *tmp_err = NULL;
    cr_DbOtherStatements ret = malloc(sizeof(*ret));

    assert(!err || *err == NULL);

    ret->db                = db;
    ret->package_id_handle = NULL;
    ret->changelog_handle  = NULL;

    ret->package_id_handle = db_package_ids_prepare(db, &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        goto error;
    }

    ret->changelog_handle = db_changelog_prepare(db, &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        goto error;
    }

    return ret;

error:
    cr_db_destroy_other_statements(ret);
    return NULL;
}


void
cr_db_add_other_pkg(cr_DbOtherStatements stmts, cr_Package *pkg, GError **err)
{
    int rc;
    GSList *iter;
    cr_ChangelogEntry *entry;
    GError *tmp_err = NULL;

    assert(!err || *err == NULL);

    sqlite3_stmt *handle = stmts->changelog_handle;

    // Add package record into the packages table
    db_package_ids_write(stmts->db, stmts->package_id_handle, pkg, &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        return;
    }

    // Add changelog recrods into the changelog table
    for (iter = pkg->changelogs; iter; iter = iter->next) {
        entry = (cr_ChangelogEntry *) iter->data;

        sqlite3_bind_int  (handle, 1, pkg->pkgKey);
        cr_sqlite3_bind_text (handle, 2, entry->author, -1, SQLITE_STATIC);
        sqlite3_bind_int  (handle, 3, entry->date);
        cr_sqlite3_bind_text (handle, 4, entry->changelog, -1, SQLITE_STATIC);

        rc = sqlite3_step (handle);
        sqlite3_reset (handle);

        if (rc != SQLITE_DONE) {
            g_critical ("Error adding changelog to db: %s",
                        sqlite3_errmsg (stmts->db));
            g_set_error(err, ERR_DOMAIN, CRE_DB,
                        "Error adding changelog to db : %s",
                        sqlite3_errmsg(stmts->db));
            return;
        }
    }
}


// Function from header file (Public interface of the module)


cr_SqliteDb *
cr_db_open(const char *path, cr_DatabaseType db_type, GError **err)
{
    cr_SqliteDb *sqlitedb = NULL;
    int exists;
    sqlite3 *db = NULL;
    GError *tmp_err = NULL;
    void *statements;

    assert(path);
    assert(db_type < CR_DB_SENTINEL);
    assert(!err || *err == NULL);

    if (path[0] == '\0') {
        g_set_error(err, ERR_DOMAIN, CRE_BADARG, "Bad path: \"%s\"", path);
        return NULL;
    }

    exists = g_file_test(path, G_FILE_TEST_IS_REGULAR);
    if (exists) {
        struct stat stat_buf;
        if (stat(path, &stat_buf) == -1) {
            g_set_error(err, ERR_DOMAIN, CRE_IO,
                        "Cannot stat %s: %s", path, g_strerror(errno));
            return NULL;
        }

        if (stat_buf.st_size == 0)
            // File exists, but is just a placeholder created by g_mkstemp()
            // because --local-sqlite option was used
            exists = FALSE;
    }

    db = open_sqlite_db(path, &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        return NULL;
    }

    sqlite3_exec(db, "BEGIN", NULL, NULL, NULL);

    db_tweak(db, &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        sqlite3_close(db);
        return NULL;
    }

    db_create_dbinfo_table(db, &tmp_err);
    if (tmp_err) {
        g_propagate_error(err, tmp_err);
        sqlite3_close(db);
        return NULL;
    }

    if (!exists) {
        // Do not recreate tables, indexes and triggers if db has existed.
        switch (db_type) {
            case CR_DB_PRIMARY:
                db_create_primary_tables(db, &tmp_err);
                break;
            case CR_DB_FILELISTS:
                db_create_filelists_tables(db, &tmp_err);
                break;
            case CR_DB_OTHER:
                db_create_other_tables(db, &tmp_err);
                break;
            default:
                g_critical("%s: Bad db_type", __func__);
                assert(0);
                g_set_error(err, ERR_DOMAIN, CRE_ASSERT, "Bad db type");
                return NULL;
        }

        if (tmp_err) {
            g_propagate_error(err, tmp_err);
            sqlite3_close(db);
            return NULL;
        }
    }

    // Compile SQL statements
    switch (db_type) {
        case CR_DB_PRIMARY:
            statements = cr_db_prepare_primary_statements(db, &tmp_err);
            break;
        case CR_DB_FILELISTS:
            statements = cr_db_prepare_filelists_statements(db, &tmp_err);
            break;
        case CR_DB_OTHER:
            statements = cr_db_prepare_other_statements(db, &tmp_err);
            break;
        default:
            g_critical("%s: Bad db_type", __func__);
            assert(0);
            g_set_error(err, ERR_DOMAIN, CRE_ASSERT, "Bad db type");
            return NULL;
    }

    if (!statements) {
            g_propagate_error(err, tmp_err);
            sqlite3_close(db);
            return NULL;
    }

    sqlitedb       = g_new0(cr_SqliteDb, 1);
    sqlitedb->db   = db;
    sqlitedb->type = db_type;

    switch (db_type) {
        case CR_DB_PRIMARY:
            sqlitedb->statements.pri = statements;
            break;
        case CR_DB_FILELISTS:
            sqlitedb->statements.fil = statements;
            break;
        case CR_DB_OTHER:
            sqlitedb->statements.oth = statements;
            break;
        default:
            g_critical("%s: Bad db_type", __func__);
            assert(0);
            g_set_error(err, ERR_DOMAIN, CRE_ASSERT, "Bad db type");
            return NULL;
    }

    return sqlitedb;
}


int
cr_db_close(cr_SqliteDb *sqlitedb, GError **err)
{
    GError *tmp_err = NULL;

    assert(!err || *err == NULL);

    if (!sqlitedb)
        return CRE_OK;

    switch (sqlitedb->type) {
        case CR_DB_PRIMARY:
            db_index_primary_tables(sqlitedb->db, &tmp_err);
            cr_db_destroy_primary_statements(sqlitedb->statements.pri);
            break;
        case CR_DB_FILELISTS:
            db_index_filelists_tables(sqlitedb->db, &tmp_err);
            cr_db_destroy_filelists_statements(sqlitedb->statements.fil);
            break;
        case CR_DB_OTHER:
            db_index_other_tables(sqlitedb->db, &tmp_err);
            cr_db_destroy_other_statements(sqlitedb->statements.oth);
            break;
        default:
            g_critical("%s: Bad db type", __func__);
            assert(0);
            g_set_error(err, ERR_DOMAIN, CRE_ASSERT, "Bad db type");
            return CRE_ASSERT;
    }

    if (tmp_err) {
        int code = tmp_err->code;
        g_propagate_error(err, tmp_err);
        return code;
    }

    sqlite3_exec (sqlitedb->db, "COMMIT", NULL, NULL, NULL);
    sqlite3_close(sqlitedb->db);

    g_free(sqlitedb);

    return CRE_OK;
}


int
cr_db_add_pkg(cr_SqliteDb *sqlitedb, cr_Package *pkg, GError **err)
{
    GError *tmp_err = NULL;

    assert(sqlitedb);
    assert(sqlitedb->type < CR_DB_SENTINEL);
    assert(!err || *err == NULL);

    if (!pkg)
        return CRE_OK;

    switch (sqlitedb->type) {
    case CR_DB_PRIMARY:
        cr_db_add_primary_pkg(sqlitedb->statements.pri, pkg, &tmp_err);
        break;
    case CR_DB_FILELISTS:
        cr_db_add_filelists_pkg(sqlitedb->statements.fil, pkg, &tmp_err);
        break;
    case CR_DB_OTHER:
        cr_db_add_other_pkg(sqlitedb->statements.oth, pkg, &tmp_err);
        break;
    default:
        g_critical("%s: Bad db type", __func__);
        assert(0);
        g_set_error(err, ERR_DOMAIN, CRE_ASSERT, "Bad db type");
        return CRE_ASSERT;
    }

    if (tmp_err) {
        int code = tmp_err->code;
        g_propagate_error(err, tmp_err);
        return code;
    }

    return CRE_OK;
}