database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](postgresql) fix postgresql cann't find table (#13550)

Browse Source
This commit is contained in:
zhangstar333
2022-10-26 09:30:28 +08:00
committed by GitHub
parent bd2b803019
commit a02a56eb38
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/fe-core/src/main/java/org/apache/doris/catalog/OdbcTable.java
View File

@ -37,6 +37,7 @@ import org.apache.logging.log4j.Logger;
import java.io.DataInput;
import java.io.DataOutput;
import java.io.IOException;
import java.util.Arrays;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
@ -81,7 +82,8 @@ public class OdbcTable extends Table {
}
private static String psqlProperName(String name) {
return "\"" + name + "\"";
List<String> list = Arrays.asList(name.split("\\."));
return list.stream().map(s -> "\"" + s + "\"").collect(Collectors.joining("."));
}
public static String databaseProperName(TOdbcTableType tableType, String name) {

2
fe/fe-core/src/main/java/org/apache/doris/planner/JdbcScanNode.java
View File

@ -101,7 +101,7 @@ public class JdbcScanNode extends ScanNode {
continue;
}
Column col = slot.getColumn();
columns.add(col.getName());
columns.add(OdbcTable.databaseProperName(jdbcType, col.getName()));
}
if (0 == columns.size()) {
columns.add("*");