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

[fix](jdbc catalog) Fix the wrong method used in loadColumnNames of JdbcIdentifierMapping (#32168)

Browse Source
This commit is contained in:
zy-kkk
2024-03-13 21:25:31 +08:00
committed by yiguolei
parent d02f7606de
commit 141189de15
2 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/JdbcIdentifierMapping.java
View File

@ -40,6 +40,6 @@ public class JdbcIdentifierMapping extends IdentifierMapping {
@Override
protected void loadColumnNames(String localDbName, String localTableName) {
jdbcClient.getJdbcColumnsInfo(localDbName, localTableName);
jdbcClient.getColumnsFromJdbc(localDbName, localTableName);
}
}

3
fe/fe-core/src/main/java/org/apache/doris/datasource/mapping/IdentifierMapping.java
View File

@ -208,8 +208,7 @@ public abstract class IdentifierMapping {
|| localColumnToRemoteColumn.get(remoteDbName).isEmpty()
|| !localColumnToRemoteColumn.get(remoteDbName).containsKey(remoteTableName)
|| localColumnToRemoteColumn.get(remoteDbName).get(remoteTableName) == null
|| localColumnToRemoteColumn.get(
remoteDbName).get(remoteTableName).isEmpty()) {
|| localColumnToRemoteColumn.get(remoteDbName).get(remoteTableName).isEmpty()) {
loadColumnNamesIfNeeded(localDbName, localTableName);
}
return localColumnToRemoteColumn.get(remoteDbName).get(remoteTableName);