sqldb

Documentation

Overview

Package sqldb provides a database handle backed by a PostgreSQL database.

Index

• type DB
  • func New(sqlDB SQL) (*DB, error)
  • func (db *DB) Begin(ctx context.Context) (db.Tx, error)
  • func (db *DB) CreateTask(tx db.Tx, creatorID todo.UserID) (todo.TaskID, error)
  • func (db *DB) CreateUser(tx db.Tx, authProviderType authn.Provider, authProviderId authn.UserID, ...) (todo.UserID, error)
  • func (d *DB) DeleteTask(tx db.Tx, taskID todo.TaskID) error
  • func (db *DB) NoTxn(ctx context.Context) db.Tx
  • func (db *DB) RunOrContinueTransaction(in db.Tx, fn func(db.Tx) error) error
  • func (db *DB) Task(tx db.Tx, id todo.TaskID) (*todo.Task, error)
  • func (db *DB) TasksByCreator(tx db.Tx, creatorID todo.UserID) ([]*todo.Task, error)
  • func (db *DB) Transactional(ctx context.Context, fn func(tx db.Tx) error) error
  • func (d *DB) UpdateTask(tx db.Tx, taskID todo.TaskID, taskMutations ...db.UpdateTaskFn) error
  • func (d *DB) UpdateUser(tx db.Tx, userID todo.UserID, userMutations ...db.UpdateUserFn) error
  • func (db *DB) User(tx db.Tx, id todo.UserID) (*todo.User, error)
  • func (d *DB) UserByAuthnProvider(tx db.Tx, authnProvider authn.Provider, authnProvidedUserID authn.UserID) (*todo.User, error)
  • func (db *DB) Users(tx db.Tx) ([]*todo.User, error)
• type DBConn
• type SQL

Types

type DB

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

func New

func New(sqlDB SQL) (*DB, error)

func (*DB) Begin

func (db *DB) Begin(ctx context.Context) (db.Tx, error)

func (*DB) CreateTask

func (db *DB) CreateTask(tx db.Tx, creatorID todo.UserID) (todo.TaskID, error)

func (*DB) CreateUser

func (db *DB) CreateUser(
	tx db.Tx,
	authProviderType authn.Provider,
	authProviderId authn.UserID,
	name string,
	email string) (todo.UserID, error)

func (*DB) DeleteTask

func (d *DB) DeleteTask(tx db.Tx, taskID todo.TaskID) error

func (*DB) NoTxn

func (db *DB) NoTxn(ctx context.Context) db.Tx

func (*DB) RunOrContinueTransaction

func (db *DB) RunOrContinueTransaction(in db.Tx, fn func(db.Tx) error) error

func (*DB) Task

func (db *DB) Task(tx db.Tx, id todo.TaskID) (*todo.Task, error)

func (*DB) TasksByCreator

func (db *DB) TasksByCreator(tx db.Tx, creatorID todo.UserID) ([]*todo.Task, error)

func (*DB) Transactional

func (db *DB) Transactional(ctx context.Context, fn func(tx db.Tx) error) error

func (*DB) UpdateTask

func (d *DB) UpdateTask(
	tx db.Tx,
	taskID todo.TaskID,
	taskMutations ...db.UpdateTaskFn) error

func (*DB) UpdateUser

func (d *DB) UpdateUser(
	tx db.Tx,
	userID todo.UserID,
	userMutations ...db.UpdateUserFn) error

func (*DB) User

func (db *DB) User(tx db.Tx, id todo.UserID) (*todo.User, error)

func (*DB) UserByAuthnProvider

func (d *DB) UserByAuthnProvider(tx db.Tx, authnProvider authn.Provider, authnProvidedUserID authn.UserID) (*todo.User, error)

func (*DB) Users

func (db *DB) Users(tx db.Tx) ([]*todo.User, error)

type DBConn

type DBConn interface {
	Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)
	QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row
	Exec(ctx context.Context, sql string, args ...interface{}) (pgconn.CommandTag, error)
}

type SQL

type SQL interface {
	DBConn
	Begin(context.Context) (pgx.Tx, error)
}