HIVEJDBC连接详解-创新互联
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存在的安全性、并发性等问题。
创新互联建站主要从事成都网站设计、网站建设、网页设计、企业做网站、公司建网站等业务。立足成都服务乐陵,十多年网站建设经验,价格优惠、服务专业,欢迎来电咨询建站服务:18980820575上面的userName和passWord是hive元数据mysql的用户名和密码
Use Cases: Hive CLI versus Beeline
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
另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。
网站栏目:HIVEJDBC连接详解-创新互联
网页地址:http://myzitong.com/article/pdogd.html