dao

Documentation

Index

• Variables
• func InitDBConnect(option DBOptions) (*gorm.DB, error)
• func SetDefault(db *gorm.DB, opts ...gen.DOOption)
• type DBOptions
• type Query
  • func Use(db *gorm.DB, opts ...gen.DOOption) *Query
  • func (q *Query) Available() bool
  • func (q *Query) Begin(opts ...*sql.TxOptions) *QueryTx
  • func (q *Query) ReadDB() *Query
  • func (q *Query) ReplaceDB(db *gorm.DB) *Query
  • func (q *Query) Transaction(fc func(tx *Query) error, opts ...*sql.TxOptions) error
  • func (q *Query) WithContext(ctx context.Context) *queryCtx
  • func (q *Query) WriteDB() *Query
• type QueryTx
  • func (q *QueryTx) Commit() error
  • func (q *QueryTx) Rollback() error
  • func (q *QueryTx) RollbackTo(name string) error
  • func (q *QueryTx) SavePoint(name string) error
• type UsersInterface

Variables

var (
	Q     = new(Query)
	Users *users
)

Functions

func InitDBConnect

func InitDBConnect(option DBOptions) (*gorm.DB, error)

func SetDefault

func SetDefault(db *gorm.DB, opts ...gen.DOOption)

Types

type DBOptions

type DBOptions struct {
	User     string
	Password string
	Addr     string
	Name     string
	Port     int
	CharSet  string
}

type Query

type Query struct {
	Users users
	// contains filtered or unexported fields
}

func Use

func Use(db *gorm.DB, opts ...gen.DOOption) *Query

func (*Query) Available

func (q *Query) Available() bool

func (*Query) Begin

func (q *Query) Begin(opts ...*sql.TxOptions) *QueryTx

func (*Query) ReadDB

func (q *Query) ReadDB() *Query

func (*Query) ReplaceDB

func (q *Query) ReplaceDB(db *gorm.DB) *Query

func (*Query) Transaction

func (q *Query) Transaction(fc func(tx *Query) error, opts ...*sql.TxOptions) error

func (*Query) WithContext

func (q *Query) WithContext(ctx context.Context) *queryCtx

func (*Query) WriteDB

func (q *Query) WriteDB() *Query

type QueryTx

type QueryTx struct {
	*Query
	Error error
}

func (*QueryTx) Commit

func (q *QueryTx) Commit() error

func (*QueryTx) Rollback

func (q *QueryTx) Rollback() error

func (*QueryTx) RollbackTo

func (q *QueryTx) RollbackTo(name string) error

func (*QueryTx) SavePoint

func (q *QueryTx) SavePoint(name string) error

type UsersInterface

type UsersInterface interface {
	// sql(select * from @@table where userid=@userid limit 1)
	FindOneUserByID(userid string) (gen.T, error)
	// sql(select * from @@table where email=@email limit 1)
	FindOneUserByEmail(email string) (gen.T, error)
}