jdbc連接Apache druid


//jdbc連接druid
<
dependency> <groupId>org.apache.calcite.avatica</groupId> <artifactId>avatica-core</artifactId> <version>1.15.0</version> </dependency>
public class Test {
    public static void main(String[] args) throws SQLException {
        AvaticaConnection connection = connection();
        AvaticaStatement statement = connection.createStatement();
        String sql = "select userNo,count(1) as num  from collection_platform_report " +
                "group by userNo " +
                "limit 10";
        ResultSet resultSet = statement.executeQuery(sql);
        while (resultSet.next()) {
            System.out.println(resultSet.getString("num"));
        }

    }

    public static AvaticaConnection connection() throws SQLException {
        String urlStr = "jdbc:avatica:remote:url=http://prod-node6:8888/druid/v2/sql/avatica/";
        Properties connectionProperties = new Properties();
        connectionProperties.put("Content-Type", "application/json; charset=utf-8");
        return (AvaticaConnection) DriverManager.getConnection(urlStr, connectionProperties);

    }
}

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM