データベーステーブルのカラム情報を、sql.Rows.ColumnTypes() と sql.ColumnType.ScanType() を利用して取得するサンプルプログラムを以下に示します。データベースは sqlite3 を使用しています。
reflect.New()
で各カラムに対応する Go の型(type)のインスタンス(ポインタ)を作成して、それらを sql.Rows.Scan()
に渡しています。ポインタですので、値を取り出すのに reflect.Value.Elem()
を使います。
sql_example.go
package main
import (
"database/sql"
"fmt"
"reflect"
_ "github.com/mattn/go-sqlite3"
)
func main() {
// Connect to database
db, err := sql.Open("sqlite3", "./test.db")
if err != nil {
panic(err)
}
defer db.Close()
// Select records
rows, err := db.Query("SELECT * from hoge")
if err != nil {
panic(err)
}
defer rows.Close()
// No records
if !rows.Next() {
return
}
// Column types
ct, err := rows.ColumnTypes()
if err != nil {
panic(err)
}
types := make([]reflect.Type, len(ct))
for i, typ := range ct {
types[i] = typ.ScanType()
}
// Column values
values := make([]interface{}, len(ct))
for i := range values {
values[i] = reflect.New(types[i]).Interface()
}
// Scan
for {
err := rows.Scan(values...)
if err != nil {
panic(err)
}
for _, v := range values {
fmt.Printf("%v|", reflect.ValueOf(v).Elem())
}
fmt.Println()
if !rows.Next() {
break
}
}
}
実行結果
$ sqlite3 test.db <<EOS
CREATE TABLE hoge (
id INTEGER PRIMARY KEY,
created_at TIMESTAMP DEFAULT (datetime(CURRENT_TIMESTAMP, 'localtime'))
);
INSERT INTO hoge VALUES (1, '2020-03-06 12:58:47');
INSERT INTO hoge VALUES (2, '2020-04-28 01:36:20');
INSERT INTO hoge VALUES (3, '2020-05-15 15:10:12');
EOS
$ sqlite3 test.db <<EOS
SELECT * from hoge;
EOS
1|2020-03-06 12:58:47
2|2020-04-28 01:36:20
3|2020-05-15 15:10:12
$ go run sql_example.go
1|2020-03-06T12:58:47Z|
2|2020-04-28T01:36:20Z|
3|2020-05-15T15:10:12Z|
[50 48 50 ...]
は2020-03-06 12:58:47
という文字列(string)を byte array([]byte) に変換したものです。