以下是一个使用 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 的表。然后,我们插入一条数据并查询表中的数据。最后,我们遍历查询结果并打印出每一行的数据。

注意:请根据实际情况修改连接字符串中的主机、端口、用户名和密码。

Golang 请求 ClickHouse 数据库示例代码

原文地址: https://www.cveoy.top/t/topic/pgIR 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录