dremio jdbc使用

驱动包地址

链接：https://pan.baidu.com/s/1Nivkvze24hRH8pXOQleCgw
提取码：gp9z

数据源是es，dremio支持多种格式类型的数据源。es本身也支持sql查询统计数据，但是现在api支持并不是很灵活，比如想group by 之后的数据分页就很难实现。但是在dremio就完全支持。

dremio 还支持支持数据csv或者json导出数据。

  public static void jdbcDremio(){
        String JDBC_DRIVER = "com.dremio.jdbc.Driver";
        String DB_URL = "jdbc:dremio:direct=172.16.220.135:31010";//浏览器访问端口号9047 ，但是api端口号是31010
        String USER = "";
        String PASS = "";

        String sql ="  SELECT goodsName,count(orderSn) as totalSaleNum " +
                " FROM vem_order_info as order_info group by goodsName order by count(orderSn) desc ";

        try {
            Class.forName(JDBC_DRIVER);
            Connection cc =  DriverManager.getConnection(DB_URL, USER, PASS);
            PreparedStatement ps = cc.prepareStatement(sql);
            ResultSet resultSet = ps.executeQuery();
            while (resultSet.next()) {
                System.out.println("------------------");
                System.out.println(resultSet.getObject(1));
            }
            resultSet.close();
             ps.close();
            cc.close();

        } catch (Exception e) {
            e.printStackTrace();
        }

    }

猜你喜欢