diff --git hplsql/src/main/java/org/apache/hive/hplsql/Select.java hplsql/src/main/java/org/apache/hive/hplsql/Select.java index 56fbb05..9d98b19 100644 --- hplsql/src/main/java/org/apache/hive/hplsql/Select.java +++ hplsql/src/main/java/org/apache/hive/hplsql/Select.java @@ -146,10 +146,10 @@ else if (ctx.parent instanceof HplsqlParser.StmtContext) { } catch (SQLException e) { exec.signal(query); - exec.closeQuery(query, exec.conf.defaultConnection); + exec.closeQuery(query, conn); return 1; } - exec.closeQuery(query, exec.conf.defaultConnection); + exec.closeQuery(query, conn); return 0; } @@ -468,4 +468,4 @@ void trace(ParserRuleContext ctx, String message) { void trace(ParserRuleContext ctx, Var var, ResultSet rs, ResultSetMetaData rm, int idx) throws SQLException { exec.trace(ctx, var, rs, rm, idx); } -} \ No newline at end of file +} diff --git hplsql/src/main/java/org/apache/hive/hplsql/Stmt.java hplsql/src/main/java/org/apache/hive/hplsql/Stmt.java index e6ac196..46390c7 100644 --- hplsql/src/main/java/org/apache/hive/hplsql/Stmt.java +++ hplsql/src/main/java/org/apache/hive/hplsql/Stmt.java @@ -636,7 +636,7 @@ else if (type == Conn.Type.HIVE && conf.insertValues == Conf.InsertValues.SELECT return 1; } exec.setSqlSuccess(); - exec.closeQuery(query, exec.conf.defaultConnection); + exec.closeQuery(query, conn); return 0; }