package Polarx.ExecPlan

Get desktop application:
View/edit binary Protocol Buffers messages

Used in: AnyPlan

• required AnyPlan sub_read_plan = 1

• required Aggr.AggrType type = 2

  聚集函数类型

• required Datatypes.Scalar field = 3

  列名

• required Expr.Expr expr = 4

  聚集函数对应的表达式

Used in: Aggr

• COUNT_FUNC = 1

  COUNT

• COUNT_DISTINCT_FUNC = 2

  COUNT(DISTINCT)

• SUM_FUNC = 3

  SUM

• SUM_DISTINCT_FUNC = 4

  SUM(DISTINCT)

• AVG_FUNC = 5

  AVG

• AVG_DISTINCT_FUNC = 6

  AVG(DISTINCT)

• MIN_FUNC = 7

  MIN

• MAX_FUNC = 8

  MAX

Used in: Aggr, ExecPlan, Filter, Project, TableProject

• required AnyPlan.PlanType plan_type = 1

• optional GetPlan get_plan = 2

• optional TableScanPlan table_scan_plan = 3

• optional TableProject table_project = 4

• optional Project project = 5

• optional Filter filter = 6

• optional RangeScan range_scan = 8

• optional Aggr aggr = 9

Used in: AnyPlan

• GET = 1

• TABLE_SCAN = 2

• TABLE_PROJECT = 3

• PROJECT = 4

• FILTER = 5

• RANGE_SCAN = 8

• AGGR = 9

  LIMIT = 7;

Client send AutoSp message to Server

• required AutoSp.Operation op = 1

• required bytes sp_name = 2

• optional bool reset_error = 3

Used in: AutoSp

• SET = 0

• RELEASE = 1

• ROLLBACK = 2

• required uint32 total_bits = 1

• required uint32 number_hash = 2

• required bytes strategy = 3

  'murmur3_128'

• required bytes data = 4

(message has no fields)

(message has no fields)

server接收的plan

• optional Transaction transaction = 1

• optional AnyPlan plan = 2

• optional bytes plan_digest = 3

• repeated Datatypes.Scalar parameters = 4

  动态参数记录在这，从0开始 **有修改**

• repeated Datatypes.SessionVariable session_variables = 5

• optional int32 token = 6

• optional bool reset_error = 7

• optional bool compact_metadata = 8

• optional uint64 snapshot_seq = 9

• optional uint64 commit_seq = 10

• optional bool use_cts_transaction = 12

• optional bool chunk_result = 11

• optional bool feed_back = 13

• optional bytes trace_id = 14

• optional bytes audit_str = 15

• optional uint64 capabilities = 16

  capabilities

• optional bool mark_distributed = 17

  innodb_mark_distributed

• optional bool query_via_flashback_area = 18

  Flashback area

Used in: AnyPlan

• required AnyPlan sub_read_plan = 1

• required Expr.Expr expr = 2

完整的行条件，可包含多个列条件，and关系

Used in: GetPlan, KeyOnlyRangeScan, RangeScan

• repeated KeyExpr keys = 1

Used in: AnyPlan

• required TableInfo table_info = 1

• optional IndexInfo index_info = 2

  如果没指定，默认走primary

• repeated GetExpr keys = 3

  索引列过滤条件，如果为空就报错，全表扫描走TableScanPlan

Client send GetTSO message to Server

• required bytes leader_name = 1

• required int32 batch_count = 2

Used in: GetPlan, KeyOnlyRangeScan, RangeScan, TableScanPlan

• required Datatypes.Scalar name = 1

  Need support string and place holder.

• optional int32 use_parts = 2

单个列条件

Used in: GetExpr

• required Datatypes.Scalar field = 1

  需要能处理列名或列id，列id从0开始

• required Datatypes.Scalar value = 2

  需要能处理动态参数

• optional Transaction snapshot = 1

  读取快照，只有作为 top plan 时填写

• optional TableInfo table_info = 3

  读取的目标 table

• optional IndexInfo index_info = 4

  读取的目标 index

• optional GetExpr key = 5

• optional GetExpr end_key = 6

  end 条件，可选

• optional bool reverse = 8

  扫描顺序

• optional int64 flag = 9

  预留

(message has no fields)

Used in: AnyPlan

• required AnyPlan sub_read_plan = 1

• repeated Datatypes.Scalar fields = 2

  输出列名

• repeated Expr.Expr exprs = 3

  支持使用Expr全部功能，包括新增的ref，引用sub_read_plan的输出

Used in: AnyPlan

• optional Transaction snapshot = 1

  读取快照，只有作为 top plan 时填写

• optional TableInfo table_info = 3

  读取的目标 table

• optional IndexInfo index_info = 4

  读取的目标 index

• optional GetExpr key = 5

• optional GetExpr end_key = 6

  end 条件，可选

• optional bool reverse = 8

  扫描顺序

• optional int64 flag = 9

  预留

Server return ResultTSO message to Client

• required int32 error_no = 1

• required uint64 ts = 2

Used in: SessionInfos

(message has no fields)

• repeated SessionInfo sessions = 1

Used in: GetPlan, KeyOnlyRangeScan, RangeScan, TableScanPlan

• optional int64 version = 1

  Multi-version?

• required Datatypes.Scalar name = 2

  Need support string and place holder.

• optional Datatypes.Scalar schema_name = 3

  Need support string and place holder.

Used in: AnyPlan

• required AnyPlan sub_read_plan = 1

  只支持GET和SCAN两种就行

• repeated Datatypes.Scalar fields = 2

  支持列名和列id（int uint），从0开始

Used in: AnyPlan

• required TableInfo table_info = 1

• optional IndexInfo index_info = 2

  如果没指定，默认走primary

• optional bool reverse = 3

  扫描顺序，默认正向

Used in: ExecPlan, KeyOnlyRangeScan, RangeScan

(message has no fields)