GOMODULES/ksql
1
0
Fork 0
mirror of https://github.com/VinGarcia/ksql.git synced 2025-05-31 11:42:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

Simplify ScanRows test

Browse Source
This commit is contained in:
Vinícius Garcia 2022-02-28 23:18:15 -03:00
parent a51e9730c3
commit 5337a9a59e
1 changed files with 2 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
adapters_test.go
View File

@ -2192,11 +2192,7 @@ func ScanRowsTest(
rows, err := db.QueryContext(ctx, "SELECT * FROM users WHERE name='User2'") rows, err := db.QueryContext(ctx, "SELECT * FROM users WHERE name='User2'")
tt.AssertNoErr(t, err) tt.AssertNoErr(t, err)
// Some drivers will hang forever if Next() is not called: defer rows.Close()
defer func() {
for rows.Next() {
}
}()
var u User var u User
err = scanRows(dialect, rows, u) err = scanRows(dialect, rows, u)
@ -2216,11 +2212,7 @@ func ScanRowsTest(
rows, err := db.QueryContext(ctx, "SELECT * FROM users WHERE name='User2'") rows, err := db.QueryContext(ctx, "SELECT * FROM users WHERE name='User2'")
tt.AssertNoErr(t, err) tt.AssertNoErr(t, err)
// Some drivers will hang forever if Next() is not called: defer rows.Close()
defer func() {
for rows.Next() {
}
}()
var u map[string]interface{} var u map[string]interface{}
err = scanRows(dialect, rows, &u) err = scanRows(dialect, rows, &u)