postgres

Documentation

Index

• type Database
• type Reader
  • func (r *Reader) Get(dest interface{}, query string, args ...interface{}) error
  • func (r *Reader) GetContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error
  • func (r *Reader) NamedQuery(query string, arg interface{}) (*sqlx.Rows, error)
  • func (r *Reader) NamedQueryContext(ctx context.Context, query string, arg interface{}) (*sqlx.Rows, error)
  • func (r *Reader) Prepare(query string) (*sql.Stmt, error)
  • func (r *Reader) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
  • func (r *Reader) PrepareNamed(query string) (*sqlx.NamedStmt, error)
  • func (r *Reader) PrepareNamedContext(ctx context.Context, query string) (*sqlx.NamedStmt, error)
  • func (r *Reader) Preparex(query string) (*sqlx.Stmt, error)
  • func (r *Reader) PreparexContext(ctx context.Context, query string) (*sqlx.Stmt, error)
  • func (r *Reader) Query(query string, args ...any) (*sql.Rows, error)
  • func (r *Reader) QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
  • func (r *Reader) QueryRow(query string, args ...any) *sql.Row
  • func (r *Reader) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
  • func (r *Reader) QueryRowx(query string, args ...interface{}) *sqlx.Row
  • func (r *Reader) QueryRowxContext(ctx context.Context, query string, args ...interface{}) *sqlx.Row
  • func (r *Reader) Queryx(query string, args ...interface{}) (*sqlx.Rows, error)
  • func (r *Reader) QueryxContext(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)
  • func (r *Reader) Select(dest interface{}, query string, args ...interface{}) error
  • func (r *Reader) SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error
• type Writer
  • func (w *Writer) Begin() (*sql.Tx, error)
  • func (w *Writer) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
  • func (w *Writer) BeginTxx(ctx context.Context, opts *sql.TxOptions) (*sqlx.Tx, error)
  • func (w *Writer) Beginx() (*sqlx.Tx, error)
  • func (w *Writer) Exec(query string, args ...any) (sql.Result, error)
  • func (w *Writer) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
  • func (w *Writer) MustBegin() *sqlx.Tx
  • func (w *Writer) MustBeginTx(ctx context.Context, opts *sql.TxOptions) *sqlx.Tx
  • func (w *Writer) MustExec(query string, args ...interface{}) sql.Result
  • func (w *Writer) MustExecContext(ctx context.Context, query string, args ...interface{}) sql.Result
  • func (w *Writer) NamedExec(query string, arg interface{}) (sql.Result, error)
  • func (w *Writer) NamedExecContext(ctx context.Context, query string, arg interface{}) (sql.Result, error)
  • func (w *Writer) Prepare(query string) (*sql.Stmt, error)
  • func (w *Writer) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)

Types

type Database

type Database struct {
	Primaries   *Writer
	Secondaries *Reader
}

type Reader

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

Writer is the writer implementation of ReadQuerierX, hence the ReadQuerier

func (*Reader) Get

func (r *Reader) Get(dest interface{}, query string, args ...interface{}) error

Get implements db.ReadQuerierX

func (*Reader) GetContext

func (r *Reader) GetContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error

GetContext implements db.ReadQuerierX

func (*Reader) NamedQuery

func (r *Reader) NamedQuery(query string, arg interface{}) (*sqlx.Rows, error)

NamedQuery implements db.ReadQuerierX

func (*Reader) NamedQueryContext

func (r *Reader) NamedQueryContext(ctx context.Context, query string, arg interface{}) (*sqlx.Rows, error)

NamedQueryContext implements db.ReadQuerierX

func (*Reader) Prepare

func (r *Reader) Prepare(query string) (*sql.Stmt, error)

Prepare implements db.ReadQuerierX

func (*Reader) PrepareContext

func (r *Reader) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)

PrepareContext implements db.ReadQuerierX

func (*Reader) PrepareNamed

func (r *Reader) PrepareNamed(query string) (*sqlx.NamedStmt, error)

PrepareNamed implements db.ReadQuerierX

func (*Reader) PrepareNamedContext

func (r *Reader) PrepareNamedContext(ctx context.Context, query string) (*sqlx.NamedStmt, error)

PrepareNamedContext implements db.ReadQuerierX

func (*Reader) Preparex

func (r *Reader) Preparex(query string) (*sqlx.Stmt, error)

Preparex implements db.ReadQuerierX

func (*Reader) PreparexContext

func (r *Reader) PreparexContext(ctx context.Context, query string) (*sqlx.Stmt, error)

PreparexContext implements db.ReadQuerierX

func (*Reader) Query

func (r *Reader) Query(query string, args ...any) (*sql.Rows, error)

Query implements db.ReadQuerierX

func (*Reader) QueryContext

func (r *Reader) QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)

QueryContext implements db.ReadQuerierX

func (*Reader) QueryRow

func (r *Reader) QueryRow(query string, args ...any) *sql.Row

QueryRow implements db.ReadQuerierX

func (*Reader) QueryRowContext

func (r *Reader) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row

QueryRowContext implements db.ReadQuerierX

func (*Reader) QueryRowx

func (r *Reader) QueryRowx(query string, args ...interface{}) *sqlx.Row

QueryRowx implements db.ReadQuerierX

func (*Reader) QueryRowxContext

func (r *Reader) QueryRowxContext(ctx context.Context, query string, args ...interface{}) *sqlx.Row

QueryRowxContext implements db.ReadQuerierX

func (*Reader) Queryx

func (r *Reader) Queryx(query string, args ...interface{}) (*sqlx.Rows, error)

Queryx implements db.ReadQuerierX

func (*Reader) QueryxContext

func (r *Reader) QueryxContext(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)

QueryxContext implements db.ReadQuerierX

func (*Reader) Select

func (r *Reader) Select(dest interface{}, query string, args ...interface{}) error

Select implements db.ReadQuerierX

func (*Reader) SelectContext

func (r *Reader) SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error

SelectContext implements db.ReadQuerierX

type Writer

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

Writer is the writer implementation of WriteQuerierX, hence the WriteQuerier

func (*Writer) Begin

func (w *Writer) Begin() (*sql.Tx, error)

Begin implements db.WriteQuerierX

func (*Writer) BeginTx

func (w *Writer) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

BeginTx implements db.WriteQuerierX

func (*Writer) BeginTxx

func (w *Writer) BeginTxx(ctx context.Context, opts *sql.TxOptions) (*sqlx.Tx, error)

BeginTxx implements db.WriteQuerierX

func (*Writer) Beginx

func (w *Writer) Beginx() (*sqlx.Tx, error)

Beginx implements db.WriteQuerierX

func (*Writer) Exec

func (w *Writer) Exec(query string, args ...any) (sql.Result, error)

Exec implements db.WriteQuerierX

func (*Writer) ExecContext

func (w *Writer) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)

ExecContext implements db.WriteQuerierX

func (*Writer) MustBegin

func (w *Writer) MustBegin() *sqlx.Tx

MustBegin implements db.WriteQuerierX

func (*Writer) MustBeginTx

func (w *Writer) MustBeginTx(ctx context.Context, opts *sql.TxOptions) *sqlx.Tx

MustBeginTx implements db.WriteQuerierX

func (*Writer) MustExec

func (w *Writer) MustExec(query string, args ...interface{}) sql.Result

MustExec implements db.WriteQuerierX

func (*Writer) MustExecContext

func (w *Writer) MustExecContext(ctx context.Context, query string, args ...interface{}) sql.Result

MustExecContext implements db.WriteQuerierX

func (*Writer) NamedExec

func (w *Writer) NamedExec(query string, arg interface{}) (sql.Result, error)

NamedExec implements db.WriteQuerierX

func (*Writer) NamedExecContext

func (w *Writer) NamedExecContext(ctx context.Context, query string, arg interface{}) (sql.Result, error)

NamedExecContext implements db.WriteQuerierX

func (*Writer) Prepare

func (w *Writer) Prepare(query string) (*sql.Stmt, error)

Prepare implements db.WriteQuerierX

func (*Writer) PrepareContext

func (w *Writer) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)

PrepareContext implements db.WriteQuerierX