Home
last modified time | relevance | path

Searched refs:logTableName (Results 1 – 7 of 7) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_storage_executor.cpp1298 std::string logTableName = DBConstant::RELATIONAL_PREFIX + tableName + "_log"; in DeleteDistributedLogTable() local
1299 std::string deleteSql = "DROP TABLE IF EXISTS " + logTableName + ";"; in DeleteDistributedLogTable()
1708 cleanLogSql = "UPDATE " + logTableName + " SET " + CloudDbConstant::FLAG; in CleanCloudDataOnLogTable()
1726 const std::string &logTableName, const RelationalSchemaObject &localSchema) in CleanCloudDataAndLogOnUserTable() argument
1729 " IN (SELECT " + DATAKEY + " FROM '" + logTableName + "' WHERE (" + FLAG_IS_LOGIC_DELETE + in CleanCloudDataAndLogOnUserTable()
1737 std::string cleanLogSql = "DELETE FROM '" + logTableName + "' WHERE " + FLAG_IS_CLOUD + " OR " + in CleanCloudDataAndLogOnUserTable()
1749 errCode = CleanCloudDataOnLogTable(logTableName, FLAG_AND_DATA); in CleanCloudDataAndLogOnUserTable()
1758 std::string cleanLogSql = "UPDATE " + logTableName + " SET " + CloudDbConstant::FLAG + " = " + in ChangeCloudDataFlagOnLogTable()
1769 const std::string &logTableName) in SetDataOnUserTableWithLogicDelete() argument
1805 return ChangeCloudDataFlagOnLogTable(logTableName); in SetDataOnUserTableWithLogicDelete()
[all …]
H A Dsqlite_single_ver_relational_storage_executor.h220 int CleanCloudDataOnLogTable(const std::string &logTableName, ClearMode mode);
222 … int CleanCloudDataAndLogOnUserTable(const std::string &tableName, const std::string &logTableName,
225 int ChangeCloudDataFlagOnLogTable(const std::string &logTableName);
227 …t SetDataOnUserTableWithLogicDelete(const std::string &tableName, const std::string &logTableName);
240 int GetCleanCloudDataKeys(const std::string &logTableName, std::vector<int64_t> &dataKeys,
H A Dsqlite_single_ver_relational_storage_executor_extend.cpp338 std::string logTableName = DBCommon::GetLogTableName(tableName); in DoCleanLogs() local
345 errCode = CleanCloudDataOnLogTable(logTableName, FLAG_ONLY); in DoCleanLogs()
457 std::string logTableName = DBCommon::GetLogTableName(tableName); in DoCleanLogAndData() local
459 errCode = GetCleanCloudDataKeys(logTableName, dataKeys, true); in DoCleanLogAndData()
472 errCode = SetDataOnUserTableWithLogicDelete(tableName, logTableName); in DoCleanLogAndData()
474 errCode = CleanCloudDataAndLogOnUserTable(tableName, logTableName, localSchema); in DoCleanLogAndData()
1132 std::string logTableName = DBConstant::SYSTEM_TABLE_PREFIX + missTable; in DeleteTableTrigger() local
1134 std::string deleteSql = "DROP TRIGGER IF EXISTS " + logTableName + endName + ";"; in DeleteTableTrigger()
H A Dsqlite_single_ver_relational_storage_extend_executor.cpp449 std::string logTableName = DBCommon::GetLogTableName(table); in GetClearWaterMarkTables() local
451 int errCode = SQLiteUtils::CheckTableExists(dbHandle_, logTableName, isExists); in GetClearWaterMarkTables()
462 errCode = SQLiteUtils::CheckTableEmpty(dbHandle_, logTableName, isEmpty); in GetClearWaterMarkTables()
1093 std::string logTableName = DBCommon::GetLogTableName(tableName); in DoCleanAssetId() local
1094 int errCode = GetCleanCloudDataKeys(logTableName, dataKeys, false); in DoCleanAssetId()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_relational_cloud_syncable_storage_test.cpp1256 std::string logTableName = RelationalStoreManager::GetDistributedLogTableName(tableName); variable
1261 std::string querysql = "select timestamp/10000 from " + logTableName + " where hash_key=?";
1312 std::string logTableName = RelationalStoreManager::GetDistributedLogTableName(tableName); variable
1317 std::string querysql = "select timestamp/10000 from " + logTableName + " where hash_key=?";
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_store_sqlite_ext.cpp1175 std::string logTableName; in GetCurrentMaxTimestamp() local
1176 GetColumnTextValue(checkTableStmt, 0, logTableName); in GetCurrentMaxTimestamp()
1177 if (logTableName.empty()) { in GetCurrentMaxTimestamp()
1181 std::string getMaxTimestampSql = "SELECT MAX(timestamp) FROM " + logTableName + ";"; in GetCurrentMaxTimestamp()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_syncer_download_assets_test.cpp531 std::string logTableName = DBCommon::GetLogTableName(tableName); in CheckCursorData() local
532 std::string sql = "SELECT cursor FROM " + logTableName + ";"; in CheckCursorData()