dps-sdk/ports/client_cmd_request.go

package ports

type AutoMigrateRequest struct {
	DatabaseID            string
	TablePrefixWithSchema string
	Version               string
	TableModelDescribe    TableModelDescribe
}

// TODO 事务

type InsertRequest struct {
	DatabaseID            string
	TablePrefixWithSchema string
	Version               string
	Keys                  []Key
	TableRow              map[string]any
	UserID                string
}

type InsertBatchRequest struct {
	DatabaseID string
	Items      []*InsertItem
}

type InsertItem struct {
	TablePrefixWithSchema string
	Version               string
	Keys                  []Key
	TableRow              map[string]any
	UserID                string
}

type DeleteRequest struct {
	DatabaseID            string
	TablePrefixWithSchema string
	Version               string
	Keys                  []Key
	UserID                string
}

type DeleteBatchRequest struct {
	DatabaseID string
	Items      []*DeleteTableItem
	UserID     string
}

type DeleteTableItem struct {
	TablePrefixWithSchema string
	Version               string
	Items                 []*DeleteItem
}

type DeleteItem struct {
	Keys []Key
}

type UpdateRequest struct {
	DatabaseID            string
	TablePrefixWithSchema string
	Version               string
	Keys                  []Key
	NewTableRow           []map[string]any
	UserID                string
}

type ReplayRequest struct {
	DatabaseID            string
	TablePrefixWithSchema string
	Version               string
	Keys                  []Key
	UserID                string
}

type TableModelDescribe struct {
	Fields []TableModelField `json:"fields"`
}

type TableModelField struct {
	Name string `json:"name"`
	Tag  string `json:"tag"`
}

type Key struct {
	Column string `json:"column"`
	Value  string `json:"value"`
}

type ColumnCompare struct {
	Column  string `json:"column"`
	Value   any    `json:"value"`
	Compare string `json:"compare"`
}