SpringBoot集成Impala

直接上干货---------------

1.由于impala的jar包可能无法直接maven下载,所以需要提前准备好jar 我是把jar直接放到nexus上方便pom文件引入

        <!-- 驱动包 -->
        <dependency>
            <groupId>org.apache.impala</groupId>
            <artifactId>ImpalaJDBC</artifactId>
            <version>2.6.23</version>
        </dependency>
         <!-- 连接池 -->
        <dependency>
            <groupId>com.zaxxer</groupId>
            <artifactId>HikariCP</artifactId>
        </dependency>

2.驱动--- com.cloudera.impala.jdbc41.Driver

3. 进入com.cloudera.impala.jdbc41.Driver类中 确保maven正常识别到jar

4.实际测试


    Connection conResult = null;
    Connection conCount = null;

    @NacosValue(value = "${supplier.impala.jdbc.url}",autoRefreshed = true)
    private String  jdbcUrl;

    @NacosValue(value = "${supplier.impala.jdbc.driver.name}",autoRefreshed = true)
    private String  jdbcDriver;
     
    public String getStatisData() {
       try {
           String connectionUrl = jdbcUrl;
           String jdbcDriverName = jdbcDriver;
           //查询语句
           String sqlResult = "select * from 库名.表名";
           conResult = DriverManager.getConnection(connectionUrl);
           //加载驱动
           Class.forName(jdbcDriverName);
           Statement stmtResult = conResult.createStatement();
           ResultSet rsResult = stmtResult.executeQuery(sqlResult);
           while (rsResult.next()) {
            //取出每列值
            Integer pvCnt = rsResult.getInt("pv_cnt");
           }
           if(conResult != null){
               conResult.close();
           }
           if(conCount != null){
               conCount.close();
           }
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
        return "";
    }


版权声明:本文为PanZiHao_BeiJing原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。