support

Documentation

Index

• func ParseRows(rows *sqlx.Rows) (results []contracts.Fields, err error)
• func ParseRowsToCollection(rows *sqlx.Rows) (contracts.Collection[contracts.Fields], error)
• func SetColVarType(colVar *[]any, i int, typeName string)
• func SetResultValue(result *map[string]any, index string, colVar any, typeName string)
• type BaseExecutor
  • func (base *BaseExecutor) DriverName() string
  • func (base *BaseExecutor) Exec(query string, args ...any) (result contracts.Result, exception contracts.Exception)
  • func (base *BaseExecutor) Get(dest any, query string, args ...any) (err contracts.Exception)
  • func (base *BaseExecutor) Query(query string, args ...any) (results contracts.Collection[contracts.Fields], exception contracts.Exception)
  • func (base *BaseExecutor) Select(dest any, query string, args ...any) (err contracts.Exception)
• type Executor
  • func NewExecutor(executor SqlxExecutor, dispatcher contracts.EventDispatcher, ...) Executor
• type SqlxExecutor

Functions

func ParseRows

func ParseRows(rows *sqlx.Rows) (results []contracts.Fields, err error)

func ParseRowsToCollection

func ParseRowsToCollection(rows *sqlx.Rows) (contracts.Collection[contracts.Fields], error)

func SetColVarType

func SetColVarType(colVar *[]any, i int, typeName string)

func SetResultValue

func SetResultValue(result *map[string]any, index string, colVar any, typeName string)

Types

type BaseExecutor

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

func (*BaseExecutor) DriverName

func (base *BaseExecutor) DriverName() string

func (*BaseExecutor) Exec

func (base *BaseExecutor) Exec(query string, args ...any) (result contracts.Result, exception contracts.Exception)

func (*BaseExecutor) Get

func (base *BaseExecutor) Get(dest any, query string, args ...any) (err contracts.Exception)

func (*BaseExecutor) Query

func (base *BaseExecutor) Query(query string, args ...any) (results contracts.Collection[contracts.Fields], exception contracts.Exception)

func (*BaseExecutor) Select

func (base *BaseExecutor) Select(dest any, query string, args ...any) (err contracts.Exception)

type Executor

type Executor interface {
	DriverName() string
	Query(query string, args ...any) (contracts.Collection[contracts.Fields], contracts.Exception)
	Get(dest any, query string, args ...any) (err contracts.Exception)
	Select(dest any, query string, args ...any) (err contracts.Exception)
	Exec(query string, args ...any) (contracts.Result, contracts.Exception)
}

func NewExecutor

func NewExecutor(executor SqlxExecutor, dispatcher contracts.EventDispatcher, wrapper func(sql string) string) Executor

type SqlxExecutor

type SqlxExecutor interface {
	DriverName() string
	Queryx(query string, args ...any) (*sqlx.Rows, error)
	Get(dest any, query string, args ...any) (err error)
	Select(dest any, query string, args ...any) (err error)
	Exec(query string, args ...any) (sql.Result, error)
}