Home
last modified time | relevance | path

Searched refs:INSERT (Results 1 - 25 of 105) sorted by relevance

12345

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_merge_strategy.cpp45 return OpType::INSERT; in TagSyncDataStatus()
74 : ((isLocalDelete && !JudgeLocalDeleteUpload()) ? OpType::INSERT : OpType::ONLY_UPDATE_GID); in TagLocallyNewer()
92 return OpType::INSERT; in TagCloudUpdateLocal()
103 return OpType::INSERT; in TagLocalNotExist()
H A Dcloud_sync_tag_assets.cpp37 if (flag == AssetOpType::INSERT) { in TagSingleAssetForDownload()
61 case AssetOpType::INSERT: { in TagSingleAssetForUpload()
63 asset.status = static_cast<uint32_t>(AssetStatus::INSERT); in TagSingleAssetForUpload()
134 AssetOpType::INSERT : AssetOpType::NO_CHANGE, coveredAsset, res, errCode); in TagAssetWithSameHash()
145 // all the element in assets will be set to INSERT in TagForNotContainsAsset()
146 TagAssetsWithNormalStatus(setNormalStatus, AssetOpType::INSERT, in TagForNotContainsAsset()
202 TagAssetWithNormalStatus(setNormalStatus, AssetOpType::INSERT, in TagAssets()
205 LOGE("Tag assets INSERT fail!"); in TagAssets()
216 TagAssetWithNormalStatus(setNormalStatus, AssetOpType::INSERT, covered, res, errCode); in TagCoveredAssetInner()
238 TagAssetWithNormalStatus(setNormalStatus, AssetOpType::INSERT, in TagAsset()
[all...]
H A Dcloud_force_pull_strategy.cpp36 return OpType::INSERT; in TagSyncDataStatus()
45 return OpType::INSERT; in TagSyncDataStatus()
H A Dcloud_sync_utils.cpp52 case OpType::INSERT: in OpTypeToChangeType()
91 case AssetStatus::INSERT: in StatusToFlag()
92 return AssetOpType::INSERT; in StatusToFlag()
353 case OpType::INSERT : in UpdateLocalCache()
361 } else if (opType == OpType::INSERT) { in UpdateLocalCache()
388 if (opType == OpType::INSERT) { in SaveChangedData()
398 // INSERT: for no primary key or composite primary key situation in SaveChangedData()
399 if (!param.isSinglePrimaryKey && opType == OpType::INSERT) { in SaveChangedData()
405 // INSERT: only for single primary key situation in SaveChangedData()
406 case OpType::INSERT in SaveChangedData()
[all...]
/foundation/ability/ability_runtime/test/unittest/dataobs_mgr_inner_ext_test/
H A Ddataobs_mgr_inner_ext_test.cpp155 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } }); in HWTEST_F()
159 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri2 } }); in HWTEST_F()
163 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri3 } }); in HWTEST_F()
196 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } }); in HWTEST_F()
204 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri2, uri3 } }); in HWTEST_F()
235 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } }); in HWTEST_F()
239 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri12, uri123, uri14, uri2 } }); in HWTEST_F()
270 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } }); in HWTEST_F()
274 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri14, uri145, uri12, uri123 } }); in HWTEST_F()
307 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_asset_compare_test.cpp276 TagAsset(AssetOpType::INSERT, GetDownloadWithNullStatus(), a1); in HWTEST_F()
277 TagAsset(AssetOpType::INSERT, GetDownloadWithNullStatus(), a2); in HWTEST_F()
278 TagAsset(AssetOpType::INSERT, GetDownloadWithNullStatus(), a3); in HWTEST_F()
279 TagAsset(AssetOpType::INSERT, GetDownloadWithNullStatus(), a4); in HWTEST_F()
297 TagAsset(AssetOpType::INSERT, GetDownloadWithNullStatus(), a1); in HWTEST_F()
298 TagAsset(AssetOpType::INSERT, GetDownloadWithNullStatus(), a2); in HWTEST_F()
299 TagAsset(AssetOpType::INSERT, GetDownloadWithNullStatus(), a3); in HWTEST_F()
300 TagAsset(AssetOpType::INSERT, GetDownloadWithNullStatus(), a4); in HWTEST_F()
394 TagAsset(AssetOpType::INSERT, GetDownloadWithNullStatus(), a4); in HWTEST_F()
415 TagAsset(AssetOpType::INSERT, GetDownloadWithNullStatu in HWTEST_F()
613 EXPECT_EQ(std::get<Asset>(DATA_BASELINE[FIELD_HOUSE]).status, AssetStatus::INSERT); HWTEST_F() member in __anon8300::AssetStatus
614 EXPECT_EQ(std::get<Assets>(DATA_BASELINE[FIELD_CARS])[0].status, AssetStatus::INSERT); HWTEST_F() member in __anon8300::AssetStatus
615 EXPECT_EQ(std::get<Assets>(DATA_BASELINE[FIELD_CARS])[1].status, AssetStatus::INSERT); HWTEST_F() member in __anon8300::AssetStatus
616 EXPECT_EQ(std::get<Assets>(DATA_BASELINE[FIELD_CARS])[2].status, AssetStatus::INSERT); HWTEST_F() member in __anon8300::AssetStatus
756 AssetStatus::INSERT); HWTEST_F() member in __anon8300::AssetStatus
773 EXPECT_EQ(std::get<Assets>(DATA_BASELINE[FIELD_CARS])[0].status, AssetStatus::INSERT); HWTEST_F() member in __anon8300::AssetStatus
774 EXPECT_EQ(std::get<Assets>(DATA_BASELINE[FIELD_CARS])[1].status, AssetStatus::INSERT); HWTEST_F() member in __anon8300::AssetStatus
775 EXPECT_EQ(std::get<Assets>(DATA_BASELINE[FIELD_CARS])[2].status, AssetStatus::INSERT); HWTEST_F() member in __anon8300::AssetStatus
791 EXPECT_EQ(std::get<Assets>(DATA_BASELINE[FIELD_CARS])[0].status, AssetStatus::INSERT); HWTEST_F() member in __anon8300::AssetStatus
792 EXPECT_EQ(std::get<Assets>(DATA_BASELINE[FIELD_CARS])[1].status, AssetStatus::INSERT); HWTEST_F() member in __anon8300::AssetStatus
793 EXPECT_EQ(std::get<Assets>(DATA_BASELINE[FIELD_CARS])[2].status, AssetStatus::INSERT); HWTEST_F() member in __anon8300::AssetStatus
[all...]
H A Ddistributeddb_cloud_strategy_test.cpp107 EXPECT_EQ(strategy->TagSyncDataStatus(false, false, localInfo, cloudInfo), OpType::INSERT); in HWTEST_F()
139 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::INSERT); in HWTEST_F()
253 EXPECT_EQ(strategy->TagSyncDataStatus(false, false, localInfo, cloudInfo), OpType::INSERT); in HWTEST_F()
312 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::INSERT); in HWTEST_F()
328 OpType result = OpType::INSERT; in HWTEST_F()
H A Ddistributeddb_cloud_syncer_lock_test.cpp354 CloudSyncOption option = PrepareOption(Query::Select().FromTable({ ASSETS_TABLE_NAME }), LockAction::INSERT); in TestConflictSync001()
435 case OpType::INSERT: in CheckUploadAbnormal()
477 std::string sql = "INSERT OR REPLACE INTO " + ASSETS_TABLE_NAME + " VALUES('0', 'XX', '', '');"; in HWTEST_F()
502 CloudSyncOption option = PrepareOption(Query::Select().FromTable({ ASSETS_TABLE_NAME }), LockAction::INSERT); in HWTEST_F()
562 CloudSyncOption option = PrepareOption(Query::Select().FromTable({ ASSETS_TABLE_NAME }), LockAction::INSERT); in HWTEST_F()
569 std::string sql = "INSERT INTO " + ASSETS_TABLE_NAME + " VALUES('20', 'XXX', NULL, NULL);"; in HWTEST_F()
683 * @tc.desc: Test download assets status for INSERT
698 * @tc.expected: step2. assets status is INSERT before download. in HWTEST_F()
703 EXPECT_EQ(asset.status, static_cast<uint32_t>(AssetStatus::INSERT)); in HWTEST_F()
707 CloudSyncOption option = PrepareOption(Query::Select().FromTable({ ASSETS_TABLE_NAME }), LockAction::INSERT); in HWTEST_F()
[all...]
/foundation/multimedia/ringtone_library/test/unittest/ringtone_data_extension_test/src/
H A Dringtone_bundle_manager_test.cpp56 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT); in HWTEST_F()
66 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT); in HWTEST_F()
72 EXPECT_EQ(type, RingtoneOperationType::INSERT); in HWTEST_F()
H A Dringtone_rdbstore_test.cpp64 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT); in HWTEST_F()
85 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT); in HWTEST_F()
103 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT); in HWTEST_F()
115 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT); in HWTEST_F()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/
H A Ddb_change_data_mock.cpp23 entries_[INSERT].push_back(entry); in DBChangeDataMock()
35 return entries_[INSERT]; in GetEntriesInserted()
H A Ddb_change_data_mock.h25 INSERT,
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/cloud/
H A Dcloud_store_types.h44 INSERT, member in DistributedDB::AssetOpType
53 INSERT, // INSERT/DELETE/UPDATE are for client use
124 INSERT = 0x1, member in DistributedDB::CloudQueryType::LockAction
158 LockAction lockAction = LockAction::INSERT;
/foundation/multimedia/ringtone_library/test/unittest/ringtone_scanner_test/src/
H A Dringtone_default_settings_test.cpp62 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT); in HWTEST_F()
95 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT); in HWTEST_F()
128 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT); in HWTEST_F()
157 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT); in HWTEST_F()
189 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT); in HWTEST_F()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dsingle_ver_natural_store_commit_notify_data.cpp76 if (dataType == DataType::INSERT || dataType == DataType::UPDATE) { in InsertCommittedData()
82 if (dataType == DataType::INSERT || dataType == DataType::UPDATE) { in InsertCommittedData()
83 type = DataType::INSERT; in InsertCommittedData()
100 if (dataType == DataType::INSERT) { in InsertEntry()
165 if (type == DataType::INSERT) { in DeleteEntryByKey()
/foundation/ability/ability_runtime/test/mock/frameworks_kits_test/DemoAbility/
H A Dmock_ability_test.h27 #define INSERT 20 macro
39 return INSERT; in Insert()
/foundation/multimedia/media_library/frameworks/services/media_thumbnail/src/
H A Dcloud_thumbnail_observer.cpp42 if (changeInfo.changeType_ != ChangeType::INSERT) { in OnChange()
/foundation/distributeddatamgr/data_share/interfaces/inner_api/common/include/
H A Ddatashare_operation_statement.h25 INSERT = 0, member in OHOS::DataShare::Operation
H A Ddatashare_observer.h34 INSERT = 0,
/foundation/ability/ability_runtime/interfaces/inner_api/dataobs_manager/include/
H A Ddataobs_mgr_changeinfo.h27 INSERT = 0,
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/relational/
H A Dprepared_stmt.h26 enum ExecutorOperation { MIN_LIMIT, QUERY, DELETE, UPDATE, INSERT, MAX_LIMIT }; enumerator
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_relational_cloud_syncable_storage_test.cpp124 string sql = "INSERT OR REPLACE INTO " + g_tableName + in CreateAndInitUserTable()
164 string sql = "INSERT OR REPLACE INTO " + tableName + in InitLogData()
240 asset.flag = static_cast<uint32_t>(i == 1 ? AssetOpType::DELETE : AssetOpType::INSERT); in ConstructMultiDownloadData()
249 asset.flag = static_cast<uint32_t>(AssetOpType::INSERT); in ConstructMultiDownloadData()
729 EXPECT_EQ(g_cloudStore->FillCloudLogAndAsset(OpType::INSERT, syncData, false, false), -E_INVALID_ARGS); in HWTEST_F()
737 EXPECT_EQ(g_cloudStore->FillCloudLogAndAsset(OpType::INSERT, syncData, false, false), -E_INVALID_ARGS); in HWTEST_F()
747 EXPECT_EQ(g_cloudStore->FillCloudLogAndAsset(OpType::INSERT, syncData, false, false), -E_INVALID_ARGS); in HWTEST_F()
757 EXPECT_EQ(g_cloudStore->FillCloudLogAndAsset(OpType::INSERT, syncData, false, false), -E_NOT_FOUND); in HWTEST_F()
764 EXPECT_EQ(g_cloudStore->FillCloudLogAndAsset(OpType::INSERT, syncData, false, false), -E_CLOUD_ERROR); in HWTEST_F()
778 EXPECT_EQ(g_cloudStore->FillCloudLogAndAsset(OpType::INSERT, syncDat in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_meta_data_test.cpp220 EXPECT_EQ(proxyObj.GetLocalWaterMarkByMode(TABLE_NAME_1, CloudWaterType::INSERT, retLocalMark), -E_INVALID_DB); in HWTEST_F()
222 EXPECT_EQ(proxyObj.PutWaterMarkByMode(TABLE_NAME_1, CloudWaterType::INSERT, retLocalMark), -E_INVALID_DB); in HWTEST_F()
223 proxyObj.ReleaseUploadRecord(TABLE_NAME_1, CloudWaterType::INSERT, retLocalMark); in HWTEST_F()
284 proxyObj.FillCloudGidIfSuccess(OpType::INSERT, data); in HWTEST_F()
371 EXPECT_EQ(obj.FillCloudLogAndAsset(OpType::INSERT, cloudDataResult, true, true), -E_INVALID_DB); in HWTEST_F()
/foundation/multimedia/media_library/frameworks/services/media_cloud_sync_notify_handle/src/
H A Duri_convert_handler.cpp28 {ChangeType::INSERT, NotifyType::NOTIFY_ADD},
/foundation/multimedia/ringtone_library/services/ringtone_data_extension/include/
H A Dringtone_data_command.h31 INSERT, member in OHOS::Media::RingtoneOperationType

Completed in 13 milliseconds

12345