Versions in this module Expand all Collapse all v0 v0.0.1 Jul 13, 2024 Changes in this version + type Connection interface + Exec func(ctx context.Context, query string, args ...interface{}) (sql.Result, error) + Get func(ctx context.Context, dest interface{}, query string, args ...interface{}) error + Prepare func(ctx context.Context, query string) (*sqlx.Stmt, error) + Query func(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error) + QueryRow func(ctx context.Context, query string, args ...interface{}) *sqlx.Row + Select func(ctx context.Context, dest interface{}, query string, args ...interface{}) error + type PgConnectionManager struct + func NewPgConnectionManager(connectionString string) (*PgConnectionManager, error) + func (cm *PgConnectionManager) CheckDatabaseHealth() error + func (cm *PgConnectionManager) Close() error + func (cm *PgConnectionManager) Query() *Query + func (cm *PgConnectionManager) Transaction() *Transaction + type Query struct + func NewQuery(db *sqlx.DB) *Query + func (q *Query) Close() error + func (q *Query) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error) + func (q *Query) Get(ctx context.Context, dest interface{}, query string, args ...interface{}) error + func (q *Query) Prepare(ctx context.Context, query string) (*sqlx.Stmt, error) + func (q *Query) Query(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error) + func (q *Query) QueryRow(ctx context.Context, query string, args ...interface{}) *sqlx.Row + func (q *Query) Select(ctx context.Context, dest interface{}, query string, args ...interface{}) error + type TX interface + Begin func(ctx context.Context) error + Commit func(ctx context.Context) error + Rollback func(ctx context.Context) error + type Transaction struct + func NewTransaction(db *sqlx.DB) *Transaction + func (t *Transaction) Begin(ctx context.Context) error + func (t *Transaction) Close() error + func (t *Transaction) Commit(ctx context.Context) error + func (t *Transaction) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error) + func (t *Transaction) Get(ctx context.Context, dest interface{}, query string, args ...interface{}) error + func (t *Transaction) Prepare(ctx context.Context, query string) (*sqlx.Stmt, error) + func (t *Transaction) Query(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error) + func (t *Transaction) QueryRow(ctx context.Context, query string, args ...interface{}) *sqlx.Row + func (t *Transaction) Rollback(ctx context.Context) error + func (t *Transaction) Select(ctx context.Context, dest interface{}, query string, args ...interface{}) error
Go to main page