| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_storage_utils.cpp | 30 int errCode = GetValueFromVBucket<int64_t>(field.colName, vBucket, val); in BindInt64()
51 int errCode = GetValueFromVBucket<bool>(field.colName, vBucket, val); in BindBool()
72 int errCode = GetValueFromVBucket<double>(field.colName, vBucket, val); in BindDouble()
93 int errCode = GetValueFromVBucket<std::string>(field.colName, vBucket, str); in BindText()
116 errCode = GetValueFromVBucket<Bytes>(field.colName, vBucket, val); in BindBlob()
122 errCode = GetValueFromVBucket(field.colName, vBucket, asset); in BindBlob()
129 errCode = GetValueFromVBucket(field.colName, vBucket, assets); in BindBlob()
263 return CloudStorageUtils::GetValueFromVBucket(field.colName, vBucket, value); in BlobToVector()
1395 int errCode = GetValueFromVBucket(field, data, blobStr); in GetBytesFromCloudData()
1406 int errCode = GetValueFromVBucket(field, data, str); in GetStringFromCloudData()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_syncer_lock_test.cpp | 586 CloudStorageUtils::GetValueFromVBucket<int64_t>(COL_ID, record, cloudPk); in __anon6ad9bb3f0702()
588 CloudStorageUtils::GetValueFromVBucket<int64_t>(COL_ID, cloudRecord, localPk); in __anon6ad9bb3f0702()
593 …CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::VERSION_FIELD, extend, localV… in __anon6ad9bb3f0702()
595 … CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::VERSION_FIELD, cloudExtend, in __anon6ad9bb3f0702()
673 CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::CURSOR_FIELD, extend, cursor); in __anon6ad9bb3f0802()
|
| H A D | distributeddb_cloud_syncer_download_assets_test.cpp | 2333 CloudStorageUtils::GetValueFromVBucket(COL_ASSETS, data, assets);
|
| /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()
842 …errCode = CloudStorageUtils::GetValueFromVBucket<int64_t>(CloudDbConstant::MODIFY_FIELD, vBucket, … in BindValueToInsertLogStatement()
854 …errCode = CloudStorageUtils::GetValueFromVBucket<int64_t>(CloudDbConstant::CREATE_FIELD, vBucket, … in BindValueToInsertLogStatement()
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()
114 (void)CloudStorageUtils::GetValueFromVBucket<Bytes>(HASH_KEY, vBucket, hashKey); in FillCloudAssetForDownload()
260 if (CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::VERSION_FIELD, in BindUpdateVersionStatement()
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()
950 if (CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::GID_FIELD, in BindStmtWithCloudGid()
1974 …errCode = CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::VERSION_FIELD, vBuc… in BindShareValueToInsertLogStatement()
1988 …errCode = CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::SHARING_RESOURCE_FI… in BindShareValueToInsertLogStatement()
|
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 1646 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::FLAG, extraLog, flag); in GetCloudDataForSync()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_executor_utils.cpp | 109 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::FLAG, extraLog, flag); in GetCloudDataForSync()
236 …errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::CLOUD_KV_FIELD_KEY, cloudData, k… in GetLogInfo()
255 errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, cloudData, gid); in GetLogInfo()
862 …errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, data.extend[i], dataI… in FillCloudGid()
869 …CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::VERSION_FIELD, data.extend[i], dataItem.ve… in FillCloudGid()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_utils.cpp | 190 … (void)CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::SHARING_RESOURCE_FIELD, in GetCloudLogInfo()
192 (void)CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::VERSION_FIELD, in GetCloudLogInfo()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/ |
| H A D | cloud_storage_utils.h | 139 static int GetValueFromVBucket(const std::string &fieldName, const VBucket &vBucket, T &outVal) in GetValueFromVBucket() function
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_save_cloud_data_test.cpp | 291 … EXPECT_EQ(CloudStorageUtils::GetValueFromVBucket("id", dataInfoWithLog.primaryKeys, val), E_OK); in GetInfoByPrimaryKeyOrGidTest()
295 …EXPECT_EQ(CloudStorageUtils::GetValueFromVBucket("name", dataInfoWithLog.primaryKeys, name), E_OK); in GetInfoByPrimaryKeyOrGidTest()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 1911 (void)CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, record, cloudGid); in UpdateRecordFlagAfterUpload()
|