databaseutilities

Documentation

Index

• type Database
• type PostgresConnection
  • func NewPostgres(ctx context.Context, cfg configutilities.DatabasePostgresConfiguration) (*PostgresConnection, error)
  • func (c *PostgresConnection) Close()
  • func (c *PostgresConnection) Query(ctx context.Context, dest interface{}, query string, args ...any) error
• type PostgresMockConn
  • func NewPostgresMock() (*PostgresMockConn, error)
  • func (m *PostgresMockConn) Close()
  • func (m *PostgresMockConn) Query(ctx context.Context, dest interface{}, query string, args ...any) error
• type UpdateQueryResult
  • func BuildUpdateWithValues(tableName string, id string, data any) (UpdateQueryResult, error)

Types

type Database

type Database[T any] interface {
	Query(ctx context.Context, query string, args ...any) (T, error)
	Close()
}

type PostgresConnection

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

func NewPostgres

func NewPostgres(ctx context.Context, cfg configutilities.DatabasePostgresConfiguration) (*PostgresConnection, error)

func (*PostgresConnection) Close

func (c *PostgresConnection) Close()

func (*PostgresConnection) Query

func (c *PostgresConnection) Query(ctx context.Context, dest interface{}, query string, args ...any) error

type PostgresMockConn

type PostgresMockConn struct {
	Mock pgxmock.PgxPoolIface
}

func NewPostgresMock

func NewPostgresMock() (*PostgresMockConn, error)

func (*PostgresMockConn) Close

func (m *PostgresMockConn) Close()

func (*PostgresMockConn) Query

func (m *PostgresMockConn) Query(ctx context.Context, dest interface{}, query string, args ...any) error

type UpdateQueryResult

type UpdateQueryResult struct {
	Query string
	Args  []string
}

func BuildUpdateWithValues

func BuildUpdateWithValues(tableName string, id string, data any) (UpdateQueryResult, error)