| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/ |
| H A D | cloud_db_constant.h | 30 static constexpr const char *CURSOR_FIELD = "#_cursor"; member in DistributedDB::CloudDbConstant
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/ |
| H A D | schema_meta.h | 57 static constexpr const char *CURSOR_FIELD = "#_cursor"; member in OHOS::DistributedData::final
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/ |
| H A D | cloud_cursor_impl.cpp | 167 entry[DBSchemaMeta::CURSOR_FIELD] = cursor_; in GetEntry()
253 if (col == DBSchemaMeta::CURSOR_FIELD) { in Get()
|
| H A D | cloud_db_impl.cpp | 125 auto it = extend.find(DistributedData::SchemaMeta::CURSOR_FIELD); in Query()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_cloud.cpp | 105 cursor->Get(SchemaMeta::CURSOR_FIELD, cursorFlag); in Query()
106 extend[SchemaMeta::CURSOR_FIELD] = ValueProxy::Convert(std::move(cursorFlag)); in Query()
|
| /foundation/distributeddatamgr/relational_store/interfaces/inner_api/rdb/include/ |
| H A D | rdb_types.h | 291 static constexpr const char *CURSOR_FIELD = "#_cursor"; member
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_syncer_lock_test.cpp | 634 extend[CloudDbConstant::CURSOR_FIELD] = std::to_string(30); in HWTEST_F()
642 EXPECT_EQ(std::get<std::string>(extend[CloudDbConstant::CURSOR_FIELD]), std::to_string(cloudCount)); in HWTEST_F()
673 CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::CURSOR_FIELD, extend, cursor); in HWTEST_F()
|
| H A D | distributeddb_cloud_syncer_download_test.cpp | 99 data.insert_or_assign(CloudDbConstant::CURSOR_FIELD, std::to_string(i)); in GetRetCloudData()
149 data.insert_or_assign(CloudDbConstant::CURSOR_FIELD, (int64_t)i); in GetInvalidTypeCloudData()
183 data.insert_or_assign(CloudDbConstant::CURSOR_FIELD, std::to_string(i)); in GetInvalidFieldCloudData()
|
| H A D | distributeddb_cloud_db_proxy_test.cpp | 207 extend[CloudDbConstant::CURSOR_FIELD] = std::string(""); in HWTEST_F()
270 extend[CloudDbConstant::CURSOR_FIELD] = std::string(""); in HWTEST_F()
|
| H A D | cloud_db_sync_utils_test.cpp | 221 extend[CloudDbConstant::CURSOR_FIELD] = std::to_string(0); in CheckCloudTotalCount()
|
| H A D | virtual_cloud_db.cpp | 29 const char *g_cursorField = CloudDbConstant::CURSOR_FIELD;
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_interfaces_relational_sync_test.cpp | 439 extend[CloudDbConstant::CURSOR_FIELD] = std::to_string(0); in CheckAssetForAssetTest006()
548 extend[CloudDbConstant::CURSOR_FIELD] = std::to_string(0); in CheckCloudTotalCount()
833 extend[CloudDbConstant::CURSOR_FIELD] = std::to_string(0); in CheckAllAssetAfterUpload()
853 extend[CloudDbConstant::CURSOR_FIELD] = std::to_string(0); in CheckAllAssetAfterUpload()
1256 extend[CloudDbConstant::CURSOR_FIELD] = std::to_string(0); in HWTEST_F()
1578 log.insert_or_assign(CloudDbConstant::CURSOR_FIELD, "0123"); in HWTEST_F()
1713 extend[CloudDbConstant::CURSOR_FIELD] = std::to_string(0); in HWTEST_F()
|
| H A D | distributeddb_cloud_task_merge_test.cpp | 224 extend[CloudDbConstant::CURSOR_FIELD] = std::to_string(0); in CheckCloudTableCount()
|
| H A D | distributeddb_cloud_check_sync_test.cpp | 424 extend[CloudDbConstant::CURSOR_FIELD] = std::to_string(0); in CheckCloudTableCount()
2212 auto cursor = std::get<std::string>(extend[CloudDbConstant::CURSOR_FIELD]); in HWTEST_F()
2252 auto cursor = std::get<std::string>(extend[CloudDbConstant::CURSOR_FIELD]); in HWTEST_F()
2291 auto cursor = std::get<std::string>(extend[CloudDbConstant::CURSOR_FIELD]); in HWTEST_F()
|
| H A D | distributeddb_cloud_assets_operation_sync_test.cpp | 1016 extend[CloudDbConstant::CURSOR_FIELD] = std::string(""); in HWTEST_F()
|
| H A D | distributeddb_cloud_reference_sync_test.cpp | 355 extend[CloudDbConstant::CURSOR_FIELD] = std::string(); in CheckCloudData()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_syncer.cpp | 905 param.cloudWaterMark = std::get<std::string>(lastData[CloudDbConstant::CURSOR_FIELD]); in SaveData()
1395 std::make_tuple(CloudDbConstant::CURSOR_FIELD, TYPE_INDEX<std::string>, true), in PreHandleData()
1434 if (extend[CloudDbConstant::CURSOR_FIELD].index() != TYPE_INDEX<std::string>) { in QueryCloudData()
1435 LOGE("[CloudSyncer] cursor type is not valid=%d", extend[CloudDbConstant::CURSOR_FIELD].index()); in QueryCloudData()
1438 cloudWaterMark = std::get<std::string>(extend[CloudDbConstant::CURSOR_FIELD]); in QueryCloudData()
|
| H A D | cloud_sync_utils.cpp | 76 key != CloudDbConstant::CURSOR_FIELD && in RemoveDataExceptExtendInfo()
|
| H A D | cloud_syncer_extend.cpp | 75 {CloudDbConstant::CURSOR_FIELD, cloudWaterMark} in FillDownloadExtend()
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/src/ |
| H A D | napi_rdb_const_properties.cpp | 126 SET_NAPI_PROPERTY(field, "CURSOR_FIELD", std::string(DistributedRdb::Field::CURSOR_FIELD)); in ExportField()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_relational_remove_device_data_test.cpp | 316 extend[CloudDbConstant::CURSOR_FIELD] = std::to_string(0); in CheckCloudTotalCount()
|
| H A D | distributeddb_cloud_interfaces_set_cloud_schema_test.cpp | 364 extend[CloudDbConstant::CURSOR_FIELD] = std::to_string(0); in CheckCloudTableCount()
|