Golang 请求 ClickHouse 数据库示例代码
以下是一个使用 Golang 请求 ClickHouse 数据库的示例代码:
package main
import (
"database/sql"
"fmt"
"log"
_ "github.com/ClickHouse/clickhouse-go"
)
func main() {
// 连接到 ClickHouse 数据库
db, err := sql.Open("clickhouse", "tcp://localhost:9000?username=default&password=123456")
if err != nil {
log.Fatal(err)
}
defer db.Close()
// 创建表
_, err = db.Exec("CREATE TABLE IF NOT EXISTS test (id Int32, name String) ENGINE = Memory")
if err != nil {
log.Fatal(err)
}
// 插入数据
_, err = db.Exec("INSERT INTO test (id, name) VALUES (?, ?)", 1, "John Doe")
if err != nil {
log.Fatal(err)
}
// 查询数据
rows, err := db.Query("SELECT id, name FROM test")
if err != nil {
log.Fatal(err)
}
defer rows.Close()
// 遍历结果集
for rows.Next() {
var id int
var name string
err = rows.Scan(&id, &name)
if err != nil {
log.Fatal(err)
}
fmt.Println(id, name)
}
if err = rows.Err(); err != nil {
log.Fatal(err)
}
}
请确保先安装并导入 github.com/ClickHouse/clickhouse-go 包。在代码中,我们首先建立与 ClickHouse 数据库的连接并创建一个名为 test 的表。然后,我们插入一条数据并查询表中的数据。最后,我们遍历查询结果并打印出每一行的数据。
注意:请根据实际情况修改连接字符串中的主机、端口、用户名和密码。
原文地址: https://www.cveoy.top/t/topic/pgIR 著作权归作者所有。请勿转载和采集!