fix test bug
diff --git a/dockertests/docker_test.go b/dockertests/docker_test.go
index 87eff5d..0851a41 100644
--- a/dockertests/docker_test.go
+++ b/dockertests/docker_test.go
@@ -121,7 +121,7 @@
It("should get data according to data scope", func(done Done) {
tableName := "docker_test_b"
targetTablename := "edgex_" + tableName
- handler := &newTableHandler{
+ handler := &newTableScopeHandler{
targetTablename: targetTablename,
done: done,
}
@@ -141,6 +141,8 @@
Expect(err).Should(Succeed())
_, err = tx.Exec("ALTER TABLE edgex." + tableName + " replica identity full;")
Expect(err).Should(Succeed())
+ _, err = tx.Exec("INSERT INTO edgex." + tableName + " values ('three', 3, '" + clusterIdFromConfig + "');")
+ Expect(err).Should(Succeed())
tx.Commit()
}
@@ -302,6 +304,7 @@
func (n *newTableHandler) Handle(event apid.Event) {
if s, ok := event.(*common.Snapshot); ok {
+ defer GinkgoRecover()
sqliteDb, err := dataService.DBVersion(s.SnapshotInfo)
Expect(err).Should(Succeed())
Expect(verifyTestTableExist(n.targetTablename, sqliteDb)).To(BeTrue())
@@ -333,6 +336,7 @@
func (n *newTableScopeHandler) Handle(event apid.Event) {
if s, ok := event.(*common.Snapshot); ok {
+ defer GinkgoRecover()
sqliteDb, err := dataService.DBVersion(s.SnapshotInfo)
Expect(err).Should(Succeed())
verifyTestTableData(n.targetTablename, sqliteDb)
