HIVE JDBC连接详解
发表于:2024-11-26 作者:千家信息网编辑
千家信息网最后更新 2024年11月26日,package org.conan.myhadoop.mr;import java.sql.Connection;import java.sql.DriverManager;import java.s
千家信息网最后更新 2024年11月26日HIVE JDBC连接详解
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存在的安全性、并发性等问题。
上面的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
问题
数据
版本
安全
安全性
信息
全新
密码
文章
用户
用户名
面的
参考
服务
查询
驱动
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全
法院网络安全岗位
软件开发辅助工具的特点
手机服务器选项
北京长河九天网络技术有限公司
无盘服务器文件管理
asp取服务器时间
我国军事管理用什么数据库技术
四线城市的软件开发公司
数据库技术---是什么
数据库删除一个用户名
无锡进口软件开发管理模式
自学网络安全学习路径
饥荒联机服务器没有响应
什么东西包含网络技术
程序编程和软件开发有关系吗
自网络技术进入中国之后
数据库文件后缀mdf
服务器不用ecc内存
二次安防数据库
ios app 服务器端
哈工大数据库建材
路由器ppoe服务器
陕西优扬龙网络技术有限公司
幼儿园网络安全教育周美篇
网络安全各个种类的图片
假定一个工厂的数据库
网络安全素质教育课程代码
计算机软件也包括软件开发
国家时间同步服务器
天融信网络安全培训可靠吗