cloudbeaver

type AuditResDataV2 struct {
	AuditLevel string          `json:"audit_level" enums:"normal,notice,warn,error,"`
	Score      int32           `json:"score"`
	PassRate   float64         `json:"pass_rate"`
	SQLResults []AuditSQLResV2 `json:"sql_results"`
}

type AuditResults struct {
	SQL       string
	IsSuccess bool
	Results   []AuditSQLResV2
}

type AuditSQLReply struct {
	Code    int             `json:"code" example:"0"`
	Message string          `json:"message" example:"ok"`
	Data    *AuditResDataV2 `json:"data"`
}

type AuditSQLReq struct {
	InstanceType string `json:"instance_type" form:"instance_type" example:"MySQL" valid:"required"`
	// 调用方不应该关心SQL是否被完美的拆分成独立的条目, 拆分SQL由SQLE实现
	SQLContent       string `json:"sql_content" form:"sql_content" example:"select * from t1; select * from t2;" valid:"required"`
	SQLType          string `json:"sql_type" form:"sql_type" example:"sql" enums:"sql,mybatis," valid:"omitempty,oneof=sql mybatis"`
	ProjectId        string `json:"project_id" form:"project_id" example:"700300" valid:"required"`
	RuleTemplateName string `json:"rule_template_name" form:"rule_template_name" example:"default" valid:"required"`
	InstanceName     string `json:"instance_name" form:"instance_name" example:"instance1"`
	SchemaName       string `json:"schema_name" form:"schema_name" example:"schema1"`
}

type AuditSQLResV2 struct {
	Number      uint                 `json:"number"`
	ExecSQL     string               `json:"exec_sql"`
	AuditResult dbmodel.AuditResults `json:"audit_result"`
	AuditLevel  string               `json:"audit_level"`
	SQLType     string               `json:"sql_type"`
}

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

type Client struct {

	// Log is called with various debug information.
	// To log to standard out, use:
	//  client.Log = func(s string) { log.Println(s) }
	Log func(s string)

	HttpResHandler func(res *http.Response)
	// contains filtered or unexported fields
}

type ClientOption func(*Client)

type CloudBeaverV2215 struct{}

type CloudBeaverV2221 struct {
	CloudBeaverV2215
}

type CloudBeaverV2223 struct {
	CloudBeaverV2221
}

type CloudBeaverV2321 struct {
	CloudBeaverV2223
}

type CloudBeaverV2521 struct {
	CloudBeaverV2321
}

type ContextKey string

type DirectAuditParams struct {
	AuditSQLReq
	SQLEAddr                         string
	AllowQueryWhenLessThanAuditLevel string
}

type File struct {
	Field string
	Name  string
	R     io.Reader
}

type GraphQLImpl interface {
	CreateConnectionQuery() string
	UpdateConnectionQuery() string
	DeleteConnectionQuery() string
	GetUserConnectionsQuery() string
	SetUserConnectionsQuery() string
	IsUserExistQuery(userId string) (string, map[string]interface{})
	UpdatePasswordQuery() string
	CreateUserQuery() string
	GrantUserRoleQuery() string
	LoginQuery() string
	GetActiveUserQuery() string
	GetExecutionContextListQuery() string
}

type MutationResolverImpl struct {
	*resolver.MutationResolverImpl
	Ctx  echo.Context
	Next Next

	// SQLExecuteResultsHandlerFn 为对SQL结果集的处理方法，具体处理逻辑为业务行为，由外部biz层定义后传入
	SQLExecuteResultsHandlerFn SQLExecuteResultsHandler
}

type NavNodeChildrenResponse struct {
	Data struct {
		NavNodeChildren []NavNodeInfo `json:"navNodeChildren"`
		NavNodeInfo     NavNodeInfo   `json:"navNodeInfo"`
	} `json:"data"`
}

type NavNodeInfo struct {
	ID          string         `json:"id"`
	Name        string         `json:"name"`
	PlainName   *string        `json:"plainName"`
	HasChildren bool           `json:"hasChildren"`
	NodeType    string         `json:"nodeType"`
	Icon        string         `json:"icon"`
	Folder      bool           `json:"folder"`
	Inline      bool           `json:"inline"`
	Navigable   bool           `json:"navigable"`
	Filtered    bool           `json:"filtered"`
	Features    []string       `json:"features"`
	ProjectID   string         `json:"projectId"`
	Object      *NavNodeObject `json:"object"`
}

type NavNodeObject struct {
	Features []string `json:"features"`
}

type Next func(c echo.Context) ([]byte, error)

type QueryResolverImpl struct {
	*resolver.QueryResolverImpl
	Ctx  echo.Context
	Next Next
}

type Request struct {

	// Header represent any request headers that will be set
	// when the request is made.
	Header http.Header
	// contains filtered or unexported fields
}

type ResolverImpl struct {
	*resolver.Resolver
	Ctx  echo.Context
	Next Next

	// SQLExecuteResultsHandlerFn 为对SQL结果集的处理方法，具体处理逻辑为业务行为，由外部biz层定义后传入
	SQLExecuteResultsHandlerFn SQLExecuteResultsHandler
	EnableResultsHandlerFn     bool
}

type SQLExecuteResultsHandler func(ctx context.Context, result *model.SQLExecuteInfo) error