bundb

Documentation

Index

• func NewBunDBService(ctx context.Context, state *state.State) (db.DB, error)
• type DBService
  • func (dbService *DBService) DB() *bun.DB
• type PostgreSQLConn
  • func (c *PostgreSQLConn) Begin() (driver.Tx, error)
  • func (c *PostgreSQLConn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)
  • func (c *PostgreSQLConn) Close() error
  • func (c *PostgreSQLConn) Exec(query string, args []driver.Value) (driver.Result, error)
  • func (c *PostgreSQLConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)
  • func (c *PostgreSQLConn) Prepare(query string) (driver.Stmt, error)
  • func (c *PostgreSQLConn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)
  • func (c *PostgreSQLConn) Query(query string, args []driver.Value) (driver.Rows, error)
  • func (c *PostgreSQLConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)
• type PostgreSQLDriver
  • func (d *PostgreSQLDriver) Open(name string) (driver.Conn, error)
• type PostgreSQLStmt
  • func (stmt *PostgreSQLStmt) Exec(args []driver.Value) (driver.Result, error)
  • func (stmt *PostgreSQLStmt) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error)
  • func (stmt *PostgreSQLStmt) Query(args []driver.Value) (driver.Rows, error)
  • func (stmt *PostgreSQLStmt) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error)
• type PostgreSQLTx
  • func (tx *PostgreSQLTx) Commit() error
  • func (tx *PostgreSQLTx) Rollback() error
• type SQLiteConn
  • func (c *SQLiteConn) Begin() (driver.Tx, error)
  • func (c *SQLiteConn) BeginTx(ctx context.Context, opts driver.TxOptions) (tx driver.Tx, err error)
  • func (c *SQLiteConn) Close() error
  • func (c *SQLiteConn) Exec(query string, args []driver.Value) (driver.Result, error)
  • func (c *SQLiteConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (result driver.Result, err error)
  • func (c *SQLiteConn) Prepare(query string) (driver.Stmt, error)
  • func (c *SQLiteConn) PrepareContext(ctx context.Context, query string) (st driver.Stmt, err error)
  • func (c *SQLiteConn) Query(query string, args []driver.Value) (driver.Rows, error)
  • func (c *SQLiteConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (rows driver.Rows, err error)
• type SQLiteDriver
  • func (d *SQLiteDriver) Open(name string) (driver.Conn, error)
• type SQLiteStmt
  • func (stmt *SQLiteStmt) Exec(args []driver.Value) (driver.Result, error)
  • func (stmt *SQLiteStmt) ExecContext(ctx context.Context, args []driver.NamedValue) (res driver.Result, err error)
  • func (stmt *SQLiteStmt) Query(args []driver.Value) (driver.Rows, error)
  • func (stmt *SQLiteStmt) QueryContext(ctx context.Context, args []driver.NamedValue) (rows driver.Rows, err error)
• type SQLiteTx
  • func (tx *SQLiteTx) Commit() (err error)
  • func (tx *SQLiteTx) Rollback() (err error)
• type UpsertQuery
  • func NewUpsert(idb bun.IDB) *UpsertQuery
  • func (u *UpsertQuery) Column(columns ...string) *UpsertQuery
  • func (u *UpsertQuery) Constraint(constraints ...string) *UpsertQuery
  • func (u *UpsertQuery) Exec(ctx context.Context, dest ...interface{}) (sql.Result, error)
  • func (u *UpsertQuery) Model(model interface{}) *UpsertQuery
  • func (u *UpsertQuery) Scan(ctx context.Context, dest ...interface{}) error

Functions

func NewBunDBService

func NewBunDBService(ctx context.Context, state *state.State) (db.DB, error)

NewBunDBService returns a bunDB derived from the provided config, which implements the go-fed DB interface. Under the hood, it uses https://github.com/uptrace/bun to create and maintain a database connection.

Types

type DBService

type DBService struct {
	db.Account
	db.Admin
	db.Application
	db.Basic
	db.Domain
	db.Emoji
	db.HeaderFilter
	db.Instance
	db.Filter
	db.List
	db.Marker
	db.Media
	db.Mention
	db.Move
	db.Notification
	db.Poll
	db.Relationship
	db.Report
	db.Rule
	db.Search
	db.Session
	db.Status
	db.StatusBookmark
	db.StatusFave
	db.Tag
	db.Thread
	db.Timeline
	db.User
	db.Tombstone
	// contains filtered or unexported fields
}

DBService satisfies the DB interface

func (*DBService) DB

func (dbService *DBService) DB() *bun.DB

GetDB returns the underlying database connection pool. Should only be used in testing + exceptional circumstance.

type PostgreSQLConn

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

func (*PostgreSQLConn) Begin

func (c *PostgreSQLConn) Begin() (driver.Tx, error)

func (*PostgreSQLConn) BeginTx

func (c *PostgreSQLConn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)

func (*PostgreSQLConn) Close

func (c *PostgreSQLConn) Close() error

func (*PostgreSQLConn) Exec

func (c *PostgreSQLConn) Exec(query string, args []driver.Value) (driver.Result, error)

func (*PostgreSQLConn) ExecContext

func (c *PostgreSQLConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

func (*PostgreSQLConn) Prepare

func (c *PostgreSQLConn) Prepare(query string) (driver.Stmt, error)

func (*PostgreSQLConn) PrepareContext

func (c *PostgreSQLConn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

func (*PostgreSQLConn) Query

func (c *PostgreSQLConn) Query(query string, args []driver.Value) (driver.Rows, error)

func (*PostgreSQLConn) QueryContext

func (c *PostgreSQLConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

type PostgreSQLDriver

type PostgreSQLDriver struct{}

PostgreSQLDriver is our own wrapper around the pgx/stdlib.Driver{} type in order to wrap further SQL driver types with our own err processing.

func (*PostgreSQLDriver) Open

func (d *PostgreSQLDriver) Open(name string) (driver.Conn, error)

type PostgreSQLStmt

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

func (*PostgreSQLStmt) Exec

func (stmt *PostgreSQLStmt) Exec(args []driver.Value) (driver.Result, error)

func (*PostgreSQLStmt) ExecContext

func (stmt *PostgreSQLStmt) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error)

func (*PostgreSQLStmt) Query

func (stmt *PostgreSQLStmt) Query(args []driver.Value) (driver.Rows, error)

func (*PostgreSQLStmt) QueryContext

func (stmt *PostgreSQLStmt) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error)

type PostgreSQLTx

type PostgreSQLTx struct{ driver.Tx }

func (*PostgreSQLTx) Commit

func (tx *PostgreSQLTx) Commit() error

func (*PostgreSQLTx) Rollback

func (tx *PostgreSQLTx) Rollback() error

type SQLiteConn

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

func (*SQLiteConn) Begin

func (c *SQLiteConn) Begin() (driver.Tx, error)

func (*SQLiteConn) BeginTx

func (c *SQLiteConn) BeginTx(ctx context.Context, opts driver.TxOptions) (tx driver.Tx, err error)

func (*SQLiteConn) Close

func (c *SQLiteConn) Close() error

func (*SQLiteConn) Exec

func (c *SQLiteConn) Exec(query string, args []driver.Value) (driver.Result, error)

func (*SQLiteConn) ExecContext

func (c *SQLiteConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (result driver.Result, err error)

func (*SQLiteConn) Prepare

func (c *SQLiteConn) Prepare(query string) (driver.Stmt, error)

func (*SQLiteConn) PrepareContext

func (c *SQLiteConn) PrepareContext(ctx context.Context, query string) (st driver.Stmt, err error)

func (*SQLiteConn) Query

func (c *SQLiteConn) Query(query string, args []driver.Value) (driver.Rows, error)

func (*SQLiteConn) QueryContext

func (c *SQLiteConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (rows driver.Rows, err error)

type SQLiteDriver

type SQLiteDriver struct{}

SQLiteDriver is our own wrapper around the sqlite.Driver{} type in order to wrap further SQL driver types with our own functionality, e.g. hooks, retries and err processing.

func (*SQLiteDriver) Open

func (d *SQLiteDriver) Open(name string) (driver.Conn, error)

type SQLiteStmt

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

func (*SQLiteStmt) Exec

func (stmt *SQLiteStmt) Exec(args []driver.Value) (driver.Result, error)

func (*SQLiteStmt) ExecContext

func (stmt *SQLiteStmt) ExecContext(ctx context.Context, args []driver.NamedValue) (res driver.Result, err error)

func (*SQLiteStmt) Query

func (stmt *SQLiteStmt) Query(args []driver.Value) (driver.Rows, error)

func (*SQLiteStmt) QueryContext

func (stmt *SQLiteStmt) QueryContext(ctx context.Context, args []driver.NamedValue) (rows driver.Rows, err error)

type SQLiteTx

type SQLiteTx struct {
	context.Context
	driver.Tx
}

func (*SQLiteTx) Commit

func (tx *SQLiteTx) Commit() (err error)

func (*SQLiteTx) Rollback

func (tx *SQLiteTx) Rollback() (err error)

type UpsertQuery

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

UpsertQuery is a wrapper around an insert query that can update if an insert fails. Doesn't implement the full set of Bun query methods, but we can add more if we need them. See https://bun.uptrace.dev/guide/query-insert.html#upsert

func NewUpsert

func NewUpsert(idb bun.IDB) *UpsertQuery

func (*UpsertQuery) Column

func (u *UpsertQuery) Column(columns ...string) *UpsertQuery

Column sets the columns to update if an insert does't happen. If empty, all columns not being used for constraints will be updated. Cannot overlap with Constraint.

func (*UpsertQuery) Constraint

func (u *UpsertQuery) Constraint(constraints ...string) *UpsertQuery

Constraint sets the columns or indexes that are used to check for conflicts. This is required.

func (*UpsertQuery) Exec

func (u *UpsertQuery) Exec(ctx context.Context, dest ...interface{}) (sql.Result, error)

Exec builds a Bun insert query from the upsert query, and executes it.

func (*UpsertQuery) Model

func (u *UpsertQuery) Model(model interface{}) *UpsertQuery

Model sets the model or models to upsert.

func (*UpsertQuery) Scan

func (u *UpsertQuery) Scan(ctx context.Context, dest ...interface{}) error

Scan builds a Bun insert query from the upsert query, and scans it.