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

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();
        }
}