| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 783 … errCode = GetReferenceGidInner(tableName, targetTable, syncBatch, targetReference, referenceGid); in GetReferenceGid()
793 const std::string &targetTable, const CloudSyncBatch &syncBatch, in GetReferenceGidInner() argument
812 errCode = GetReferenceGidByStmt(statement, syncBatch, targetTable, referenceGid); in GetReferenceGidInner()
862 …const CloudSyncBatch &syncBatch, const std::string &targetTable, std::map<int64_t, Entries> &refer… in GetReferenceGidByStmt() argument
865 if (syncBatch.rowid.size() != syncBatch.timestamp.size()) { in GetReferenceGidByStmt()
866 … LOGE("[RDBExecutor] rowid size [%zu] not equal to timestamp size [%zu].", syncBatch.rowid.size(), in GetReferenceGidByStmt()
867 syncBatch.timestamp.size()); in GetReferenceGidByStmt()
871 for (size_t i = 0u; i < syncBatch.rowid.size(); i++) { in GetReferenceGidByStmt()
872 … errCode = SQLiteUtils::BindInt64ToStatement(statement, 1, syncBatch.rowid[i]); // 1 is rowid index in GetReferenceGidByStmt()
877 …errCode = SQLiteUtils::BindInt64ToStatement(statement, 2, syncBatch.timestamp[i]); // 2 is timesta… in GetReferenceGidByStmt()
[all …]
|
| H A D | sqlite_single_ver_relational_storage_executor.h | 165 int GetReferenceGid(const std::string &tableName, const CloudSyncBatch &syncBatch,
372 … const CloudSyncBatch &syncBatch, const std::vector<TableReferenceProperty> &targetTableReference,
375 int GetReferenceGidByStmt(sqlite3_stmt *statement, const CloudSyncBatch &syncBatch,
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_store.h | 110 …atic void FillTimestamp(Timestamp rawSystemTime, Timestamp virtualTime, CloudSyncBatch &syncBatch);
|
| H A D | sqlite_cloud_kv_executor_utils.cpp | 1084 CloudSyncBatch syncBatch = isInsert ? data.insData : data.updData; in FillCloudVersionRecord() local
1085 if (syncBatch.record.empty()) { in FillCloudVersionRecord()
1089 syncBatch.record[0].insert(syncBatch.extend[0].begin(), syncBatch.extend[0].end()); in FillCloudVersionRecord()
1090 …auto res = CloudStorageUtils::GetSystemRecordFromCloudData(syncBatch.record[0]); // only record fi… in FillCloudVersionRecord()
|
| H A D | sqlite_cloud_kv_store.cpp | 475 …udKvStore::FillTimestamp(Timestamp rawSystemTime, Timestamp virtualTime, CloudSyncBatch &syncBatch) in FillTimestamp() argument
477 for (auto &item : syncBatch.extend) { in FillTimestamp()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_save_cloud_data_test.cpp | 1431 const CloudSyncBatch &syncBatch, std::map<int64_t, Entries> &referenceGid) { in __anon2ff534420802() argument
1433 EXPECT_EQ(syncBatch.rowid.size(), 1u); // has 1 record in __anon2ff534420802()
1434 for (auto rowid : syncBatch.rowid) { in __anon2ff534420802()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_sync_able_storage.h | 239 virtual int GetReferenceGid(const std::string &tableName, const CloudSyncBatch &syncBatch,
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 1601 …onalSyncAbleStorage::GetReferenceGid(const std::string &tableName, const CloudSyncBatch &syncBatch, in GetReferenceGid() argument
1617 errCode = handle->GetReferenceGid(tableName, syncBatch, tableReference, referenceGid); in GetReferenceGid()
|