Change-Id: Ia573149eb300989156a941427f8007c17514627b
PKGID TEXT,\
LIBRARY TEXT);"
PKGID TEXT,\
LIBRARY TEXT);"
-sqlite3* dbCreate(std::string path, std::string query);
-sqlite3* dbOpen(std::string path);
-void dbClose(sqlite3 *tac_db);
-void dbRollback(sqlite3 *tac_db);
-bool dbUpdate(sqlite3 *tac_db, std::string query);
-bool dbInsert(sqlite3 *tac_db, std::string query);
-bool dbDelete(sqlite3 *tac_db, std::string query);
-std::vector<std::string> dbSelect(sqlite3 *tac_db, std::string query);
+sqlite3* createDB(std::string path, std::string query);
+sqlite3* openDB(std::string path);
+void closeDB(sqlite3 *tac_db);
+void rollbackDB(sqlite3 *tac_db);
+bool updateDB(sqlite3 *tac_db, std::string query);
+bool insertDB(sqlite3 *tac_db, std::string query);
+bool deleteDB(sqlite3 *tac_db, std::string query);
+std::vector<std::string> selectDB(sqlite3 *tac_db, std::string query);
#endif /* __DB_MANAGER_H__ */
#endif /* __DB_MANAGER_H__ */
* @brief restore database of TAC
* @return tac_error_e
*/
* @brief restore database of TAC
* @return tac_error_e
*/
-tac_error_e restoreTACDB();
+tac_error_e tac_restoreDB();
/**
* @brief disable tac feature.
/**
* @brief disable tac feature.
* @brief restore database of TLC
* @return tac_error_e
*/
* @brief restore database of TLC
* @return tac_error_e
*/
-tac_error_e restoreTLCDB();
+tac_error_e tlc_restoreDB();
#endif /* __TAC_COMMON_H__ */
#endif /* __TAC_COMMON_H__ */
-static int copyNCreateTacSymlink(std::string binPath, std::string tacVersionDir, std::string nugetPackage, bool isCreateTacDir)
+static int copyAssemblyCreateSymlink(std::string binPath, std::string tacVersionDir, std::string nugetPackage, bool isCreateTacDir)
{
std::string tac_dir = concatPath(binPath, TAC_SYMLINK_SUB_DIR);
if (!createDir(tac_dir)) {
{
std::string tac_dir = concatPath(binPath, TAC_SYMLINK_SUB_DIR);
if (!createDir(tac_dir)) {
-static void copyNCreateTlcSymlink(const char* pkgId, std::vector<std::string> LibrariesInfo, std::string tlcDir)
+static void copyLibraryCreateSymlink(const char* pkgId, std::vector<std::string> LibrariesInfo, std::string tlcDir)
{
if (LibrariesInfo.empty()) {
_INFO("Not exist data for TLC in %s", pkgId);
{
if (LibrariesInfo.empty()) {
_INFO("Not exist data for TLC in %s", pkgId);
bf::create_symlink(concatPath(tlcDir, fileSha), library);
char *sql = sqlite3_mprintf("INSERT INTO TLC (PKGID, LIBRARY) VALUES (%Q, %Q);", pkgId, fileSha.c_str());
bf::create_symlink(concatPath(tlcDir, fileSha), library);
char *sql = sqlite3_mprintf("INSERT INTO TLC (PKGID, LIBRARY) VALUES (%Q, %Q);", pkgId, fileSha.c_str());
- if (!dbInsert(tlc_db, sql)) {
+ if (!insertDB(tlc_db, sql)) {
_ERR("Sqlite insert error");
sqlite3_free(sql);
copyFile(concatPath(tlcDir, fileSha), library);
_ERR("Sqlite insert error");
sqlite3_free(sql);
copyFile(concatPath(tlcDir, fileSha), library);
-static void depsJsonCheck(std::string rootPath, std::string binPath, std::string execName)
+static void checkDepsJson(std::string rootPath, std::string binPath, std::string execName)
{
for (auto& npAssembly : depsJsonParser(rootPath, execName)) {
std::string nuget_package = npAssembly.substr(0, npAssembly.rfind(':'));
{
for (auto& npAssembly : depsJsonParser(rootPath, execName)) {
std::string nuget_package = npAssembly.substr(0, npAssembly.rfind(':'));
return 0;
}
if (metaValue == METADATA_VALUE) {
return 0;
}
if (metaValue == METADATA_VALUE) {
- depsJsonCheck(rootPath, binPath, execName);
+ checkDepsJson(rootPath, binPath, execName);
- tac_db = dbCreate(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
+ tac_db = createDB(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
if (!tac_db) {
_ERR("Sqlite create error. So restore the database.");
if (!tac_db) {
_ERR("Sqlite create error. So restore the database.");
- if (restoreTACDB() != TAC_ERROR_NONE) {
+ if (tac_restoreDB() != TAC_ERROR_NONE) {
_ERR("Sqlite create error");
return 0;
}
_ERR("Sqlite create error");
return 0;
}
- tac_db = dbCreate(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
+ tac_db = createDB(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
if (!tac_db) {
_ERR("Sqlite create error");
return 0;
if (!tac_db) {
_ERR("Sqlite create error");
return 0;
- if (copyNCreateTacSymlink(binPath, tac_version_dir, np, true) < 0) {
+ if (copyAssemblyCreateSymlink(binPath, tac_version_dir, np, true) < 0) {
_ERR("Failed to create symlink");
return -1;
}
_ERR("Failed to create symlink");
return -1;
}
char *sql = sqlite3_mprintf(
"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
"VALUES (%Q, %Q, %Q, %Q);", pkgId, np.c_str(), tac_name.c_str(), tac_version.c_str());
char *sql = sqlite3_mprintf(
"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
"VALUES (%Q, %Q, %Q, %Q);", pkgId, np.c_str(), tac_name.c_str(), tac_version.c_str());
sqlite3_free(sql);
} else {
_INFO("Exists tac_version_dir [%s]", tac_version_dir.c_str());
if (!bf::is_symlink(sha256_info)) {
if (compareSHA256Info(sha256_info, np)) {
sqlite3_free(sql);
} else {
_INFO("Exists tac_version_dir [%s]", tac_version_dir.c_str());
if (!bf::is_symlink(sha256_info)) {
if (compareSHA256Info(sha256_info, np)) {
- if (copyNCreateTacSymlink(binPath, tac_version_dir, np, false) < 0) {
+ if (copyAssemblyCreateSymlink(binPath, tac_version_dir, np, false) < 0) {
_ERR("Failed to create symlink");
return -1;
}
_ERR("Failed to create symlink");
return -1;
}
char *sql = sqlite3_mprintf(
"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
"VALUES (%Q, %Q, %Q, %Q);", pkgId, np.c_str(), tac_name.c_str(), tac_version.c_str());
char *sql = sqlite3_mprintf(
"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
"VALUES (%Q, %Q, %Q, %Q);", pkgId, np.c_str(), tac_name.c_str(), tac_version.c_str());
sqlite3_free(sql);
} else {
_INFO("Different nuget : %s", np.c_str());
sqlite3_free(sql);
} else {
_INFO("Different nuget : %s", np.c_str());
- tlc_db = dbCreate(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
+ tlc_db = createDB(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
if (!tlc_db) {
_ERR("Sqlite create error. So restore the database.");
if (!tlc_db) {
_ERR("Sqlite create error. So restore the database.");
- if (restoreTLCDB() != TAC_ERROR_NONE) {
+ if (tlc_restoreDB() != TAC_ERROR_NONE) {
_ERR("Sqlite create error");
return 0;
}
_ERR("Sqlite create error");
return 0;
}
- tlc_db = dbCreate(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
+ tlc_db = createDB(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
if (!tlc_db) {
_ERR("Sqlite create error");
return 0;
if (!tlc_db) {
_ERR("Sqlite create error");
return 0;
}
sqlite3_exec(tlc_db, "BEGIN;", NULL, NULL, NULL);
}
sqlite3_exec(tlc_db, "BEGIN;", NULL, NULL, NULL);
- copyNCreateTlcSymlink(pkgId, getLibrariesInfo(rootPath), tlcDir);
+ copyLibraryCreateSymlink(pkgId, getLibrariesInfo(rootPath), tlcDir);
-static int updateTacDB(sqlite3 *sqlite)
+static int tac_updateDB(sqlite3 *sqlite)
{
for (auto& unp : updateTac) {
int count = -1;
{
for (auto& unp : updateTac) {
int count = -1;
-static void updateTlcDB(sqlite3 *sqlite, std::vector<std::string> updateTlc, std::string tlcDir)
+static void tlc_updateDB(sqlite3 *sqlite, std::vector<std::string> updateTlc, std::string tlcDir)
{
for (auto& ulp : updateTlc) {
int count = -1;
{
for (auto& ulp : updateTlc) {
int count = -1;
return 0;
}
if (metaValue == METADATA_VALUE) {
return 0;
}
if (metaValue == METADATA_VALUE) {
- depsJsonCheck(rootPath, binPath, execName);
+ checkDepsJson(rootPath, binPath, execName);
- tac_db = dbCreate(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
+ tac_db = createDB(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
if (!tac_db) {
_ERR("Sqlite create error. So restore the database.");
if (!tac_db) {
_ERR("Sqlite create error. So restore the database.");
- if (restoreTACDB() != TAC_ERROR_NONE) {
+ if (tac_restoreDB() != TAC_ERROR_NONE) {
_ERR("Sqlite create error");
return 0;
}
_ERR("Sqlite create error");
return 0;
}
- tac_db = dbCreate(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
+ tac_db = createDB(TAC_APP_LIST_DB, CREATE_TAC_DB_TABLE);
if (!tac_db) {
_ERR("Sqlite create error");
return 0;
if (!tac_db) {
_ERR("Sqlite create error");
return 0;
sqlite3_exec(tac_db, "BEGIN;", NULL, NULL, NULL);
char *sql = sqlite3_mprintf("SELECT * FROM TAC WHERE PKGID = %Q;", pkgId);
sqlite3_exec(tac_db, "BEGIN;", NULL, NULL, NULL);
char *sql = sqlite3_mprintf("SELECT * FROM TAC WHERE PKGID = %Q;", pkgId);
- updateTac = dbSelect(tac_db, sql);
+ updateTac = selectDB(tac_db, sql);
sqlite3_free(sql);
bool skipTLC = false;
if (tacDB.empty()) {
sql = sqlite3_mprintf("DELETE FROM TAC WHERE PKGID = %Q;", pkgId);
sqlite3_free(sql);
bool skipTLC = false;
if (tacDB.empty()) {
sql = sqlite3_mprintf("DELETE FROM TAC WHERE PKGID = %Q;", pkgId);
- if (updateTacDB(tac_db) < 0) {
+ if (tac_updateDB(tac_db) < 0) {
return -1;
}
skipTLC = true;
return -1;
}
skipTLC = true;
- if (copyNCreateTacSymlink(binPath, tac_version_dir, np, true) < 0) {
+ if (copyAssemblyCreateSymlink(binPath, tac_version_dir, np, true) < 0) {
_ERR("Failed to create symlink");
return -1;
}
_ERR("Failed to create symlink");
return -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, tac_name.c_str());
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, tac_name.c_str());
sqlite3_free(sql);
} else if (count == 0) {
sql = sqlite3_mprintf(
"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
"VALUES (%Q, %Q, %Q, %Q);", pkgId, np.c_str(), tac_name.c_str(), tac_version.c_str());
sqlite3_free(sql);
} else if (count == 0) {
sql = sqlite3_mprintf(
"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
"VALUES (%Q, %Q, %Q, %Q);", pkgId, np.c_str(), tac_name.c_str(), tac_version.c_str());
sqlite3_free(sql);
}
} else {
_INFO("Exists tac_version_dir [%s]", tac_version_dir.c_str());
if (!bf::is_symlink(sha256_info)) {
if (compareSHA256Info(sha256_info, np)) {
sqlite3_free(sql);
}
} else {
_INFO("Exists tac_version_dir [%s]", tac_version_dir.c_str());
if (!bf::is_symlink(sha256_info)) {
if (compareSHA256Info(sha256_info, np)) {
- if (copyNCreateTacSymlink(binPath, tac_version_dir, np, false) < 0) {
+ if (copyAssemblyCreateSymlink(binPath, tac_version_dir, np, false) < 0) {
_ERR("Failed to create symlink");
return -1;
}
_ERR("Failed to create symlink");
return -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, tac_name.c_str());
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, tac_name.c_str());
sqlite3_free(sql);
} else if (count == 0) {
sql = sqlite3_mprintf(
"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
"VALUES (%Q, %Q, %Q, %Q);", pkgId, np.c_str(), tac_name.c_str(), tac_version.c_str());
sqlite3_free(sql);
} else if (count == 0) {
sql = sqlite3_mprintf(
"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
"VALUES (%Q, %Q, %Q, %Q);", pkgId, np.c_str(), tac_name.c_str(), tac_version.c_str());
sqlite3_free(sql);
}
} else {
sqlite3_free(sql);
}
} else {
}
if (!isExits) {
char *sql = sqlite3_mprintf("DELETE FROM TAC WHERE PKGID = %Q AND NUGET = %Q;", pkgId, unp.c_str());
}
if (!isExits) {
char *sql = sqlite3_mprintf("DELETE FROM TAC WHERE PKGID = %Q AND NUGET = %Q;", pkgId, unp.c_str());
- if (updateTacDB(tac_db) < 0) {
+ if (tac_updateDB(tac_db) < 0) {
- tlc_db = dbCreate(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
+ tlc_db = createDB(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
if (!tlc_db) {
_ERR("Sqlite create error. So restore the database.");
if (!tlc_db) {
_ERR("Sqlite create error. So restore the database.");
- if (restoreTLCDB() != TAC_ERROR_NONE) {
+ if (tlc_restoreDB() != TAC_ERROR_NONE) {
_ERR("Sqlite create error");
return 0;
}
_ERR("Sqlite create error");
return 0;
}
- tlc_db = dbCreate(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
+ tlc_db = createDB(TLC_APP_LIST_DB, CREATE_TLC_DB_TABLE);
if (!tlc_db) {
_ERR("Sqlite create error");
return 0;
if (!tlc_db) {
_ERR("Sqlite create error");
return 0;
sqlite3_exec(tlc_db, "BEGIN;", NULL, NULL, NULL);
sql = sqlite3_mprintf("SELECT * FROM TLC WHERE PKGID = %Q;", pkgId);
sqlite3_exec(tlc_db, "BEGIN;", NULL, NULL, NULL);
sql = sqlite3_mprintf("SELECT * FROM TLC WHERE PKGID = %Q;", pkgId);
- std::vector<std::string> updateTlc = dbSelect(tlc_db, sql);
+ std::vector<std::string> updateTlc = selectDB(tlc_db, sql);
sqlite3_free(sql);
sql = sqlite3_mprintf("DELETE FROM TLC WHERE PKGID = %Q;", pkgId);
sqlite3_free(sql);
sql = sqlite3_mprintf("DELETE FROM TLC WHERE PKGID = %Q;", pkgId);
sqlite3_free(sql);
std::vector<std::string> librariesInfo = getLibrariesInfo(rootPath);
sqlite3_free(sql);
std::vector<std::string> librariesInfo = getLibrariesInfo(rootPath);
- copyNCreateTlcSymlink(pkgId, librariesInfo, tlcDir);
+ copyLibraryCreateSymlink(pkgId, librariesInfo, tlcDir);
- updateTlcDB(tlc_db, updateTlc, tlcDir);
+ tlc_updateDB(tlc_db, updateTlc, tlcDir);
tacPluginInstalled = true;
status = "uninstall";
tacPluginInstalled = true;
status = "uninstall";
- tac_db = dbOpen(TAC_APP_LIST_DB);
+ tac_db = openDB(TAC_APP_LIST_DB);
if (!tac_db) {
_ERR("Sqlite open error. So restore the database.");
if (!tac_db) {
_ERR("Sqlite open error. So restore the database.");
- if (restoreTACDB() != TAC_ERROR_NONE) {
+ if (tac_restoreDB() != TAC_ERROR_NONE) {
_ERR("Sqlite open error");
return 0;
}
_ERR("Sqlite open error");
return 0;
}
- tac_db = dbOpen(TAC_APP_LIST_DB);
+ tac_db = openDB(TAC_APP_LIST_DB);
if (!tac_db) {
_ERR("Sqlite open error");
return 0;
if (!tac_db) {
_ERR("Sqlite open error");
return 0;
sqlite3_exec(tac_db, "BEGIN;", NULL, NULL, NULL);
char *sql = sqlite3_mprintf("SELECT * FROM TAC WHERE PKGID = %Q;", pkgId);
sqlite3_exec(tac_db, "BEGIN;", NULL, NULL, NULL);
char *sql = sqlite3_mprintf("SELECT * FROM TAC WHERE PKGID = %Q;", pkgId);
- updateTac = dbSelect(tac_db, sql);
+ updateTac = selectDB(tac_db, sql);
sqlite3_free(sql);
sql = sqlite3_mprintf("DELETE FROM TAC WHERE PKGID = %Q;", pkgId);
sqlite3_free(sql);
sql = sqlite3_mprintf("DELETE FROM TAC WHERE PKGID = %Q;", pkgId);
- if (updateTacDB(tac_db) < 0) {
+ if (tac_updateDB(tac_db) < 0) {
return -1;
}
///// TLC /////
return -1;
}
///// TLC /////
- tlc_db = dbOpen(TLC_APP_LIST_DB);
+ tlc_db = openDB(TLC_APP_LIST_DB);
if (!tlc_db) {
_ERR("Sqlite open error. So restore the database.");
if (!tlc_db) {
_ERR("Sqlite open error. So restore the database.");
- if (restoreTLCDB() != TAC_ERROR_NONE) {
+ if (tlc_restoreDB() != TAC_ERROR_NONE) {
_ERR("Sqlite open error");
return 0;
}
_ERR("Sqlite open error");
return 0;
}
- tlc_db = dbOpen(TLC_APP_LIST_DB);
+ tlc_db = openDB(TLC_APP_LIST_DB);
if (!tlc_db) {
_ERR("Sqlite open error");
return 0;
if (!tlc_db) {
_ERR("Sqlite open error");
return 0;
sqlite3_exec(tlc_db, "BEGIN;", NULL, NULL, NULL);
sql = sqlite3_mprintf("SELECT * FROM TLC WHERE PKGID = %Q;", pkgId);
sqlite3_exec(tlc_db, "BEGIN;", NULL, NULL, NULL);
sql = sqlite3_mprintf("SELECT * FROM TLC WHERE PKGID = %Q;", pkgId);
- std::vector<std::string> updateTlc = dbSelect(tlc_db, sql);
+ std::vector<std::string> updateTlc = selectDB(tlc_db, sql);
sqlite3_free(sql);
sql = sqlite3_mprintf("DELETE FROM TLC WHERE PKGID = %Q;", pkgId);
sqlite3_free(sql);
sql = sqlite3_mprintf("DELETE FROM TLC WHERE PKGID = %Q;", pkgId);
- updateTlcDB(tlc_db, updateTlc, concatPath(__DOTNET_DIR, TLC_LIBRARIES_DIR));
+ tlc_updateDB(tlc_db, updateTlc, concatPath(__DOTNET_DIR, TLC_LIBRARIES_DIR));
tac_db = NULL;
}
if (tlc_db) {
tac_db = NULL;
}
if (tlc_db) {
tac_db = NULL;
}
if (tlc_db) {
tac_db = NULL;
}
if (tlc_db) {
tlc_db = NULL;
}
return 0;
tlc_db = NULL;
}
return 0;
-}
\ No newline at end of file
}
//sh-3.2# dotnettool --tac-restore-db
else if (cmd == "--tac-restore-db") {
}
//sh-3.2# dotnettool --tac-restore-db
else if (cmd == "--tac-restore-db") {
- int ret = restoreTACDB();
+ int ret = tac_restoreDB();
if (ret != TAC_ERROR_NONE) {
fprintf(stderr, "Failed to restore TAC db\n");
}
if (ret != TAC_ERROR_NONE) {
fprintf(stderr, "Failed to restore TAC db\n");
}
if (ret != TAC_ERROR_NONE) {
fprintf(stderr, "Failed to restore TLC db\n");
}
if (ret != TAC_ERROR_NONE) {
fprintf(stderr, "Failed to restore TLC db\n");
}
- sqlite3 *tac_db = dbOpen(TAC_APP_LIST_DB);
+ sqlite3 *tac_db = openDB(TAC_APP_LIST_DB);
if (!tac_db) {
fprintf(stderr, "Sqlite open error\n");
return -1;
if (!tac_db) {
fprintf(stderr, "Sqlite open error\n");
return -1;
sqlite3_exec(tac_db, "BEGIN;", NULL, NULL, NULL);
char *sql = sqlite3_mprintf("SELECT * FROM TAC WHERE PKGID = %Q;", pkgId);
sqlite3_exec(tac_db, "BEGIN;", NULL, NULL, NULL);
char *sql = sqlite3_mprintf("SELECT * FROM TAC WHERE PKGID = %Q;", pkgId);
- std::vector<std::string> nugets = dbSelect(tac_db, sql);
+ std::vector<std::string> nugets = selectDB(tac_db, sql);
sqlite3_free(sql);
if (tac_db) {
sqlite3_free(sql);
if (tac_db) {
}
// callback function of "pkgmgrinfo_appinfo_metadata_filter_foreach"
}
// callback function of "pkgmgrinfo_appinfo_metadata_filter_foreach"
-static int restoreTACDBCb(pkgmgrinfo_appinfo_h handle, void *userData)
+static int tac_restoreDBCb(pkgmgrinfo_appinfo_h handle, void *userData)
{
char *pkgId = NULL;
char *root = NULL;
{
char *pkgId = NULL;
char *root = NULL;
char *sql = sqlite3_mprintf(
"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
"VALUES (%Q, %Q, %Q, %Q);", pkgId, nuget.c_str(), name.c_str(), version.c_str());
char *sql = sqlite3_mprintf(
"INSERT INTO TAC (PKGID, NUGET, NAME, VERSION) " \
"VALUES (%Q, %Q, %Q, %Q);", pkgId, nuget.c_str(), name.c_str(), version.c_str());
restore_nuget.push_back(concatPath(__DOTNET_DIR, nuget));
sqlite3_free(sql);
}
restore_nuget.push_back(concatPath(__DOTNET_DIR, nuget));
sqlite3_free(sql);
}
-tac_error_e restoreTACDB()
+tac_error_e tac_restoreDB()
{
if (!removeFile(TAC_APP_LIST_RESTORE_DB)) {
fprintf(stderr, "Failed to remove of %s\n", TAC_APP_LIST_RESTORE_DB);
{
if (!removeFile(TAC_APP_LIST_RESTORE_DB)) {
fprintf(stderr, "Failed to remove of %s\n", TAC_APP_LIST_RESTORE_DB);
return TAC_ERROR_UNKNOWN;
}
return TAC_ERROR_UNKNOWN;
}
- tac_db = dbCreate(TAC_APP_LIST_RESTORE_DB, CREATE_TAC_DB_TABLE);
+ tac_db = createDB(TAC_APP_LIST_RESTORE_DB, CREATE_TAC_DB_TABLE);
if (!tac_db) {
fprintf(stderr, "Sqlite create error\n");
return TAC_ERROR_UNKNOWN;
if (!tac_db) {
fprintf(stderr, "Sqlite create error\n");
return TAC_ERROR_UNKNOWN;
return TAC_ERROR_UNKNOWN;
}
return TAC_ERROR_UNKNOWN;
}
- ret = pkgmgrinfo_appinfo_metadata_filter_foreach(handle, restoreTACDBCb, NULL);
+ ret = pkgmgrinfo_appinfo_metadata_filter_foreach(handle, tac_restoreDBCb, NULL);
if (ret != PMINFO_R_OK) {
fprintf(stderr, "Failed pkgmgrinfo_appinfo_metadata_filter_foreach\n");
pkgmgrinfo_appinfo_metadata_filter_destroy(handle);
if (ret != PMINFO_R_OK) {
fprintf(stderr, "Failed pkgmgrinfo_appinfo_metadata_filter_foreach\n");
pkgmgrinfo_appinfo_metadata_filter_destroy(handle);
pkgmgrinfo_appinfo_metadata_filter_destroy(handle);
if (tac_db) {
pkgmgrinfo_appinfo_metadata_filter_destroy(handle);
if (tac_db) {
}
// callback function of "pkgmgrinfo_appinfo_metadata_filter_foreach"
}
// callback function of "pkgmgrinfo_appinfo_metadata_filter_foreach"
-static int restoreTLCDBCb(pkgmgrinfo_appinfo_h handle, void *userData)
+static int tlc_restoreDBCb(pkgmgrinfo_appinfo_h handle, void *userData)
{
char *pkgId = NULL;
char *root = NULL;
{
char *pkgId = NULL;
char *root = NULL;
if (bf::exists(library)) {
std::string fileSha = library.substr(library.rfind('/') + 1) + ".." + librarySha.substr(librarySha.find(':') + 1);
char *sql = sqlite3_mprintf("INSERT INTO TLC (PKGID, LIBRARY) VALUES (%Q, %Q);", pkgId, fileSha.c_str());
if (bf::exists(library)) {
std::string fileSha = library.substr(library.rfind('/') + 1) + ".." + librarySha.substr(librarySha.find(':') + 1);
char *sql = sqlite3_mprintf("INSERT INTO TLC (PKGID, LIBRARY) VALUES (%Q, %Q);", pkgId, fileSha.c_str());
restore_library.push_back(fileSha);
sqlite3_free(sql);
}
restore_library.push_back(fileSha);
sqlite3_free(sql);
}
-tac_error_e restoreTLCDB()
+tac_error_e tlc_restoreDB()
{
if (!removeFile(TLC_APP_LIST_RESTORE_DB)) {
fprintf(stderr, "Failed to remove of %s\n", TLC_APP_LIST_RESTORE_DB);
{
if (!removeFile(TLC_APP_LIST_RESTORE_DB)) {
fprintf(stderr, "Failed to remove of %s\n", TLC_APP_LIST_RESTORE_DB);
return TAC_ERROR_UNKNOWN;
}
return TAC_ERROR_UNKNOWN;
}
- tlc_db = dbCreate(TLC_APP_LIST_RESTORE_DB, CREATE_TLC_DB_TABLE);
+ tlc_db = createDB(TLC_APP_LIST_RESTORE_DB, CREATE_TLC_DB_TABLE);
if (!tlc_db) {
fprintf(stderr, "Sqlite create error\n");
return TAC_ERROR_UNKNOWN;
if (!tlc_db) {
fprintf(stderr, "Sqlite create error\n");
return TAC_ERROR_UNKNOWN;
return TAC_ERROR_UNKNOWN;
}
return TAC_ERROR_UNKNOWN;
}
- ret = pkgmgrinfo_appinfo_metadata_filter_foreach(handle, restoreTLCDBCb, NULL);
+ ret = pkgmgrinfo_appinfo_metadata_filter_foreach(handle, tlc_restoreDBCb, NULL);
if (ret != PMINFO_R_OK) {
fprintf(stderr, "Failed pkgmgrinfo_appinfo_metadata_filter_foreach\n");
pkgmgrinfo_appinfo_metadata_filter_destroy(handle);
if (ret != PMINFO_R_OK) {
fprintf(stderr, "Failed pkgmgrinfo_appinfo_metadata_filter_foreach\n");
pkgmgrinfo_appinfo_metadata_filter_destroy(handle);
pkgmgrinfo_appinfo_metadata_filter_destroy(handle);
if (tlc_db) {
pkgmgrinfo_appinfo_metadata_filter_destroy(handle);
if (tlc_db) {
#endif
#define LOG_TAG "DOTNET_INSTALLER_PLUGIN"
#endif
#define LOG_TAG "DOTNET_INSTALLER_PLUGIN"
-static int dbIntegrityCheckCb(void *user_data, int argc, char **argv, char **not_used)
+static int checkIntegrityDBCb(void *user_data, int argc, char **argv, char **not_used)
{
bool* is_db_corrupted = static_cast<bool*>(user_data);
std::string result_DB_check = argv[0];
{
bool* is_db_corrupted = static_cast<bool*>(user_data);
std::string result_DB_check = argv[0];
-sqlite3* dbCreate(std::string path, std::string query)
+sqlite3* createDB(std::string path, std::string query)
{
sqlite3 *sqlite = NULL;
bool is_db_corrupted = false;
{
sqlite3 *sqlite = NULL;
bool is_db_corrupted = false;
sqlite = NULL;
return sqlite;
}
sqlite = NULL;
return sqlite;
}
- ret = sqlite3_exec(sqlite, "PRAGMA integrity_check", dbIntegrityCheckCb, &is_db_corrupted, NULL);
+ ret = sqlite3_exec(sqlite, "PRAGMA integrity_check", checkIntegrityDBCb, &is_db_corrupted, NULL);
if (ret == SQLITE_CORRUPT || is_db_corrupted) {
_INFO("DB file is corrupted, start to recover corrupted db");
sqlite3_close(sqlite);
if (ret == SQLITE_CORRUPT || is_db_corrupted) {
_INFO("DB file is corrupted, start to recover corrupted db");
sqlite3_close(sqlite);
-sqlite3* dbOpen(std::string path)
+sqlite3* openDB(std::string path)
{
sqlite3 *sqlite = NULL;
bool is_db_corrupted = false;
{
sqlite3 *sqlite = NULL;
bool is_db_corrupted = false;
_INFO("DB file is corrupted, start to recover corrupted db");
return sqlite;
}
_INFO("DB file is corrupted, start to recover corrupted db");
return sqlite;
}
- ret = sqlite3_exec(sqlite, "PRAGMA integrity_check", dbIntegrityCheckCb, &is_db_corrupted, NULL);
+ ret = sqlite3_exec(sqlite, "PRAGMA integrity_check", checkIntegrityDBCb, &is_db_corrupted, NULL);
if (ret == SQLITE_CORRUPT || is_db_corrupted) {
_INFO("DB file is corrupted, start to recover corrupted db");
sqlite3_close(sqlite);
if (ret == SQLITE_CORRUPT || is_db_corrupted) {
_INFO("DB file is corrupted, start to recover corrupted db");
sqlite3_close(sqlite);
-void dbFinalize(sqlite3_stmt *stmt)
+void finalizeDB(sqlite3_stmt *stmt)
{
if (stmt) {
sqlite3_finalize(stmt);
{
if (stmt) {
sqlite3_finalize(stmt);
-void dbClose(sqlite3 *sqlite)
+void closeDB(sqlite3 *sqlite)
{
if (sqlite) {
sqlite3_exec(sqlite, "COMMIT;", NULL, NULL, NULL);
{
if (sqlite) {
sqlite3_exec(sqlite, "COMMIT;", NULL, NULL, NULL);
-void dbRollback(sqlite3 *sqlite)
+void rollbackDB(sqlite3 *sqlite)
{
if (sqlite) {
sqlite3_exec(sqlite, "ROLLBACK;", NULL, NULL, NULL);
{
if (sqlite) {
sqlite3_exec(sqlite, "ROLLBACK;", NULL, NULL, NULL);
-static bool dbExec(sqlite3 *sqlite, std::string query)
+static bool execDB(sqlite3 *sqlite, std::string query)
{
int ret = sqlite3_exec(sqlite, query.c_str(), NULL, NULL, NULL);
if (ret != SQLITE_OK) {
{
int ret = sqlite3_exec(sqlite, query.c_str(), NULL, NULL, NULL);
if (ret != SQLITE_OK) {
-bool dbUpdate(sqlite3 *sqlite, std::string query)
+bool updateDB(sqlite3 *sqlite, std::string query)
- return dbExec(sqlite, query);
+ return execDB(sqlite, query);
-bool dbInsert(sqlite3 *sqlite, std::string query)
+bool insertDB(sqlite3 *sqlite, std::string query)
- return dbExec(sqlite, query);
+ return execDB(sqlite, query);
-bool dbDelete(sqlite3 *sqlite, std::string query)
+bool deleteDB(sqlite3 *sqlite, std::string query)
- return dbExec(sqlite, query);
+ return execDB(sqlite, query);
-std::vector<std::string> dbSelect(sqlite3 *sqlite, std::string query)
+std::vector<std::string> selectDB(sqlite3 *sqlite, std::string query)
{
std::vector<std::string> selectData;
sqlite3_stmt* stmt = NULL;
{
std::vector<std::string> selectData;
sqlite3_stmt* stmt = NULL;
str = (const char *) sqlite3_column_text(stmt, 2);
selectData.push_back((!str || !strlen(str)) ? NULL : strdup(str));
}
str = (const char *) sqlite3_column_text(stmt, 2);
selectData.push_back((!str || !strlen(str)) ? NULL : strdup(str));
}