db

Documentation

Overview

Package db provides tools for easy and quick access to database via Connector.

Index

• func BuildDsn(config Config) string
• func GetEntityColumns(entity interface{}) []interface{}
• type CommonDBConnector
  • func New(dsn, driver string, logger *slog.Logger, opts ...PoolOption) (*CommonDBConnector, error)
  • func (connector *CommonDBConnector) Close() error
  • func (connector *CommonDBConnector) Connection(ctx context.Context) (*sql.Conn, error)
  • func (connector *CommonDBConnector) Pool() *sql.DB
  • func (connector *CommonDBConnector) Transaction(ctx context.Context, opts ...TransactionOption) (*sql.Tx, error)
• type Config
• type Connector
• type NilDBConnectionError
  • func (e NilDBConnectionError) Error() string
• type PoolOption
  • func WithMaxConnectionIdleTime(idleTime time.Duration) PoolOption
  • func WithMaxConnectionLifetime(lifetime time.Duration) PoolOption
  • func WithMaxIdleConnections(num int) PoolOption
  • func WithMaxOpenConnections(num int) PoolOption
• type TransactionOption
  • func WithTransactionIsolationLevel(isolationLevel sql.IsolationLevel) TransactionOption
  • func WithTransactionReadOnly(readOnly bool) TransactionOption

Functions

func BuildDsn

func BuildDsn(config Config) string

func GetEntityColumns

func GetEntityColumns(entity interface{}) []interface{}

GetEntityColumns receives a POINTER on entity (NOT A VALUE), parses is using reflection and returns a slice of columns for db/sql Query() method purpose for retrieving data from result rows. https://stackoverflow.com/questions/56525471/how-to-use-rows-scan-of-gos-database-sql

Types

type CommonDBConnector

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

CommonDBConnector is base connector to work with database.

func New

func New(dsn, driver string, logger *slog.Logger, opts ...PoolOption) (*CommonDBConnector, error)

New is constructor of CommonDBConnector. Gets database Config and *slog.Logger to create an instance.

func (*CommonDBConnector) Close

func (connector *CommonDBConnector) Close() error

Close closes pool of connections.

func (*CommonDBConnector) Connection

func (connector *CommonDBConnector) Connection(ctx context.Context) (*sql.Conn, error)

Connection creates connection with database, if not exists. Returns connection for external usage.

func (*CommonDBConnector) Pool

func (connector *CommonDBConnector) Pool() *sql.DB

func (*CommonDBConnector) Transaction

func (connector *CommonDBConnector) Transaction(ctx context.Context, opts ...TransactionOption) (*sql.Tx, error)

Transaction return database transaction object for external usage with atomicity of operations.

type Config

type Config struct {
	Host         string
	Port         int
	User         string
	Password     string
	DatabaseName string
	SSLMode      string
	Driver       string
}

Config is a database config, on base of which new connector is created.

type Connector

type Connector interface {
	Close() error
	Transaction(ctx context.Context, opts ...TransactionOption) (*sql.Tx, error)
	Connection(ctx context.Context) (*sql.Conn, error)
	Pool() *sql.DB
}

Connector interface is created for usage in external application according to "dependency inversion principle" of SOLID due to working via abstractions.

type NilDBConnectionError

type NilDBConnectionError struct {
	Message string
	BaseErr error
}

NilDBConnectionError is an error, representing not being able to connect to database and create a connection pool.

func (NilDBConnectionError) Error

func (e NilDBConnectionError) Error() string

type PoolOption

type PoolOption func(options *poolOptions) error

PoolOption represents golang functional option pattern func for connections pool settings.

func WithMaxConnectionIdleTime

func WithMaxConnectionIdleTime(idleTime time.Duration) PoolOption

WithMaxConnectionIdleTime sets maximum connection idle time (without usage) before closure in database connections pool.

func WithMaxConnectionLifetime

func WithMaxConnectionLifetime(lifetime time.Duration) PoolOption

WithMaxConnectionLifetime sets maximum connection lifetime before closure in database connections pool.

func WithMaxIdleConnections

func WithMaxIdleConnections(num int) PoolOption

WithMaxIdleConnections sets maximum idle connections in database connections pool.

func WithMaxOpenConnections

func WithMaxOpenConnections(num int) PoolOption

WithMaxOpenConnections sets maximum opened connections in database connections pool.

type TransactionOption

type TransactionOption func(options *transactionOptions) error

TransactionOption represents golang functional option pattern func for transaction settings.

func WithTransactionIsolationLevel

func WithTransactionIsolationLevel(isolationLevel sql.IsolationLevel) TransactionOption

WithTransactionIsolationLevel sets transaction isolation level for database transaction.

func WithTransactionReadOnly

func WithTransactionReadOnly(readOnly bool) TransactionOption

WithTransactionReadOnly sets readOnly attribute for database transaction.