clickhousex

Documentation

Index

• Constants
• func Dsn(user, pass, addr, dbName, altHosts string, readTimeOut, writeTimeOut int) string
• type DB
  • func (d *DB) Close() error
  • func (d *DB) GetDb() *gorm.DB
• type Info
• type Predicate
• type QueryBuilder
  • func NewQueryBuilder(model interface{}, mustBeField ...string) *QueryBuilder
  • func (qb *QueryBuilder) BuildQuery(db *gorm.DB) *gorm.DB
  • func (qb *QueryBuilder) Count(db *gorm.DB) (int64, error)
  • func (qb *QueryBuilder) Create(db *gorm.DB, model interface{}) (rowsAffected int64, err error)
  • func (qb *QueryBuilder) Delete(db *gorm.DB) (rowsAffected int64, err error)
  • func (qb *QueryBuilder) Exist(db *gorm.DB) (bool, error)
  • func (qb *QueryBuilder) First(db *gorm.DB, ret interface{}) error
  • func (qb *QueryBuilder) Get(db *gorm.DB, ret interface{}) error
  • func (qb *QueryBuilder) GroupBy(field string) *QueryBuilder
  • func (qb *QueryBuilder) Limit(limit int) *QueryBuilder
  • func (qb *QueryBuilder) List(db *gorm.DB, ret interface{}) error
  • func (qb *QueryBuilder) Offset(offset int) *QueryBuilder
  • func (qb *QueryBuilder) OrderBy(field string, sortType pagex.SortType) *QueryBuilder
  • func (qb *QueryBuilder) Page(db *gorm.DB, val interface{}, param *pagex.Params) (*pagex.Result, error)
  • func (qb *QueryBuilder) SetModel(model interface{})
  • func (qb *QueryBuilder) Transaction(db *gorm.DB, fc func(tx *gorm.DB) error, opts ...*sql.TxOptions) (err error)
  • func (qb *QueryBuilder) Updates(db *gorm.DB, m map[string]interface{}) (rowsAffected int64, err error)
  • func (qb *QueryBuilder) Where(p Predicate, field string, value interface{}) *QueryBuilder
  • func (qb *QueryBuilder) WhereIn(field string, value interface{}) *QueryBuilder
  • func (qb *QueryBuilder) WhereNotIn(field string, value interface{}) *QueryBuilder
• type Repo
  • func Default() Repo
  • func New(cfg Info) (Repo, error)
• type User

Constants

const (
	EqualPredicate              = Predicate("=")
	NotEqualPredicate           = Predicate("<>")
	GreaterThanPredicate        = Predicate(">")
	GreaterThanOrEqualPredicate = Predicate(">=")
	SmallerThanPredicate        = Predicate("<")
	SmallerThanOrEqualPredicate = Predicate("<=")
	LikePredicate               = Predicate("LIKE")
)

const (
	CreateErrStr  = "create error"
	UpdatesErrStr = "updates error"
	DeleteErrStr  = "delete error"
)

err 常量

const (
	DescStr  = "DESC"
	AscStr   = "ASC"
	InStr    = "IN"
	NotInStr = "NOT IN"
)

查询常量

Functions

func Dsn

func Dsn(user, pass, addr, dbName, altHosts string, readTimeOut, writeTimeOut int) string

Types

type DB

type DB struct {
	Db *gorm.DB
}

func (*DB) Close

func (d *DB) Close() error

func (*DB) GetDb

func (d *DB) GetDb() *gorm.DB

type Info

type Info struct {
	Addr            string        `toml:"Addr" json:"Addr"`                       // "host:port", 必须使用clickhouse的tcp端口, 不能使用http端口
	User            string        `toml:"User" json:"User"`                       // "用户名"
	Pass            string        `toml:"Pass" json:"Pass"`                       // 密码
	Name            string        `toml:"Name" json:"Name"`                       // 数据库名
	AltHosts        string        `toml:"AltHosts" json:"AltHosts"`               // 集群地址 "host:port,host:port..."
	MaxOpenConn     int           `toml:"MaxOpenConn" json:"MaxOpenConn"`         // 最大连接数
	MaxIDleConn     int           `toml:"MaxIDleConn" json:"MaxIDleConn"`         // 最大空闲连接数
	ReadTimeOut     int           `toml:"ReadTimeOut" json:"ReadTimeOut"`         // 读超时时间
	WriteTimeOut    int           `toml:"WriteTimeOut" json:"WriteTimeOut"`       // 写超时时间
	ConnMaxLifeTime time.Duration `toml:"ConnMaxLifeTime" json:"ConnMaxLifeTime"` // 最大连接超时时间, 单位分钟
}

type Predicate

type Predicate string

Predicate is a string that acts as a condition in the where clause

type QueryBuilder

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

func NewQueryBuilder

func NewQueryBuilder(model interface{}, mustBeField ...string) *QueryBuilder

func (*QueryBuilder) BuildQuery

func (qb *QueryBuilder) BuildQuery(db *gorm.DB) *gorm.DB

func (*QueryBuilder) Count

func (qb *QueryBuilder) Count(db *gorm.DB) (int64, error)

func (*QueryBuilder) Create

func (qb *QueryBuilder) Create(db *gorm.DB, model interface{}) (rowsAffected int64, err error)

func (*QueryBuilder) Delete

func (qb *QueryBuilder) Delete(db *gorm.DB) (rowsAffected int64, err error)

func (*QueryBuilder) Exist

func (qb *QueryBuilder) Exist(db *gorm.DB) (bool, error)

func (*QueryBuilder) First

func (qb *QueryBuilder) First(db *gorm.DB, ret interface{}) error

func (*QueryBuilder) Get

func (qb *QueryBuilder) Get(db *gorm.DB, ret interface{}) error

func (*QueryBuilder) GroupBy

func (qb *QueryBuilder) GroupBy(field string) *QueryBuilder

func (*QueryBuilder) Limit

func (qb *QueryBuilder) Limit(limit int) *QueryBuilder

func (*QueryBuilder) List

func (qb *QueryBuilder) List(db *gorm.DB, ret interface{}) error

func (*QueryBuilder) Offset

func (qb *QueryBuilder) Offset(offset int) *QueryBuilder

func (*QueryBuilder) OrderBy

func (qb *QueryBuilder) OrderBy(field string, sortType pagex.SortType) *QueryBuilder

func (*QueryBuilder) Page

func (qb *QueryBuilder) Page(db *gorm.DB, val interface{}, param *pagex.Params) (*pagex.Result, error)

func (*QueryBuilder) SetModel

func (qb *QueryBuilder) SetModel(model interface{})

func (*QueryBuilder) Transaction

func (qb *QueryBuilder) Transaction(db *gorm.DB, fc func(tx *gorm.DB) error, opts ...*sql.TxOptions) (err error)

func (*QueryBuilder) Updates

func (qb *QueryBuilder) Updates(db *gorm.DB, m map[string]interface{}) (rowsAffected int64, err error)

func (*QueryBuilder) Where

func (qb *QueryBuilder) Where(p Predicate, field string, value interface{}) *QueryBuilder

func (*QueryBuilder) WhereIn

func (qb *QueryBuilder) WhereIn(field string, value interface{}) *QueryBuilder

func (*QueryBuilder) WhereNotIn

func (qb *QueryBuilder) WhereNotIn(field string, value interface{}) *QueryBuilder

type Repo

type Repo interface {
	GetDb() *gorm.DB
	Close() error
}

func Default

func Default() Repo

func New

func New(cfg Info) (Repo, error)

type User

type User struct {
	Name string
	Age  int
}