| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/oh_adapter/src/ |
| H A D | rd_sqlite_utils.h | 26 enum class TransactType { enum
44 static int BeginTransaction(sqlite3 *db, TransactType type = TransactType::DEFERRED);
|
| H A D | rd_sqlite_utils.cpp | 207 int RDSQLiteUtils::BeginTransaction(sqlite3 *db, TransactType type) in BeginTransaction()
209 if (type == TransactType::IMMEDIATE) { in BeginTransaction()
|
| H A D | sqlite_store_executor_impl.cpp | 94 return RDSQLiteUtils::BeginTransaction(dbHandle_, TransactType::IMMEDIATE); in StartTransaction()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_natural_store_connection.h | 154 int StartTransactionInner(TransactType transType = TransactType::DEFERRED);
205 int StartTransactionInCacheMode(TransactType transType = TransactType::DEFERRED);
206 int StartTransactionNormally(TransactType transType = TransactType::DEFERRED);
|
| H A D | sqlite_utils.h | 34 enum class TransactType { enum
83 static int BeginTransaction(sqlite3 *db, TransactType type = TransactType::DEFERRED);
|
| H A D | sqlite_cloud_kv_store.cpp | 88 int SqliteCloudKvStore::StartTransaction(TransactType type) in StartTransaction()
97 auto [errCode, handle] = storageHandle_->GetStorageExecutor(type == TransactType::IMMEDIATE); in StartTransaction()
284 ret = StartTransaction(TransactType::DEFERRED); in FillCloudLogAndAsset()
589 int ret = StartTransaction(TransactType::DEFERRED); in GetCompensatedSyncQuery()
|
| H A D | sqlite_single_ver_natural_store_extend.cpp | 411 errCode = handle->StartTransaction(TransactType::IMMEDIATE); in AddSubscribe()
518 errCode = handle->StartTransaction(TransactType::IMMEDIATE); in RemoveDeviceDataInner()
547 errCode = handle->StartTransaction(TransactType::IMMEDIATE); in RemoveDeviceDataInner()
|
| H A D | sqlite_single_ver_natural_store_connection.cpp | 817 errCode = StartTransactionInner(TransactType::IMMEDIATE); in PutBatchInner()
865 errCode = StartTransactionInner(TransactType::IMMEDIATE); in DeleteBatchInner()
1218 int SQLiteSingleVerNaturalStoreConnection::StartTransactionInner(TransactType transType) in StartTransactionInner()
1227 int SQLiteSingleVerNaturalStoreConnection::StartTransactionInCacheMode(TransactType transType) in StartTransactionInCacheMode()
1250 int SQLiteSingleVerNaturalStoreConnection::StartTransactionNormally(TransactType transType) in StartTransactionNormally()
1421 errCode = StartTransactionInner(TransactType::IMMEDIATE); in PublishLocal()
1542 errCode = StartTransactionInner(TransactType::IMMEDIATE); in UnpublishToLocal()
1873 errCode = handle->StartTransaction(TransactType::IMMEDIATE); in SetCloudDbSchema()
|
| H A D | sqlite_cloud_kv_store.h | 40 int StartTransaction(TransactType type) override;
|
| H A D | sqlite_single_ver_natural_store.cpp | 589 handle->StartTransaction(TransactType::IMMEDIATE); in DeleteMetaData()
741 errCode = handle->StartTransaction(TransactType::DEFERRED); in GetSyncDataForQuerySync()
1255 errCode = handle->StartTransaction(TransactType::IMMEDIATE); in SaveSyncItems()
1785 int errCode = handle->StartTransaction(TransactType::IMMEDIATE); in SaveSyncItemsInCacheMode()
1885 errCode = handle->StartTransaction(TransactType::IMMEDIATE); in RemoveSubscribe()
1929 errCode = handle->StartTransaction(TransactType::IMMEDIATE); in RemoveAllSubscribe()
|
| H A D | sqlite_single_ver_database_upgrader.cpp | 132 return SQLiteUtils::BeginTransaction(db_, TransactType::IMMEDIATE); in BeginUpgrade()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
| H A D | rd_single_ver_natural_store_connection.h | 145 int StartTransactionInner(TransactType transType = TransactType::DEFERRED);
147 int StartTransactionNormally(TransactType transType = TransactType::DEFERRED);
|
| H A D | rd_single_ver_natural_store_connection.cpp | 564 errCode = StartTransactionInner(TransactType::IMMEDIATE); in PutBatchInner()
648 int RdSingleVerNaturalStoreConnection::StartTransactionInner(TransactType transType) in StartTransactionInner()
657 int RdSingleVerNaturalStoreConnection::StartTransactionNormally(TransactType transType) in StartTransactionNormally()
754 errCode = StartTransactionInner(TransactType::IMMEDIATE); in DeleteBatchInner()
|
| H A D | rd_single_ver_storage_executor.h | 121 int StartTransaction(TransactType type);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | storage_proxy.h | 54 int StartTransaction(TransactType type = TransactType::DEFERRED);
|
| H A D | icloud_sync_storage_interface.h | 106 virtual int StartTransaction(TransactType type) = 0;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | mock_icloud_sync_storage_interface.h | 30 MOCK_METHOD1(StartTransaction, int(TransactType));
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_relational_storage_engine.cpp | 276 errCode = handle->StartTransaction(TransactType::IMMEDIATE); in CreateDistributedTable()
348 errCode = handle->StartTransaction(TransactType::IMMEDIATE); in UpgradeDistributedTable()
405 errCode = handle->StartTransaction(TransactType::IMMEDIATE); in CleanDistributedDeviceTable()
464 errCode = handle->StartTransaction(TransactType::IMMEDIATE); in SetTrackerTable()
719 errCode = handle->StartTransaction(TransactType::IMMEDIATE); in UpgradeSharedTable()
1028 errCode = handle->StartTransaction(TransactType::IMMEDIATE); in GenLogInfoForUpgrade()
|
| H A D | sqlite_relational_database_upgrader.cpp | 69 return SQLiteUtils::BeginTransaction(db_, TransactType::IMMEDIATE); in BeginUpgrade()
|
| H A D | sqlite_relational_store_connection.cpp | 104 errCode = handle->StartTransaction(TransactType::DEFERRED); in StartTransaction()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_relational_cloud_syncable_storage_test.cpp | 328 ASSERT_EQ(g_storageProxy->StartTransaction(TransactType::IMMEDIATE), E_OK); in fillCloudAssetTest()
486 EXPECT_EQ(g_cloudStore->StartTransaction(TransactType::DEFERRED), E_OK);
492 EXPECT_EQ(g_cloudStore->StartTransaction(TransactType::DEFERRED), E_OK);
538 EXPECT_EQ(g_storageProxy->StartTransaction(TransactType::IMMEDIATE), E_OK);
676 EXPECT_EQ(g_storageProxy->StartTransaction(TransactType::IMMEDIATE), E_OK);
861 EXPECT_EQ(g_storageProxy->StartTransaction(TransactType::IMMEDIATE), E_OK);
929 EXPECT_EQ(g_storageProxy->StartTransaction(TransactType::IMMEDIATE), E_OK);
969 EXPECT_EQ(g_storageProxy->StartTransaction(TransactType::IMMEDIATE), E_OK);
1622 EXPECT_EQ(g_storageProxy->StartTransaction(TransactType::IMMEDIATE), E_OK);
|
| H A D | distributeddb_storage_rd_single_ver_natural_executor_test.cpp | 207 EXPECT_EQ(g_nullHandle->StartTransaction(TransactType::DEFERRED), E_OK); // -E_INVALID_DB
211 EXPECT_EQ(g_handle->StartTransaction(TransactType::DEFERRED), E_OK);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_save_cloud_data_test.cpp | 842 EXPECT_EQ(storageProxy->StartTransaction(TransactType::IMMEDIATE), E_OK); in SaveCloudDataTest()
1066 EXPECT_EQ(storageProxy->StartTransaction(TransactType::IMMEDIATE), E_OK);
1099 EXPECT_EQ(storageProxy->StartTransaction(TransactType::IMMEDIATE), E_OK);
1151 EXPECT_EQ(storageProxy->StartTransaction(TransactType::IMMEDIATE), E_OK);
1185 EXPECT_EQ(storageProxy->StartTransaction(TransactType::IMMEDIATE), E_OK);
1245 EXPECT_EQ(storageProxy->StartTransaction(TransactType::IMMEDIATE), E_OK); in DeleteWithPkTest()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 277 handle->StartTransaction(TransactType::IMMEDIATE); in DeleteMetaData()
670 errCode = handle->StartTransaction(TransactType::IMMEDIATE); in CreateDistributedDeviceTable()
1013 int RelationalSyncAbleStorage::StartTransaction(TransactType type) in StartTransaction()
1025 … storageEngine_->FindExecutor(type == TransactType::IMMEDIATE, OperatePerm::NORMAL_PERM, errCode)); in StartTransaction()
1404 errCode = writeHandle->StartTransaction(TransactType::IMMEDIATE); in FillCloudLogAndAsset()
1778 errCode = handle->StartTransaction(TransactType::IMMEDIATE); in UpsertDataInner()
1966 errCode = handle->StartTransaction(TransactType::IMMEDIATE); in ClearUnLockingNoNeedCompensated()
2010 errCode = handle->StartTransaction(TransactType::IMMEDIATE); in GetCompensatedSyncQueryInner()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | storage_proxy.cpp | 125 int StorageProxy::StartTransaction(TransactType type) in StartTransaction()
134 isWrite_.store(type == TransactType::IMMEDIATE); in StartTransaction()
|