client

Documentation

Index

• func CheckMigrationVersion(ctx context.Context, connectionString string, expectedMigration int64) error
• type Client
  • func NewClient(ctx context.Context, databaseURL string, options ...pool.Option) (*Client, error)
  • func (db *Client) Close() error
  • func (db *Client) TestsRawSQL(ctx context.Context, sql string, args ...any) error
  • func (db *Client) TestsRawSQLQuery(ctx context.Context, sql string, processRows func(pgx.Rows) error, args ...any) error
  • func (db *Client) WithTx(ctx context.Context) (*Client, pgx.Tx, error)

Functions

func CheckMigrationVersion

func CheckMigrationVersion(ctx context.Context, connectionString string, expectedMigration int64) error

Types

type Client

type Client struct {
	*database.Queries
	// contains filtered or unexported fields
}

func NewClient

func NewClient(ctx context.Context, databaseURL string, options ...pool.Option) (*Client, error)

func (*Client) Close

func (db *Client) Close() error

func (*Client) TestsRawSQL

func (db *Client) TestsRawSQL(ctx context.Context, sql string, args ...any) error

func (*Client) TestsRawSQLQuery

func (db *Client) TestsRawSQLQuery(ctx context.Context, sql string, processRows func(pgx.Rows) error, args ...any) error

func (*Client) WithTx

func (db *Client) WithTx(ctx context.Context) (*Client, pgx.Tx, error)

WithTx starts a read-write transaction and returns a transactional Client.