*: Support InsertStmt in new plan.

ast/dml.go

@@ -605,7 +605,7 @@ const (
 type InsertStmt struct {
 	dmlNode
 
-	Replace     bool
+	IsReplace   bool
 	Table       *TableRefsClause
 	Columns     []*ColumnName
 	Lists       [][]ExprNode

ast/expressions.go

@@ -706,7 +706,7 @@ func (n *UnaryOperationExpr) Accept(v Visitor) (Node, bool) {
 type ValuesExpr struct {
 	exprNode
 	// model.CIStr is column name.
-	Column *ColumnName
+	Column *ColumnNameExpr
 }
 
 // Accept implements Node Accept interface.
@@ -720,7 +720,7 @@ func (n *ValuesExpr) Accept(v Visitor) (Node, bool) {
 	if !ok {
 		return n, false
 	}
-	n.Column = node.(*ColumnName)
+	n.Column = node.(*ColumnNameExpr)
 	return v.Leave(n)
 }
 

executor/builder.go

@@ -16,6 +16,7 @@ package executor
 import (
 	"math"
 
+	"github.com/juju/errors"
 	"github.com/pingcap/tidb/ast"
 	"github.com/pingcap/tidb/column"
 	"github.com/pingcap/tidb/context"
@@ -64,6 +65,8 @@ func (b *executorBuilder) build(p plan.Plan) Executor {
 		return b.buildHaving(v)
 	case *plan.IndexScan:
 		return b.buildIndexScan(v)
+	case *plan.Insert:
+		return b.buildInsert(v)
 	case *plan.JoinInner:
 		return b.buildJoinInner(v)
 	case *plan.JoinOuter:
@@ -333,3 +336,39 @@ func (b *executorBuilder) buildDelete(v *plan.Delete) Executor {
 func (b *executorBuilder) buildSimple(v *plan.Simple) Executor {
 	return &SimpleExec{Statement: v.Statement, ctx: b.ctx}
 }
+
+func (b *executorBuilder) buildInsert(v *plan.Insert) Executor {
+	insert := &InsertExec{
+		ctx:         b.ctx,
+		Columns:     v.Columns,
+		Lists:       v.Lists,
+		Setlist:     v.Setlist,
+		OnDuplicate: v.OnDuplicate,
+		IsReplace:   v.IsReplace,
+		Priority:    v.Priority,
+	}
+	if v.SelectPlan != nil {
+		insert.SelectExec = b.build(v.SelectPlan)
+	}
+	// Get Table
+	ts, ok := v.Table.TableRefs.Left.(*ast.TableSource)
+	if !ok {
+		b.err = errors.New("Can not get table")
+		return nil
+	}
+	// fields is used to evaluate values expr.
+	insert.fields = ts.GetResultFields()
+	tn, ok := ts.Source.(*ast.TableName)
+	if !ok {
+		b.err = errors.New("Can not get table")
+		return nil
+	}
+	tableInfo := tn.TableInfo
+	tbl, ok := b.is.TableByID(tableInfo.ID)
+	if !ok {
+		b.err = errors.Errorf("Can not get table %d", tableInfo.ID)
+		return nil
+	}
+	insert.Table = tbl
+	return insert
+}

executor/converter/convert_expr.go

@@ -306,7 +306,7 @@ func (c *expressionConverter) unaryOperation(v *ast.UnaryOperationExpr) {
 }
 
 func (c *expressionConverter) values(v *ast.ValuesExpr) {
-	nameStr := joinColumnName(v.Column)
+	nameStr := joinColumnName(v.Column.Name)
 	c.exprMap[v] = &expression.Values{CIStr: model.NewCIStr(nameStr)}
 }
 

executor/converter/convert_stmt.go

@@ -78,7 +78,7 @@ func convertInsert(converter *expressionConverter, v *ast.InsertStmt) (stmt.Stat
 			return nil, errors.Trace(err)
 		}
 	}
-	if v.Replace {
+	if v.IsReplace {
 		return &stmts.ReplaceIntoStmt{
 			InsertValues: insertValues,
 			Text:         v.Text(),