database

Documentation

Index

• func IsNoRows(err error) bool
• func IsUniqueViolation(err error) bool
• type DB
  • func New(logger *slog.Logger, dsn string, automigrate bool) (*DB, error)
  • func (db *DB) Close() error
• type FindOptions
• type FindUserFilter
• type InsertSessionDTO
  • func NewInsertSessionDTO(user model.ID, task model.ID) InsertSessionDTO
• type InsertUserDTO
  • func NewInsertUserDTO(name string, surname string, passportSerie int, passportNumber int, ...) InsertUserDTO
  • func NewInsertUserDTOWithPatronymic(name string, surname string, patronymic string, passportSerie int, ...) InsertUserDTO
  • func (dto *InsertUserDTO) SetPatronymic(patronymic string)
• type SessionDAO
  • func NewSessionDAO(logger *slog.Logger, db *DB) *SessionDAO
  • func (dao *SessionDAO) FindByUser(ctx context.Context, user model.ID, opts SessionTimelineOptions) ([]model.Session, error)
  • func (dao *SessionDAO) Get(ctx context.Context, id model.ID) (model.Session, error)
  • func (dao *SessionDAO) Insert(ctx context.Context, dto InsertSessionDTO) (model.ID, error)
  • func (dao *SessionDAO) LastByTaskAndUser(ctx context.Context, task, user model.ID) (model.Session, error)
  • func (dao *SessionDAO) Update(ctx context.Context, id model.ID, dto UpdateSessionDTO) error
• type SessionTimelineOptions
• type UpdateSessionDTO
• type UpdateUserDTO
• type UserDAO
  • func NewUserDAO(logger *slog.Logger, db *DB) *UserDAO
  • func (dao *UserDAO) Delete(ctx context.Context, id model.ID) error
  • func (dao *UserDAO) Find(ctx context.Context, filter FindUserFilter, opts FindOptions) ([]model.User, error)
  • func (dao *UserDAO) Get(ctx context.Context, id model.ID) (model.User, error)
  • func (dao *UserDAO) Insert(ctx context.Context, dto InsertUserDTO) (model.ID, error)
  • func (dao *UserDAO) Update(ctx context.Context, id model.ID, dto UpdateUserDTO) error

Functions

func IsNoRows

func IsNoRows(err error) bool

func IsUniqueViolation

func IsUniqueViolation(err error) bool

Types

type DB

type DB struct {
	*sqlx.DB
	Builder squirrel.StatementBuilderType
	Logger  *slog.Logger
}

func New

func New(logger *slog.Logger, dsn string, automigrate bool) (*DB, error)

func (*DB) Close

func (db *DB) Close() error

type FindOptions

type FindOptions struct {
	Limit  uint64
	Offset uint64
}

type FindUserFilter

type FindUserFilter struct {
	Name           *string
	Surname        *string
	Patronymic     *string
	PassportSerie  *int
	PassportNumber *int
	Address        *string
}

type InsertSessionDTO

type InsertSessionDTO struct {
	User  model.ID
	Task  model.ID
	Begin time.Time
}

func NewInsertSessionDTO

func NewInsertSessionDTO(user model.ID, task model.ID) InsertSessionDTO

type InsertUserDTO

type InsertUserDTO struct {
	Name           string
	Surname        string
	Patronymic     *string
	PassportSerie  int
	PassportNumber int
	Address        string
}

func NewInsertUserDTO

func NewInsertUserDTO(
	name string, surname string,
	passportSerie int, passportNumber int,
	address string,
) InsertUserDTO

func NewInsertUserDTOWithPatronymic

func NewInsertUserDTOWithPatronymic(
	name string, surname string, patronymic string,
	passportSerie int, passportNumber int,
	address string,
) InsertUserDTO

func (*InsertUserDTO) SetPatronymic

func (dto *InsertUserDTO) SetPatronymic(patronymic string)

type SessionDAO

type SessionDAO struct {
	Logger *slog.Logger
	*DB
}

func NewSessionDAO

func NewSessionDAO(logger *slog.Logger, db *DB) *SessionDAO

func (*SessionDAO) FindByUser

func (dao *SessionDAO) FindByUser(ctx context.Context, user model.ID, opts SessionTimelineOptions) ([]model.Session, error)

func (*SessionDAO) Get

func (dao *SessionDAO) Get(ctx context.Context, id model.ID) (model.Session, error)

func (*SessionDAO) Insert

func (dao *SessionDAO) Insert(ctx context.Context, dto InsertSessionDTO) (model.ID, error)

func (*SessionDAO) LastByTaskAndUser

func (dao *SessionDAO) LastByTaskAndUser(ctx context.Context, task, user model.ID) (model.Session, error)

func (*SessionDAO) Update

func (dao *SessionDAO) Update(ctx context.Context, id model.ID, dto UpdateSessionDTO) error

type SessionTimelineOptions

type SessionTimelineOptions struct {
	After  *time.Time
	Before *time.Time
}

type UpdateSessionDTO

type UpdateSessionDTO struct {
	End time.Time
}

type UpdateUserDTO

type UpdateUserDTO struct {
	Name           *string
	Surname        *string
	Patronymic     *string
	PassportSerie  *int
	PassportNumber *int
	Address        *string
}

type UserDAO

type UserDAO struct {
	Logger *slog.Logger
	*DB
}

func NewUserDAO

func NewUserDAO(logger *slog.Logger, db *DB) *UserDAO

func (*UserDAO) Delete

func (dao *UserDAO) Delete(ctx context.Context, id model.ID) error

func (*UserDAO) Find

func (dao *UserDAO) Find(ctx context.Context, filter FindUserFilter, opts FindOptions) ([]model.User, error)

func (*UserDAO) Get

func (dao *UserDAO) Get(ctx context.Context, id model.ID) (model.User, error)

func (*UserDAO) Insert

func (dao *UserDAO) Insert(ctx context.Context, dto InsertUserDTO) (model.ID, error)

func (*UserDAO) Update

func (dao *UserDAO) Update(ctx context.Context, id model.ID, dto UpdateUserDTO) error