7x31
/
databasir
mirror of https://github.com/vran-dev/databasir.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: cursor over limit when sync

This commit is contained in:
vran 2022-04-21 11:02:24 +08:00
parent 137923c740
commit 770b22ca16
2 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
plugin/src/main/java/com/databasir/core/meta/repository/impl/jdbc/JdbcColumnMetaRepository.java
View File

@ -94,11 +94,15 @@ public class JdbcColumnMetaRepository implements ColumnMetaRepository {
TableCondition tableCondition) throws SQLException { TableCondition tableCondition) throws SQLException {
ResultSet result = meta.getPrimaryKeys(tableCondition.getDatabaseName(), ResultSet result = meta.getPrimaryKeys(tableCondition.getDatabaseName(),
tableCondition.getSchemaName(), tableCondition.getTableName()); tableCondition.getSchemaName(), tableCondition.getTableName());
List<String> columns = new ArrayList<>(); try {
while (result.next()) { List<String> columns = new ArrayList<>();
String columnName = result.getString("COLUMN_NAME"); while (result.next()) {
columns.add(columnName); String columnName = result.getString("COLUMN_NAME");
columns.add(columnName);
}
return columns;
} finally {
result.close();
} }
return columns;
} }
} }

4
plugin/src/main/java/com/databasir/core/meta/repository/impl/jdbc/JdbcForeignKeyMetaRepository.java
View File

@ -52,7 +52,9 @@ public class JdbcForeignKeyMetaRepository implements ForeignKeyMetaRepository {
log.warn("warn: ignore foreign keys in " + databaseName + "." + tableName + ", " + e.getMessage()); log.warn("warn: ignore foreign keys in " + databaseName + "." + tableName + ", " + e.getMessage());
} finally { } finally {
try { try {
keyResult.close(); if (keyResult != null) {
keyResult.close();
}
} catch (SQLException e) { } catch (SQLException e) {
log.warn("warn: close key result error " + databaseName + "." + tableName + ", " + e.getMessage()); log.warn("warn: close key result error " + databaseName + "." + tableName + ", " + e.getMessage());
} }