Skip to content

Commit 7fe3ad1

Browse files
committed
fix
1 parent ae18f5c commit 7fe3ad1

File tree

4 files changed

+5
-14
lines changed

4 files changed

+5
-14
lines changed

executor/builder.go

+1-3
Original file line numberDiff line numberDiff line change
@@ -211,9 +211,7 @@ func (b *executorBuilder) buildCancelDDLJobs(v *plannercore.CancelDDLJobs) Execu
211211

212212
func (b *executorBuilder) buildChange(v *plannercore.Change) Executor {
213213
return &ChangeExec{
214-
NodeType: v.NodeType,
215-
State: v.State,
216-
NodeID: v.NodeID,
214+
ChangeStmt: v.ChangeStmt,
217215
}
218216
}
219217

executor/change.go

+2-4
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@ package executor
1515

1616
import (
1717
"context"
18+
"github.com/pingcap/parser/ast"
1819
"strings"
1920

2021
"github.com/pingcap/errors"
@@ -26,10 +27,7 @@ import (
2627
// ChangeExec represents a change executor.
2728
type ChangeExec struct {
2829
baseExecutor
29-
30-
NodeType string
31-
State string
32-
NodeID string
30+
*ast.ChangeStmt
3331
}
3432

3533
// Next implements the Executor Next interface.

planner/core/common_plans.go

+1-4
Original file line numberDiff line numberDiff line change
@@ -136,10 +136,7 @@ type CancelDDLJobs struct {
136136
// Change represents a change plan.
137137
type Change struct {
138138
baseSchemaProducer
139-
140-
NodeType string
141-
State string
142-
NodeID string
139+
*ast.ChangeStmt
143140
}
144141

145142
// Prepare represents prepare plan.

planner/core/planbuilder.go

+1-3
Original file line numberDiff line numberDiff line change
@@ -225,9 +225,7 @@ func (b *PlanBuilder) Build(node ast.Node) (Plan, error) {
225225

226226
func (b *PlanBuilder) buildChange(v *ast.ChangeStmt) (Plan, error) {
227227
exe := &Change{
228-
NodeType: v.NodeType,
229-
State: v.State,
230-
NodeID: v.NodeID,
228+
ChangeStmt: v,
231229
}
232230
return exe, nil
233231
}

0 commit comments

Comments
 (0)