sqlxx

May 6, 2024

Changes in this version

+ const TagDS

+ const TagReadonly

+ const TagSQL

+ const TagTx

+ const TxDefault

+ const TxLinearizable

+ const TxReadCommitted

+ const TxReadUncommitted

+ const TxRepeatableRead

+ const TxSerializable

+ const TxSnapshot

+ const TxWriteCommitted

+ var ClearTemplateFS = StdFactory.ClearTemplateFS

+ var CreateAndSet = StdFactory.CreateAndSet

+ var DBType = reflect.TypeOf((*DB)(nil))

+ var DefaultDriver = dialect.MySQL

+ var DefaultName = "Default"

+ var Drivers = map[string]*dialect.Driver

+ var ErrNilDB = errors.New("DB is nil")

+ var ErrNilDriver = errors.New("driver is nil")

+ var ExecFuncType = reflect.TypeOf(ExecFunc(nil))

+ var Get = StdFactory.Get

+ var ManagerType = reflect.TypeOf((*Factory)(nil))

+ var MustGet = StdFactory.MustGet

+ var MySQL = dialect.MySQL

+ var NameFunc = utils.LowerCase

+ var NamedExecFuncType = reflect.TypeOf(NamedExecFunc(nil))

+ var OpenDB = StdFactory.Open

+ var SQLServer = dialect.SQLServer

+ var Set = StdFactory.Set

+ var SetConstructor = StdFactory.SetConstructor

+ var SetTemplateFS = StdFactory.SetTemplateFS

+ var Shutdown = StdFactory.Shutdown

+ var StdFactory = NewFactory(DefaultName)

+ var TxFuncType = reflect.TypeOf(TxFunc(nil))

+ func Boost(dest interface{}, ds string) error

+ func BoostMapper(dest interface{}, factory *Factory, ds string) error

+ func EvalAfterHook(entity any) error

+ func EvalAfterHooks[T any](entities ...T) error

+ func EvalBeforeHook(entity any) error

+ func EvalBeforeHooks[T any](entities ...T) error

+ func GetWith(p reflect.Type, db *DB, templateList []string, args []any) (any, error)

+ func MakeFuncMap(driver *dialect.Driver) template.FuncMap

+ func NamedGetWith(p reflect.Type, db *DB, templateList []string, arg any) (any, error)

+ func NamedSelectWith(p reflect.Type, db *DB, templateList []string, arg any) (any, error)

+ func NewMapperWith[T any](factory *Factory, dataSource string) (*T, error)

+ func NewMapper[T any](dataSource string) (*T, error)

+ func SelectWith(p reflect.Type, db *DB, templateList []string, args []any) (any, error)

+ func SetLogger(l Logger)

+ type AfterDelete interface

+ AfterDelete func() error

+ type AfterInsert interface

+ AfterInsert func() error

+ type AfterUpdate interface

+ AfterUpdate func() error

+ type BaseMapper struct

+ CreateTx TxFunc

+ DeleteTx TxFunc

+ EraseTx TxFunc

+ PartialUpdateTx TxFunc

+ UpdateByIdTx TxFunc

+ UpdateTx TxFunc

+ func (b *BaseMapper[T]) AutoPartialUpdate(useTenantId bool, entities ...T) error

+ func (b *BaseMapper[T]) Column(name string) *Column

+ func (b *BaseMapper[T]) CountBy(where map[string]any, fns ...expr.FilterFn) (total int64, err error)

+ func (b *BaseMapper[T]) CountByExample(entity T, filters ...expr.FilterFn) (total int64, err error)

+ func (b *BaseMapper[T]) Create(entities ...T) error

+ func (b *BaseMapper[T]) DeleteBy(builders ...expr.DeleteExprFn) (rowAffected int64, err error)

+ func (b *BaseMapper[T]) DeleteByExample(example T, builders ...expr.DeleteExprFn) (effect int64, err error)

+ func (b *BaseMapper[T]) DeleteById(tenantId any, ids ...any) error

+ func (b *BaseMapper[T]) EraseById(tenantId any, ids ...any) error

+ func (b *BaseMapper[T]) Insert(entities ...T) error

+ func (b *BaseMapper[T]) InsertExpr(builders ...expr.InsertFilterFn) error

+ func (b *BaseMapper[T]) ListById(tenantId any, ids ...any) (entities []T, err error)

+ func (b *BaseMapper[T]) Meta() *Entity

+ func (b *BaseMapper[T]) PartialUpdate(useTenantId bool, specifiedField []string, entities ...T) error

+ func (b *BaseMapper[T]) Select(builders ...expr.FilterFn) (result []T, total int64, err error)

+ func (b *BaseMapper[T]) SelectByExample(entity T, builders ...expr.FilterFn) ([]T, int64, error)

+ func (b *BaseMapper[T]) Update(useTenantId bool, entities ...T) error

+ func (b *BaseMapper[T]) UpdateBy(builders ...expr.FilterFn) (effect int64, err error)

+ func (b *BaseMapper[T]) UpdateByExample(newValue T, example T, builders ...expr.FilterFn) (effect int64, err error)

+ type BeforeDelete interface

+ BeforeDelete func() error

+ type BeforeInsert interface

+ BeforeInsert func() error

+ type BeforeUpdate interface

+ BeforeUpdate func() error

+ type DB struct

+ func Open(driverName, datasource string) (*DB, error)

+ func OpenWith(f *Factory, driver *dialect.Driver, datasource string) (*DB, error)

+ func (d *DB) Batch(ctx context.Context, opts *sql.TxOptions, fn func(tx *Tx) error) (err error)

+ func (d *DB) Batchxx(ctx context.Context, opts *sql.TxOptions, tpl string, fn func(tx *Tx) error) (err error)

+ func (d *DB) ExecExpr(exp expr.Expr) (sql.Result, error)

+ func (d *DB) Execxx(sqlOrTpl string, args ...interface{}) (sql.Result, error)

+ func (d *DB) GetExpr(dest interface{}, exp expr.Expr, filters ...expr.FilterFn) error

+ func (d *DB) NamedExecxx(sqlOrTpl string, arg interface{}) (sql.Result, error)

+ func (d *DB) NamedGet(dest interface{}, query string, arg interface{}) error

+ func (d *DB) NamedQueryxx(sqlOrTpl string, arg interface{}) (*sqlx.Rows, error)

+ func (d *DB) NamedSelect(dest interface{}, sql string, arg any) (err error)

+ func (d *DB) NamedSelectxx(dest interface{}, sqlOrTpl string, args interface{}) (err error)

+ func (d *DB) ParseSQL(sqlOrTpl string, args any) (query string, err error)

+ func (d *DB) ParseTemplate(name string, tpl string) (*template.Template, error)

+ func (d *DB) ParseTemplateFS(f fs.FS, patterns ...string) error

+ func (d *DB) PrepareNamedxx(tplName string, args any) (*sqlx.NamedStmt, error)

+ func (d *DB) Preparexx(sqlOrTpl string, args any) (*sqlx.Stmt, error)

+ func (d *DB) RunPrepareNamed(sqlOrTpl string, arg any, fn func(*sqlx.NamedStmt) error) (err error)

+ func (d *DB) RunPrepared(sqlOrTpl string, arg any, fn func(*sqlx.Stmt) error) (err error)

+ func (d *DB) SelectExpr(dest interface{}, exp expr.Expr) error

+ func (d *DB) Selectxx(dest interface{}, sqlOrTpl string, args ...any) error

+ func (d *DB) SetManager(m *Factory)

+ func (d *DB) SetTemplate(tpl *template.Template)

+ func (d *DB) Template() *template.Template

+ type DBConstructor func() (*DB, error)

+ type ExecFunc func(args ...any) (sql.Result, error)

+ func NewExecFuncWith(db *DB, tpl string) ExecFunc

+ type Factory struct

+ func NewFactory(name string) *Factory

+ func NewFactoryWithDriver(name string, driver *dialect.Driver) *Factory

+ func (m *Factory) BoostMapper(dest any, dataSource string) error

+ func (m *Factory) ClearTemplateFS()

+ func (m *Factory) CreateAndSet(name string, fn DBConstructor) (*DB, error)

+ func (m *Factory) Get(name string) (*DB, error)

+ func (m *Factory) MustGet(name string) *DB

+ func (m *Factory) Open(name, driverName, dsn string) (*DB, error)

+ func (m *Factory) Set(name string, db *DB)

+ func (m *Factory) SetConstructor(name string, loadFunc DBConstructor)

+ func (m *Factory) SetTemplateFS(f fs.FS, patterns ...string)

+ func (m *Factory) Shutdown() error

+ func (m *Factory) String() string

+ type GetFunc func(args ...any) (T, error)

+ type Logger interface

+ Debug func(...any)

+ Debugf func(string, ...any)

+ Error func(...any)

+ Errorf func(string, ...any)

+ Info func(...any)

+ Infof func(string, ...any)

+ Trace func(...any)

+ Tracef func(string, ...any)

+ Warn func(...any)

+ Warnf func(string, ...any)

+ type NamedExecFunc func(arg any) (sql.Result, error)

+ func NewNamedExecFuncWith(db *DB, tpl string) NamedExecFunc

+ type NamedGetFunc func(arg any) (T, error)

+ func NewNamedGetFuncWith[T any](m *Factory, db, tpl string) NamedGetFunc[T]

+ type NamedSelectFunc func(arg any) ([]T, error)

+ func NewNamedSelectFuncWith[T any](manager *Factory, db, tpl string) NamedSelectFunc[T]

+ func NewNamedSelectFunc[T any](db, tpl string) NamedSelectFunc[T]

+ type SelectFunc func(args ...any) ([]T, error)

+ func NewSelectFuncWith[T any](m *Factory, db, tpl string) SelectFunc[T]

+ func NewSelectFunc[T any](db, tpl string) SelectFunc[T]

+ type TplFS struct

+ FS fs.FS

+ Patterns []string

+ type Tx struct

+ func NewTxWith(tx *sqlx.Tx, d *DB, tpl string) *Tx

+ func (t *Tx) ExecCurrent(args ...interface{}) (sql.Result, error)

+ func (t *Tx) ExecExpr(exp expr.Expr) (sql.Result, error)

+ func (t *Tx) Execxx(sqlOrTpl string, args ...interface{}) (sql.Result, error)

+ func (t *Tx) GetExpr(dest interface{}, exp expr.Expr) error

+ func (t *Tx) Getxx(dest any, tpl string, args ...any) error

+ func (t *Tx) NamedExecCurrent(arg interface{}) (sql.Result, error)

+ func (t *Tx) NamedExecxx(sqlOrTpl string, arg interface{}) (sql.Result, error)

+ func (t *Tx) NamedGet(dest interface{}, query string, arg interface{}) error

+ func (t *Tx) NamedSelect(dest interface{}, sql string, arg any) (err error)

+ func (t *Tx) Parse(tplName string, args any) (string, error)

+ func (t *Tx) ParseAndPrepare(sqlOrTpl string, arg any) (*sqlx.Stmt, error)

+ func (t *Tx) ParseAndPrepareNamed(tplName string, arg any) (*sqlx.NamedStmt, error)

+ func (t *Tx) PrepareNamed(query string) (*sqlx.NamedStmt, error)

+ func (t *Tx) Preparex(query string) (*sqlx.Stmt, error)

+ func (t *Tx) RunCurrentPrepareNamed(arg any, fn func(*sqlx.NamedStmt) error) (err error)

+ func (t *Tx) RunCurrentPrepared(arg any, fn func(*sqlx.Stmt) error) (err error)

+ func (t *Tx) RunPrepareNamedxx(sqlOrTpl string, arg any, fn func(*sqlx.NamedStmt) error) (err error)

+ func (t *Tx) RunPreparedxx(sqlOrTpl string, arg any, fn func(*sqlx.Stmt) error) (err error)

+ func (t *Tx) SelectExpr(dest interface{}, exp expr.Expr) error

+ func (t *Tx) Tpl() string

+ type TxFunc func(func(*Tx) error) error

+ func NewTxFuncWith(db *DB, tpl string, opts *sql.TxOptions) TxFunc