Skip to content

Commit 32cb5f7

Browse files
committed
alter the loops
1 parent 2cf29d5 commit 32cb5f7

1 file changed

Lines changed: 6 additions & 5 deletions

File tree

  • Database/src/main/java/org/broken/arrow/library/database/core

Database/src/main/java/org/broken/arrow/library/database/core/Database.java

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -793,10 +793,10 @@ private boolean setValuesToDatabase(final SqlQueryTable queryTable, final Primar
793793
});
794794
if (update.getWhereBuilder() == null) {
795795
log.log(Level.WARNING, () -> "Update skipped, no WHERE clause was provided. For this table '" + queryTable.getTableName() + "'" + ". Updates without a WHERE clause are not allowed for safety reasons.");
796-
continue;
796+
} else {
797+
String sql = saveBuilder.build();
798+
batchGroups.computeIfAbsent(sql, k -> new ArrayList<>()).add(saveBuilder.getValues());
797799
}
798-
String sql = saveBuilder.build();
799-
batchGroups.computeIfAbsent(sql, k -> new ArrayList<>()).add(saveBuilder.getValues());
800800
}
801801
return primaryMapValuesSet;
802802
}
@@ -807,11 +807,12 @@ private void setConstraints(final Connection connection, final SqlQueryTable que
807807
final List<Column> primaryColumns = queryTable.getPrimaryColumns();
808808

809809
for (final Column column : primaryColumns) {
810+
boolean addingPrimary = false;
810811
if (primaryValuesComplete) {
811812
columnsToBeModified.add(column);
812-
continue;
813+
addingPrimary = true;
813814
}
814-
if (!newPrimaryKeys.contains(column.getColumnName())) {
815+
if (addingPrimary || !newPrimaryKeys.contains(column.getColumnName())) {
815816
continue;
816817
}
817818
columnsToBeModified.add(column);

0 commit comments

Comments
 (0)