Home
last modified time | relevance | path

Searched refs:db_ (Results 1 - 25 of 32) sorted by relevance

12

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_relational_database_upgrader.cpp29 : db_(db) in SqliteRelationalDatabaseUpgrader()
38 int errCode = SQLiteUtils::GetLogTableVersion(db_, logTableVersion); in Upgrade()
69 return SQLiteUtils::BeginTransaction(db_, TransactType::IMMEDIATE); in BeginUpgrade()
75 int errCode = SQLiteUtils::GetLogTableVersion(db_, logTableVersion); in ExecuteUpgrade()
105 return SQLiteUtils::CommitTransaction(db_); in EndUpgrade()
108 return SQLiteUtils::RollbackTransaction(db_); in EndUpgrade()
123 int errCode = SQLiteUtils::CheckTableExists(db_, table.first, isExists); in UpgradeTrigger()
131 errCode = manager->AddRelationalLogTableTrigger(db_, tableInfo, ""); in UpgradeTrigger()
142 int ret = SQLiteRelationalUtils::AnalysisTrackerTable(db_, table.second.GetTrackerTable(), tableInfo); in UpgradeTrigger()
151 ret = manager->AddRelationalLogTableTrigger(db_, tableInf in UpgradeTrigger()
[all...]
H A Dsqlite_relational_database_upgrader.h42 sqlite3 *db_; member in DistributedDB::SqliteRelationalDatabaseUpgrader
/foundation/distributeddatamgr/preferences/frameworks/native/src/
H A Dpreferences_enhance_impl.cpp45 db_ = nullptr; in ~PreferencesEnhanceImpl()
51 db_ = std::make_shared<PreferencesDb>(); in Init()
53 int errCode = db_->Init(options_.filePath, options_.bundleName); in Init()
55 db_ = nullptr; in Init()
67 if (db_ == nullptr) { in Get()
73 if (db_->GetKernelDataVersion(kernelDataVersion) != E_OK) { in Get()
86 int errCode = db_->Get(oriKey, oriValue); in Get()
109 if (db_ == nullptr) { in HasKey()
115 if (db_->GetKernelDataVersion(kernelDataVersion) != E_OK) { in HasKey()
128 int errCode = db_ in HasKey()
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/service/src/gatt/
H A Dgatt_server_profile.cpp33 db_(), in impl()
43 GattDatabase db_ = {}; member
181 pimpl->db_.RemoveAllServices(); in Disable()
394 auto service = db_.GetServices().begin(); in DiscoverAllPrimaryServiceResponse()
399 for (; service != db_.GetServices().end(); service++) { in DiscoverAllPrimaryServiceResponse()
457 auto service = db_.GetServices().begin(); in DiscoverPrimaryServiceByUuidResponse()
470 for (; service != db_.GetServices().end(); service++) { in DiscoverPrimaryServiceByUuidResponse()
517 auto isvc = db_.GetIncludeService(startHandle); in FindIncludedServiceResponse()
578 auto characteristic = db_.GetCharacteristic(startHandle + MIN_ATTRIBUTE_HANDLE); in DiscoverCharacteristicResponse()
636 if (db_ in DiscoverAllCharacteristicDescriptorResponse()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/
H A Dmulti_ver_natural_store_commit_notify_data.cpp24 : db_(db), in MultiVerNaturalStoreCommitNotifyData()
33 if (db_ != nullptr) { in ~MultiVerNaturalStoreCommitNotifyData()
34 db_->RemoveVersionConstraintFromList(version_); in ~MultiVerNaturalStoreCommitNotifyData()
37 db_ = nullptr; in ~MultiVerNaturalStoreCommitNotifyData()
94 if (db_ == nullptr) { in FillInnerData()
99 int errCode = db_->GetDiffEntries(startCommitID_, endCommitID_, diffData_); in FillInnerData()
H A Dmulti_ver_natural_store_commit_notify_data.h48 mutable MultiVerNaturalStore *db_; member in DistributedDB::final
/foundation/distributeddatamgr/preferences/frameworks/native/platform/src/
H A Dpreferences_db_adapter.cpp135 if (db_ != nullptr || PreferenceDbAdapter::GetApiInstance().DbCloseApi != nullptr) { in ~PreferencesDb()
136 PreferenceDbAdapter::GetApiInstance().DbCloseApi(db_, GRD_DB_CLOSE_IGNORE_ERROR); in ~PreferencesDb()
137 db_ = nullptr; in ~PreferencesDb()
141 db_ == nullptr); in ~PreferencesDb()
159 if (db_ != nullptr) { in CloseDb()
164 int errCode = PreferenceDbAdapter::GetApiInstance().DbCloseApi(db_, GRD_DB_CLOSE_IGNORE_ERROR); in CloseDb()
171 db_ = nullptr; in CloseDb()
184 int errCode = PreferenceDbAdapter::GetApiInstance().DbCreateCollectionApi(db_, TABLENAME, in CreateCollection()
202 int errCode = PreferenceDbAdapter::GetApiInstance().DbOpenApi(dbPath_.c_str(), CONFIG_STR, flag, &db_); in OpenDb()
262 if (db_ ! in Init()
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/
H A Dkv_delegate.cpp118 if (db_ != NULL) { in RestoreIfNeed()
119 GRD_DBClose(db_, GRD_DB_CLOSE); in RestoreIfNeed()
120 db_ = nullptr; in RestoreIfNeed()
137 int count = GRD_UpsertDoc(db_, collectionName.c_str(), filter.c_str(), value.c_str(), 0); in Upsert()
163 auto count = GRD_DeleteDoc(db_, collectionName.c_str(), result.c_str(), 0); in Delete()
188 (path_ + "/dataShare.db").c_str(), nullptr, GRD_DB_OPEN_CREATE | GRD_DB_OPEN_CHECK_FOR_ABNORMAL, &db_); in Init()
189 if (status != GRD_OK || db_ == nullptr) { in Init()
197 GRD_DBClose(db_, GRD_DB_CLOSE); in Init()
198 db_ = nullptr; in Init()
204 status = GRD_CreateCollection(db_, TEMPLATE_TABL in Init()
[all...]
H A Dkv_delegate.h53 GRD_DB *db_ = nullptr; member in OHOS::DataShare::final
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_schema_database_upgrader.cpp31 int errCode = SQLiteUtils::GetSchema(db_, dbSchema); in GetDatabaseSchema()
41 int errCode = SQLiteUtils::SaveSchema(db_, dbSchema); in SetDatabaseSchema()
179 int errCode = sqlite3_create_function_v2(db_, FUNC_NAME_CHECK_AMEND_VALUE.c_str(), in UpgradeValues()
186 errCode = sqlite3_create_function_v2(db_, FUNC_NAME_GET_AMENDED_VALUE.c_str(), in UpgradeValues()
192 errCode = SQLiteUtils::ExecuteRawSQL(db_, VALUE_UPGRADE_SQL); in UpgradeValues()
210 int errCode = SQLiteUtils::DecreaseIndex(db_, entry); in UpgradeIndexes()
217 int errCode = SQLiteUtils::ChangeIndex(db_, entry.first, entry.second, theType, skipSize); in UpgradeIndexes()
224 int errCode = SQLiteUtils::IncreaseIndex(db_, entry.first, entry.second, theType, skipSize); in UpgradeIndexes()
H A Dsqlite_single_ver_database_upgrader.cpp83 : db_(db), in SQLiteSingleVerDatabaseUpgrader()
93 db_ = nullptr; in ~SQLiteSingleVerDatabaseUpgrader()
132 return SQLiteUtils::BeginTransaction(db_, TransactType::IMMEDIATE); in BeginUpgrade()
138 return SQLiteUtils::CommitTransaction(db_); in EndUpgrade()
140 int errCode = SQLiteUtils::RollbackTransaction(db_); in EndUpgrade()
153 return SQLiteUtils::GetVersion(db_, version); in GetDatabaseVersion()
158 return SQLiteUtils::SetUserVer(db_, version); in SetDatabaseVersion()
204 int errCode = SQLiteUtils::ExecuteRawSQL(db_, item); in UpgradeFromDatabaseVersion()
386 errCode = SQLiteUtils::GetStatement(db_, SELECT_META_VALUE_SQL, stmt); in GetLocalTimeOffset()
434 int errCode = SQLiteUtils::ExecuteRawSQL(db_, updateSQ in UpgradeTime()
[all...]
H A Dsqlite_multi_ver_transaction.cpp127 db_(nullptr), in SQLiteMultiVerTransaction()
134 if (db_ != nullptr) { in ~SQLiteMultiVerTransaction()
135 (void)sqlite3_close_v2(db_); in ~SQLiteMultiVerTransaction()
136 db_ = nullptr; in ~SQLiteMultiVerTransaction()
148 int errCode = SQLiteUtils::OpenDatabase(option, db_); in Initialize()
242 int errCode = SQLiteUtils::GetStatement(db_, SELECT_ONE_SQL, statement); in Get()
264 int errCode = SQLiteUtils::GetStatement(db_, SELECT_BY_HASHKEY_VER_SQL, statement); in GetValueForTrimSlice()
452 int errCode = SQLiteUtils::GetStatement(db_, SELECT_ONE_VER_RAW_SQL, statement); in GetDiffEntries()
508 int errCode = SQLiteUtils::GetStatement(db_, sql, statement); in GetMaxVersion()
536 int errCode = SQLiteUtils::GetStatement(db_, DELETE_VER_SQ in ClearEntriesByVersion()
[all...]
H A Dsqlite_single_ver_database_upgrader.h55 sqlite3 *db_ = nullptr; member in DistributedDB::SQLiteSingleVerDatabaseUpgrader
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_cloud_interfaces_set_cloud_schema_test.cpp136 sqlite3 *db_ = nullptr; member in __anon8186::DistributedDBCloudInterfacesSetCloudSchemaTest
158 db_ = RelationalTestUtils::CreateDataBase(g_storePath); in SetUp()
159 ASSERT_NE(db_, nullptr); in SetUp()
179 EXPECT_EQ(sqlite3_close_v2(db_), SQLITE_OK); in TearDown()
188 ASSERT_EQ(RelationalTestUtils::ExecSql(db_, "PRAGMA journal_mode=WAL;"), SQLITE_OK); in CreateUserDBAndTable()
189 ASSERT_EQ(RelationalTestUtils::ExecSql(db_, CREATE_TABLE_SQL), SQLITE_OK); in CreateUserDBAndTable()
190 ASSERT_EQ(RelationalTestUtils::ExecSql(db_, CREATE_TABLE_WITHOUT_PRIMARY_SQL), SQLITE_OK); in CreateUserDBAndTable()
199 ASSERT_EQ(SQLiteUtils::GetStatement(db_, sql, stmt), E_OK); in CheckSharedTable()
221 ASSERT_EQ(SQLiteUtils::GetStatement(db_, sql, stmt), E_OK); in CheckDistributedSharedTable()
240 ASSERT_NE(db_, nullpt in InsertLocalSharedTableRecords()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_single_ver_storage_executor.cpp31 RDStorageExecutor::RDStorageExecutor(GRD_DB *db, bool isWrite) : StorageExecutor(isWrite), db_(db) in RDStorageExecutor()
46 dbHandle = db_; in GetDbHandle()
58 if (db_ != nullptr) { in ~RdSingleVerStorageExecutor()
59 ret = RdDBClose(db_, 0); in ~RdSingleVerStorageExecutor()
65 db_ = nullptr; in ~RdSingleVerStorageExecutor()
71 int errCode = RdKVScan(db_, SYNC_COLLECTION_NAME, key, mode, resultSet); in OpenResultSet()
80 int errCode = RdKVRangeScan(db_, SYNC_COLLECTION_NAME, beginKey, endKey, resultSet); in OpenResultSet()
233 int errCode = RdKVScan(db_, SYNC_COLLECTION_NAME, key, kvScanMode, &tmpResultSet); in GetCount()
245 int errCode = RdKVRangeScan(db_, SYNC_COLLECTION_NAME, beginKey, endKey, &tmpResultSet); in GetCount()
278 return RdKVGet(db_, SYNC_COLLECTION_NAM in GetKvData()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_assets_operation_sync_test.cpp109 sqlite3 *db_ = nullptr; member in __anon8248::DistributedDBCloudAssetsOperationSyncTest
139 db_ = RelationalTestUtils::CreateDataBase(storePath_); in SetUp()
140 ASSERT_NE(db_, nullptr); in SetUp()
141 CreateUserDBAndTable(db_); in SetUp()
163 EXPECT_EQ(sqlite3_close_v2(db_), SQLITE_OK); in TearDown()
224 ASSERT_EQ(SQLiteUtils::GetStatement(db_, sql, stmt), E_OK); in InsertUserTableRecord()
289 ASSERT_EQ(RelationalTestUtils::SelectData(db_, dbSchema.tables[0], allData), E_OK); in CheckAssetsCount()
319 ASSERT_EQ(RelationalTestUtils::ExecSql(db_, sql), SQLITE_OK); in ForkDownloadAndRemoveAsset()
335 ASSERT_EQ(RelationalTestUtils::SelectData(db_, dbSchema.tables[0], allData), E_OK); in CheckAssetData()
367 ASSERT_EQ(RelationalTestUtils::ExecSql(db_, sq in HWTEST_F()
[all...]
H A Ddistributeddb_cloud_check_sync_test.cpp224 sqlite3 *db_ = nullptr; member in __anon8249::DistributedDBCloudCheckSyncTest
254 db_ = RelationalTestUtils::CreateDataBase(storePath_); in SetUp()
255 ASSERT_NE(db_, nullptr); in SetUp()
256 CreateUserDBAndTable(db_); in SetUp()
279 EXPECT_EQ(sqlite3_close_v2(db_), SQLITE_OK); in TearDown()
333 ASSERT_NE(db_, nullptr); in InsertUserTableRecord()
338 ASSERT_EQ(SQLiteUtils::ExecuteRawSQL(db_, sql), E_OK); in InsertUserTableRecord()
395 ASSERT_NE(db_, nullptr); in DeleteUserTableRecord()
397 ASSERT_EQ(SQLiteUtils::ExecuteRawSQL(db_, sql), E_OK); in DeleteUserTableRecord()
402 ASSERT_NE(db_, nullpt in DeleteUserTableRecord()
[all...]
H A Ddistributeddb_cloud_reference_sync_test.cpp63 sqlite3 *db_ = nullptr; member in __anon8252::DistributedDBCloudReferenceSyncTest
100 db_ = RelationalTestUtils::CreateDataBase(storePath_); in SetUp()
101 ASSERT_NE(db_, nullptr); in SetUp()
102 InitWalModeAndTable(db_, { parentTableName_, childTableName_ }); in SetUp()
124 EXPECT_EQ(sqlite3_close_v2(db_), SQLITE_OK); in TearDown()
221 ASSERT_NE(db_, nullptr); in InsertUserTableRecord()
237 ASSERT_EQ(SQLiteUtils::ExecuteRawSQL(db_, sql), E_OK); in InsertUserTableRecord()
250 ASSERT_EQ(RelationalTestUtils::ExecSql(db_, updateAge), SQLITE_OK); in UpdateUserTableRecord()
258 ASSERT_EQ(RelationalTestUtils::ExecSql(db_, sql), SQLITE_OK); in DeleteUserTableRecord()
379 ASSERT_EQ(SQLiteUtils::GetStatement(db_, sq in CheckDistributedSharedData()
[all...]
H A Ddistributeddb_cloud_task_merge_test.cpp107 sqlite3 *db_ = nullptr; member in __anon8254::DistributedDBCloudTaskMergeTest
137 db_ = RelationalTestUtils::CreateDataBase(storePath_); in SetUp()
138 ASSERT_NE(db_, nullptr); in SetUp()
139 CreateUserDBAndTable(db_); in SetUp()
163 EXPECT_EQ(sqlite3_close_v2(db_), SQLITE_OK); in TearDown()
210 ASSERT_NE(db_, nullptr); in InsertUserTableRecord()
215 ASSERT_EQ(SQLiteUtils::ExecuteRawSQL(db_, sql), E_OK); in InsertUserTableRecord()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_kvstore_test.cpp575 sqlite3 *db_; in SetFlag() local
579 ASSERT_TRUE(sqlite3_open_v2(fileUrl.c_str(), &db_, openFlag, nullptr) == SQLITE_OK); in SetFlag()
583 errCode = SQLiteUtils::GetStatement(db_, sql, statement); in SetFlag()
598 sqlite3_close_v2(db_); in SetFlag()
603 sqlite3 *db_; in CheckFlag() local
607 int errCode = sqlite3_open_v2(fileUrl.c_str(), &db_, openFlag, nullptr); in CheckFlag()
613 errCode = SQLiteUtils::GetStatement(db_, sql, statement); in CheckFlag()
632 sqlite3_close_v2(db_); in CheckFlag()
637 sqlite3_close_v2(db_); in CheckFlag()
642 sqlite3_close_v2(db_); in CheckFlag()
648 sqlite3 *db_; CheckWaterMark() local
696 sqlite3 *db_; SetDeviceId() local
730 sqlite3 *db_; CheckLogTable() local
772 sqlite3 *db_; ChangeUserId() local
811 sqlite3 *db_; ChangeHashKey() local
[all...]
H A Ddistributeddb_cloud_kv_syncer_test.cpp282 sqlite3 *db_; in CheckUploadAbnormal() local
286 EXPECT_EQ(sqlite3_open_v2(fileUrl.c_str(), &db_, flag, nullptr), SQLITE_OK); in CheckUploadAbnormal()
304 EXPECT_EQ(sqlite3_exec(db_, sql.c_str(), CloudDBSyncUtilsTest::QueryCountCallback, in CheckUploadAbnormal()
306 sqlite3_close_v2(db_); in CheckUploadAbnormal()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/store/
H A Dgeneral_store.h92 : db_(std::move(db)), loader_(std::move(loader)) in BindInfo()
98 return db_ < bindInfo.db_; in operator <()
101 std::shared_ptr<CloudDB> db_; member
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/cloudsync_fuzzer/
H A Dcloudsync_fuzzer.cpp169 int errCode = SQLiteUtils::GetStatement(db_, g_insertLocalAssetSql, stmt); in InitDbAsset()
247 db_ = RdbTestUtils::CreateDataBase(storePath_); in SetUp()
248 if (db_ == nullptr) { in SetUp()
251 CreateTable(db_); in SetUp()
279 if (db_ != nullptr) { in TearDown()
280 int errCode = sqlite3_close_v2(db_); in TearDown()
466 InitDbData(db_, data, size); in DataChangeSync()
532 sqlite3 *db_ = nullptr; member in OHOS::CloudSyncTest
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/test/
H A Dgeneral_store_test.cpp86 ASSERT_EQ(bindInfo.db_, db); in HWTEST_F()
92 ASSERT_EQ(bindInfo1.db_, db1); in HWTEST_F()
/foundation/distributeddatamgr/preferences/frameworks/native/include/
H A Dpreferences_enhance_impl.h69 std::shared_ptr<PreferencesDb> db_; member in OHOS::NativePreferences::PreferencesEnhanceImpl

Completed in 24 milliseconds

12