Home
last modified time | relevance | path

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

12

/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...]
/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...]
/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...]
/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...]
H A Dtransaction_test.cpp40 static inline std::shared_ptr<RdbStore> store_; member in TransactionTest
67 TransactionTest::store_ = RdbHelper::GetRdbStore(config, 1, helper, errCode); in SetUpTestCase() member in TransactionTest
68 EXPECT_NE(TransactionTest::store_, nullptr); in SetUpTestCase()
74 store_ = nullptr; in TearDownTestCase()
80 store_->Execute("DELETE FROM test"); in SetUp()
94 std::shared_ptr<RdbStore> &store = TransactionTest::store_; in HWTEST_F()
145 std::shared_ptr<RdbStore> &store = TransactionTest::store_; in HWTEST_F()
190 std::shared_ptr<RdbStore> &store = TransactionTest::store_; in HWTEST_F()
223 std::shared_ptr<RdbStore> &store = TransactionTest::store_; in HWTEST_F()
256 std::shared_ptr<RdbStore> &store = TransactionTest::store_; in HWTEST_F()
[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()
/foundation/distributeddatamgr/relational_store/test/native/rdb/distributedtest/rdb_store_impl_test/
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()
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...]
/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/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/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/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...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/
H A Drdb_delegate.cpp109 store_ = RdbHelper::GetRdbStore(config, version, callback, errCode_); in RdbDelegate()
134 if (store_ == nullptr) { in InsertEx()
140 int ret = store_->Insert(rowId, tableName, bucket); in InsertEx()
157 if (store_ == nullptr) { in UpdateEx()
164 int ret = store_->Update(changeCount, bucket, predicates); in UpdateEx()
180 if (store_ == nullptr) { in DeleteEx()
186 int ret = store_->Delete(changeCount, predicates); in DeleteEx()
204 if (store_ == nullptr) { in Query()
215 std::shared_ptr<NativeRdb::ResultSet> resultSet = store_->QueryByStep(rdbPredicates, columns); in Query()
256 if (store_ in Query()
[all...]
/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/communication/netmanager_ext/test/vpnmanager/unittest/sys_vpn_manager_test/
H A Dvpn_database_helper_test.cpp47 std::shared_ptr<OHOS::NativeRdb::RdbStore> store_ = in HWTEST_F() local
49 int32_t ret = dbCallBack->OnCreate(*(store_)); in HWTEST_F()
61 std::shared_ptr<OHOS::NativeRdb::RdbStore> store_ = in HWTEST_F() local
63 int32_t ret = dbCallBack->OnUpgrade(*(store_), OLD_VERSION, NEW_VERSION); in HWTEST_F()
75 std::shared_ptr<OHOS::NativeRdb::RdbStore> store_ = in HWTEST_F() local
77 int32_t ret = dbCallBack->OnDowngrade(*(store_), OLD_VERSION, NEW_VERSION); in HWTEST_F()
208 std::shared_ptr<OHOS::NativeRdb::RdbStore> tmp = vpnDataHelper_.store_; in HWTEST_F()
209 vpnDataHelper_.store_ = nullptr; in HWTEST_F()
225 vpnDataHelper_.store_ = tmp; in HWTEST_F()
/foundation/communication/netmanager_ext/services/vpnmanager/src/
H A Dvpn_database_helper.cpp52 store_ = OHOS::NativeRdb::RdbHelper::GetRdbStore(config, DATABASE_OPEN_VERSION, sqliteOpenHelperCallback, errCode); in VpnDatabaseHelper()
104 if (store_ == nullptr) { in IsVpnInfoExists()
105 NETMGR_EXT_LOG_E("IsVpnInfoExists store_ is nullptr"); in IsVpnInfoExists()
112 auto queryResultSet = store_->Query(rdbPredicate, columns); in IsVpnInfoExists()
184 if (store_ == nullptr) { in InsertData()
185 NETMGR_EXT_LOG_E("InsertData store_ is nullptr"); in InsertData()
192 int ret = store_->Insert(rowId, VPN_CONFIG_TABLE, values); in InsertData()
202 if (store_ == nullptr) { in UpdateData()
203 NETMGR_EXT_LOG_E("UpdateData store_ is nullptr"); in UpdateData()
216 int32_t ret = store_ in UpdateData()
[all...]
/foundation/distributeddatamgr/relational_store/test/native/rdb/fuzztest/rdbstore_fuzzer/
H A Drdbstore_fuzzer.cpp35 static std::shared_ptr<RdbStore> store_; member in OHOS::RdbStoreFuzzTest
37 std::shared_ptr<RdbStore> RdbStoreFuzzTest::store_ = nullptr; member in OHOS::RdbStoreFuzzTest
66 RdbStoreFuzzTest::store_ = RdbHelper::GetRdbStore(config, 1, helper, errCode); in SetUpTestCase() member in OHOS::RdbStoreFuzzTest
67 if (store_ == nullptr || errCode != E_OK) { in SetUpTestCase()
107 std::shared_ptr<RdbStore> &store = RdbStoreFuzzTest::store_; in RdbInsertFuzz()
125 std::shared_ptr<RdbStore> &store = RdbStoreFuzzTest::store_; in RdbDeleteFuzz()
151 std::shared_ptr<RdbStore> &store = RdbStoreFuzzTest::store_; in RdbUpdateFuzz()
186 std::shared_ptr<RdbStore> &store = RdbStoreFuzzTest::store_; in RdbDoLockRowFuzz()
233 std::shared_ptr<RdbStore> &store = RdbStoreFuzzTest::store_; in RdbQueryLockedRowFuzz1()
279 std::shared_ptr<RdbStore> &store = RdbStoreFuzzTest::store_; in RdbQueryLockedRowFuzz2()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/
H A Dcloud_meta_data.cpp25 : store_(store) in CloudMetaData()
158 if (store_ == nullptr) { in ReadMarkFromMeta()
162 int ret = store_->GetMetaData(DBCommon::GetPrefixTableName(tableName), blobMetaVal); in ReadMarkFromMeta()
182 if (store_ == nullptr) { in WriteMarkToMeta()
185 return store_->PutMetaData(DBCommon::GetPrefixTableName(tableName), blobMetaVal); in WriteMarkToMeta()
195 if (store_ == nullptr) { in WriteTypeMarkToMeta()
198 return store_->PutMetaData(DBCommon::GetPrefixTableName(tableName), blobMetaVal); in WriteTypeMarkToMeta()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/executor/include/
H A Dgrd_type_inner.h24 DocumentDB::DocumentStore *store_ = nullptr; member
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_store_connection.cpp24 : store_(store), isExclusive_(false) in RelationalStoreConnection()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_relational_store_connection.cpp37 if (store_ == nullptr) { in Close()
58 static_cast<SQLiteRelationalStore *>(store_)->ReleaseDBConnection(GetConnectionId(), this); in Close()
64 if (store_ == nullptr) { in GetIdentifier()
67 return store_->GetProperties().GetStringProp(RelationalDBProperties::IDENTIFIER_DATA, ""); in GetIdentifier()
284 return static_cast<SQLiteRelationalStore *>(store_)->RegisterObserverAction(GetConnectionId(), observer, action); in RegisterObserverAction()
289 return static_cast<SQLiteRelationalStore *>(store_)->UnRegisterObserverAction(GetConnectionId(), observer); in UnRegisterObserverAction()

Completed in 14 milliseconds

12