postgresql

Dec 5, 2025

Changes in this version

type Connection

+ func (c *Connection) MigrationTable() string

Sep 11, 2025

Changes in this version

+ type Statement struct

+ func (s *Statement) Close() error

+ func (s *Statement) Exec(ctx context.Context, args ...interface{}) (sql.Result, error)

+ func (s *Statement) Query(ctx context.Context, args ...interface{}) (*sql.Rows, error)

+ func (s *Statement) QueryRow(ctx context.Context, args ...interface{}) *sql.Row

+ type Transaction struct

+ func (t *Transaction) Commit() error

+ func (t *Transaction) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (t *Transaction) Prepare(ctx context.Context, query string) (database.Statement, error)

+ func (t *Transaction) Query(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (t *Transaction) QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (t *Transaction) Rollback() error

Sep 11, 2025

Changes in this version

+ func NewConnection(cfg *config.DatabaseConfig, log logger.Logger) (database.Interface, error)

+ type Connection struct

+ func (c *Connection) Begin(ctx context.Context) (*sql.Tx, error)

+ func (c *Connection) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

+ func (c *Connection) Close() error

+ func (c *Connection) CreateMigrationTable(ctx context.Context) error

+ func (c *Connection) DatabaseType() string

+ func (c *Connection) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (c *Connection) GetMigrationTable() string

+ func (c *Connection) Health(ctx context.Context) error

+ func (c *Connection) Prepare(ctx context.Context, query string) (*sql.Stmt, error)

+ func (c *Connection) Query(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (c *Connection) QueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (c *Connection) Stats() (map[string]interface{}, error)