代码拉取完成,页面将自动刷新
diff --git a/frameworks/libs/distributeddb/test/unittest/common/interfaces/distributeddb_cloud_interfaces_relational_ext_test.cpp b/frameworks/libs/distributeddb/test/unittest/common/interfaces/distributeddb_cloud_interfaces_relational_ext_test.cpp
index 8c3aa9757..91b909aea 100644
--- a/frameworks/libs/distributeddb/test/unittest/common/interfaces/distributeddb_cloud_interfaces_relational_ext_test.cpp
+++ b/frameworks/libs/distributeddb/test/unittest/common/interfaces/distributeddb_cloud_interfaces_relational_ext_test.cpp
@@ -600,6 +600,7 @@ HWTEST_F(DistributedDBCloudInterfacesRelationalExtTest, TriggerObserverTest002,
ClientObserver clientObserver = std::bind(&DistributedDBCloudInterfacesRelationalExtTest::ClientObserverFunc,
this, std::placeholders::_1);
EXPECT_EQ(RegisterClientObserver(db, clientObserver), OK);
+ RegisterDbHook(db);
/**
* @tc.steps:step3. insert data into sync_data, check observer.
@@ -637,6 +638,7 @@ HWTEST_F(DistributedDBCloudInterfacesRelationalExtTest, TriggerObserverTest002,
ClientObserver clientObserver2 = std::bind(&DistributedDBCloudInterfacesRelationalExtTest::ClientObserverFunc2,
this, std::placeholders::_1);
EXPECT_EQ(RegisterClientObserver(db, clientObserver2), OK);
+ RegisterDbHook(db);
sql = "update " + tableName + " set name = 'lisi2' where id = 2;";
EXPECT_EQ(RelationalTestUtils::ExecSql(db, sql), E_OK);
WaitAndResetNotify();
@@ -715,6 +717,7 @@ HWTEST_F(DistributedDBCloudInterfacesRelationalExtTest, TriggerObserverTest004,
ClientObserver clientObserver = std::bind(&DistributedDBCloudInterfacesRelationalExtTest::ClientObserverFunc,
this, std::placeholders::_1);
EXPECT_EQ(RegisterClientObserver(db, clientObserver), OK);
+ RegisterDbHook(db);
/**
* @tc.steps:step3. insert data into sync_data, check observer.
@@ -778,6 +781,7 @@ HWTEST_F(DistributedDBCloudInterfacesRelationalExtTest, TriggerObserverTest005,
ClientObserver clientObserver = std::bind(&DistributedDBCloudInterfacesRelationalExtTest::ClientObserverFunc,
this, std::placeholders::_1);
EXPECT_EQ(RegisterClientObserver(db, clientObserver), OK);
+ RegisterDbHook(db);
/**
* @tc.steps:step3. begin transaction and commit.
@@ -853,6 +857,7 @@ HWTEST_F(DistributedDBCloudInterfacesRelationalExtTest, TriggerObserverTest006,
ClientObserver clientObserver = std::bind(&DistributedDBCloudInterfacesRelationalExtTest::ClientObserverFunc,
this, std::placeholders::_1);
EXPECT_EQ(RegisterClientObserver(db, clientObserver), OK);
+ RegisterDbHook(db);
/**
* @tc.steps:step3. begin transaction and commit.
@@ -882,6 +887,7 @@ HWTEST_F(DistributedDBCloudInterfacesRelationalExtTest, TriggerObserverTest006,
* @tc.expected: step5. check observer ok.
*/
EXPECT_EQ(RegisterClientObserver(db, clientObserver), OK);
+ RegisterDbHook(db);
sql = "insert into " + tableName1 + " VALUES(7, 'zhangjiu');";
EXPECT_EQ(RelationalTestUtils::ExecSql(db, sql), E_OK);
WaitAndResetNotify();
@@ -918,6 +924,7 @@ HWTEST_F(DistributedDBCloudInterfacesRelationalExtTest, TriggerObserverTest007,
ClientObserver clientObserver = std::bind(&DistributedDBCloudInterfacesRelationalExtTest::ClientObserverFunc,
this, std::placeholders::_1);
EXPECT_EQ(RegisterClientObserver(db, clientObserver), OK);
+ RegisterDbHook(db);
/**
* @tc.steps:step3. insert data into sync_data, check observer.
@@ -1576,6 +1583,7 @@ HWTEST_F(DistributedDBCloudInterfacesRelationalExtTest, RegisterStoreObserverTes
*/
auto storeObserver = std::make_shared<MockStoreObserver>();
EXPECT_EQ(RegisterStoreObserver(db, storeObserver), OK);
+ RegisterDbHook(db);
EXPECT_TRUE(g_changedData.empty());
int dataCounts = 10; // 10 is count of insert options.
int begin = 0;
@@ -1623,6 +1631,7 @@ HWTEST_F(DistributedDBCloudInterfacesRelationalExtTest, RegisterStoreObserverTes
EXPECT_NE(db, nullptr);
auto storeObserver = std::make_shared<MockStoreObserver>();
EXPECT_EQ(RegisterStoreObserver(db, storeObserver), OK);
+ RegisterDbHook(db);
EXPECT_EQ(RelationalTestUtils::ExecSql(db, "PRAGMA journal_mode=WAL;"), SQLITE_OK);
std::string tableName = "primary_test";
CreateTableForStoreObserver(db, tableName);
@@ -1674,6 +1683,7 @@ HWTEST_F(DistributedDBCloudInterfacesRelationalExtTest, RegisterStoreObserverTes
auto storeObserver2 = std::make_shared<MockStoreObserver>();
EXPECT_EQ(RegisterStoreObserver(db, storeObserver1), OK);
EXPECT_EQ(RegisterStoreObserver(db, storeObserver2), OK);
+ RegisterDbHook(db);
EXPECT_EQ(RelationalTestUtils::ExecSql(db, "PRAGMA journal_mode=WAL;"), SQLITE_OK);
std::string tableName = "primary_test";
CreateTableForStoreObserver(db, tableName);
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。