@@ -73,7 +73,6 @@ func TestIntegration_ReadmeExample(t *testing.T) {
7373 if err != nil {
7474 t .Fatal (err )
7575 }
76- defer rows .Close ()
7776 ids := []int {}
7877 for rows .Next () {
7978 var id int
@@ -82,6 +81,9 @@ func TestIntegration_ReadmeExample(t *testing.T) {
8281 }
8382 ids = append (ids , id )
8483 }
84+ if err := rows .Err (); err != nil {
85+ t .Fatal (err )
86+ }
8587
8688 if len (ids ) != 2 {
8789 t .Fatalf ("expected 2 rows, got %d" , len (ids ))
@@ -137,7 +139,6 @@ func TestIntegration_InAny_PQ(t *testing.T) {
137139 if err != nil {
138140 t .Fatal (err )
139141 }
140- defer rows .Close ()
141142 ids := []int {}
142143 for rows .Next () {
143144 var id int
@@ -146,6 +147,9 @@ func TestIntegration_InAny_PQ(t *testing.T) {
146147 }
147148 ids = append (ids , id )
148149 }
150+ if err := rows .Err (); err != nil {
151+ t .Fatal (err )
152+ }
149153
150154 if len (ids ) != 8 {
151155 t .Fatalf ("expected 8 rows, got %d" , len (ids ))
@@ -202,7 +206,6 @@ func TestIntegration_InAny_PGX(t *testing.T) {
202206 if err != nil {
203207 t .Fatal (err )
204208 }
205- defer rows .Close ()
206209 ids := []int {}
207210 for rows .Next () {
208211 var id int
@@ -211,6 +214,9 @@ func TestIntegration_InAny_PGX(t *testing.T) {
211214 }
212215 ids = append (ids , id )
213216 }
217+ if err := rows .Err (); err != nil {
218+ t .Fatal (err )
219+ }
214220
215221 if len (ids ) != 8 {
216222 t .Fatalf ("expected 8 rows, got %d" , len (ids ))
@@ -466,7 +472,6 @@ func TestIntegration_BasicOperators(t *testing.T) {
466472 }
467473 return
468474 }
469- defer rows .Close ()
470475 players := []int {}
471476 for rows .Next () {
472477 var id int
@@ -475,6 +480,9 @@ func TestIntegration_BasicOperators(t *testing.T) {
475480 }
476481 players = append (players , id )
477482 }
483+ if err := rows .Err (); err != nil {
484+ t .Fatal (err )
485+ }
478486
479487 if ! reflect .DeepEqual (players , tt .expectedPlayers ) {
480488 t .Fatalf ("expected %v, got %v" , tt .expectedPlayers , players )
@@ -536,7 +544,6 @@ func TestIntegration_NestedJSONB(t *testing.T) {
536544 if err != nil {
537545 t .Fatal (err )
538546 }
539- defer rows .Close ()
540547 players := []int {}
541548 for rows .Next () {
542549 var id int
@@ -545,6 +552,9 @@ func TestIntegration_NestedJSONB(t *testing.T) {
545552 }
546553 players = append (players , id )
547554 }
555+ if err := rows .Err (); err != nil {
556+ t .Fatal (err )
557+ }
548558
549559 if ! reflect .DeepEqual (players , tt .expectedPlayers ) {
550560 t .Fatalf ("%q expected %v, got %v (conditions used: %q)" , tt .input , tt .expectedPlayers , players , conditions )
@@ -604,7 +614,6 @@ func TestIntegration_Logic(t *testing.T) {
604614 if err != nil {
605615 t .Fatal (err )
606616 }
607- defer rows .Close ()
608617 players := []int {}
609618 for rows .Next () {
610619 var id int
@@ -613,6 +622,9 @@ func TestIntegration_Logic(t *testing.T) {
613622 }
614623 players = append (players , id )
615624 }
625+ if err := rows .Err (); err != nil {
626+ t .Fatal (err )
627+ }
616628
617629 if ! reflect .DeepEqual (players , tt .expectedPlayers ) {
618630 t .Fatalf ("%q expected %v, got %v (conditions used: %q)" , tt .input , tt .expectedPlayers , players , conditions )
0 commit comments