pgtest

Documentation

Index

• func ExpectQuery(sql string, params [][]byte, oids []uint32) pgmock.Step
• func ExpectTerminate() pgmock.Step
• func MockMigrationHistory(conn *MockConn)
• type MockConn
  • func NewConn() *MockConn
  • func NewWithStatus(status map[string]string) *MockConn
  • func (r *MockConn) Close(t *testing.T)
  • func (r *MockConn) Intercept(config *pgx.ConnConfig)
  • func (r *MockConn) Query(sql string, args ...interface{}) *MockConn
  • func (r *MockConn) Reply(tag string, rows ...[]interface{}) *MockConn
  • func (r *MockConn) ReplyError(code, message string) *MockConn

Functions

func ExpectQuery

func ExpectQuery(sql string, params [][]byte, oids []uint32) pgmock.Step

Expects a SQL query in any form: simple, prepared, or anonymous.

func ExpectTerminate

func ExpectTerminate() pgmock.Step

func MockMigrationHistory

func MockMigrationHistory(conn *MockConn)

Types

type MockConn

type MockConn struct {
	// contains filtered or unexported fields
}

func NewConn

func NewConn() *MockConn

func NewWithStatus

func NewWithStatus(status map[string]string) *MockConn

func (*MockConn) Close

func (r *MockConn) Close(t *testing.T)

func (*MockConn) Intercept

func (r *MockConn) Intercept(config *pgx.ConnConfig)

Configures pgx to use the mock dialer.

The mock dialer provides a full duplex net.Conn backed by an in-memory buffer. It is implemented by grcp/test/bufconn package.

func (*MockConn) Query

func (r *MockConn) Query(sql string, args ...interface{}) *MockConn

Adds a simple query or prepared statement to the mock connection.

func (*MockConn) Reply

func (r *MockConn) Reply(tag string, rows ...[]interface{}) *MockConn

Adds a server reply using text protocol format.

TODO: support binary protocol

func (*MockConn) ReplyError

func (r *MockConn) ReplyError(code, message string) *MockConn

Simulates an error reply from the server.

TODO: simulate a notice reply