| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/service_impl/ |
| H A D | cloud_db.rs | 18 Database, RawValueBucket, Value, CREATE_FIELD, GID_FIELD, MODIFY_FIELD,
70 extends[i].insert(GID_FIELD.to_string(), Value::String(id.to_string())); in batch_insert()
73 vb.insert(GID_FIELD.to_string(), Value::String(id.to_string())); in batch_insert()
125 match ext.get(GID_FIELD) { in batch_delete()
252 match ext.get(GID_FIELD) { in upload()
|
| H A D | types.rs | 20 pub(crate) const GID_FIELD: &str = "#_gid";
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_save_cloud_data_test.cpp | 283 vBucket[CloudDbConstant::GID_FIELD] = gidStr; in GetInfoByPrimaryKeyOrGidTest()
465 vBucket[CloudDbConstant::GID_FIELD] = gid; in VbucketWithoutPrimaryDataTest()
546 vBucket[CloudDbConstant::GID_FIELD] = gid; in PrimaryKeyCollateTest()
815 vBucket[CloudDbConstant::GID_FIELD] = gid; in ConstructDownloadData()
1033 vBucket[CloudDbConstant::GID_FIELD] = gid; in ConstructMultiDownloadData()
1156 vBucket[CloudDbConstant::GID_FIELD] = gid;
1191 vBucket[CloudDbConstant::GID_FIELD] = gid;
1256 vBucket[CloudDbConstant::GID_FIELD] = gid; in DeleteWithPkTest()
|
| H A D | distributeddb_cloud_assets_operation_sync_test.cpp | 278 log.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(i)); in UpdateCloudTableRecord()
1032 extend[std::string(CloudDbConstant::GID_FIELD)] = std::string(""); in __anond35eef630c02()
1094 extend[std::string(CloudDbConstant::GID_FIELD)] = ""; in __anond35eef630d02()
|
| H A D | distributeddb_cloud_reference_sync_test.cpp | 329 log.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(i)); in UpdateCloudSharedTableRecord()
331 log.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(++i)); in UpdateCloudSharedTableRecord()
344 data.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(j)); in DeleteCloudSharedTableRecordByGid()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/ |
| H A D | cloud_db_constant.h | 26 static constexpr const char *GID_FIELD = "#_gid"; variable
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/ |
| H A D | cloud_cursor_impl.cpp | 25 { DistributedData::SchemaMeta::GID_FIELD, "id" },
164 entry[DBSchemaMeta::GID_FIELD] = GetExtend(vBucket, GID_KEY); in GetEntry()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/ |
| H A D | schema_meta.h | 54 static constexpr const char *GID_FIELD = "#_gid"; variable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_relational_cloud_syncable_storage_test.cpp | 241 … vBucket[CloudDbConstant::GID_FIELD] = (i == 1 ? std::to_string(i) : std::to_string(count + i)); in ConstructMultiDownloadData()
244 vBucket[CloudDbConstant::GID_FIELD] = std::to_string(i); in ConstructMultiDownloadData()
312 vBucket[CloudDbConstant::GID_FIELD] = std::to_string(1); in fillCloudAssetTest()
787 bucket1.insert_or_assign(CloudDbConstant::GID_FIELD, 1L);
819 bucket1.insert_or_assign(CloudDbConstant::GID_FIELD, std::string("1"));
828 bucket2.insert_or_assign(CloudDbConstant::GID_FIELD, std::string("2"));
991 vBucket[CloudDbConstant::GID_FIELD] = std::to_string(i);
1029 vBucket[CloudDbConstant::GID_FIELD] = std::to_string(i);
1208 bucket1.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(i));
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_executor_extend.cpp | 198 errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, cloudGid); in GetQueryLogStatement()
229 …int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, cloudGid… in GetQueryLogSql()
687 … int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gidStr); in InsertLogRecord()
788 …errCode = CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::GID_FIELD, vBucket,… in BindHashKeyAndGidToInsertLogStatement()
927 … int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gidStr); in GetUpdateDataTableStatement()
1056 … int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gidStr); in GetDeleteStatementForCloudSync()
|
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 42 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gid); in GetQueryInfoSql()
100 …int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, cloudGid… in FillCloudAssetForDownload()
293 …(void)CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::GID_FIELD, vBucket, clo… in InitFillUploadAssetStatement()
718 … int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gidStr); in AppendUpdateLogRecordWhereSqlCondition()
931 auto gidEntry = cloudDataResult.insData.extend[i].find(CloudDbConstant::GID_FIELD); in BindStmtWithCloudGid()
950 if (CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::GID_FIELD, in BindStmtWithCloudGid()
|
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 615 logInfo.insert_or_assign(CloudDbConstant::GID_FIELD, cloudGid); in GetCloudLog()
1846 updateColName.push_back(CloudDbConstant::GID_FIELD); in GetUpdateLogRecordStatement()
1863 updateColName.push_back(CloudDbConstant::GID_FIELD); in GetUpdateLogRecordStatement()
1871 updateColName.push_back(CloudDbConstant::GID_FIELD); in GetUpdateLogRecordStatement()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_syncer_lock_test.cpp | 229 log.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(i + gidStart)); in GenerateDataRecords()
295 log.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(beginGid + i)); in DeleteCloudDBData()
424 log.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(0)); in UpdateCloudAssets()
|
| H A D | cloud_db_sync_utils_test.cpp | 134 log.insert_or_assign(CloudDbConstant::GID_FIELD, to_string(i)); in UpdateCloudTableRecord()
147 data.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(i)); in DeleteCloudTableRecordByGid()
|
| H A D | distributeddb_cloud_syncer_download_test.cpp | 95 data.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(i)); in GetRetCloudData()
137 data.insert_or_assign(CloudDbConstant::GID_FIELD, (int64_t)i); in GetInvalidTypeCloudData()
171 data.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(i)); in GetInvalidFieldCloudData()
|
| H A D | cloud_syncer_test.h | 202 std::pair<std::string, std::string>(CloudDbConstant::GID_FIELD, "0"), in initFullCloudSyncData()
|
| H A D | virtual_cloud_db.cpp | 28 const char *g_gidField = CloudDbConstant::GID_FIELD;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_db_proxy.cpp | 573 if (extend.count(CloudDbConstant::GID_FIELD) == 0) { in IsRecordActionFail()
583 auto gid = std::get_if<std::string>(&extend.at(CloudDbConstant::GID_FIELD)); in IsRecordActionFail()
|
| H A D | cloud_sync_utils.cpp | 72 if (key != CloudDbConstant::GID_FIELD && in RemoveDataExceptExtendInfo()
188 cloudLogInfo.cloudGid = std::get<std::string>(datum[CloudDbConstant::GID_FIELD]); in GetCloudLogInfo()
|
| H A D | cloud_syncer_extend.cpp | 422 normalAssets[CloudDbConstant::GID_FIELD] = gid; in CommitDownloadAssets()
423 failedAssets[CloudDbConstant::GID_FIELD] = gid; in CommitDownloadAssets()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_storage_utils.cpp | 1086 if (colName == CloudDbConstant::GID_FIELD) { in BindUpdateLogStmtFromVBucket()
1212 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, data, gidStr); in BindStepConsistentFlagStmt()
1292 bool isInsert = (!isDelete) && (log.find(CloudDbConstant::GID_FIELD) == log.end()); in IdentifyCloudTypeInner()
1364 GetStringFromCloudData(CloudDbConstant::GID_FIELD, data, dataItem.gid); in GetDataItemFromCloudData()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | query_sync_object.cpp | 257 objNode.fieldName = CloudDbConstant::GID_FIELD; in SetCloudGid()
|
| H A D | sqlite_cloud_kv_executor_utils.cpp | 154 logInfo.insert_or_assign(CloudDbConstant::GID_FIELD, cloudGid); in GetCloudLog()
255 errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, cloudData, gid); in GetLogInfo()
862 …errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, data.extend[i], dataI… in FillCloudGid()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_set_cloud_schema_test.cpp | 302 log.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(beginGid + i)); in InsertCloudTableRecord()
395 log.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(beginGid + i)); in DeleteCloudTableRecord()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_single_ver_multi_sub_user_test.cpp | 330 log.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(i + gidStart)); in GenerateDataRecords()
|