1 Star 0 Fork 0

廖永煌/lyh

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
br_253_ut.diff 4.76 KB
一键复制 编辑 原始数据 按行查看 历史
廖永煌 提交于 2025-03-06 19:54 +08:00 . 1
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);
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/liao-yonghuang/lyh.git
git@gitee.com:liao-yonghuang/lyh.git
liao-yonghuang
lyh
lyh
master

搜索帮助