persistence

Documentation

Index

• func Connect(config Configuration) *sqlx.DB
• func NewSessionStore(db *sqlx.DB) session.SessionStore
• type Configuration
• type Findable
  • func NewFindable[ENTITY any, FILTER any](db *sqlx.DB, ...) Findable[ENTITY, FILTER]
  • func NewFindableDefault[ENTITY any, FILTER any](db *sqlx.DB, ...) Findable[ENTITY, FILTER]
  • func (repo Findable[ENTITY, FILTER]) Find(filter *FILTER, pag *pagination.Pagination) (pagination.List[ENTITY], error)
• type SQLDao
  • func NewDao(db *sqlx.DB) SQLDao
  • func (repo SQLDao) BeginOrFatal() *sqlx.Tx
• type SQLSessionStore
  • func (store SQLSessionStore) Delete(id session.Id)
  • func (store SQLSessionStore) Get(id session.Id) (session.Entry, error)
  • func (store SQLSessionStore) Save(entry session.Entry)

Functions

func Connect

func Connect(config Configuration) *sqlx.DB

func NewSessionStore

func NewSessionStore(db *sqlx.DB) session.SessionStore

Types

type Configuration

type Configuration struct {
	Driver     string `configName:"dbdriver"`
	Connection string `configName:"dbconn"`
}

type Findable

type Findable[ENTITY any, FILTER any] struct {
	SQLDao
	// contains filtered or unexported fields
}

func NewFindable

func NewFindable[ENTITY any, FILTER any](
	db *sqlx.DB,
	buildFindSql func(filter *FILTER, params map[string]interface{}) string,
	buildOrderBySql func() string,
	elementsPerPage int) Findable[ENTITY, FILTER]

func NewFindableDefault

func NewFindableDefault[ENTITY any, FILTER any](
	db *sqlx.DB,
	buildFindSql func(filter *FILTER, params map[string]interface{}) string,
	buildOrderBySql func() string) Findable[ENTITY, FILTER]

func (Findable[ENTITY, FILTER]) Find

func (repo Findable[ENTITY, FILTER]) Find(filter *FILTER, pag *pagination.Pagination) (pagination.List[ENTITY], error)

type SQLDao

type SQLDao struct {
	DB *sqlx.DB
}

func NewDao

func NewDao(db *sqlx.DB) SQLDao

func (SQLDao) BeginOrFatal

func (repo SQLDao) BeginOrFatal() *sqlx.Tx

type SQLSessionStore

type SQLSessionStore struct {
	SQLDao
}

func (SQLSessionStore) Delete

func (store SQLSessionStore) Delete(id session.Id)

func (SQLSessionStore) Get

func (store SQLSessionStore) Get(id session.Id) (session.Entry, error)

func (SQLSessionStore) Save

func (store SQLSessionStore) Save(entry session.Entry)