我使用Apache Calcite解析一个简单的SQL语句并返回它的关系树。我使用到一个简单的SQLite数据库的JDBC连接获得了一个数据库模式。然后使用FrameworkConfig添加该模式。然后修改解析器配置以处理标识符引用和大小写(不敏感)。但是,SQL验证器无法在SQL语句中找到带引号的表标识符。不知何故,解析器忽略了配置设置,并将表转换为大写。将引发SqlValidatorException,声明找不到表名。我怀疑,配置没有正确更新?我已经验证了表名是否正确地包含在模式的元数据中。
公共类ParseSQL {
public static void main(String[] args) {
try {
// register the JDBC driver
String sDriverName = "org.sqlite.JDBC";
Class.forName(sDriverName);
JsonObjectBuilder builder = Json.createObjectBuilder();
builder.add("jdbcDriver", "org.sqlite.JDBC")
.add("jdbcUrl",
"jdbc:sqlite://calcite/students.db")
.add("jdbcUser", "root")
.add("jdbcPassword", "root");
Map<String, JsonValue> JsonObject = builder.build();
//argument for JdbcSchema.Factory().create(....)
Map<String, Object> operand = new HashMap<String, Object>();
//explicitly extract JsonString(s) and load into operand map
for(String key : JsonObject.keySet()) {
JsonString value = (JsonString) JsonObject.get(key);
operand.put(key, value.getString());
}
final SchemaPlus rootSchema = Frameworks.createRootSchema(true);
Schema schema = new JdbcSchema.Factory().create(rootSchema, "students", operand);
rootSchema.add("students", schema);
//build a FrameworkConfig using defaults where values aren't required
Frameworks.ConfigBuilder configBuilder = Frameworks.newConfigBuilder();
//set defaultSchema
configBuilder.defaultSchema(rootSchema);
//build configuration
FrameworkConfig frameworkdConfig = configBuilder.build();
//use SQL parser config builder to ignore case of quoted identifier
SqlParser.configBuilder(frameworkdConfig.getParserConfig()).setQuotedCasing(Casing.UNCHANGED).build();
//use SQL parser config builder to set SQL case sensitive = false
SqlParser.configBuilder(frameworkdConfig.getParserConfig()).setCaseSensitive(false).build();
//get planner
Planner planner = Frameworks.getPlanner(frameworkdConfig);
//parse SQL statement
SqlNode sql_node = planner.parse("SELECT * FROM \"Students\" WHERE age > 15.0");
System.out.println("\n" + sql_node.toString());
//validate SQL
SqlNode sql_validated = planner.validate(sql_node);
//get associated relational expression
RelRoot relationalExpression = planner.rel(sql_validated);
relationalExpression.toString();
} catch (SqlParseException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (RelConversionException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (ValidationException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} // end main} //结束类
*错误消息* Jan 20,2016 8:54:51 PM org.apache.calcite.sql.validate.SqlValidatorException SEVERE:找不到org.apache.calcite.sql.validate.SqlValidatorException:表'Students‘
发布于 2016-02-10 11:04:14
这是一个区分大小写的问题,类似于table not found with apache calcite。因为您在SQL语句中用引号将表名括起来,所以验证器将查找名为"Students“的表,错误消息证明了这一点。如果你的桌子被称为“学生”,我很惊讶方解石找不到它。
您使用SqlParser.ConfigBuilder的方式有问题。当您调用build()时,您没有使用它创建的SqlParser.Config对象。如果你把这个对象传递给Frameworks.ConfigBuilder.parserConfig,我想你会得到你想要的行为。
https://stackoverflow.com/questions/34929614
复制相似问题