JDBC 连接Hive 简单样例（开启Kerberos）

• 运用 Ambari 搭建的HDP 集群，由于开启了kerberos ，对外提供Hive数据时统一用JDBC的方式，所以写了下面这么一个简单样例供第三方数据接入参考。
  代码如下所示：

/**
* 用于连接Hive所需的一些参数设置 driverName:用于连接hive的JDBC驱动名 When connecting to
* HiveServer2 with Kerberos authentication, the URL format is:
* jdbc:hive2://<host>:<port>/<db>;principal=
* <Server_Principal_of_HiveServer2>
*/
private static String driverName = "org.apache.hive.jdbc.HiveDriver";
// 注意：这里的principal是固定不变的，其指的hive服务所对应的principal,而不是用户所对应的principal
private static String url = "jdbc:hive2://168.61.2.26:10000/default;principal=hive/ip-168-61-2-26.htsc.com@HTSC.COM";
private static String sql = "";
private static ResultSet res;
public static Connection get_conn() throws SQLException, ClassNotFoundException {
/** 使用Hadoop安全登录 **/
org.apache.hadoop.conf.Configuration conf = new org.apache.hadoop.conf.Configuration();
conf.set("hadoop.security.authentication", "Kerberos");
if (System.getProperty("os.name").toLowerCase().startsWith("win")) {
// 默认：这里不设置的话，win默认会到 C盘下读取krb5.init
System.setProperty("java.security.krb5.conf", "C:/Windows/krbconf/bms/krb5.ini");
} // linux 会默认到 /etc/krb5.conf 中读取krb5.conf,本文笔者已将该文件放到/etc/目录下，因而这里便不用再设置了
try {
UserGroupInformation.setConfiguration(conf);
UserGroupInformation.loginUserFromKeytab("test2/hdp39@BMSOFT.COM", "./conf/test2.keytab");
} catch (IOException e1) {
e1.printStackTrace();
}
Class.forName(driverName);
Connection conn = DriverManager.getConnection(url);
return conn;
}

最后

以上就是感性发箍为你收集整理的JDBC 连接Hive 简单样例（开启Kerberos）的全部内容，希望文章能够帮你解决JDBC 连接Hive 简单样例（开启Kerberos）所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。