rdb

Jan 22, 2026

Changes in this version

type Config

+ ExpandPoolBy int

Oct 8, 2025

Changes in this version

type Config

+ SoftWait time.Duration

type ConnPool

+ func OpenContext(ctx context.Context, config *Config) (*ConnPool, error)

Sep 10, 2025

Changes in this version

+ var ErrClosed = errors.New("closed result")

type Config

+ RollbackTimeout time.Duration

May 22, 2024

Changes in this version

+ var ErrBulkBatchDone = errors.New("batch is complete, more data to follow")

May 13, 2024

Changes in this version

+ var ErrBulkSkip = errors.New("skip batch row")

May 13, 2024

Changes in this version

type IsolationLevel

+ const LevelReadCommitted

+ const LevelReadUncommitted

+ const LevelWriteCommitted

+ func (i IsolationLevel) String() string

May 11, 2024

Changes in this version

+ var ErrArity = errors.New("result row count does not match desired arity")

+ var ErrNotImplemented = errors.New("the feature has not been implemented")

+ var ErrPreparedTokenNotValid = errors.New("the prepared token is not valid")

+ var ErrScanNull = errors.New("can only scan NULL value into a Nullable type")

+ type Bulk interface

+ Next func(row []Param) error

+ Start func() (sql string, col []Param, err error)

type Command

+ Bulk Bulk

+ SQL string

type Type

+ const TypeJSON

+ const TypeXML

Jan 12, 2023

Changes in this version

type MessageType

+ func (mt MessageType) String() string

Jan 12, 2023

Changes in this version

type Command

+ Log func(msg *Message)

Jul 5, 2022

Changes in this version

+ var ErrCancel = errors.New("Query Cancelled")

Jul 4, 2022

Changes in this version

type Config

+ ResetConnectionTimeout time.Duration

type Message

+ Class byte

+ State byte

Jun 16, 2022

Changes in this version

type Config

+ ConnectionMaxLifetime time.Duration

type DriverConn

+ Opened func() time.Time

Jul 19, 2021

Changes in this version

type Config

+ InsecureDisableEncryption bool

May 31, 2021

Changes in this version

+ const TypeDriverThresh

+ var ArityError = errors.New("Result row count does not match desired arity.")

+ var ErrTimeout = pools.ErrTimeout

+ var NotImplemented = errors.New("The feature has not been implemented.")

+ var PreparedTokenNotValid = errors.New("The prepared token is not valid.")

+ var ScanNullError = errors.New("Can only scan NULL value into a Nullable type.")

+ func AssignValue(c *Column, outValue Nullable, prep interface{}, assign Assigner) error

+ func Register(name string, dr Driver)

+ type Arity byte

+ const Any

+ const ArityMust

+ const One

+ const OneMust

+ const Zero

+ const ZeroMust

+ type Assigner func(input, output interface{}) (handled bool, err error)

+ type Column struct

+ Generic Type

+ Index int

+ Key bool

+ Length int

+ Name string

+ Nullable bool

+ Precision int

+ Scale int

+ Serial bool

+ Type Type

+ Unlimit bool

+ type ColumnConverter func(column *Column, nullable *Nullable) error

+ type Command struct

+ Arity Arity

+ AutoClose time.Duration

+ Context context.Context

+ Converter Converter

+ Fields []Field

+ IsoLevel IsolationLevel

+ Name string

+ Prepare bool

+ QueryTimeout time.Duration

+ Sql string

+ StringMethod StringMethod

+ TruncLongText bool

+ type Config struct

+ Database string

+ DialTimeout time.Duration

+ DriverName string

+ Hostname string

+ InsecureSkipVerify bool

+ Instance string

+ KV map[string]interface{}

+ Password string

+ PoolIdleTimeout time.Duration

+ PoolInitCapacity int

+ PoolMaxCapacity int

+ Port int

+ QueryTimeout time.Duration

+ ResetQuery string

+ RootCAs *x509.CertPool

+ Secure bool

+ Username string

+ func ParseConfigURL(connectionString string) (*Config, error)

+ type ConnPool struct

+ OnAutoClose func(sql string)

+ func Open(config *Config) (*ConnPool, error)

+ func (cp *ConnPool) Begin() (*Transaction, error)

+ func (cp *ConnPool) BeginLevel(level IsolationLevel) (*Transaction, error)

+ func (cp *ConnPool) Close()

+ func (cp *ConnPool) Connection() (*Connection, error)

+ func (cp *ConnPool) ConnectionInfo() (*ConnectionInfo, error)

+ func (cp *ConnPool) Ping() error

+ func (cp *ConnPool) PoolAvailable() (capacity, available int)

+ func (cp *ConnPool) Query(cmd *Command, params ...Param) (*Result, error)

+ type Connection struct

+ func (c *Connection) Active() bool

+ func (c *Connection) Close() error

+ func (c *Connection) Query(cmd *Command, params ...Param) (*Result, error)

+ type ConnectionInfo struct

+ Protocol *semver.Version

+ Server *semver.Version

+ type Converter interface

+ ColumnConverter func(column *Column) ColumnConverter

+ ConvertParam func(param *Param) error

+ type Driver interface

+ DriverInfo func() *DriverInfo

+ Open func(c *Config) (DriverConn, error)

+ PingCommand func() *Command

+ type DriverConn interface

+ Available func() bool

+ Begin func(iso IsolationLevel) error

+ Close func()

+ Commit func() error

+ ConnectionInfo func() *ConnectionInfo

+ NextQuery func() (err error)

+ NextResult func() (more bool, err error)

+ Prepare func(*Command) (preparedToken interface{}, err error)

+ Query func(cmd *Command, params []Param, preparedToken interface{}, val DriverValuer) error

+ Reset func(*Config) error

+ Rollback func(savepoint string) error

+ SavePoint func(name string) error

+ Scan func() error

+ SetAvailable func(available bool)

+ Status func() DriverConnStatus

+ Unprepare func(preparedToken interface{}) (err error)

+ type DriverConnStatus byte

+ const StatusBulkCopy

+ const StatusDisconnected

+ const StatusQuery

+ const StatusReady

+ const StatusResultDone

+ type DriverInfo struct

+ Options []*DriverOption

+ type DriverNotFound struct

+ func (dr DriverNotFound) Error() string

+ type DriverOption struct

+ Description string

+ Name string

+ Parse func(input string) (interface{}, error)

+ type DriverSupport struct

+ BulkInsert bool

+ FluidType bool

+ MultipleResult bool

+ NamedParameter bool

+ Notification bool

+ PreparePerConn bool

+ SecureConnection bool

+ UserDataTypes bool

+ type DriverValue struct

+ Chunked bool

+ More bool

+ MustCopy bool

+ Null bool

+ Value interface{}

+ type DriverValuer interface

+ Columns func([]*Column) error

+ Done func() error

+ Message func(*Message)

+ RowScanned func()

+ RowsAffected func(count uint64)

+ WriteField func(c *Column, value *DriverValue, assign Assigner) error

+ type ErrorColumnNotFound struct

+ At string

+ Index int

+ Name string

+ func (err ErrorColumnNotFound) Error() string

+ type Errors []*Message

+ func (errs Errors) Error() string

+ type Field struct

+ Name string

+ Null interface{}

+ type IsolationLevel byte

+ const LevelDefault

+ const LevelReadCommited

+ const LevelReadUncommited

+ const LevelRepeatableRead

+ const LevelSerializable

+ const LevelSnapshot

+ const LevelWriteCommited

+ type Message struct

+ LineNumber int32

+ Message string

+ Number int32

+ ProcName string

+ ServerName string

+ SqlState string

+ Type MessageType

+ func (err *Message) String() string

+ type MessageType byte

+ const SqlError

+ const SqlInfo

+ type NullType struct

+ var Null NullType

+ type Nullable struct

+ Null bool

+ Value interface{}

+ type Param struct

+ Length int

+ Name string

+ Null bool

+ Out bool

+ Precision int

+ Scale int

+ Type Type

+ Value interface{}

+ type Queryer interface

+ Query func(cmd *Command, params ...Param) (*Result, error)

+ type Result struct

+ func (r *Result) Close() error

+ func (r *Result) Get(name string) interface{}

+ func (r *Result) GetN(name string) Nullable

+ func (r *Result) GetRowN() []Nullable

+ func (r *Result) Getx(index int) interface{}

+ func (r *Result) GetxN(index int) Nullable

+ func (r *Result) Info() []*Message

+ func (r *Result) Next() (more bool)

+ func (r *Result) NextResult() (more bool, err error)

+ func (r *Result) Prep(name string, value interface{}) *Result

+ func (r *Result) Prepx(index int, value interface{}) *Result

+ func (r *Result) RowsAffected() uint64

+ func (r *Result) Scan(values ...interface{}) error

+ func (r *Result) Schema() []*Column

+ type StringMethod byte

+ const StringAsBytes

+ const StringAsString

+ type Transaction struct

+ func (tran *Transaction) Active() bool

+ func (tran *Transaction) Commit() error

+ func (tran *Transaction) Query(cmd *Command, params ...Param) (*Result, error)

+ func (tran *Transaction) Rollback() error

+ func (tran *Transaction) RollbackTo(savepoint string) error

+ func (tran *Transaction) SavePoint(name string) error

+ type Type uint32

+ const Binary

+ const Bool

+ const Decimal

+ const Float

+ const Integer

+ const Other

+ const Text

+ const Time

+ const TypeAnsiChar

+ const TypeAnsiText

+ const TypeAnsiVarChar

+ const TypeArray

+ const TypeBinary

+ const TypeBool

+ const TypeChar

+ const TypeDate

+ const TypeDecimal

+ const TypeDuration

+ const TypeEnum

+ const TypeFloat32

+ const TypeFloat64

+ const TypeInt16

+ const TypeInt32

+ const TypeInt64

+ const TypeInt8

+ const TypeJson

+ const TypeMoney

+ const TypeRange

+ const TypeSerial16

+ const TypeSerial32

+ const TypeSerial64

+ const TypeTable

+ const TypeText

+ const TypeTime

+ const TypeTimestamp

+ const TypeTimestampz

+ const TypeUUID

+ const TypeUint16

+ const TypeUint32

+ const TypeUint64

+ const TypeUint8

+ const TypeUnknown

+ const TypeVarChar

+ const TypeXml

+ func (t Type) Driver() bool

+ func (t Type) Generic() bool