inner 1568

This commit is contained in:
yanhuqing666
2021-12-29 21:05:38 +08:00
parent 1993b687a3
commit c99d888e41
2 changed files with 5 additions and 3 deletions
@@ -44,7 +44,7 @@ public class SingleRowSubQueryHandler extends SubQueryHandler {
this.fieldPackets = fieldPackets;
sourceField = HandlerTool.createField(this.fieldPackets.get(0));
if (itemSubQuery.isField()) {
setSubQueryFiled();
setSubQueryField();
}
}
} finally {
@@ -71,7 +71,7 @@ public class SingleRowSubQueryHandler extends SubQueryHandler {
row.read(rowNull);
}
if (!itemSubQuery.isField()) {
setSubQueryFiled();
setSubQueryField();
}
sourceField.setPtr(row.getValue(0));
} finally {
@@ -86,7 +86,7 @@ public class SingleRowSubQueryHandler extends SubQueryHandler {
return HandlerType.SCALAR_SUB_QUERY;
}
private void setSubQueryFiled() {
private void setSubQueryField() {
Item select = itemSubQuery.getSelect();
select.setPushDownName(select.getAlias());
Item tmpItem = HandlerTool.createItem(select, Collections.singletonList(this.sourceField), 0, isAllPushDown(), type());
@@ -109,6 +109,8 @@ public final class PlanUtil {
public static boolean canPush(Item sel, PlanNode child, PlanNode parent) {
if (sel == null)
return false;
if (sel.isWithSubQuery())
return false;
if (sel.isWithSumFunc())
return false;
HashSet<PlanNode> referTables = sel.getReferTables();