Versions in this module Expand all Collapse all v0 v0.1.0 Mar 25, 2026 Changes in this version + const DEFAULT_MAX_CONNECTIONS + const DEFAULT_MAX_IDLE + const DEFAULT_MIN_CONNECTIONS + func NewConnection(conn *sql.DB) (*connection, error) + func NewConnectionPool(dsn db.DSN) *connectionPool + func NewLeasedConnection(pooledConnection PooledConnectionIfc, leaseKey int64) *leasedConnection + func NewLeasedConnections() *leasedConnections + func NewMySQLConnectionFactory() *db.DBConnectionFactory + func NewPooledConnection(connection ConnectionIfc, connPool ConnectionPoolIfc) (*pooledConnection, error) + func NewQuery(connection ConnectionIfc, sqlQuery SQLQueryIfc) (*query, error) + func NewResult(res db.Result) *result + func NewResultSet() *resultSet + type ConnectionCommonIfc interface + Begin func() error + Commit func() error + Exec func(query SQLQueryIfc, args ...interface{}) (sql.Result, error) + InTransaction func() bool + NewQuery func(query SQLQueryIfc) (QueryIfc, error) + Query func(query SQLQueryIfc, args ...interface{}) (*sql.Rows, error) + QueryRow func(query SQLQueryIfc, args ...interface{}) *sql.Row + Rollback func() error + type ConnectionIfc interface + IsConnected func() bool + type ConnectionPoolIfc interface + Close func() error + GetConnection func() (*leasedConnection, error) + GetMaxIdle func() int + Release func(leaseKey int64) error + func ConnectionPoolFromIfc(i interface{}) (ConnectionPoolIfc, error) + type LeasedConnectionIfc interface + Release func() error + type LeasedConnectionsIfc interface + GetLeaseForConnection func(connection PooledConnectionIfc) *leasedConnection + Release func(leaseKey int64) bool + type PooledConnectionIfc interface + IsConnected func() bool + IsExpired func() bool + IsLeased func() bool + Lease func(leaseKey int64) + MatchesLeaseKey func(leaseKey int64) bool + Release func() error + Touch func() + type QueryIfc interface + Run func(args ...interface{}) (*result, error) + RunReturnAll func(args ...interface{}) (*resultSet, error) + RunReturnInt func(args ...interface{}) (*int, error) + RunReturnOne func(args ...interface{}) (*ResultRow, error) + RunReturnSome func(max int, args ...interface{}) (*resultSet, error) + RunReturnString func(args ...interface{}) (*string, error) + RunReturnValue func(receiver interface{}, args ...interface{}) error + type ResultIfc interface + GetLastInsertId func() (*int64, error) + GetRowsAffected func() (*int64, error) + type ResultRow struct + func NewResultRow() *ResultRow + func (r *ResultRow) Set(field string, value nullables.Nullable) + func (r ResultRow) Fields() []string + func (r ResultRow) Get(field string) nullables.NullableIfc + func (r ResultRow) Has(field string) bool + func (r ResultRow) MarshalJSON() ([]byte, error) + func (r ResultRow) ToJson() (*string, error) + type ResultRowIfc interface + Fields func() []string + Get func(field string) nullables.NullableIfc + Has func(field string) bool + Set func(field string, value nullables.Nullable) + ToJson func() (*string, error) + type ResultSetIfc interface + Add func(result ResultRowIfc) + Finalize func() + Get func(rowNum int) *ResultRow + IsEmpty func() bool + IsFinalized func() bool + Len func() int + ToJson func() (*string, error) + type SQLQuery struct + func NewSQLQuery(query string) *SQLQuery + func (r *SQLQuery) Resolve(args ...interface{}) (string, error) + type SQLQueryIfc interface + Resolve func(args ...interface{}) (string, error)
Go to main page