store

type Adaptor[T any] struct {
	Resource Resource[T]
}

type DbType interface {
	Where(field string, op crud.Operator, val string) (string, interface{}, error)
}

type EditableModel interface {
	PrepareCreate() ([]string, error)
	PrepareUpdate(id string) ([]string, error)
}

type Executor interface {
	Begin(ctx context.Context) (Transaction, error)
}

type FilterSet map[string]DbType

type IntDbType struct{}

type JsonDbType struct{}

type Limiter func(offset, limit int) string

type Model interface {
	GetID() string
}

type Querier interface {
	GetContext(ctx context.Context, result interface{}, query string, args ...interface{}) error
	SelectContext(ctx context.Context, result interface{}, query string, args ...interface{}) error
}

type QueryError struct {
	Query   string
	Params  interface{}
	Message string
	Cause   error
}

type Resource[T any] interface {
	// Get resource by id
	GetById(context.Context, string) (T, error)
	// Get resource by filter
	Get(ctx context.Context, filter []crud.Filter, outerOp crud.OuterOperation, innerOp crud.InnerOperation, sort []string, ascending bool, offset, limit int) ([]T, error)
	// Count resource by filter
	Count(ctx context.Context, filter []crud.Filter, outerOp crud.OuterOperation, innerOp crud.InnerOperation) (uint64, error)
	// Post (create) new resource, return id
	Post(ctx context.Context, data T) (string, error)
	// Put (update) resource
	Put(ctx context.Context, id string, data T) error
	// Delete resource by id
	Delete(context.Context, string) error
}

type SQLResource[T Model, P interface {
	*T
	EditableModel
}] struct {
	// contains filtered or unexported fields
}

type Statement interface {
	QueryString() string
	Execute(ctx context.Context, params ...any) (int, error)
	Close() error
}

type StringDbType struct{}

type TimeDbType struct{}

type Transaction interface {
	PrepareNamed(ctx context.Context, sql string, mapping any) (Statement, []any, error)
	Commit() error
	Rollback()
}