diff --git itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestJdbcDriver2.java itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestJdbcDriver2.java index 1ba8ad3..59c8ddb 100644 --- itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestJdbcDriver2.java +++ itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestJdbcDriver2.java @@ -1302,7 +1302,7 @@ public void testDescribeTable() throws SQLException { public void testDatabaseMetaData() throws SQLException { DatabaseMetaData meta = con.getMetaData(); - assertEquals("Hive", meta.getDatabaseProductName()); + assertEquals("Apache Hive", meta.getDatabaseProductName()); assertEquals(HiveVersionInfo.getVersion(), meta.getDatabaseProductVersion()); assertEquals(System.getProperty("hive.version"), meta.getDatabaseProductVersion()); assertTrue("verifying hive version pattern. got " + meta.getDatabaseProductVersion(), diff --git jdbc/src/java/org/apache/hive/jdbc/HiveDatabaseMetaData.java jdbc/src/java/org/apache/hive/jdbc/HiveDatabaseMetaData.java index 5087ded..62c3835 100644 --- jdbc/src/java/org/apache/hive/jdbc/HiveDatabaseMetaData.java +++ jdbc/src/java/org/apache/hive/jdbc/HiveDatabaseMetaData.java @@ -265,7 +265,15 @@ public int getDatabaseMinorVersion() throws SQLException { } public String getDatabaseProductName() throws SQLException { - return "Hive"; + TGetInfoReq req = new TGetInfoReq(sessHandle, GetInfoType.CLI_DBMS_NAME.toTGetInfoType()); + TGetInfoResp resp; + + try { + resp = client.GetInfo(req); + } catch (TException e) { + throw new SQLException(e.getMessage(), "08S01", e); + } + return resp.getInfoValue().getStringValue(); } public String getDatabaseProductVersion() throws SQLException {