updated mapping

adranwit · adranwit · commit e55731fda855 · 2025-08-26T05:26:42.000-07:00
diff --git a/io/columns.go b/io/columns.go
@@ -187,7 +187,11 @@ func TypesToColumns(columns []*sql.ColumnType) []Column {
 		dbType := columns[i].DatabaseTypeName()
 		dbType = strings.Replace(dbType, "UNSIGNED", "", 1)
 		dbType = strings.TrimSpace(dbType)
-		result[i] = &columnType{databaseTypeName: dbType, ColumnType: columns[i], scanType: NormalizeColumnType(columns[i].ScanType(), columns[i].DatabaseTypeName())}
+		scanType := columns[i].ScanType()
+		if scanType == nil {
+			scanType = reflect.TypeOf(sql.RawBytes{})
+		}
+		result[i] = &columnType{databaseTypeName: dbType, ColumnType: columns[i], scanType: NormalizeColumnType(scanType, columns[i].DatabaseTypeName())}
 	}
 	return result
 }

Original file line number	Diff line number	Diff line change
`@@ -187,7 +187,11 @@ func TypesToColumns(columns []*sql.ColumnType) []Column {`
`187`	`187`	`dbType := columns[i].DatabaseTypeName()`
`188`	`188`	`dbType = strings.Replace(dbType, "UNSIGNED", "", 1)`
`189`	`189`	`dbType = strings.TrimSpace(dbType)`
`190`		`- result[i] = &columnType{databaseTypeName: dbType, ColumnType: columns[i], scanType: NormalizeColumnType(columns[i].ScanType(), columns[i].DatabaseTypeName())}`
	`190`	`+ scanType := columns[i].ScanType()`
	`191`	`+ if scanType == nil {`
	`192`	`+ scanType = reflect.TypeOf(sql.RawBytes{})`
	`193`	`+ }`
	`194`	`+ result[i] = &columnType{databaseTypeName: dbType, ColumnType: columns[i], scanType: NormalizeColumnType(scanType, columns[i].DatabaseTypeName())}`
`191`	`195`	`}`
`192`	`196`	`return result`
`193`	`197`	`}`