大数据+kerberos+impala源码

package com; import com.cloudera.impala.jdbc41.internal.apache.logging.log4j.LogManager; import com.cloudera.impala.jdbc41.internal.apache.logging.log4j.Logger; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.security.UserGroupInformation; import java.io.IOException; import java.security.PrivilegedAction; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException; public class main { private static String JDBC_DRIVER = "com.cloudera.impala.jdbc41.Driver"; private static String CONNECTION_URL = "jdbc:impala://10.10.10.10:21050/default;AuthMech=1;KrbRealm=XXXX.CN;KrbHostFQDN=10.10.10.10;KrbServiceName=impala"; private static final Logger logger = LogManager.getLogger(main.class); public static void main(String[] args) { try { Class.forName(JDBC_DRIVER); } catch (ClassNotFoundException e) { e.printStackTrace(); } try { System.setProperty("java.security.krb5.conf", "/opt/krb5.conf"); Configuration configuration = new Configuration(); configuration.set("hadoop.security.authentication" , "Kerberos"); UserGroupInformation. setConfiguration(configuration); UserGroupInformation.loginUserFromKeytab("impala/XXXXX@SPOTLIGHT.CN", "/opt/impala.keytab"); System.out.println(UserGroupInformation.getCurrentUser() + "------" + UserGroupInformation.getLoginUser()); UserGroupInformation loginUser = UserGroupInformation.getLoginUser(); loginUser.doAs((PrivilegedAction<Object>) () -> { Connection connection = null; int rs ; PreparedStatement ps = null; //刷新表源数据 String sql="refresh xxxx.xxxxx"; try { Class.forName(JDBC_DRIVER); connection = DriverManager.getConnection(CONNECTION_URL); ps = connection.prepareStatement(sql); rs = ps.executeUpdate(); if(rs==-1){ logger.info("执行SQL语句:"+sql+"成功"); } } catch (Exception e) { logger.error("执行SQL语句:"+sql+"失败;"+e); } finally { try { connection.close(); ps.close(); } catch (SQLException e) { e.printStackTrace(); } } return null; }); } catch (IOException e) { e.printStackTrace(); } } }