Matt

import org.apache.hadoop.security.UserGroupInformation;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.IOException;
import java.security.PrivilegedAction;
import java.sql.*;
import java.util.LinkedList;

/*** 类名： ImpalaJdbcUtils

• • 描述：impala jdbc 的工具类
• • 自定义连接工具池
• • /
    public class ImpalaJdbcUtils {
    private static final Logger log = LoggerFactory.getLogger(ImpalaJdbcUtils.class);
    /* 描述：驱动类
    */
    private static String DRIVER_CLASS = "org.apache.hive.jdbc.HiveDriver";
    private static String CONNECTION_URL = "jdbc:hive2:///default;principal=impala/";
    / 连接池/
    private static LinkedList pool = new LinkedList();// 初始化 10 个连接

  static {
  try {
  for (int i = 0; i < 15; i++) {
  Connection conn = getImpalaConnection();
  // 得到一个连接
  pool.add(conn);
  }
  } catch (Exception e) {
  log.error ("数据库连接池初始化失败，请检查配置", e);
  }
  }
  /*** 从连接池中获取连接 **/
  public static Connection getConnection() throws SQLException {
  // 取出连接池中一个连接
  Connection conn = null;
  // 测试连接是否超时，超时重新连接
  try {
  conn = pool.removeFirst();
  // 执行以下链接，查看是否异常
  String sql = "show DATABASES";
  PreparedStatement ps = conn.prepareStatement(sql);
  ResultSet rs = ps.executeQuery();
  rs.close();
  ps.close();
  }catch (Exception e){
  log.warn ("连接异常，尝试重新生成连接！");
  conn = getImpalaConnection();
  }
  // 删除第一个连接返回
  log.info ("取出一个连接剩余" + pool.size () + "个连接！");
  return conn;
  }

  /*** @Description 释放连接 ***/
  public static void releaseConnection(Connection conn) {
  pool.add(conn);
  log.info ("将连接放回到连接池中，数量:" + pool.size ());
  }
  /*** @Description 获取 impala 连接 * /
  public static Connection getImpalaConnection() {
  try {
  Object o = UserGroupInformation.getLoginUser().doAs((PrivilegedAction) () -> {
  Connection connection = null;
  try {
  Class.forName(DRIVER_CLASS);
  } catch (ClassNotFoundException e) {
  log.error ("加载 impala 驱动失败", e);
  }
  try {
  connection = DriverManager.getConnection(CONNECTION_URL);
  } catch (SQLException e) {
  log.error ("获取 jdbc 连接失败", e);
  }
  return connection;
  });
  return (Connection) o;
  } catch (IOException e) {
  e.printStackTrace();
  }
  return null;
  }
  /* 关闭 jdbc 连接 * **/
  public static void disconnect(Connection connection, ResultSet res, PreparedStatement ps) {
  try {
  if (res != null){
  res.close();
  }
  if (ps != null){
  ps.close();
  }
  if (connection != null) {
  connection.close();
  ImpalaJdbcUtils.releaseConnection(connection);
  }
  } catch (SQLException e) {
  log.error ("jdbc 连接关闭失败", e);
  }
  }

  // 不使用连接池
  public Connection getConnectSync(){
  try {
  Object o = UserGroupInformation.getLoginUser().doAs((PrivilegedAction) () -> {
  Connection connection = null;
  try {
  Class.forName(DRIVER_CLASS);
  } catch (ClassNotFoundException e) {
  log.error ("加载 impala 驱动失败", e);
  }
  try {
  connection = DriverManager.getConnection(CONNECTION_URL);
  } catch (SQLException e) {
  log.error ("获取 jdbc 连接失败", e);
  }
  return connection;
  });
  return (Connection) o;
  } catch (IOException e) {
  e.printStackTrace();
  }
  return null;
  }
  }