You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by da...@apache.org on 2018/09/15 18:52:39 UTC
hive git commit: HIVE-20355: Clean up parameter of
HiveConnection.setSchema (Daniel Dai, reviewed by Sankar Hariappan)
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 <da...@gmail.com>
Authored: Sat Sep 15 11:51:50 2018 -0700
Committer: Daniel Dai <da...@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();