Home
last modified time | relevance | path

Searched refs:GetLogTableName (Results 1 – 25 of 33) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsimple_tracker_log_table_manager.cpp42 const std::string tableName = GetLogTableName(table); in GetIndexSql()
63 std::string logTblName = GetLogTableName(table); in GetInsertTrigger()
92 std::string logTblName = GetLogTableName(table); in GetUpdateTrigger()
128 deleteTrigger += "\t UPDATE " + GetLogTableName(table); in GetDeleteTrigger()
152 std::string deleteLogTable = "DROP TABLE IF EXISTS " + GetLogTableName(table) + ";"; in GetDropTriggers()
H A Dcloud_sync_log_table_manager.cpp65 const std::string tableName = GetLogTableName(table); in GetIndexSql()
93 std::string logTblName = GetLogTableName(table); in GetInsertTrigger()
128 std::string logTblName = GetLogTableName(table); in GetUpdateTrigger()
158 std::string logTblName = GetLogTableName(table); in GetDeleteTrigger()
167 deleteTrigger += "\t UPDATE " + GetLogTableName(table); in GetDeleteTrigger()
201 std::string clearExtendSql = "UPDATE " + GetLogTableName(table) + " SET extend_field = '';"; in GetDropTriggers()
H A Dsqlite_single_ver_relational_storage_executor_extend.cpp338 std::string logTableName = DBCommon::GetLogTableName(tableName); in DoCleanLogs()
457 std::string logTableName = DBCommon::GetLogTableName(tableName); in DoCleanLogAndData()
692 …std::string sql = "DELETE FROM " + DBCommon::GetLogTableName(tableSchema.name) + " WHERE cloud_gid… in InsertLogRecord()
701 std::string sql = "INSERT OR REPLACE INTO " + DBCommon::GetLogTableName(tableSchema.name) + in InsertLogRecord()
703 DBCommon::GetLogTableName(tableSchema.name) + " WHERE hash_key=?) IS NULL THEN 0 ELSE " + in InsertLogRecord()
704 …"(SELECT status FROM " + DBCommon::GetLogTableName(tableSchema.name) + " WHERE hash_key=?) " + "EN… in InsertLogRecord()
882 DBCommon::GetLogTableName(tableName) + " WHERE cloud_gid = '" + gidStr + "')"; in GetWhereConditionForDataTable()
1152 …std::string sql = "UPDATE " + DBCommon::GetLogTableName(tableName) + " SET " + status + " WHERE ha… in UpdateRecordStatus()
1341 std::string sql = "UPDATE " + DBCommon::GetLogTableName(tableName) + in MarkFlagAsConsistent()
1376 std::string sql = "UPDATE '" + DBCommon::GetLogTableName(tableName) + in FillCloudVersionForUpload()
[all …]
H A Dsqlite_single_ver_relational_storage_extend_executor.cpp78 … sql += "SELECT data_key FROM " + DBCommon::GetLogTableName(tableName) + " where cloud_gid = ?);"; in GetFillDownloadAssetStatement()
376 return CheckInventoryData(DBCommon::GetLogTableName(table.GetTableName())); in CreateTrackerTable()
449 std::string logTableName = DBCommon::GetLogTableName(table); in GetClearWaterMarkTables()
481 std::string logTable = DBCommon::GetLogTableName(tableInfo.GetTableName()); in UpgradedLogForExistedData()
829 std::string logTargetTable = DBCommon::GetLogTableName(targetTable); in GetReferenceGidSql()
830 std::string logSourceTable = DBCommon::GetLogTableName(sourceTable); in GetReferenceGidSql()
1008 std::string logTable = DBCommon::GetLogTableName(table); in GetCloudDeleteSql()
1041 …std::string removeLogSql = "DELETE FROM " + DBCommon::GetLogTableName(tableName) + " WHERE data_ke… in RemoveDataAndLog()
1093 std::string logTableName = DBCommon::GetLogTableName(tableName); in DoCleanAssetId()
1930 … sql += "UPDATE " + DBCommon::GetLogTableName(tableName) + " SET status = (CASE WHEN status == 1 "+ in ClearUnLockingStatus()
H A Dcollaboration_log_table_manager.cpp125 GetLogTableName(table) + "(data_key);"; in GetIndexSql()
H A Dsqlite_relational_database_upgrader.cpp190 std::string logName = DBCommon::GetLogTableName(tableName); in UpgradeLogBaseOnVersion()
H A Dsqlite_single_relational_storage_engine.cpp594 errCode = handle->CheckInventoryData(DBCommon::GetLogTableName(tableName)); in SaveTrackerSchema()
852 std::string oldDistributedName = DBCommon::GetLogTableName(tableName.first); in DoAlterSharedTableName()
853 std::string newDistributedName = DBCommon::GetLogTableName(tableName.second); in DoAlterSharedTableName()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_cloud_interfaces_relational_remove_device_data_test.cpp1142 std::string sql = "select count(*) from " + DBCommon::GetLogTableName(tableName) +
1370 std::string sql = "select count(*) from " + DBCommon::GetLogTableName(g_tables[0]) +
1401 std::string sql = "select count(*) from " + DBCommon::GetLogTableName(g_tables[0]) +
1455 std::string sql = "select count() from " + DBCommon::GetLogTableName(g_tables[0]) +
1491 std::string sql = "select count(*) from " + DBCommon::GetLogTableName(g_tables[0]) +
1495 sql = "select count(*) from " + DBCommon::GetLogTableName(g_tables[0]) +
1536 std::string sql = "select count(*) from " + DBCommon::GetLogTableName(g_tables[0]) +
1570 std::string sql = "select count(*) from " + DBCommon::GetLogTableName(g_tables[0]) +
1621 std::string sql = "select count(*) from " + DBCommon::GetLogTableName(g_tables[0]) +
1663 std::string sql = "select count(*) from " + DBCommon::GetLogTableName(g_tables[0]) +
[all …]
H A Ddistributeddb_cloud_interfaces_relational_ext_test.cpp351 sql = "update " + DBCommon::GetLogTableName(tableName) + " set cloud_gid = '" + gid + "'";
361 …sql = "select data_key, device, ori_device, flag, cloud_gid from " + DBCommon::GetLogTableName(tab…
1300 …std::string sql = "UPDATE " + DBCommon::GetLogTableName(tableName) + " SET status=(CASE WHEN data_… in InitDataStatus()
1308 …std::string sql = "SELECT count(1) FROM " + DBCommon::GetLogTableName(tableName) + " WHERE " + con… in CheckDataStatus()
1403 std::string sql = "update " + DBCommon::GetLogTableName(tableName) + " SET status=0";
H A Ddistributeddb_cloud_interfaces_set_cloud_schema_test.cpp270 return "SELECT COUNT(*) FROM " + DBCommon::GetLogTableName(tableName) in QueryResourceCountSql()
1807 …std::string sql = "update " + DBCommon::GetLogTableName(g_sharedTableName1) + " SET sharing_resour…
1819 …sql = "SELECT COUNT(*) FROM " + DBCommon::GetLogTableName(g_sharedTableName1) + " where flag&0x02=…
1857 std::string sql = "SELECT COUNT(*) FROM " + DBCommon::GetLogTableName(g_tableName2)
1867 …sql = "SELECT COUNT(*) FROM " + DBCommon::GetLogTableName(g_tableName2) + " where sharing_resource…
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_log_table_manager.cpp48 const std::string tableName = GetLogTableName(table); in CreateRelationalLogTable()
106 const std::string tableName = GetLogTableName(table); in GetIndexSql()
117 std::string SqliteLogTableManager::GetLogTableName(const TableInfo &table) const in GetLogTableName() function in DistributedDB::SqliteLogTableManager
H A Dsqlite_log_table_manager.h39 std::string GetLogTableName(const TableInfo &table) const;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_syncer_download_assets_test.cpp98 const std::string QUERY_CONSISTENT_SQL = "select count(*) from " + DBCommon::GetLogTableName(ASSETS…
100 const std::string QUERY_COMPENSATED_SQL = "select count(*) from " + DBCommon::GetLogTableName(ASSET…
267 std::string logName = DBCommon::GetLogTableName(ASSETS_TABLE_NAME); in CheckLockStatus()
531 std::string logTableName = DBCommon::GetLogTableName(tableName); in CheckCursorData()
574 std::string logName = DBCommon::GetLogTableName(ASSETS_TABLE_NAME); in InitDataStatusTest()
597 …std::string sql = "select count(*) from " + DBCommon::GetLogTableName(ASSETS_TABLE_NAME) + " WHERE… in DataStatusTest001()
602 …std::string sql = "select count(*) from " + DBCommon::GetLogTableName(ASSETS_TABLE_NAME) + " WHERE… in DataStatusTest001()
676 std::string sql = "update " + DBCommon::GetLogTableName(ASSETS_TABLE_NAME) + in DataStatusTest004()
1593 std::string sql = "update " + DBCommon::GetLogTableName(ASSETS_TABLE_NAME)
2267 std::string logName = DBCommon::GetLogTableName(ASSETS_TABLE_NAME);
[all …]
H A Ddistributeddb_cloud_syncer_lock_test.cpp433 …std::string sql = "SELECT count(*) FROM " + DBCommon::GetLogTableName(ASSETS_TABLE_NAME) + " WHERE… in CheckUploadAbnormal()
479 sql = "select count(*) from " + DBCommon::GetLogTableName(ASSETS_TABLE_NAME) +
515 std::string sql = "select count(*) from " + DBCommon::GetLogTableName(ASSETS_TABLE_NAME) +
766 std::string sql = "select count(*) from " + DBCommon::GetLogTableName(ASSETS_TABLE_NAME) +
806 std::string sql = "select count(*) from " + DBCommon::GetLogTableName(ASSETS_TABLE_NAME) +
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_save_cloud_data_test.cpp151 sql = "update " + DBCommon::GetLogTableName(tableName) + " set cloud_gid = '" + in PrepareDataBase()
154 sql = "update " + DBCommon::GetLogTableName(tableName) + " set cloud_gid = '" + in PrepareDataBase()
869 std::string sql = "select count(data_key) from " + DBCommon::GetLogTableName(g_tableName) +
1110 sql = "select device, timestamp, flag from " + DBCommon::GetLogTableName(g_tableName) +
1203 std::string sql = "select cloud_gid, flag from " + DBCommon::GetLogTableName(g_tableName) +
1335 sql = "update " + DBCommon::GetLogTableName("t_cloud") + " set flag = 0";
1344 sql = "select flag from " + DBCommon::GetLogTableName("t_cloud") + " where data_key = -1;";
1360 sql = "select flag from " + DBCommon::GetLogTableName("t_device") + " where flag = 0x03;";
1502 sql = "select flag from " + DBCommon::GetLogTableName(g_tableName) +
1514 sql = "select flag from " + DBCommon::GetLogTableName(g_tableName) +
[all …]
H A Ddistributeddb_cloud_check_sync_test.cpp582 std::string sql1 = "select count(*) from " + DBCommon::GetLogTableName(tableName_) + in CheckLogCleaned()
586 …std::string sql2 = "select count(*) from " + DBCommon::GetLogTableName(tableName_) + " where cloud… in CheckLogCleaned()
590 std::string sql3 = "select count(*) from " + DBCommon::GetLogTableName(tableName_) + in CheckLogCleaned()
2016 std::string sql = "update " + DBCommon::GetLogTableName(tableName_) +
2020 …sql = "select count(*) from " + DBCommon::GetLogTableName(tableName_) + " where flag & 0x800=0x800…
2435 std::string querySql = "select count(*) from " + DBCommon::GetLogTableName(tableName_) +
2467 …std::string sql = "update " + DBCommon::GetLogTableName(tableName_) + " SET status = 1 where data_… in SyncDataStatusTest()
2469 …sql = "update " + DBCommon::GetLogTableName(tableName_) + " SET status = 2 where data_key in (2,12… in SyncDataStatusTest()
2471 …sql = "update " + DBCommon::GetLogTableName(tableName_) + " SET status = 3 where data_key in (3,13… in SyncDataStatusTest()
2486 std::string preSql = "select count(*) from " + DBCommon::GetLogTableName(tableName_); in SyncDataStatusTest()
H A Ddistributeddb_cloud_reference_sync_test.cpp377 …std::string sql = "SELECT version FROM " + DBCommon::GetLogTableName(sharedTables_[i]) + " WHERE r… in CheckDistributedSharedData()
889 …QLiteUtils::GetStatement(db_, "SELECT max(timestamp) FROM " + DBCommon::GetLogTableName("table_c"),
902 …ASSERT_EQ(SQLiteUtils::GetStatement(db_, "SELECT count(*) FROM " + DBCommon::GetLogTableName("tabl…
945 …QLiteUtils::GetStatement(db_, "SELECT max(timestamp) FROM " + DBCommon::GetLogTableName("table_d"),
958 …ASSERT_EQ(SQLiteUtils::GetStatement(db_, "SELECT count(*) FROM " + DBCommon::GetLogTableName("tabl…
H A Ddistributeddb_cloud_assets_operation_sync_test.cpp593 …std::string sql = "SELECT cursor FROM " + DBCommon::GetLogTableName(tableName_) + " where data_key…
596 sql = "SELECT cursor FROM " + DBCommon::GetLogTableName(tableName_) + " where data_key=5";
831 …std::string checkLogSql = "SELECT count(*) FROM " + DBCommon::GetLogTableName(tableName_) + " whe…
846 …checkLogSql = "SELECT count(*) FROM " + DBCommon::GetLogTableName(tableName_) + " where cursor = …
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Drdb_store.cpp240 std::string logTable = GetLogTableName(table); in Query()
264 std::string logTable = GetLogTableName(table); in QueryByStep()
600 std::string RdbStore::GetLogTableName(const std::string &tableName) in GetLogTableName() function in OHOS::NativeRdb::RdbStore
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/
H A Dcloud_storage_utils.cpp805 std::string sourceLogName = DBCommon::GetLogTableName(reference.sourceTableName); in GetTableRefUpdateSql()
845 …sql += " FROM '" + DBCommon::GetLogTableName(tableName) + "' AS a LEFT JOIN '" + tableName + "' AS… in GetLeftJoinLogSql()
848 …sql += " FROM '" + DBCommon::GetLogTableName(tableName) + "' AS b LEFT JOIN '" + tableName + "' AS… in GetLeftJoinLogSql()
1132 …std::string sql = "UPDATE " + DBCommon::GetLogTableName(tableName) + " SET flag = (CASE WHEN times… in GetUpdateRecordFlagSql()
1171 …sql += "UPDATE " + DBCommon::GetLogTableName(tableName) + " SET flag = (CASE WHEN timestamp = ? OR… in GetUpdateRecordFlagSqlUpload()
1174 …sql += "UPDATE " + DBCommon::GetLogTableName(tableName) + " SET flag = (CASE WHEN timestamp = ? TH… in GetUpdateRecordFlagSqlUpload()
1204 …return "UPDATE " + DBCommon::GetLogTableName(tableName) + " SET flag = (CASE WHEN timestamp = ? AN… in GetUpdateUploadFinishedSql()
1487 " NULL THEN 0 ELSE MAX(cursor) END FROM " + DBCommon::GetLogTableName(tableName) + "));"; in GetCursorUpgradeSql()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/storage_fuzzer/
H A Dstorage_fuzzer.cpp290 …std::string sql = "UPDATE " + DBCommon::GetLogTableName(tableName) + " SET status=(CASE WHEN data_… in InitDataStatus()
300 …std::string sql = "select hash_key from " + DBCommon::GetLogTableName(tableName) + " where " + con… in GetHashKey()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/
H A Ddb_common.h35 static inline std::string GetLogTableName(const std::string &tableName) in GetLogTableName() function
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_store_manager.cpp162 return DBCommon::GetLogTableName(tableName); in GetDistributedLogTableName()
/ohos5.0/foundation/distributeddatamgr/relational_store/interfaces/inner_api/rdb/include/
H A Drdb_store.h696 virtual std::string GetLogTableName(const std::string &tableName);
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/
H A Drdb_store_impl.h156 std::string GetLogTableName(const std::string &tableName) override;

12