fix subquery and quer with limit

jd-opensource · Aug 2, 2023 · 28eb762 · 28eb762
1 parent 5ecd284
commit 28eb762
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/main/java/com/jd/jdbc/engine/PulloutSubqueryEngine.java b/src/main/java/com/jd/jdbc/engine/PulloutSubqueryEngine.java
@@ -84,7 +84,12 @@ public IExecute.ExecuteMultiShardResponse execute(IContext ctx, Vcursor vcursor,
      * @return
      */
     private BindVarsResponse execSubqery(IContext ctx, Vcursor vcursor, Map<String, BindVariable> bindVariableMap, boolean wantFields) throws SQLException {
-        IExecute.ExecuteMultiShardResponse subResultSet = this.subquery.execute(ctx, vcursor, bindVariableMap, wantFields);
+
+        Map<String, BindVariable> subBindVarMap = bindVariableMap;
+        if (bindVariableMap != null) {
+            subBindVarMap = new HashMap<>(bindVariableMap);
+        }
+        IExecute.ExecuteMultiShardResponse subResultSet = this.subquery.execute(ctx, vcursor, subBindVarMap, wantFields);
         if (subResultSet.getVtRowList() == null) {
             throw new SQLException("VtRowList is null");
         }