Java操作Hive

喜欢ヅ旅行 2022-09-02 00:42 184阅读 0赞

> 使用JDBC操作Hive也需要先启动`hiveserver2`服务

引入依赖

<dependency>
        <groupId>org.apache.hive</groupId>
        <artifactId>hive-jdbc</artifactId>
        <version>3.1.2</version>
    </dependency>

创建连接

import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.Statement;
    
    public class HiveJdbcDemo { 
        public static void main(String[] args) throws Exception{ 
    		// 指定hiveserver2的连接
    		String jdbcUrl = "jdbc:hive2://192.168.0.1:10000"; 
    		// 获取jdbc连接，这里的user使用root，就是linux中的用户名，password随便指定 
    		Connection conn = DriverManager.getConnection(jdbcUrl, "root", "root") 
    		// 获取Statement
    		Statement stmt = conn.createStatement();
    		// 指定查询的sql
    		String sql = "select * from t1";
    		// 执行sql
    		ResultSet res = stmt.executeQuery(sql);
    		// 循环读取结果
    		while (res.next()){            
    			System.out.println(res.getInt("id")+"\t"+res.getString("name"));
    		}
    	} 
    }

这里已经可以查询表了，但是可能会有一些slf4j的抛错，在hive-jdbc中去掉依赖即可

<dependency>
        <groupId>org.apache.hive</groupId>
        <artifactId>hive-jdbc</artifactId>
        <version>3.1.2</version>
        <exclusions>
    		 
    		<exclusion>
    			<groupId>org.slf4j</groupId>
    			<artifactId>slf4j-log4j12</artifactId>
    		</exclusion>
    	</exclusions>
    </dependency>

插入数据与查询一样，修改sql语句即可！