搭建Hive JDBC开发环境.docx

搭建Hive JDBC开发环境-hzz第一部分：搭建Hive JDBC开发环境 新建工程hiveTest 本实例建立在hadoop-2.0.2、hive-0.11.0、jdk-7u21-linux-i586、mysql-5.6.12-linux-glibc2.5-i686环境搭建好的情况下导入Hive依赖的包 hive-exec-0.11.0.jarhive-jdbc-0.11.0.jarhive-metastore-0.11.0.jarhive-service-0.11.0.jarlibfb303-0.9.0.jarhadoop-core-1.0.3.jarHive 命令行启动Thrift服务 hive -service hiveserver & -&程序后台方式运行 第二部分：基本操作对象的介绍 Connection 说明：与Hive连接的Connection对象 Hive 的连接 jdbc:hive:/IP:10000/default“ 获取Connection的方法 DriverManager.getConnection(jdbc:hive:/IP:10000/default, , ); Statement 说明: 用于执行语句 创建方法 Statement stmt = con.createStatement(); 主要方法 executeQuery execute ResultSet 说明：用来存储结果集 创建方法 stmt.executeQuery 方法得到 主要方法 getString() 特殊类型的处理 Array Map Struct 第三部分：简单示例 package mon;import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import org.apache.log4j.Logger;public class ConnHiveTest private static String driverName = org.apache.hadoop.hive.jdbc.HiveDriver; private static String url = jdbc:hive:/3:10000/default; private static String user = hive; private static String password = mysql; private static String sql = ; private static ResultSet res; private static final Logger log = Logger.getLogger(ConnHiveTest.class);/* * param args */public static void main(String args) / TODO Auto-generated method stub try Class.forName(driverName); Connection conn = DriverManager.getConnection(url, user, password); Statement stmt = conn.createStatement(); / 创建的表名 String tableName = testHiveDriverTable; /* 第一步:存在就先删除 */ sql = drop table + tableName; stmt.executeQuery(sql); System.out.println(删除表+tableName+成功！); /* 第二步:不存在就创建 */ sql = create table + tableName + (key int, value string) row format delimited fields terminated by t; stmt.executeQuery(sql); / 执行“show tables”操作 sql = show tables + tableName + ; System.out.println(Running: + sql); res = stmt.executeQuery(sql); System.out.println(执行“show tables”行结运果:); if (res.next() System.out.println(res.getString(1); / 执行“describe table”操作 sql = describe + tableName; System.out.println(Running: + sql); res = stmt.executeQuery(sql); System.out.println(执行“describe table”运行结果:); while (res.next() System.out.println(res.getString(1) + t + res.getString(2); / 执行“load data into table”操作 String filepath = /temp/testinfo.txt; sql = load data local inpath + filepath + into table + tableName; System.out.println(Running: + sql); res = stmt.executeQuery(sql); / 执行“select * query”操作 sql = select * from + tableName; System.out.println(Running: + sql); res = stmt.executeQuery(sql); System.out.println(执行“select * query”运行结果:); while (res.next() System.out.println(res.getInt(1) + t + res.getString(2); / 执行“regular hive query”操作 sql = select count(1) from + tableName; System.out.println(Running: + sql); res = stmt.executeQuery(sql); System.out.println(执行“regular hive query”运行结果:); while (res.next() System.out.println(res.getString(1); conn.close(); conn = null; catch (ClassNotFoundException e) e.printStackTrace(