database

package

v1.0.0 Latest Latest Go to latest Published: Nov 21, 2025 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Pool manages database connections

func NewPool(cfg *config.DatabaseConfig) (*Pool, error)

NewPool creates a new database connection pool

func (p *Pool) Begin(ctx context.Context) (*sql.Tx, error)

Begin starts a new transaction

func (p *Pool) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

BeginTx starts a new transaction with options

func (p *Pool) Close() error

Close closes all connections in the pool

func (p *Pool) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

Exec executes a query without returning rows

func (p *Pool) GetDB() *sql.DB

GetDB returns the underlying *sql.DB (use with caution)

func (p *Pool) Health(ctx context.Context) error

Health checks database health

func (p *Pool) Ping(ctx context.Context) error

Ping checks if the database is reachable

func (p *Pool) Query(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

Query executes a SELECT query

func (p *Pool) QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row

QueryRow executes a query that returns at most one row

func (p *Pool) Stats() sql.DBStats

Stats returns database statistics