通过JDBC驱动连接Hive操作实例
2014-08-07 23:45
447 查看
转自:http://www.aboutyun.com/forum.php?mod=viewthread&tid=7083&highlight=hive
启动Hive远程服务接口:
bin/hive --service hiveserver
测试代码如下
package com.yuxipacific;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class Hive {
public static void main(String[] args) throws Exception {
Class.forName("org.apache.hadoop.hive.jdbc.HiveDriver");
//String dropSQL="drop table javabloger";
//String createSQL="create table javabloger (key int, value string)";
//String insterSQL="LOAD DATA LOCAL INPATH '/work/hive/examples/files/kv1.txt' OVERWRITE INTO TABLE javabloger";
//String querySQL="SELECT a.* FROM javabloger a";
String querySQL="SELECT * FROM pokes";
Connection con = DriverManager.getConnection("jdbc:hive://192.168.11.124:10000/default", "", "");
Statement stmt = con.createStatement();
// stmt.executeQuery(dropSQL);
// stmt.executeQuery(createSQL);
// stmt.executeQuery(insterSQL);
ResultSet res = stmt.executeQuery(querySQL);
while (res.next()) {
System.out.println("Result: key:"+res.getString(1) +" –> value:" +res.getString(2));
}
}
}
复制代码
我们在编程过程中数据库连接比较常用的,如果连接hive可以作为参考:虽然内容较短,但是里面仍有文章: 1.连接涉及到那些包? 2.Class.forName的作用是什么? 3.如何启动远程服务器借口? 4.Statement与传统数据库那个类型作用相似 |
bin/hive --service hiveserver
测试代码如下
package com.yuxipacific;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class Hive {
public static void main(String[] args) throws Exception {
Class.forName("org.apache.hadoop.hive.jdbc.HiveDriver");
//String dropSQL="drop table javabloger";
//String createSQL="create table javabloger (key int, value string)";
//String insterSQL="LOAD DATA LOCAL INPATH '/work/hive/examples/files/kv1.txt' OVERWRITE INTO TABLE javabloger";
//String querySQL="SELECT a.* FROM javabloger a";
String querySQL="SELECT * FROM pokes";
Connection con = DriverManager.getConnection("jdbc:hive://192.168.11.124:10000/default", "", "");
Statement stmt = con.createStatement();
// stmt.executeQuery(dropSQL);
// stmt.executeQuery(createSQL);
// stmt.executeQuery(insterSQL);
ResultSet res = stmt.executeQuery(querySQL);
while (res.next()) {
System.out.println("Result: key:"+res.getString(1) +" –> value:" +res.getString(2));
}
}
}
复制代码
相关文章推荐
- java通过jdbc驱动连接hive操作实例
- java 通过jdbc驱动连接hive操作实例
- java 通过jdbc驱动连接hive操作实例
- java 通过jdbc驱动连接hive操作实例
- java 通过jdbc驱动连接hive操作实例
- java通过JDBC驱动连接操作hive实例
- java通过JDBC驱动连接操作hive实例
- java通过JDBC驱动连接操作hive实例
- java通过JDBC驱动连接操作hive实例
- 通过JDBC驱动连接Hive操作实例
- java 通过jdbc驱动连接hive操作实例
- java 通过jdbc驱动连接hive操作
- Hive用户接口(二)—使用Hive JDBC驱动连接Hive操作实例
- Hive用户接口(二)—使用Hive JDBC驱动连接Hive操作实例
- java通过jdbc驱动连接hive
- 基于CDH5.x 下面使用eclipse 操作hive 。使用java通过jdbc连接HIVESERVICE 创建表出现的问题及解决
- 基于CDH5.x 下面使用eclipse 操作hive 。使用java通过jdbc连接HIVESERVICE 创建表
- JDBC 实例--JDBC通过工具类DBUtil连接到数据库,让我们不再恐惧操作数据库
- Java 通过jdbc连接HIVESERVER
- 通过代理类实现java连接数据库(使用dao层操作数据)实例分享