repo

Documentation

Index

• type ClickhouseRepo
  • func NewClickhouseRepo(config ClickhouseRepoConfig) (*ClickhouseRepo, error)
  • func (cr *ClickhouseRepo) BatchInsert(ctx context.Context, table string, columns []string, vals [][]interface{}, ...) error
  • func (cr *ClickhouseRepo) Exec(ctx context.Context, sql string) error
  • func (cr *ClickhouseRepo) Ping(ctx context.Context) error
• type ClickhouseRepoConfig
• type DemoRepo
  • func NewDemoRepo(config ClickhouseRepoConfig) (*DemoRepo, error)
  • func (cr *DemoRepo) BatchInsert(ctx context.Context, table string, columns []string, vals [][]interface{}, ...) error
• type Repo

Types

type ClickhouseRepo

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

func NewClickhouseRepo

func NewClickhouseRepo(config ClickhouseRepoConfig) (*ClickhouseRepo, error)

func (*ClickhouseRepo) BatchInsert

func (cr *ClickhouseRepo) BatchInsert(ctx context.Context, table string, columns []string, vals [][]interface{}, async bool) error

func (*ClickhouseRepo) Exec

func (cr *ClickhouseRepo) Exec(ctx context.Context, sql string) error

func (*ClickhouseRepo) Ping

func (cr *ClickhouseRepo) Ping(ctx context.Context) error

type ClickhouseRepoConfig

type ClickhouseRepoConfig struct {
	Host     string // 服务端主机
	Port     int    // 端口
	DB       string // 数据库
	User     string // 用户名
	Password string // 密码
}

type DemoRepo

type DemoRepo struct {
}

func NewDemoRepo

func NewDemoRepo(config ClickhouseRepoConfig) (*DemoRepo, error)

func (*DemoRepo) BatchInsert

func (cr *DemoRepo) BatchInsert(ctx context.Context, table string, columns []string, vals [][]interface{}, async bool) error

type Repo

type Repo interface {
	InsertM(ctx context.Context, columns []string, val [][]interface{}) error
}