本文共 2143 字，大约阅读时间需要 7 分钟。

官方文档

1、pom.xml

       
        
            
     
      org.apache.kylin
             
     
      kylin-jdbc
             
     
      2.3.1
         
        ...  
   

2、Statement

package com.cntaiping.tpa.kylin;import java.sql.Connection;  import java.sql.DriverManager;import java.sql.ResultSet;  import java.sql.Statement;  public class KylinDemo1 {    public static void main(String[] args) throws Exception{        String conStr = "jdbc:kylin://10.17.12.160:7070/learn_kylin";        Class.forName("org.apache.kylin.jdbc.Driver");        Connection conn = DriverManager.getConnection(conStr, "ADMIN", "KYLIN");          Statement state= conn.createStatement();          String sql="select part_dt, sum(price) as total_selled,count(distinct seller_id) as sellers " +                  "from kylin_sales group by part_dt order by part_dt limit 5";        ResultSet rs=state.executeQuery(sql);          System.out.println("part_dt\t"+ "\t" + "total_selled" + "\t" +"sellers");                      while(rs.next()) {                System.out.println(rs.getString(1)+ "\t" +rs.getString(2) + "\t" +rs.getString(3));          }      }}

运行结果

part_dt     total_selled    sellers2011-12-31  466.9037    122012-01-01  970.2347    172012-01-02  917.4138    142012-01-03  553.0541    102012-01-04  732.9007    18

3、PreparedStatement

package com.cntaiping.tpa.kylin;import java.sql.Connection;  import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;  public class KylinDemo2 {    public static void main(String[] args) throws Exception{        String conStr = "jdbc:kylin://10.17.12.160:7070/learn_kylin";        Class.forName("org.apache.kylin.jdbc.Driver");        Connection conn = DriverManager.getConnection(conStr, "ADMIN", "KYLIN");            String sql="select * from KYLIN_CATEGORY_GROUPINGS where LEAF_CATEG_ID = ?";        PreparedStatement state = conn.prepareStatement(sql);          state.setLong(1,10058);          ResultSet rs= state.executeQuery();                    while(rs.next()) {                System.out.println(rs.getString(1)+ "\t" +rs.getString(2) + "\t" +rs.getString(3));          }      }}