HIVE JDBC连接详解
发表于:2025-12-04 作者:千家信息网编辑
千家信息网最后更新 2025年12月04日,package org.conan.myhadoop.mr;import java.sql.Connection;import java.sql.DriverManager;import java.s
千家信息网最后更新 2025年12月04日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安全错误
数据库的锁怎样保障安全
刻蚀工艺软件开发
维普硕博论文数据库
服务器ups可以提供多久
我的小游戏服务器
影视网站数据库的内容
网络安全监测装置 端口
dw显示数据库记录
杭州入行网络技术有限公司
关系数据库二维表哪两部分
数据库查询每月工资
软件开发广告模式
TP 路由器刷打印机服务器
暗黑西游记多玩服务器
中科院时间服务器
尔雅计算机网络技术2021答案
广州做软件开发
未来教育安卓三级网络技术
武汉众信天成网络技术
软件开发认证考试时间
多豆科技互联网加
西宁软件开发哪家好
海量数据包括哪些数据库
数据库第七版第三章答案
虹口区信息软件开发品质保障
idc 网络安全类
触发器数据库怎么弄
登陆局域网服务器
下列系统数据库中
常用关系数据库有什么
网络安全测评工程师面试问题