| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/tests/ |
| H A D | demo.txt | 42 "colName": "data",
60 "colName": "uuid",
76 "colName": "data",
94 "colName": "uuid",
110 "colName": "data",
128 "colName": "uuid",
144 "colName": "data",
162 "colName": "uuid",
178 "colName": "data",
196 "colName": "uuid",
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/cloud/ |
| H A D | asset_operation_utils.cpp | 45 for (const auto &[colName, colData] : cacheAssets) { in CalAssetOperation()
46 auto checkAssets = GetAssets(colName, dbAssets); in CalAssetOperation()
49 res[colName][asset.name] = reaction(asset, checkAssets); in CalAssetOperation()
53 res[colName][asset.name] = reaction(asset, checkAssets); in CalAssetOperation()
60 AssetOperationUtils::AssetOpType AssetOperationUtils::CalAssetOperation(const std::string &colName, in CalAssetOperation() argument
66 return reaction(cacheAsset, GetAssets(colName, dbAssets)); in CalAssetOperation()
86 for (auto &[colName, colData] : targetRecord) { in UpdateAssetsFlag()
87 auto fromAssets = GetAssets(colName, fromRecord); in UpdateAssetsFlag()
189 Assets AssetOperationUtils::GetAssets(const std::string &colName, const VBucket &rowData) in GetAssets() argument
191 if (rowData.find(colName) == rowData.end()) { in GetAssets()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_cloud_schema_mgr_test.cpp | 80 .colName = FIELD_NAME_1,
86 .colName = FIELD_NAME_2,
98 .colName = FIELD_NAME_1,
104 .colName = FIELD_NAME_2,
116 .colName = FIELD_NAME_1,
122 .colName = FIELD_NAME_2,
128 .colName = FIELD_NAME_3,
140 .colName = FIELD_NAME_1,
146 .colName = FIELD_NAME_2,
152 .colName = FIELD_NAME_3,
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/relational/ |
| H A D | tracker_table.cpp | 62 for (const auto &colName: trackerColNames_) { in GetDiffTrackerValSql() local
63 sql += "(NEW." + colName + " IS NOT OLD." + colName + ")"; in GetDiffTrackerValSql()
80 for (const auto &colName: trackerColNames_) { in GetDiffIncCursorSql() local
81 sql += "(NEW." + colName + " IS NOT OLD." + colName + ")"; in GetDiffIncCursorSql()
104 for (const auto &colName: trackerColNames_) { in ToString() local
105 attrStr += "\"" + colName + "\","; in ToString()
234 void TrackerTable::SetExtendName(const std::string &colName) in SetExtendName() argument
236 extendColName_ = colName; in SetExtendName()
|
| H A D | relational_row_data_set.cpp | 61 for (const auto &colName : colNames_) { in Serialize() local
62 (void)parcel.WriteString(colName); in Serialize()
125 for (const auto &colName : colNames_) { in SetColNames() local
126 serialLength_ -= Parcel::GetStringLen(colName); in SetColNames()
129 for (const auto &colName : colNames_) { in SetColNames() local
130 serialLength_ += Parcel::GetStringLen(colName); in SetColNames()
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/ |
| H A D | rdb_sqlite_shared_result_set_test.cpp | 254 std::string colName = ""; variable
256 EXPECT_EQ(colName, "data5");
259 EXPECT_EQ(colName, "data6");
320 std::string colName = ""; variable
322 EXPECT_EQ(colName, "data1");
325 EXPECT_EQ(colName, "data2");
328 EXPECT_EQ(colName, "data3");
331 EXPECT_EQ(colName, "data4");
780 std::string colName = ""; variable
782 EXPECT_EQ(colName, "data1");
[all …]
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/innerkitsimpl/media_library_helper/src/ |
| H A D | file_asset.cpp | 657 void FileAsset::SetResultTypeMap(const string &colName, ResultSetDataType type) in SetResultTypeMap() argument
659 if (resultTypeMap_.count(colName) != 0) { in SetResultTypeMap()
662 resultTypeMap_.insert(make_pair(colName, type)); in SetResultTypeMap()
667 for (auto &[colName, _] : member_) { in GetAssetJson()
668 if (resultTypeMap_.count(colName) == 0) { in GetAssetJson()
671 switch (resultTypeMap_.at(colName)) { in GetAssetJson()
673 jsonObject[colName] = GetStrMember(colName); in GetAssetJson()
676 jsonObject[colName] = GetInt32Member(colName); in GetAssetJson()
679 jsonObject[colName] = GetInt64Member(colName); in GetAssetJson()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | cache_cursor_test.cpp | 86 std::string colName; variable
87 auto err = cursor->GetColumnName(4, colName);
89 err = cursor->GetColumnName(-1, colName);
91 err = cursor->GetColumnName(1, colName);
136 std::string colName; variable
137 auto err = cursor->GetColumnName(4, colName);
139 err = cursor->GetColumnName(-1, colName);
141 err = cursor->GetColumnName(1, colName);
|
| H A D | cloud_test.cpp | 123 field.colName = "field_name1_test";
133 EXPECT_EQ(field.colName, field2.colName);
|
| H A D | rdb_result_set_impl_test.cpp | 104 std::string colName; variable
105 ASSERT_EQ(resultSet->GetColumnName(i, colName), NativeRdb::E_OK);
106 ASSERT_EQ(colName, names[i]);
109 ASSERT_EQ(columnType, getColumnType(colName));
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_storage_utils.cpp | 292 pkSet.insert(field.colName); in GetCloudPrimaryKey()
320 return a.colName < b.colName; in GetCloudPrimaryKeyField()
335 pkMap[field.colName] = field; in GetCloudPrimaryKeyFieldMap()
418 vBucket[field.colName] = asset; in ChangeAssetsOnVBucketToAsset()
1084 for (const auto &colName : colNames) { in BindUpdateLogStmtFromVBucket() local
1086 if (colName == CloudDbConstant::GID_FIELD) { in BindUpdateLogStmtFromVBucket()
1087 if (vBucket.find(colName) == vBucket.end()) { in BindUpdateLogStmtFromVBucket()
1092 std::get<std::string>(vBucket.at(colName))); in BindUpdateLogStmtFromVBucket()
1094 if (vBucket.find(colName) == vBucket.end()) { in BindUpdateLogStmtFromVBucket()
1100 if (vBucket.find(colName) == vBucket.end()) { in BindUpdateLogStmtFromVBucket()
[all …]
|
| H A D | schema_mgr.cpp | 64 if (localFields.find(cloudField.colName) == localFields.end()) { in CompareFieldSchema()
72 FieldInfo &localField = localFields[cloudField.colName]; in CompareFieldSchema()
85 cloudColNames.emplace(cloudField.colName); in CompareFieldSchema()
141 if (DBCommon::CaseInsensitiveCompare(kvPair.second, cloudField.colName)) { in ComparePrimaryField()
165 if (localFields.find((*it).colName) == localFields.end()) { in SetCloudDbSchema()
167 … LOGI("Column name mismatch between local and cloud schema, colName: %s", (*it).colName.c_str()); in SetCloudDbSchema()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | param_check_utils.cpp | 295 … if (fields.find(field.colName) != fields.end() || field.colName == CloudDbConstant::CLOUD_OWNER || in CheckSharedTableName()
296 field.colName == CloudDbConstant::CLOUD_PRIVILEGE) { in CheckSharedTableName()
300 fields.insert(field.colName); in CheckSharedTableName()
313 … std::transform(field.colName.begin(), field.colName.end(), field.colName.begin(), ::tolower); in TransferSchemaToLower()
|
| /ohos5.0/base/hiviewdfx/hiview/plugins/usage_event_report/cache/ |
| H A D | fold_app_usage_db_helper.cpp | 65 const std::string& colName, std::string &value) in GetStringFromResultSet() argument
68 if (resultSet->GetColumnIndex(colName, colIndex) != NativeRdb::E_OK) { in GetStringFromResultSet()
69 HIVIEW_LOGE("failed to get column index, column = %{public}s", colName.c_str()); in GetStringFromResultSet()
73 HIVIEW_LOGE("failed to get string value, column = %{public}s", colName.c_str()); in GetStringFromResultSet()
80 const std::string& colName, int &value) in GetIntFromResultSet() argument
83 if (resultSet->GetColumnIndex(colName, colIndex) != NativeRdb::E_OK) { in GetIntFromResultSet()
84 HIVIEW_LOGE("failed to get column index, column = %{public}s", colName.c_str()); in GetIntFromResultSet()
88 HIVIEW_LOGE("failed to get int value, column = %{public}s", colName.c_str()); in GetIntFromResultSet()
95 const std::string& colName, int64_t &value) in GetLongFromResultSet() argument
98 if (resultSet->GetColumnIndex(colName, colIndex) != NativeRdb::E_OK) { in GetLongFromResultSet()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/ |
| H A D | schema_meta.cpp | 87 SetValue(node[GET_NAME(colName)], colName); in Marshal()
97 GetValue(node, GET_NAME(colName), colName); in Unmarshal()
|
| /ohos5.0/base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/cache/ |
| H A D | app_event_store.cpp | 47 …FromResultSet(std::shared_ptr<NativeRdb::AbsSharedResultSet> resultSet, const std::string& colName) in GetIntFromResultSet() argument
51 if (resultSet->GetColumnIndex(colName, colIndex) != NativeRdb::E_OK) { in GetIntFromResultSet()
52 HILOG_WARN(LOG_CORE, "failed to get column index, colName=%{public}s", colName.c_str()); in GetIntFromResultSet()
56 HILOG_WARN(LOG_CORE, "failed to get int value, colName=%{public}s", colName.c_str()); in GetIntFromResultSet()
61 …FromResultSet(std::shared_ptr<NativeRdb::AbsSharedResultSet> resultSet, const std::string& colName) in GetLongFromResultSet() argument
65 if (resultSet->GetColumnIndex(colName, colIndex) != NativeRdb::E_OK) { in GetLongFromResultSet()
66 HILOG_WARN(LOG_CORE, "failed to get column index, colName=%{public}s", colName.c_str()); in GetLongFromResultSet()
70 HILOG_WARN(LOG_CORE, "failed to get long value, colName=%{public}s", colName.c_str()); in GetLongFromResultSet()
79 if (resultSet->GetColumnIndex(colName, colIndex) != NativeRdb::E_OK) { in GetStringFromResultSet()
80 HILOG_WARN(LOG_CORE, "failed to get column index, colName=%{public}s", colName.c_str()); in GetStringFromResultSet()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_data_inserter.cpp | 117 std::string colName; in GetInsertStatement() local
123 colName += "'" + it.GetFieldName() + "',"; in GetInsertStatement()
126 colName.pop_back(); in GetInsertStatement()
130 " (" + colName + ") VALUES (" + dataFormat + ");"; in GetInsertStatement()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/cloud/ |
| H A D | cloud_store_types.h | 96 std::string colName; member
102 return (colName == comparedField.colName) && (type == comparedField.type) &&
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/ |
| H A D | asset_operation_utils.h | 37 …static AssetOperationUtils::AssetOpType CalAssetOperation(const std::string &colName, const Asset …
51 static Assets GetAssets(const std::string &colName, const VBucket &rowData);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_relational_utils.cpp | 250 const char *colName = sqlite3_column_name(stmt, cid); in GetSelectVBucket() local
251 bucket.insert_or_assign(colName, std::move(typeVal)); in GetSelectVBucket()
385 for (const auto &[colName, colType] : fieldList) { in AddUpgradeSqlToList()
386 auto it = tableInfo.GetFields().find(colName); in AddUpgradeSqlToList()
390 sqlList.push_back("alter table " + tableInfo.GetTableName() + " add " + colName + in AddUpgradeSqlToList()
|
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 55 sql += ", b." + field.colName; in GetQueryInfoSql()
74 sql += field.colName + " = ?,"; in GetFillDownloadAssetStatement()
635 createTableSql += ", " + field.colName + " "; in CreateSharedTable()
639 primaryKey += ", " + field.colName; in CreateSharedTable()
687 addColumnSql += field.colName + " "; in UpdateSharedTable()
1264 sql += " b." + field.colName + ","; in GetAssetsByGidOrHashKey()
1710 UpdateLocalAssetId(vBucket, field.colName, asset); in UpdateAssetId()
1713 updateAssetIdSql += " " + field.colName + " = ?,"; in UpdateAssetId()
1718 UpdateLocalAssetsId(vBucket, field.colName, assets); in UpdateAssetId()
1784 useFields.insert(field.colName); in GetUpdateField()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_db_proxy_test.cpp | 40 .colName = "col1", in GetFields()
46 .colName = "col2", in GetFields()
51 .colName = "col3", in GetFields()
217 Type expect = expectRecords[i][field.colName];
218 Type actual = actualRecords[i][field.colName];
276 Type expect = expectRecords[i][field.colName];
277 Type actual = actualRecords[i][field.colName];
|
| H A D | distributeddb_cloud_kv_syncer_test.cpp | 197 field.colName = CloudDbConstant::CLOUD_KV_FIELD_KEY; in GetDataBaseSchema()
201 field.colName = CloudDbConstant::CLOUD_KV_FIELD_DEVICE; in GetDataBaseSchema()
204 field.colName = CloudDbConstant::CLOUD_KV_FIELD_ORI_DEVICE; in GetDataBaseSchema()
206 field.colName = CloudDbConstant::CLOUD_KV_FIELD_VALUE; in GetDataBaseSchema()
208 field.colName = CloudDbConstant::CLOUD_KV_FIELD_DEVICE_CREATE_TIME; in GetDataBaseSchema()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_tag_assets.cpp | 338 … assets = TagAssets(assetField.colName, coveredData, beCoveredData, setNormalStatus, errCode); in TagAssetsInSingleCol()
342 … assets = TagAsset(assetField.colName, coveredData, beCoveredData, setNormalStatus, errCode); in TagAssetsInSingleCol()
366 TagAssetsForUpload(assetField.colName, isInsert, coveredData); in TagAssetsInSingleCol()
370 TagAssetForUpload(assetField.colName, isInsert, coveredData); in TagAssetsInSingleCol()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/cloudsync_fuzzer/ |
| H A D | cloudsync_fuzzer.cpp | 340 field.colName = CloudDbConstant::CLOUD_KV_FIELD_KEY; in GetDataBaseSchema()
344 field.colName = CloudDbConstant::CLOUD_KV_FIELD_DEVICE; in GetDataBaseSchema()
347 field.colName = CloudDbConstant::CLOUD_KV_FIELD_ORI_DEVICE; in GetDataBaseSchema()
349 field.colName = CloudDbConstant::CLOUD_KV_FIELD_VALUE; in GetDataBaseSchema()
351 field.colName = CloudDbConstant::CLOUD_KV_FIELD_DEVICE_CREATE_TIME; in GetDataBaseSchema()
|