sqlapi

Oct 3, 2020

Changes in this version

type Logger

+ func NewStdLogger(lgr StdLog) Logger

type StdLog

+ Println func(v ...interface{})

Oct 2, 2020

Changes in this version

type Execer

+ Exec func(ctx context.Context, sql string, arguments ...interface{}) (int64, error)

+ Insert func(ctx context.Context, pk, query string, arguments ...interface{}) (int64, error)

type Getter

+ Query func(ctx context.Context, sql string, arguments ...interface{}) (SqlRows, error)

+ QueryRow func(ctx context.Context, query string, arguments ...interface{}) SqlRow

type SqlDB

+ func Connect(ctx context.Context, driver, dsn string, di dialect.Dialect, lgr Logger, ...) (SqlDB, error)

+ func ConnectEnv(ctx context.Context, lgr pgx.Logger, logLevel pgx.LogLevel, tries int) (SqlDB, error)

+ func MustConnect(ctx context.Context, driverName, dataSourceName string, di dialect.Dialect, ...) SqlDB

+ func MustConnectEnv(ctx context.Context, lgr pgx.Logger, logLevel pgx.LogLevel, tries int) SqlDB

+ Ping func(ctx context.Context) error

Sep 23, 2020

Changes in this version

type SqlDB

+ UserItem func() interface{}

+ With func(wrapped interface{}) SqlDB

Sep 23, 2020

Changes in this version

+ type CoreTable struct

+ Ex Execer

+ Nm TableName

+ func (tbl CoreTable) Ctx() context.Context

+ func (tbl CoreTable) DB() SqlDB

+ func (tbl CoreTable) Dialect() dialect.Dialect

+ func (tbl CoreTable) Execer() Execer

+ func (tbl CoreTable) IsTx() bool

+ func (tbl CoreTable) Logger() Logger

+ func (tbl CoreTable) Name() TableName

+ func (tbl CoreTable) Tx() SqlTx

Sep 22, 2020

Changes in this version

+ func ListTables(ex Execer, re *regexp.Regexp) (collection.StringList, error)

type Execer

+ Dialect func() dialect.Dialect

+ Logger func() Logger

type Logger

+ SetOutput func(out io.Writer)

Jul 5, 2019

Changes in this version

type SqlDB

+ SingleConn func(ctx context.Context, fn func(conn *sql.Conn) error) error

Jul 4, 2019

Changes in this version

+ type DBStats = sql.DBStats

+ type Getter interface

+ QueryContext func(ctx context.Context, sql string, arguments ...interface{}) (SqlRows, error)

+ QueryRowContext func(ctx context.Context, query string, arguments ...interface{}) SqlRow

Jul 2, 2019

Changes in this version

type SqlDB

+ Close func() error

+ Transact func(ctx context.Context, txOptions *sql.TxOptions, fn func(SqlTx) error) error

Jul 1, 2019

Changes in this version

type Logger

+ func NewLogger(lgr StdLog) Logger

+ Log func(format string, v ...interface{})

+ LogError func(err error) error

+ LogIfError func(err error) error

+ LogQuery func(query string, args ...interface{})

+ LogT func(msg string, startTime *time.Time, data ...interface{})

+ TraceLogging func(on bool)

+ type StdLog interface

+ Printf func(format string, v ...interface{})

+ SetOutput func(w io.Writer)

Jun 30, 2019

Changes in this version

type Execer

+ InsertContext func(ctx context.Context, query string, args ...interface{}) (int64, error)

+ IsTx func() bool

+ type Logger interface

+ Printf func(format string, v ...interface{})

type SqlDB

+ func WrapDB(ex *sql.DB) SqlDB

Mar 14, 2019

Changes in this version

+ type SqlDB interface

+ BeginTx func(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

+ PingContext func(ctx context.Context) error

+ Stats func() sql.DBStats

+ type SqlRow interface

+ Scan func(dest ...interface{}) error

+ type SqlRows interface

+ Close func() error

+ ColumnTypes func() ([]*sql.ColumnType, error)

+ Columns func() ([]string, error)

+ Err func() error

+ Next func() bool

+ type SqlStmt interface

+ Close func() error

+ ExecContext func(ctx context.Context, args ...interface{}) (sql.Result, error)

+ QueryContext func(ctx context.Context, args ...interface{}) (*sql.Rows, error)

+ QueryRowContext func(ctx context.Context, args ...interface{}) *sql.Row

+ type SqlTx interface

+ Commit func() error

+ Rollback func() error

Feb 7, 2019

Changes in this version

+ const Version

Sep 11, 2018

Changes in this version

+ func Named(name string, value interface{}) sql.NamedArg

+ func NamedArgString(arg sql.NamedArg) string

+ type CanPostGet interface

+ PostGet func() error

+ type CanPreInsert interface

+ PreInsert func() error

+ type CanPreUpdate interface

+ PreUpdate func() error

+ type Database struct

+ func NewDatabase(db Execer, dialect schema.Dialect, logger *log.Logger, wrapper interface{}) *Database

+ func (database *Database) Begin() (*sql.Tx, error)

+ func (database *Database) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

+ func (database *Database) DB() Execer

+ func (database *Database) Dialect() schema.Dialect

+ func (database *Database) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (database *Database) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (database *Database) ListTables() (util.StringList, error)

+ func (database *Database) LogError(err error) error

+ func (database *Database) LogIfError(err error) error

+ func (database *Database) LogQuery(query string, args ...interface{})

+ func (database *Database) Logger() *log.Logger

+ func (database *Database) Ping() error

+ func (database *Database) PingContext(ctx context.Context) error

+ func (database *Database) Prepare(query string) (*sql.Stmt, error)

+ func (database *Database) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)

+ func (database *Database) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (database *Database) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (database *Database) QueryRow(query string, args ...interface{}) *sql.Row

+ func (database *Database) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (database *Database) ScanFloat32List(req require.Requirement, rows *sql.Rows) ([]float32, error)

+ func (database *Database) ScanFloat64List(req require.Requirement, rows *sql.Rows) ([]float64, error)

+ func (database *Database) ScanInt16List(req require.Requirement, rows *sql.Rows) ([]int16, error)

+ func (database *Database) ScanInt32List(req require.Requirement, rows *sql.Rows) ([]int32, error)

+ func (database *Database) ScanInt64List(req require.Requirement, rows *sql.Rows) ([]int64, error)

+ func (database *Database) ScanInt8List(req require.Requirement, rows *sql.Rows) ([]int8, error)

+ func (database *Database) ScanIntList(req require.Requirement, rows *sql.Rows) ([]int, error)

+ func (database *Database) ScanStringList(req require.Requirement, rows *sql.Rows) ([]string, error)

+ func (database *Database) ScanUint16List(req require.Requirement, rows *sql.Rows) ([]uint16, error)

+ func (database *Database) ScanUint32List(req require.Requirement, rows *sql.Rows) ([]uint32, error)

+ func (database *Database) ScanUint64List(req require.Requirement, rows *sql.Rows) ([]uint64, error)

+ func (database *Database) ScanUint8List(req require.Requirement, rows *sql.Rows) ([]uint8, error)

+ func (database *Database) ScanUintList(req require.Requirement, rows *sql.Rows) ([]uint, error)

+ func (database *Database) Stats() sql.DBStats

+ func (database *Database) TableExists(name TableName) (yes bool, err error)

+ func (database *Database) TraceLogging(on bool)

+ func (database *Database) Wrapper() interface{}

+ type Execer interface

+ ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error)

+ QueryContext func(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ QueryRowContext func(ctx context.Context, query string, args ...interface{}) *sql.Row

+ type NamedArgList []sql.NamedArg

+ func (list NamedArgList) Assignments(d schema.Dialect, from int) []string

+ func (list NamedArgList) Contains(name string) bool

+ func (list NamedArgList) Exists(fn func(sql.NamedArg) bool) bool

+ func (list NamedArgList) Find(fn func(sql.NamedArg) bool) (sql.NamedArg, bool)

+ func (list NamedArgList) FindByName(name string) (sql.NamedArg, bool)

+ func (list NamedArgList) MkString(sep string) string

+ func (list NamedArgList) Names() []string

+ func (list NamedArgList) String() string

+ func (list NamedArgList) Values() []interface{}

+ type RowData struct

+ ColumnTypes []*sql.ColumnType

+ Columns []string

+ Data util.StringAnyMap

+ type Rows struct

+ Rows *sql.Rows

+ func WrapRows(rows *sql.Rows) (*Rows, error)

+ func (rams *Rows) Close() error

+ func (rams *Rows) ColumnTypes() ([]*sql.ColumnType, error)

+ func (rams *Rows) Columns() ([]string, error)

+ func (rams *Rows) Err() error

+ func (rams *Rows) Next() bool

+ func (rams *Rows) Scan(dest ...interface{}) error

+ func (rams *Rows) ScanToMap() (RowData, error)

+ type Table interface

+ Ctx func() context.Context

+ DB func() *sql.DB

+ Database func() *Database

+ Dialect func() schema.Dialect

+ Execer func() Execer

+ IsTx func() bool

+ Logger func() *log.Logger

+ Name func() TableName

+ Query func(query string, args ...interface{}) (*sql.Rows, error)

+ Tx func() *sql.Tx

+ type TableCreator interface

+ CreateTable func(ifNotExists bool) (int64, error)

+ DropTable func(ifExists bool) (int64, error)

+ Truncate func(force bool) (err error)

+ type TableName struct

+ Name string

+ Prefix string

+ func (tn TableName) PrefixWithoutDot() string

+ func (tn TableName) String() string

+ type TableWithCrud interface

+ Count func(where where.Expression) (count int64, err error)

+ CountWhere func(where string, args ...interface{}) (count int64, err error)

+ Delete func(req require.Requirement, wh where.Expression) (int64, error)

+ Exec func(req require.Requirement, query string, args ...interface{}) (int64, error)

+ QueryOneNullFloat64 func(req require.Requirement, query string, args ...interface{}) (result sql.NullFloat64, err error)

+ QueryOneNullInt64 func(req require.Requirement, query string, args ...interface{}) (result sql.NullInt64, err error)

+ QueryOneNullString func(req require.Requirement, query string, args ...interface{}) (result sql.NullString, err error)

+ UpdateFields func(req require.Requirement, where where.Expression, fields ...sql.NamedArg) (int64, error)

+ type TableWithIndexes interface

+ CreateIndexes func(ifNotExist bool) (err error)

+ CreateTableWithIndexes func(ifNotExist bool) (err error)

+ DropIndexes func(ifExist bool) (err error)

+ type TxStarter interface

+ BeginTx func(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)