database

Sep 3, 2020

Changes in this version

+ func HealthCheck(ctx context.Context, db DB) (*repository.HealthResponse, error)

Sep 2, 2020

Changes in this version

+ type Database struct

+ func (b *Database) AddRelations(ctx context.Context, model mapping.Model, relationField *mapping.StructField, ...) error

+ func (b *Database) Begin(ctx context.Context, options *query.TxOptions) *Tx

+ func (b *Database) ClearRelations(ctx context.Context, model mapping.Model, relationField *mapping.StructField) (int64, error)

+ func (b *Database) Close(ctx context.Context) error

+ func (b *Database) Delete(ctx context.Context, mStruct *mapping.ModelStruct, models ...mapping.Model) (int64, error)

+ func (b *Database) DeleteQuery(ctx context.Context, q *query.Scope) (int64, error)

+ func (b *Database) Dial(ctx context.Context) error

+ func (b *Database) GetDefaultRepository() (repository.Repository, bool)

+ func (b *Database) GetRelations(ctx context.Context, mStruct *mapping.ModelStruct, models []mapping.Model, ...) ([]mapping.Model, error)

+ func (b *Database) GetRepository(model mapping.Model) (repository.Repository, error)

+ func (b *Database) IncludeRelations(ctx context.Context, mStruct *mapping.ModelStruct, models []mapping.Model, ...) error

+ func (b *Database) Insert(ctx context.Context, mStruct *mapping.ModelStruct, models ...mapping.Model) error

+ func (b *Database) InsertQuery(ctx context.Context, q *query.Scope) error

+ func (b *Database) ModelMap() *mapping.ModelMap

+ func (b *Database) Now() time.Time

+ func (b *Database) Query(model *mapping.ModelStruct, models ...mapping.Model) Builder

+ func (b *Database) QueryAddRelations(ctx context.Context, s *query.Scope, relationField *mapping.StructField, ...) error

+ func (b *Database) QueryClearRelations(ctx context.Context, s *query.Scope, relationField *mapping.StructField) (int64, error)

+ func (b *Database) QueryCtx(ctx context.Context, model *mapping.ModelStruct, models ...mapping.Model) Builder

+ func (b *Database) QueryFind(ctx context.Context, q *query.Scope) ([]mapping.Model, error)

+ func (b *Database) QueryGet(ctx context.Context, q *query.Scope) (mapping.Model, error)

+ func (b *Database) QueryRefresh(ctx context.Context, q *query.Scope) error

+ func (b *Database) QuerySetRelations(ctx context.Context, s *query.Scope, relationField *mapping.StructField, ...) error

+ func (b *Database) Refresh(ctx context.Context, mStruct *mapping.ModelStruct, models ...mapping.Model) error

+ func (b *Database) SetRelations(ctx context.Context, model mapping.Model, relationField *mapping.StructField, ...) error

+ func (b *Database) Update(ctx context.Context, mStruct *mapping.ModelStruct, models ...mapping.Model) (int64, error)

+ func (b *Database) UpdateQuery(ctx context.Context, q *query.Scope) (int64, error)

+ type DefaultRepositoryGetter interface

+ GetDefaultRepository func() (repository.Repository, bool)

+ type RepositoryGetter interface

+ GetRepository func(model mapping.Model) (repository.Repository, error)

type Tx

+ func (t *Tx) GetDefaultRepository() (repository.Repository, bool)

+ func (t *Tx) GetRepository(model mapping.Model) (repository.Repository, error)

Sep 2, 2020

Changes in this version

type DB

+ ModelMap func() *mapping.ModelMap

type Tx

+ func (t *Tx) ModelMap() *mapping.ModelMap

Sep 2, 2020

Changes in this version

+ var ErrDatabase = errors.New("database")

+ var ErrRepository = errors.Wrap(ErrDatabase, "repository")

+ var ErrRepositoryAlreadyRegistered = errors.Wrap(ErrRepository, "already registered")

+ var ErrRepositoryNotFound = errors.Wrap(ErrRepository, "not found")

type DB

+ Now func() time.Time

+ type Option func(o *Options)

+ func WithDefaultRepository(r repository.Repository) Option

+ func WithMigrateModels(models ...mapping.Model) Option

+ func WithModelMap(m *mapping.ModelMap) Option

+ func WithRepositoryModels(r repository.Repository, models ...mapping.Model) Option

+ func WithSynchronousConnections() Option

+ func WithTimeFunc(timeFunc func() time.Time) Option

+ type Options struct

+ DefaultRepository repository.Repository

+ MigrateModels []mapping.Model

+ ModelMap *mapping.ModelMap

+ RepositoryModels map[repository.Repository][]mapping.Model

+ SynchronousConnections bool

+ TimeFunc func() time.Time

+ type RepositoryMapper struct

+ DefaultRepository repository.Repository

+ ModelMap *mapping.ModelMap

+ ModelRepositories map[*mapping.ModelStruct]repository.Repository

+ Repositories map[string]repository.Repository

+ func (r *RepositoryMapper) GetRepository(model mapping.Model) (repository.Repository, error)

+ func (r *RepositoryMapper) GetRepositoryByModelStruct(mStruct *mapping.ModelStruct) (repository.Repository, error)

+ func (r *RepositoryMapper) RegisterRepositories(repositories ...repository.Repository)

+ func (r *RepositoryMapper) RegisterRepositoryModels() error

+ func (r *RepositoryMapper) SetUnmappedModelRepositories() error

type Tx

+ func (t *Tx) Now() time.Time

Aug 29, 2020

Changes in this version

type Tx

+ func (t *Tx) RollbackSavepoint(ctx context.Context, name string) error

+ func (t *Tx) Savepoint(ctx context.Context, name string) error

Aug 16, 2020

Changes in this version

+ func RunInTransaction(ctx context.Context, db DB, options *query.TxOptions, txFunc TxFunc) error

+ type TxFunc func(db DB) error

Aug 7, 2020

Changes in this version

+ func Count(ctx context.Context, db DB, s *query.Scope) (int64, error)

+ func Exists(ctx context.Context, db DB, s *query.Scope) (bool, error)

+ func New(c *controller.Controller) *db

+ func RefreshModels(ctx context.Context, db DB, mStruct *mapping.ModelStruct, ...) error

+ type AfterDeleter interface

+ AfterDelete func(context.Context, DB) error

+ type AfterFinder interface

+ AfterFind func(context.Context, DB) error

+ type AfterInserter interface

+ AfterInsert func(context.Context, DB) error

+ type AfterUpdater interface

+ AfterUpdate func(context.Context, DB) error

+ type BeforeDeleter interface

+ BeforeDelete func(context.Context, DB) error

+ type BeforeInserter interface

+ BeforeInsert func(context.Context, DB) error

+ type BeforeUpdater interface

+ BeforeUpdate func(context.Context, DB) error

+ type Builder interface

+ AddRelations func(relationField *mapping.StructField, relations ...mapping.Model) error

+ Count func() (int64, error)

+ Ctx func() context.Context

+ Delete func() (int64, error)

+ Err func() error

+ Exists func() (bool, error)

+ Filter func(filter filter.Filter) Builder

+ Find func() ([]mapping.Model, error)

+ Get func() (mapping.Model, error)

+ GetRelations func(relationField *mapping.StructField, relationFieldSet ...*mapping.StructField) ([]mapping.Model, error)

+ Include func(relation *mapping.StructField, relationFieldset ...*mapping.StructField) Builder

+ Insert func() error

+ Limit func(limit int64) Builder

+ Offset func(offset int64) Builder

+ OrderBy func(fields ...query.Sort) Builder

+ Refresh func() error

+ RemoveRelations func(relationField *mapping.StructField) (int64, error)

+ Scope func() *query.Scope

+ Select func(fields ...*mapping.StructField) Builder

+ SetRelations func(relationField *mapping.StructField, relations ...mapping.Model) error

+ Update func() (int64, error)

+ Where func(filter string, arguments ...interface{}) Builder

+ WhereOr func(filters ...filter.Simple) Builder

+ type Collection interface

+ InitializeCollection func(c *controller.Controller) error

+ type DB interface

+ AddRelations func(ctx context.Context, model mapping.Model, relationField *mapping.StructField, ...) error

+ ClearRelations func(ctx context.Context, model mapping.Model, relationField *mapping.StructField) (int64, error)

+ Controller func() *controller.Controller

+ Delete func(ctx context.Context, mStruct *mapping.ModelStruct, models ...mapping.Model) (int64, error)

+ GetRelations func(ctx context.Context, mStruct *mapping.ModelStruct, models []mapping.Model, ...) ([]mapping.Model, error)

+ IncludeRelations func(ctx context.Context, mStruct *mapping.ModelStruct, models []mapping.Model, ...) error

+ Insert func(ctx context.Context, mStruct *mapping.ModelStruct, models ...mapping.Model) error

+ Query func(model *mapping.ModelStruct, models ...mapping.Model) Builder

+ QueryCtx func(ctx context.Context, model *mapping.ModelStruct, models ...mapping.Model) Builder

+ Refresh func(ctx context.Context, mStruct *mapping.ModelStruct, models ...mapping.Model) error

+ SetRelations func(ctx context.Context, model mapping.Model, relationField *mapping.StructField, ...) error

+ Update func(ctx context.Context, mStruct *mapping.ModelStruct, models ...mapping.Model) (int64, error)

+ type QueryDeleter interface

+ DeleteQuery func(ctx context.Context, q *query.Scope) (int64, error)

+ type QueryFinder interface

+ QueryFind func(ctx context.Context, q *query.Scope) ([]mapping.Model, error)

+ type QueryGetter interface

+ QueryGet func(ctx context.Context, q *query.Scope) (mapping.Model, error)

+ type QueryInserter interface

+ InsertQuery func(ctx context.Context, q *query.Scope) error

+ type QueryRefresher interface

+ QueryRefresh func(ctx context.Context, q *query.Scope) error

+ type QueryRelationAdder interface

+ QueryAddRelations func(ctx context.Context, s *query.Scope, relField *mapping.StructField, ...) error

+ type QueryRelationClearer interface

+ QueryClearRelations func(ctx context.Context, s *query.Scope, relField *mapping.StructField) (int64, error)

+ type QueryRelationSetter interface

+ QuerySetRelations func(ctx context.Context, s *query.Scope, relationField *mapping.StructField, ...) error

+ type QueryUpdater interface

+ UpdateQuery func(ctx context.Context, q *query.Scope) (modelsAffected int64, err error)

+ type Tx struct

+ Transaction *query.Transaction

+ func Begin(ctx context.Context, db DB, options *query.TxOptions) (*Tx, error)

+ func (t *Tx) AddRelations(ctx context.Context, model mapping.Model, relationField *mapping.StructField, ...) error

+ func (t *Tx) ClearRelations(ctx context.Context, model mapping.Model, relationField *mapping.StructField) (int64, error)

+ func (t *Tx) Commit() error

+ func (t *Tx) Controller() *controller.Controller

+ func (t *Tx) Delete(ctx context.Context, mStruct *mapping.ModelStruct, models ...mapping.Model) (int64, error)

+ func (t *Tx) DeleteQuery(ctx context.Context, s *query.Scope) (int64, error)

+ func (t *Tx) Err() error

+ func (t *Tx) GetRelations(ctx context.Context, mStruct *mapping.ModelStruct, models []mapping.Model, ...) ([]mapping.Model, error)

+ func (t *Tx) ID() uuid.UUID

+ func (t *Tx) IncludeRelations(ctx context.Context, mStruct *mapping.ModelStruct, models []mapping.Model, ...) error

+ func (t *Tx) Insert(ctx context.Context, mStruct *mapping.ModelStruct, models ...mapping.Model) error

+ func (t *Tx) InsertQuery(ctx context.Context, q *query.Scope) error

+ func (t *Tx) Options() query.TxOptions

+ func (t *Tx) Query(model *mapping.ModelStruct, models ...mapping.Model) Builder

+ func (t *Tx) QueryAddRelations(ctx context.Context, s *query.Scope, relationField *mapping.StructField, ...) error

+ func (t *Tx) QueryClearRelations(ctx context.Context, q *query.Scope, relationField *mapping.StructField) (int64, error)

+ func (t *Tx) QueryCtx(ctx context.Context, model *mapping.ModelStruct, models ...mapping.Model) Builder

+ func (t *Tx) QueryFind(ctx context.Context, q *query.Scope) ([]mapping.Model, error)

+ func (t *Tx) QueryGet(ctx context.Context, q *query.Scope) (mapping.Model, error)

+ func (t *Tx) QueryRefresh(ctx context.Context, q *query.Scope) error

+ func (t *Tx) QuerySetRelations(ctx context.Context, q *query.Scope, relationField *mapping.StructField, ...) error

+ func (t *Tx) Refresh(ctx context.Context, mStruct *mapping.ModelStruct, models ...mapping.Model) error

+ func (t *Tx) Rollback() error

+ func (t *Tx) SetRelations(ctx context.Context, model mapping.Model, relationField *mapping.StructField, ...) error

+ func (t *Tx) State() query.TxState

+ func (t *Tx) Update(ctx context.Context, mStruct *mapping.ModelStruct, models ...mapping.Model) (int64, error)

+ func (t *Tx) UpdateQuery(ctx context.Context, q *query.Scope) (int64, error)