Flink Table SQL 中的引用标识符可以使用什么语法？答案

【问题标题】：What syntax can I use for quoted identifiers in Flink Table SQL?Flink Table SQL 中的引用标识符可以使用什么语法？
【发布时间】：2021-02-11 18:22:37
【问题描述】：

我正在尝试在 Flink 中使用带引号的标识符（主要是因为我有一些列名与 year 等关键字冲突）。但我无法让它解析。

我归结为一个最小的失败示例：

EnvironmentSettings settings = 
EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build();
TableEnvironment tEnv = TableEnvironment.create(settings);
 String sql = "CREATE TABLE table1(\"ts\" TIMESTAMP) WITH ('connector' = 'filesystem', 'path' = 'file:///Users/ecerulm/tmp/csv/', 'format' = 'csv');";
System.out.println(sql);
tEnv.executeSql(sql);

抱怨"ts" 部分失败：

org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "\"" at line 1, column 21.
Was expecting one of:
    "CONSTRAINT" ...
    "PRIMARY" ...
    "UNIQUE" ...
    "WATERMARK" ...
    <BRACKET_QUOTED_IDENTIFIER> ...
    <QUOTED_IDENTIFIER> ...
    <BACK_QUOTED_IDENTIFIER> ...
    <HYPHENATED_IDENTIFIER> ...
    <IDENTIFIER> ...
    <UNICODE_QUOTED_IDENTIFIER> ...
    

    at org.apache.flink.table.planner.calcite.CalciteParser.parse(CalciteParser.java:56)
    at org.apache.flink.table.planner.delegation.ParserImpl.parse(ParserImpl.java:76)
    at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:658)
    at com.rubenlaguna.BatchJobTest.testBatchJob(BatchJobTest.java:22)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
    at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
    at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:69)
    at com.intellij.rt.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:33)
    at com.intellij.rt.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:220)
    at com.intellij.rt.junit.JUnitStarter.main(JUnitStarter.java:53)

据我所知，它不期望 " 字符，因为它不匹配任何解析替代方案，如 <QUOTED_IDENTIFIER>，但据我了解，Calcite documentation 引用标识符的语法只是 "myidentifier"。

【问题讨论】：

标签： apache-flink apache-calcite

【解决方案1】：

Flink documentation for Expanding Table Identifiers 说：

标识符遵循 SQL 要求，这意味着它们可以使用反引号字符 (`) 进行转义。

它确实没有提到双引号标识符。

因此，尽管Flink SQL 基于 Calcite SQL，尽管Calcite has double quoted identifiers 似乎Flink SQL 仅支持常规 sql 标识符 + 反引号标识符。所以你需要像这样编写查询：

String sql = "CREATE TABLE table1(`ts` TIMESTAMP) WITH ('connector' = 'filesystem', 'path' = 'file:///Users/ecerulm/tmp/csv/', 'format' = 'csv')";
tEnv.executeSql(sql);

所以不要使用"ts"（带双引号）使用`ts`（带反引号）。

【讨论】：