mysql

Documentation

Index

• Constants
• func FilterDeleted() func(db *gorm.DB) *gorm.DB
• func NewKidLogger(config *gLogger.Config) gLogger.Interface
• func Paginate(pageNum, pageSize int) func(db *gorm.DB) *gorm.DB
• func Search(wheres []*WhereWrapper) func(db *gorm.DB) *gorm.DB
• func SearchScope(wheres repository.Wheres) func(db *gorm.DB) *gorm.DB
• func Where(wheres []*WhereWrapper) func(db *gorm.DB) *gorm.DB
• func Wheres(wheres repository.Wheres) func(db *gorm.DB) *gorm.DB
• type AutoMigrate
• type KidLogger
  • func (log *KidLogger) Error(ctx context.Context, msg string, data ...interface{})
  • func (log *KidLogger) Info(ctx context.Context, msg string, data ...interface{})
  • func (log *KidLogger) LogMode(level gLogger.LogLevel) gLogger.Interface
  • func (log *KidLogger) Trace(ctx context.Context, begin time.Time, ...)
  • func (log *KidLogger) Warn(ctx context.Context, msg string, data ...interface{})
• type MySQL
  • func New(opts ...Option) *MySQL
  • func (conn *MySQL) Provide(ctx context.Context) interface{}
• type Option
  • func WithDb(dbName string) Option
  • func WithHost(host string) Option
  • func WithLogLevel(logLevel int) Option
  • func WithMaxIdle(maxIdle int) Option
  • func WithMaxLife(maxLife time.Duration) Option
  • func WithMaxOpen(maxOpen int) Option
  • func WithPassword(password string) Option
  • func WithPort(port int) Option
  • func WithUser(user string) Option
• type Options
• type Repository
  • func (repo *Repository) Create(val interface{}) error
  • func (repo *Repository) CreateInTx(ctx context.Context, val interface{}) error
  • func (repo *Repository) Delete(delete *repository.Delete) error
  • func (repo *Repository) DeleteInTx(ctx context.Context, delete *repository.Delete) error
  • func (repo *Repository) Find(query *repository.Query) error
  • func (repo *Repository) Get(query *repository.Query) error
  • func (repo *Repository) GetTx(ctx context.Context) (interface{}, error)
  • func (repo *Repository) Provide(context.Context) interface{}
  • func (repo *Repository) Tx(ctx context.Context, txFunc func(context.Context) error) error
  • func (repo *Repository) Update(update *repository.Update) error
  • func (repo *Repository) UpdateColumn(update *repository.Update) error
  • func (repo *Repository) UpdateColumnInTx(ctx context.Context, update *repository.Update) error
  • func (repo *Repository) UpdateInTx(ctx context.Context, update *repository.Update) error
• type WhereWrapper
  • func NewWhereWrapper(col string, condition string, val interface{}) *WhereWrapper
  • func Wrappers(conditions ...*WhereWrapper) []*WhereWrapper

Constants

const (
	ConditionTypeLte = "<="
	ConditionTypeLt  = "<"
	ConditionTypeGte = ">="
	ConditionTypeGt  = ">"
	ConditionTypeEq  = "="
	ConditionTypeIn  = "in"
)

Functions

func FilterDeleted

func FilterDeleted() func(db *gorm.DB) *gorm.DB

func NewKidLogger

func NewKidLogger(config *gLogger.Config) gLogger.Interface

func Paginate

func Paginate(pageNum, pageSize int) func(db *gorm.DB) *gorm.DB

func Search

func Search(wheres []*WhereWrapper) func(db *gorm.DB) *gorm.DB

Search 搜索 多个值 当有值

func SearchScope

func SearchScope(wheres repository.Wheres) func(db *gorm.DB) *gorm.DB

func Where

func Where(wheres []*WhereWrapper) func(db *gorm.DB) *gorm.DB

func Wheres

func Wheres(wheres repository.Wheres) func(db *gorm.DB) *gorm.DB

Types

type AutoMigrate

type AutoMigrate interface {
	Models() []interface{}
}

type KidLogger

type KidLogger struct {
	logger.Logger
	*gLogger.Config
	// contains filtered or unexported fields
}

func (*KidLogger) Error

func (log *KidLogger) Error(ctx context.Context, msg string, data ...interface{})

func (*KidLogger) Info

func (log *KidLogger) Info(ctx context.Context, msg string, data ...interface{})

func (*KidLogger) LogMode

func (log *KidLogger) LogMode(level gLogger.LogLevel) gLogger.Interface

func (*KidLogger) Trace

func (log *KidLogger) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error)

func (*KidLogger) Warn

func (log *KidLogger) Warn(ctx context.Context, msg string, data ...interface{})

type MySQL

type MySQL struct {
	*gorm.DB
	// contains filtered or unexported fields
}

func New

func New(opts ...Option) *MySQL

func (*MySQL) Provide

func (conn *MySQL) Provide(ctx context.Context) interface{}

type Option

type Option func(*Options)

func WithDb

func WithDb(dbName string) Option

func WithHost

func WithHost(host string) Option

func WithLogLevel

func WithLogLevel(logLevel int) Option

func WithMaxIdle

func WithMaxIdle(maxIdle int) Option

func WithMaxLife

func WithMaxLife(maxLife time.Duration) Option

func WithMaxOpen

func WithMaxOpen(maxOpen int) Option

func WithPassword

func WithPassword(password string) Option

func WithPort

func WithPort(port int) Option

func WithUser

func WithUser(user string) Option

type Options

type Options struct {
	User     string        // 数据库用户名
	Password string        // 数据库密码
	Host     string        // 数据库连接地址
	Port     int           // 数据库连接端口
	Db       string        // 数据库库名
	MaxIdle  int           // 最大空闲连接数
	MaxOpen  int           // 最大连接数
	MaxLife  time.Duration // 连接最大存活时间
	LogLevel int           // 日志级别
}

type Repository

type Repository struct {
	DB *MySQL `inject:""`
}

func (*Repository) Create

func (repo *Repository) Create(val interface{}) error

func (*Repository) CreateInTx

func (repo *Repository) CreateInTx(ctx context.Context, val interface{}) error

func (*Repository) Delete

func (repo *Repository) Delete(delete *repository.Delete) error

func (*Repository) DeleteInTx

func (repo *Repository) DeleteInTx(ctx context.Context, delete *repository.Delete) error

func (*Repository) Find

func (repo *Repository) Find(query *repository.Query) error

func (*Repository) Get

func (repo *Repository) Get(query *repository.Query) error

func (*Repository) GetTx

func (repo *Repository) GetTx(ctx context.Context) (interface{}, error)

func (*Repository) Provide

func (repo *Repository) Provide(context.Context) interface{}

func (*Repository) Tx

func (repo *Repository) Tx(ctx context.Context, txFunc func(context.Context) error) error

func (*Repository) Update

func (repo *Repository) Update(update *repository.Update) error

func (*Repository) UpdateColumn

func (repo *Repository) UpdateColumn(update *repository.Update) error

func (*Repository) UpdateColumnInTx

func (repo *Repository) UpdateColumnInTx(ctx context.Context, update *repository.Update) error

func (*Repository) UpdateInTx

func (repo *Repository) UpdateInTx(ctx context.Context, update *repository.Update) error

type WhereWrapper

type WhereWrapper struct {
	Column    string
	Condition string
	Value     interface{}
}

func NewWhereWrapper

func NewWhereWrapper(col string, condition string, val interface{}) *WhereWrapper

func Wrappers

func Wrappers(conditions ...*WhereWrapper) []*WhereWrapper