本篇教程探讨了大数据技术 Java采用JDBC的方式连接Hive，希望阅读本篇文章以后大家有所收获，帮助大家对大数据技术的理解更加深入。

<

一、Hive的访问方式

一般情况下，Hive是不能直接Java连接并访问的，后来出现来一个SparkSQL的东东，变得可以通过JDBC的方式访问连接。首先，我先介绍一些从Linux下访问的方法：

1、远程登录到Linux平台：

2、进入到hive数据库中，我们执行一条查询语句：

通过上图可以看到，系统执行了Map/Reduce操作，并最后显示相关的结果。

这里有一个干货哦：Hive查询语句不支持类似于Mysql中的分页查询的，因此，这里采用了另外一种办法进行分页，自己看图片学习啦~！

3、下边我们采用Beeline远程连接SqarkSQL然后访问Hive数据。

 

通过上边页面可以看到，系统可以正确将数据查询出来。

二、使用Java代码进行连接访问。

如果想要通过Java进行访问，首先要在引用一下三个Jar包：

 
        org.apache.hive 
        hive-jdbc 
        1.2.1 
 
    
 
        org.apache.hadoop 
        hadoop-common 
       2.4.1 
 
   
 
       jdk.tools 
       jdk.tools 
       1.6 
       system 
       ${JAVA_HOME}/lib/tools.jar 
    

 需要注意的是，包的版本一定要确认好，切勿版本过高

如果发生以下错误：

 org.apache.thrift.TApplicationException: Required field 'client_protocol' is unset!   Struct:TOpenSessionReq(client_protocol:null)

则极可能的原因是你项目的hive-jdbc版本和服务器不一致的原因造成的，替换成和服务器一致的版本就可以了，

以下访问代码都已经经过了测试，拿走直接用，哈哈：

 
public static int hiveJDBC_RowCount(String sql,Map params){
    try {
        ResourceBundle rb = ResourceBundle.getBundle("config");
        Class.forName(rb.getString("hivedriverClassName")).newInstance();
 
        Connection conn = DriverManager.getConnection(rb.getString("hiveurl"),rb.getString("hiveusername"),rb.getString("hivepassword"));
        java.sql.PreparedStatement pstsm = conn.prepareStatement(sql);
        for(Integer key : params.keySet()){
            pstsm.setString(key, params.get(key));
        }
        ResultSet resultSet = pstsm.executeQuery();
        int rowNum = 0;
        if(resultSet.next()){
            rowNum = resultSet.getInt(1);
        }
        return rowNum;
    } catch (Exception e) {
        System.out.println(e);
        return 0;
    }
}

 

 
hivedriverClassName=org.apache.hive.jdbc.HiveDriver
hiveurl=jdbc:hive2://192.168.31.243:10000/default
hiveusername=root
hivepassword=    

本文由职坐标整理发布，学习更多的大数据技术相关知识，请关注职坐标大技术云计算大技术技术频道！