postgresql

Documentation

Index

• func NewConnection(cfg *config.DatabaseConfig, log logger.Logger) (types.Interface, error)
• type Connection
  • func (c *Connection) Begin(ctx context.Context) (types.Tx, error)
  • func (c *Connection) BeginTx(ctx context.Context, opts *sql.TxOptions) (types.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 ...any) (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) (types.Statement, error)
  • func (c *Connection) Query(ctx context.Context, query string, args ...any) (*sql.Rows, error)
  • func (c *Connection) QueryRow(ctx context.Context, query string, args ...any) types.Row
  • func (c *Connection) Stats() (map[string]any, error)
• type Statement
  • func (s *Statement) Close() error
  • func (s *Statement) Exec(ctx context.Context, args ...any) (sql.Result, error)
  • func (s *Statement) Query(ctx context.Context, args ...any) (*sql.Rows, error)
  • func (s *Statement) QueryRow(ctx context.Context, args ...any) types.Row
• type Transaction
  • func (t *Transaction) Commit() error
  • func (t *Transaction) Exec(ctx context.Context, query string, args ...any) (sql.Result, error)
  • func (t *Transaction) Prepare(ctx context.Context, query string) (types.Statement, error)
  • func (t *Transaction) Query(ctx context.Context, query string, args ...any) (*sql.Rows, error)
  • func (t *Transaction) QueryRow(ctx context.Context, query string, args ...any) types.Row
  • func (t *Transaction) Rollback() error

Functions

func NewConnection

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

NewConnection creates and configures a PostgreSQL Connection using cfg and log. It validates cfg, builds or uses the provided DSN, sets pool options, ensures connectivity with a ping, logs success, and returns the wrapped Connection or an error.

Types

type Connection

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

Connection implements the types.Interface for PostgreSQL

func (*Connection) Begin

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

Begin starts a transaction

func (*Connection) BeginTx

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

BeginTx starts a transaction with options

func (*Connection) Close

func (c *Connection) Close() error

Close closes the database connection

func (*Connection) CreateMigrationTable

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

CreateMigrationTable creates the migration table if it doesn't exist

func (*Connection) DatabaseType

func (c *Connection) DatabaseType() string

DatabaseType returns the database type

func (*Connection) Exec

func (c *Connection) Exec(ctx context.Context, query string, args ...any) (sql.Result, error)

Exec executes a query without returning any rows

func (*Connection) GetMigrationTable

func (c *Connection) GetMigrationTable() string

GetMigrationTable returns the migration table name for PostgreSQL

func (*Connection) Health

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

Health checks database connectivity

func (*Connection) Prepare

func (c *Connection) Prepare(ctx context.Context, query string) (types.Statement, error)

Prepare creates a prepared statement for later queries or executions

func (*Connection) Query

func (c *Connection) Query(ctx context.Context, query string, args ...any) (*sql.Rows, error)

Query executes a query that returns rows

func (*Connection) QueryRow

func (c *Connection) QueryRow(ctx context.Context, query string, args ...any) types.Row

QueryRow executes a query that returns at most one row

func (*Connection) Stats

func (c *Connection) Stats() (map[string]any, error)

Stats returns database connection statistics

type Statement

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

Statement wraps sql.Stmt to implement types.Statement

func (*Statement) Close

func (s *Statement) Close() error

Close closes the prepared statement

func (*Statement) Exec

func (s *Statement) Exec(ctx context.Context, args ...any) (sql.Result, error)

Exec executes a prepared statement with arguments

func (*Statement) Query

func (s *Statement) Query(ctx context.Context, args ...any) (*sql.Rows, error)

Query executes a prepared query with arguments

func (*Statement) QueryRow

func (s *Statement) QueryRow(ctx context.Context, args ...any) types.Row

QueryRow executes a prepared query that returns a single row

type Transaction

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

Transaction wraps sql.Tx to implement types.Tx

func (*Transaction) Commit

func (t *Transaction) Commit() error

Commit commits the transaction

func (*Transaction) Exec

func (t *Transaction) Exec(ctx context.Context, query string, args ...any) (sql.Result, error)

Exec executes a query without returning rows within the transaction

func (*Transaction) Prepare

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

Prepare creates a prepared statement within the transaction

func (*Transaction) Query

func (t *Transaction) Query(ctx context.Context, query string, args ...any) (*sql.Rows, error)

Query executes a query within the transaction

func (*Transaction) QueryRow

func (t *Transaction) QueryRow(ctx context.Context, query string, args ...any) types.Row

QueryRow executes a query that returns a single row within the transaction

func (*Transaction) Rollback

func (t *Transaction) Rollback() error

Rollback rolls back the transaction