mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-07 05:10:20 -06:00
Code Issues Packages Projects Releases Wiki Activity

inner 1568

Browse Source
This commit is contained in:
yanhuqing666
2021-12-29 21:05:38 +08:00
parent a189e0d793
commit e335606f1e
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/query/impl/subquery/SingleRowSubQueryHandler.java
View File

@@ -47,7 +47,7 @@ public class SingleRowSubQueryHandler extends SubQueryHandler {
this.fieldPackets = fieldPackets;
sourceField = HandlerTool.createField(this.fieldPackets.get(0));
if (itemSubQuery.isField()) {
setSubQueryFiled();
setSubQueryField();
}
}
} finally {
@@ -74,7 +74,7 @@ public class SingleRowSubQueryHandler extends SubQueryHandler {
row.read(rowNull);
}
if (!itemSubQuery.isField()) {
setSubQueryFiled();
setSubQueryField();
}
sourceField.setPtr(row.getValue(0));
} finally {
@@ -89,7 +89,7 @@ public class SingleRowSubQueryHandler extends SubQueryHandler {
return HandlerType.SCALAR_SUB_QUERY;
}
private void setSubQueryFiled() {
private void setSubQueryField() {
Item select = itemSubQuery.getSelect();
PlanNode planNode = itemSubQuery.getPlanNode();
if (!(planNode instanceof ManagerTableNode) || ((ManagerTableNode) planNode).isNeedSendMaker()) {

2
src/main/java/com/actiontech/dble/plan/util/PlanUtil.java
View File

@@ -110,6 +110,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();