/applications/standard/contacts_data/dataBusiness/contacts/src/ |
H A D | profile_database.cpp | 95 int SqliteOpenHelperProfileCallback::OnCreate(OHOS::NativeRdb::RdbStore &store) in OnCreate() argument 97 store.ExecuteSql(CREATE_CONTACT); in OnCreate() 98 store.ExecuteSql(CREATE_CONTACT_INDEX); in OnCreate() 99 store.ExecuteSql(CREATE_RAW_CONTACT); in OnCreate() 100 store.ExecuteSql(CREATE_RAW_CONTACT_INDEX); in OnCreate() 101 store.ExecuteSql(CREATE_CONTACT_DATA); in OnCreate() 102 store.ExecuteSql(CREATE_CONTACT_INDEX_DATA1); in OnCreate() 103 store.ExecuteSql(CREATE_CONTACT_INDEX_DATA2); in OnCreate() 104 store.ExecuteSql(CREATE_CONTACT_BLOCKLIST); in OnCreate() 105 store in OnCreate() 134 OnUpgrade(OHOS::NativeRdb::RdbStore &store, int oldVersion, int newVersion) OnUpgrade() argument 147 UpgradeToV2(OHOS::NativeRdb::RdbStore &store, int oldVersion, int newVersion) UpgradeToV2() argument 175 OnDowngrade(OHOS::NativeRdb::RdbStore &store, int oldVersion, int newVersion) OnDowngrade() argument [all...] |
H A D | contacts_database.cpp | 635 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store, std::vector<OHOS::NativeRdb::ValuesBucket> &queryValuesBucket) in DeletedAsyncTask() 677 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store, std::vector<OHOS::NativeRdb::ValuesBucket> &queryValuesBucket) in DeleteRecordInsert() 713 int delRet = store->Delete(rowId, ContactTableName::SEARCH_CONTACT, whereCase, whereArgs); in DeleteRecordInsert() 720 contactsUpdateHelper.UpdateCallLogByPhoneNum(rawContactIdVector, store, true); in DeleteRecordInsert() 898 HILOG_ERROR("ContactsDataBase DeleteLocal store is nullptr"); in DeleteLocal() 1083 int SqliteOpenHelperContactCallback::OnCreate(OHOS::NativeRdb::RdbStore &store) in OnCreate() argument 1085 store.ExecuteSql(CREATE_CONTACT); in OnCreate() 1086 store.ExecuteSql(CREATE_CONTACT_INDEX); in OnCreate() 1087 store.ExecuteSql(CREATE_RAW_CONTACT); in OnCreate() 1088 store in OnCreate() 634 DeletedAsyncTask( std::shared_ptr<OHOS::NativeRdb::RdbStore> &store, std::vector<OHOS::NativeRdb::ValuesBucket> &queryValuesBucket) DeletedAsyncTask() argument 676 DeleteRecordInsert( std::shared_ptr<OHOS::NativeRdb::RdbStore> &store, std::vector<OHOS::NativeRdb::ValuesBucket> &queryValuesBucket) DeleteRecordInsert() argument 1122 OnUpgrade(OHOS::NativeRdb::RdbStore &store, int oldVersion, int newVersion) OnUpgrade() argument 1135 UpgradeToV2(OHOS::NativeRdb::RdbStore &store, int oldVersion, int newVersion) UpgradeToV2() argument 1163 OnDowngrade(OHOS::NativeRdb::RdbStore &store, int oldVersion, int newVersion) OnDowngrade() argument 1283 InsertMergeData( std::shared_ptr<OHOS::NativeRdb::RdbStore> &store, std::vector<int> &rawContactIdVector) InsertMergeData() argument 1298 MergeUpdateTask( std::shared_ptr<OHOS::NativeRdb::RdbStore> &store, std::vector<int> &rawContactIdVector, bool isDeleted) MergeUpdateTask() argument 1306 MarkMerge(std::shared_ptr<OHOS::NativeRdb::RdbStore> &store) MarkMerge() argument [all...] |
H A D | contacts.cpp | 124 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store = rdbStore; in DeleteContactById() local 125 if (store == nullptr) { in DeleteContactById() 126 HILOG_ERROR("ContactsAccount DeletecontactById store is nullptr"); in DeleteContactById() 138 int delContact = store->Delete(rowId, ContactTableName::CONTACT, whereCase, whereArgs); in DeleteContactById()
|
/applications/standard/contacts_data/ability/account/src/ |
H A D | account_sync.cpp | 83 std::shared_ptr<OHOS::NativeRdb::RdbStore> store = nullptr; in SyncUpdateAccount() local 85 store = profileDataBase_->store_; in SyncUpdateAccount() 88 store = contactsDataBase_->contactStore_; in SyncUpdateAccount() 91 if (store == nullptr) { in SyncUpdateAccount() 92 HILOG_ERROR("SyncUpdateAccount isProfile values is %{public}d this database store ponit is null", isProfile); in SyncUpdateAccount() 96 std::vector<AccountDataCollection> accounts = g_contactsAccount->GetAccountFromLocal(store); in SyncUpdateAccount() 110 store->BeginTransaction(); in SyncUpdateAccount() 112 g_contactsAccount->StopForegin(store); in SyncUpdateAccount() 113 store->Commit(); in SyncUpdateAccount() 115 int accountId = g_contactsAccount->GetNotExistAccount(store, notInSysAccount in SyncUpdateAccount() 129 ClearData(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int accountId) ClearData() argument [all...] |
/applications/standard/contacts_data/ability/merge/src/ |
H A D | merger_contacts.cpp | 41 * @param store Conditions for split operation 45 int MergerContacts::ContactMerge(std::shared_ptr<OHOS::NativeRdb::RdbStore> store) in ContactMerge() argument 47 if (store == nullptr) { in ContactMerge() 48 HILOG_ERROR("store is empty"); in ContactMerge() 53 std::vector<std::set<int>> candidates = QueryMergeContacts(store, MERGE_MODE_AUTO); in ContactMerge() 54 int ret = MergeCircle(store, candidates); in ContactMerge() 58 int MergerContacts::MergeCircle(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, std::vector<std::set<int>> candidates) in MergeCircle() argument 74 UpdateRawContacts(store, minId, ids); in MergeCircle() 76 int error = store->ExecuteSql(sql); in MergeCircle() 82 matchCandidate.AddHasByRawId(store, minI in MergeCircle() 93 DeleteContacts( std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int minId, std::set<int> handledIds) DeleteContacts() argument 124 HandleIds(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, std::set<int> ids) HandleIds() argument 160 UpdateRawContacts( std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int minRawId, std::set<int> Ids) UpdateRawContacts() argument 186 UpdateRawContactsExecute( std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int minContactId, std::set<int> Ids) UpdateRawContactsExecute() argument 231 QueryCandidateName(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int id) QueryCandidateName() argument 258 QueryTargetName( std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId, std::set<std::string> data) QueryTargetName() argument 293 QueryMergeContacts( std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int mode) QueryMergeContacts() argument 327 UpdateCandidate(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, std::vector<int> currentIds, std::vector<std::set<int>> &candidates) UpdateCandidate() argument 357 SelectCandidate( std::shared_ptr<OHOS::NativeRdb::RdbStore> store) SelectCandidate() argument 417 ReContactMerge( std::shared_ptr<OHOS::NativeRdb::RdbStore> store, const DataShare::DataSharePredicates &predicates) ReContactMerge() argument 458 ManualMergeOperation( std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int minId, std::set<int> handledIds) ManualMergeOperation() argument 472 SelectIdsByName( std::shared_ptr<OHOS::NativeRdb::RdbStore> store, std::set<int> ids) SelectIdsByName() argument 507 UpdateIdsByName(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, std::set<std::string> names, std::set<int> ids, std::vector<std::set<int>> &selectedIds) UpdateIdsByName() argument 543 isNameMatch(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, std::set<int> ids) isNameMatch() argument 565 ForceContactMerge(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, std::set<int> ids) ForceContactMerge() argument [all...] |
H A D | match_candidate.cpp | 39 * @param store Conditions for query operation 44 int MatchCandidate::FindMatchContact(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId) in FindMatchContact() argument 48 Candidate candidate = candidateStatus.QueryAllForMerge(store, rawId); in FindMatchContact() 61 int code = store->ExecuteSql(updateMergeTarget); in FindMatchContact() 68 int retCode = UpdateMergeMode(store, candidate); in FindMatchContact() 76 * @param store Conditions for split operation 81 int MatchCandidate::Split(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId) in Split() argument 83 if (store == nullptr) { in Split() 84 HILOG_ERROR("MatchCandidate::Split store is nullptr"); in Split() 89 mergeUtils.GetRawIdsByRawId(store, rawI in Split() 108 AddHasByRawId(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId) AddHasByRawId() argument 122 UpdateSearch(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId, int contactsId) UpdateSearch() argument 138 AddNewContact(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId) AddNewContact() argument 177 ExecuteUpdateMode(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, std::set<int> Ids, int mode) ExecuteUpdateMode() argument 201 UpdateMergeMode(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, Candidate candidate) UpdateMergeMode() argument 222 UpdateRawContact(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId, int64_t contactsId) UpdateRawContact() argument [all...] |
H A D | candidate_status.cpp | 37 * @param store Conditions for query operation 42 Candidate CandidateStatus::QueryAllForMerge(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId) in QueryAllForMerge() argument 49 std::set<std::string> names = mergeUtils.QueryRawContactByType(store, rawId, nameType); in QueryAllForMerge() 51 std::vector<int> nameIds = mergeUtils.QueryByDataName(rawId, names, store); in QueryAllForMerge() 53 std::set<std::string> phones = mergeUtils.QueryRawContactByType(store, rawId, phoneType); in QueryAllForMerge() 58 if (!IsNeedMerge(store, nameIds[i]) || !IsMergeStatus(store, nameIds[i])) { in QueryAllForMerge() 61 std::set<std::string> otherPhones = mergeUtils.QueryRawContactByType(store, nameIds[i], phoneType); in QueryAllForMerge() 99 * @param store Conditions for query operation 104 bool CandidateStatus::IsNeedMerge(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, in argument 139 IsMergeStatus(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId) IsMergeStatus() argument 174 IsMerged(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId) IsMerged() argument 202 JudgeDataDifferent( std::shared_ptr<OHOS::NativeRdb::RdbStore> store, std::vector<int> ids, int rawId) JudgeDataDifferent() argument [all...] |
/applications/standard/contacts_data/dataBusiness/calllog/src/ |
H A D | calllog_database.cpp | 90 int SqliteOpenHelperCallLogCallback::OnCreate(OHOS::NativeRdb::RdbStore &store) in OnCreate() argument 93 judgeSuccess.push_back(store.ExecuteSql(CREATE_VOICEMAIL)); in OnCreate() 94 judgeSuccess.push_back(store.ExecuteSql(CREATE_CALLLOG)); in OnCreate() 95 judgeSuccess.push_back(store.ExecuteSql(CREATE_REPLYING)); in OnCreate() 96 judgeSuccess.push_back(store.ExecuteSql(CREATE_DATABASE_BACKUP_TASK)); in OnCreate() 97 judgeSuccess.push_back(store.ExecuteSql(CREATE_INSERT_BACKUP_TIME)); in OnCreate() 98 judgeSuccess.push_back(store.ExecuteSql(CALL_LOG_PHONE_NUMBER_INDEX)); in OnCreate() 108 int SqliteOpenHelperCallLogCallback::OnUpgrade(OHOS::NativeRdb::RdbStore &store, int oldVersion, int newVersion) in OnUpgrade() argument 112 store.ExecuteSql("ALTER TABLE database_backup_task ADD COLUMN sync TEXT"); in OnUpgrade() 115 UpgradeToV2(store, oldVersio in OnUpgrade() 121 UpgradeToV2(OHOS::NativeRdb::RdbStore &store, int oldVersion, int newVersion) UpgradeToV2() argument 129 OnDowngrade(OHOS::NativeRdb::RdbStore &store, int oldVersion, int newVersion) OnDowngrade() argument [all...] |
/applications/standard/contacts_data/ability/common/utils/include/ |
H A D | async_task.h | 168 std::shared_ptr<OHOS::NativeRdb::RdbStore> store; member in OHOS::Contacts::AsyncTask 176 contactsUpdateHelper.UpdateCallLogByPhoneNum(rawContactIdVector, store, isDeleted); in Run() 178 contactsDataBase->InsertMergeData(store, rawContactIdVector); in Run() 179 contactsDataBase->MarkMerge(store); in Run() 183 AsyncTask(std::shared_ptr<OHOS::NativeRdb::RdbStore> &store, std::vector<int> &rawContactIdVector, bool isDeleted) in AsyncTask() argument 185 this->store = store; in AsyncTask() 198 std::shared_ptr<OHOS::NativeRdb::RdbStore> store; member in OHOS::Contacts::AsyncDeleteContactsTask 204 contactsDataBase->DeleteRecordInsert(store, queryValuesBucket); in Run() 208 AsyncDeleteContactsTask(std::shared_ptr<OHOS::NativeRdb::RdbStore> &store, in AsyncDeleteContactsTask() argument [all...] |
H A D | merge_utils.h | 34 std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId, int typeId); 36 std::shared_ptr<OHOS::NativeRdb::RdbStore> store, std::set<int> &rawIds, int typeId); 38 std::shared_ptr<OHOS::NativeRdb::RdbStore> store, std::set<int> rawIds, int typeId); 40 int rawId, std::set<std::string> data, std::shared_ptr<OHOS::NativeRdb::RdbStore> store); 43 std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId, OHOS::NativeRdb::ValuesBucket &value); 44 void GetRawIdsByRawId(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId, std::set<int> &rawIds);
|
/applications/standard/contacts_data/ability/merge/include/ |
H A D | match_candidate.h | 27 int FindMatchContact(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId); 28 int Split(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId); 29 void AddHasByRawId(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId); 32 int UpdateSearch(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId, int contactsId); 33 int ExecuteUpdateMode(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, std::set<int> Ids, int mode); 34 int UpdateMergeMode(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, Candidate candidate); 35 int64_t AddNewContact(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId); 36 int UpdateRawContact(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId, int64_t contactsId);
|
H A D | candidate_status.h | 31 Candidate QueryAllForMerge(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId); 34 int PhoneMatch(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, std::set<std::string> phones, int id); 35 bool IsMerged(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId); 36 bool IsNeedMerge(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId); 37 bool IsMergeStatus(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId); 38 bool JudgeDataDifferent(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, std::vector<int> ids, int rawId);
|
H A D | merger_contacts.h | 44 std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int minContactId, std::set<int> Ids); 49 int ManualMergeOperation(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int minId, std::set<int> handledIds);
|
/applications/standard/contacts_data/ability/common/utils/src/ |
H A D | merge_utils.cpp | 32 std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId, int typeId) in QueryRawContactByType() 50 auto rawIdsSet = store->QuerySql(sql, selectionArgs); in QueryRawContactByType() 60 return QueryDataExecute(store, rawIds, typeId); in QueryRawContactByType() 64 std::shared_ptr<OHOS::NativeRdb::RdbStore> store, std::set<int> rawIds, int typeId) in QueryDataExecute() 89 auto resultSet = store->QuerySql(query, selectionArgs); in QueryDataExecute() 104 int rawId, std::set<std::string> data, std::shared_ptr<OHOS::NativeRdb::RdbStore> store) in QueryByDataName() 123 auto resultSet = store->QuerySql(query); in QueryByDataName() 152 std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId, OHOS::NativeRdb::ValuesBucket &values) in AddHasJudgeForRawId() 168 auto resultSet = store->QuerySql(sql); in AddHasJudgeForRawId() 196 void MergeUtils::GetRawIdsByRawId(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, in argument 31 QueryRawContactByType( std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId, int typeId) QueryRawContactByType() argument 63 QueryDataExecute( std::shared_ptr<OHOS::NativeRdb::RdbStore> store, std::set<int> rawIds, int typeId) QueryDataExecute() argument 103 QueryByDataName( int rawId, std::set<std::string> data, std::shared_ptr<OHOS::NativeRdb::RdbStore> store) QueryByDataName() argument 151 AddHasJudgeForRawId( std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int rawId, OHOS::NativeRdb::ValuesBucket &values) AddHasJudgeForRawId() argument [all...] |
/applications/standard/contacts_data/dataBusiness/contacts/include/ |
H A D | contacts_database.h | 68 void DeleteExecute(std::shared_ptr<OHOS::NativeRdb::RdbStore> &store, 70 void InsertMergeData(std::shared_ptr<OHOS::NativeRdb::RdbStore> &store, std::vector<int> &rawContactIdVector); 71 void MarkMerge(std::shared_ptr<OHOS::NativeRdb::RdbStore> &store); 73 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store, std::vector<int> &rawContactIdVector, bool isDeleted); 74 void DeleteRecordInsert(std::shared_ptr<OHOS::NativeRdb::RdbStore> &store, 76 void DeletedAsyncTask(std::shared_ptr<OHOS::NativeRdb::RdbStore> &store, 107 void UpgradeToV2(OHOS::NativeRdb::RdbStore &store, int oldVersion, int newVersion);
|
H A D | profile_database.h | 53 void UpgradeToV2(OHOS::NativeRdb::RdbStore &store, int oldVersion, int newVersion);
|
/applications/standard/app_samples/code/SuperFeature/DistributedAppDev/DistributeCalc/entry/src/main/js/MainAbility/common/ |
H A D | kvstoreModel.js | 53 this.kvManager.getKVStore(STORE_ID, options).then((store) => { 54 logger.debug(TAG, `getKVStore success, kvStore=${store}`) 55 this.kvStore = store
|
/applications/standard/app_samples/code/SuperFeature/DistributedAppDev/JsDistributedMusicPlayer/entry/src/main/js/MainAbility/model/ |
H A D | KvStoreModel.js | 53 self.kvManager.getKVStore(STORE_ID, options).then((store) => { 54 logger.debug(TAG, `getKVStore success, kvStore=${store}`) 55 self.kvStore = store
|
/applications/standard/contacts_data/ability/account/include/ |
H A D | account_sync.h | 42 int ClearData(std::shared_ptr<OHOS::NativeRdb::RdbStore> store, int accountId);
|
/applications/standard/contacts_data/dataBusiness/calllog/include/ |
H A D | calllog_database.h | 66 void UpgradeToV2(OHOS::NativeRdb::RdbStore &store, int oldVersion, int newVersion);
|