Skip to content
This repository was archived by the owner on Dec 13, 2023. It is now read-only.

Commit 60b83bc

Browse files
committed
Added needed context cancels
1 parent 48e53d5 commit 60b83bc

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

cqlSql_test.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -114,6 +114,7 @@ func TestSqlInsertUpdateSelectDelete(t *testing.T) {
114114
// truncate table
115115
ctx, cancel := context.WithTimeout(context.Background(), TimeoutValid)
116116
result, err := db.ExecContext(ctx, "truncate table "+KeyspaceName+"."+TableName)
117+
cancel()
117118
if err != nil {
118119
t.Fatal("ExecContext error: ", err)
119120
}
@@ -567,6 +568,7 @@ func TestSqlSelectLoop(t *testing.T) {
567568
// truncate table
568569
ctx, cancel := context.WithTimeout(context.Background(), TimeoutValid)
569570
result, err := db.ExecContext(ctx, "truncate table "+KeyspaceName+"."+TableName)
571+
cancel()
570572
if err != nil {
571573
t.Fatal("ExecContext error: ", err)
572574
}
@@ -577,13 +579,13 @@ func TestSqlSelectLoop(t *testing.T) {
577579
// insert one
578580
ctx, cancel = context.WithTimeout(context.Background(), TimeoutValid)
579581
result, err = db.ExecContext(ctx, "insert into "+KeyspaceName+"."+TableName+" (text_data, int_data) values (?, ?)", "one", 1)
582+
cancel()
580583
if err != nil {
581584
t.Fatal("ExecContext error: ", err)
582585
}
583586
if result == nil {
584587
t.Fatal("result is nil")
585588
}
586-
cancel()
587589

588590
for i := 0; i < 100; i++ {
589591
// select all

0 commit comments

Comments
 (0)