proto

type AnalysisDriverClient interface {
	// Init should be called at first before calling following methods.
	// It will pass some necessary info to plugin server. In the beginning,
	// we consider that put this info to the executable binary environment.
	// We put all communication on gRPC for unification in the end.
	Init(ctx context.Context, in *AnalysisDriverInitRequest, opts ...grpc.CallOption) (*Empty, error)
	ListTablesInSchema(ctx context.Context, in *ListTablesInSchemaRequest, opts ...grpc.CallOption) (*ListTablesInSchemaResponse, error)
	GetTableMetaByTableName(ctx context.Context, in *GetTableMetaByTableNameRequest, opts ...grpc.CallOption) (*GetTableMetaByTableNameResponse, error)
	GetTableMetaBySQL(ctx context.Context, in *GetTableMetaBySQLRequest, opts ...grpc.CallOption) (*GetTableMetaBySQLResponse, error)
	Explain(ctx context.Context, in *ExplainRequest, opts ...grpc.CallOption) (*ExplainResponse, error)
}

type AnalysisDriverInitRequest struct {
	Dsn *DSN `protobuf:"bytes,1,opt,name=dsn" json:"dsn,omitempty"`
}

type AnalysisDriverServer interface {
	// Init should be called at first before calling following methods.
	// It will pass some necessary info to plugin server. In the beginning,
	// we consider that put this info to the executable binary environment.
	// We put all communication on gRPC for unification in the end.
	Init(context.Context, *AnalysisDriverInitRequest) (*Empty, error)
	ListTablesInSchema(context.Context, *ListTablesInSchemaRequest) (*ListTablesInSchemaResponse, error)
	GetTableMetaByTableName(context.Context, *GetTableMetaByTableNameRequest) (*GetTableMetaByTableNameResponse, error)
	GetTableMetaBySQL(context.Context, *GetTableMetaBySQLRequest) (*GetTableMetaBySQLResponse, error)
	Explain(context.Context, *ExplainRequest) (*ExplainResponse, error)
}

type AnalysisInfoHead struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Desc string `protobuf:"bytes,2,opt,name=desc" json:"desc,omitempty"`
}

type AnalysisInfoInTableFormat struct {
	Columns []*AnalysisInfoHead `protobuf:"bytes,1,rep,name=columns" json:"columns,omitempty"`
	Rows    []*Row              `protobuf:"bytes,2,rep,name=rows" json:"rows,omitempty"`
}

type AuditRequest struct {
	Sql string `protobuf:"bytes,1,opt,name=sql" json:"sql,omitempty"`
}

type AuditResponse struct {
	Results []*AuditResult `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
}

type AuditResult struct {
	Message string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
	Level   string `protobuf:"bytes,2,opt,name=level" json:"level,omitempty"`
}

type ColumnsInfo struct {
	AnalysisInfoInTableFormat *AnalysisInfoInTableFormat `protobuf:"bytes,1,opt,name=analysisInfoInTableFormat" json:"analysisInfoInTableFormat,omitempty"`
}

type DSN struct {
	Host             string   `protobuf:"bytes,1,opt,name=host" json:"host,omitempty"`
	Port             string   `protobuf:"bytes,2,opt,name=port" json:"port,omitempty"`
	User             string   `protobuf:"bytes,3,opt,name=user" json:"user,omitempty"`
	Password         string   `protobuf:"bytes,4,opt,name=password" json:"password,omitempty"`
	Database         string   `protobuf:"bytes,5,opt,name=database" json:"database,omitempty"`
	AdditionalParams []*Param `protobuf:"bytes,6,rep,name=additionalParams" json:"additionalParams,omitempty"`
}

type DatabasesResponse struct {
	Databases []string `protobuf:"bytes,1,rep,name=databases" json:"databases,omitempty"`
}

type DriverClient interface {
	// Metas returns some base info from plugin server.
	Metas(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*MetasResponse, error)
	// Init will should be called at first before calling following methods.
	// It will pass some necessary info to plugin server. In the beginning,
	// we consider that put this info to the executable binary environment.
	// We put all communication on gRPC for unification in the end.
	Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*Empty, error)
	Close(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	Exec(ctx context.Context, in *ExecRequest, opts ...grpc.CallOption) (*ExecResponse, error)
	Tx(ctx context.Context, in *TxRequest, opts ...grpc.CallOption) (*TxResponse, error)
	Databases(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DatabasesResponse, error)
	Parse(ctx context.Context, in *ParseRequest, opts ...grpc.CallOption) (*ParseResponse, error)
	Audit(ctx context.Context, in *AuditRequest, opts ...grpc.CallOption) (*AuditResponse, error)
	GenRollbackSQL(ctx context.Context, in *GenRollbackSQLRequest, opts ...grpc.CallOption) (*GenRollbackSQLResponse, error)
}

type DriverServer interface {
	// Metas returns some base info from plugin server.
	Metas(context.Context, *Empty) (*MetasResponse, error)
	// Init will should be called at first before calling following methods.
	// It will pass some necessary info to plugin server. In the beginning,
	// we consider that put this info to the executable binary environment.
	// We put all communication on gRPC for unification in the end.
	Init(context.Context, *InitRequest) (*Empty, error)
	Close(context.Context, *Empty) (*Empty, error)
	Ping(context.Context, *Empty) (*Empty, error)
	Exec(context.Context, *ExecRequest) (*ExecResponse, error)
	Tx(context.Context, *TxRequest) (*TxResponse, error)
	Databases(context.Context, *Empty) (*DatabasesResponse, error)
	Parse(context.Context, *ParseRequest) (*ParseResponse, error)
	Audit(context.Context, *AuditRequest) (*AuditResponse, error)
	GenRollbackSQL(context.Context, *GenRollbackSQLRequest) (*GenRollbackSQLResponse, error)
}

type Empty struct {
}

type ExecRequest struct {
	Query string `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"`
}

type ExecResponse struct {
	LastInsertId      int64  `protobuf:"varint,1,opt,name=lastInsertId" json:"lastInsertId,omitempty"`
	LastInsertIdError string `protobuf:"bytes,2,opt,name=lastInsertIdError" json:"lastInsertIdError,omitempty"`
	RowsAffected      int64  `protobuf:"varint,3,opt,name=rowsAffected" json:"rowsAffected,omitempty"`
	RowsAffectedError string `protobuf:"bytes,4,opt,name=rowsAffectedError" json:"rowsAffectedError,omitempty"`
}

type ExplainClassicResult struct {
	AnalysisInfoInTableFormat *AnalysisInfoInTableFormat `protobuf:"bytes,1,opt,name=analysisInfoInTableFormat" json:"analysisInfoInTableFormat,omitempty"`
}

type ExplainRequest struct {
	Sql string `protobuf:"bytes,1,opt,name=sql" json:"sql,omitempty"`
}

type ExplainResponse struct {
	ClassicResult *ExplainClassicResult `protobuf:"bytes,1,opt,name=classicResult" json:"classicResult,omitempty"`
}

type GenRollbackSQLRequest struct {
	Sql string `protobuf:"bytes,1,opt,name=sql" json:"sql,omitempty"`
}

type GenRollbackSQLResponse struct {
	Sql    string `protobuf:"bytes,1,opt,name=sql" json:"sql,omitempty"`
	Reason string `protobuf:"bytes,2,opt,name=reason" json:"reason,omitempty"`
}

type GetTableMetaBySQLRequest struct {
	Sql string `protobuf:"bytes,1,opt,name=sql" json:"sql,omitempty"`
}

type GetTableMetaBySQLResponse struct {
	TableMetas []*TableMetaItemBySQL `protobuf:"bytes,1,rep,name=tableMetas" json:"tableMetas,omitempty"`
}

type GetTableMetaByTableNameRequest struct {
	Schema string `protobuf:"bytes,1,opt,name=schema" json:"schema,omitempty"`
	Table  string `protobuf:"bytes,2,opt,name=table" json:"table,omitempty"`
}

type GetTableMetaByTableNameResponse struct {
	TableMeta *TableItem `protobuf:"bytes,1,opt,name=tableMeta" json:"tableMeta,omitempty"`
}

type IndexesInfo struct {
	AnalysisInfoInTableFormat *AnalysisInfoInTableFormat `protobuf:"bytes,1,opt,name=analysisInfoInTableFormat" json:"analysisInfoInTableFormat,omitempty"`
}

type InitRequest struct {
	Dsn   *DSN    `protobuf:"bytes,1,opt,name=dsn" json:"dsn,omitempty"`
	Rules []*Rule `protobuf:"bytes,3,rep,name=rules" json:"rules,omitempty"`
}

type ListTablesInSchemaRequest struct {
	Schema string `protobuf:"bytes,1,opt,name=schema" json:"schema,omitempty"`
}

type ListTablesInSchemaResponse struct {
	Tables []*Table `protobuf:"bytes,1,rep,name=tables" json:"tables,omitempty"`
}

type MetasResponse struct {
	Name             string   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Rules            []*Rule  `protobuf:"bytes,2,rep,name=rules" json:"rules,omitempty"`
	AdditionalParams []*Param `protobuf:"bytes,3,rep,name=additionalParams" json:"additionalParams,omitempty"`
	Version          int32    `protobuf:"varint,4,opt,name=version" json:"version,omitempty"`
}

type Node struct {
	Text        string `protobuf:"bytes,1,opt,name=text" json:"text,omitempty"`
	Type        string `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"`
	Fingerprint string `protobuf:"bytes,3,opt,name=fingerprint" json:"fingerprint,omitempty"`
}

type Param struct {
	Key   string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	Desc  string `protobuf:"bytes,3,opt,name=desc" json:"desc,omitempty"`
	Type  string `protobuf:"bytes,4,opt,name=type" json:"type,omitempty"`
}

type ParseRequest struct {
	SqlText string `protobuf:"bytes,1,opt,name=sqlText" json:"sqlText,omitempty"`
}

type ParseResponse struct {
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes" json:"nodes,omitempty"`
}

type QueryConf struct {
	TimeOutSecond uint32 `protobuf:"varint,1,opt,name=timeOutSecond" json:"timeOutSecond,omitempty"`
}

type QueryDriverClient interface {
	// Init will should be called at first before calling following methods.
	// It will pass some necessary info to plugin server. In the beginning,
	// we consider that put this info to the executable binary environment.
	// We put all communication on gRPC for unification in the end.
	Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*Empty, error)
	QueryPrepare(ctx context.Context, in *QueryPrepareRequest, opts ...grpc.CallOption) (*QueryPrepareResponse, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
}

type QueryDriverServer interface {
	// Init will should be called at first before calling following methods.
	// It will pass some necessary info to plugin server. In the beginning,
	// we consider that put this info to the executable binary environment.
	// We put all communication on gRPC for unification in the end.
	Init(context.Context, *InitRequest) (*Empty, error)
	QueryPrepare(context.Context, *QueryPrepareRequest) (*QueryPrepareResponse, error)
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
}

type QueryPrepareConf struct {
	Limit  uint32 `protobuf:"varint,1,opt,name=limit" json:"limit,omitempty"`
	Offset uint32 `protobuf:"varint,2,opt,name=offset" json:"offset,omitempty"`
}

type QueryPrepareRequest struct {
	Sql  string            `protobuf:"bytes,1,opt,name=sql" json:"sql,omitempty"`
	Conf *QueryPrepareConf `protobuf:"bytes,2,opt,name=conf" json:"conf,omitempty"`
}

type QueryPrepareResponse struct {
	NewSql    string `protobuf:"bytes,1,opt,name=newSql" json:"newSql,omitempty"`
	ErrorType string `protobuf:"bytes,2,opt,name=errorType" json:"errorType,omitempty"`
	Error     string `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
}

type QueryRequest struct {
	Sql  string     `protobuf:"bytes,1,opt,name=sql" json:"sql,omitempty"`
	Conf *QueryConf `protobuf:"bytes,2,opt,name=conf" json:"conf,omitempty"`
}

type QueryResponse struct {
	Column []*Param          `protobuf:"bytes,1,rep,name=column" json:"column,omitempty"`
	Rows   []*QueryResultRow `protobuf:"bytes,2,rep,name=rows" json:"rows,omitempty"`
}

type QueryResultRow struct {
	Values []*QueryResultValue `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
}

type QueryResultValue struct {
	Value string `protobuf:"bytes,1,opt,name=value" json:"value,omitempty"`
}

type Row struct {
	Items []string `protobuf:"bytes,1,rep,name=items" json:"items,omitempty"`
}

type Rule struct {
	Name     string   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Desc     string   `protobuf:"bytes,2,opt,name=desc" json:"desc,omitempty"`
	Value    string   `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"`
	Level    string   `protobuf:"bytes,4,opt,name=level" json:"level,omitempty"`
	Category string   `protobuf:"bytes,5,opt,name=category" json:"category,omitempty"`
	Params   []*Param `protobuf:"bytes,6,rep,name=params" json:"params,omitempty"`
}

type Table struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

type TableItem struct {
	Name           string       `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Schema         string       `protobuf:"bytes,2,opt,name=schema" json:"schema,omitempty"`
	ColumnsInfo    *ColumnsInfo `protobuf:"bytes,3,opt,name=columnsInfo" json:"columnsInfo,omitempty"`
	IndexesInfo    *IndexesInfo `protobuf:"bytes,4,opt,name=indexesInfo" json:"indexesInfo,omitempty"`
	CreateTableSQL string       `protobuf:"bytes,5,opt,name=createTableSQL" json:"createTableSQL,omitempty"`
}

type TableMetaItemBySQL struct {
	Name           string       `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Schema         string       `protobuf:"bytes,2,opt,name=schema" json:"schema,omitempty"`
	ColumnsInfo    *ColumnsInfo `protobuf:"bytes,3,opt,name=columnsInfo" json:"columnsInfo,omitempty"`
	IndexesInfo    *IndexesInfo `protobuf:"bytes,4,opt,name=indexesInfo" json:"indexesInfo,omitempty"`
	CreateTableSQL string       `protobuf:"bytes,5,opt,name=createTableSQL" json:"createTableSQL,omitempty"`
	ErrMessage     string       `protobuf:"bytes,6,opt,name=errMessage" json:"errMessage,omitempty"`
}

type TxRequest struct {
	Queries []string `protobuf:"bytes,1,rep,name=queries" json:"queries,omitempty"`
}

type TxResponse struct {
	Results []*ExecResponse `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
}