db

Documentation

Index

• func Create() *srDb
• func GetUpdateHelper() abs.DbGetUpdateHelper
• func NewUpdateHelper() abs.DbUpdateHelper
• type Repo
  • func (slf *Repo[T]) Count(logc *clog.Instance, whereQuery, endQuery string, wherePars ...interface{}) (int, error)
  • func (slf *Repo[T]) Delete(logc *clog.Instance, whereQuery string, wherePars ...interface{}) error
  • func (slf *Repo[T]) Execute(logc *clog.Instance, sqlQuery string, sqlPars ...interface{}) error
  • func (slf *Repo[T]) GenerateParamSigns(columnNames string) (paramSign string)
  • func (slf *Repo[T]) GetData(logc *clog.Instance, whereQuery string, endQuery string, ...) (*T, error)
  • func (slf *Repo[T]) GetDatas(logc *clog.Instance, whereQuery string, endQuery string, ...) ([]T, error)
  • func (slf *Repo[T]) Insert(logc *clog.Instance, sqlPars ...interface{}) error
  • func (slf *Repo[T]) InsertRID(logc *clog.Instance, sqlPars ...interface{}) (*int64, error)
  • func (slf *Repo[T]) OnUnsafe(unsafe *model.DbUnsafeSelectError)
  • func (slf *Repo[T]) RawCount(logc *clog.Instance, query string, pars ...interface{}) (int, error)
  • func (slf *Repo[T]) Select(logc *clog.Instance, query string, args ...interface{}) ([]T, error)
  • func (slf *Repo[T]) SelectFirst(logc *clog.Instance, query string, args ...interface{}) (*T, error)
  • func (slf *Repo[T]) SetColumnNames(names string)
  • func (slf *Repo[T]) SetInsertColumnNames(names string)
  • func (slf *Repo[T]) TxCount(logc *clog.Instance, tx abs.DbTx, whereQuery, endQuery string, ...) (int, error)
  • func (slf *Repo[T]) TxDelete(logc *clog.Instance, tx abs.DbTx, whereQuery string, wherePars ...interface{}) error
  • func (slf *Repo[T]) TxExecute(logc *clog.Instance, tx abs.DbTx, sqlQuery string, sqlPars ...interface{}) error
  • func (slf *Repo[T]) TxGetData(logc *clog.Instance, tx abs.DbTx, whereQuery string, endQuery string, ...) (*T, error)
  • func (slf *Repo[T]) TxGetDatas(logc *clog.Instance, tx abs.DbTx, whereQuery string, endQuery string, ...) ([]T, error)
  • func (slf *Repo[T]) TxInsert(logc *clog.Instance, tx abs.DbTx, sqlPars ...interface{}) error
  • func (slf *Repo[T]) TxInsertRID(logc *clog.Instance, tx abs.DbTx, sqlPars ...interface{}) (*int64, error)
  • func (slf *Repo[T]) TxRawCount(logc *clog.Instance, tx abs.DbTx, query string, pars ...interface{}) (int, error)
  • func (slf *Repo[T]) TxSelect(logc *clog.Instance, tx abs.DbTx, query string, args ...interface{}) ([]T, error)
  • func (slf *Repo[T]) TxSelectFirst(logc *clog.Instance, tx abs.DbTx, query string, args ...interface{}) (*T, error)
  • func (slf *Repo[T]) TxUpdate(logc *clog.Instance, tx abs.DbTx, keyVals map[string]interface{}, ...) error
  • func (slf *Repo[T]) Update(logc *clog.Instance, keyVals map[string]interface{}, whereQuery string, ...) error
• type View
  • func (slf *View) New(db abs.DbInstance, printUnsafeErr bool) *View
  • func (slf *View) Select(out interface{}, sqlQuery string, sqlPars ...interface{}) error

Functions

func Create

func Create() *srDb

func GetUpdateHelper

func GetUpdateHelper() abs.DbGetUpdateHelper

func NewUpdateHelper

func NewUpdateHelper() abs.DbUpdateHelper

Types

type Repo

type Repo[T any] struct {
	DbInstance        abs.DbInstance
	TableName         string
	ColumnNames       string
	InsertColumnNames string // if empty then use columnNames
	ParamSigns        string
	InsertParamSign   string // if empty then use paramSigns
	PrintUnsafeErr    bool
}

func (*Repo[T]) Count

func (slf *Repo[T]) Count(logc *clog.Instance, whereQuery, endQuery string, wherePars ...interface{}) (int, error)

func (*Repo[T]) Delete

func (slf *Repo[T]) Delete(logc *clog.Instance, whereQuery string, wherePars ...interface{}) error

func (*Repo[T]) Execute

func (slf *Repo[T]) Execute(logc *clog.Instance, sqlQuery string, sqlPars ...interface{}) error

func (*Repo[T]) GenerateParamSigns

func (slf *Repo[T]) GenerateParamSigns(columnNames string) (paramSign string)

func (*Repo[T]) GetData

func (slf *Repo[T]) GetData(logc *clog.Instance, whereQuery string, endQuery string, wherePars ...interface{}) (*T, error)

func (*Repo[T]) GetDatas

func (slf *Repo[T]) GetDatas(logc *clog.Instance, whereQuery string, endQuery string, wherePars ...interface{}) ([]T, error)

func (*Repo[T]) Insert

func (slf *Repo[T]) Insert(logc *clog.Instance, sqlPars ...interface{}) error

func (*Repo[T]) InsertRID

func (slf *Repo[T]) InsertRID(logc *clog.Instance, sqlPars ...interface{}) (*int64, error)

func (*Repo[T]) OnUnsafe

func (slf *Repo[T]) OnUnsafe(unsafe *model.DbUnsafeSelectError)

func (*Repo[T]) RawCount

func (slf *Repo[T]) RawCount(logc *clog.Instance, query string, pars ...interface{}) (int, error)

func (*Repo[T]) Select

func (slf *Repo[T]) Select(logc *clog.Instance, query string, args ...interface{}) ([]T, error)

func (*Repo[T]) SelectFirst

func (slf *Repo[T]) SelectFirst(logc *clog.Instance, query string, args ...interface{}) (*T, error)

func (*Repo[T]) SetColumnNames

func (slf *Repo[T]) SetColumnNames(names string)

func (*Repo[T]) SetInsertColumnNames

func (slf *Repo[T]) SetInsertColumnNames(names string)

func (*Repo[T]) TxCount

func (slf *Repo[T]) TxCount(logc *clog.Instance, tx abs.DbTx, whereQuery, endQuery string, wherePars ...interface{}) (int, error)

func (*Repo[T]) TxDelete

func (slf *Repo[T]) TxDelete(logc *clog.Instance, tx abs.DbTx, whereQuery string, wherePars ...interface{}) error

func (*Repo[T]) TxExecute

func (slf *Repo[T]) TxExecute(logc *clog.Instance, tx abs.DbTx, sqlQuery string, sqlPars ...interface{}) error

func (*Repo[T]) TxGetData

func (slf *Repo[T]) TxGetData(logc *clog.Instance, tx abs.DbTx, whereQuery string, endQuery string, wherePars ...interface{}) (*T, error)

func (*Repo[T]) TxGetDatas

func (slf *Repo[T]) TxGetDatas(logc *clog.Instance, tx abs.DbTx, whereQuery string, endQuery string, wherePars ...interface{}) ([]T, error)

func (*Repo[T]) TxInsert

func (slf *Repo[T]) TxInsert(logc *clog.Instance, tx abs.DbTx, sqlPars ...interface{}) error

func (*Repo[T]) TxInsertRID

func (slf *Repo[T]) TxInsertRID(logc *clog.Instance, tx abs.DbTx, sqlPars ...interface{}) (*int64, error)

func (*Repo[T]) TxRawCount

func (slf *Repo[T]) TxRawCount(logc *clog.Instance, tx abs.DbTx, query string, pars ...interface{}) (int, error)

func (*Repo[T]) TxSelect

func (slf *Repo[T]) TxSelect(logc *clog.Instance, tx abs.DbTx, query string, args ...interface{}) ([]T, error)

func (*Repo[T]) TxSelectFirst

func (slf *Repo[T]) TxSelectFirst(logc *clog.Instance, tx abs.DbTx, query string, args ...interface{}) (*T, error)

func (*Repo[T]) TxUpdate

func (slf *Repo[T]) TxUpdate(logc *clog.Instance, tx abs.DbTx, keyVals map[string]interface{}, whereQuery string, wherePars ...interface{}) error

func (*Repo[T]) Update

func (slf *Repo[T]) Update(logc *clog.Instance, keyVals map[string]interface{}, whereQuery string, wherePars ...interface{}) error

type View

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

func (*View) New

func (slf *View) New(db abs.DbInstance, printUnsafeErr bool) *View

func (*View) Select

func (slf *View) Select(out interface{}, sqlQuery string, sqlPars ...interface{}) error