api

type AggFunc string

type AlterTableStmt struct {
	Table string
	Plan  kernal.AlterTablePlan
}

type Backend string

type CreateTableStmt struct {
	Table  string
	Schema kernal.TableSchema
}

type DeleteStmt struct {
	Table      string
	Conditions []kernal.QueryCondition
}

type DropTableStmt struct{ Table string }

type Engine struct {
	Database string
	Backend  Backend
	Actor    *driver.AuthenticatedUser
	// contains filtered or unexported fields
}

type ExecResult struct {
	Rows         []kernal.Row  `json:"rows,omitempty"`
	Affected     int           `json:"affected"`
	Inserted     kernal.Row    `json:"inserted,omitempty"`
	InsertedRows []kernal.Row  `json:"insertedRows,omitempty"`
	Updated      kernal.Row    `json:"updated,omitempty"`
	UpdatedRows  []kernal.Row  `json:"updatedRows,omitempty"`
	Statement    StatementType `json:"statement"`
	Pagination   *Pagination   `json:"pagination,omitempty"`
}

type InsertStmt struct {
	Table string
	Row   kernal.Row
	Rows  []kernal.Row
}

type JoinClause struct {
	Type       JoinType // INNER | LEFT
	Table      string   // 从表名
	LeftAlias  string   // 主表字段（可含 "alias.field"）
	RightAlias string   // 从表字段（可含 "alias.field"）
}

type JoinType string

type Pagination struct {
	CurrentPage int `json:"currentPage"`
	TotalPages  int `json:"totalPages"`
	TotalItems  int `json:"totalItems"`
	PageSize    int `json:"pageSize"`
}

type SelectField struct {
	Star     bool    // SELECT *
	Field    string  // plain column name
	Agg      AggFunc // COUNT / SUM / AVG / MIN / MAX
	AggField string  // field inside aggregate ("*" for COUNT(*))
	Alias    string  // AS alias
}

type SelectStmt struct {
	Table      string
	Fields     []SelectField
	Joins      []JoinClause
	Conditions []kernal.QueryCondition
	SubConds   []SubqueryCondition
	GroupBy    []string
	OrderBy    string
	OrderDesc  bool
	Limit      int
	Offset     int
	Page       int
	PageSize   int
}

type Statement interface {
	Type() StatementType
	TableName() string
}

type StatementType string

type SubqueryCondition struct {
	Field   string
	NotIn   bool
	SubStmt SelectStmt
}

type TruncateTableStmt struct{ Table string }

type UpdateStmt struct {
	Table       string
	PrimaryKey  any
	PrimaryKeys []any
	Updates     kernal.Row
}