bundb

Apr 10, 2024

Changes in this version

+ type UpsertQuery struct

+ 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

Mar 4, 2024

Changes in this version

+ type PostgreSQLConn struct

+ 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 struct

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

+ type PostgreSQLStmt struct

+ 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 struct

+ func (tx *PostgreSQLTx) Commit() error

+ func (tx *PostgreSQLTx) Rollback() error

+ type SQLiteConn struct

+ 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 struct

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

+ type SQLiteStmt struct

+ 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 struct

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

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

Oct 18, 2023

Changes in this version

+ type Tx struct

+ func (tx Tx) Commit() (err error)

+ func (tx Tx) Dialect() schema.Dialect

+ func (tx Tx) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (tx Tx) NewAddColumn() *bun.AddColumnQuery

+ func (tx Tx) NewCreateIndex() *bun.CreateIndexQuery

+ func (tx Tx) NewCreateTable() *bun.CreateTableQuery

+ func (tx Tx) NewDelete() *bun.DeleteQuery

+ func (tx Tx) NewDropColumn() *bun.DropColumnQuery

+ func (tx Tx) NewDropIndex() *bun.DropIndexQuery

+ func (tx Tx) NewDropTable() *bun.DropTableQuery

+ func (tx Tx) NewInsert() *bun.InsertQuery

+ func (tx Tx) NewMerge() *bun.MergeQuery

+ func (tx Tx) NewRaw(query string, args ...interface{}) *bun.RawQuery

+ func (tx Tx) NewSelect() *bun.SelectQuery

+ func (tx Tx) NewTruncateTable() *bun.TruncateTableQuery

+ func (tx Tx) NewUpdate() *bun.UpdateQuery

+ func (tx Tx) NewValues(model interface{}) *bun.ValuesQuery

+ func (tx Tx) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (tx Tx) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (tx Tx) Rollback() (err error)

Aug 21, 2023

Changes in this version

+ type DB struct

+ func (db *DB) AddQueryHook(hook bun.QueryHook)

+ func (db *DB) BeginTx(ctx context.Context, opts *sql.TxOptions) (tx bun.Tx, err error)

+ func (db *DB) Close() error

+ func (db *DB) Dialect() schema.Dialect

+ func (db *DB) ExecContext(ctx context.Context, query string, args ...any) (result sql.Result, err error)

+ func (db *DB) Exists(ctx context.Context, query *bun.SelectQuery) (bool, error)

+ func (db *DB) NewAddColumn() *bun.AddColumnQuery

+ func (db *DB) NewCreateIndex() *bun.CreateIndexQuery

+ func (db *DB) NewCreateTable() *bun.CreateTableQuery

+ func (db *DB) NewDelete() *bun.DeleteQuery

+ func (db *DB) NewDropColumn() *bun.DropColumnQuery

+ func (db *DB) NewDropIndex() *bun.DropIndexQuery

+ func (db *DB) NewDropTable() *bun.DropTableQuery

+ func (db *DB) NewInsert() *bun.InsertQuery

+ func (db *DB) NewMerge() *bun.MergeQuery

+ func (db *DB) NewRaw(query string, args ...interface{}) *bun.RawQuery

+ func (db *DB) NewSelect() *bun.SelectQuery

+ func (db *DB) NewTruncateTable() *bun.TruncateTableQuery

+ func (db *DB) NewUpdate() *bun.UpdateQuery

+ func (db *DB) NewValues(model interface{}) *bun.ValuesQuery

+ func (db *DB) NotExists(ctx context.Context, query *bun.SelectQuery) (bool, error)

+ func (db *DB) PingContext(ctx context.Context) error

+ func (db *DB) QueryContext(ctx context.Context, query string, args ...any) (rows *sql.Rows, err error)

+ func (db *DB) QueryRowContext(ctx context.Context, query string, args ...any) (row *sql.Row)

+ func (db *DB) RegisterModel(models ...any)

+ func (db *DB) RunInTx(ctx context.Context, fn func(bun.Tx) error) error

Aug 14, 2023

Changes in this version

type DBService

+ func (dbService *DBService) DB() *WrappedDB

+ type WrappedDB struct

+ func WrapDB(db *bun.DB) *WrappedDB

+ func (db *WrappedDB) BeginTx(ctx context.Context, opts *sql.TxOptions) (tx bun.Tx, err error)

+ func (db *WrappedDB) ExecContext(ctx context.Context, query string, args ...any) (result sql.Result, err error)

+ func (db *WrappedDB) Exists(ctx context.Context, query *bun.SelectQuery) (bool, error)

+ func (db *WrappedDB) NewAddColumn() *bun.AddColumnQuery

+ func (db *WrappedDB) NewCreateIndex() *bun.CreateIndexQuery

+ func (db *WrappedDB) NewCreateTable() *bun.CreateTableQuery

+ func (db *WrappedDB) NewDelete() *bun.DeleteQuery

+ func (db *WrappedDB) NewDropColumn() *bun.DropColumnQuery

+ func (db *WrappedDB) NewDropIndex() *bun.DropIndexQuery

+ func (db *WrappedDB) NewDropTable() *bun.DropTableQuery

+ func (db *WrappedDB) NewInsert() *bun.InsertQuery

+ func (db *WrappedDB) NewMerge() *bun.MergeQuery

+ func (db *WrappedDB) NewRaw(query string, args ...interface{}) *bun.RawQuery

+ func (db *WrappedDB) NewSelect() *bun.SelectQuery

+ func (db *WrappedDB) NewTruncateTable() *bun.TruncateTableQuery

+ func (db *WrappedDB) NewUpdate() *bun.UpdateQuery

+ func (db *WrappedDB) NewValues(model interface{}) *bun.ValuesQuery

+ func (db *WrappedDB) NotExists(ctx context.Context, query *bun.SelectQuery) (bool, error)

+ func (db *WrappedDB) ProcessError(err error) error

+ func (db *WrappedDB) QueryContext(ctx context.Context, query string, args ...any) (rows *sql.Rows, err error)

+ func (db *WrappedDB) QueryRowContext(ctx context.Context, query string, args ...any) (row *sql.Row)

+ func (db *WrappedDB) RunInTx(ctx context.Context, fn func(bun.Tx) error) error

Feb 16, 2023

Changes in this version

type DBService

+ func (dbService *DBService) TagStringToTag(ctx context.Context, t string, originAccountID string) (*gtsmodel.Tag, error)

Sep 27, 2022

Changes in this version

+ type DBService struct

+ func (dbService *DBService) GetConn() *DBConn

+ func (dbService *DBService) TagStringsToTags(ctx context.Context, tags []string, originAccountID string) ([]*gtsmodel.Tag, error)

Nov 13, 2021

Changes in this version

+ func NewBunDBService(ctx context.Context, c *config.Config) (db.DB, error)

+ type DBConn struct

+ func WrapDBConn(dbConn *bun.DB) *DBConn

+ func (conn *DBConn) Exists(ctx context.Context, query *bun.SelectQuery) (bool, db.Error)

+ func (conn *DBConn) NotExists(ctx context.Context, query *bun.SelectQuery) (bool, db.Error)

+ func (conn *DBConn) ProcessError(err error) db.Error

+ func (conn *DBConn) RunInTx(ctx context.Context, fn func(bun.Tx) error) db.Error