database

Documentation

Index

• type Connection
  • func NewConnection(db *sqlx.DB, configOptions ...ConnectionConfigurator) *Connection
  • func (c *Connection) Execute(ctx context.Context, statement string, parameters map[string]any) (sql.Result, error)
  • func (c *Connection) Select(ctx context.Context, target any, statement string, parameters map[string]any) error
• type ConnectionConfigurator
  • func WithPreRunHook(preRunHook PreRunHook) ConnectionConfigurator
• type Entity
• type PreRunHook
• type Query
  • func GenerateQuery(e Entity) Query
  • func (q Query) String() string
• type ReadOnlyRepository
  • func NewReadOnlyRepository[T Entity](connection *Connection) *ReadOnlyRepository[T]
  • func (repo ReadOnlyRepository[T]) Find(ctx context.Context, query Query, parameters map[string]any) ([]T, error)
  • func (repo ReadOnlyRepository[T]) FindOne(ctx context.Context, query Query, parameters map[string]any) (T, error)
• type Repository
  • func NewRepository[T Entity](connection *Connection) *Repository[T]
  • func (repo Repository[T]) Delete(ctx context.Context, entity T) error
  • func (repo Repository[T]) Insert(ctx context.Context, entity T) (uint64, error)
  • func (repo Repository[T]) Save(ctx context.Context, entity T) error
  • func (repo Repository[T]) Update(ctx context.Context, entity T) error

Types

type Connection

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

func NewConnection

func NewConnection(
	db *sqlx.DB,
	configOptions ...ConnectionConfigurator,
) *Connection

func (*Connection) Execute

func (c *Connection) Execute(ctx context.Context, statement string, parameters map[string]any) (sql.Result, error)

func (*Connection) Select

func (c *Connection) Select(ctx context.Context, target any, statement string, parameters map[string]any) error

type ConnectionConfigurator

type ConnectionConfigurator func(connection *Connection)

func WithPreRunHook

func WithPreRunHook(preRunHook PreRunHook) ConnectionConfigurator

type Entity

type Entity interface {
	TableName() string
	Joins() string
}

type PreRunHook

type PreRunHook func(statement string, parameters map[string]any) error

type Query

type Query struct {
	Select     string
	From       string
	Join       string
	Where      string
	OrderBy    string
	GroupBy    string
	Having     string
	Limit      string
	PrimaryKey string
}

func GenerateQuery

func GenerateQuery(e Entity) Query

func (Query) String

func (q Query) String() string

type ReadOnlyRepository

type ReadOnlyRepository[T Entity] struct {
	// contains filtered or unexported fields
}

func NewReadOnlyRepository

func NewReadOnlyRepository[T Entity](connection *Connection) *ReadOnlyRepository[T]

func (ReadOnlyRepository[T]) Find

func (repo ReadOnlyRepository[T]) Find(ctx context.Context, query Query, parameters map[string]any) ([]T, error)

func (ReadOnlyRepository[T]) FindOne

func (repo ReadOnlyRepository[T]) FindOne(ctx context.Context, query Query, parameters map[string]any) (T, error)

type Repository

type Repository[T Entity] struct {
	*ReadOnlyRepository[T]
	// contains filtered or unexported fields
}

func NewRepository

func NewRepository[T Entity](connection *Connection) *Repository[T]

func (Repository[T]) Delete

func (repo Repository[T]) Delete(ctx context.Context, entity T) error

func (Repository[T]) Insert

func (repo Repository[T]) Insert(ctx context.Context, entity T) (uint64, error)

func (Repository[T]) Save

func (repo Repository[T]) Save(ctx context.Context, entity T) error

func (Repository[T]) Update

func (repo Repository[T]) Update(ctx context.Context, entity T) error