Versions in this module Expand all Collapse all v2 v2.0.1 Mar 24, 2021 v2.0.0 Mar 22, 2021 Changes in this version + var LoggingFunc = func(msg string, err error) + func NewDB(dsnConnString, sqlDriverName string) (*sqlx.DB, error) + func ValidateConn(conn *sqlx.DB, maxConnAttempts int) error + type FakeConn struct + Error error + FakeFx *FakeFx + FakeStmt *FakeStmt + IsClosed bool + func (fc *FakeConn) Begin() (driver.Tx, error) + func (fc *FakeConn) Close() error + func (fc *FakeConn) Prepare(query string) (driver.Stmt, error) + type FakeFx struct + IsBegun bool + IsCommit bool + IsRollback bool + func (fx *FakeFx) Commit() error + func (fx *FakeFx) Rollback() error + type FakeSQLDriver struct + Conn *FakeConn + ConnStr string + ErrFuncProvider func() error + func NewFakeSQLDriver() *FakeSQLDriver + func (fsq *FakeSQLDriver) Open(connStr string) (driver.Conn, error) + type FakeStmt struct + Args []driver.Value + NumInputCount int + RowsAffected int64 + RowsSlice *RowsData + func (fs *FakeStmt) Close() error + func (fs *FakeStmt) Exec(args []driver.Value) (driver.Result, error) + func (fs *FakeStmt) NumInput() int + func (fs *FakeStmt) Query(args []driver.Value) (driver.Rows, error) + type Gateway struct + func BuildDBGateway(driverName, dsnConnString string, maxConnAttempts int) (*Gateway, error) + func BuildMysqlDBGateway(dsnConnString string, maxConnAttempts int) (*Gateway, error) + func NewDBGateway(conn *sqlx.DB) *Gateway + func (dg *Gateway) Begin() (*baseSql.Tx, error) + func (dg *Gateway) Destroy() error + func (dg *Gateway) Exec(query string, args ...interface{}) (baseSql.Result, error) + func (dg *Gateway) FindByQuery(target interface{}, sql string, args []interface{}) error + func (dg *Gateway) FindByQueryFlex(target interface{}, sql string, args ...interface{}) error + func (dg *Gateway) FindOneStructByID(target interface{}, tableName string, id int64) (bool, error) + func (dg *Gateway) QueryWithCallback(resultCallback func(row map[string]interface{}, errCallback error), sql string, ...) error + func (dg *Gateway) ScanScalarByQuery(target interface{}, sql string, args ...interface{}) (found bool, err error) + func (dg *Gateway) ScanStructByQuery(target interface{}, q string, args ...interface{}) (bool, error) + func (dg *Gateway) TruncateTable(tableName string) (baseSql.Result, error) + type RowsData struct + Cols []string + CurRow int + Data [][]interface{} + IsClosed bool + func (fr *RowsData) Close() error + func (fr *RowsData) Columns() []string + func (fr *RowsData) Next(dest []driver.Value) error