Home
last modified time | relevance | path

Searched refs:cloudDataResult (Results 1 – 17 of 17) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_syncer_upload_test.cpp410 cloudDataResult = uploadData; in __anon29de99fb0502()
466 cloudDataResult = uploadData2; in __anon29de99fb0702()
475 cloudDataResult = uploadData3; in __anon29de99fb0802()
532 cloudDataResult = uploadData2; in __anon29de99fb0a02()
582 cloudDataResult = uploadData; in __anon29de99fb0c02()
595 cloudDataResult = uploadData; in __anon29de99fb0d02()
646 cloudDataResult = uploadData2; in __anon29de99fb0f02()
683 cloudDataResult = uploadData; in __anon29de99fb1002()
759 cloudDataResult = uploadData2; in __anon29de99fb1302()
814 cloudDataResult = uploadData3; in __anon29de99fb1502()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_continue_token.cpp176 …iteSingleVerRelationalContinueToken::GetCloudStatement(sqlite3 *db, CloudSyncData &cloudDataResult, in GetCloudStatement() argument
189 …std::string sql = helper.GetRelationalCloudQuerySql(tableSchema_.fields, cloudDataResult.isCloudFo… in GetCloudStatement()
190 cloudDataResult.isCompensatedTask, cloudDataResult.mode); in GetCloudStatement()
H A Dsqlite_single_ver_relational_continue_token.h43 …int GetCloudStatement(sqlite3 *db, CloudSyncData &cloudDataResult, sqlite3_stmt *&queryStmt, bool …
H A Dsqlite_single_ver_relational_storage_executor_extend.cpp1471 …t SQLiteSingleVerRelationalStorageExecutor::UpdateCloudLogGid(const CloudSyncData &cloudDataResult, in UpdateCloudLogGid() argument
1474 if (cloudDataResult.insData.extend.empty() || cloudDataResult.insData.rowid.empty() || in UpdateCloudLogGid()
1475 cloudDataResult.insData.extend.size() != cloudDataResult.insData.rowid.size()) { in UpdateCloudLogGid()
1478 std::string sql = "UPDATE '" + DBCommon::GetLogTableName(cloudDataResult.tableName) in UpdateCloudLogGid()
1485 errCode = BindStmtWithCloudGid(cloudDataResult, ignoreEmptyGid, stmt); in UpdateCloudLogGid()
1492 CloudSyncData &cloudDataResult, SQLiteSingleVerRelationalContinueToken &token) in GetSyncCloudData() argument
1497 int errCode = token.GetCloudStatement(dbHandle_, cloudDataResult, queryStmt, isStepNext); in GetSyncCloudData()
1513 … errCode = GetCloudDataForSync(uploadRecorder, queryStmt, cloudDataResult, ++stepNum, totalSize); in GetSyncCloudData()
H A Dsqlite_single_ver_relational_storage_executor.h121 int UpdateCloudLogGid(const CloudSyncData &cloudDataResult, bool ignoreEmptyGid);
123 int GetSyncCloudData(const CloudUploadRecorder &uploadRecorder, CloudSyncData &cloudDataResult,
286 CloudSyncData &cloudDataResult, uint32_t &stepNum, uint32_t &totalSize);
384 …int BindStmtWithCloudGid(const CloudSyncData &cloudDataResult, bool ignoreEmptyGid, sqlite3_stmt *…
H A Dsqlite_single_ver_relational_storage_extend_executor.cpp925 …QLiteSingleVerRelationalStorageExecutor::BindStmtWithCloudGid(const CloudSyncData &cloudDataResult, in BindStmtWithCloudGid() argument
930 for (size_t i = 0; i < cloudDataResult.insData.extend.size(); ++i) { in BindStmtWithCloudGid()
931 auto gidEntry = cloudDataResult.insData.extend[i].find(CloudDbConstant::GID_FIELD); in BindStmtWithCloudGid()
932 if (gidEntry == cloudDataResult.insData.extend[i].end()) { in BindStmtWithCloudGid()
934 if (DBCommon::IsRecordAssetsMissing(cloudDataResult.insData.extend[i])) { in BindStmtWithCloudGid()
945 bool containError = DBCommon::IsRecordError(cloudDataResult.insData.extend[i]); in BindStmtWithCloudGid()
951 cloudDataResult.insData.extend[i], val) != E_OK) { in BindStmtWithCloudGid()
961 … errCode = BindStmtWithCloudGidInner(val, cloudDataResult.insData.rowid[i], stmt, fillGidCount); in BindStmtWithCloudGid()
H A Dsqlite_single_ver_relational_storage_executor.cpp1636 sqlite3_stmt *statement, CloudSyncData &cloudDataResult, uint32_t &stepNum, uint32_t &totalSize) in GetCloudDataForSync() argument
1667 …errCode = CloudStorageUtils::IdentifyCloudType(uploadRecorder, cloudDataResult, data, log, extraLo… in GetCloudDataForSync()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dstorage_proxy.h70 ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult);
73 ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult);
75 int GetCloudDataNext(ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) const;
H A Dicloud_sync_storage_interface.h119 ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) = 0;
121 …virtual int GetCloudDataNext(ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) = 0;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_meta_data_test.cpp229 CloudSyncData cloudDataResult; variable
230 …EXPECT_EQ(proxyObj.GetCloudData(query, retLocalMark, continueStmtToken, cloudDataResult), -E_INVAL…
231 EXPECT_EQ(proxyObj.GetCloudDataNext(continueStmtToken, cloudDataResult), -E_INVALID_DB);
372 CloudSyncData cloudDataResult; variable
373 … EXPECT_EQ(obj.FillCloudLogAndAsset(OpType::INSERT, cloudDataResult, true, true), -E_INVALID_DB);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dstorage_proxy.cpp223 ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) in GetCloudData() argument
227 return GetCloudData(querySyncObject, timeRange, continueStmtToken, cloudDataResult); in GetCloudData()
231 ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) in GetCloudData() argument
246 … store_->GetCloudData(tableSchema, querySyncObject, timeRange, continueStmtToken, cloudDataResult); in GetCloudData()
249 int StorageProxy::GetCloudDataNext(ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult… in GetCloudDataNext()
259 return store_->GetCloudDataNext(continueStmtToken, cloudDataResult); in GetCloudDataNext()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_cloud_kv_store.h53 ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) override;
55 int GetCloudDataNext(ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) override;
H A Dsqlite_cloud_kv_store.cpp180 const Timestamp &beginTime, ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) in GetCloudData() argument
192 cloudDataResult.tableName = CloudDbConstant::CLOUD_KV_TABLE_NAME; in GetCloudData()
194 return GetCloudDataNext(continueStmtToken, cloudDataResult); in GetCloudData()
197 …iteCloudKvStore::GetCloudDataNext(ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) in GetCloudDataNext() argument
215 cloudDataResult); in GetCloudDataNext()
H A Dsqlite_cloud_kv_executor_utils.h67 sqlite3_stmt *statement, CloudSyncData &cloudDataResult, UploadDetail &detail);
H A Dsqlite_cloud_kv_executor_utils.cpp98 sqlite3_stmt *statement, CloudSyncData &cloudDataResult, UploadDetail &detail) in GetCloudDataForSync() argument
122 … errCode = CloudStorageUtils::IdentifyCloudType(recorder, cloudDataResult, data, log, extraLog); in GetCloudDataForSync()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_able_storage.cpp1103 const Timestamp &beginTime, ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) in GetCloudData() argument
1119 return GetCloudDataNext(continueStmtToken, cloudDataResult); in GetCloudData()
1123 CloudSyncData &cloudDataResult) in GetCloudDataNext() argument
1137 cloudDataResult.isShared = IsSharedTable(cloudDataResult.tableName); in GetCloudDataNext()
1140 int errCode = transactionHandle_->GetSyncCloudData(uploadRecorder_, cloudDataResult, *token); in GetCloudDataNext()
1141 LOGI("mode:%d upload data, ins:%zu, upd:%zu, del:%zu, lock:%zu", cloudDataResult.mode, in GetCloudDataNext()
1142 cloudDataResult.insData.extend.size(), cloudDataResult.updData.extend.size(), in GetCloudDataNext()
1143 cloudDataResult.delData.extend.size(), cloudDataResult.lockData.extend.size()); in GetCloudDataNext()
1152 int fillRefGidCode = FillReferenceData(cloudDataResult); in GetCloudDataNext()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_sync_able_storage.h150 ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) override;
152 int GetCloudDataNext(ContinueToken &continueStmtToken, CloudSyncData &cloudDataResult) override;