Repository: hive Updated Branches: refs/heads/master 01083a61c -> 2c8e67942
HIVE-20355: Clean up parameter of HiveConnection.setSchema (Daniel Dai, reviewed by Sankar Hariappan) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/2c8e6794 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/2c8e6794 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/2c8e6794 Branch: refs/heads/master Commit: 2c8e679429352e6f550e3d9bdfa41860095d4e06 Parents: 01083a6 Author: Daniel Dai <dai...@gmail.com> Authored: Sat Sep 15 11:51:50 2018 -0700 Committer: Daniel Dai <dai...@gmail.com> Committed: Sat Sep 15 11:51:50 2018 -0700 ---------------------------------------------------------------------- jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/2c8e6794/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java ---------------------------------------------------------------------- diff --git a/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java b/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java index 458158e..70cc34d 100644 --- a/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java +++ b/jdbc/src/java/org/apache/hive/jdbc/HiveConnection.java @@ -1492,6 +1492,9 @@ public class HiveConnection implements java.sql.Connection { if (schema == null || schema.isEmpty()) { throw new SQLException("Schema name is null or empty"); } + if (schema.contains(";")) { + throw new SQLException("invalid schema name"); + } Statement stmt = createStatement(); stmt.execute("use " + schema); stmt.close();
