wip

go/vt/vtgate/planbuilder/operators/expressions.go

@@ -60,6 +60,24 @@ func breakExpressionInLHSandRHS(
  return
 }
 
+func valuesJoinExpressionSplit(ctx *plancontext.PlanningContext, expr sqlparser.Expr, lhs semantics.TableSet, tableName string) (lhsExprs sqlparser.Exprs, rhsExpr sqlparser.Expr) {
+ rhsExpr = sqlparser.CopyOnRewrite(expr, nil, func(cursor *sqlparser.CopyOnWriteCursor) {
+ nodeExpr, ok := cursor.Node().(sqlparser.Expr)
+ if !ok || !mustFetchFromInput(ctx, nodeExpr) {
+ return
+ }
+
+ deps := ctx.SemTable.RecursiveDeps(nodeExpr)
+ if !deps.IsSolvedBy(lhs) {
+ return
+ }
+
+ lhsExprs = append(lhsExprs, nodeExpr)
+
+ }, ctx.SemTable.CopySemanticInfo).(sqlparser.Expr)
+ return
+}
+
 // nothingNeedsFetching will return true if all the nodes in the expression are constant
 func nothingNeedsFetching(ctx *plancontext.PlanningContext, expr sqlparser.Expr) (constant bool) {
  constant = true

go/vt/vtgate/planbuilder/operators/route_planning.go

@@ -289,6 +289,9 @@ func requiresSwitchingSides(ctx *plancontext.PlanningContext, op Operator) (requ
  return
 }
 
+// select 1 from user u join user_extra ue on ue.id = u.id
+// ue.id = ::u_id
+
 // Will create a join valid for the current mysql version
 func createJoin(ctx *plancontext.PlanningContext, lhs, rhs Operator, joinType sqlparser.JoinType, joinPredicates []sqlparser.Expr) (join JoinOp) {
  sigOk := ctx.SemTable.QuerySignature.EmptySet()

go/vt/vtgate/planbuilder/testdata/onecase.json

@@ -1,7 +1,7 @@
 [
  {
  "comment": "Add your test case here for debugging and run go test -run=One.",
- "query": "",
+ "query": "select 1 from user u join user_extra ue on u.foo = ue.user_id",
  "plan": {
  }
  }