quxiucheng / apache-calcite-tutorial Goto Github PK

哥们，我最近想基于Flink1.8 SQL上扩展一些维表JOIN的功能，看了Flink SQL底层解析是通过Calcite的，然后发现哥们你的学习案例和笔记写的非常好和详细，所以想问你留个联系方式，想像您学习请教些Calcite相关的问题。

您好，请教下下面的这个代码转换后的Insert语句存在row关键词，而当前大多数的oracle/mysql/postgresql数据库都不支持，请指教：

	public static void main(String[] args) {
		String sql="insert into dept (name, deptno) values ('a', 123) ,('b',345) ";
        SqlParser.Config config =SqlParser.configBuilder().setCaseSensitive(true).build();
        SqlParser parser = SqlParser.create(sql, config);
        SqlNode sqlNode =null;
        try {
				sqlNode=parser.parseStmt();
        }catch(SqlParseException e) {
        	e.printStackTrace();
        }
        System.out.println(sqlNode.toSqlString(OracleSqlDialect.DEFAULT));
        System.out.println("========================");
        System.out.println(sqlNode.toSqlString(PostgresqlSqlDialect.DEFAULT));
        System.out.println("========================");
        System.out.println(sqlNode.toSqlString(MysqlSqlDialect.DEFAULT));
	}

结果输出为：

INSERT INTO "DEPT" ("NAME", "DEPTNO")
VALUES ROW('a', 123),
ROW('b', 345)
========================
INSERT INTO "DEPT" ("NAME", "DEPTNO")
VALUES ROW('a', 123),
ROW('b', 345)
========================
INSERT INTO `DEPT` (`NAME`, `DEPTNO`)
VALUES ROW('a', 123),
ROW('b', 345)

但我期望的是：

INSERT INTO "DEPT" ("NAME", "DEPTNO")
VALUES ('a', 123),('b', 345)
========================
INSERT INTO "DEPT" ("NAME", "DEPTNO")
VALUES ('a', 123),('b', 345)
========================
INSERT INTO `DEPT` (`NAME`, `DEPTNO`)
VALUES ('a', 123),('b', 345)

有什么底层实现的案例吗？
从自定义Driver到底层sql逻辑的翻译？
我把parse vaildate 等都实现了，但是卡在了FilterableTable 和TranslatableTable这两个接口上。sql的翻译没看懂。

parser-4-calcite-custom-tutorial模块编译过不了

1. 执行mvn clean install
2. [INFO] apache-calcite-tutorial ............................ SUCCESS [ 0.310 s]
   [INFO] calcite-tutorial-0-translation ..................... SUCCESS [ 0.387 s]
   [INFO] calcite-tutorial-1-basic ........................... SUCCESS [ 0.014 s]
   [INFO] calcite-tutorial-2-parser .......................... SUCCESS [ 0.002 s]
   [INFO] parser-1-fmpp-tutorial ............................. SUCCESS [ 0.407 s]
   [INFO] parser-2-javacc-tutorial ........................... SUCCESS [ 0.043 s]
   [INFO] parser-3-calcite-tutorial .......................... SUCCESS [ 0.443 s]
   [INFO] parser-4-calcite-custom-tutorial ................... FAILURE [ 2.458 s]
   [INFO] calcite-tutorial-3-schema .......................... SKIPPED
   [INFO] calcite-tutorial-4-validator ....................... SKIPPED
   [INFO] validator-1-calcite-validator ...................... SKIPPED
   [INFO] calcite-tutorial-common ............................ SKIPPED
   [INFO] calcite-tutorial-9-rule ............................ SKIPPED
   [INFO] ------------------------------------------------------------------------
   [INFO] BUILD FAILURE
   [INFO] ------------------------------------------------------------------------
   [INFO] Total time: 4.168 s
   [INFO] Finished at: 2022-08-11T20:09:33+08:00
   [INFO] ------------------------------------------------------------------------
   [ERROR] Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.0:compile (default-compile) on project parser-4-calcite-custom-tutorial: Compilation failure: Compilation failure:
   [ERROR] /D:/work/calcite/apache-calcite-tutorial/calcite-tutorial-2-parser/parser-4-calcite-custom-tutorial/target/generated-sources/com/github/quxiucheng/calcite/parser/tutorial/CustomSqlParserImpl.java:[107,8] com.github.quxiucheng.calcite.parser.tutorial.CustomSqlParserImpl不是抽象的, 并且未覆盖org.apache.calcite.sql.parser.SqlAbstractParserImpl中的抽象方法switchTo(org.apache.calcite.sql.parser.SqlAbstractParserImpl.LexicalState)