以下是一个示例的 Golang 代码,用于初始化分布式 ClickHouse:
package main
import (
"fmt"
"github.com/kshvakov/clickhouse"
)
func main() {
// 配置连接信息
connect, err := clickhouse.OpenDirect("tcp://192.168.1.100:9000?username=default&password=123456")
if err != nil {
fmt.Println(err)
return
}
defer connect.Close()
// 创建分布式表
_, err = connect.Exec(`
CREATE TABLE default.test_table ON CLUSTER my_cluster (
id Int32,
name String
) ENGINE = Distributed(my_cluster, default, test_table, rand())
`)
if err != nil {
fmt.Println(err)
return
}
fmt.Println("分布式表创建成功!")
}
其中,clickhouse
是 Golang 中的 ClickHouse 连接器库,在使用前需要安装。这里使用了 OpenDirect()
方法直接连接 ClickHouse 数据库,并在该连接上执行 SQL 命令来创建分布式表。
请注意,这只是一个简单示例,实际的代码可能需要更多的错误处理和参数配置。