You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by yi...@apache.org on 2022/10/26 01:30:37 UTC
[doris] branch master updated: [fix](postgresql) fix postgresql cann't find table (#13550)
This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new a02a56eb38 [fix](postgresql) fix postgresql cann't find table (#13550)
a02a56eb38 is described below
commit a02a56eb38ae404b1370c23eeb4cc95d99690ca8
Author: zhangstar333 <87...@users.noreply.github.com>
AuthorDate: Wed Oct 26 09:30:28 2022 +0800
[fix](postgresql) fix postgresql cann't find table (#13550)
---
fe/fe-core/src/main/java/org/apache/doris/catalog/OdbcTable.java | 4 +++-
fe/fe-core/src/main/java/org/apache/doris/planner/JdbcScanNode.java | 2 +-
2 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/OdbcTable.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/OdbcTable.java
index 427a8c2e44..35e55bb9e4 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/OdbcTable.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/OdbcTable.java
@@ -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) {
diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/JdbcScanNode.java b/fe/fe-core/src/main/java/org/apache/doris/planner/JdbcScanNode.java
index 2651182ec1..edbe898758 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/JdbcScanNode.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/planner/JdbcScanNode.java
@@ -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("*");
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org