Skip to content

Commit 86d5457

Browse files
committedMay 9, 2023
Use sql.Scanner to refer to the sql.Scanner interface
1 parent 414c62e commit 86d5457

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed
 

‎lib/column/array.go

+2-1
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
package column
1919

2020
import (
21+
"database/sql"
2122
"fmt"
2223
"github.com/ClickHouse/ch-go/proto"
2324
"reflect"
@@ -218,7 +219,7 @@ func (col *Array) WriteStatePrefix(buffer *proto.Buffer) error {
218219
}
219220

220221
func (col *Array) ScanRow(dest any, row int) error {
221-
if scanner, ok := dest.(interface{ Scan(any) error }); ok {
222+
if scanner, ok := dest.(sql.Scanner); ok {
222223
value, err := col.scan(scanTypeAny, row)
223224
if err != nil {
224225
return err

‎lib/column/map.go

+2-1
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
package column
1919

2020
import (
21+
"database/sql"
2122
"fmt"
2223
"github.com/ClickHouse/ch-go/proto"
2324
"reflect"
@@ -88,7 +89,7 @@ func (col *Map) Row(i int, ptr bool) any {
8889
}
8990

9091
func (col *Map) ScanRow(dest any, i int) error {
91-
if scanner, ok := dest.(interface{ Scan(any) error }); ok {
92+
if scanner, ok := dest.(sql.Scanner); ok {
9293
return scanner.Scan(col.row(i).Interface())
9394
}
9495
value := reflect.Indirect(reflect.ValueOf(dest))

0 commit comments

Comments
 (0)
Please sign in to comment.