最全【JDBC-Hive】使用JDBC操作Hive数据库_jdbc操作hive到本地，2024年最新这份字节跳动历年校招大数据开发面试真题解析_hive jdbc

作者：码创造者 | 2024-07-30 15:30:29

踩

hive jdbc

网上学习资料一大堆，但如果学到的知识不成体系，遇到问题时只是浅尝辄止，不再深入研究，那么很难做到真正的技术提升。

需要这份系统化资料的朋友，可以戳这里获取

一个人可以走的很快，但一群人才能走的更远！不论你是正从事IT行业的老鸟或是对IT行业感兴趣的新人，都欢迎加入我们的的圈子（技术交流、学习资源、职场吐槽、大厂内推、面试辅导），让我们一起学习成长！

private static String TARGET = "`dw\_x8v`.`dwd\_tsp\_tab\_tbox\_change`";

private static Connection conn = null;
private static ResultSet rs = null;
private static PreparedStatement ps = null;

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

}


### 2.2.删除



1
2
3
4
5

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”;

//Hive源
private static String SOURCE = "`ods\_x8v`.`ods\_tsp\_tab\_tbox\_change`";
private static String TARGET = "`dw\_x8v`.`dwd\_tsp\_tab\_tbox\_change`";

private static Connection conn = null;
private static ResultSet rs = null;
private static PreparedStatement ps = null;

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

}


### 2.3.修改



1
2
3
4
5

import java.io.IOException;
import java.sql.*;

//Hive源
private static String SOURCE = "`ods\_x8v`.`ods\_tsp\_tab\_tbox\_change`";
private static String TARGET = "`dw\_x8v`.`dwd\_tsp\_tab\_tbox\_change`";

private static Connection conn = null;
private static ResultSet rs = null;
private static PreparedStatement ps = null;

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

}


### 2.4.查询



1
2
3
4
5

import java.io.IOException;
import java.sql.*;

//Hive源
private static String SOURCE = "`ods\_x8v`.`ods\_tsp\_tab\_tbox\_change`";
private static String TARGET = "`dw\_x8v`.`dwd\_tsp\_tab\_tbox\_change`";

private static Connection conn = null;
private static ResultSet rs = null;
private static PreparedStatement ps = null;

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

网上学习资料一大堆，但如果学到的知识不成体系，遇到问题时只是浅尝辄止，不再深入研究，那么很难做到真正的技术提升。

需要这份系统化资料的朋友，可以戳这里获取

止，不再深入研究，那么很难做到真正的技术提升。**

需要这份系统化资料的朋友，可以戳这里获取

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/码创造者/article/detail/904328