clickhouse

func (*Driver) Begin ¶

func (d *Driver) Begin(ctx context.Context) (tx gdb.TX, err error)

func (*Driver) ConvertDataForRecord ¶

func (d *Driver) ConvertDataForRecord(ctx context.Context, value interface{}) (map[string]interface{}, error)

ConvertDataForRecord converting for any data that will be inserted into table/collection as a record.

func (*Driver) DoCommit ¶

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

DoCommit commits current sql and arguments to underlying sql driver.

func (*Driver) DoDelete ¶

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

func (*Driver) DoFilter ¶

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

DoFilter handles the sql before posts it to database.

func (*Driver) DoInsert ¶

func (d *Driver) DoInsert(
	ctx context.Context, link gdb.Link, table string, list gdb.List, option gdb.DoInsertOption,
) (result sql.Result, err error)

func (*Driver) DoUpdate ¶

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

func (*Driver) InsertAndGetId ¶

func (d *Driver) InsertAndGetId(ctx context.Context, table string, data interface{}, batch ...int) (int64, error)

InsertAndGetId Other queries for modifying data parts are not supported: REPLACE, MERGE, UPSERT, INSERT UPDATE.

func (*Driver) InsertIgnore ¶

func (d *Driver) InsertIgnore(ctx context.Context, table string, data interface{}, batch ...int) (sql.Result, error)

InsertIgnore Other queries for modifying data parts are not supported: REPLACE, MERGE, UPSERT, INSERT UPDATE.

func (*Driver) New ¶

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

New creates and returns a database object for clickhouse. It implements the interface of gdb.Driver for extra database driver installation.

func (*Driver) Open ¶

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

Open creates and returns an underlying sql.DB object for clickhouse.

func (*Driver) PingMaster ¶

func (d *Driver) PingMaster() error

PingMaster pings the master node to check authentication or keeps the connection alive.

func (*Driver) PingSlave ¶

func (d *Driver) PingSlave() error

PingSlave pings the slave node to check authentication or keeps the connection alive.

func (*Driver) Replace ¶

func (d *Driver) Replace(ctx context.Context, table string, data interface{}, batch ...int) (sql.Result, error)

Replace Other queries for modifying data parts are not supported: REPLACE, MERGE, UPSERT, INSERT UPDATE.

func (*Driver) TableFields ¶

func (d *Driver) TableFields(
	ctx context.Context, table string, schema ...string,
) (fields map[string]*gdb.TableField, err error)

TableFields retrieves and returns the fields' information of specified table of current schema. Also see DriverMysql.TableFields.

func (*Driver) Tables ¶

func (d *Driver) Tables(ctx context.Context, schema ...string) (tables []string, err error)

Tables retrieves and returns the tables of current schema. It's mainly used in cli tool chain for automatically generating the models.

func (*Driver) Transaction ¶

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