Home
last modified time | relevance | path

Searched refs:store_ (Results 1 - 25 of 113) sorted by relevance

12345

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dstorage_proxy.cpp25 :store_(iCloud), in StorageProxy()
40 cloudMetaData_ = std::make_shared<CloudMetaData>(store_); in Init()
50 store_ = nullptr; in Close()
128 if (store_ == nullptr) { in StartTransaction()
131 int errCode = store_->StartTransaction(type); in StartTransaction()
142 if (store_ == nullptr) { in Commit()
145 int errCode = store_->Commit(); in Commit()
155 if (store_ == nullptr) { in Rollback()
158 int errCode = store_->Rollback(); in Rollback()
169 if (store_ in GetUploadCount()
[all...]
H A Dsync_able_engine.cpp33 store_(store), in SyncAbleEngine()
102 if (store_ == nullptr) { in StartSyncerWithNoLock()
111 int errCode = syncer_.Initialize(store_, isNeedActive); in StartSyncerWithNoLock()
118 bool isSyncDualTupleMode = store_->GetDbProperties().GetBoolProp(DBProperties::SYNC_DUAL_TUPLE_MODE, false); in StartSyncerWithNoLock()
119 std::string label = store_->GetDbProperties().GetStringProp(DBProperties::IDENTIFIER_DATA, ""); in StartSyncerWithNoLock()
167 if (store_ == nullptr) { in UserChangeHandle()
171 bool isSyncDualTupleMode = store_->GetDbProperties().GetBoolProp(DBProperties::SYNC_DUAL_TUPLE_MODE, false); in UserChangeHandle()
181 bool isNeedActive = RuntimeContext::GetInstance()->IsSyncerNeedActive(store_->GetDbProperties()); in UserChangeHandle()
201 std::string label = store_->GetDbProperties().GetStringProp(DBProperties::IDENTIFIER_DATA, ""); in ChangeUserListener()
211 bool isSyncDualTupleMode = store_ in SetSyncModuleActive()
[all...]
/foundation/deviceprofile/device_info_manager/services/core/src/persistenceadapter/rdbadapter/
H A Drdb_adapter.cpp69 store_ = nullptr; in UnInit()
82 if (store_ == nullptr) { in Put()
86 int32_t ret = store_->Insert(outRowId, table, values); in Put()
89 int32_t restoreRet = store_->Restore(""); in Put()
94 ret = store_->Insert(outRowId, table, values); in Put()
113 if (store_ == nullptr) { in Delete()
117 int32_t ret = store_->Delete(deleteRows, table, whereClause, bindArgs); in Delete()
120 int32_t restoreRet = store_->Restore(""); in Delete()
125 ret = store_->Delete(deleteRows, table, whereClause, bindArgs); in Delete()
144 if (store_ in Update()
245 OnCreate(RdbStore& store_) OnCreate() argument
251 OnUpgrade(RdbStore& store_, int oldVersion, int newVersion) OnUpgrade() argument
[all...]
/applications/standard/contacts_data/dataBusiness/voicemail/src/
H A Dvoicemail_database.cpp24 std::shared_ptr<OHOS::NativeRdb::RdbStore> VoiceMailDataBase::store_ = nullptr; member in OHOS::Contacts::VoiceMailDataBase
28 store_ = CallLogDataBase::GetInstance()->store_; in VoiceMailDataBase()
43 if (store_ == nullptr) { in InsertVoiceMail()
44 HILOG_ERROR("VoiceMailDataBase Insert store_ is nullptr"); in InsertVoiceMail()
48 int ret = store_->Insert(outRowId, tableName, insertValues); in InsertVoiceMail()
60 if (store_ == nullptr) { in UpdateVoiceMail()
61 HILOG_ERROR("VoiceMailDataBase Update store_ is nullptr"); in UpdateVoiceMail()
67 int ret = store_->Update(changedRows, values, rdbPredicates); in UpdateVoiceMail()
78 if (store_ in DeleteVoiceMail()
[all...]
/foundation/communication/netmanager_ext/services/netfirewallmanager/src/
H A Dnetfirewall_database.cpp45 store_ = OHOS::NativeRdb::RdbHelper::GetRdbStore(config, DATABASE_OPEN_VERSION, sqliteOpenHelperCallback, errCode); in NetFirewallDataBase()
73 if (store_ == nullptr) { in BeginTransaction()
74 NETMGR_EXT_LOG_E("BeginTransaction store_ is nullptr"); in BeginTransaction()
77 int32_t ret = store_->BeginTransaction(); in BeginTransaction()
87 if (store_ == nullptr) { in Commit()
88 NETMGR_EXT_LOG_E("Commit store_ is nullptr"); in Commit()
91 int32_t ret = store_->Commit(); in Commit()
101 if (store_ == nullptr) { in RollBack()
102 NETMGR_EXT_LOG_E("RollBack store_ is nullptr"); in RollBack()
105 int32_t ret = store_ in RollBack()
[all...]
/applications/standard/contacts_data/dataBusiness/contacts/src/
H A Dcontacts_account.cpp54 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store_ = rdbStore; in Insert() local
59 if (store_ == nullptr) { in Insert()
60 HILOG_ERROR("ContactsAccount insert store_ is nullptr"); in Insert()
63 int ret = store_->Insert(outRowId, ContactTableName::ACCOUNT, values); in Insert()
81 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store_ = rdbStore; in LookupAccountTypeId() local
97 auto resultSet = store_->QuerySql(sqlBuilder, selectionArgs); in LookupAccountTypeId()
114 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store_ = rdbStore; in GetAccountFromLocal() local
116 if (store_ == nullptr) { in GetAccountFromLocal()
117 HILOG_ERROR("ContactsAccount GetAccountFromLocal store_ is nullptr"); in GetAccountFromLocal()
130 auto result = store_ in GetAccountFromLocal()
156 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store_ = rdbStore; GetNotExistAccount() local
201 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store_ = rdbStore; DeleteAccountByAccountId() local
220 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store_ = rdbStore; DeleteDataByRawId() local
239 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store_ = rdbStore; DeleteGroupsByAccountId() local
258 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store_ = rdbStore; StopForegin() local
268 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store_ = rdbStore; OpenForegin() local
[all...]
H A Dcontacts_database.cpp44 std::shared_ptr<OHOS::NativeRdb::RdbStore> ContactsDataBase::store_ = nullptr; member in OHOS::Contacts::ContactsDataBase
75 store_ = contactStore_; in ContactsDataBase()
77 contactsAccount->PrepopulateCommonAccountTypes(store_); in ContactsDataBase()
79 contactsType.PrepopulateCommonTypes(store_); in ContactsDataBase()
98 if (store_ == nullptr) { in BeginTransaction()
99 HILOG_ERROR("ContactsDataBase BeginTransaction store_ is nullptr"); in BeginTransaction()
102 int ret = store_->BeginTransaction(); in BeginTransaction()
111 if (store_ == nullptr) { in Commit()
112 HILOG_ERROR("ContactsDataBase Commit store_ is nullptr"); in Commit()
115 int ret = store_ in Commit()
[all...]
H A Draw_contacts.cpp89 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store_ = rdbStore; in GetDeleteContactIdByAccountId() local
90 if (store_ == nullptr) { in GetDeleteContactIdByAccountId()
91 HILOG_ERROR("RawContacts GetDeleteContactIdByAccountId store_ is nullptr or accountId illegal"); in GetDeleteContactIdByAccountId()
123 auto rawResult = store_->QuerySql(sql, selectArgs); in GetDeleteContactIdByAccountId()
141 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store_ = rdbStore; in GetDeleteRawContactIdByAccountId() local
142 if (store_ == nullptr) { in GetDeleteRawContactIdByAccountId()
143 HILOG_ERROR("RawContacts GetDeleteRawContactIdByAccountId store_ is nullptr"); in GetDeleteRawContactIdByAccountId()
163 auto rawResult = store_->QuerySql(sql, selectArgs); in GetDeleteRawContactIdByAccountId()
180 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store_ = rdbStore; in DeleteRawcontactByRawId() local
181 if (store_ in DeleteRawcontactByRawId()
[all...]
H A Dcontacts_type.cpp35 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store_ = rdbStore; in Insert() local
41 if (store_ == nullptr) { in Insert()
42 HILOG_ERROR("ContactsType insert store_ is nullptr"); in Insert()
46 int ret = store_->Insert(outRowId, ContactTableName::CONTACT_TYPE, values); in Insert()
86 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store_ = rdbStore; in LookupTypeId() local
94 auto resultSet = store_->QuerySql(sqlBuilder, selectionArgs); in LookupTypeId()
109 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store_ = rdbStore; in GetTypeText() local
117 auto resultSet = store_->QuerySql(sqlBuilder, selectionArgs); in GetTypeText()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/executor/document/
H A Dgrd_document_api_inner.cpp27 if (db == nullptr || db->store_ == nullptr) { in GRD_CreateCollectionInner()
33 int ret = db->store_->CreateCollection(name, option, flags); in GRD_CreateCollectionInner()
39 if (db == nullptr || db->store_ == nullptr) { in GRD_DropCollectionInner()
44 int ret = db->store_->DropCollection(name, flags); in GRD_DropCollectionInner()
51 if (db == nullptr || db->store_ == nullptr || collectionName == nullptr || filter == nullptr || update == nullptr) { in GRD_UpdateDocInner()
54 int ret = db->store_->UpdateDocument(collectionName, filter, update, flags); in GRD_UpdateDocInner()
64 if (db == nullptr || db->store_ == nullptr || collectionName == nullptr || filter == nullptr || in GRD_UpsertDocInner()
68 int ret = db->store_->UpsertDocument(collectionName, filter, document, flags); in GRD_UpsertDocInner()
77 if (db == nullptr || db->store_ == nullptr || collectionName == nullptr || document == nullptr) { in GRD_InsertDocInner()
80 int ret = db->store_ in GRD_InsertDocInner()
[all...]
/third_party/skia/third_party/externals/sfntly/cpp/src/sfntly/port/
H A Dmemory_output_stream.cc28 store_.insert(store_.end(), buffer->begin(), buffer->end()); in Write()
36 store_.insert(store_.end(), in Write()
49 store_.insert(store_.end(), buffer + offset, buffer + offset + length); in Write()
58 store_.push_back(b); in Write()
62 if (store_.empty()) { in Get()
65 return &(store_[0]); in Get()
69 return store_ in Size()
[all...]
/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/
H A Drdb_predicates_join_b_test.cpp55 std::shared_ptr<RdbStore> store_; member in RdbStorePredicateJoinBTest
101 store_ = nullptr; in SetUp()
106 store_ = RdbHelper::GetRdbStore(config, 1, helper, errCode); in SetUp()
107 EXPECT_NE(store_, nullptr); in SetUp()
113 store_ = nullptr; in TearDown()
119 store_->ExecuteSql(CREATE_TABLE_DEPT_SQL); in GenerateAllTables()
122 store_->ExecuteSql(CREATE_TABLE_JOB_SQL); in GenerateAllTables()
125 store_->ExecuteSql(CREATE_TABLE_EMP_SQL); in GenerateAllTables()
128 store_->ExecuteSql(CREATE_TABLE_SALARYGRADE_SQL); in GenerateAllTables()
140 store_ in InsertDeptDates()
[all...]
H A Drdb_store_impl_test.cpp44 std::shared_ptr<RdbStore> store_; member in RdbStoreImplTest
75 store_ = nullptr; in SetUp()
80 store_ = RdbHelper::GetRdbStore(config, 1, helper, errCode); in SetUp()
81 EXPECT_NE(store_, nullptr); in SetUp()
87 store_ = nullptr; in TearDown()
100 store_->ExecuteSql("CREATE TABLE naturalbase_rdb_aux_rdbstoreimpltest_integer_log " in HWTEST_F()
107 int errorCode = store_->Insert(rowId, "naturalbase_rdb_aux_rdbstoreimpltest_integer_log", valuesBucket); in HWTEST_F()
113 store_->GetModifyTime("rdbstoreimpltest_integer", "ROWID", PKey); in HWTEST_F()
118 store_->ExecuteSql("DROP TABLE IF EXISTS naturalbase_rdb_aux_rdbstoreimpltest_integer_log"); in HWTEST_F()
129 store_ in HWTEST_F()
[all...]
/applications/standard/contacts_data/ability/datadisasterrecovery/src/
H A Ddatabase_disaster_recovery.cpp62 redbStoreMap.insert(std::make_pair(PROFILE_DATABASE_NAME, profile->store_)); in SQLiteCheckDb()
71 std::shared_ptr<OHOS::NativeRdb::RdbStore> store_ = kv.second; in SQLiteCheckDb() local
72 int ret = SQLiteCheckDb(store_, kv.first); in SQLiteCheckDb()
88 std::shared_ptr<OHOS::NativeRdb::RdbStore> &store_ = rdbStore; in SQLiteCheckDb() local
89 if (store_ == nullptr) { in SQLiteCheckDb()
90 HILOG_ERROR("DataBaseDisasterRecovery SQLliteCheck %{public}s store_ is nullptr", dataBaseName.c_str()); in SQLiteCheckDb()
94 store_->ExecuteAndGetString(result, "PRAGMA quick_check(0)"); in SQLiteCheckDb()
114 redbStoreMap.insert(std::make_pair(PROFILE_DATABASE_NAME, profile->store_)); in BackDatabase()
123 std::shared_ptr<OHOS::NativeRdb::RdbStore> store_ = kv.second; in BackDatabase() local
125 store_ in BackDatabase()
140 std::shared_ptr<OHOS::NativeRdb::RdbStore> store_ = iter->second; BackDatabase() local
168 GetBackUpDatabase(const std::shared_ptr<OHOS::NativeRdb::RdbStore> &store_) GetBackUpDatabase() argument
[all...]
/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/multiThread/
H A Drdb_connection_test.cpp56 std::shared_ptr<RdbStore> store_; member in RdbMultiThreadConnectionTest
81 store_ = nullptr; in SetUp()
86 store_ = RdbHelper::GetRdbStore(sqliteSharedRstConfig, 1, sqliteSharedRstHelper, errCode); in SetUp()
87 EXPECT_NE(store_, nullptr); in SetUp()
89 auto ret = store_->ExecuteSql(CREATE_TABLE_SQL); in SetUp()
97 store_ = nullptr; in TearDown()
105 auto ret = store_->Insert(id, "test", UTUtils::SetRowData(UTUtils::g_rowData[0])); in GenerateData()
111 ret = store_->Insert(id, "test", UTUtils::SetRowData(UTUtils::g_rowData[1])); in GenerateData()
117 ret = store_->Insert(id, "test", UTUtils::SetRowData(UTUtils::g_rowData[2])); in GenerateData()
134 auto taskId1 = executors_->Execute([store = store_, block in HWTEST_F()
[all...]
H A Drdb_connection_rd_test.cpp49 std::shared_ptr<RdbStore> store_; member in Test::RdbMultiThreadConnectionRdTest
76 store_ = nullptr; in RdbMultiThreadConnectionRdTest()
83 store_ = RdbHelper::GetRdbStore(config, 1, helper, errCode); in RdbMultiThreadConnectionRdTest()
84 EXPECT_NE(store_, nullptr); in RdbMultiThreadConnectionRdTest()
103 store_ = nullptr; in TearDown()
117 auto taskId1 = executors_->Execute([store = store_]() { in HWTEST_F()
128 auto taskId2 = executors_->Execute([store = store_]() { in HWTEST_F()
153 auto taskId1 = executors_->Execute([store = store_]() { in HWTEST_F()
164 auto taskId2 = executors_->Execute([store = store_]() { in HWTEST_F()
/applications/standard/contacts_data/dataBusiness/calllog/src/
H A Dcalllog_database.cpp25 std::shared_ptr<OHOS::NativeRdb::RdbStore> CallLogDataBase::store_ = nullptr; member in OHOS::Contacts::CallLogDataBase
34 store_ = OHOS::NativeRdb::RdbHelper::GetRdbStore(config, DATABASE_OPEN_VERSION, sqliteOpenHelperCallback, errCode); in CallLogDataBase()
53 if (store_ == nullptr) { in BeginTransaction()
54 HILOG_ERROR("CallLogDataBase BeginTransaction store_ is nullptr"); in BeginTransaction()
57 int ret = store_->BeginTransaction(); in BeginTransaction()
66 if (store_ == nullptr) { in Commit()
67 HILOG_ERROR(" CallLogDataBase Commit store_ is nullptr"); in Commit()
70 int ret = store_->Commit(); in Commit()
79 if (store_ == nullptr) { in RollBack()
80 HILOG_ERROR(" CallLogDataBase RollBack store_ i in RollBack()
[all...]
/foundation/distributeddatamgr/relational_store/test/native/rdb/distributedtest/rdb_store_impl_test/
H A Ddistributed_test.cpp54 static std::shared_ptr<RdbStore> store_; member in __anon8385::DistributedTest
60 std::shared_ptr<RdbStore> DistributedTest::store_ = nullptr; member in __anon8385::DistributedTest
113 int DistributedTestOpenCallback::OnCreate(RdbStore &store_) in OnCreate() argument
115 return store_.ExecuteSql(CREATE_TABLE_TEST); in OnCreate()
118 int DistributedTestOpenCallback::OnUpgrade(RdbStore &store_, int oldVersion, int newVersion) in OnUpgrade() argument
130 DistributedTest::store_ = RdbHelper::GetRdbStore(config, 1, helper, errCode); in SetUpTestCase() member in __anon8385::DistributedTest
131 EXPECT_NE(DistributedTest::store_, nullptr); in SetUpTestCase()
143 store_->ExecuteSql("DELETE FROM test"); in SetUp()
158 std::shared_ptr<RdbStore> &store_ = DistributedTest::store_; in HWTEST_F() local
[all...]
H A Ddistributed_test_agent.cpp49 static std::shared_ptr<RdbStore> store_; member in __anon8386::DistributedTestAgent
57 std::shared_ptr<RdbStore> DistributedTestAgent::store_ = nullptr; member in __anon8386::DistributedTestAgent
107 DistributedTestAgent::store_ = RdbHelper::GetRdbStore(config, 1, helper, errCode); in OnProcessMsg() member in __anon8386::DistributedTestAgent
108 std::shared_ptr<RdbStore> &store_ = DistributedTestAgent::store_; in OnProcessMsg() local
120 store_->SetDistributedTables(tables); in OnProcessMsg()
122 status = store_->Insert(id, "test", values); in OnProcessMsg()
129 store_->QuerySql("SELECT * FROM test WHERE name = ?", std::vector<std::string>{ "zhangsan" }); in OnProcessMsg()
/third_party/node/src/
H A Daliased_struct-inl.h18 store_ = v8::ArrayBuffer::NewBackingStore(isolate, sizeof(T)); in AliasedStruct()
19 ptr_ = new (store_->Data()) T(std::forward<Args>(args)...); in AliasedStruct()
22 v8::Local<v8::ArrayBuffer> buffer = v8::ArrayBuffer::New(isolate, store_); in AliasedStruct()
35 store_ = that.store_;
41 that.store_.reset();
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/store/
H A Dauto_cache.cpp250 : store_(delegate), watchers_(watchers), user_(user), meta_(meta) in Delegate()
253 if (store_ != nullptr) { in Delegate()
254 store_->Watch(Origin::ORIGIN_ALL, *this); in Delegate()
260 store_ = delegate.store_; in Delegate()
261 if (store_ != nullptr) { in Delegate()
262 store_->AddRef(); in Delegate()
268 if (store_ != nullptr) { in ~Delegate()
269 store_->Close(true); in ~Delegate()
270 store_ in ~Delegate()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/executor/base/
H A Dgrd_db_api_inner.cpp45 (*db)->store_ = store; in GRD_DBOpenInner()
51 if (db == nullptr || db->store_ == nullptr) { in GRD_DBCloseInner()
55 int ret = DocumentStoreManager::CloseDocumentStore(db->store_, flags); in GRD_DBCloseInner()
60 db->store_ = nullptr; in GRD_DBCloseInner()
67 if (db == nullptr || db->store_ == nullptr) { in GRD_FlushInner()
/foundation/ai/intelligent_voice_framework/services/intell_voice_trigger/server/
H A Dtrigger_db_helper.cpp85 store_ = RdbHelper::GetRdbStore(config, VERSION_ADD_MODEL_TYPE, helper, errCode); in TriggerDbHelper()
86 if (store_ == nullptr) { in TriggerDbHelper()
93 store_ = nullptr; in ~TriggerDbHelper()
101 if (store_ == nullptr) { in UpdateGenericTriggerModel()
119 int ret = store_->InsertWithConflictResolution(rowId, TABLE_NAME, values, ConflictResolution::ON_CONFLICT_REPLACE); in UpdateGenericTriggerModel()
200 if (store_ == nullptr) { in GetGenericTriggerModel()
205 std::shared_ptr<AbsSharedResultSet> set = store_->QuerySql( in GetGenericTriggerModel()
257 if (store_ == nullptr) { in DeleteGenericTriggerModel()
262 store_->Delete(deletedRows, "trigger", "model_uuid = ?", std::vector<std::string> {std::to_string(modelUuid)}); in DeleteGenericTriggerModel()
/foundation/distributeddatamgr/relational_store/test/native/relational_store_test/unittest/
H A Drdb_store_test.cpp44 std::shared_ptr<RdbStore> store_; member in RdbTest
75 store_ = nullptr; in SetUp()
80 store_ = RdbHelper::GetRdbStore(config, 1, helper, errCode); in SetUp()
81 EXPECT_NE(store_, nullptr); in SetUp()
87 store_ = nullptr; in TearDown()
100 store_->ExecuteSql("CREATE TABLE naturalbase_rdb_aux_RdbTest_integer_log " in HWTEST_F()
107 int errorCode = store_->Insert(rowId, "naturalbase_rdb_aux_RdbTest_integer_log", valuesBucket); in HWTEST_F()
113 store_->GetModifyTime("RdbTest_integer", "ROWID", PKey); in HWTEST_F()
118 store_->ExecuteSql("DROP TABLE IF EXISTS naturalbase_rdb_aux_RdbTest_integer_log"); in HWTEST_F()
129 store_ in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/interface/src/
H A Dresult_set.cpp32 if (store_ != nullptr) { in EraseCollection()
33 store_->EraseCollection(context_->collectionName); in EraseCollection()
41 store_ = store; in Init()
48 Collection coll = store_->GetCollection(context_->collectionName); in GetValueFromDB()
106 bool isCollectionExist = store_->IsCollectionExists(RdDBConstant::COLL_PREFIX + lowerCaseName, errCode); in GetNextInner()
130 std::lock_guard<std::mutex> lock(store_->dbMutex_); in GetNext()
131 int errCode = store_->StartTransaction(); in GetNext()
138 store_->Commit(); in GetNext()
140 store_->Rollback(); in GetNext()
147 std::lock_guard<std::mutex> lock(store_ in GetValue()
[all...]

Completed in 14 milliseconds

12345