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 void setSchema(String schema) throws SQLException { 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();