使用用于配置单元的jdbc元数据api获取不明确的结果

smdncfj3 于 2021-06-28 发布在 Hive

关注(0)|答案(1)|浏览(257)

我正在尝试使用 DatabaseMetaData 类似于rdbms。
示例代码：

try (Connection con = getJdbcConnection(connectionUri, driverName, username, password);) {
        DatabaseMetaData metadata = con.getMetaData();
        ResultSet rs = metadata.getTables(null, null, tableName, null);
        while (rs.next()) {
            System.out.println(rs.getString(3));
       }

  } catch (SQLException e) {
  }

private static void registerDriver(String driverName) {
        try {
            Class.forName(driverName);
         } catch (ClassNotFoundException e) {
            LOG.error("No class found for " + driverName + ". Details: " + e);
        }
    }

private static Connection getJdbcConnection(String connectionUri, String driverName, String username,
        String password) throws SQLException{
    registerDriver(driverName);
    return DriverManager.getConnection(connectionUri, username,password);
}

特定数据库中没有表。使用不同的表名，我得到不同的输出。
例如：
我把表名 emp ，共有3条记录 emp 我把表名 employee ，共有5条记录 employee 我把表名 emp12 ，它没有返回任何记录（这是预期的）
我做错什么了吗？
我不应该用吗 DatabaseMetaData 检查表是否存在？

Hive jdbc database-metadata

来源：https://stackoverflow.com/questions/39960901/getting-ambiguous-result-using-jdbc-metadata-api-for-hive

1条答案

按热度按时间

pxy2qtax1#

我需要传入架构名称 getTables 方法
签名：

ResultSet getTables(String catalog,
                  String schemaPattern,
                  String tableNamePattern,
                  String[] types)
                    throws SQLException

我通过了以下考试：
catalog=null；
schemapattern=配置单元架构名称
tablenamepattern=配置单元表名称
类型= new String[] { "TABLE" } 示例代码：

try (Connection con = getJdbcConnection(connectionUri, driverName, username, password);) {
        DatabaseMetaData metadata = con.getMetaData();
        ResultSet rs = metadata.getTables(null, schemaName, tableName, new String[] { "TABLE" });

        while (rs.next()) {
            String tName = rs.getString("TABLE_NAME");
            if (tName != null && tName.equals(tableName)) {
                LOG.info("Table [" + tableName + "] is present in the Database.");
                return true;
            }
        }
        rs.close();

        LOG.info("Table [" + tableName + "] is not present in the Database.");
        return false;

    } catch (SQLException e) {
        LOG.error("Not able to get Table Metadata . Caused By: " + e);
    }

赞(0）回复(0）举报 2021-06-28

我来回答

使用用于配置单元的jdbc元数据api获取不明确的结果

1条答案

相关问题

热门标签

最新问答