Skip to content

Commit

Permalink
Disable query caching for subqueries
Browse files Browse the repository at this point in the history
Resolves: #8563
  • Loading branch information
luigidellaquila committed Sep 25, 2018
1 parent 095ec8d commit 48cd4b8
Show file tree
Hide file tree
Showing 5 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -155,7 +155,7 @@ private void handleTarget(OUpdateExecutionPlan result, OCommandContext ctx, OFro
sourceStatement.setTarget(target);
sourceStatement.setWhereClause(whereClause);
OSelectExecutionPlanner planner = new OSelectExecutionPlanner(sourceStatement);
result.chain(new SubQueryStep(planner.createExecutionPlan(ctx, profilingEnabled, true), ctx, ctx, profilingEnabled));
result.chain(new SubQueryStep(planner.createExecutionPlan(ctx, profilingEnabled, false), ctx, ctx, profilingEnabled));
}

private void handleGlobalLet(ODeleteExecutionPlan result, OIdentifier name, OExpression expression, OCommandContext ctx,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -148,7 +148,7 @@ private void handleTarget(OUpdateExecutionPlan result, OCommandContext ctx, OFro
sourceStatement.setTarget(target);
sourceStatement.setWhereClause(whereClause);
OSelectExecutionPlanner planner = new OSelectExecutionPlanner(sourceStatement);
result.chain(new SubQueryStep(planner.createExecutionPlan(ctx, profilingEnabled, true), ctx, ctx, profilingEnabled));
result.chain(new SubQueryStep(planner.createExecutionPlan(ctx, profilingEnabled, false), ctx, ctx, profilingEnabled));
}

private OBooleanExpression getKeyCondition(OAndBlock andBlock) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -81,6 +81,6 @@ private void handleTarget(OUpdateExecutionPlan result, OCommandContext ctx, OFro
sourceStatement.setTarget(target);
sourceStatement.setWhereClause(whereClause);
OSelectExecutionPlanner planner = new OSelectExecutionPlanner(sourceStatement);
result.chain(new SubQueryStep(planner.createExecutionPlan(ctx, profilingEnabled, true), ctx, ctx, profilingEnabled));
result.chain(new SubQueryStep(planner.createExecutionPlan(ctx, profilingEnabled, false), ctx, ctx, profilingEnabled));
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -143,6 +143,6 @@ private void handleSource(OUpdateExecutionPlan result, OCommandContext ctx, OFro
sourceStatement.setTarget(new OFromClause(-1));
sourceStatement.getTarget().setItem(source);
OSelectExecutionPlanner planner = new OSelectExecutionPlanner(sourceStatement);
result.chain(new SubQueryStep(planner.createExecutionPlan(ctx, profilingEnabled, true), ctx, ctx, profilingEnabled));
result.chain(new SubQueryStep(planner.createExecutionPlan(ctx, profilingEnabled, false), ctx, ctx, profilingEnabled));
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -180,6 +180,6 @@ private void handleTarget(OUpdateExecutionPlan result, OCommandContext ctx, OFro
sourceStatement.setTimeout(this.timeout.copy());
}
OSelectExecutionPlanner planner = new OSelectExecutionPlanner(sourceStatement);
result.chain(new SubQueryStep(planner.createExecutionPlan(ctx, profilingEnabled, true), ctx, ctx, profilingEnabled));
result.chain(new SubQueryStep(planner.createExecutionPlan(ctx, profilingEnabled, false), ctx, ctx, profilingEnabled));
}
}

0 comments on commit 48cd4b8

Please sign in to comment.