X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=NativeLauncher%2Ftool%2Ftac_installer.cc;h=88d7953a871d7d347756b7839be16035fd3f1c2a;hb=83b3a27a7b9f93fd8852b4dc64e9a3a713ca53d8;hp=6bf9b571ca46a0424d4d0d9cd9375c2d4a23ff38;hpb=33b4aa2fcbb716d081fc13ac6855fc53bd343532;p=platform%2Fcore%2Fdotnet%2Flauncher.git

diff --git a/NativeLauncher/tool/tac_installer.cc b/NativeLauncher/tool/tac_installer.cc
index 6bf9b57..88d7953 100644
--- a/NativeLauncher/tool/tac_installer.cc
+++ b/NativeLauncher/tool/tac_installer.cc
@@ -19,6 +19,7 @@
 #include "db_manager.h"
 #include "tac_common.h"
 #include "tac_installer.h"
+#include "tac_db.h"
 
 #include <cstring>
 #include <fstream>
@@ -45,11 +46,10 @@ static std::vector<std::string> tacDB;
 static std::vector<std::string> createDirectories;
 static std::vector<std::string> createLibraries;
 static std::vector<std::string> updateTac;
+static std::vector<std::string> updateTlc;
 static tac_state tacState = TAC_STATE_NONE;
-static sqlite3 *tac_db = NULL;
-static sqlite3 *tlc_db = NULL;
-static bool tacPluginInstalled = false;
-static bool tacPluginFinished = false;
+static std::string prevInstallPkgId = std::string("");
+static std::string prevFinishPkgId = std::string("");
 
 static void createSHA256Info(std::string sha256Info, std::string nugetPackage)
 {
@@ -168,7 +168,7 @@ static bool copyAssemblyCreateSymlink(std::string binPath, std::string tacDir, s
 	return nuget_restoration;
 }
 
-static void copyLibraryCreateSymlink(const std::string pkgId, std::vector<std::string> LibrariesInfo, std::string tlcDir)
+static void copyLibraryCreateSymlink(const std::string pkgId, std::vector<std::string> LibrariesInfo)
 {
 	if (LibrariesInfo.empty()) {
 		return;
@@ -178,47 +178,44 @@ static void copyLibraryCreateSymlink(const std::string pkgId, std::vector<std::s
 		std::string library = librarySha.substr(0, librarySha.find(':'));
 		std::string filename = library.substr(library.rfind('/') + 1);
 		std::string fileSha = filename + ".." + librarySha.substr(librarySha.find(':') + 1);
+		std::string shaPath = concatPath(TLC_LIBRARIES_DIR, fileSha);
 		bool fileCopied = false;
-		if (!exist(concatPath(tlcDir, fileSha))) {
-			if (!copyFile(library, concatPath(tlcDir, fileSha))) {
+		if (!exist(shaPath)) {
+			if (!copyFile(library, shaPath)) {
 				_ERR("Failed to copy of %s", filename.c_str());
 				continue;
 			}
 			fileCopied = true;
-			createLibraries.push_back(concatPath(tlcDir, fileSha));
+			createLibraries.push_back(shaPath);
 		}
 		if (!removeFile(library)) {
 			_ERR("Failed to remove of %s", library.c_str());
 			if (fileCopied) {
-				removeFile(concatPath(tlcDir, fileSha));
+				removeFile(shaPath);
 			}
 			continue;
 		}
 		bs::error_code error;
-		bf::create_symlink(concatPath(tlcDir, fileSha), library, error);
+		bf::create_symlink(shaPath, library, error);
 		if (error) {
 			_ERR("Failed to create symlink %s file", library.c_str());
-			copyFile(concatPath(tlcDir, fileSha), library);
+			copyFile(shaPath, library);
 			copySmackAndOwnership(getBaseName(library), library);
 			if (fileCopied) {
-				removeFile(concatPath(tlcDir, fileSha));
+				removeFile(shaPath);
 			}
 			continue;
 		}
 		copySmackAndOwnership(getBaseName(library), library, true);
 
-		char *sql = sqlite3_mprintf("INSERT INTO TLC (PKGID, LIBRARY) VALUES (%Q, %Q);", pkgId.c_str(), fileSha.c_str());
-		if (!insertDB(tlc_db, sql)) {
-			_ERR("Sqlite insert error");
-			sqlite3_free(sql);
-			copyFile(concatPath(tlcDir, fileSha), library);
+		if (tlc_insertDB(pkgId, fileSha) != 0) {
+			copyFile(shaPath, library);
 			copySmackAndOwnership(getBaseName(library), library);
 			if (fileCopied) {
-				removeFile(concatPath(tlcDir, fileSha));
+				removeFile(shaPath);
 			}
 			continue;
 		}
-		sqlite3_free(sql);
 	}
 }
 
@@ -236,70 +233,14 @@ static void checkDepsJson(std::string rootPath, std::string binPath, std::string
 	tacDB.erase(unique(tacDB.begin(), tacDB.end()), tacDB.end());
 }
 
-int tacInstall(const std::string& pkgId, tac_state state, bool tacForce)
+static int generateTAC(const std::string& pkgId, const std::string& binPath)
 {
-	_DBG("[===== PKGMGR_MDPARSER_PLUGIN_INSTALL =====]");
-	_INFO("PackageID : %s", pkgId.c_str());
-
-	// Can be multiple apps in one package
-	if (tacPluginInstalled) {
-		_INFO("TAC plugin already installed");
-		return 0;
-	}
-	tacPluginInstalled = true;
-
-	std::string appType = getAppType(pkgId);
-	if (strstr(appType.c_str(), "dotnet") == NULL) {
-		_ERR("App type is not dotnet");
-		return 0;
-	}
-	std::string execName = getExecName(pkgId);
-	std::string rootPath = getRootPath(pkgId);
-	if (execName.empty() || rootPath.empty()) {
-		return 0;
-	}
-
-	std::string binPath = concatPath(rootPath, "bin");
-	if (exist(concatPath(binPath, PRE_COMPILED_PACKAGE_FILE))) {
-		_INFO("The %s is a Pre-Compiled package. So, skip the TAC", pkgId.c_str());
-		return 0;
-	}
-
-	std::string metaValue = getMetadataValue(pkgId, TAC_METADATA_KEY);
-	if (!tacForce) {
-		if (metaValue.empty()) {
-			return 0;
-		}
-	}
-	if (metaValue == METADATA_VALUE_TRUE || tacForce) {
-		checkDepsJson(rootPath, binPath, execName);
-	}
-
-	tacState = state;
-	if (tacDB.empty()) {
-		return 0;
-	}
-
-	tac_db = createDB(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
-	if (!tac_db) {
-		_ERR("Sqlite create error. So restore the database.");
-		if (tac_restoreDB() != TAC_ERROR_NONE) {
-			_ERR("Sqlite create error");
-			return -1;
-		}
-		tac_db = createDB(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
-		if (!tac_db) {
-			_ERR("Sqlite create error");
-			return -1;
-		}
-	}
-	sqlite3_exec(tac_db, "BEGIN;", NULL, NULL, NULL);
-
 	std::string tac_dir = concatPath(binPath, TAC_SYMLINK_SUB_DIR);
 	if (!createDir(tac_dir)) {
 		_ERR("Cannot create directory: %s", tac_dir.c_str());
 		return 0;
 	}
+
 	copySmackAndOwnership(binPath.c_str(), tac_dir.c_str());
 
 	for (auto& np : tacDB) {
@@ -311,179 +252,200 @@ int tacInstall(const std::string& pkgId, tac_state state, bool tacForce)
 		bs::error_code error;
 		std::string tac_version_dir = concatPath(__DOTNET_DIR, np);
 		std::string sha256_info = concatPath(tac_version_dir, TAC_SHA_256_INFO);
+		bool isCreateTacDir = false;
 		if (!exist(tac_version_dir)) {
 			_INFO("Create tac_version_dir [%s]", tac_version_dir.c_str());
+
 			if (!createDir(tac_version_dir)) {
 				_ERR("Cannot create directory: %s", tac_version_dir.c_str());
 				tacState = TAC_STATE_RESTORE;
 				return -1;
 			}
 			createDirectories.push_back(tac_version_dir);
-			if (!isSymlinkFile(sha256_info)) {
-				createSHA256Info(sha256_info, np);
-			} else {
+
+			if (isSymlinkFile(sha256_info)) {
 				_ERR("Failed to create sha256_info. Symbolic link is detected");
 				tacState = TAC_STATE_RESTORE;
 				return -1;
 			}
 
-			if (!exist(sha256_info)) {
-				tacState = TAC_STATE_RESTORE;
-				return -1;
-			}
+			createSHA256Info(sha256_info, np);
 
-			if (copyAssemblyCreateSymlink(binPath, tac_dir, np, true)) {
-				_ERR("Failed to create symlink");
+			if (!exist(sha256_info)) {
 				tacState = TAC_STATE_RESTORE;
 				return -1;
 			}
 
-			char *sql = sqlite3_mprintf(
-				"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
-				"VALUES (%Q, %Q, %Q, %Q);", pkgId.c_str(), np.c_str(), tac_name.c_str(), tac_version.c_str());
-			if (!insertDB(tac_db, sql)) {
-				_ERR("Sqlite insert error");
-				sqlite3_free(sql);
-				tacState = TAC_STATE_RESTORE;
-				return -1;
-			}
-			sqlite3_free(sql);
+			isCreateTacDir = true;
 		} else {
 			_INFO("Exists tac_version_dir [%s]", tac_version_dir.c_str());
-			if (!isSymlinkFile(sha256_info)) {
-				if (compareSHA256Info(sha256_info, np)) {
-					if (copyAssemblyCreateSymlink(binPath, tac_dir, np, false)) {
-						_ERR("Failed to create symlink");
-						tacState = TAC_STATE_RESTORE;
-						return -1;
-					}
 
-					char *sql = sqlite3_mprintf(
-						"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
-						"VALUES (%Q, %Q, %Q, %Q);", pkgId.c_str(), np.c_str(), tac_name.c_str(), tac_version.c_str());
-					if (!insertDB(tac_db, sql)) {
-						_ERR("Sqlite insert error");
-						sqlite3_free(sql);
-						tacState = TAC_STATE_RESTORE;
-						return -1;
-					}
-					sqlite3_free(sql);
-				} else {
-					_INFO("Different nuget : %s", np.c_str());
-					continue;
-				}
-			} else {
+			if (isSymlinkFile(sha256_info)) {
 				_ERR("Failed to create sha256_info. Symbolic link is detected");
 				tacState = TAC_STATE_RESTORE;
 				return -1;
 			}
-		}
-	}
 
-	///// TLC /////
-	std::string tlcDir = concatPath(__DOTNET_DIR, TLC_LIBRARIES_DIR);
-	if (!createDir(tlcDir)) {
-		_ERR("Cannot create directory: %s", tlcDir.c_str());
-		return 0;
-	}
-	copySmackAndOwnership(__DOTNET_DIR, tlcDir);
+			if (!compareSHA256Info(sha256_info, np)) {
+				_INFO("Different nuget : %s", np.c_str());
+				continue;
+			}
 
-	tlc_db = createDB(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
-	if (!tlc_db) {
-		_ERR("Sqlite create error. So restore the database.");
-		if (tlc_restoreDB() != TAC_ERROR_NONE) {
-			_ERR("Sqlite create error");
-			return 0;
+			isCreateTacDir = false;
 		}
-		tlc_db = createDB(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
-		if (!tlc_db) {
-			_ERR("Sqlite create error");
-			return 0;
-		}
-	}
-	sqlite3_exec(tlc_db, "BEGIN;", NULL, NULL, NULL);
-
-	copyLibraryCreateSymlink(pkgId, getLibrariesInfo(rootPath), tlcDir);
 
-	return 0;
-}
+		if (copyAssemblyCreateSymlink(binPath, tac_dir, np, isCreateTacDir)) {
+			_ERR("Failed to create symlink");
+			tacState = TAC_STATE_RESTORE;
+			return -1;
+		}
 
-static int sqliteCb(void *count, int argc, char **argv, char **colName)
-{
-	int *c = (int*)count;
-	*c = atoi(argv[0]);
+		if (tacState == TAC_STATE_INSTALL) {
+			if (tac_insertDB(pkgId, np, tac_name, tac_version) != 0) {
+				tacState = TAC_STATE_RESTORE;
+				return -1;
+			}
+		} else if (tacState == TAC_STATE_UPGRADE) {
+			int count = -1;
+			if (tac_countDB(pkgId, tac_name, "", count) != 0) {
+				tacState = TAC_STATE_RESTORE;
+				return -1;
+			}
+			if (count == 1) {
+				if (tac_updateDB(pkgId, np, tac_name, tac_version) != 0) {
+					tacState = TAC_STATE_RESTORE;
+					return -1;
+				}
+			} else if (count == 0) {
+				if (tac_insertDB(pkgId, np, tac_name, tac_version) != 0) {
+					tacState = TAC_STATE_RESTORE;
+					return -1;
+				}
+			}
+		}
+	}
 	return 0;
 }
 
-static void tac_updateDB(sqlite3 *sqlite)
+void tacUpdateDB(const std::string& pkgId)
 {
 	for (auto& unp : updateTac) {
 		int count = -1;
-		char *sql = sqlite3_mprintf("SELECT COUNT(NUGET) FROM TAC WHERE NUGET = %Q;", unp.c_str());
-		int ret = sqlite3_exec(sqlite, sql, sqliteCb, &count, NULL);
-		if (ret != SQLITE_OK) {
-			_ERR("Sqlite select error");
-			sqlite3_free(sql);
+		if (tac_countDB(pkgId, "", unp, count) != 0) {
 			continue;
 		}
+
 		if (count == 0) {
 			std::string tac_version_dir_prev = concatPath(__DOTNET_DIR, unp);
 			std::string tac_version_dir_backup = tac_version_dir_prev + ".bck";
 			if (!copyDir(tac_version_dir_prev, tac_version_dir_backup)) {
 				_ERR("Failed to copy of %s to %s", tac_version_dir_prev.c_str(), tac_version_dir_backup.c_str());
-				sqlite3_free(sql);
 				continue;
 			}
 			if (!removeAll(tac_version_dir_prev)) {
 				_ERR("Failed to remove of %s", tac_version_dir_prev.c_str());
-				sqlite3_free(sql);
 				continue;
 			}
 		}
-		sqlite3_free(sql);
 	}
 }
 
-static void tlc_updateDB(sqlite3 *sqlite, std::vector<std::string> updateTlc, std::string tlcDir)
+void tlcUpdateDB(const std::string& pkgId)
 {
 	for (auto& ulp : updateTlc) {
 		int count = -1;
-		char *sql = sqlite3_mprintf("SELECT COUNT(LIBRARY) FROM TLC WHERE LIBRARY = %Q;", ulp.c_str());
-		int ret = sqlite3_exec(sqlite, sql, sqliteCb, &count, NULL);
-		if (ret != SQLITE_OK) {
-			_ERR("Sqlite select error");
-			sqlite3_free(sql);
+		if (tlc_countDB(pkgId, ulp, count) != 0) {
 			continue;
 		}
+
 		if (count == 0) {
-			std::string library_prev = concatPath(tlcDir, ulp);
+			std::string library_prev = concatPath(TLC_LIBRARIES_DIR, ulp);
 			std::string library_backup = library_prev + ".bck";
 			if (!copyFile(library_prev, library_backup)) {
 				_ERR("Failed to copy of %s", library_prev.c_str());
-				sqlite3_free(sql);
 				continue;
 			}
 			if (!removeFile(library_prev)) {
 				_ERR("Failed to remove of %s", library_prev.c_str());
-				sqlite3_free(sql);
 				continue;
 			}
 		}
-		sqlite3_free(sql);
 	}
 }
 
+int tacInstall(const std::string& pkgId, tac_state state, bool tacForce)
+{
+	_DBG("[===== PKGMGR_MDPARSER_PLUGIN_INSTALL =====]");
+	_INFO("PackageID : %s", pkgId.c_str());
+
+	// Can be multiple apps in one package
+	if (strcmp(pkgId.c_str(), prevInstallPkgId.c_str()) == 0) {
+		_INFO("TAC Plugin(INSTALL) already run for same pkgId (%s)", pkgId.c_str());
+		return 0;
+	}
+	prevInstallPkgId = pkgId;
+
+	std::string appType = getAppType(pkgId);
+	if (strstr(appType.c_str(), "dotnet") == NULL) {
+		_ERR("App type is not dotnet");
+		return 0;
+	}
+	std::string execName = getExecName(pkgId);
+	std::string rootPath = getRootPath(pkgId);
+	if (execName.empty() || rootPath.empty()) {
+		return 0;
+	}
+
+	std::string binPath = concatPath(rootPath, "bin");
+	if (exist(concatPath(binPath, PRE_COMPILED_PACKAGE_FILE))) {
+		_INFO("The %s is a Pre-Compiled package. So, skip the TAC", pkgId.c_str());
+		return 0;
+	}
+
+	std::string metaValue = getMetadataValue(pkgId, TAC_METADATA_KEY);
+	if (!tacForce) {
+		if (metaValue.empty()) {
+			return 0;
+		}
+	}
+	if (metaValue == METADATA_VALUE_TRUE || tacForce) {
+		checkDepsJson(rootPath, binPath, execName);
+	}
+
+	tacState = state;
+	if (tacDB.empty()) {
+		return 0;
+	}
+
+	if (tac_createDB() != 0) {
+		return -1;
+	}
+
+	if (generateTAC(pkgId, binPath) != 0) {
+		return -1;
+	}
+
+	///// TLC /////
+	if (tlc_createDB() != 0) {
+		return -1;
+	}
+
+	copyLibraryCreateSymlink(pkgId, getLibrariesInfo(rootPath));
+
+	return 0;
+}
+
 int tacUpgrade(const std::string& pkgId, tac_state state, bool tacForce)
 {
 	_DBG("[===== PKGMGR_MDPARSER_PLUGIN_UPGRADE =====]");
 	_INFO("PackageID : %s", pkgId.c_str());
 
 	// Can be multiple apps in one package
-	if (tacPluginInstalled) {
-		_INFO("TAC plugin already upgraded");
+	if (strcmp(pkgId.c_str(), prevInstallPkgId.c_str()) == 0) {
+		_INFO("TAC Plugin(UPGRADE) already run for same pkgId (%s)", pkgId.c_str());
 		return 0;
 	}
-	tacPluginInstalled = true;
+	prevInstallPkgId = pkgId;
 
 	std::string appType = getAppType(pkgId);
 	if (strstr(appType.c_str(), "dotnet") == NULL) {
@@ -517,171 +479,25 @@ int tacUpgrade(const std::string& pkgId, tac_state state, bool tacForce)
 	}
 
 	tacState = TAC_STATE_UPGRADE;
-	tac_db = createDB(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
-	if (!tac_db) {
-		_ERR("Sqlite create error. So restore the database.");
-		if (tac_restoreDB() != TAC_ERROR_NONE) {
-			_ERR("Sqlite create error");
-			return -1;
-		}
-		tac_db = createDB(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
-		if (!tac_db) {
-			_ERR("Sqlite create error");
-			return -1;
-		}
+	if (tac_createDB() != 0) {
+		return -1;
 	}
-	sqlite3_exec(tac_db, "BEGIN;", NULL, NULL, NULL);
 
-	char *sql = sqlite3_mprintf("SELECT * FROM TAC WHERE PKGID = %Q;", pkgId.c_str());
-	updateTac = selectDB(tac_db, sql);
-	sqlite3_free(sql);
+	updateTac = tac_selectDB(pkgId);
 
 	bool skipTLC = false;
 	if (tacDB.empty()) {
-		sql = sqlite3_mprintf("DELETE FROM TAC WHERE PKGID = %Q;", pkgId.c_str());
-		if (!deleteDB(tac_db, sql)) {
-			_ERR("Sqlite delete error");
-			sqlite3_free(sql);
+		if (tac_deleteDB(pkgId, "") != 0) {
 			return -1;
 		}
-		sqlite3_free(sql);
-
-		tac_updateDB(tac_db);
+		tacUpdateDB(pkgId);
 
 		skipTLC = true;
 	} else {
-		std::string tac_dir = concatPath(binPath, TAC_SYMLINK_SUB_DIR);
-		if (!createDir(tac_dir)) {
-			_ERR("Cannot create directory: %s", tac_dir.c_str());
-			return 0;
+		if (generateTAC(pkgId, binPath) != 0) {
+			return -1;
 		}
-		copySmackAndOwnership(binPath.c_str(), tac_dir.c_str());
 
-		for (auto& np : tacDB) {
-			std::string tac_name = np.substr(0, np.find('/'));
-			std::string tac_version = np.substr(np.rfind('/') + 1);
-			_INFO("TAC name : %s", tac_name.c_str());
-			_INFO("TAC version : %s", tac_version.c_str());
-
-			bs::error_code error;
-			std::string tac_version_dir = concatPath(__DOTNET_DIR, np);
-			std::string sha256_info = concatPath(tac_version_dir, TAC_SHA_256_INFO);
-			if (!exist(tac_version_dir)) {
-				_INFO("Create tac_version_dir [%s]", tac_version_dir.c_str());
-				if (!createDir(tac_version_dir)) {
-					_ERR("Cannot create directory: %s", tac_version_dir.c_str());
-					tacState = TAC_STATE_RESTORE;
-					return -1;
-				}
-				createDirectories.push_back(tac_version_dir);
-				if (!isSymlinkFile(sha256_info)) {
-					createSHA256Info(sha256_info, np);
-				} else {
-					_ERR("Failed to create sha256_info. Symbolic link is detected");
-					tacState = TAC_STATE_RESTORE;
-					return -1;
-				}
-
-				if (!exist(sha256_info)) {
-					tacState = TAC_STATE_RESTORE;
-					return -1;
-				}
-
-				if (copyAssemblyCreateSymlink(binPath, tac_dir, np, true)) {
-					_ERR("Failed to create symlink");
-					tacState = TAC_STATE_RESTORE;
-					return -1;
-				}
-
-				int count = -1;
-				sql = sqlite3_mprintf(
-						"SELECT COUNT(NUGET) FROM TAC WHERE PKGID = %Q AND NAME = %Q;", pkgId.c_str(), tac_name.c_str());
-				int ret = sqlite3_exec(tac_db, sql, sqliteCb, &count, NULL);
-				if (ret != SQLITE_OK) {
-					_ERR("Sqlite select error");
-					sqlite3_free(sql);
-					tacState = TAC_STATE_RESTORE;
-					return -1;
-				}
-				sqlite3_free(sql);
-				if (count == 1) {
-					sql = sqlite3_mprintf(
-						"UPDATE TAC SET NAME = %Q, VERSION = %Q, NUGET = %Q WHERE PKGID = %Q AND NAME = %Q;",
-						tac_name.c_str(), tac_version.c_str(), np.c_str(), pkgId.c_str(), tac_name.c_str());
-					if (!updateDB(tac_db, sql)) {
-						_ERR("Sqlite update error");
-						sqlite3_free(sql);
-						tacState = TAC_STATE_RESTORE;
-						return -1;
-					}
-					sqlite3_free(sql);
-				} else if (count == 0) {
-					sql = sqlite3_mprintf(
-						"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
-						"VALUES (%Q, %Q, %Q, %Q);", pkgId.c_str(), np.c_str(), tac_name.c_str(), tac_version.c_str());
-					if (!insertDB(tac_db, sql)) {
-						_ERR("Sqlite insert error");
-						sqlite3_free(sql);
-						tacState = TAC_STATE_RESTORE;
-						return -1;
-					}
-					sqlite3_free(sql);
-				}
-			} else {
-				_INFO("Exists tac_version_dir [%s]", tac_version_dir.c_str());
-				if (!isSymlinkFile(sha256_info)) {
-					if (compareSHA256Info(sha256_info, np)) {
-						if (copyAssemblyCreateSymlink(binPath, tac_dir, np, false)) {
-							_ERR("Failed to create symlink");
-							tacState = TAC_STATE_RESTORE;
-							return -1;
-						}
-
-						int count = -1;
-						char *sql = sqlite3_mprintf(
-							"SELECT COUNT(NUGET) FROM TAC WHERE PKGID = %Q AND NAME = %Q;", pkgId.c_str(), tac_name.c_str());
-						int ret = sqlite3_exec(tac_db, sql, sqliteCb, &count, NULL);
-						if (ret != SQLITE_OK) {
-							_ERR("Sqlite select error");
-							sqlite3_free(sql);
-							tacState = TAC_STATE_RESTORE;
-							return -1;
-						}
-						sqlite3_free(sql);
-						if (count == 1) {
-							sql = sqlite3_mprintf(
-								"UPDATE TAC SET NAME = %Q, VERSION = %Q, NUGET = %Q WHERE PKGID = %Q AND NAME = %Q;",
-								tac_name.c_str(), tac_version.c_str(), np.c_str(), pkgId.c_str(), tac_name.c_str());
-							if (!updateDB(tac_db, sql)) {
-								_ERR("Sqlite update error");
-								sqlite3_free(sql);
-								tacState = TAC_STATE_RESTORE;
-								return -1;
-							}
-							sqlite3_free(sql);
-						} else if (count == 0) {
-							sql = sqlite3_mprintf(
-								"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
-								"VALUES (%Q, %Q, %Q, %Q);", pkgId.c_str(), np.c_str(), tac_name.c_str(), tac_version.c_str());
-							if (!insertDB(tac_db, sql)) {
-								_ERR("Sqlite insert error");
-								sqlite3_free(sql);
-								tacState = TAC_STATE_RESTORE;
-								return -1;
-							}
-							sqlite3_free(sql);
-						}
-					} else {
-						_INFO("Different nuget : %s", np.c_str());
-						continue;
-					}
-				} else {
-					_ERR("Failed to create sha256_info. Symbolic link is detected");
-					tacState = TAC_STATE_RESTORE;
-					return -1;
-				}
-			}
-		}
 		for (auto& unp : updateTac) {
 			bool isExits = false;
 			for (auto& np : tacDB) {
@@ -691,62 +507,29 @@ int tacUpgrade(const std::string& pkgId, tac_state state, bool tacForce)
 				}
 			}
 			if (!isExits) {
-				char *sql = sqlite3_mprintf("DELETE FROM TAC WHERE PKGID = %Q AND NUGET = %Q;", pkgId.c_str(), unp.c_str());
-				if (!deleteDB(tac_db, sql)) {
-					_ERR("Sqlite delete error");
-					sqlite3_free(sql);
+				if (tac_deleteDB(pkgId, unp) != 0) {
 					tacState = TAC_STATE_RESTORE;
 					return -1;
 				}
-				sqlite3_free(sql);
 			}
 		}
-		tac_updateDB(tac_db);
+		tacUpdateDB(pkgId);
 	}
 
 	///// TLC /////
-	std::string tlcDir = concatPath(__DOTNET_DIR, TLC_LIBRARIES_DIR);
-	if (!createDir(tlcDir)) {
-		_ERR("Cannot create directory: %s", tlcDir.c_str());
-		return 0;
-	}
-	copySmackAndOwnership(__DOTNET_DIR, tlcDir);
-
-	tlc_db = createDB(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
-	if (!tlc_db) {
-		_ERR("Sqlite create error. So restore the database.");
-		if (tlc_restoreDB() != TAC_ERROR_NONE) {
-			_ERR("Sqlite create error");
-			return 0;
-		}
-		tlc_db = createDB(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
-		if (!tlc_db) {
-			_ERR("Sqlite create error");
-			return 0;
-		}
+	if (tlc_createDB() != 0) {
+		return -1;
 	}
-	sqlite3_exec(tlc_db, "BEGIN;", NULL, NULL, NULL);
 
-	sql = sqlite3_mprintf("SELECT * FROM TLC WHERE PKGID = %Q;", pkgId.c_str());
-	std::vector<std::string> updateTlc = selectDB(tlc_db, sql);
-	sqlite3_free(sql);
+	updateTlc = tlc_selectDB(pkgId);
 
-	sql = sqlite3_mprintf("DELETE FROM TLC WHERE PKGID = %Q;", pkgId.c_str());
-	if (!deleteDB(tlc_db, sql)) {
-		_ERR("Sqlite delete error");
-		sqlite3_free(sql);
-		return 0;
-	}
-	sqlite3_free(sql);
-
-	std::vector<std::string> librariesInfo;
-	if (!skipTLC) {
-		librariesInfo = getLibrariesInfo(rootPath);
+	if (tlc_deleteDB(pkgId) != 0) {
+		return -1;
 	}
 
-	copyLibraryCreateSymlink(pkgId, librariesInfo, tlcDir);
+	tlcUpdateDB(pkgId);
 
-	tlc_updateDB(tlc_db, updateTlc, tlcDir);
+	copyLibraryCreateSymlink(pkgId, skipTLC ? std::vector<std::string>() : getLibrariesInfo(rootPath));
 
 	return 0;
 }
@@ -757,73 +540,37 @@ int tacUninstall(const std::string& pkgId, tac_state state)
 	_INFO("PackageID : %s", pkgId.c_str());
 
 	// Can be multiple apps in one package
-	if (tacPluginInstalled) {
-		_INFO("TAC plugin already uninstalled");
+	if (strcmp(pkgId.c_str(), prevInstallPkgId.c_str()) == 0) {
+		_INFO("TAC Plugin(UNINSTALL) already run for same pkgId (%s)", pkgId.c_str());
 		return 0;
 	}
-	tacPluginInstalled = true;
+	prevInstallPkgId = pkgId;
 
 	tacState= state;
-	tac_db = openDB(TAC_APP_LIST_DB);
-	if (!tac_db) {
-		_ERR("Sqlite open error. So restore the database.");
-		if (tac_restoreDB() != TAC_ERROR_NONE) {
-			_ERR("Sqlite open error");
-			return -1;
-		}
-		tac_db = openDB(TAC_APP_LIST_DB);
-		if (!tac_db) {
-			_ERR("Sqlite open error");
-			return -1;
-		}
+	if (tac_openDB() != 0) {
+		return -1;
 	}
-	sqlite3_exec(tac_db, "BEGIN;", NULL, NULL, NULL);
 
-	char *sql = sqlite3_mprintf("SELECT * FROM TAC WHERE PKGID = %Q;", pkgId.c_str());
-	updateTac = selectDB(tac_db, sql);
-	sqlite3_free(sql);
+	updateTac = tac_selectDB(pkgId);
 
-	sql = sqlite3_mprintf("DELETE FROM TAC WHERE PKGID = %Q;", pkgId.c_str());
-
-	if (!deleteDB(tac_db, sql)) {
-		_ERR("Sqlite delete error");
-		sqlite3_free(sql);
+	if (tac_deleteDB(pkgId, "") != 0) {
 		tacState = TAC_STATE_RESTORE;
 		return -1;
 	}
-	sqlite3_free(sql);
-
-	tac_updateDB(tac_db);
+	tacUpdateDB(pkgId);
 
 	///// TLC /////
-	tlc_db = openDB(TLC_APP_LIST_DB);
-	if (!tlc_db) {
-		_ERR("Sqlite open error. So restore the database.");
-		if (tlc_restoreDB() != TAC_ERROR_NONE) {
-			_ERR("Sqlite open error");
-			return 0;
-		}
-		tlc_db = openDB(TLC_APP_LIST_DB);
-		if (!tlc_db) {
-			_ERR("Sqlite open error");
-			return 0;
-		}
+	if (tlc_openDB() != 0) {
+		return -1;
 	}
-	sqlite3_exec(tlc_db, "BEGIN;", NULL, NULL, NULL);
 
-	sql = sqlite3_mprintf("SELECT * FROM TLC WHERE PKGID = %Q;", pkgId.c_str());
-	std::vector<std::string> updateTlc = selectDB(tlc_db, sql);
-	sqlite3_free(sql);
+	updateTlc = tlc_selectDB(pkgId);
 
-	sql = sqlite3_mprintf("DELETE FROM TLC WHERE PKGID = %Q;", pkgId.c_str());
-	if (!deleteDB(tlc_db, sql)) {
-		_ERR("Sqlite delete error");
-		sqlite3_free(sql);
-		return 0;
+	if (tlc_deleteDB(pkgId) != 0) {
+		return -1;
 	}
-	sqlite3_free(sql);
 
-	tlc_updateDB(tlc_db, updateTlc, concatPath(__DOTNET_DIR, TLC_LIBRARIES_DIR));
+	tlcUpdateDB(pkgId);
 
 	return 0;
 }
@@ -863,7 +610,7 @@ void undoStep(std::string tac)
 		}
 	};
 
-	scanFilesInDirectory(concatPath(__DOTNET_DIR, TLC_LIBRARIES_DIR), convert, 0);
+	scanFilesInDirectory(TLC_LIBRARIES_DIR, convert, 0);
 }
 
 void install_Undo()
@@ -905,11 +652,11 @@ int tacUndo(const std::string& pkgId)
 	_INFO("PackageID : %s", pkgId.c_str());
 
 	// Can be multiple apps in one package
-	if (tacPluginFinished) {
-		_INFO("TAC plugin already finished(UNDO)");
+	if (strcmp(pkgId.c_str(), prevFinishPkgId.c_str()) == 0) {
+		_INFO("TAC Plugin(UNDO) already run for same pkgId (%s)", pkgId.c_str());
 		return 0;
 	}
-	tacPluginFinished = true;
+	prevFinishPkgId = pkgId;
 
 	if (tacState == TAC_STATE_INSTALL) {
 		install_Undo();
@@ -921,15 +668,9 @@ int tacUndo(const std::string& pkgId)
 		update_Undo();
 	}
 
-	if (tac_db) {
-		rollbackDB(tac_db);
-		tac_db = NULL;
-	}
+	tac_rollbackDB();
 
-	if (tlc_db) {
-		rollbackDB(tlc_db);
-		tlc_db = NULL;
-	}
+	tlc_rollbackDB();
 
 	return 0;
 }
@@ -986,7 +727,7 @@ void cleanStep(std::string tac)
 		}
 	};
 
-	scanFilesInDirectory(concatPath(__DOTNET_DIR, TLC_LIBRARIES_DIR), convert, 0);
+	scanFilesInDirectory(TLC_LIBRARIES_DIR, convert, 0);
 }
 
 void install_Clean()
@@ -1061,11 +802,11 @@ int tacClean(const std::string& pkgId)
 	_INFO("PackageID : %s", pkgId.c_str());
 
 	// Can be multiple apps in one package
-	if (tacPluginFinished) {
-		_INFO("TAC plugin already finished(CLEAN)");
+	if (strcmp(pkgId.c_str(), prevFinishPkgId.c_str()) == 0) {
+		_INFO("TAC Plugin(CLEAN) already run for same pkgId (%s)", pkgId.c_str());
 		return 0;
 	}
-	tacPluginFinished = true;
+	prevFinishPkgId = pkgId;
 
 	if (tacState == TAC_STATE_INSTALL) {
 		install_Clean();
@@ -1075,16 +816,12 @@ int tacClean(const std::string& pkgId)
 		unInstall_Clean();
 	}
 
-	if (tac_db) {
-		closeDB(tac_db);
-		tac_db = NULL;
+	if (tac_closeDB()) {
 		copySmackAndOwnership(__DOTNET_DIR, TAC_APP_LIST_DB);
 		copySmackAndOwnership(__DOTNET_DIR, TAC_APP_LIST_DB + std::string("-journal"));
 	}
 
-	if (tlc_db) {
-		closeDB(tlc_db);
-		tlc_db = NULL;
+	if (tlc_closeDB()) {
 		copySmackAndOwnership(__DOTNET_DIR, TLC_APP_LIST_DB);
 		copySmackAndOwnership(__DOTNET_DIR, TLC_APP_LIST_DB + std::string("-journal"));
 	}