Java使用JDBC连接Impala

一、下载驱动
到官网下载对应版本的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的版本:

 Java使用JDBC连接Impala

 我们这里选择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包安装到本地仓库即可。

上一篇:impala基础


下一篇:Hive、Spark、Impala原理阅读笔记