feat: 增加对原生sql查询支持

This commit is contained in:
zhouhao
2023-04-28 11:06:17 +08:00
parent a670b7563c
commit 0939f8d5db

View File

@@ -33,7 +33,7 @@ class QueryAnalyzerImpl implements FromItemVisitor, SelectItemVisitor, SelectVis
private String sql;
private SelectBody parsed;
private final SelectBody parsed;
private QueryAnalyzer.Select select;
@@ -115,9 +115,7 @@ class QueryAnalyzerImpl implements FromItemVisitor, SelectItemVisitor, SelectVis
parsePlainName(alias),
schemaMetadata
.getTableOrView(parsePlainName(tableName.getName()), false)
.orElseThrow(() -> {
throw new IllegalStateException("table or view " + tableName.getName() + " not found in " + schemaMetadata.getName());
})
.orElseThrow(() -> new IllegalStateException("table or view " + tableName.getName() + " not found in " + schemaMetadata.getName()))
);
select = new QueryAnalyzer.Select(new LinkedHashMap<>(), table);