dbctx

type Column struct {
	Name string
	Kind ColumnKind
}

type ColumnKind int

type DBContext interface {
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
}

type DBTransaction interface {
	DBContext
	Commit() error
	Rollback() error
}

type Fields map[string]any

type Filters map[string]any

type FindOptions struct {
	Filters    Filters
	Pagination *Pagination
	Order      *Order
}

type Order struct {
	Field string
	Desc  bool
}

type Pagination struct {
	Offset int
	Limit  int
}

type PgSQLRepo[T any] struct {
	// contains filtered or unexported fields
}

type Repo[T any] interface {
	Create(ctx context.Context, db DBContext, item *T) error
	UpdateOne(ctx context.Context, db DBContext, item T) error
	UpdateMany(ctx context.Context, db DBContext, fields Fields, filters Filters) error
	DeleteOne(ctx context.Context, db DBContext, item T) error
	DeleteMany(ctx context.Context, db DBContext, filters Filters) error
	FindOne(ctx context.Context, db DBContext, filters Filters) (*T, error)
	FindMany(ctx context.Context, db DBContext, opts FindOptions) ([]T, error)
}

type SQLRepoConfig[T any] struct {
	Table          string
	Columns        []Column
	MapScan        func(item *T) []any
	NoSoftDelete   bool
	NoCreateUpdate bool
}

type UpdateOptions struct {
	Filters Filters
}