HiveServer2可以通过JDBC访问,首先确定JDBC驱动,并加载驱动

private static String driverName = "org.apache.hive.jdbc.HiveDriver";
        try {
            Class.forName(driverName);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }

创建数据连接,指定连接路径、用户名、密码

Connection con = DriverManager.getConnection("jdbc:hive2://10.110.18.216:10000/sparktest", "root", "root");

创建Statement

Statement stmt = con.createStatement();

创建表

        String tableName = "wyphao";
        stmt.execute("drop table if exists " + tableName);
        stmt.execute("create table " + tableName +  " (key int, value string)");

查询数据

        sql = "select * from " + tableName;
        res = stmt.executeQuery(sql);
        while (res.next()) {
            System.out.println(String.valueOf(res.getInt(1)) + "\t" + res.getString(2));
        }

results matching ""

    No results matching ""