fix: trigger diff failed

This commit is contained in:
vran
2022-05-17 16:47:45 +08:00
parent ae8dc7ebcc
commit 2a7de68680
2 changed files with 12 additions and 9 deletions

View File

@@ -35,14 +35,17 @@ public class JdbcIndexMetaProvider implements IndexMetaProvider {
return indexMetas;
}
Map<String, IndexMeta> pojoGroupByName = new HashMap<>();
Map<String, IndexMeta> metaGroupByName = new HashMap<>();
try {
while (indexResults.next()) {
Boolean nonUnique = indexResults.getBoolean("NON_UNIQUE");
String indexName = indexResults.getString("INDEX_NAME");
String columnName = indexResults.getString("COLUMN_NAME");
if (pojoGroupByName.containsKey(indexName)) {
pojoGroupByName.get(indexName).getColumnNames().add(columnName);
if (indexName == null) {
continue;
}
if (metaGroupByName.containsKey(indexName)) {
metaGroupByName.get(indexName).getColumnNames().add(columnName);
} else {
List<String> columns = new ArrayList<>();
columns.add(columnName);
@@ -51,13 +54,13 @@ public class JdbcIndexMetaProvider implements IndexMetaProvider {
.columnNames(columns)
.isUniqueKey(Objects.equals(nonUnique, false))
.build();
pojoGroupByName.put(indexName, indexMeta);
metaGroupByName.put(indexName, indexMeta);
}
}
} finally {
indexResults.close();
}
return new ArrayList<>(pojoGroupByName.values());
return new ArrayList<>(metaGroupByName.values());
}
}