Hive使用druid作鏈接池代碼實現

• 配置文檔

hive_jdbc_url=jdbc:hive2://192.168.0.22:10000/default
hive.dbname=xxxxx
hive_jdbc_username=root
hive_jdbc_password=123456

#配置初始化大小、最小、最大
hive_initialSize=20
hive_minIdle=20
hive_maxActive=500

#配置獲取鏈接等待超時的時間
hive_maxWait=60000

 

• Jar包引入（Maven）

        <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid</artifactId>
                <version>1.0.26</version>
        </dependency>    

 

• 代碼實現

public class HiveDataSourceUtil {
    private static DruidDataSource hiveDataSource = new DruidDataSource();
    public static Connection conn = null;
    private static final Logger log = LoggerFactory.getLogger(HiveDataSourceUtil.class); 

    public static DruidDataSource getHiveDataSource() {
        if(hiveDataSource.isInited()){  
            return hiveDataSource;
        }         
                   
        try {       
            Properties dsProp = PropertiesUtil.getDataSourceProp();
            //基本屬性 url、user、password
            hiveDataSource.setUrl(dsProp.getProperty("hive_jdbc_url"));
            hiveDataSource.setUsername(dsProp.getProperty("hive_jdbc_username"));
            hiveDataSource.setPassword(dsProp.getProperty("hive_jdbc_password"));

            //配置初始化大小、最小、最大
            hiveDataSource.setInitialSize(Integer.parseInt(dsProp.getProperty("hive_initialSize")));
            hiveDataSource.setMinIdle(Integer.parseInt(dsProp.getProperty("hive_minIdle")));
            hiveDataSource.setMaxActive(Integer.parseInt(dsProp.getProperty("hive_maxActive")));

            //配置獲取鏈接等待超時的時間
            hiveDataSource.setMaxWait(Integer.parseInt(dsProp.getProperty("hive_maxWait")));

            //配置間隔多久才進行一次檢測，檢測須要關閉的空閒鏈接，單位是毫秒
            hiveDataSource.setTimeBetweenEvictionRunsMillis(60000);

            //配置一個鏈接在池中最小生存的時間，單位是毫秒
            hiveDataSource.setMinEvictableIdleTimeMillis(300000);

//            hiveDataSource.setValidationQuery("select * from xxxx");
            hiveDataSource.setTestWhileIdle(false);
//            hiveDataSource.setTestOnBorrow(false);
//            hiveDataSource.setTestOnReturn(false);

            //打開PSCache，而且指定每一個鏈接上PSCache的大小
            hiveDataSource.setPoolPreparedStatements(true);
            hiveDataSource.setMaxPoolPreparedStatementPerConnectionSize(20);
   
            //配置監控統計攔截的filters
//            hiveDataSource.setFilters("stat");

            hiveDataSource.init();
        } catch (SQLException e) {
            e.printStackTrace();
            closeHiveDataSource();
        }
        return hiveDataSource;
    }

    /**
     *@Description:關閉Hive鏈接池
     */
    public static void closeHiveDataSource(){
        if(hiveDataSource != null){
            hiveDataSource.close();
        }
    }  

    /**
     * 
     *@Description:獲取Hive鏈接 
     *@return
     */
    public static Connection getHiveConn(){
        try {
            hiveDataSource = getHiveDataSource();
            conn = hiveDataSource.getConnection();
        } catch (SQLException e) {
            log.error("--"+e+":獲取Hive鏈接失敗！");
        }
        return conn;
    }

    /**
     *@Description:關閉Hive數據鏈接
     */
    public static void closeConn(){
        try {
            if(conn != null){
                conn.close();
            }
        } catch (SQLException e) {
            log.error("--"+e+":關閉Hive-conn鏈接失敗！");
        }
    }
   

    public static void main(String[] args) throws Exception {
        DataSource ds = HiveDataSourceUtil.getHiveDataSource();
        Connection conn = ds.getConnection();
        Statement stmt = null;
        if(conn == null){  
            System.out.println("null");
        }else{
            System.out.println("conn");
            stmt = conn.createStatement();
            ResultSet res = stmt.executeQuery("select * from xxxx t");  
            int i = 0;
            while(res.next()){
                if(i<10){
                    System.out.println(res.getString(1));
                    i++;
                }
            }
        }

        stmt.close();  
        conn.close();
    }
}

• 服務端服務開啓

打開遠程端口：hive --service hiveserver2 &   
PS本身不懂的話，能夠找運維人員