From 251bcf52d03647490e771956f660b41b538791e8 Mon Sep 17 00:00:00 2001 From: Eric Long Date: Mon, 7 Nov 2022 08:42:28 -0500 Subject: [PATCH] 0005573: Unique index on function causes error when resolving a conflict --- .../io/data/writer/DefaultDatabaseWriterConflictResolver.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/DefaultDatabaseWriterConflictResolver.java b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/DefaultDatabaseWriterConflictResolver.java index 4c5a7335b9..d975e528e6 100644 --- a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/DefaultDatabaseWriterConflictResolver.java +++ b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/DefaultDatabaseWriterConflictResolver.java @@ -268,6 +268,9 @@ protected boolean isCaptureTimeNewerForUk(AbstractDatabaseWriter writer, CsvData int count = 0; Object[] values = databaseWriter.getPlatform().getObjectValues(writer.getBatch().getBinaryEncoding(), ukData, uniqueKeyColumns); + if (values == null || values.length == 0) { + break; + } if (!databaseWriter.getPlatform(targetTable.getName()).supportsMultiThreadedTransactions() || (databaseWriter.getPlatform().getDatabaseInfo().isRequiresSavePointsInTransaction() && Boolean.TRUE.equals(databaseWriter.getContext().get(AbstractDatabaseWriter.TRANSACTION_ABORTED)))) {