diff --git a/reader/sql/utils.go b/reader/sql/utils.go index 2a56cd4dc..80e7888a4 100644 --- a/reader/sql/utils.go +++ b/reader/sql/utils.go @@ -152,6 +152,11 @@ func GetInitScans(length int, rows *sql.Rows, schemas map[string]string, runnerN nochoiced[i] = true } } + nullable, ok := v.Nullable() + nullable = nullable && ok + if nullable { + scanArgs[i] = new(interface{}) + } } return scanArgs, nochoiced }