ckgroup

package

v0.0.5 Latest Latest Go to latest Published: Sep 28, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ClickHouseClient struct {
	// contains filtered or unexported fields
}

ClickHouseClient ClickHouse客户端

var CKCONN ClickHouseClient

func NewClickHouseClient(config Config) (*ClickHouseClient, error)

NewClickHouseClient 创建新的ClickHouse客户端

func (c *ClickHouseClient) BatchInsert(tableName string, data interface{}) error

BatchInsert 批量插入数据，支持nested结构

func (c *ClickHouseClient) Close() error

Close 关闭连接

func (c *ClickHouseClient) Count(tableName string, where string, args ...interface{}) (int64, error)

Count 获取表记录数

func (c *ClickHouseClient) CreateDistributedTable(distDB, localTable, desc string, cols []Column) error

func (c *ClickHouseClient) CreateTable(database, table, order, desc string, cols []Column) error

func (c *ClickHouseClient) Exec(query string, args ...interface{}) error

Exec 执行SQL语句

func (c *ClickHouseClient) Query(query string, args ...interface{}) (*sql.Rows, error)

Query 执行查询

func (c *ClickHouseClient) QueryRow(query string, args ...interface{}) *sql.Row

QueryRow 执行单行查询

func (c *ClickHouseClient) QueryToStruct(dest interface{}, query string, args ...interface{}) error

QueryToStruct 查询并映射到结构体切片

type Column struct {
	Name string
	Type string
}

type Config struct {
	Hosts     string
	Database  string
	Username  string
	Password  string
	BatchSize int
	Debug     bool
}

Config 配置结构