clickhouse

Documentation

Overview

Package clickhouse 实现了 gdb.Driver，它支持 ClickHouse 数据库的操作。 md5:8c421a92a767ff72

Index

• func New() gdb.Driver
• type Driver
  • func (d *Driver) New(core *gdb.Core, node *gdb.ConfigNode) (gdb.DB, error)
  • func (d *Driver) X事务(ctx context.Context, f func(ctx context.Context, tx gdb.TX) error) error
  • func (d *Driver) X事务开启(ctx context.Context) (tx gdb.TX, err error)
  • func (d *Driver) X取表名称数组(ctx context.Context, schema ...string) (tables []string, err error)
  • func (d *Driver) X取表字段信息Map(ctx context.Context, table string, schema ...string) (fields map[string]*gdb.TableField, err error)
  • func (d *Driver) X向主节点发送心跳() error
  • func (d *Driver) X向从节点发送心跳() error
  • func (d *Driver) X底层ConvertValueForField(ctx context.Context, fieldType string, fieldValue interface{}) (interface{}, error)
  • func (d *Driver) X底层DoCommit(ctx context.Context, in gdb.DoCommitInput) (out gdb.DoCommitOutput, err error)
  • func (d *Driver) X底层DoFilter(ctx context.Context, link gdb.Link, originSql string, args []interface{}) (newSql string, newArgs []interface{}, err error)
  • func (d *Driver) X底层Open(config *gdb.ConfigNode) (db *sql.DB, err error)
  • func (d *Driver) X底层删除(ctx context.Context, link gdb.Link, table string, condition string, ...) (result sql.Result, err error)
  • func (d *Driver) X底层插入(ctx context.Context, link gdb.Link, table string, list gdb.Map数组, ...) (result sql.Result, err error)
  • func (d *Driver) X底层更新(ctx context.Context, link gdb.Link, table string, data interface{}, ...) (result sql.Result, err error)
  • func (d *Driver) X插入并取ID(ctx context.Context, table string, data interface{}, batch ...int) (int64, error)
  • func (d *Driver) X插入并替换已存在(ctx context.Context, table string, data interface{}, batch ...int) (sql.Result, error)
  • func (d *Driver) X插入并跳过已存在(ctx context.Context, table string, data interface{}, batch ...int) (sql.Result, error)

Functions

func New

func New() gdb.Driver

New 创建并返回一个实现了gdb.Driver接口的驱动器，该驱动器支持对Clickhouse的操作。 md5:e191d797c82bf046

Types

type Driver

type Driver struct {
	*gdb.Core
}

Driver 是用于 postgresql 数据库的驱动程序。 md5:4abf0752f49a3cfc

func (*Driver) New

func (d *Driver) New(core *gdb.Core, node *gdb.ConfigNode) (gdb.DB, error)

New 创建并返回一个用于ClickHouse的数据库对象。它实现了gdb.Driver接口，以便于额外的数据库驱动程序安装。 md5:79dabf2eba06bc88

func (*Driver) X事务

func (d *Driver) X事务(ctx context.Context, f func(ctx context.Context, tx gdb.TX) error) error

X事务 使用函数 `f` 包裹事务逻辑。 md5:e6842034a9a21a66

func (*Driver) X事务开启

func (d *Driver) X事务开启(ctx context.Context) (tx gdb.TX, err error)

X事务开启 方法开始并返回事务对象。 md5:8fa258c0123d6569

func (*Driver) X取表名称数组

func (d *Driver) X取表名称数组(ctx context.Context, schema ...string) (tables []string, err error)

X取表名称数组 获取并返回当前模式下的表格列表。 主要用于命令行工具链，用于自动生成模型。 md5:bce161ba95454bf5

func (*Driver) X取表字段信息Map

func (d *Driver) X取表字段信息Map(ctx context.Context, table string, schema ...string) (fields map[string]*gdb.TableField, err error)

X取表字段信息Map 获取并返回当前模式指定表的字段信息。也可以参考 DriverMysql.X取表字段信息Map。 md5:2ca710808274dcba

func (*Driver) X向主节点发送心跳

func (d *Driver) X向主节点发送心跳() error

X向主节点发送心跳 向主节点发送请求以检查身份验证或保持连接活动。 md5:47a7df55cbee8583

func (*Driver) X向从节点发送心跳

func (d *Driver) X向从节点发送心跳() error

X向从节点发送心跳 调用ping命令检查从节点的认证或者维持连接。 md5:62272b38d874eda6

func (*Driver) X底层ConvertValueForField

func (d *Driver) X底层ConvertValueForField(ctx context.Context, fieldType string, fieldValue interface{}) (interface{}, error)

X底层ConvertValueForField 将值转换为记录字段的类型。 md5:8da3e2d9dc99c3ab

func (*Driver) X底层DoCommit

func (d *Driver) X底层DoCommit(ctx context.Context, in gdb.DoCommitInput) (out gdb.DoCommitOutput, err error)

X底层DoCommit 将当前SQL和参数提交给底层SQL驱动程序。 md5:7cf9b1f6f4d9d2cb

func (*Driver) X底层DoFilter

func (d *Driver) X底层DoFilter(
	ctx context.Context, link gdb.Link, originSql string, args []interface{},
) (newSql string, newArgs []interface{}, err error)

X底层DoFilter 在将SQL提交到数据库之前进行处理。 md5:e56455a7432db765

func (*Driver) X底层Open

func (d *Driver) X底层Open(config *gdb.ConfigNode) (db *sql.DB, err error)

X底层Open 创建并返回clickhouse的底层sql.DB对象。 md5:af49366510276559

func (*Driver) X底层删除

func (d *Driver) X底层删除(ctx context.Context, link gdb.Link, table string, condition string, args ...interface{}) (result sql.Result, err error)

X底层删除 为表执行 "DELETE FROM ... " 语句。 md5:48e885baa804ab97

func (*Driver) X底层插入

func (d *Driver) X底层插入(
	ctx context.Context, link gdb.Link, table string, list gdb.Map数组, option gdb.DoInsertOption,
) (result sql.Result, err error)

X底层插入 为给定的表插入或更新数据。 md5:2a62d01f344269b8

func (*Driver) X底层更新

func (d *Driver) X底层更新(ctx context.Context, link gdb.Link, table string, data interface{}, condition string, args ...interface{}) (result sql.Result, err error)

X底层更新 对该表执行 "UPDATE ... " 语句。 md5:d99c5c0beb2de28e

func (*Driver) X插入并取ID

func (d *Driver) X插入并取ID(ctx context.Context, table string, data interface{}, batch ...int) (int64, error)

X插入并取ID 不支持其他用于修改数据部分的查询：REPLACE、MERGE、UPSERT、INSERT UPDATE。 md5:9d4693bead6866d9

func (*Driver) X插入并替换已存在

func (d *Driver) X插入并替换已存在(ctx context.Context, table string, data interface{}, batch ...int) (sql.Result, error)

不支持用于修改数据部分的其他查询：REPLACE、MERGE、UPSERT、INSERT UPDATE。 md5:d0b1de268614fdfa

func (*Driver) X插入并跳过已存在

func (d *Driver) X插入并跳过已存在(ctx context.Context, table string, data interface{}, batch ...int) (sql.Result, error)

X插入并跳过已存在 不支持用于修改数据部分的其他查询：REPLACE、MERGE、UPSERT、INSERT UPDATE。 md5:ac3efdb87c360d83