database

Documentation

Index

• func FileWithLineNum() string
• func GetDsn(connection string) (string, error)
• func New(writer logger.Writer, config logger.Config) logger.Interface
• func NewGorm(ctx context.Context, connection string) (contractsorm.DB, error)
• func NewGormInstance(connection string) (*gorm.DB, error)
• func NewOrm() contractsorm.Orm
• type Application
  • func (app *Application) Init() orm.Orm
• type DB
  • func (r *DB) Connection(name string) database.DB
  • func (r *DB) Query() database.Sqlx
  • func (r *DB) Transaction(ctx context.Context, txFunc func(tx *sqlx.Tx) error) error
• type Gorm
  • func (r *Gorm) Begin() (contractsorm.Transaction, error)
  • func (r *Gorm) Commit() error
  • func (r *Gorm) Count(count *int64) error
  • func (r *Gorm) Create(value interface{}) error
  • func (r *Gorm) Delete(value interface{}, conds ...interface{}) error
  • func (r *Gorm) Exec(sql string, values ...interface{}) error
  • func (r *Gorm) Find(dest interface{}, conds ...interface{}) error
  • func (r *Gorm) First(dest interface{}) error
  • func (r *Gorm) FirstOrCreate(dest interface{}, conds ...interface{}) error
  • func (r *Gorm) ForceDelete(value interface{}, conds ...interface{}) error
  • func (r *Gorm) Get(dest interface{}) error
  • func (r *Gorm) Group(name string) contractsorm.Query
  • func (r *Gorm) Having(query interface{}, args ...interface{}) contractsorm.Query
  • func (r *Gorm) Join(query string, args ...interface{}) contractsorm.Query
  • func (r *Gorm) Limit(limit int) contractsorm.Query
  • func (r *Gorm) Model(value interface{}) contractsorm.Query
  • func (r *Gorm) Offset(offset int) contractsorm.Query
  • func (r *Gorm) OrWhere(query interface{}, args ...interface{}) contractsorm.Query
  • func (r *Gorm) Order(value interface{}) contractsorm.Query
  • func (r *Gorm) Pluck(column string, dest interface{}) error
  • func (r *Gorm) Raw(sql string, values ...interface{}) contractsorm.Query
  • func (r *Gorm) Rollback() error
  • func (r *Gorm) Save(value interface{}) error
  • func (r *Gorm) Scan(dest interface{}) error
  • func (r *Gorm) Scopes(funcs ...func(contractsorm.Query) contractsorm.Query) contractsorm.Query
  • func (r *Gorm) Select(query interface{}, args ...interface{}) contractsorm.Query
  • func (r *Gorm) Table(name string, args ...interface{}) contractsorm.Query
  • func (r *Gorm) Update(column string, value interface{}) error
  • func (r *Gorm) Updates(values interface{}) error
  • func (r *Gorm) Where(query interface{}, args ...interface{}) contractsorm.Query
  • func (r *Gorm) WithTrashed() contractsorm.Query
• type Logger
  • func (l Logger) Error(ctx context.Context, msg string, data ...interface{})
  • func (l Logger) Info(ctx context.Context, msg string, data ...interface{})
  • func (l *Logger) LogMode(level logger.LogLevel) logger.Interface
  • func (l Logger) Trace(ctx context.Context, begin time.Time, fc func() (string, int64), err error)
  • func (l Logger) Warn(ctx context.Context, msg string, data ...interface{})
• type Orm
  • func (r *Orm) Connection(name string) contractsorm.Orm
  • func (r *Orm) Query() contractsorm.DB
  • func (r *Orm) Transaction(txFunc func(tx contractsorm.Transaction) error) error
  • func (r *Orm) WithContext(ctx context.Context) contractsorm.Orm
• type ServiceProvider
  • func (database *ServiceProvider) Boot()
  • func (database *ServiceProvider) Register()

Functions

func FileWithLineNum

func FileWithLineNum() string

FileWithLineNum return the file name and line number of the current file

func GetDsn

func GetDsn(connection string) (string, error)

func New

func New(writer logger.Writer, config logger.Config) logger.Interface

New initialize Logger

func NewGorm

func NewGorm(ctx context.Context, connection string) (contractsorm.DB, error)

func NewGormInstance

func NewGormInstance(connection string) (*gorm.DB, error)

func NewOrm

func NewOrm() contractsorm.Orm

Types

type Application

type Application struct {
}

func (*Application) Init

func (app *Application) Init() orm.Orm

type DB

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

func (*DB) Connection

func (r *DB) Connection(name string) database.DB

func (*DB) Query

func (r *DB) Query() database.Sqlx

func (*DB) Transaction

func (r *DB) Transaction(ctx context.Context, txFunc func(tx *sqlx.Tx) error) error

type Gorm

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

func (*Gorm) Begin

func (r *Gorm) Begin() (contractsorm.Transaction, error)

func (*Gorm) Commit

func (r *Gorm) Commit() error

func (*Gorm) Count

func (r *Gorm) Count(count *int64) error

func (*Gorm) Create

func (r *Gorm) Create(value interface{}) error

func (*Gorm) Delete

func (r *Gorm) Delete(value interface{}, conds ...interface{}) error

func (*Gorm) Exec

func (r *Gorm) Exec(sql string, values ...interface{}) error

func (*Gorm) Find

func (r *Gorm) Find(dest interface{}, conds ...interface{}) error

func (*Gorm) First

func (r *Gorm) First(dest interface{}) error

func (*Gorm) FirstOrCreate

func (r *Gorm) FirstOrCreate(dest interface{}, conds ...interface{}) error

func (*Gorm) ForceDelete

func (r *Gorm) ForceDelete(value interface{}, conds ...interface{}) error

func (*Gorm) Get

func (r *Gorm) Get(dest interface{}) error

func (*Gorm) Group

func (r *Gorm) Group(name string) contractsorm.Query

func (*Gorm) Having

func (r *Gorm) Having(query interface{}, args ...interface{}) contractsorm.Query

func (*Gorm) Join

func (r *Gorm) Join(query string, args ...interface{}) contractsorm.Query

func (*Gorm) Limit

func (r *Gorm) Limit(limit int) contractsorm.Query

func (*Gorm) Model

func (r *Gorm) Model(value interface{}) contractsorm.Query

func (*Gorm) Offset

func (r *Gorm) Offset(offset int) contractsorm.Query

func (*Gorm) OrWhere

func (r *Gorm) OrWhere(query interface{}, args ...interface{}) contractsorm.Query

func (*Gorm) Order

func (r *Gorm) Order(value interface{}) contractsorm.Query

func (*Gorm) Pluck

func (r *Gorm) Pluck(column string, dest interface{}) error

func (*Gorm) Raw

func (r *Gorm) Raw(sql string, values ...interface{}) contractsorm.Query

func (*Gorm) Rollback

func (r *Gorm) Rollback() error

func (*Gorm) Save

func (r *Gorm) Save(value interface{}) error

func (*Gorm) Scan

func (r *Gorm) Scan(dest interface{}) error

func (*Gorm) Scopes

func (r *Gorm) Scopes(funcs ...func(contractsorm.Query) contractsorm.Query) contractsorm.Query

func (*Gorm) Select

func (r *Gorm) Select(query interface{}, args ...interface{}) contractsorm.Query

func (*Gorm) Table

func (r *Gorm) Table(name string, args ...interface{}) contractsorm.Query

func (*Gorm) Update

func (r *Gorm) Update(column string, value interface{}) error

func (*Gorm) Updates

func (r *Gorm) Updates(values interface{}) error

func (*Gorm) Where

func (r *Gorm) Where(query interface{}, args ...interface{}) contractsorm.Query

func (*Gorm) WithTrashed

func (r *Gorm) WithTrashed() contractsorm.Query

type Logger

type Logger struct {
	logger.Writer
	logger.Config
	// contains filtered or unexported fields
}

func (Logger) Error

func (l Logger) Error(ctx context.Context, msg string, data ...interface{})

Error print error messages

func (Logger) Info

func (l Logger) Info(ctx context.Context, msg string, data ...interface{})

Info print info

func (*Logger) LogMode

func (l *Logger) LogMode(level logger.LogLevel) logger.Interface

LogMode log mode

func (Logger) Trace

func (l Logger) Trace(ctx context.Context, begin time.Time, fc func() (string, int64), err error)

Trace print sql message

func (Logger) Warn

func (l Logger) Warn(ctx context.Context, msg string, data ...interface{})

Warn print warn messages

type Orm

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

func (*Orm) Connection

func (r *Orm) Connection(name string) contractsorm.Orm

func (*Orm) Query

func (r *Orm) Query() contractsorm.DB

func (*Orm) Transaction

func (r *Orm) Transaction(txFunc func(tx contractsorm.Transaction) error) error

func (*Orm) WithContext

func (r *Orm) WithContext(ctx context.Context) contractsorm.Orm

type ServiceProvider

type ServiceProvider struct {
}

func (*ServiceProvider) Boot

func (database *ServiceProvider) Boot()

func (*ServiceProvider) Register

func (database *ServiceProvider) Register()