fix: [Bug] 使用mongobi 连接,发现表名或是字段带中文查询不了 #12659

This commit is contained in:
taojinlong 2024-10-30 17:39:20 +08:00
parent 367550df23
commit 4034d1217e

View File

@ -269,7 +269,7 @@ public class CalciteProvider extends Provider {
try (Connection con = getConnectionFromPool(datasourceRequest.getDatasource().getId()); Statement statement = getStatement(con, 30)) { try (Connection con = getConnectionFromPool(datasourceRequest.getDatasource().getId()); Statement statement = getStatement(con, 30)) {
datasourceRequest.setDsVersion(con.getMetaData().getDatabaseMajorVersion()); datasourceRequest.setDsVersion(con.getMetaData().getDatabaseMajorVersion());
if (datasourceRequest.getDatasource().getType().equalsIgnoreCase("mongo") || isDorisCatalog(datasourceRequest)) { if (datasourceRequest.getDatasource().getType().equalsIgnoreCase("mongo") || isDorisCatalog(datasourceRequest)) {
resultSet = statement.executeQuery("select * from " + table + " limit 0 offset 0 "); resultSet = statement.executeQuery("select * from " + String.format(" `%s`", table) + " limit 0 offset 0 ");
return fetchResultField(resultSet); return fetchResultField(resultSet);
} }
resultSet = statement.executeQuery(getTableFiledSql(datasourceRequest)); resultSet = statement.executeQuery(getTableFiledSql(datasourceRequest));