inline3

Documentation

Index

• type DBQuerier
  • func NewQuerier(conn genericConn) *DBQuerier
  • func (q *DBQuerier) CountAuthors(ctx context.Context) (*int, error)
  • func (q *DBQuerier) CountAuthorsBatch(batch genericBatch)
  • func (q *DBQuerier) CountAuthorsScan(results pgx.BatchResults) (*int, error)
  • func (q *DBQuerier) DeleteAuthorsByFullName(ctx context.Context, firstName string, lastName string, suffix string) (pgconn.CommandTag, error)
  • func (q *DBQuerier) DeleteAuthorsByFullNameBatch(batch genericBatch, firstName string, lastName string, suffix string)
  • func (q *DBQuerier) DeleteAuthorsByFullNameScan(results pgx.BatchResults) (pgconn.CommandTag, error)
  • func (q *DBQuerier) FindAuthorByID(ctx context.Context, authorID int32) (FindAuthorByIDRow, error)
  • func (q *DBQuerier) FindAuthorByIDBatch(batch genericBatch, authorID int32)
  • func (q *DBQuerier) FindAuthorByIDScan(results pgx.BatchResults) (FindAuthorByIDRow, error)
  • func (q *DBQuerier) InsertAuthor(ctx context.Context, firstName string, lastName string) (int32, error)
  • func (q *DBQuerier) InsertAuthorBatch(batch genericBatch, firstName string, lastName string)
  • func (q *DBQuerier) InsertAuthorScan(results pgx.BatchResults) (int32, error)
• type FindAuthorByIDRow
• type Querier

Types

type DBQuerier

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

func NewQuerier

func NewQuerier(conn genericConn) *DBQuerier

NewQuerier creates a DBQuerier that implements Querier. conn is typically *pgx.Conn, pgx.Tx, or *pgxpool.Pool.

func (*DBQuerier) CountAuthors

func (q *DBQuerier) CountAuthors(ctx context.Context) (*int, error)

CountAuthors implements Querier.CountAuthors.

func (*DBQuerier) CountAuthorsBatch

func (q *DBQuerier) CountAuthorsBatch(batch genericBatch)

CountAuthorsBatch implements Querier.CountAuthorsBatch.

func (*DBQuerier) CountAuthorsScan

func (q *DBQuerier) CountAuthorsScan(results pgx.BatchResults) (*int, error)

CountAuthorsScan implements Querier.CountAuthorsScan.

func (*DBQuerier) DeleteAuthorsByFullName

func (q *DBQuerier) DeleteAuthorsByFullName(ctx context.Context, firstName string, lastName string, suffix string) (pgconn.CommandTag, error)

DeleteAuthorsByFullName implements Querier.DeleteAuthorsByFullName.

func (*DBQuerier) DeleteAuthorsByFullNameBatch

func (q *DBQuerier) DeleteAuthorsByFullNameBatch(batch genericBatch, firstName string, lastName string, suffix string)

DeleteAuthorsByFullNameBatch implements Querier.DeleteAuthorsByFullNameBatch.

func (*DBQuerier) DeleteAuthorsByFullNameScan

func (q *DBQuerier) DeleteAuthorsByFullNameScan(results pgx.BatchResults) (pgconn.CommandTag, error)

DeleteAuthorsByFullNameScan implements Querier.DeleteAuthorsByFullNameScan.

func (*DBQuerier) FindAuthorByID

func (q *DBQuerier) FindAuthorByID(ctx context.Context, authorID int32) (FindAuthorByIDRow, error)

FindAuthorByID implements Querier.FindAuthorByID.

func (*DBQuerier) FindAuthorByIDBatch

func (q *DBQuerier) FindAuthorByIDBatch(batch genericBatch, authorID int32)

FindAuthorByIDBatch implements Querier.FindAuthorByIDBatch.

func (*DBQuerier) FindAuthorByIDScan

func (q *DBQuerier) FindAuthorByIDScan(results pgx.BatchResults) (FindAuthorByIDRow, error)

FindAuthorByIDScan implements Querier.FindAuthorByIDScan.

func (*DBQuerier) InsertAuthor

func (q *DBQuerier) InsertAuthor(ctx context.Context, firstName string, lastName string) (int32, error)

InsertAuthor implements Querier.InsertAuthor.

func (*DBQuerier) InsertAuthorBatch

func (q *DBQuerier) InsertAuthorBatch(batch genericBatch, firstName string, lastName string)

InsertAuthorBatch implements Querier.InsertAuthorBatch.

func (*DBQuerier) InsertAuthorScan

func (q *DBQuerier) InsertAuthorScan(results pgx.BatchResults) (int32, error)

InsertAuthorScan implements Querier.InsertAuthorScan.

type FindAuthorByIDRow

type FindAuthorByIDRow struct {
	AuthorID  int32   `json:"author_id"`
	FirstName string  `json:"first_name"`
	LastName  string  `json:"last_name"`
	Suffix    *string `json:"suffix"`
}

type Querier

type Querier interface {
	// CountAuthors returns the number of authors (zero params).
	CountAuthors(ctx context.Context) (*int, error)
	// CountAuthorsBatch enqueues a CountAuthors query into batch to be executed
	// later by the batch.
	CountAuthorsBatch(batch genericBatch)
	// CountAuthorsScan scans the result of an executed CountAuthorsBatch query.
	CountAuthorsScan(results pgx.BatchResults) (*int, error)

	// FindAuthorById finds one (or zero) authors by ID (one param).
	FindAuthorByID(ctx context.Context, authorID int32) (FindAuthorByIDRow, error)
	// FindAuthorByIDBatch enqueues a FindAuthorByID query into batch to be executed
	// later by the batch.
	FindAuthorByIDBatch(batch genericBatch, authorID int32)
	// FindAuthorByIDScan scans the result of an executed FindAuthorByIDBatch query.
	FindAuthorByIDScan(results pgx.BatchResults) (FindAuthorByIDRow, error)

	// InsertAuthor inserts an author by name and returns the ID (two params).
	InsertAuthor(ctx context.Context, firstName string, lastName string) (int32, error)
	// InsertAuthorBatch enqueues a InsertAuthor query into batch to be executed
	// later by the batch.
	InsertAuthorBatch(batch genericBatch, firstName string, lastName string)
	// InsertAuthorScan scans the result of an executed InsertAuthorBatch query.
	InsertAuthorScan(results pgx.BatchResults) (int32, error)

	// DeleteAuthorsByFullName deletes authors by the full name (three params).
	DeleteAuthorsByFullName(ctx context.Context, firstName string, lastName string, suffix string) (pgconn.CommandTag, error)
	// DeleteAuthorsByFullNameBatch enqueues a DeleteAuthorsByFullName query into batch to be executed
	// later by the batch.
	DeleteAuthorsByFullNameBatch(batch genericBatch, firstName string, lastName string, suffix string)
	// DeleteAuthorsByFullNameScan scans the result of an executed DeleteAuthorsByFullNameBatch query.
	DeleteAuthorsByFullNameScan(results pgx.BatchResults) (pgconn.CommandTag, error)
}

Querier is a typesafe Go interface backed by SQL queries.

Methods ending with Batch enqueue a query to run later in a pgx.Batch. After calling SendBatch on pgx.Conn, pgxpool.Pool, or pgx.Tx, use the Scan methods to parse the results.