Calcite源码阅读二

简介: 如何利用calcite框架使用sql读取csv文件

一、利用calcite项目使用sql读取csv文件
进入calcite的example/csv module,在该module下新建main方法的函数,代码如下

  public static void main(String[] args) throws Exception{
  Properties info = new Properties();
  info.put("model",
      "inline:"
          + "{\n"
          + "  version: '1.0',\n"
          + "  defaultSchema: 'SALES',\n"
          + "   schemas: [\n"
          + "     {\n"
          + "       name: 'SALES',\n"
          + "       tables: [\n"
          + "         {\n"
          + "           name: 'DEPTS',\n"
          + "           type: 'custom',\n"
          + "           factory: 'org.apache.calcite.adapter.csv.CsvTableFactory',\n"
          + "           operand: {\n"
          + "             file: '/Users/xxx/project/calcite/example/csv/src/test/resources/sales/DEPTS.csv',\n"
          + "             flavor: 'scannable'\n"
          + "           }\n"
          + "         }\n"
          + "       ]\n"
          + "     }\n"
          + "   ]\n"
          + "}");
  Connection connection = DriverManager.getConnection("jdbc:calcite:", info);
  Statement statement = connection.createStatement();
  ResultSet rs = statement.executeQuery("select * from DEPTS");
  while (rs.next()) {
    System.out.println(rs.getString(1));
  }
  rs.close();
  statement.close();
  connection.close();
}

其中file是自己本地文件路径,通过这种方式可以使用select方法访问DEPTS.csv文件,执行项目输出

  10
  20
  30

至此,我们完成了calcite项目的基本使用方式

目录
相关文章
|
8月前
|
SQL Java 数据库连接
Apache Zeppelin系列教程第四篇——JDBCInterpreter原理分析
Apache Zeppelin系列教程第四篇——JDBCInterpreter原理分析
84 0
|
SQL 算法 Java
Apache Calcite入门
Apache Calcite入门
405 0
|
8月前
|
存储 SQL 关系型数据库
Apache Doris 聚合函数源码阅读与解析|源码解读系列
Apache Doris Active Contributor 隐形通过本文记录下对源码的理解,以方便新人快速上手源码开发。
Apache Doris 聚合函数源码阅读与解析|源码解读系列
|
8月前
|
Java 数据库连接 Apache
Apache Zeppelin系列教程第五篇——Interpreter原理分析
Apache Zeppelin系列教程第五篇——Interpreter原理分析
137 0
|
资源调度 前端开发 Java
深度剖析Dinky源码(上)
深度剖析Dinky源码
470 0
|
SQL 资源调度 前端开发
深度剖析Dinky源码(下)
深度剖析Dinky源码(下)
368 0
|
Java Apache 开发工具
Flink 源码阅读环境搭建
阅读优秀的源码是提升我们代码技能最重要的手段之一,工欲善其事必先利其器,所以,搭建好源码阅读环境是我们阅读的第一步。
|
SQL Web App开发 JSON
深度剖析Dinky源码
深度剖析Dinky源码
918 0
|
存储 分布式计算 Spark
【源码解读】|SparkContext源码解读(上)
【源码解读】|SparkContext源码解读
204 0
【源码解读】|SparkContext源码解读(上)
|
存储 JSON 缓存
【源码解读】|SparkContext源码解读(下)
【源码解读】|SparkContext源码解读

热门文章

最新文章