package org.conan.myhadoop.mr; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class HiveJDBCConnection { private static String driverName = "org.apache.hadoop.hive.jdbc.HiveDriver"; // Hive 0.11.0版本以后org.apache.hive.jdbc.HiveDriver private static String url = "jdbc:hive://localhost:10000/default"; // Hive 0.11.0版本以后jdbc:hive2://localhost:10000/default private static String userName = ""; private static String passWord = ""; public static void main(String[] args) { try { Class.forName(driverName); Connection con = DriverManager.getConnection("url", "userName", "passWord"); Statement stmt = con.createStatement(); // 如果存在了就删除 String tableName = "jdbc_table"; String sql = "drop table if exists " + tableName; stmt.execute(sql); // 创建表 sql = "create table" + tableName + " (key string,value string) row format delimited fields terminated by ',' stored as textfile "; stmt.execute(sql); //加载数据 String Path="/home/hive_1.txt"; sql ="load data local inpath '"+Path+"' into table "+tableName; stmt.execute(sql); // 查询数据 sql ="select * from "+tableName; ResultSet res = stmt.executeQuery(sql); while(res.next()){ System.out.println(res.getString(1)+"\t"+res.getString(1)); } } catch (ClassNotFoundException e) { System.out.println("没有找到驱动类"); e.printStackTrace(); } catch (SQLException e) { System.out.println("连接Hive的信息有问题"); e.printStackTrace(); } } }
上面是用Java连接HiveServer,而HiveServer本身存在很多问题(比如:安全性、并发性等);针对这些问题,Hive0.11.0版本提供了一个全新的服务:HiveServer2,这个很好的解决HiveServer存在的安全性、并发性等问题。
创新互联是一家专注于成都网站建设、成都网站设计与策划设计,平远网站建设哪家好?创新互联做网站,专注于网站建设十多年,网设计领域的专业建站公司;建站业务涵盖:平远等地区。平远做网站价格咨询:028-86922220
上面的userName和passWord是hive元数据MySQL的用户名和密码
The following section focuses on the common uses of Hive CLI/HiveServer1 and how you can migrate to Beeline/HiveServer2 in each case.
http://blog.cloudera.com/blog/2014/02/migrating-from-hive-cli-to-beeline-a-primer/?utm_source=tuicool&utm_medium=referral
参考文章:
http://www.iteblog.com/archives/846
售后响应及时
7×24小时客服热线数据备份
更安全、更高效、更稳定价格公道精准
项目经理精准报价不弄虚作假合作无风险
重合同讲信誉,无效全额退款