DuckDB Go 驱动程序，go-duckdb，允许通过 database/sql 接口使用 DuckDB。
有关如何使用此接口的示例，请参阅 官方文档 和 教程。
Go客户端是一个第三方库，其代码库托管在https://github.com/marcboeker/go-duckdb。
Installation
要安装 go-duckdb 客户端，请运行：
go get github.com/marcboeker/go-duckdb
导入
要导入DuckDB Go包，请将以下条目添加到您的导入中：
import (
"database/sql"
_ "github.com/marcboeker/go-duckdb"
)
Appender
DuckDB Go客户端支持用于批量插入的DuckDB Appender API。您可以通过向NewAppenderFromConn()提供DuckDB连接来获取一个新的Appender。例如：
connector, err := duckdb.NewConnector("test.db", nil)
if err != nil {
...
}
conn, err := connector.Connect(context.Background())
if err != nil {
...
}
defer conn.Close()
// Retrieve appender from connection (note that you have to create the table 'test' beforehand).
appender, err := NewAppenderFromConn(conn, "", "test")
if err != nil {
...
}
defer appender.Close()
err = appender.AppendRow(...)
if err != nil {
...
}
// Optional, if you want to access the appended rows immediately.
err = appender.Flush()
if err != nil {
...
}
Examples
简单示例
使用 Go API 的示例如下：
package main
import (
"database/sql"
"errors"
"fmt"
"log"
_ "github.com/marcboeker/go-duckdb"
)
func main() {
db, err := sql.Open("duckdb", "")
if err != nil {
log.Fatal(err)
}
defer db.Close()
_, err = db.Exec(`CREATE TABLE people (id INTEGER, name VARCHAR)`)
if err != nil {
log.Fatal(err)
}
_, err = db.Exec(`INSERT INTO people VALUES (42, 'John')`)
if err != nil {
log.Fatal(err)
}
var (
id int
name string
)
row := db.QueryRow(`SELECT id, name FROM people`)
err = row.Scan(&id, &name)
if errors.Is(err, sql.ErrNoRows) {
log.Println("no rows")
} else if err != nil {
log.Fatal(err)
}
fmt.Printf("id: %d, name: %s\n", id, name)
}
更多示例
更多示例，请参见duckdb-go 仓库中的示例。