Kylin如何進行JDBC方式訪問或者調用

       Kylin提供了標準的ODBC和JDBC接口，可以和傳統BI工具進行很好的集成。分析師們能夠用他們最熟悉的工具來享受Kylin帶來的快速。咱們也能夠對它進行定製開發報表等，把kylin當作數據庫服務器就好了。

首先咱們來看一下鏈接Kylin的URL格式爲：

jdbc:kylin://<hostname>:<port>/<kylin_project_name>

注：

若是「ssl」爲true話，那麼上面的端口號應該爲Kylin服務的HTTPS端口號。

 kylin_project_name必須指定，而且在Kylin服務中存在。

運行環境須要把安裝文件的那個lib目錄拷貝到本身的項目引用下

 

下面介紹幾種方式訪問Kylin數據：

第一種方法：使用Statement方式查詢

第二種方法：使用PreparedStatement方式查詢

第三種方法：獲取查詢結果集元數據

 

package org.apache.kylin.jdbc;

import java.sql.SQLException;
import java.util.Properties;
import org.junit.Test;
import java.sql.Connection;  
import java.sql.Driver;
import java.sql.PreparedStatement;
import java.sql.ResultSet;  
import java.sql.Statement;  

/** 
* @author : 
* @date   : 2017年4月17日 
* @version 1.0 
* @parameter  
*/
public class QueryKylinST {

    
    @Test
    public void testStatementWithMockData() throws SQLException, InstantiationException, IllegalAccessException, ClassNotFoundException {
        // 加載Kylin的JDBC驅動程序  
        Driver driver = (Driver) Class.forName("org.apache.kylin.jdbc.Driver").newInstance();  
   
         // 配置登陸Kylin的用戶名和密碼  
         Properties info= new Properties();  
         info.put("user","ADMIN");  
         info.put("password","KYLIN");  
   
         // 鏈接Kylin服務  
         Connection conn= driver.connect("jdbc:kylin://10.8.217.66:7070/learn_kylin",info);  
         Statement state= conn.createStatement();  
         ResultSet resultSet =state.executeQuery("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");  
   
         System.out.println("part_dt\t"+ "\t" + "total_selled" + "\t" +"sellers");  
                    
         while(resultSet.next()) {  
                   String col1 = resultSet.getString(1);  
                   String col2 = resultSet.getString(2);  
                   String col3 = resultSet.getString(3);  
                   System.out.println(col1+ "\t" + col2 + "\t" + col3);  
         }  
    }
    
    @Test
    public  void testanylist() throws Exception {  
        Driver driver =(Driver) Class.forName("org.apache.kylin.jdbc.Driver").newInstance();  
        Properties info= new Properties();  
        info.put("user","ADMIN");  
        info.put("password","KYLIN");  
        Connection conn= driver.connect("jdbc:kylin://10.8.217.66:7070/learn_kylin",info);  
  
        PreparedStatement state = conn.prepareStatement("select * from KYLIN_CATEGORY_GROUPINGS where LEAF_CATEG_ID = ?");  
        state.setLong(1,10058);  
                   
        ResultSet resultSet = state.executeQuery();  
        while (resultSet.next()) {  
                  String col1 = resultSet.getString(1);  
                  String col2 = resultSet.getString(2);  
                  String col3 = resultSet.getString(3);  
                  System.out.println(col1+ "\t" + col2 + "\t" + col3);  
            }  
     }  
    
    @Test
    public  void testmetadatalist() throws Exception {  
        Driver driver = (Driver) Class.forName("org.apache.kylin.jdbc.Driver").newInstance();
        Properties info = new Properties();
        info.put("user", "ADMIN");
        info.put("password", "KYLIN");
        Connection conn = driver.connect("jdbc:kylin://10.8.217.66:7070/learn_kylin", info);
        Statement state = conn.createStatement();
        ResultSet resultSet = state.executeQuery("select * from kylin_sales");

        //第三個是表名稱，通常狀況下若是要獲取全部的表的話，能夠直接設置爲null，若是設置爲特定的表名稱，則返回該表的具體信息。
        ResultSet tables = conn.getMetaData().getTables(null, null, null, new String[]{"TABLE"});
        while (tables.next()) {
//            for (int i = 0; i < 10; i++) {
//                System.out.println(tables.getString(i + 1));               
//            }
            String col1 = tables.getString(1);  //表類別
            String col2 = tables.getString(2);  //表模式
            String col3 = tables.getString(3);  //表名稱
            System.out.println("表信息:"+col1+ "\t" + col2 + "\t" + col3);  
        }
     }  
}

結果以下：因爲單元測試，前後順序不一致，注意忽視

 

 參考資料

http://kylin.apache.org/docs20/howto/howto_jdbc.htmlhttp://www.cnblogs.com/en-heng/p/5420269.html Python Post方式http://blog.csdn.net/linlinv3/article/details/53893144 Java 使用httpClient 進行post訪問