Home
last modified time | relevance | path

Searched refs:kvDB_ (Results 1 – 16 of 16) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/kv/
H A Dsqlite_local_kvdb_connection.cpp40 if (kvDB_ == nullptr) { in Get()
162 if (kvDB_ == nullptr) { in GetEntries()
268 if (kvDB_ == nullptr) { in GetSnapshot()
369 if (kvDB_ == nullptr) { in StartTransactionInner()
400 if (kvDB_ == nullptr) { in CommitInner()
415 if (kvDB_ == nullptr) { in RollBackInner()
424 if (kvDB_ == nullptr) { in Rekey()
447 errCode = kvDB_->Rekey(passwd); in Rekey()
456 if (kvDB_ == nullptr) { in Export()
464 if (kvDB_ == nullptr) { in Import()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/
H A Dgeneric_kvdb_connection.cpp29 : kvDB_(kvDB), in GenericKvDBConnection()
51 if (kvDB_ == nullptr) { in RegisterObserverForOneType()
59 errCode = kvDB_->RegisterFunction(funcType); in RegisterObserverForOneType()
132 if (kvDB_ == nullptr) { in UnRegisterObserver()
180 if (kvDB_ == nullptr) { in Close()
188 if (kvDB_->IsDataMigrating()) { in Close()
198 kvDB_->ReleaseDBConnection(this); in Close()
204 if (kvDB_ == nullptr) { in GetIdentifier()
281 if (kvDB_ == nullptr) { in GetSecurityOption()
297 if (kvDB_ == nullptr) { in RegisterSpecialListener()
[all …]
H A Dgeneric_kvdb_connection.h120 return static_cast<DerivedDBType *>(kvDB_); in GetDB()
136 GenericKvDB *kvDB_; variable
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_forward_cursor.cpp23 : kvDB_(kvDB), in SQLiteSingleVerForwardCursor()
33 : kvDB_(kvDB), in SQLiteSingleVerForwardCursor()
43 kvDB_ = nullptr; in ~SQLiteSingleVerForwardCursor()
56 handle_ = kvDB_->GetHandle(false, errCode); in Open()
70 kvDB_->ReleaseHandle(handle_); in Open()
75 kvDB_->ReleaseHandle(handle_); in Open()
90 kvDB_->ReleaseHandle(handle_); in Close()
113 kvDB_->ReleaseHandle(handle_); in Reload()
140 kvDB_->ReleaseHandle(handle_); in GetNext()
H A Dsqlite_single_ver_result_set.cpp33 …& option) : option_(option), type_(ResultSetType::KEYPREFIX), keyPrefix_(keyPrefix), kvDB_(kvDB) {} in SQLiteSingleVerResultSet()
36 …Option& option) : option_(option), type_(ResultSetType::QUERY), queryObj_(queryObj), kvDB_(kvDB) {} in SQLiteSingleVerResultSet()
43 kvDB_ = nullptr; in ~SQLiteSingleVerResultSet()
56 if (kvDB_ == nullptr) { // Unlikely in Open()
69 rawCursor_ = new (std::nothrow) SQLiteSingleVerForwardCursor(kvDB_, keyPrefix_); in OpenForCacheFullEntryMode()
71 rawCursor_ = new (std::nothrow) SQLiteSingleVerForwardCursor(kvDB_, queryObj_); in OpenForCacheFullEntryMode()
106 handle_ = kvDB_->GetHandle(false, errCode); in OpenForCacheEntryIdMode()
120 kvDB_->ReleaseHandle(handle_); in OpenForCacheEntryIdMode()
378 kvDB_->ReleaseHandle(handle_); in CloseForCacheEntryIdMode()
H A Dsqlite_single_ver_natural_store_connection.cpp445 if (kvDB_ == nullptr) { in SetConflictNotifier()
490 errCode = kvDB_->Rekey(passwd); in Rekey()
500 if (kvDB_ == nullptr) { in Export()
509 return kvDB_->Export(filePath, passwd); in Export()
524 errCode = kvDB_->Import(filePath, passwd); in Import()
529 kvDB_->ResetSyncStatus(); in Import()
645 if (kvDB_ == nullptr) { in RegisterLifeCycleCallback()
731 if (kvDB_ == nullptr) { in CheckMonoStatus()
761 kvDB_->ReEnableConnection(perm); in CheckMonoStatus()
773 kvDB_->ReEnableConnection(perm); in CheckMonoStatus()
[all …]
H A Dsqlite_single_ver_forward_cursor.h52 SQLiteSingleVerNaturalStore *kvDB_;
H A Dsqlite_single_ver_result_set.h105 SQLiteSingleVerNaturalStore *kvDB_ = nullptr; variable
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/
H A Dmulti_ver_natural_store_connection.cpp265 if (kvDB_ == nullptr) { in GetSnapshot()
365 if (kvDB_ == nullptr) { in CommitTransactionInner()
383 if (kvDB_ == nullptr) { in RollBackTransactionInner()
398 if (kvDB_ == nullptr) { in StartTransactionInner()
438 if (kvDB_ == nullptr) { in Rekey()
456 errCode = kvDB_->Rekey(passwd); in Rekey()
464 if (kvDB_ == nullptr) { in Export()
467 return kvDB_->Export(filePath, passwd); in Export()
472 if (kvDB_ == nullptr) { in Import()
487 errCode = kvDB_->Import(filePath, passwd); in Import()
[all …]
H A Dmulti_ver_storage_engine.cpp25 : kvDB_(nullptr), in MultiVerStorageEngine()
33 kvDB_ = nullptr; in ~MultiVerStorageEngine()
50 kvDB_ = kvDB; in InitDatabases()
59 …handle = new (std::nothrow) MultiVerStorageExecutor(kvDB_, dataStorage_, commitStorage_, kvDataSto… in CreateNewExecutor()
H A Dmulti_ver_storage_executor.cpp33 kvDB_(kvDB), in MultiVerStorageExecutor()
43 kvDB_ = nullptr; in ~MultiVerStorageExecutor()
739 Version maxVersion = static_cast<MultiVerNaturalStore *>(kvDB_)->GetMaxCommitVersion(); in StartAllDbTransaction()
793 Version maxVersion = static_cast<MultiVerNaturalStore *>(kvDB_)->GetMaxCommitVersion(); in StartTransaction()
877 static_cast<MultiVerNaturalStore *>(kvDB_)->SetMaxCommitVersion(commitVersion); in CommitTransaction()
940 MultiVerNaturalStore *multiVerNatureStore = static_cast<MultiVerNaturalStore *>(kvDB_); in Close()
1173 if (kvDB_ == nullptr || commitStorage_ == nullptr) { in FillAndCommitLogEntry()
1186 static_cast<MultiVerNaturalStore *>(kvDB_)->GetCurrentTag(vectTag); in FillAndCommitLogEntry()
1220 if (commitStorage_ == nullptr || kvDB_ == nullptr) { in FillCommitByForeign()
1230 static_cast<MultiVerNaturalStore *>(kvDB_)->GetCurrentTag(vectTag); in FillCommitByForeign()
[all …]
H A Dmulti_ver_storage_engine.h43 IKvDB *kvDB_;
H A Dmulti_ver_storage_executor.h178 IKvDB *kvDB_; variable
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_single_ver_result_set.cpp25 : key_(key), kvDB_(kvDB) in RdSingleVerResultSet()
32 : beginKey_(beginKey), endKey_(endKey), kvScanMode_(kvScanMode), kvDB_(kvDB) {} in RdSingleVerResultSet()
38 kvDB_ = nullptr; in ~RdSingleVerResultSet()
50 if (kvDB_ == nullptr) { // Unlikely in Open()
58 handle_ = kvDB_->GetHandle(false, errCode); in Open()
77 kvDB_->ReleaseHandle(handle_); in Open()
95 kvDB_->ReleaseHandle(handle_); in Close()
98 kvDB_->ReleaseHandle(handle_); in Close()
110 if (kvDB_ == nullptr) { // Unlikely in PreCheckResultSet()
H A Drd_single_ver_natural_store_connection.cpp405 if (kvDB_ == nullptr) { in Export()
415 return kvDB_->Export(filePath, passwd); in Export()
431 errCode = kvDB_->Import(filePath, passwd); in Import()
436 kvDB_->ReEnableConnection(OperatePerm::IMPORT_MONOPOLIZE_PERM); in Import()
438 kvDB_->ResetSyncStatus(); in Import()
445 if (kvDB_ == nullptr) { in CheckRdMonoStatus()
458 int errCode = kvDB_->TryToDisableConnection(perm); in CheckRdMonoStatus()
468 kvDB_->ReEnableConnection(perm); in CheckRdMonoStatus()
476 kvDB_->ReEnableConnection(perm); in CheckRdMonoStatus()
633 kvDB_->ReEnableConnection(OperatePerm::NORMAL_WRITE); in ReleaseExecutor()
[all …]
H A Drd_single_ver_result_set.h92 RdSingleVerNaturalStore *kvDB_ = nullptr; variable