pgx

type CommandTag string

type CopyFromSource interface {
	// Next returns true if there is another row and makes the next row data
	// available to Values(). When there are no more rows available or an error
	// has occurred it returns false.
	Next() bool

	// Values returns the values for the current row.
	Values() ([]interface{}, error)

	// Err returns any error that has been encountered by the CopyFromSource. If
	// this is not nil *Conn.CopyFrom will abort the copy.
	Err() error
}

type FieldDescription struct {
	Name            string
	Table           Oid
	AttributeNumber int16
	DataType        Oid
	DataTypeSize    int16
	DataTypeName    string
	Modifier        int32
	FormatCode      int16
}

type Identifier []string

type Mocker interface {
	PGXer
	QueriesRun() []onedb.MethodsRun
	SaveMethodCall(name string, arguments []interface{})
	VerifyNextCommand(t *testing.T, name string, expected ...interface{})
}

type Oid uint32

type PGXQuerier interface {
	onedb.DBer
	// contains filtered or unexported methods
}

type PGXer interface {
	onedb.DBer
	// contains filtered or unexported methods
}

type Rower interface {
	AfterClose(f func(Rower)) // modified from pgxRower to use interface
	Close() error             // modified from pgxRower to match database/sql
	Conn() *pgx.Conn
	Err() error
	Fatal(err error)
	FieldDescriptions() []FieldDescription
	Next() bool
	onedb.Scanner
	Values() ([]interface{}, error)

	Columns() ([]string, error) // added
}

type Txer interface {
	Commit() error
	Conn() *pgx.Conn
	Rollback() error
	Status() int8
	PGXQuerier
}