sqlite

Mar 31, 2024

Changes in this version

type OpenOption

+ func WithLogger(logger *slog.Logger) OpenOption

type RepoConfig

+ Logger *slog.Logger

Mar 16, 2024

Changes in this version

+ type MissingKeyError struct

+ Key string

+ func (e MissingKeyError) Error() string

+ type OpenOption func(opts *openOptions)

+ func WithDriver(driverName string) OpenOption

Apr 18, 2023

Changes in this version

type RepoSingleton

+ func (repo *RepoSingleton[T]) List(ctx context.Context) ([]*T, error)

+ func (repo *RepoSingleton[T]) QueryList(ctx context.Context, query string, args ...interface{}) ([]*T, error)

Mar 19, 2023

Changes in this version

+ type HookAfterPut interface

+ AfterPut func(ctx context.Context) error

+ type HookBeforePut interface

+ BeforePut func(ctx context.Context, tx *Tx[T]) error

Mar 19, 2023

Changes in this version

type RepoGeneric

+ func (repo *RepoGeneric[T]) BeginTx(ctx context.Context) (*Tx[T], error)

type RepoSingleton

+ func (repo *RepoSingleton[T]) BeginTx(ctx context.Context) (*Tx[T], error)

+ type Tx struct

+ func (tx *Tx[T]) Commit() error

+ func (tx *Tx[T]) Put(ctx context.Context, model *T) error

+ func (tx *Tx[T]) Rollback() error

Mar 19, 2023

Changes in this version

type Hooks

+ BeforePut []Hook[T]

Mar 16, 2023

Changes in this version

+ type Query struct

+ func NewQuery(repo queryable, sql string, pending []string) *Query[T]

+ func (q *Query[T]) Bind(args ...sql.NamedArg)

+ func (q *Query[T]) Query(ctx context.Context, args ...sql.NamedArg) (*T, error)

+ func (q *Query[T]) QueryValue(ctx context.Context, args ...sql.NamedArg) (T, error)

type RepoGeneric

+ func (repo *RepoGeneric[T]) ExistsQuery() *Query[bool]

Mar 11, 2023

Changes in this version

type RepoGeneric

+ func (repo *RepoGeneric[T]) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

Feb 14, 2023

Changes in this version

+ type Hook func(ctx context.Context, model *T) error

+ type Hooks struct

+ AfterPut []Hook[T]

type RepoConfig

+ Hooks Hooks[T]

Feb 11, 2023

Changes in this version

type RepoGeneric

+ func (repo *RepoGeneric[T]) Exists(ctx context.Context, key string) (bool, error)

Feb 10, 2023

Changes in this version

type RepoGeneric

+ func (repo *RepoGeneric[T]) Delete(ctx context.Context, model *T) error

+ func (repo *RepoGeneric[T]) DeleteKey(ctx context.Context, key string) error

Feb 6, 2023

Changes in this version

+ func Open(dsn string) (*sqlx.DB, error)

+ type MultiError []error

+ func (m MultiError) Error() string

+ func (m MultiError) HasError() bool

+ func (m MultiError) Unwrap() error

+ type RepoConfig struct

+ PrimaryKey string

+ Table string

+ type RepoGeneric struct

+ DB *sqlx.DB

+ func NewRepoGeneric(db *sqlx.DB, cnf RepoConfig) *RepoGeneric[T]

+ func (repo *RepoGeneric[T]) Count(ctx context.Context) (int64, error)

+ func (repo *RepoGeneric[T]) Get(ctx context.Context, key string) (*T, error)

+ func (repo *RepoGeneric[T]) GetMulti(ctx context.Context, keys []string) ([]*T, error)

+ func (repo *RepoGeneric[T]) List(ctx context.Context) ([]*T, error)

+ func (repo *RepoGeneric[T]) Put(ctx context.Context, model *T) error

+ func (repo *RepoGeneric[T]) Query(ctx context.Context, query string, args ...interface{}) (*T, error)

+ func (repo *RepoGeneric[T]) QueryList(ctx context.Context, query string, args ...interface{}) ([]*T, error)

+ func (repo *RepoGeneric[T]) QueryMap(ctx context.Context, query string, args ...interface{}) (map[string]*T, error)

+ type RepoSingleton struct

+ DB *sqlx.DB

+ func NewRepoSingleton(db *sqlx.DB, cnf RepoConfig) *RepoSingleton[T]

+ func (repo *RepoSingleton[T]) Exists(ctx context.Context, key string) (bool, error)

+ func (repo *RepoSingleton[T]) Get(ctx context.Context, key string) (*T, error)

+ func (repo *RepoSingleton[T]) Put(ctx context.Context, model *T) error

+ func (repo *RepoSingleton[T]) Query(ctx context.Context, query string, args ...interface{}) (*T, error)