data

type Agg struct {
	Alias string
	Op    string
	Field string
}

type AndExpr struct{ Items []Expr }

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 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
	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) error
	TxReadOnly(TxFunc) error
	Migrate(...string)
	MigratePlan(...string) MigrateReport
	MigrateDiff(...string) MigrateReport
	MigrateUp(...string)
	MigrateDown(int)
	MigrateTo(string)
	MigrateDownTo(string)
	Capabilities() Capabilities
	Error() error
	ClearError()

	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
	Change(Map, Map) Map
	Remove(...Any) Map
	Update(Map, ...Any) int64
	Delete(...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 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"`
}

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"`
	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 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
	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"`
	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
	Setting Map
}

type TrueExpr struct{}

type TxFunc func(DataBase) error

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

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

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