[fix](catalog) fix the include_database_list not in effect (#19589)
This commit is contained in:
@ -234,7 +234,7 @@ public abstract class ExternalCatalog
|
||||
if (!excludeDatabaseMap.isEmpty() && excludeDatabaseMap.containsKey(dbName)) {
|
||||
continue;
|
||||
}
|
||||
if (!includeDatabaseMap.isEmpty() && includeDatabaseMap.containsKey(dbName)) {
|
||||
if (!includeDatabaseMap.isEmpty() && !includeDatabaseMap.containsKey(dbName)) {
|
||||
continue;
|
||||
}
|
||||
long dbId;
|
||||
|
||||
@ -229,7 +229,7 @@ public class JdbcClient {
|
||||
if (!excludeDatabaseMap.isEmpty() && excludeDatabaseMap.containsKey(db)) {
|
||||
continue;
|
||||
}
|
||||
if (!includeDatabaseMap.isEmpty() && includeDatabaseMap.containsKey(db)) {
|
||||
if (!includeDatabaseMap.isEmpty() && !includeDatabaseMap.containsKey(db)) {
|
||||
continue;
|
||||
}
|
||||
databaseNames.add(db);
|
||||
@ -250,10 +250,10 @@ public class JdbcClient {
|
||||
try {
|
||||
switch (dbType) {
|
||||
case JdbcResource.MYSQL:
|
||||
case JdbcResource.CLICKHOUSE:
|
||||
case JdbcResource.OCEANBASE:
|
||||
databaseNames.add(conn.getCatalog());
|
||||
break;
|
||||
case JdbcResource.CLICKHOUSE:
|
||||
case JdbcResource.POSTGRESQL:
|
||||
case JdbcResource.ORACLE:
|
||||
case JdbcResource.SQLSERVER:
|
||||
|
||||
Reference in New Issue
Block a user