updated mapping

adranwit · adranwit · commit 771ac1fd9ef4 · 2025-10-14T08:37:12.000-07:00
diff --git a/io/read/reader.go b/io/read/reader.go
@@ -78,7 +78,7 @@ func (r *Reader) QueryAll(ctx context.Context, emit func(row interface{}) error,
 		return fmt.Errorf("failed to read all %w", err)
 	}
 
-	if rows != nil {
+	if rows != nil && rows.Err() != nil {
 		return fmt.Errorf("encounter error: %w", rows.Err())
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -78,7 +78,7 @@ func (r *Reader) QueryAll(ctx context.Context, emit func(row interface{}) error,`
`78`	`78`	`return fmt.Errorf("failed to read all %w", err)`
`79`	`79`	`}`
`80`	`80`
`81`		`- if rows != nil {`
	`81`	`+ if rows != nil && rows.Err() != nil {`
`82`	`82`	`return fmt.Errorf("encounter error: %w", rows.Err())`
`83`	`83`	`}`
`84`	`84`