Documentation
¶
Index ¶
- func ParseRows(rows *sqlx.Rows) (results []contracts.Fields, err error)
- func ParseRowsToCollection(rows *sqlx.Rows) (contracts.Collection, error)
- func SetColVarType(colVar *[]interface{}, i int, typeName string)
- func SetResultValue(result *map[string]interface{}, index string, colVar interface{}, ...)
- type BaseExecutor
- func (this *BaseExecutor) DriverName() string
- func (this *BaseExecutor) Exec(query string, args ...interface{}) (result contracts.Result, err error)
- func (this *BaseExecutor) Get(dest interface{}, query string, args ...interface{}) (err error)
- func (this *BaseExecutor) Query(query string, args ...interface{}) (results contracts.Collection, err error)
- func (this *BaseExecutor) Select(dest interface{}, query string, args ...interface{}) (err error)
- type Executor
- type SqlxExecutor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ParseRowsToCollection ¶
func ParseRowsToCollection(rows *sqlx.Rows) (contracts.Collection, error)
func SetColVarType ¶ added in v0.1.10
func SetResultValue ¶ added in v0.1.10
Types ¶
type BaseExecutor ¶
type BaseExecutor struct {
// contains filtered or unexported fields
}
func (*BaseExecutor) DriverName ¶
func (this *BaseExecutor) DriverName() string
func (*BaseExecutor) Exec ¶
func (this *BaseExecutor) Exec(query string, args ...interface{}) (result contracts.Result, err error)
func (*BaseExecutor) Get ¶
func (this *BaseExecutor) Get(dest interface{}, query string, args ...interface{}) (err error)
func (*BaseExecutor) Query ¶
func (this *BaseExecutor) Query(query string, args ...interface{}) (results contracts.Collection, err error)
func (*BaseExecutor) Select ¶
func (this *BaseExecutor) Select(dest interface{}, query string, args ...interface{}) (err error)
type Executor ¶
type Executor interface {
DriverName() string
Query(query string, args ...interface{}) (contracts.Collection, error)
Get(dest interface{}, query string, args ...interface{}) (err error)
Select(dest interface{}, query string, args ...interface{}) (err error)
Exec(query string, args ...interface{}) (contracts.Result, error)
}
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 ...interface{}) (*sqlx.Rows, error)
Get(dest interface{}, query string, args ...interface{}) (err error)
Select(dest interface{}, query string, args ...interface{}) (err error)
Exec(query string, args ...interface{}) (sql.Result, error)
}
Source Files
Click to show internal directories.
Click to hide internal directories.