pgxmock

Apr 22, 2022

Changes in this version

type Rows

+ func (r *Rows) AddCommandTag(tag pgconn.CommandTag) *Rows

May 27, 2021

Changes in this version

+ type ExpectedCopyFrom struct

+ func (e *ExpectedCopyFrom) String() string

+ func (e *ExpectedCopyFrom) WillDelayFor(duration time.Duration) *ExpectedCopyFrom

+ func (e *ExpectedCopyFrom) WillReturnError(err error) *ExpectedCopyFrom

+ func (e *ExpectedCopyFrom) WillReturnResult(result int64) *ExpectedCopyFrom

Apr 27, 2021

Changes in this version

+ var CSVColumnParser = func(s string) interface{}

+ var ErrCancelled = errors.New("canceling query due to user request")

+ func MonitorPingsOption(monitorPings bool) func(*pgxmock) error

+ func NewErrorResult(err error) pgconn.CommandTag

+ func NewResult(op string, rowsAffected int64) pgconn.CommandTag

+ func QueryMatcherOption(queryMatcher QueryMatcher) func(*pgxmock) error

+ type Argument interface

+ Match func(interface{}) bool

+ func AnyArg() Argument

+ type ExpectedBegin struct

+ func (e *ExpectedBegin) String() string

+ func (e *ExpectedBegin) WillDelayFor(duration time.Duration) *ExpectedBegin

+ func (e *ExpectedBegin) WillReturnError(err error) *ExpectedBegin

+ type ExpectedClose struct

+ func (e *ExpectedClose) String() string

+ func (e *ExpectedClose) WillReturnError(err error) *ExpectedClose

+ type ExpectedCommit struct

+ func (e *ExpectedCommit) String() string

+ func (e *ExpectedCommit) WillReturnError(err error) *ExpectedCommit

+ type ExpectedExec struct

+ func (e *ExpectedExec) String() string

+ func (e *ExpectedExec) WillDelayFor(duration time.Duration) *ExpectedExec

+ func (e *ExpectedExec) WillReturnError(err error) *ExpectedExec

+ func (e *ExpectedExec) WillReturnResult(result pgconn.CommandTag) *ExpectedExec

+ func (e *ExpectedExec) WithArgs(args ...interface{}) *ExpectedExec

+ type ExpectedPing struct

+ func (e *ExpectedPing) String() string

+ func (e *ExpectedPing) WillDelayFor(duration time.Duration) *ExpectedPing

+ func (e *ExpectedPing) WillReturnError(err error) *ExpectedPing

+ type ExpectedPrepare struct

+ func (e *ExpectedPrepare) ExpectExec() *ExpectedExec

+ func (e *ExpectedPrepare) ExpectQuery() *ExpectedQuery

+ func (e *ExpectedPrepare) String() string

+ func (e *ExpectedPrepare) WillBeClosed() *ExpectedPrepare

+ func (e *ExpectedPrepare) WillDelayFor(duration time.Duration) *ExpectedPrepare

+ func (e *ExpectedPrepare) WillReturnCloseError(err error) *ExpectedPrepare

+ func (e *ExpectedPrepare) WillReturnError(err error) *ExpectedPrepare

+ type ExpectedQuery struct

+ func (e *ExpectedQuery) RowsWillBeClosed() *ExpectedQuery

+ func (e *ExpectedQuery) String() string

+ func (e *ExpectedQuery) WillDelayFor(duration time.Duration) *ExpectedQuery

+ func (e *ExpectedQuery) WillReturnError(err error) *ExpectedQuery

+ func (e *ExpectedQuery) WillReturnRows(rows ...*Rows) *ExpectedQuery

+ func (e *ExpectedQuery) WithArgs(args ...interface{}) *ExpectedQuery

+ type ExpectedRollback struct

+ func (e *ExpectedRollback) String() string

+ func (e *ExpectedRollback) WillReturnError(err error) *ExpectedRollback

+ type PgxConnIface interface

+ Close func(ctx context.Context) error

+ func NewConn(options ...func(*pgxmock) error) (PgxConnIface, error)

+ type PgxPoolIface interface

+ Acquire func(ctx context.Context) (*pgxpool.Conn, error)

+ Close func()

+ func NewPool(options ...func(*pgxmock) error) (PgxPoolIface, error)

+ type QueryMatcher interface

+ Match func(expectedSQL, actualSQL string) error

+ var QueryMatcherEqual QueryMatcher = QueryMatcherFunc(func(expectedSQL, actualSQL string) error { ... })

+ var QueryMatcherRegexp QueryMatcher = QueryMatcherFunc(func(expectedSQL, actualSQL string) error { ... })

+ type QueryMatcherFunc func(expectedSQL, actualSQL string) error

+ func (f QueryMatcherFunc) Match(expectedSQL, actualSQL string) error

+ type Rows struct

+ func NewRows(columns []string) *Rows

+ func NewRowsWithColumnDefinition(columns ...pgproto3.FieldDescription) *Rows

+ func (r *Rows) AddRow(values ...interface{}) *Rows

+ func (r *Rows) CloseError(err error) *Rows

+ func (r *Rows) FromCSVString(s string) *Rows

+ func (r *Rows) RowError(row int, err error) *Rows