Rework db insertion code

[platform/core/appfw/pkgmgr-info.git] / src / pkgmgrinfo_db.c

diff --git a/src/pkgmgrinfo_db.c b/src/pkgmgrinfo_db.c
index 7af6e71..27ea246 100644 (file)
--- a/src/pkgmgrinfo_db.c
+++ b/src/pkgmgrinfo_db.c
@@ -19,78 +19,7 @@
 #include "pkgmgrinfo_debug.h"
 #include "pkgmgrinfo_private.h"
 #include "pkgmgr_parser.h"
-
-#define QUERY_CREATE_TABLE_PACKAGE_CERT_INDEX_INFO \
-       "CREATE TABLE IF NOT EXISTS package_cert_index_info( " \
-       " cert_info TEXT UNIQUE, " \
-       " cert_id INTEGER PRIMARY KEY, " \
-       " cert_ref_count INTEGER NOT NULL)"
-
-#define QUERY_CREATE_TABLE_PACKAGE_CERT_INFO \
-       "CREATE TABLE IF NOT EXISTS package_cert_info( " \
-       " package TEXT PRIMARY KEY, " \
-       " package_count INTEGER, " \
-       " author_root_cert INTEGER, " \
-       " author_im_cert INTEGER, " \
-       " author_signer_cert INTEGER, " \
-       " dist_root_cert INTEGER, " \
-       " dist_im_cert INTEGER, " \
-       " dist_signer_cert INTEGER, " \
-       " dist2_root_cert INTEGER, " \
-       " dist2_im_cert INTEGER, " \
-       " dist2_signer_cert INTEGER)"
-
-#define QUERY_CREATE_TRIGGER_UPDATE_CERT_INFO \
-       "CREATE TRIGGER IF NOT EXISTS update_cert_info " \
-       "AFTER UPDATE ON package_cert_info " \
-       "WHEN (NEW.package_count = 0) " \
-       "BEGIN" \
-       " DELETE FROM package_cert_info WHERE package=OLD.package;" \
-       "END;"
-
-#define QUERY_CREATE_TRIGGER_UPDATE_CERT_INFO2 \
-       "CREATE TRIGGER IF NOT EXISTS update_cert_info2 " \
-       "AFTER UPDATE ON package_cert_info " \
-       "WHEN (NEW.package_count = OLD.package_count + 1) " \
-       "BEGIN" \
-       " UPDATE package_cert_index_info SET" \
-       "  cert_ref_count = cert_ref_count - 1" \
-       " WHERE cert_id = OLD.author_root_cert" \
-       "  OR cert_id = OLD.author_im_cert" \
-       "  OR cert_id = OLD.author_signer_cert" \
-       "  OR cert_id = OLD.dist_root_cert" \
-       "  OR cert_id = OLD.dist_im_cert" \
-       "  OR cert_id = OLD.dist_signer_cert" \
-       "  OR cert_id = OLD.dist2_root_cert" \
-       "  OR cert_id = OLD.dist2_im_cert" \
-       "  OR cert_id = OLD.dist2_signer_cert;" \
-       "END;"
-
-#define QUERY_CREATE_TRIGGER_DELETE_CERT_INFO \
-       "CREATE TRIGGER IF NOT EXISTS delete_cert_info " \
-       "AFTER DELETE ON package_cert_info " \
-       "BEGIN" \
-       " UPDATE package_cert_index_info SET" \
-       "  cert_ref_count = cert_ref_count - 1" \
-       " WHERE cert_id = OLD.author_root_cert" \
-       "  OR cert_id = OLD.author_im_cert" \
-       "  OR cert_id = OLD.author_signer_cert" \
-       "  OR cert_id = OLD.dist_root_cert" \
-       "  OR cert_id = OLD.dist_im_cert" \
-       "  OR cert_id = OLD.dist_signer_cert" \
-       "  OR cert_id = OLD.dist2_root_cert" \
-       "  OR cert_id = OLD.dist2_im_cert" \
-       "  OR cert_id = OLD.dist2_signer_cert;" \
-       "END;"
-
-#define QUERY_CREATE_TRIGGER_UPDATE_CERT_INDEX_INFO \
-       "CREATE TRIGGER IF NOT EXISTS update_cert_index_info " \
-       "AFTER UPDATE ON package_cert_index_info " \
-       "WHEN ((SELECT cert_ref_count FROM package_cert_index_info " \
-       "       WHERE cert_id = OLD.cert_id) = 0) "\
-       "BEGIN" \
-       " DELETE FROM package_cert_index_info WHERE cert_id = OLD.cert_id;" \
-       "END;"
+#include "pkgmgr_parser_db.h"
 
 __thread db_handle manifest_db;
 __thread db_handle cert_db;
@@ -214,41 +143,11 @@ static int __attach_and_create_view(sqlite3 *handle, const char *db, const char
        return SQLITE_OK;
 }
 
-static int __exec_db_query(sqlite3 *db, char *query, sqlite_query_callback callback, void *data)
+int _check_create_cert_db(void)
 {
-       char *error_message = NULL;
-       int ret = sqlite3_exec(db, query, callback, data, &error_message);
-       if (SQLITE_OK != ret) {
-               _LOGE("Don't execute query = %s error message = %s   ret = %d\n", query,
-                      error_message, ret);
-               sqlite3_free(error_message);
-               return -1;
-       }
-       sqlite3_free(error_message);
-       return 0;
+       return pkgmgr_parser_initialize_cert_db();
 }
 
-int _check_create_cert_db(sqlite3 *certdb)
-{
-       int ret = 0;
-       ret = __exec_db_query(certdb, QUERY_CREATE_TABLE_PACKAGE_CERT_INDEX_INFO, NULL, NULL);
-       if (ret < 0)
-               return ret;
-       ret = __exec_db_query(certdb, QUERY_CREATE_TABLE_PACKAGE_CERT_INFO, NULL, NULL);
-       if (ret < 0)
-               return ret;
-       ret = __exec_db_query(certdb, QUERY_CREATE_TRIGGER_UPDATE_CERT_INFO, NULL, NULL);
-       if (ret < 0)
-               return ret;
-       ret = __exec_db_query(certdb, QUERY_CREATE_TRIGGER_UPDATE_CERT_INFO2, NULL, NULL);
-       if (ret < 0)
-               return ret;
-       ret = __exec_db_query(certdb, QUERY_CREATE_TRIGGER_DELETE_CERT_INFO, NULL, NULL);
-       if (ret < 0)
-               return ret;
-       ret = __exec_db_query(certdb, QUERY_CREATE_TRIGGER_UPDATE_CERT_INDEX_INFO, NULL, NULL);
-       return ret;
-}
 static gid_t _get_gid(const char *name)
 {
        char buf[BUFSIZE];