| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_executor.h | 135 const TrackerTable &trackerTable, DownloadData &downloadData);
148 int AnalysisTrackerTable(const TrackerTable &trackerTable, TableInfo &tableInfo);
149 int CreateTrackerTable(const TrackerTable &trackerTable, bool isUpgrade);
155 int CreateTempSyncTrigger(const TrackerTable &trackerTable, bool flag);
291 … const TrackerTable &trackerTable, DownloadData &downloadData, std::map<int, int> &statisticMap);
318 …InsertCloudData(VBucket &vBucket, const TableSchema &tableSchema, const TrackerTable &trackerTable,
321 …int InsertLogRecord(const TableSchema &tableSchema, const TrackerTable &trackerTable, VBucket &vBu…
330 const TrackerTable &trackerTable, sqlite3_stmt *insertLogStmt);
336 const TrackerTable &trackerTable, sqlite3_stmt *insertLogStmt);
362 const TrackerTable &trackerTable);
[all …]
|
| H A D | sqlite_single_ver_relational_storage_executor_extend.cpp | 251 const TableSchema &tableSchema, const TrackerTable &trackerTable, DownloadData &downloadData, in ExecutePutCloudData() argument
266 errCode = DeleteCloudData(tableName, vBucket, tableSchema, trackerTable); in ExecutePutCloudData()
643 const TrackerTable &trackerTable, int64_t dataKey) in InsertCloudData() argument
677 return InsertLogRecord(tableSchema, trackerTable, vBucket); in InsertCloudData()
681 const TrackerTable &trackerTable, VBucket &vBucket) in InsertLogRecord() argument
801 …if (trackerTable.GetExtendName().empty() || vBucket.find(trackerTable.GetExtendName()) == vBucket.… in BindHashKeyAndGidToInsertLogStatement()
804 Type extendValue = vBucket.at(trackerTable.GetExtendName()); in BindHashKeyAndGidToInsertLogStatement()
1088 const TableSchema &tableSchema, const TrackerTable &trackerTable) in DeleteCloudData() argument
1091 return LogicDeleteCloudData(tableName, vBucket, tableSchema, trackerTable); in DeleteCloudData()
1183 const TableSchema &tableSchema, const TrackerTable &trackerTable) in LogicDeleteCloudData() argument
[all …]
|
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 324 int SQLiteSingleVerRelationalStorageExecutor::AnalysisTrackerTable(const TrackerTable &trackerTable, in AnalysisTrackerTable() argument
327 return SQLiteRelationalUtils::AnalysisTrackerTable(dbHandle_, trackerTable, tableInfo); in AnalysisTrackerTable()
334 int errCode = AnalysisTrackerTable(trackerTable, table); in CreateTrackerTable()
339 if (trackerTable.GetTrackerColNames().empty()) { in CreateTrackerTable()
362 …errCode = GeneLogInfoForExistedData(dbHandle_, trackerTable.GetTableName(), calPrimaryKeyHash, tab… in CreateTrackerTable()
500 TrackerTable trackerTable = tableInfo.GetTrackerTable(); in UpgradedLogForExistedData() local
501 errCode = trackerTable.ReBuildTempTrigger(dbHandle_, TriggerMode::TriggerModeEnum::UPDATE, in UpgradedLogForExistedData()
515 std::vector<std::string> dropSql = trackerTable.GetDropTempTriggerSql(); in CreateTempSyncTrigger()
523 errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, trackerTable.GetTempInsertTriggerSql(flag)); in CreateTempSyncTrigger()
528 errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, trackerTable.GetTempUpdateTriggerSql(flag)); in CreateTempSyncTrigger()
[all …]
|
| H A D | sqlite_relational_utils.cpp | 395 int SQLiteRelationalUtils::AnalysisTrackerTable(sqlite3 *db, const TrackerTable &trackerTable, Tabl… in AnalysisTrackerTable() argument
397 int errCode = SQLiteUtils::AnalysisSchema(db, trackerTable.GetTableName(), tableInfo, true); in AnalysisTrackerTable()
402 tableInfo.SetTrackerTable(trackerTable); in AnalysisTrackerTable()
|
| H A D | sqlite_relational_utils.h | 47 …static int AnalysisTrackerTable(sqlite3 *db, const TrackerTable &trackerTable, TableInfo &tableInf…
|
| H A D | sqlite_single_relational_storage_engine.cpp | 697 TrackerTable trackerTable = GetTrackerSchema().GetTrackerTable(tableName); in CleanTrackerData() local
700 if (!trackerTable.IsTableNameEmpty() && in CleanTrackerData()
|
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 194 TrackerTable trackerTable = tableInfo.GetTrackerTable(); in GeneLogInfoForExistedData() local
195 trackerTable.SetTableName(tableName); in GeneLogInfoForExistedData()
201 … errCode = trackerTable.ReBuildTempTrigger(db, TriggerMode::TriggerModeEnum::INSERT, [db, &sql]() { in GeneLogInfoForExistedData()
|
| /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() local
1292 errCode = handle->PutCloudSyncData(tableName, tableSchema, trackerTable, downloadData); in PutCloudSyncDataInner()
2056 TrackerTable trackerTable = storageEngine_->GetTrackerSchema().GetTrackerTable(tableName); in CreateTempSyncTriggerInner() local
2057 if (trackerTable.IsEmpty()) { in CreateTempSyncTriggerInner()
2058 trackerTable.SetTableName(tableName); in CreateTempSyncTriggerInner()
2060 return handle->CreateTempSyncTrigger(trackerTable, flag); in CreateTempSyncTriggerInner()
|