rdb

Documentation

Index

• type Err
  • func (i Err) String() string
• type Instruct
• type InstructOptionFunc
  • func WithPlaceholder(placeholder string) InstructOptionFunc
• type Meta
• type MetaOptionFunc
  • func WithDbName(dbName string) MetaOptionFunc
  • func WithIp(ip string) MetaOptionFunc
  • func WithLogger(logger log.API) MetaOptionFunc
  • func WithMaxIdleConns(MaxIdleConns int) MetaOptionFunc
  • func WithMaxLifeTime(MaxLifeTime time.Duration) MetaOptionFunc
  • func WithPassWord(PassWord string) MetaOptionFunc
  • func WithPort(port string) MetaOptionFunc
  • func WithUserName(UserName string) MetaOptionFunc
• type QueryOption
• type QueryOptionFunc
  • func WithColumn(column []string) QueryOptionFunc
  • func WithWhere(where map[string]interface{}) QueryOptionFunc
• type Rdb
  • func NewRdb(dbType Type, opts ...MetaOptionFunc) (*Rdb, error)
  • func (r *Rdb) Delete(ctx context.Context, table string, where map[string]interface{}, ...) (map[string]int64, error)
  • func (r *Rdb) Engine() *sqlx.DB
  • func (r *Rdb) Insert(ctx context.Context, table string, data map[string]interface{}, ...) (map[string]int64, error)
  • func (r *Rdb) Query(ctx context.Context, table []string, opts ...QueryOptionFunc) ([]map[string]interface{}, error)
  • func (r *Rdb) Update(ctx context.Context, table string, data map[string]interface{}, ...) (map[string]int64, error)
• type SqlOption
• type Type
  • func (i Type) String() string

Types

type Err

type Err int

const (
	UnknownErrCode Err = iota
	IllegalParams
)

func (Err) String

func (i Err) String() string

type Instruct

type Instruct struct {
	Sql  string
	Args []interface{}
}

type InstructOptionFunc

type InstructOptionFunc func(*instructOpts)

func WithPlaceholder

func WithPlaceholder(placeholder string) InstructOptionFunc

type Meta

type Meta struct {
	IP       string
	Port     string
	DbName   string
	UserName string
	PassWord string

	MaxIdleConns int
	MaxLifeTime  time.Duration

	Logger log.API
}

type MetaOptionFunc

type MetaOptionFunc func(*Meta)

func WithDbName

func WithDbName(dbName string) MetaOptionFunc

func WithIp

func WithIp(ip string) MetaOptionFunc

func WithLogger

func WithLogger(logger log.API) MetaOptionFunc

func WithMaxIdleConns

func WithMaxIdleConns(MaxIdleConns int) MetaOptionFunc

func WithMaxLifeTime

func WithMaxLifeTime(MaxLifeTime time.Duration) MetaOptionFunc

func WithPassWord

func WithPassWord(PassWord string) MetaOptionFunc

func WithPort

func WithPort(port string) MetaOptionFunc

func WithUserName

func WithUserName(UserName string) MetaOptionFunc

type QueryOption

type QueryOption interface {
	// contains filtered or unexported methods
}

type QueryOptionFunc

type QueryOptionFunc func(*SqlOption)

func WithColumn

func WithColumn(column []string) QueryOptionFunc

func WithWhere

func WithWhere(where map[string]interface{}) QueryOptionFunc

type Rdb

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

func NewRdb

func NewRdb(dbType Type, opts ...MetaOptionFunc) (*Rdb, error)

func (*Rdb) Delete

func (r *Rdb) Delete(ctx context.Context, table string, where map[string]interface{}, opts ...QueryOptionFunc) (map[string]int64, error)

func (*Rdb) Engine

func (r *Rdb) Engine() *sqlx.DB

func (*Rdb) Insert

func (r *Rdb) Insert(ctx context.Context, table string, data map[string]interface{}, opts ...QueryOptionFunc) (map[string]int64, error)

func (*Rdb) Query

func (r *Rdb) Query(ctx context.Context, table []string, opts ...QueryOptionFunc) ([]map[string]interface{}, error)

func (*Rdb) Update

func (r *Rdb) Update(ctx context.Context, table string, data map[string]interface{}, where map[string]interface{}, opts ...QueryOptionFunc) (map[string]int64, error)

type SqlOption

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

type Type

type Type int64

const (
	UnknownType Type = iota
	Mysql
	Sqlite
)

func (Type) String

func (i Type) String() string