一、下载驱动
到官网下载对应版本的Impala JDBC Connector,我这里下载的是2.6.12版本,若有需要,可自行选择版本:
https://www.cloudera.com/downloads/connectors/impala/jdbc/2-6-12.html
注:官网下载需要填写用户信息,要方便的话这里直接给出2.6.12版本的百度网盘分享地址:
链接:https://pan.baidu.com/s/1lhpljIoVM6HwDXuarv-fkA
提取码:imk2
下载的文件里包含JDBC4 和JDBC4.1的版本:
我们这里选择4.1的版本,解压它并找到ImpalaJDBC41.jar文件。
二、引入jar包
我当前使用的是idea,依次选择:File -> Project Structure -> Libraries -> "+" -> Java,选择引入上面的ImpalaJDBC41.jar文件。
三、测试
这里直接贴出简单的测试代码:
import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; public class ImpalaExample { public static void main(String[] args) throws Exception { //这个地址填写自己的impala server地址,默认端口为21050 //格式为jdbc:impala://[Host]:[Port]/[Schema];[Property1]=[Value];[Property2]=[Value];... //默认连接default库 String connectionUrl = "jdbc:impala://172.16.4.5:21050"; //使用4.1版本 String jdbcDriverName = "com.cloudera.impala.jdbc41.Driver"; //简单的一个查询语句 String sqlStatement = "show tables;"; //加载驱动 Class.forName(jdbcDriverName); try (Connection con = DriverManager.getConnection(connectionUrl)) { //查询 Statement stmt = con.createStatement(); ResultSet rs = stmt.executeQuery(sqlStatement); System.out.println("---begin query---"); //打印输出 while (rs.next()) { System.out.println(rs.getString(1)); } System.out.println("---end query---"); } catch (Exception e) { e.printStackTrace(); } } }
注:如果使用maven,将jar包安装到本地仓库即可。