| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_relational_utils.cpp | 94 cloudValue = static_cast<bool>(sqlite3_column_int(statement, cid)); in GetCloudValueByType()
97 cloudValue = static_cast<int64_t>(sqlite3_column_int64(statement, cid)); in GetCloudValueByType()
101 cloudValue = sqlite3_column_double(statement, cid); in GetCloudValueByType()
110 cloudValue = blobValue; in GetCloudValueByType()
121 cloudValue = blobValue; in GetCloudValueByType()
126 cloudValue = str; in GetCloudValueByType()
130 cloudValue = Nil(); in GetCloudValueByType()
136 void SQLiteRelationalUtils::CalCloudValueLen(Type &cloudValue, uint32_t &totalSize) in CalCloudValueLen() argument
138 switch (cloudValue.index()) { in CalCloudValueLen()
146 totalSize += std::get<std::string>(cloudValue).size(); in CalCloudValueLen()
[all …]
|
| H A D | sqlite_relational_utils.h | 32 static int GetCloudValueByType(sqlite3_stmt *statement, int type, int cid, Type &cloudValue);
34 static void CalCloudValueLen(Type &cloudValue, uint32_t &totalSize);
|
| H A D | sqlite_single_ver_relational_storage_executor_extend.cpp | 117 Type cloudValue; in GetInfoByStatement() local
118 … errCode = SQLiteRelationalUtils::GetCloudValueByType(statement, field.type, index++, cloudValue); in GetInfoByStatement()
122 errCode = PutVBucketByType(assetInfo, field, cloudValue); in GetInfoByStatement()
134 Type cloudValue; in GetInfoByStatement() local
139 errCode = PutVBucketByType(dataInfoWithLog.primaryKeys, item.second, cloudValue); in GetInfoByStatement()
1232 Type cloudValue; in GetAssetInfoOnTable() local
1237 errCode = PutVBucketByType(assetInfo, field, cloudValue); in GetAssetInfoOnTable()
1523 if (field.type == TYPE_INDEX<Asset> && cloudValue.index() == TYPE_INDEX<Bytes>) { in PutVBucketByType()
1525 … int errCode = RuntimeContext::GetInstance()->BlobToAsset(std::get<Bytes>(cloudValue), asset); in PutVBucketByType()
1533 } else if (field.type == TYPE_INDEX<Assets> && cloudValue.index() == TYPE_INDEX<Bytes>) { in PutVBucketByType()
[all …]
|
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 1282 Type cloudValue; in GetAssetsByGidOrHashKey() local
1283 … errCode = SQLiteRelationalUtils::GetCloudValueByType(stmt, field.type, index++, cloudValue); in GetAssetsByGidOrHashKey()
1287 errCode = PutVBucketByType(assets, field, cloudValue); in GetAssetsByGidOrHashKey()
1954 Type cloudValue; in GetRecordFromStmt() local
1955 … errCode = SQLiteRelationalUtils::GetCloudValueByType(stmt, field.type, startIndex, cloudValue); in GetRecordFromStmt()
1959 errCode = PutVBucketByType(record, field, cloudValue); in GetRecordFromStmt()
|
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 1652 Type cloudValue; in GetCloudDataForSync() local
1654 tableSchema_.fields[cid].type, cid + STATUS_INDEX + 1, cloudValue); in GetCloudDataForSync()
1658 SQLiteRelationalUtils::CalCloudValueLen(cloudValue, totalSize); in GetCloudDataForSync()
1659 errCode = PutVBucketByType(data, tableSchema_.fields[cid], cloudValue); in GetCloudDataForSync()
|
| H A D | sqlite_single_ver_relational_storage_executor.h | 288 int PutVBucketByType(VBucket &vBucket, const Field &field, Type &cloudValue);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/ |
| H A D | cloud_storage_utils.h | 127 static int GetValueFromOneField(Type &cloudValue, T &outVal) in GetValueFromOneField() argument
129 T *value = std::get_if<T>(&cloudValue); in GetValueFromOneField()
141 Type cloudValue; in GetValueFromVBucket() local
142 bool isExisted = GetTypeCaseInsensitive(fieldName, vBucket, cloudValue); in GetValueFromVBucket()
146 return GetValueFromOneField(cloudValue, outVal); in GetValueFromVBucket()
150 static int GetValueFromType(Type &cloudValue, T &outVal) in GetValueFromType() argument
152 T *value = std::get_if<T>(&cloudValue); in GetValueFromType()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_syncer_download_assets_test.cpp | 350 Type cloudValue; in CheckDownloadFailedForTest002() local
354 ASSERT_EQ(CloudStorageUtils::GetValueFromOneField(cloudValue, assetsBlob), E_OK); in CheckDownloadFailedForTest002()
501 Type cloudValue; in CheckLocaLAssets() local
503 Assets assets = g_virtualCloudDataTranslate->BlobToAssets(std::get<Bytes>(cloudValue)); in CheckLocaLAssets()
537 Type cloudValue; in CheckCursorData() local
539 EXPECT_EQ(std::get<int64_t>(cloudValue), begin); in CheckCursorData()
1269 Type cloudValue; variable
1556 Type cloudValue; variable
1560 ASSERT_EQ(CloudStorageUtils::GetValueFromOneField(cloudValue, assetsBlob), E_OK);
2379 Type cloudValue; variable
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_set_cloud_schema_test.cpp | 203 Type cloudValue; in CheckSharedTable() local
204 …EQ(SQLiteRelationalUtils::GetCloudValueByType(stmt, TYPE_INDEX<std::string>, 0, cloudValue), E_OK); in CheckSharedTable()
206 ASSERT_EQ(CloudStorageUtils::GetValueFromOneField(cloudValue, actualTableName), E_OK); in CheckSharedTable()
225 Type cloudValue; in CheckDistributedSharedTable() local
226 …EQ(SQLiteRelationalUtils::GetCloudValueByType(stmt, TYPE_INDEX<std::string>, 0, cloudValue), E_OK); in CheckDistributedSharedTable()
228 ASSERT_EQ(CloudStorageUtils::GetValueFromOneField(cloudValue, actualTableName), E_OK); in CheckDistributedSharedTable()
1273 Type cloudValue; variable
1274 …SSERT_EQ(SQLiteRelationalUtils::GetCloudValueByType(stmt, TYPE_INDEX<Asset>, 0, cloudValue), E_OK);
1277 ASSERT_EQ(CloudStorageUtils::GetValueFromOneField(cloudValue, assetBlob), E_OK);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_reference_sync_test.cpp | 382 Type cloudValue; in CheckDistributedSharedData() local
383 …EQ(SQLiteRelationalUtils::GetCloudValueByType(stmt, TYPE_INDEX<std::string>, 0, cloudValue), E_OK); in CheckDistributedSharedData()
385 ASSERT_EQ(CloudStorageUtils::GetValueFromOneField(cloudValue, versionValue), E_OK); in CheckDistributedSharedData()
401 Type cloudValue; in CheckSharedDataAfterUpdated() local
402 …SERT_EQ(SQLiteRelationalUtils::GetCloudValueByType(stmt, TYPE_INDEX<double>, 0, cloudValue), E_OK); in CheckSharedDataAfterUpdated()
404 ASSERT_EQ(CloudStorageUtils::GetValueFromOneField(cloudValue, heightValue), E_OK); in CheckSharedDataAfterUpdated()
|
| H A D | distributeddb_cloud_interfaces_relational_sync_test.cpp | 419 Type cloudValue; in CheckDiffTypeAsset() local
420 …SERT_EQ(SQLiteRelationalUtils::GetCloudValueByType(stmt, TYPE_INDEX<Assets>, 0, cloudValue), E_OK); in CheckDiffTypeAsset()
423 ASSERT_EQ(CloudStorageUtils::GetValueFromOneField(cloudValue, assetsBlob), E_OK); in CheckDiffTypeAsset()
463 Type cloudValue; in CheckFillAssetForTest10() local
464 …SSERT_EQ(SQLiteRelationalUtils::GetCloudValueByType(stmt, TYPE_INDEX<Asset>, 0, cloudValue), E_OK); in CheckFillAssetForTest10()
467 ASSERT_EQ(CloudStorageUtils::GetValueFromOneField(cloudValue, assetBlob), E_OK); in CheckFillAssetForTest10()
496 Type cloudValue; in CheckFillAssetsForTest10() local
497 …SERT_EQ(SQLiteRelationalUtils::GetCloudValueByType(stmt, TYPE_INDEX<Assets>, 0, cloudValue), E_OK); in CheckFillAssetsForTest10()
500 ASSERT_EQ(CloudStorageUtils::GetValueFromOneField(cloudValue, assetsBlob), E_OK); in CheckFillAssetsForTest10()
|
| H A D | distributeddb_cloud_assets_operation_sync_test.cpp | 427 Type cloudValue; variable
428 …SERT_EQ(SQLiteRelationalUtils::GetCloudValueByType(stmt, TYPE_INDEX<Assets>, 0, cloudValue), E_OK);
431 ASSERT_EQ(CloudStorageUtils::GetValueFromOneField(cloudValue, assetsBlob), E_OK);
|