database

Dec 17, 2025

Changes in this version

type BunSelectQuery

+ func (b *BunSelectQuery) OrderExpr(order string, args ...interface{}) common.SelectQuery

type GormSelectQuery

+ func (g *GormSelectQuery) OrderExpr(order string, args ...interface{}) common.SelectQuery

type PgSQLSelectQuery

+ func (p *PgSQLSelectQuery) OrderExpr(order string, args ...interface{}) common.SelectQuery

Dec 12, 2025

Changes in this version

type BunAdapter

+ func (b *BunAdapter) GetUnderlyingDB() interface{}

type BunTxAdapter

+ func (b *BunTxAdapter) GetUnderlyingDB() interface{}

type GormAdapter

+ func (g *GormAdapter) GetUnderlyingDB() interface{}

type PgSQLAdapter

+ func (p *PgSQLAdapter) GetUnderlyingDB() interface{}

type PgSQLTxAdapter

+ func (p *PgSQLTxAdapter) GetUnderlyingDB() interface{}

Dec 11, 2025

Changes in this version

+ func ExampleCompleteWorkflow() error

+ func ExampleJoinRelation() error

+ func ExamplePgSQLAdapter() error

+ func ExamplePreload() error

+ func ExamplePreloadRelation() error

+ func ExampleScanModel() error

+ func ExampleWithModel() error

+ type Author struct

+ Email string

+ ID int

+ Name string

+ Posts []*Post

+ func (a Author) TableName() string

+ type Comment struct

+ Content string

+ ID int

+ Post *Post

+ PostID int

+ func (c Comment) TableName() string

+ type PgSQLAdapter struct

+ func NewPgSQLAdapter(db *sql.DB) *PgSQLAdapter

+ func (p *PgSQLAdapter) BeginTx(ctx context.Context) (common.Database, error)

+ func (p *PgSQLAdapter) CommitTx(ctx context.Context) error

+ func (p *PgSQLAdapter) EnableQueryDebug()

+ func (p *PgSQLAdapter) Exec(ctx context.Context, query string, args ...interface{}) (res common.Result, err error)

+ func (p *PgSQLAdapter) NewDelete() common.DeleteQuery

+ func (p *PgSQLAdapter) NewInsert() common.InsertQuery

+ func (p *PgSQLAdapter) NewSelect() common.SelectQuery

+ func (p *PgSQLAdapter) NewUpdate() common.UpdateQuery

+ func (p *PgSQLAdapter) Query(ctx context.Context, dest interface{}, query string, args ...interface{}) (err error)

+ func (p *PgSQLAdapter) RollbackTx(ctx context.Context) error

+ func (p *PgSQLAdapter) RunInTransaction(ctx context.Context, fn func(common.Database) error) (err error)

+ type PgSQLDeleteQuery struct

+ func (p *PgSQLDeleteQuery) Exec(ctx context.Context) (res common.Result, err error)

+ func (p *PgSQLDeleteQuery) Model(model interface{}) common.DeleteQuery

+ func (p *PgSQLDeleteQuery) Table(table string) common.DeleteQuery

+ func (p *PgSQLDeleteQuery) Where(query string, args ...interface{}) common.DeleteQuery

+ type PgSQLInsertQuery struct

+ func (p *PgSQLInsertQuery) Exec(ctx context.Context) (res common.Result, err error)

+ func (p *PgSQLInsertQuery) Model(model interface{}) common.InsertQuery

+ func (p *PgSQLInsertQuery) OnConflict(action string) common.InsertQuery

+ func (p *PgSQLInsertQuery) Returning(columns ...string) common.InsertQuery

+ func (p *PgSQLInsertQuery) Table(table string) common.InsertQuery

+ func (p *PgSQLInsertQuery) Value(column string, value interface{}) common.InsertQuery

+ type PgSQLResult struct

+ func (p *PgSQLResult) LastInsertId() (int64, error)

+ func (p *PgSQLResult) RowsAffected() int64

+ type PgSQLSelectQuery struct

+ func (p *PgSQLSelectQuery) Column(columns ...string) common.SelectQuery

+ func (p *PgSQLSelectQuery) ColumnExpr(query string, args ...interface{}) common.SelectQuery

+ func (p *PgSQLSelectQuery) Count(ctx context.Context) (count int, err error)

+ func (p *PgSQLSelectQuery) Exists(ctx context.Context) (exists bool, err error)

+ func (p *PgSQLSelectQuery) Group(group string) common.SelectQuery

+ func (p *PgSQLSelectQuery) Having(having string, args ...interface{}) common.SelectQuery

+ func (p *PgSQLSelectQuery) Join(query string, args ...interface{}) common.SelectQuery

+ func (p *PgSQLSelectQuery) JoinRelation(relation string, apply ...func(common.SelectQuery) common.SelectQuery) common.SelectQuery

+ func (p *PgSQLSelectQuery) LeftJoin(query string, args ...interface{}) common.SelectQuery

+ func (p *PgSQLSelectQuery) Limit(n int) common.SelectQuery

+ func (p *PgSQLSelectQuery) Model(model interface{}) common.SelectQuery

+ func (p *PgSQLSelectQuery) Offset(n int) common.SelectQuery

+ func (p *PgSQLSelectQuery) Order(order string) common.SelectQuery

+ func (p *PgSQLSelectQuery) Preload(relation string, conditions ...interface{}) common.SelectQuery

+ func (p *PgSQLSelectQuery) PreloadRelation(relation string, apply ...func(common.SelectQuery) common.SelectQuery) common.SelectQuery

+ func (p *PgSQLSelectQuery) Scan(ctx context.Context, dest interface{}) (err error)

+ func (p *PgSQLSelectQuery) ScanModel(ctx context.Context) error

+ func (p *PgSQLSelectQuery) Table(table string) common.SelectQuery

+ func (p *PgSQLSelectQuery) Where(query string, args ...interface{}) common.SelectQuery

+ func (p *PgSQLSelectQuery) WhereOr(query string, args ...interface{}) common.SelectQuery

+ type PgSQLTxAdapter struct

+ func (p *PgSQLTxAdapter) BeginTx(ctx context.Context) (common.Database, error)

+ func (p *PgSQLTxAdapter) CommitTx(ctx context.Context) error

+ func (p *PgSQLTxAdapter) Exec(ctx context.Context, query string, args ...interface{}) (common.Result, error)

+ func (p *PgSQLTxAdapter) NewDelete() common.DeleteQuery

+ func (p *PgSQLTxAdapter) NewInsert() common.InsertQuery

+ func (p *PgSQLTxAdapter) NewSelect() common.SelectQuery

+ func (p *PgSQLTxAdapter) NewUpdate() common.UpdateQuery

+ func (p *PgSQLTxAdapter) Query(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (p *PgSQLTxAdapter) RollbackTx(ctx context.Context) error

+ func (p *PgSQLTxAdapter) RunInTransaction(ctx context.Context, fn func(common.Database) error) error

+ type PgSQLUpdateQuery struct

+ func (p *PgSQLUpdateQuery) Exec(ctx context.Context) (res common.Result, err error)

+ func (p *PgSQLUpdateQuery) Model(model interface{}) common.UpdateQuery

+ func (p *PgSQLUpdateQuery) Returning(columns ...string) common.UpdateQuery

+ func (p *PgSQLUpdateQuery) Set(column string, value interface{}) common.UpdateQuery

+ func (p *PgSQLUpdateQuery) SetMap(values map[string]interface{}) common.UpdateQuery

+ func (p *PgSQLUpdateQuery) Table(table string) common.UpdateQuery

+ func (p *PgSQLUpdateQuery) Where(query string, args ...interface{}) common.UpdateQuery

+ type Post struct

+ Author *Author

+ AuthorID int

+ Comments []*Comment

+ Content string

+ ID int

+ Title string

+ func (p Post) TableName() string

+ type TestHelper struct

+ Adapter *PgSQLAdapter

+ DB *sql.DB

+ func NewTestHelper(t *testing.T, db *sql.DB) *TestHelper

+ func (h *TestHelper) AssertUserCount(expected int)

+ func (h *TestHelper) AssertUserExists(email string)

+ func (h *TestHelper) BeginTestTransaction() (*PgSQLTxAdapter, func())

+ func (h *TestHelper) CleanupTables()

+ func (h *TestHelper) GetUserByEmail(email string) map[string]interface{}

+ func (h *TestHelper) InsertComment(postID int, content string) int

+ func (h *TestHelper) InsertPost(userID int, title, content string, published bool) int

+ func (h *TestHelper) InsertUser(name, email string, age int) int

+ type User struct

+ Age int

+ Email string

+ ID int

+ Name string

+ func (u User) TableName() string

Dec 10, 2025

Changes in this version

type BunAdapter

+ func (b *BunAdapter) EnableDetailedScanDebug()

Dec 9, 2025

Changes in this version

type BunSelectQuery

+ func (b *BunSelectQuery) JoinRelation(relation string, apply ...func(common.SelectQuery) common.SelectQuery) common.SelectQuery

type GormSelectQuery

+ func (g *GormSelectQuery) JoinRelation(relation string, apply ...func(common.SelectQuery) common.SelectQuery) common.SelectQuery

Dec 9, 2025

Changes in this version

type BunAdapter

+ func (b *BunAdapter) DisableQueryDebug()

+ func (b *BunAdapter) EnableQueryDebug()

type GormAdapter

+ func (g *GormAdapter) DisableQueryDebug() *GormAdapter

+ func (g *GormAdapter) EnableQueryDebug() *GormAdapter

+ type QueryDebugHook struct

+ func (h *QueryDebugHook) AfterQuery(ctx context.Context, event *bun.QueryEvent)

+ func (h *QueryDebugHook) BeforeQuery(ctx context.Context, event *bun.QueryEvent) context.Context

Nov 11, 2025

Changes in this version

type BunSelectQuery

+ func (b *BunSelectQuery) PreloadRelation(relation string, apply ...func(common.SelectQuery) common.SelectQuery) common.SelectQuery

type GormSelectQuery

+ func (g *GormSelectQuery) PreloadRelation(relation string, apply ...func(common.SelectQuery) common.SelectQuery) common.SelectQuery

Nov 11, 2025

Changes in this version

type BunSelectQuery

+ func (b *BunSelectQuery) ColumnExpr(query string, args ...interface{}) common.SelectQuery

type GormSelectQuery

+ func (g *GormSelectQuery) ColumnExpr(query string, args ...interface{}) common.SelectQuery

Nov 11, 2025

Changes in this version

type BunSelectQuery

+ func (b *BunSelectQuery) ScanModel(ctx context.Context) error

type GormSelectQuery

+ func (g *GormSelectQuery) ScanModel(ctx context.Context) error

Nov 10, 2025

Changes in this version

+ func GetModelColumns(model any) []string

+ func GetPrimaryKeyName(model any) string

+ type BunAdapter struct

+ func NewBunAdapter(db *bun.DB) *BunAdapter

+ func (b *BunAdapter) BeginTx(ctx context.Context) (common.Database, error)

+ func (b *BunAdapter) CommitTx(ctx context.Context) error

+ func (b *BunAdapter) Exec(ctx context.Context, query string, args ...interface{}) (common.Result, error)

+ func (b *BunAdapter) NewDelete() common.DeleteQuery

+ func (b *BunAdapter) NewInsert() common.InsertQuery

+ func (b *BunAdapter) NewSelect() common.SelectQuery

+ func (b *BunAdapter) NewUpdate() common.UpdateQuery

+ func (b *BunAdapter) Query(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (b *BunAdapter) RollbackTx(ctx context.Context) error

+ func (b *BunAdapter) RunInTransaction(ctx context.Context, fn func(common.Database) error) error

+ type BunDeleteQuery struct

+ func (b *BunDeleteQuery) Exec(ctx context.Context) (common.Result, error)

+ func (b *BunDeleteQuery) Model(model interface{}) common.DeleteQuery

+ func (b *BunDeleteQuery) Table(table string) common.DeleteQuery

+ func (b *BunDeleteQuery) Where(query string, args ...interface{}) common.DeleteQuery

+ type BunInsertQuery struct

+ func (b *BunInsertQuery) Exec(ctx context.Context) (common.Result, error)

+ func (b *BunInsertQuery) Model(model interface{}) common.InsertQuery

+ func (b *BunInsertQuery) OnConflict(action string) common.InsertQuery

+ func (b *BunInsertQuery) Returning(columns ...string) common.InsertQuery

+ func (b *BunInsertQuery) Table(table string) common.InsertQuery

+ func (b *BunInsertQuery) Value(column string, value interface{}) common.InsertQuery

+ type BunResult struct

+ func (b *BunResult) LastInsertId() (int64, error)

+ func (b *BunResult) RowsAffected() int64

+ type BunSelectQuery struct

+ func (b *BunSelectQuery) Column(columns ...string) common.SelectQuery

+ func (b *BunSelectQuery) Count(ctx context.Context) (int, error)

+ func (b *BunSelectQuery) Exists(ctx context.Context) (bool, error)

+ func (b *BunSelectQuery) Group(group string) common.SelectQuery

+ func (b *BunSelectQuery) Having(having string, args ...interface{}) common.SelectQuery

+ func (b *BunSelectQuery) Join(query string, args ...interface{}) common.SelectQuery

+ func (b *BunSelectQuery) LeftJoin(query string, args ...interface{}) common.SelectQuery

+ func (b *BunSelectQuery) Limit(n int) common.SelectQuery

+ func (b *BunSelectQuery) Model(model interface{}) common.SelectQuery

+ func (b *BunSelectQuery) Offset(n int) common.SelectQuery

+ func (b *BunSelectQuery) Order(order string) common.SelectQuery

+ func (b *BunSelectQuery) Preload(relation string, conditions ...interface{}) common.SelectQuery

+ func (b *BunSelectQuery) Scan(ctx context.Context, dest interface{}) error

+ func (b *BunSelectQuery) Table(table string) common.SelectQuery

+ func (b *BunSelectQuery) Where(query string, args ...interface{}) common.SelectQuery

+ func (b *BunSelectQuery) WhereOr(query string, args ...interface{}) common.SelectQuery

+ type BunTxAdapter struct

+ func (b *BunTxAdapter) BeginTx(ctx context.Context) (common.Database, error)

+ func (b *BunTxAdapter) CommitTx(ctx context.Context) error

+ func (b *BunTxAdapter) Exec(ctx context.Context, query string, args ...interface{}) (common.Result, error)

+ func (b *BunTxAdapter) NewDelete() common.DeleteQuery

+ func (b *BunTxAdapter) NewInsert() common.InsertQuery

+ func (b *BunTxAdapter) NewSelect() common.SelectQuery

+ func (b *BunTxAdapter) NewUpdate() common.UpdateQuery

+ func (b *BunTxAdapter) Query(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (b *BunTxAdapter) RollbackTx(ctx context.Context) error

+ func (b *BunTxAdapter) RunInTransaction(ctx context.Context, fn func(common.Database) error) error

+ type BunUpdateQuery struct

+ func (b *BunUpdateQuery) Exec(ctx context.Context) (common.Result, error)

+ func (b *BunUpdateQuery) Model(model interface{}) common.UpdateQuery

+ func (b *BunUpdateQuery) Returning(columns ...string) common.UpdateQuery

+ func (b *BunUpdateQuery) Set(column string, value interface{}) common.UpdateQuery

+ func (b *BunUpdateQuery) SetMap(values map[string]interface{}) common.UpdateQuery

+ func (b *BunUpdateQuery) Table(table string) common.UpdateQuery

+ func (b *BunUpdateQuery) Where(query string, args ...interface{}) common.UpdateQuery

+ type GormAdapter struct

+ func NewGormAdapter(db *gorm.DB) *GormAdapter

+ func (g *GormAdapter) BeginTx(ctx context.Context) (common.Database, error)

+ func (g *GormAdapter) CommitTx(ctx context.Context) error

+ func (g *GormAdapter) Exec(ctx context.Context, query string, args ...interface{}) (common.Result, error)

+ func (g *GormAdapter) NewDelete() common.DeleteQuery

+ func (g *GormAdapter) NewInsert() common.InsertQuery

+ func (g *GormAdapter) NewSelect() common.SelectQuery

+ func (g *GormAdapter) NewUpdate() common.UpdateQuery

+ func (g *GormAdapter) Query(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (g *GormAdapter) RollbackTx(ctx context.Context) error

+ func (g *GormAdapter) RunInTransaction(ctx context.Context, fn func(common.Database) error) error

+ type GormDeleteQuery struct

+ func (g *GormDeleteQuery) Exec(ctx context.Context) (common.Result, error)

+ func (g *GormDeleteQuery) Model(model interface{}) common.DeleteQuery

+ func (g *GormDeleteQuery) Table(table string) common.DeleteQuery

+ func (g *GormDeleteQuery) Where(query string, args ...interface{}) common.DeleteQuery

+ type GormInsertQuery struct

+ func (g *GormInsertQuery) Exec(ctx context.Context) (common.Result, error)

+ func (g *GormInsertQuery) Model(model interface{}) common.InsertQuery

+ func (g *GormInsertQuery) OnConflict(action string) common.InsertQuery

+ func (g *GormInsertQuery) Returning(columns ...string) common.InsertQuery

+ func (g *GormInsertQuery) Table(table string) common.InsertQuery

+ func (g *GormInsertQuery) Value(column string, value interface{}) common.InsertQuery

+ type GormResult struct

+ func (g *GormResult) LastInsertId() (int64, error)

+ func (g *GormResult) RowsAffected() int64

+ type GormSelectQuery struct

+ func (g *GormSelectQuery) Column(columns ...string) common.SelectQuery

+ func (g *GormSelectQuery) Count(ctx context.Context) (int, error)

+ func (g *GormSelectQuery) Exists(ctx context.Context) (bool, error)

+ func (g *GormSelectQuery) Group(group string) common.SelectQuery

+ func (g *GormSelectQuery) Having(having string, args ...interface{}) common.SelectQuery

+ func (g *GormSelectQuery) Join(query string, args ...interface{}) common.SelectQuery

+ func (g *GormSelectQuery) LeftJoin(query string, args ...interface{}) common.SelectQuery

+ func (g *GormSelectQuery) Limit(n int) common.SelectQuery

+ func (g *GormSelectQuery) Model(model interface{}) common.SelectQuery

+ func (g *GormSelectQuery) Offset(n int) common.SelectQuery

+ func (g *GormSelectQuery) Order(order string) common.SelectQuery

+ func (g *GormSelectQuery) Preload(relation string, conditions ...interface{}) common.SelectQuery

+ func (g *GormSelectQuery) Scan(ctx context.Context, dest interface{}) error

+ func (g *GormSelectQuery) Table(table string) common.SelectQuery

+ func (g *GormSelectQuery) Where(query string, args ...interface{}) common.SelectQuery

+ func (g *GormSelectQuery) WhereOr(query string, args ...interface{}) common.SelectQuery

+ type GormUpdateQuery struct

+ func (g *GormUpdateQuery) Exec(ctx context.Context) (common.Result, error)

+ func (g *GormUpdateQuery) Model(model interface{}) common.UpdateQuery

+ func (g *GormUpdateQuery) Returning(columns ...string) common.UpdateQuery

+ func (g *GormUpdateQuery) Set(column string, value interface{}) common.UpdateQuery

+ func (g *GormUpdateQuery) SetMap(values map[string]interface{}) common.UpdateQuery

+ func (g *GormUpdateQuery) Table(table string) common.UpdateQuery

+ func (g *GormUpdateQuery) Where(query string, args ...interface{}) common.UpdateQuery