rt

Documentation

Index

• Variables
• func IsRowNotFound(err error) bool
• type Limit
  • func NewLimit(limitCount int) Limit
  • func NewLimitFrom(from, limit int) Limit
  • func NewLimitOffset(limit, offset int) Limit
• type Option
• type Provider
  • func NewProvider(dialect constants.DIALECT, source string, opt *Option) (*Provider, error)
  • func (p *Provider) Executor() exec.SQLExecutor
  • func (p *Provider) GetTimeStampzFormat() string
  • func (p *Provider) GetTimezone() *time.Location
  • func (p *Provider) LogSQL() bool
  • func (p *Provider) SetConnMaxIdleTime(d time.Duration) *Provider
  • func (p *Provider) SetConnMaxLifetime(d time.Duration) *Provider
  • func (p *Provider) SetLogSQL(log bool) *Provider
  • func (p *Provider) SetMaxIdleConns(n int) *Provider
  • func (p *Provider) SetMaxOpenConns(n int) *Provider
  • func (p *Provider) Transaction(fn func() error) (err error)

Variables

var ErrRowNotFound = errors.New("row not exists")

Functions

func IsRowNotFound

func IsRowNotFound(err error) bool

Types

type Limit

type Limit interface {
	LimitSQL() string
}

func NewLimit

func NewLimit(limitCount int) Limit

NewLimit limit ${limitCount}

func NewLimitFrom

func NewLimitFrom(from, limit int) Limit

NewLimit limit ${from},${limit}

func NewLimitOffset

func NewLimitOffset(limit, offset int) Limit

NewLimitOffset limit ${limit} offset ${offset}

type Option

type Option struct {
	Conext   context.Context
	Timezone *time.Location
	Logger   logo.Logger
	LogSQL   bool
}

type Provider

type Provider struct {
	Logger logo.Logger
	// contains filtered or unexported fields
}

func NewProvider

func NewProvider(dialect constants.DIALECT, source string, opt *Option) (*Provider, error)

func (*Provider) Executor

func (p *Provider) Executor() exec.SQLExecutor

func (*Provider) GetTimeStampzFormat

func (p *Provider) GetTimeStampzFormat() string

func (*Provider) GetTimezone

func (p *Provider) GetTimezone() *time.Location

func (*Provider) LogSQL

func (p *Provider) LogSQL() bool

func (*Provider) SetConnMaxIdleTime

func (p *Provider) SetConnMaxIdleTime(d time.Duration) *Provider

func (*Provider) SetConnMaxLifetime

func (p *Provider) SetConnMaxLifetime(d time.Duration) *Provider

func (*Provider) SetLogSQL

func (p *Provider) SetLogSQL(log bool) *Provider

func (*Provider) SetMaxIdleConns

func (p *Provider) SetMaxIdleConns(n int) *Provider

func (*Provider) SetMaxOpenConns

func (p *Provider) SetMaxOpenConns(n int) *Provider

func (*Provider) Transaction

func (p *Provider) Transaction(fn func() error) (err error)