栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Java 代码通过Kerberos的方式连接HiveServer2

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Java 代码通过Kerberos的方式连接HiveServer2

背景

        想用LDAP方式连接,结果忘记了密码,还好beeline 通过kerberos 可以连接。

        网上的一些博客给的代码真的是一言难尽,都是一起抄的,所以也就都是错的,经过搜索加自己的思考,终于能够连接成功了。

经测试通过的正确代码
import org.apache.hadoop.security.UserGroupInformation;

import java.sql.*;
// 使用Kerberos 连接 HiveServer2
public class KerberosHiveTest {
        private static String driverName = "org.apache.hive.jdbc.HiveDriver";
        public static void main(String[] args) throws SQLException {
            System.setProperty("java.security.krb5.conf", "/etc/krb5.conf");
            org.apache.hadoop.conf.Configuration conf = new org.apache.hadoop.conf.Configuration();
            conf.set("hadoop.security.authentication", "Kerberos");
            UserGroupInformation.setConfiguration(conf);
            try {
                Class.forName(driverName);
            }
            catch (ClassNotFoundException e) {
                e.printStackTrace();
                System.exit(1);
            }
            System.setProperty("java.security.krb5.conf", "/etc/krb5.conf");
            String JDBC_DB_URL = "jdbc:hive2://10.255.25.6:10000/default;" +
                    "principal=hive/hostname@TEST.LOCAL;"+
                    "authentication=kerberos;";
            Connection con = DriverManager.getConnection(JDBC_DB_URL);
            Statement stmt = con.createStatement();
            String sql = "select * from stu";
            ResultSet res = stmt.executeQuery(sql);
            System.out.println("Running: " + sql);
            while (res.next()) {
                System.out.println(res.getString(1));
                System.out.println(res.getString(2));
            }
            res.close();
            stmt.close();
            con.close();
        }
}

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/696245.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号