最全【JDBC-Hive】使用JDBC操纵Hive数据库_jdbc操纵hive到本地，2024年最新 ...

网上学习资料一大堆，但假如学到的知识不成体系，遇到题目时只是浅尝辄止，不再深入研究，那么很难做到真正的技术提升。
需要这份系统化资料的朋友，可以戳这里获取
一个人可以走的很快，但一群人才能走的更远！岂论你是正从事IT行业的老鸟或是对IT行业感爱好的新人，都接待参加我们的的圈子（技术交流、学习资源、职场吐槽、大厂内推、面试辅导），让我们一起学习发展！

1. private static String TARGET = "`dw\_x8v`.`dwd\_tsp\_tab\_tbox\_change`";
3. private static Connection conn = null;
4. private static ResultSet rs = null;
5. private static PreparedStatement ps = null;
7. public static void main(String[] args) {
8.     //HiveJDBC驱动
9.     try {
10.         Class.forName(JDBC\_DRIVER);
11.     } catch (ClassNotFoundException e) {
12.         e.printStackTrace();
13.     }
14.     //连接Hive
15.     try {
16.         conn = DriverManager.getConnection(HIVE\_URL, HIVE\_USERNAME, HIVE\_PASSWORD);
17.     } catch (SQLException e) {
18.         e.printStackTrace();
19.     }
20.     try {
21.         ps = conn.prepareStatement("insert into " + SOURCE + " values(?, ?)");
22.         //写入数据id为1234，name为张三
23.         ps.setInt(1,1234);
24.         ps.setString(2, "张三");
25.         rs = ps.executeUpdate();
26.     } catch (Exception e) {
27.         e.printStackTrace();
28.     }
29. }

复制代码

}

2. ### 2.2.删除

复制代码

import java.io.IOException;
import java.sql.*;
public class Test{
//Hive连接信息
private static String JDBC_DRIVER = “org.apache.hive.jdbc.HiveDriver”;
private static String HIVE_URL = “jdbc:hive2://192.168.1.1:25005/test”;
private static String HIVE_USERNAME = “root”;
private static String HIVE_PASSWORD = “123456”;

1. //Hive源
2. private static String SOURCE = "`ods\_x8v`.`ods\_tsp\_tab\_tbox\_change`";
3. private static String TARGET = "`dw\_x8v`.`dwd\_tsp\_tab\_tbox\_change`";
5. private static Connection conn = null;
6. private static ResultSet rs = null;
7. private static PreparedStatement ps = null;
9. public static void main(String[] args) {
10.     //HiveJDBC驱动
11.     try {
12.         Class.forName(JDBC\_DRIVER);
13.     } catch (ClassNotFoundException e) {
14.         e.printStackTrace();
15.     }
16.     //连接Hive
17.     try {
18.         conn = DriverManager.getConnection(HIVE\_URL, HIVE\_USERNAME, HIVE\_PASSWORD);
19.     } catch (SQLException e) {
20.         e.printStackTrace();
21.     }
22.     try {
23.         ps = conn.prepareStatement("delete from " + SOURCE + " where id = ?");
24.         //删除id为1234的数据
25.         ps.setInt(1,1234);
26.         //执行数据更新操作
27.         rs = ps.executeUpdate();
28.     } catch (Exception e) {
29.         e.printStackTrace();
30.     }
31. }

复制代码

}

2. ### 2.3.修改

复制代码

import java.io.IOException;
import java.sql.*;
public class Test{
//Hive连接信息
private static String JDBC_DRIVER = “org.apache.hive.jdbc.HiveDriver”;
private static String HIVE_URL = “jdbc:hive2://192.168.1.1:25005/test”;
private static String HIVE_USERNAME = “root”;
private static String HIVE_PASSWORD = “123456”;

1. //Hive源
2. private static String SOURCE = "`ods\_x8v`.`ods\_tsp\_tab\_tbox\_change`";
3. private static String TARGET = "`dw\_x8v`.`dwd\_tsp\_tab\_tbox\_change`";
5. private static Connection conn = null;
6. private static ResultSet rs = null;
7. private static PreparedStatement ps = null;
9. public static void main(String[] args) {
10.     //HiveJDBC驱动
11.     try {
12.         Class.forName(JDBC\_DRIVER);
13.     } catch (ClassNotFoundException e) {
14.         e.printStackTrace();
15.     }
16.     //连接Hive
17.     try {
18.         conn = DriverManager.getConnection(HIVE\_URL, HIVE\_USERNAME, HIVE\_PASSWORD);
19.     } catch (SQLException e) {
20.         e.printStackTrace();
21.     }
22.     try {
23.         ps = conn.prepareStatement("update " + SOURCE + " set name = ? where id = ?");
24.                 //修改id为1234的数据name字段为张三
25.         ps.setString(1, "张三");
26.         ps.setInt(2,1234);
27.         //执行数据更新操作
28.         rs = ps.executeUpdate();
29.     } catch (Exception e) {
30.         e.printStackTrace();
31.     }
32. }

复制代码

}

2. ### 2.4.查询

复制代码

import java.io.IOException;
import java.sql.*;
public class Test{
//Hive连接信息
private static String JDBC_DRIVER = “org.apache.hive.jdbc.HiveDriver”;
private static String HIVE_URL = “jdbc:hive2://192.168.1.1:25005/test”;
private static String HIVE_USERNAME = “root”;
private static String HIVE_PASSWORD = “123456”;

1. //Hive源
2. private static String SOURCE = "`ods\_x8v`.`ods\_tsp\_tab\_tbox\_change`";
3. private static String TARGET = "`dw\_x8v`.`dwd\_tsp\_tab\_tbox\_change`";
5. private static Connection conn = null;
6. private static ResultSet rs = null;
7. private static PreparedStatement ps = null;
9. public static void main(String[] args) {
10.     //HiveJDBC驱动
11.     try {
12.         Class.forName(JDBC\_DRIVER);
13.     } catch (ClassNotFoundException e) {
14.         e.printStackTrace();
15.     }
16.     //连接Hive
17.     try {
18.         conn = DriverManager.getConnection(HIVE\_URL, HIVE\_USERNAME, HIVE\_PASSWORD);
19.     } catch (SQLException e) {
20.         e.printStackTrace();
21.     }
22.     try {
23.             //查询表中id，name字段数据
24.         ps = conn.prepareStatement("select id, name from " + SOURCE);
25.         //将查询结果返回结果集
26.         rs = ps.executeQuery();
27.         //遍历结果集
28.         while (rs.next()) {
29.             int id = rs.getInt(1);
30.             String name = rs.getString(2);
31.         }

复制代码

网上学习资料一大堆，但假如学到的知识不成体系，遇到题目时只是浅尝辄止，不再深入研究，那么很难做到真正的技术提升。
需要这份系统化资料的朋友，可以戳这里获取
一个人可以走的很快，但一群人才能走的更远！岂论你是正从事IT行业的老鸟或是对IT行业感爱好的新人，都接待参加我们的的圈子（技术交流、学习资源、职场吐槽、大厂内推、面试辅导），让我们一起学习发展！
止，不再深入研究，那么很难做到真正的技术提升。**
需要这份系统化资料的朋友，可以戳这里获取
一个人可以走的很快，但一群人才能走的更远！岂论你是正从事IT行业的老鸟或是对IT行业感爱好的新人，都接待参加我们的的圈子（技术交流、学习资源、职场吐槽、大厂内推、面试辅导），让我们一起学习发展！

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。