data

type Agg struct {
	Alias string
	Op    string
	Field string
}

type AndExpr struct{ Items []Expr }

type ArrayBinder interface {
	BindArray(any) any
}

type Capabilities struct {
	Dialect       string `json:"dialect"`
	ILike         bool   `json:"ilike"`
	Returning     bool   `json:"returning"`
	Join          bool   `json:"join"`
	Group         bool   `json:"group"`
	Having        bool   `json:"having"`
	Aggregate     bool   `json:"aggregate"`
	KeysetAfter   bool   `json:"keyset_after"`
	JsonContains  bool   `json:"json_contains"`
	ArrayOverlap  bool   `json:"array_overlap"`
	JsonElemMatch bool   `json:"json_elem_match"`
}

type Cascade struct {
	Table      string
	ForeignKey string
}

type CmpExpr struct {
	Field string
	Op    string
	Value Any
}

type Config struct {
	Driver      string
	Url         string
	Schema      string
	Mapping     bool
	MaxOpen     int
	MaxIdle     int
	MaxLifetime time.Duration
	MaxIdleTime time.Duration
	ReadOnly    bool
	Trash       TrashOptions
	Watcher     Map
	Migrate     MigrateOptions
	Setting     Map
}

type Configs map[string]Config

type Connection interface {
	Open() error
	Close() error
	Health() Health
	DB() *sql.DB
	Dialect() Dialect
}

type DataBase interface {
	Close() error
	WithContext(context.Context) DataBase
	WithTimeout(time.Duration) DataBase
	Begin() error
	Commit() error
	Rollback() error
	Tx(TxFunc) Res
	TxReadOnly(TxFunc) Res
	Migrate(...string)
	MigratePlan(...string) MigrateReport
	MigrateDiff(...string) MigrateReport
	MigrateUp(...string)
	MigrateDown(int)
	MigrateTo(string)
	MigrateDownTo(string)
	Capabilities() Capabilities
	Error() error
	ClearError()
	Sequence(string, int64, int64) (int64, error)
	SequenceMany(string, int64, int64, int64) ([]int64, error)

	Table(string) DataTable
	View(string) DataView
	Model(string) DataModel

	Raw(string, ...Any) []Map
	Exec(string, ...Any) int64
	Parse(...Any) (string, []Any)
}

type DataError struct {
	Op   string
	Code error
	Err  error
	Kind string
}

type DataModel interface {
	First(...Any) Map
	Query(...Any) []Map
	Scan(ScanFunc, ...Any) Res
	ScanN(int64, ScanFunc, ...Any) Res
	Slice(offset, limit int64, args ...Any) (int64, []Map)
}

type DataTable interface {
	Insert(Map) Map
	InsertMany([]Map) []Map
	Upsert(Map, ...Any) Map
	UpsertMany([]Map, ...Any) []Map
	Update(Map, ...Any) Map
	UpdateMany(Map, ...Any) int64
	Remove(...Any) Map
	RemoveMany(...Any) int64
	Restore(...Any) Map
	RestoreMany(...Any) int64
	Delete(...Any) Map
	DeleteMany(...Any) int64

	Entity(Any) Map
	Count(...Any) int64
	Aggregate(...Any) []Map
	First(...Any) Map
	Query(...Any) []Map
	Scan(ScanFunc, ...Any) Res
	ScanN(int64, ScanFunc, ...Any) Res
	Slice(offset, limit int64, args ...Any) (int64, []Map)
	Group(field string, args ...Any) []Map
}

type DataView interface {
	Count(...Any) int64
	Aggregate(...Any) []Map
	First(...Any) Map
	Query(...Any) []Map
	Scan(ScanFunc, ...Any) Res
	ScanN(int64, ScanFunc, ...Any) Res
	Slice(offset, limit int64, args ...Any) (int64, []Map)
	Group(field string, args ...Any) []Map
}

type DeleteWatcher struct {
	Name   string
	Desc   string
	Action func(Mutation)
}

type Dialect interface {
	Name() string
	Quote(string) string
	Placeholder(int) string
	SupportsILike() bool
	SupportsReturning() bool
}

type Driver interface {
	Connect(*Instance) (Connection, error)
}

type ErrorClassifier interface {
	ClassifyError(error) error
}

type ExistsExpr struct {
	Field string
	Yes   bool
}

type Expr interface {
	// contains filtered or unexported methods
}

type FieldRef string

type Health struct {
	Workload int64
}

type Index struct {
	Name   string
	Fields []string
	Unique bool
}

type InsertWatcher struct {
	Name   string
	Desc   string
	Action func(Mutation)
}

type Instance struct {
	Name    string
	Config  Config
	Setting Map
	// contains filtered or unexported fields
}

type Join struct {
	From         string
	Alias        string
	Type         string
	LocalField   string
	ForeignField string
	On           Expr
}

type MigrateAction struct {
	Kind   string         `json:"kind"`
	Target string         `json:"target"`
	SQL    string         `json:"sql,omitempty"`
	Apply  bool           `json:"apply"`
	Risk   string         `json:"risk,omitempty"`
	Detail string         `json:"detail,omitempty"`
	Diffs  []MigrateDelta `json:"diffs,omitempty"`
}

type MigrateDelta struct {
	Field  string `json:"field"`
	Kind   string `json:"kind"`
	From   string `json:"from,omitempty"`
	To     string `json:"to,omitempty"`
	Apply  bool   `json:"apply"`
	Risk   string `json:"risk,omitempty"`
	Detail string `json:"detail,omitempty"`
}

type MigrateOptions struct {
	Startup     string
	Mode        string
	DryRun      bool
	DiffOnly    bool
	Concurrent  bool
	Timeout     time.Duration
	LockTimeout time.Duration
	Retry       int
	RetryDelay  time.Duration
	Jitter      time.Duration
}

type MigrateReport struct {
	Mode    string          `json:"mode"`
	DryRun  bool            `json:"dryRun"`
	Actions []MigrateAction `json:"actions"`
}

type Migration struct {
	Version string
	Name    string
	Desc    string
	Up      func(DataBase) error
	Down    func(DataBase) error
}

type Model struct {
	Name    string
	Desc    string
	Schema  string
	Model   string
	Key     string
	Fields  Vars
	Setting Map
}

type Module struct {
	// contains filtered or unexported fields
}

type Mutation struct {
	Base  string    `json:"base"`
	Table string    `json:"table"`
	Op    string    `json:"op"`
	Rows  int64     `json:"rows"`
	Key   Any       `json:"key,omitempty"`
	Keys  []Any     `json:"keys,omitempty"`
	Data  Map       `json:"data,omitempty"`
	Where Map       `json:"where,omitempty"`
	At    time.Time `json:"at"`
}

type NotExpr struct{ Item Expr }

type NullExpr struct {
	Field string
	Yes   bool
}

type OrExpr struct{ Items []Expr }

type ParameterLimiter interface {
	MaxParams() int
}

type PlanOptions struct {
	Enable   bool
	Capacity int
	TTL      time.Duration
}

type PoolStats struct {
	Name         string  `json:"name"`
	Driver       string  `json:"driver"`
	Open         int     `json:"open"`
	InUse        int     `json:"inUse"`
	Idle         int     `json:"idle"`
	WaitCount    int64   `json:"waitCount"`
	WaitDuration int64   `json:"waitDurationMs"`
	MaxOpen      int     `json:"maxOpen"`
	Queries      int64   `json:"queries"`
	Writes       int64   `json:"writes"`
	Errors       int64   `json:"errors"`
	CacheHit     int64   `json:"cacheHit"`
	CacheRate    float64 `json:"cacheRate"`
	Slow         int64   `json:"slow"`
	SlowAvgMs    int64   `json:"slowAvgMs"`
	SlowP50Ms    int64   `json:"slowP50Ms"`
	SlowP95Ms    int64   `json:"slowP95Ms"`
}

type Query struct {
	Select      []string
	Filter      Expr
	Sort        []Sort
	Limit       int64
	Offset      int64
	After       Map
	WithCount   bool
	WithDeleted bool
	OnlyDeleted bool
	Unscoped    bool
	Unsafe      bool
	Batch       int64
	Group       []string
	Aggs        []Agg
	Having      Expr
	Joins       []Join

	RawWhere  string
	RawParams []Any
}

type RawExpr struct {
	SQL    string
	Params []Any
}

type SQLBuilder struct {
	// contains filtered or unexported fields
}

type ScanFunc func(Map) Res

type Sort struct {
	Field string
	Desc  bool
}

type Stats struct {
	Queries     int64   `json:"queries"`
	Writes      int64   `json:"writes"`
	Errors      int64   `json:"errors"`
	Slow        int64   `json:"slow"`
	CacheHit    int64   `json:"cacheHit"`
	CacheMiss   int64   `json:"cacheMiss"`
	CacheFlight int64   `json:"cacheFlight"`
	CacheWait   int64   `json:"cacheWait"`
	CacheRate   float64 `json:"cacheRate"`
	SlowAvgMs   int64   `json:"slowAvgMs"`
	SlowP50Ms   int64   `json:"slowP50Ms"`
	SlowP95Ms   int64   `json:"slowP95Ms"`
	ChangeIn    int64   `json:"changeIn"`
	ChangeDrop  int64   `json:"changeDrop"`
	ChangeFail  int64   `json:"changeFail"`
}

type Table struct {
	Name     string
	Desc     string
	Schema   string
	Table    string
	Key      string
	Fields   Vars
	Indexes  []Index
	Cascades []Cascade
	Setting  Map
}

type TrashOptions struct {
	Enable  bool
	Field   string
	Value   string
	Cascade string
}

type TrueExpr struct{}

type TxFunc func(DataBase) Res

type UpdateWatcher struct {
	Name   string
	Desc   string
	Action func(Mutation)
}

type UpsertWatcher struct {
	Name   string
	Desc   string
	Action func(Mutation)
}

type ValueBinder interface {
	BindValue(Var, any) (any, bool)
}

type ValueDecoder interface {
	DecodeValue(Var, any) (any, bool)
}

type View struct {
	Name    string
	Desc    string
	Schema  string
	View    string
	Key     string
	Fields  Vars
	Setting Map
}

type Watcher struct {
	Name   string
	Desc   string
	Action func(Mutation)
	Insert func(Mutation)
	Update func(Mutation)
	Upsert func(Mutation)
	Delete func(Mutation)
}

type Watchers map[string]Watcher