Kylin对接JDBC集成Zepplin的实现方法

        
            org.apache.kylin
            kylin-jdbc
            2.5.1
        
    

package com.xzw.kylin;
 
import java.sql.*;
 
/**
 * @author: xzw
 * @create_date: 2021/5/11 10:21
 * @desc:
 * @modifier:
 * @modified_date:
 * @desc:
 */
public class TestJDBC {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        //1、定义连接串
        String driverClass = "org.apache.kylin.jdbc.Driver";
        String url = "jdbc:kylin://master:7070/emp_dept";
        String user = "ADMIN";
        String password = "KYLIN";
 
        //2、加载驱动
        Class.forName(driverClass);
 
        //3、获取连接
        Connection conn = DriverManager.getConnection(url, user, password);
 
        //4、SQL语句
        String sql = "select dept.dept_name,sum(emp.sal) from emp join dept on emp.dept_no = dept.dept_no group by " +
                "dept.dept_name";
 
        //5、预编译SQL
        PreparedStatement ps = conn.prepareStatement(sql);
 
        //6、执行SQL
        ResultSet rs = ps.executeQuery();
 
        //7、遍历，打印结果
        while (rs.next()) {
            System.out.println(rs.getString(1) + "\t" + rs.getString(2));
        }
 
        //8、关闭连接
        conn.close();
 
    }
}

[root@master software]# tar -zxvf zeppelin-0.8.0-bin-all.tgz -C ../modules/

[root@master zeppelin-0.8.0-bin-all]# bin/zeppelin-daemon.sh start