Home
last modified time | relevance | path

Searched refs:colName (Results 1 - 25 of 59) sorted by relevance

123

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/cloud/
H A Dasset_operation_utils.cpp45 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()
188 Assets AssetOperationUtils::GetAssets(const std::string &colName, const VBucket &rowData) in GetAssets() argument
190 if (rowData.find(colName) in GetAssets()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_cloud_schema_mgr_test.cpp80 .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
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/relational/
H A Drelational_row_data_set.cpp61 for (const auto &colName : colNames_) { in Serialize()
62 (void)parcel.WriteString(colName); in Serialize()
125 for (const auto &colName : colNames_) { in SetColNames()
126 serialLength_ -= Parcel::GetStringLen(colName); in SetColNames()
129 for (const auto &colName : colNames_) { in SetColNames()
130 serialLength_ += Parcel::GetStringLen(colName); in SetColNames()
H A Dtracker_table.cpp62 for (const auto &colName: trackerColNames_) { in GetDiffTrackerValSql()
63 sql += "(NEW." + colName + " IS NOT OLD." + colName + ")"; in GetDiffTrackerValSql()
80 for (const auto &colName: trackerColNames_) { in GetDiffIncCursorSql()
81 sql += "(NEW." + colName + " IS NOT OLD." + colName + ")"; in GetDiffIncCursorSql()
104 for (const auto &colName: trackerColNames_) { in ToString()
105 attrStr += "\"" + colName + "\","; in ToString()
234 void TrackerTable::SetExtendName(const std::string &colName) in SetExtendName() argument
236 extendColName_ = colName; in SetExtendName()
[all...]
/foundation/multimedia/media_library/frameworks/innerkitsimpl/media_library_helper/src/
H A Dfile_asset.cpp657 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()
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/
H A Dschema_meta.cpp87 SetValue(node[GET_NAME(colName)], colName); in Marshal()
97 GetValue(node, GET_NAME(colName), colName); in Unmarshal()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dcache_cursor_test.cpp88 std::string colName; in HWTEST_F() local
89 auto err = cursor->GetColumnName(4, colName); in HWTEST_F()
91 err = cursor->GetColumnName(-1, colName); in HWTEST_F()
93 err = cursor->GetColumnName(1, colName); in HWTEST_F()
138 std::string colName; in HWTEST_F() local
139 auto err = cursor->GetColumnName(4, colName); in HWTEST_F()
141 err = cursor->GetColumnName(-1, colName); in HWTEST_F()
143 err = cursor->GetColumnName(1, colName); in HWTEST_F()
H A Dcloud_test.cpp123 field.colName = "field_name1_test"; in HWTEST_F()
133 EXPECT_EQ(field.colName, field2.colName); in HWTEST_F()
H A Drdb_result_set_impl_test.cpp105 std::string colName; in HWTEST_F() local
106 ASSERT_EQ(resultSet->GetColumnName(i, colName), NativeRdb::E_OK); in HWTEST_F()
107 ASSERT_EQ(colName, names[i]); in HWTEST_F()
110 ASSERT_EQ(columnType, getColumnType(colName)); in HWTEST_F()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Dparam_check_utils.cpp295 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()
H A Dschema_utils.cpp514 std::string colName(srcName.length(), ' '); in TransTrackerSchemaToLower()
515 std::transform(srcName.begin(), srcName.end(), colName.begin(), ::tolower); in TransTrackerSchemaToLower()
516 destSchema.trackerColNames.insert(colName); in TransTrackerSchemaToLower()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/
H A Dcloud_storage_utils.cpp30 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()
155 bool isExisted = GetTypeCaseInsensitive(field.colName, vBucket, entry); in BindAsset()
208 if (CloudStorageUtils::GetValueFromVBucket(field.colName, vBucket, val) != E_OK) { in Int64ToVector()
220 if (CloudStorageUtils::GetValueFromVBucket(field.colName, vBucke in BoolToVector()
[all...]
H A Dschema_mgr.cpp64 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()
167 if (localFields.find((*it).colName) == localFields.end()) { in SetCloudDbSchema()
169 LOGI("Column name mismatch between local and cloud schema, colName: %s", (*it).colName.c_str()); in SetCloudDbSchema()
/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/
H A Drdb_sqlite_shared_result_set_test.cpp254 std::string colName = ""; in HWTEST_F() local
255 rstSet->GetColumnName(5, colName); in HWTEST_F()
256 EXPECT_EQ(colName, "data5"); in HWTEST_F()
258 rstSet->GetColumnName(6, colName); in HWTEST_F()
259 EXPECT_EQ(colName, "data6"); in HWTEST_F()
320 std::string colName = ""; in HWTEST_F() local
321 rstSet->GetColumnName(1, colName); in HWTEST_F()
322 EXPECT_EQ(colName, "data1"); in HWTEST_F()
324 rstSet->GetColumnName(2, colName); in HWTEST_F()
325 EXPECT_EQ(colName, "data in HWTEST_F()
780 std::string colName = ""; HWTEST_F() local
1528 std::string colName = ""; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/
H A Dasset_operation_utils.h37 static AssetOperationUtils::AssetOpType CalAssetOperation(const std::string &colName, const Asset &cacheAsset,
51 static Assets GetAssets(const std::string &colName, const VBucket &rowData);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/cloud/
H A Dcloud_store_types.h96 std::string colName; member
102 return (colName == comparedField.colName) && (type == comparedField.type) && in operator ==()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_data_inserter.cpp117 std::string colName; in GetInsertStatement() local
123 colName += "'" + it.GetFieldName() + "',"; in GetInsertStatement()
126 colName.pop_back(); in GetInsertStatement()
130 " (" + colName + ") VALUES (" + dataFormat + ");"; in GetInsertStatement()
/foundation/distributeddatamgr/relational_store/test/native/relational_store_test/unittest/
H A Drdb_store_test.cpp881 std::string colName = ""; in HWTEST_F() local
882 rstSet->GetColumnName(1, colName); in HWTEST_F()
883 EXPECT_EQ(colName, "data1"); in HWTEST_F()
885 rstSet->GetColumnName(2, colName); in HWTEST_F()
886 EXPECT_EQ(colName, "data2"); in HWTEST_F()
888 rstSet->GetColumnName(3, colName); in HWTEST_F()
889 EXPECT_EQ(colName, "data3"); in HWTEST_F()
891 rstSet->GetColumnName(4, colName); in HWTEST_F()
892 EXPECT_EQ(colName, "data4"); in HWTEST_F()
1392 std::string colName in HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_relational_utils.cpp250 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()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_db_proxy_test.cpp40 .colName = "col1", in GetFields()
46 .colName = "col2", in GetFields()
51 .colName = "col3", in GetFields()
217 Type expect = expectRecords[i][field.colName]; in HWTEST_F()
218 Type actual = actualRecords[i][field.colName]; in HWTEST_F()
276 Type expect = expectRecords[i][field.colName]; in HWTEST_F()
277 Type actual = actualRecords[i][field.colName]; in HWTEST_F()
H A Dcloud_db_data_utils.cpp58 bucket[field.colName] = std::move(value); in GenerateRecord()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_sync_tag_assets.cpp334 assets = TagAssets(assetField.colName, coveredData, beCoveredData, setNormalStatus, errCode); in TagAssetsInSingleCol()
338 assets = TagAsset(assetField.colName, coveredData, beCoveredData, setNormalStatus, errCode); in TagAssetsInSingleCol()
362 TagAssetsForUpload(assetField.colName, isInsert, coveredData); in TagAssetsInSingleCol()
366 TagAssetForUpload(assetField.colName, isInsert, coveredData); in TagAssetsInSingleCol()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/cloudsync_fuzzer/
H A Dcloudsync_fuzzer.cpp340 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()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/relational/
H A Dtracker_table.h52 void SetExtendName(const std::string &colName);
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/
H A Dextension_util.cpp157 size_t fdLen = field.colName.size() + field.alias.size() + sizeof(int) + sizeof(bool) * 2; in Convert()
159 .colName = reinterpret_cast<const unsigned char *>(field.colName.c_str()), in Convert()
160 .colNameLen = field.colName.size(), in Convert()

Completed in 19 milliseconds

123