首先开启hive服务端
新建maven项目
添加依赖
<dependencies> <dependency> <groupId>org.apache.hadoop</groupId> <artifactId>hadoop-common</artifactId> <version>2.7.6</version> </dependency> <dependency> <groupId>org.apache.hive</groupId> <artifactId>hive-jdbc</artifactId> <version>1.2.1</version> </dependency> </dependencies>
测试:
import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; public class HiveText { public static void main(String[] args) throws Exception { //加载包 Class.forName("org.apache.hive.jdbc.HiveDriver"); //连接 Connection conn = DriverManager.getConnection("jdbc:hive2://master:10000/lycc"); //获取执行器 String sql = "select * from studentsinit"; PreparedStatement ps = conn.prepareStatement(sql); //数据处理 ResultSet rs = ps.executeQuery(); while (rs.next()){ System.out.println(rs.getString("name")); } //关闭资源 rs.close(); ps.close(); conn.close(); } }
结果: