| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | flatbuffer_schema.cpp | 308 auto type = fieldInfo.type(); in DoVerifyBeforeExtract()
347 auto strVal = flatbuffers::GetFieldS(rootValue, fieldInfo); in DoExtractString()
356 auto type = fieldInfo.type(); in DoExtractValue()
404 auto type = fieldInfo.type(); in ExtractFlatBufferValueFinal()
412 int errCode = DoVerifyBeforeExtract(rootValue, fieldInfo, verifier); in ExtractFlatBufferValueFinal()
417 errCode = DoExtractValue(rootValue, fieldInfo, outExtract); in ExtractFlatBufferValueFinal()
443 auto fieldInfo = GetFieldInfoFromSchemaByPath(*schema, pathStr); in ExtractFlatBufferValue() local
444 if (fieldInfo == nullptr) { in ExtractFlatBufferValue()
616 fieldInfo.type = MapFieldType(baseType); in ParseCheckFieldInfo()
617 fieldInfo.isIndexable = (IsIndexableType(baseType) && isRootField); in ParseCheckFieldInfo()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_data_transformer_test.cpp | 187 FieldInfo fieldInfo; variable
188 fieldInfo.SetStorageType(item.first);
189 fieldInfo.SetFieldName(std::to_string(count++));
190 fieldInfoList.push_back(fieldInfo);
|
| H A D | distributeddb_cloud_schema_mgr_test.cpp | 708 FieldInfo fieldInfo; variable
709 fieldInfo.SetDataType("long");
710 EXPECT_EQ(fieldInfo.GetStorageType(), StorageType::STORAGE_TYPE_INTEGER);
711 fieldInfo.SetDataType("LONG");
712 EXPECT_EQ(fieldInfo.GetStorageType(), StorageType::STORAGE_TYPE_INTEGER);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | schema_mgr.cpp | 91 for (const auto &[fieldName, fieldInfo] : localFields) { in CompareFieldSchema()
92 if (!fieldInfo.HasDefaultValue() && in CompareFieldSchema()
93 fieldInfo.IsNotNull() && in CompareFieldSchema()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/relational/ |
| H A D | table_info.cpp | 710 for (const auto &[fieldName, fieldInfo] : GetFields()) { in GetSchemaDefine()
712 defaultValue.stringValue = fieldInfo.GetDefaultValue(); in GetSchemaDefine()
716 .hasNotNullConstraint = fieldInfo.IsNotNull(), in GetSchemaDefine()
717 .hasDefaultValue = fieldInfo.HasDefaultValue(), in GetSchemaDefine()
|
| H A D | relational_schema_object.cpp | 720 FieldInfo fieldInfo; in ParseCheckTableDefine() local
721 fieldInfo.SetFieldName(field.first[1]); // 1 : table name element in path in ParseCheckTableDefine()
722 errCode = ParseCheckTableFieldInfo(fieldObj, field.first, fieldInfo); in ParseCheckTableDefine()
727 resultTable.AddField(fieldInfo); in ParseCheckTableDefine()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | data_transformer.h | 95 … static int SerializeDataItem(const RowDataWithLog &data, const std::vector<FieldInfo> &fieldInfo,
|
| H A D | data_transformer.cpp | 59 const std::vector<FieldInfo> &fieldInfo, DataItem &dataItem) in SerializeDataItem() argument
61 int errCode = SerializeValue(dataItem.value, data.rowData, fieldInfo); in SerializeDataItem()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_relational_ver_p2p_sync_test.cpp | 173 for (const auto &fieldInfo : fieldInfoList) { in PrepareInsert() local
177 sql += fieldInfo.GetFieldName(); in PrepareInsert()
301 for (auto &fieldInfo : fieldInfoList) { in GenerateValue() local
304 fieldInfo.SetStorageType(StorageType::STORAGE_TYPE_NULL); in GenerateValue()
306 typeMapFunction[fieldInfo.GetStorageType()](dataValue); in GenerateValue()
307 dataMap[fieldInfo.GetFieldName()] = std::move(dataValue); in GenerateValue()
537 FieldInfo fieldInfo; in GetFieldInfo() local
538 fieldInfo.SetFieldName("field_" + std::to_string(index)); in GetFieldInfo()
539 fieldInfo.SetColumnId(index); in GetFieldInfo()
540 fieldInfo.SetStorageType(type); in GetFieldInfo()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_executor_extend.cpp | 575 for (const auto &fieldInfo: fieldInfos) { in GetCloudAssets() local
576 if (fieldInfo.IsAssetType()) { in GetCloudAssets()
577 errCode = GetAssetOnTable(tableName, fieldInfo.GetFieldName(), dataKeys, assets); in GetCloudAssets()
582 } else if (fieldInfo.IsAssetsType()) { in GetCloudAssets()
583 errCode = GetCloudAssetsOnTable(tableName, fieldInfo.GetFieldName(), dataKeys, assets); in GetCloudAssets()
|
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 1111 for (const auto &fieldInfo : fieldInfos) { in CleanAssetId() local
1112 if (fieldInfo.IsAssetType()) { in CleanAssetId()
1114 errCode = GetAssetOnTable(tableName, fieldInfo.GetFieldName(), dataKeys, assets); in CleanAssetId()
1119 … errCode = UpdateAssetIdOnUserTable(tableName, fieldInfo.GetFieldName(), dataKeys, assets); in CleanAssetId()
1124 } else if (fieldInfo.IsAssetsType()) { in CleanAssetId()
1125 errCode = GetAssetsAndUpdateAssetsId(tableName, fieldInfo.GetFieldName(), dataKeys); in CleanAssetId()
|
| H A D | sqlite_relational_store.cpp | 1527 for (auto &fieldInfo : table.GetFieldInfos()) { in CheckSchemaForUpsertData() local
1528 schemaFields.insert(fieldInfo.GetFieldName()); in CheckSchemaForUpsertData()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 470 for (const auto &fieldInfo : fieldInfos) { // order by cid in GetSyncDataNext() local
471 fieldNames.push_back(fieldInfo.GetFieldName()); in GetSyncDataNext()
|