/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
H A D | sqlite_relational_store_connection.cpp | 25 auto *store = GetDB<SQLiteRelationalStore>(); in SQLiteRelationalStoreConnection() 72 auto *store = GetDB<SQLiteRelationalStore>(); in GetExecutor() 84 auto *store = GetDB<SQLiteRelationalStore>(); in ReleaseExecutor() 146 auto *store = GetDB<SQLiteRelationalStore>(); in CreateDistributedTable() 161 auto *store = GetDB<SQLiteRelationalStore>(); in RemoveDeviceData() 176 auto *store = GetDB<SQLiteRelationalStore>(); in GetCloudSyncTaskCount() 190 auto *store = GetDB<SQLiteRelationalStore>(); in DoClean() 210 auto *store = GetDB<SQLiteRelationalStore>(); in RemoveDeviceData() 232 auto *store = GetDB<SQLiteRelationalStore>(); in SyncToDevice() 272 auto *store = GetDB<SQLiteRelationalStore>(); in RegisterLifeCycleCallback() [all …]
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
H A D | sync_able_kvdb_connection.cpp | 32 auto *db = GetDB<SyncAbleKvDB>(); in SyncAbleKvDBConnection() 128 SyncAbleKvDB *kvDB = GetDB<SyncAbleKvDB>(); in PragmaSyncAction() 164 SyncAbleKvDB *kvDB = GetDB<SyncAbleKvDB>(); in EnableAutoSync() 194 SyncAbleKvDB *kvDB = GetDB<SyncAbleKvDB>(); in GetQueuedSyncSize() 210 SyncAbleKvDB *kvDB = GetDB<SyncAbleKvDB>(); in SetQueuedSyncLimit() 222 SyncAbleKvDB *kvDB = GetDB<SyncAbleKvDB>(); in GetQueuedSyncLimit() 231 SyncAbleKvDB *kvDB = GetDB<SyncAbleKvDB>(); in DisableManualSync() 240 SyncAbleKvDB *kvDB = GetDB<SyncAbleKvDB>(); in EnableManualSync() 252 SyncAbleKvDB *kvDB = GetDB<SyncAbleKvDB>(); in SetStaleDataWipePolicy() 383 auto *kvDB = GetDB<SyncAbleKvDB>(); in SetGenCloudVersionCallback() [all …]
|
H A D | generic_kvdb_connection.h | 118 DerivedDBType *GetDB() const in GetDB() function
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
H A D | sqlite_single_ver_natural_store_connection.cpp | 72 SQLiteSingleVerNaturalStore *naturalStore = GetDB<SQLiteSingleVerNaturalStore>(); in CheckReadDataControlled() 144 SQLiteSingleVerNaturalStore *naturalStore = GetDB<SQLiteSingleVerNaturalStore>(); in GetEntries() 199 SQLiteSingleVerNaturalStore *naturalStore = GetDB<SQLiteSingleVerNaturalStore>(); in GetCount() 556 SQLiteSingleVerNaturalStore *naturalStore = GetDB<SQLiteSingleVerNaturalStore>(); in GetResultSet() 1157 GenericKvDB *naturalStore = GetDB<GenericKvDB>(); in CheckLocalEntriesValid() 1181 GenericKvDB *naturalStore = GetDB<GenericKvDB>(); in CheckLocalKeysValid() 1892 auto naturalStore = GetDB<SQLiteSingleVerNaturalStore>(); in SetCloudDbSchema() 1903 auto naturalStore = GetDB<SQLiteSingleVerNaturalStore>(); in RegisterObserverAction() 1913 auto naturalStore = GetDB<SQLiteSingleVerNaturalStore>(); in UnRegisterObserverAction() 1955 auto naturalStore = GetDB<SQLiteSingleVerNaturalStore>(); in GetCloudVersion() [all …]
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
H A D | multi_ver_natural_store_connection.cpp | 65 GetDB<MultiVerNaturalStore>()->ReleaseHandle(handle); in Get() 174 GetDB<MultiVerNaturalStore>()->ReleaseHandle(handle); in GetEntries() 278 GetDB<MultiVerNaturalStore>()->ReleaseHandle(handle); in GetSnapshot() 284 GetDB<MultiVerNaturalStore>()->ReleaseHandle(handle); in GetSnapshot() 290 GetDB<MultiVerNaturalStore>()->AddVersionConstraintToList(handle->GetCurrentReadVersion()); in GetSnapshot() 375 GetDB<MultiVerNaturalStore>()->ReleaseHandle(writeHandle_); in CommitTransactionInner() 391 GetDB<MultiVerNaturalStore>()->ReleaseHandle(writeHandle_); in RollBackTransactionInner() 415 GetDB<MultiVerNaturalStore>()->ReleaseHandle(handle); in StartTransactionInner() 513 MultiVerNaturalStore *multiVerNatureStore = GetDB<MultiVerNaturalStore>(); in GetHandle()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/kv/ |
H A D | sqlite_local_kvdb_connection.cpp | 53 SQLiteLocalStorageExecutor *handle = GetDB<SQLiteLocalKvDB>()->GetHandle(false, errCode); in Get() 59 GetDB<SQLiteLocalKvDB>()->ReleaseHandle(handle); in Get() 175 SQLiteLocalStorageExecutor *handle = GetDB<SQLiteLocalKvDB>()->GetHandle(false, errCode); in GetEntries() 180 GetDB<SQLiteLocalKvDB>()->ReleaseHandle(handle); in GetEntries() 351 GetDB<SQLiteLocalKvDB>()->ReleaseHandle(writeHandle_); in PreClose() 375 SQLiteLocalStorageExecutor *handle = GetDB<SQLiteLocalKvDB>()->GetHandle(true, errCode); in StartTransactionInner() 382 GetDB<SQLiteLocalKvDB>()->ReleaseHandle(handle); in StartTransactionInner() 403 GetDB<SQLiteLocalKvDB>()->ReleaseHandle(writeHandle_); in CommitInner() 418 GetDB<SQLiteLocalKvDB>()->ReleaseHandle(writeHandle_); in RollBackInner()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
H A D | rd_single_ver_natural_store_connection.cpp | 109 RdSingleVerNaturalStore *naturalStore = GetDB<RdSingleVerNaturalStore>(); in GetResultSet() 162 RdSingleVerNaturalStore *naturalStore = GetDB<RdSingleVerNaturalStore>(); in GetResultSet() 253 RdSingleVerNaturalStore *naturalStore = GetDB<RdSingleVerNaturalStore>(); in CommitAndReleaseNotifyData() 513 RdSingleVerNaturalStore *naturalStore = GetDB<RdSingleVerNaturalStore>(); in CheckIntegrity() 538 RdSingleVerNaturalStore *naturalStore = GetDB<RdSingleVerNaturalStore>(); in CheckSyncEntriesValid() 597 RdSingleVerNaturalStore *naturalStore = GetDB<RdSingleVerNaturalStore>(); in SaveEntry() 622 RdSingleVerNaturalStore *naturalStore = GetDB<RdSingleVerNaturalStore>(); in GetExecutor() 634 RdSingleVerNaturalStore *naturalStore = GetDB<RdSingleVerNaturalStore>(); in ReleaseExecutor() 713 RdSingleVerNaturalStore *naturalStore = GetDB<RdSingleVerNaturalStore>(); in CheckReadDataControlled() 727 RdSingleVerNaturalStore *naturalStore = GetDB<RdSingleVerNaturalStore>(); in CheckSyncKeysValid()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
H A D | distributeddb_relational_multi_user_test.cpp | 106 int GetDB(sqlite3 *&db, const std::string &dbPath) in GetDB() function 123 EXPECT_EQ(GetDB(db, dbPath), SQLITE_OK); in PrepareVirtualDeviceEnv() 144 EXPECT_EQ(GetDB(db, dbPath), SQLITE_OK); in PrepareData() 189 EXPECT_EQ(GetDB(db, dbPath), SQLITE_OK); in PrepareEnvironment() 393 EXPECT_EQ(GetDB(db, g_storePath2), SQLITE_OK); in CheckDataInRealDevice() 445 ASSERT_EQ(GetDB(db1, g_storePath1), SQLITE_OK); in SetUpTestCase() 449 ASSERT_EQ(GetDB(db2, g_storePath2), SQLITE_OK); in SetUpTestCase()
|
H A D | distributeddb_relational_ver_p2p_sync_test.cpp | 430 EXPECT_EQ(GetDB(db), SQLITE_OK); in InsertValueToDB() 439 EXPECT_EQ(GetDB(db), SQLITE_OK); in PrepareBasicTable() 498 EXPECT_EQ(GetDB(db), SQLITE_OK); in CheckData() 816 ASSERT_EQ(GetDB(db), SQLITE_OK); in SetUpTestCase() 852 ASSERT_EQ(GetDB(db), SQLITE_OK); in SetUp() 999 EXPECT_EQ(GetDB(db), SQLITE_OK); 1070 EXPECT_EQ(GetDB(db), SQLITE_OK); 1105 EXPECT_EQ(GetDB(db), SQLITE_OK); 1133 EXPECT_EQ(GetDB(db), SQLITE_OK); 2814 EXPECT_EQ(GetDB(db), SQLITE_OK); [all …]
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
H A D | relational_store_connection.h | 90 DerivedDBType *GetDB() const in GetDB() function
|