用java api 实现查询 Hive 数据

版本：cdh5.4.7， hive1.1.0

pom文件

　　　　　　　　　<dependency><groupId>org.apache.hive</groupId><artifactId>hive-jdbc</artifactId><version>1.2.1</version></dependency><dependency><groupId>org.apache.hadoop</groupId><artifactId>hadoop-common</artifactId><version>2.6.0</version></dependency><dependency><groupId>org.apache.hadoop</groupId><artifactId>hadoop-client</artifactId><version>2.6.0</version></dependency><dependency><groupId>org.apache.thrift</groupId><artifactId>libthrift</artifactId><version>0.9.3</version></dependency>

需要先启动的服务有:

./hive --service hiveserver2

./hive --service metastore

　java代码：

public static void main(String[] args) {String connectionURL = "jdbc:hive2://node11:10000/didu";String drivername = "org.apache.hive.jdbc.HiveDriver";String username = "";String password = "";try {Class.forName(drivername);} catch (ClassNotFoundException e){// TODO Auto-generated catch block
            e.printStackTrace();System.exit(1);}try {Connection con = DriverManager.getConnection(connectionURL, username, password);if(con != null) {System.out.println("Connected");}else{System.out.println("Not Connected");}Statement stmt = con.createStatement(); // select * query
                String sql;ResultSet res;sql = "select * from u_data limit 10";// sql = "show tables";System.out.println("Running: " + sql);res = stmt.executeQuery(sql);while (res.next()){System.out.println(String.valueOf(res.getString(1)) + "\t" + res.getString(2));}}catch(SQLException se) {se.printStackTrace();}}

结果展示：

转载于:https://www.cnblogs.com/zhanggl/p/5473843.html

用java api 实现查询 Hive 数据相关推荐

ES8(Java API Client)查询详解
根据我之前文章对 ES命令的查询使用,测试索引的文档数据前面文章有提到的. 下面我们就通过 ES8(Java API Client)来进行查询. 参考官方AP文档:https://www.elasti ...
ElasticSearch java API - 聚合查询-聚合多字段聚合demo
以球员信息为例,player索引的player type包含5个字段,姓名,年龄,薪水,球队,场上位置. index的mapping为: "mappings": {"pl ...
es java api 子查询,criteria 子查询 es
elasticsearch.core.query中Criteria类各个方法详解--CSDN... 2016年2月25日 asticsearch.core.query中Criteria类各个方法详解 ...
java一次查询900w数据_一次SQL查询优化原理分析（900W+数据，从17s到300ms）
有一张财务流水表,未分库分表,目前的数据量为9555695,分页查询使用到了limit,优化之前的查询耗时16 s 938 ms (execution: 16 s 831 ms, fetching: ...
Bootstrap4+MySQL前后端综合实训-Day06-PM【MD5加码-生成32位md5码、ResultData.java、分页查询用户数据、添加用户按钮的实现】
[Bootstrap4前端框架+MySQL数据库]前后端综合实训[10天课程博客汇总表详细笔记][附:实训所有代码] 目录 MD5加码生成32位md5码 ResultData.java 分页查询 ...
mongodb java 多条件查询_MongoDB_Java连接mongo 使用Java多条件查询mongo数据
在mongo shell中的查询语句是这样的.. db.user.find({"age":{"$gt":5,"$lt":14}})我们用Ja ...
java 实现违章_基于JAVA的违章查询助手数据调用代码实例详解
[Java]代码 import java.io.BufferedReader; import java.io.DataOutputStream; import java.io.IOException; ...
java 实现违章_基于JAVA的违章查询助手数据调用代码实例
1.[代码][Java]代码 import java.io.BufferedReader; import java.io.DataOutputStream; import java.io.IOExce ...
java使用多线程查询大批量数据
前言在某些时候,一旦单表数据量过大,查询数据的时候就会变得异常卡顿,虽然在大多数情况下并不需要查询所有的数据,而是通过分页或缓存的形式去减少或者避免这个问题,但是仍然存在需要这样的场景,比如需要导出 ...

用java api 实现查询 Hive 数据

用java api 实现查询 Hive 数据相关推荐

最新文章

热门文章