diff --git beeline/src/java/org/apache/hive/beeline/BeeLine.java beeline/src/java/org/apache/hive/beeline/BeeLine.java index 2f3350e..bb33305 100644 --- beeline/src/java/org/apache/hive/beeline/BeeLine.java +++ beeline/src/java/org/apache/hive/beeline/BeeLine.java @@ -1163,8 +1163,9 @@ String getPrompt() { if (getDatabaseConnection() == null || getDatabaseConnection().getUrl() == null) { return "beeline> "; } else { + String printClosed = getDatabaseConnection().isClosed() ? " (closed)" : ""; return getPrompt(getDatabaseConnections().getIndex() - + ": " + getDatabaseConnection().getUrl()) + "> "; + + ": " + getDatabaseConnection().getUrl()) + printClosed + "> "; } } diff --git beeline/src/java/org/apache/hive/beeline/DatabaseConnection.java beeline/src/java/org/apache/hive/beeline/DatabaseConnection.java index 00b49af..43d8b9f 100644 --- beeline/src/java/org/apache/hive/beeline/DatabaseConnection.java +++ beeline/src/java/org/apache/hive/beeline/DatabaseConnection.java @@ -54,6 +54,9 @@ private Schema schema = null; private Completor sqlCompletor = null; + public boolean isClosed() { + return (null == connection); + } public DatabaseConnection(BeeLine beeLine, String driver, String url, Properties info) throws SQLException { @@ -101,15 +104,6 @@ public boolean isDelimiterChar(String buf, int pos) { /** * Connection to the specified data source. - * - * @param driver - * the driver class - * @param url - * the connection URL - * @param username - * the username - * @param password - * the password */ boolean connect() throws SQLException { try {