Skip to content

Commit 760d710

Browse files
authored
fix(data-masking): unavailable when existing invalid database with duplicated name (#2385)
* fix(data-masking): unavailable when existing invalid database with duplicated name (#2355) * cherry bugfix
1 parent 4a193ab commit 760d710

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

server/odc-service/src/main/java/com/oceanbase/odc/service/datasecurity/SensitiveColumnService.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -431,9 +431,9 @@ public List<Set<SensitiveColumn>> filterSensitiveColumns(@NotNull Long datasourc
431431
tableColumns.forEach(t -> tableSensitiveColumns.add(new HashSet<>()));
432432
return tableSensitiveColumns;
433433
}
434-
Map<String, Long> databaseName2Id =
435-
databaseService.listDatabasesByConnectionIds(Collections.singleton(datasourceId)).stream()
436-
.collect(Collectors.toMap(Database::getName, Database::getId, (d1, d2) -> d1));
434+
Map<String, Long> databaseName2Id = databaseService
435+
.listDatabasesByConnectionIds(Collections.singleton(datasourceId)).stream().filter(Database::getExisted)
436+
.collect(Collectors.toMap(Database::getName, Database::getId, (d1, d2) -> d1));
437437
Map<Long, String> databaseId2Name = new HashMap<>();
438438
for (String databaseName : databaseNames) {
439439
databaseId2Name.put(databaseName2Id.get(databaseName), databaseName);

0 commit comments

Comments
 (0)