Hive进阶_Hive的客户端操作
2024-09-29 20:00:59
启动远程客户端 # hive --service hiveserver2
获取连接-〉创建运行环境-〉执行HQL-〉处理结果-〉释放资源
工具类
package demo.utils; import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement; public class JDBCUtils {
private static String driverString = "org.apache.hive.jdbc.HiveDriver";
private static String urlString = "jdbc:hive2://sd-9c1f-2eac:10000/default";
static {
try {
Class.forName(driverString);
} catch (ClassNotFoundException e) {
throw new ExceptionInInitializerError(e);
}
} public static Connection getConnection() {
try {
return DriverManager.getConnection(urlString);
} catch (SQLException e) {
e.printStackTrace();
}
return null;
} public static void release (Connection conn, Statement st, ResultSet rs){
if (rs!=null){
try{
rs.close();
}catch(SQLException e){
e.printStackTrace();
}finally{
rs=null;
}
}
if (st!=null){
try{
st.close();
}catch(SQLException e){
e.printStackTrace();
}finally{
st=null;
}
}
if (conn!=null){
try{
conn.close();
}catch(SQLException e){
e.printStackTrace();
}finally{
conn=null;
}
}
} }
JDBCUtil.java
测试类
package demo.hive; import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement; import demo.utils.JDBCUtils; public class HiveJDBCDemo {
public static void main(String[] args) {
Connection conn=null;
Statement st=null;
ResultSet rs=null;
String sql="select * from sampledata";
conn=JDBCUtils.getConnection();
try {
st=conn.createStatement();
rs = st.executeQuery(sql);
while(rs.next()){
String sid = rs.getString(1);
String sname = rs.getString(2);
String gender = rs.getString(3);
System.out.println(sid+" "+sname+" "+gender);
}
} catch (SQLException e) {
e.printStackTrace();
}finally{
JDBCUtils.release(conn, st, rs);
} } }
HiveJDBCDemo.java
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/C:/Users/PL62716/workspace/HiveDemo/lib/log4j-slf4j-impl-2.4.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/C:/Users/PL62716/workspace/HiveDemo/lib/slf4j-log4j12-1.7.22.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]
ERROR StatusLogger No log4j2 configuration file found. Using default configuration: logging only errors to the console.
1 Tom M
2 Mary F
3 Jerry M
4 Rose M
5 Mike F
add hive/lib->all jar and hadoop->share->hadoop->common->hadoop-common.jar to project build path.
最新文章
- DeprecatedAttribute vs. ObsoleteAttribute
- linux命令分享（四）：iostat
- Web Audio API_基本概念
- U3D临时文件GICache巨大
- php phpeclipse + xampp 配置安装过程
- PS4 的下载速度问题
- java懒汉式单例遇到多线程
- Spring的配置文件
- C#读取Excel五种方式的体会
- 运维小东西：每天备份sql到远程服务器上
- 限制TextBox输入，只能输入整数
- MVC 创建Word文档
- xampp——apache服务启动问题（端口占用）
- 004_Python高级特性（1）：Iterators、Generators和itertools（参考）
- 2019.01.22 uoj#14. 【UER #1】DZY Loves Graph（并查集）
- 生成学习算法(Generative Learning algorithms)
- 12月8日 周五 image_tag.
- Elasticsearch 索引的全量/增量更新
- UVaLive 2531 The K-League (网络流)
- IOS第三方之SVProgressHUD