栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

5.1.5、Hive

5.1.5、Hive

首先将hive的服务端开启 --hive连接的 端口为10000

启动hiveserver2
service hiveserver2 &
或者
hiveserver2 &(配好环境变量)

导包:

    org.apache.hadoop
    hadoop-common
    2.7.6




    org.apache.hive
    hive-jdbc
    1.2.1

如果sql语句是使用了开窗函数的就需要在url后面指定用户root,由于底层是使用hive驱动mapreduce,需要用户,直接在shell上就是root用户,使用java连接时没有指定用户

public class Demo01Conn {
    public static void main(String[] args) throws Exception{
        Class.forName("org.apache.hive.jdbc.HiveDriver");
        Connection connection = DriverManager.getConnection("jdbc:hive2://master:10000/shujia");
        String sql="select * from students_year_month";
        PreparedStatement statement = connection.prepareStatement(sql);
        ResultSet re = statement.executeQuery();
        while (re.next()){
            String id = re.getString("id");
            String name = re.getString("name");
            int age = re.getInt("age");
            String gender = re.getString("gender");
            String clazz = re.getString("clazz");
            String year = re.getString("year");
            String month = re.getString("month");
            String string=id+"t"+name+"t"+age+"t"+gender+"t"+clazz+"t"+year+"t"+month;
            System.out.println(string);
        }
        statement.close();
        re.close();
        connection.close();
    }
}
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/303172.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号