Hive中java对数据库、表的操作

谁借莪１个温暖的怀抱￠ 2022-06-13 12:54 226阅读 0赞

在应用Hive之前，首先搭建Hive环境，关于Hive的搭建 参考之前的搭建文档

[http://blog.csdn.net/liulihui1988/article/details/74351532][http_blog.csdn.net_liulihui1988_article_details_74351532]

## java代码执行Hive脚本 ##

java代码执行Hive脚本，需要启动Hive的内部服务，供其他或者java代码链接，Hive内部服务启动命令

# ./hive --service hiveserver2

![这里写图片描述][SouthEast]

启动成功后tcp会自动监听 一个10000的端口

![这里写图片描述][SouthEast 1]

但是这里监听的IP是127.0.0.1,是不能供其它链接的，需要修改配置文件，指定服务地址，IP或者服务器名称

*  需改 Hive-site.xml 的配置文件

# vi ../conf/hive-site.xml

需要把如下value的localhost 改为服务器名称或者IP

<property>
      <name>hive.server2.thrift.bind.host</name>
      <value>centos-node6</value>
      <description>Bind host on which to run the HiveServer2 Thrift interface.
      Can be overridden by setting $HIVE_SERVER2_THRIFT_BIND_HOST</description>
    </property>

再次启动Hive的内部服务，查看监听的tcp和端口号服务

![这里写图片描述][SouthEast 2]

内部服务开启成功，现在可以供其它链接Hive，本地测试 命令进入/bin目录下

# ./beeline

beeline> !connect jdbc:hive2://centos-node6/default;

![这里写图片描述][SouthEast 3]

用户名默认：root 密码：无

登陆成功后命令查看default数据库中的表

show tables

出现错误 5000L，这是Hive的一个bug，需要修改配置文件

![这里写图片描述][SouthEast 4]

修改配置文件 hive-site.xml，修改value值为5000

<property>
      <name>hive.server2.long.polling.timeout</name>
      <value>5000</value>
      <description>Time in milliseconds that HiveServer2 will wait, before responding to asynchronous calls that use long polling</description>
    </property>

再次命令查看default 中的表 show tables

![这里写图片描述][SouthEast 5]

远程链接Hive测试成功！

## java代码JDBC链接Hive ##

*  jdbc测试链接Hive代码如下

import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.Statement;
    
    /** * Hive远程测试连接 * @author llh * */
    public class HiveTest { 
    
        public static void main(String[] args) throws Exception{
            Class.forName("org.apache.hive.jdbc.HiveDriver");
            Connection conn = DriverManager.getConnection("jdbc:hive2://centos-node6/default", "root", "");
            try {
                Statement st = conn.createStatement();
                ResultSet re = st.executeQuery("select count(*) from t_emp"); 
                if(re.next()){
                    System.err.println("t_emp数据条数:"+re.getInt(1));
                }
            } catch (Exception e) {
                e.printStackTrace();
            }finally{
                conn.close();
            }
        }
    
    }

![这里写图片描述][SouthEast 6]

测试成功

[http_blog.csdn.net_liulihui1988_article_details_74351532]: http://blog.csdn.net/liulihui1988/article/details/74351532
[SouthEast]: /images/20220613/024337837d1d45378ca952c451efc0a5.png
[SouthEast 1]: /images/20220613/4e1373a1a0da45b08d2e19310eedf312.png
[SouthEast 2]: /images/20220613/f42c347bbf37414082d9ecb8aa83d683.png
[SouthEast 3]: /images/20220613/fa28b67936db4720996b0fdce7956bfb.png
[SouthEast 4]: /images/20220613/7ea0004022b642249eb1934ad031c3c8.png
[SouthEast 5]: /images/20220613/d8a8a6fd93924fe199dfcf410d17dd9c.png
[SouthEast 6]: /images/20220613/90235d521f594e48934e62c65f268a12.png