Documentation ¶
Index ¶
- Constants
- func Connect(ctx context.Context, connString string) (*pgxpool.Pool, error)
- func ConnectConfig(ctx context.Context, config *pgxpool.Config) (*pgxpool.Pool, error)
- func NewMockCommandTag(op string, rowsAffected int64) pgconn.CommandTag
- func NewMockCommandTagError(err error) pgconn.CommandTag
- func NewMockErrDB(code string) error
- func ParseConfig(connString string) (*pgxpool.Config, error)
- type ErrDatabase
- type MockPool
- func (_m *MockPool) Acquire(ctx context.Context) (*pgxpool.Conn, error)
- func (_m *MockPool) AcquireAllIdle(ctx context.Context) []*pgxpool.Conn
- func (_m *MockPool) AcquireFunc(ctx context.Context, f func(*pgxpool.Conn) error) error
- func (_m *MockPool) Begin(ctx context.Context) (pgx.Tx, error)
- func (_m *MockPool) BeginFunc(ctx context.Context, f func(pgx.Tx) error) error
- func (_m *MockPool) BeginTx(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)
- func (_m *MockPool) BeginTxFunc(ctx context.Context, txOptions pgx.TxOptions, f func(pgx.Tx) error) error
- func (_m *MockPool) Close()
- func (_m *MockPool) Config() *pgxpool.Config
- func (_m *MockPool) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, ...) (int64, error)
- func (_m *MockPool) Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)
- func (_m *MockPool) Ping(ctx context.Context) error
- func (_m *MockPool) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)
- func (_m *MockPool) QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, ...) (pgconn.CommandTag, error)
- func (_m *MockPool) QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row
- func (_m *MockPool) SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults
- func (_m *MockPool) Stat() *pgxpool.Stat
- type MockRow
- type MockRows
- type MockTx
- func (_m *MockTx) Begin(ctx context.Context) (pgx.Tx, error)
- func (_m *MockTx) BeginFunc(ctx context.Context, f func(pgx.Tx) error) error
- func (_m *MockTx) Commit(ctx context.Context) error
- func (_m *MockTx) Conn() *pgx.Conn
- func (_m *MockTx) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, ...) (int64, error)
- func (_m *MockTx) Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)
- func (_m *MockTx) LargeObjects() pgx.LargeObjects
- func (_m *MockTx) Prepare(ctx context.Context, name string, sql string) (*pgconn.StatementDescription, error)
- func (_m *MockTx) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)
- func (_m *MockTx) QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, ...) (pgconn.CommandTag, error)
- func (_m *MockTx) QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row
- func (_m *MockTx) Rollback(ctx context.Context) error
- func (_m *MockTx) SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults
- type Pool
- type Tx
Constants ¶
const ErrDBCodeColumnNotExists = "42703"
const ErrDBCodeDuplicateKey = "23505"
const ErrDBCodeInvalidInputSyntax = "22P02"
Variables ¶
This section is empty.
Functions ¶
func ConnectConfig ¶
ConnectConfig runs pgxpool.ConnectConfig.
func NewMockCommandTag ¶ added in v1.1.0
func NewMockCommandTag(op string, rowsAffected int64) pgconn.CommandTag
NewMockCommandTag mocks pgconn.CommandTag.
func NewMockCommandTagError ¶ added in v1.2.0
func NewMockCommandTagError(err error) pgconn.CommandTag
NewMockCommandTagError mocks pgconn.CommandTag error.
func NewMockErrDB ¶ added in v1.2.2
Types ¶
type ErrDatabase ¶ added in v1.2.1
func ErrDB ¶ added in v1.2.1
func ErrDB(e error) *ErrDatabase
func (*ErrDatabase) Code ¶ added in v1.2.1
func (e *ErrDatabase) Code() string
func (*ErrDatabase) Error ¶ added in v1.2.1
func (e *ErrDatabase) Error() string
func (*ErrDatabase) IsColumnNotExists ¶ added in v1.2.2
func (e *ErrDatabase) IsColumnNotExists() bool
func (*ErrDatabase) IsDuplicateKey ¶ added in v1.2.2
func (e *ErrDatabase) IsDuplicateKey() bool
func (*ErrDatabase) IsInvalidInputSyntax ¶ added in v1.2.2
func (e *ErrDatabase) IsInvalidInputSyntax() bool
func (*ErrDatabase) IsNoRows ¶ added in v1.2.2
func (e *ErrDatabase) IsNoRows() bool
func (*ErrDatabase) Message ¶ added in v1.2.1
func (e *ErrDatabase) Message() string
type MockPool ¶
MockPool is an autogenerated mock type for the Pool type
func NewMockPool ¶
func NewMockPool(t mockConstructorTestingTNewMockPool) *MockPool
NewMockPool creates a new instance of MockPool. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*MockPool) AcquireAllIdle ¶
AcquireAllIdle provides a mock function with given fields: ctx
func (*MockPool) AcquireFunc ¶
AcquireFunc provides a mock function with given fields: ctx, f
func (*MockPool) BeginTxFunc ¶
func (_m *MockPool) BeginTxFunc(ctx context.Context, txOptions pgx.TxOptions, f func(pgx.Tx) error) error
BeginTxFunc provides a mock function with given fields: ctx, txOptions, f
func (*MockPool) Close ¶
func (_m *MockPool) Close()
Close provides a mock function with given fields:
func (*MockPool) CopyFrom ¶
func (_m *MockPool) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)
CopyFrom provides a mock function with given fields: ctx, tableName, columnNames, rowSrc
func (*MockPool) Exec ¶
func (_m *MockPool) Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)
Exec provides a mock function with given fields: ctx, sql, arguments
func (*MockPool) QueryFunc ¶
func (_m *MockPool) QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, f func(pgx.QueryFuncRow) error) (pgconn.CommandTag, error)
QueryFunc provides a mock function with given fields: ctx, sql, args, scans, f
type MockRow ¶ added in v1.1.0
type MockRow struct {
// contains filtered or unexported fields
}
func NewMockRow ¶ added in v1.1.0
NewMockRow mocks pgx.Row.
type MockRows ¶
type MockRows struct {
// contains filtered or unexported fields
}
func (*MockRows) AddCommandTag ¶
func (mr *MockRows) AddCommandTag(tag pgconn.CommandTag) *MockRows
type MockTx ¶ added in v1.2.0
MockTx is an autogenerated mock type for the Tx type
func NewMockTx ¶ added in v1.2.0
func NewMockTx(t mockConstructorTestingTNewMockTx) *MockTx
NewMockTx creates a new instance of MockTx. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*MockTx) BeginFunc ¶ added in v1.2.0
BeginFunc provides a mock function with given fields: ctx, f
func (*MockTx) CopyFrom ¶ added in v1.2.0
func (_m *MockTx) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)
CopyFrom provides a mock function with given fields: ctx, tableName, columnNames, rowSrc
func (*MockTx) Exec ¶ added in v1.2.0
func (_m *MockTx) Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)
Exec provides a mock function with given fields: ctx, sql, arguments
func (*MockTx) LargeObjects ¶ added in v1.2.0
func (_m *MockTx) LargeObjects() pgx.LargeObjects
LargeObjects provides a mock function with given fields:
func (*MockTx) Prepare ¶ added in v1.2.0
func (_m *MockTx) Prepare(ctx context.Context, name string, sql string) (*pgconn.StatementDescription, error)
Prepare provides a mock function with given fields: ctx, name, sql
func (*MockTx) Query ¶ added in v1.2.0
Query provides a mock function with given fields: ctx, sql, args
func (*MockTx) QueryFunc ¶ added in v1.2.0
func (_m *MockTx) QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, f func(pgx.QueryFuncRow) error) (pgconn.CommandTag, error)
QueryFunc provides a mock function with given fields: ctx, sql, args, scans, f
func (*MockTx) QueryRow ¶ added in v1.2.0
QueryRow provides a mock function with given fields: ctx, sql, args
type Pool ¶
type Pool interface { Close() Acquire(ctx context.Context) (*pgxpool.Conn, error) AcquireFunc(ctx context.Context, f func(*pgxpool.Conn) error) error AcquireAllIdle(ctx context.Context) []*pgxpool.Conn Config() *pgxpool.Config Stat() *pgxpool.Stat Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error) QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, f func(pgx.QueryFuncRow) error) (pgconn.CommandTag, error) SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults Begin(ctx context.Context) (pgx.Tx, error) BeginTx(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error) BeginFunc(ctx context.Context, f func(pgx.Tx) error) error BeginTxFunc(ctx context.Context, txOptions pgx.TxOptions, f func(pgx.Tx) error) error CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error) Ping(ctx context.Context) error }
type Tx ¶ added in v1.2.0
type Tx interface { Begin(ctx context.Context) (pgx.Tx, error) BeginFunc(ctx context.Context, f func(pgx.Tx) error) (err error) Commit(ctx context.Context) error Rollback(ctx context.Context) error CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error) SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults LargeObjects() pgx.LargeObjects Prepare(ctx context.Context, name string, sql string) (*pgconn.StatementDescription, error) Exec(ctx context.Context, sql string, arguments ...interface{}) (commandTag pgconn.CommandTag, err error) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error) QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, f func(pgx.QueryFuncRow) error) (pgconn.CommandTag, error) Conn() *pgx.Conn }