| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | simple_tracker_log_table_manager.cpp | 60 if (table.GetTrackerTable().GetTrackerColNames().empty()) { in GetInsertTrigger()
77 insertTrigger += table.GetTrackerTable().GetAssignValSql(); in GetInsertTrigger()
80 insertTrigger += table.GetTrackerTable().GetTrackerColNames().empty() ? "0" : "1"; in GetInsertTrigger()
88 if (table.GetTrackerTable().GetTrackerColNames().empty()) { in GetUpdateTrigger()
101 updateTrigger += " AND " + table.GetTrackerTable().GetDiffTrackerValSql() + ";"; in GetUpdateTrigger()
104 updateTrigger += table.GetTrackerTable().GetExtendAssignValSql(); in GetUpdateTrigger()
105 updateTrigger += table.GetTrackerTable().GetDiffIncCursorSql(tableName); in GetUpdateTrigger()
109 updateTrigger += table.GetTrackerTable().GetDiffTrackerValSql(); in GetUpdateTrigger()
117 if (table.GetTrackerTable().GetTrackerColNames().empty()) { in GetDeleteTrigger()
130 deleteTrigger += table.GetTrackerTable().GetExtendAssignValSql(true); in GetDeleteTrigger()
[all …]
|
| H A D | cloud_sync_log_table_manager.cpp | 111 insertTrigger += table.GetTrackerTable().GetAssignValSql(); in GetInsertTrigger()
119 insertTrigger += (table.GetTrackerTable().GetTrackerColNames().empty() ? "0" : "1"); in GetInsertTrigger()
139 if (!table.GetTrackerTable().GetTrackerColNames().empty()) { in GetUpdateTrigger()
140 updateTrigger += table.GetTrackerTable().GetExtendAssignValSql(); in GetUpdateTrigger()
149 updateTrigger += table.GetTrackerTable().GetDiffTrackerValSql(); in GetUpdateTrigger()
175 if (!table.GetTrackerTable().GetTrackerColNames().empty()) { in GetDeleteTrigger()
176 deleteTrigger += table.GetTrackerTable().GetExtendAssignValSql(true); in GetDeleteTrigger()
184 deleteTrigger += table.GetTrackerTable().GetTrackerColNames().empty() ? "0" : "1"; in GetDeleteTrigger()
200 if (table.GetTrackerTable().GetTrackerColNames().empty()) { in GetDropTriggers()
|
| H A D | sqlite_single_relational_storage_engine.cpp | 248 table.SetTrackerTable(trackerSchema_.GetTrackerTable(sharedTableName)); in CreateDistributedSharedTable()
284 table.SetTrackerTable(GetTrackerSchema().GetTrackerTable(tableName)); in CreateDistributedTable()
288 if (!table.GetTrackerTable().IsEmpty() && tableSyncType == TableSyncType::DEVICE_COOPERATION) { in CreateDistributedTable()
470 if (!tracker.GetTrackerTable(schema.tableName).IsChanging(schema) && !schema.isForceUpgrade) { in SetTrackerTable()
476 bool isUpgrade = !tracker.GetTrackerTable(schema.tableName).IsEmpty(); in SetTrackerTable()
478 int ret = handle->CreateTrackerTable(tracker.GetTrackerTable(schema.tableName), isUpgrade); in SetTrackerTable()
524 isFirstCreate = tracker.GetTrackerTable(schema.tableName).IsEmpty(); in CheckAndCacheTrackerSchema()
526 tableInfo.SetTrackerTable(tracker.GetTrackerTable(schema.tableName)); in CheckAndCacheTrackerSchema()
560 errCode = handle->AnalysisTrackerTable(iter.second.GetTrackerTable(), tableInfo); in GetOrInitTrackerSchemaFromMeta()
562 const std::string trackerTableName = iter.second.GetTrackerTable().GetTableName(); in GetOrInitTrackerSchemaFromMeta()
[all …]
|
| H A D | sqlite_relational_database_upgrader.cpp | 129 tableInfo.SetTrackerTable(trackerSchemaObj.GetTrackerTable(table.first)); in UpgradeTrigger()
142 …int ret = SQLiteRelationalUtils::AnalysisTrackerTable(db_, table.second.GetTrackerTable(), tableIn… in UpgradeTrigger()
|
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 194 TrackerTable trackerTable = tableInfo.GetTrackerTable(); in GeneLogInfoForExistedData()
199 …sql += tableInfo.GetTrackerTable().GetExtendName().empty() ? "''" : tableInfo.GetTrackerTable().Ge… in GeneLogInfoForExistedData()
|
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 491 if (tableInfo.GetTrackerTable().IsEmpty()) { in UpgradedLogForExistedData()
500 TrackerTable trackerTable = tableInfo.GetTrackerTable(); in UpgradedLogForExistedData()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/relational/ |
| H A D | table_info.h | 101 const TrackerTable &GetTrackerTable() const;
|
| H A D | relational_schema_object.h | 59 TrackerTable GetTrackerTable(const std::string &tableName) const;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/relational/ |
| H A D | relational_schema_object.cpp | 179 schemaString_ += it->second.GetTrackerTable().ToString(); in GenerateTrackerSchemaString()
304 TrackerTable RelationalSchemaObject::GetTrackerTable(const std::string &tableName) const in GetTrackerTable() function in DistributedDB::RelationalSchemaObject
308 return it->second.GetTrackerTable(); in GetTrackerTable()
|
| H A D | table_info.cpp | 780 const TrackerTable &TableInfo::GetTrackerTable() const in GetTrackerTable() function in DistributedDB::TableInfo
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 1290 TrackerTable trackerTable = storageEngine_->GetTrackerSchema().GetTrackerTable(tableName); in PutCloudSyncDataInner()
2056 TrackerTable trackerTable = storageEngine_->GetTrackerSchema().GetTrackerTable(tableName); in CreateTempSyncTriggerInner()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_relational_tracker_table_test.cpp | 235 EXPECT_EQ(schemaObject.GetTrackerTable(TABLE_NAME2).IsEmpty(), true); in CheckDropTableAndReopenDb()
|