diff --git a/build.gradle b/build.gradle index 371706c..e01c70d 100644 --- a/build.gradle +++ b/build.gradle @@ -6,7 +6,7 @@ plugins { } group = 'com.nucleodb' -version = '1.14.0' +version = '1.14.1' repositories { mavenCentral() diff --git a/src/main/java/com/nucleodb/library/database/tables/table/DataTable.java b/src/main/java/com/nucleodb/library/database/tables/table/DataTable.java index b4fdb4e..9558627 100644 --- a/src/main/java/com/nucleodb/library/database/tables/table/DataTable.java +++ b/src/main/java/com/nucleodb/library/database/tables/table/DataTable.java @@ -439,10 +439,9 @@ private boolean deleteInternalConsumer(DataEntry entry, Consumer cons if (consumer != null) consumer.accept(null); return false; } - DataEntry entryDelete = createNewObject(entry); String changeUUID = UUID.randomUUID().toString(); - entryDelete.versionIncrease(); - Delete delete = new Delete(changeUUID, entryDelete); + entry.versionIncrease(); + Delete delete = new Delete(changeUUID, entry); if (consumer != null) { consumers.put(changeUUID, consumer); } @@ -723,7 +722,7 @@ public void modify(Modification mod, Object modification) { try { itemProcessed(); if (this.config.getReadToTime() != null && u.getTime().isAfter(this.config.getReadToTime())) { - //System.out.println("Update after target db date"); + logger.info("Update after target db date"); consumerResponse(null, u.getChangeUUID()); fireListeners(Modification.UPDATE, null); return; @@ -731,11 +730,11 @@ public void modify(Modification mod, Object modification) { DataEntry de = keyToEntry.get(u.getKey()); if (de != null) { if (de.getVersion() >= u.getVersion()) { - //logger.info("Ignore already saved change. " + de.getKey()+" table: "+ getConfig().table); + logger.info("Ignore already saved change. " + de.getKey()+" table: "+ getConfig().table); return; // ignore change } if (de.getVersion() + 1 != u.getVersion()) { - //logger.info("Version not ready!" + de.getKey()+" table: "+ getConfig().table); + logger.info("Version not ready!" + de.getKey()+" table: "+ getConfig().table); itemRequeue(); modqueue.add(new ModificationQueueItem(mod, modification)); leftInModQueue.incrementAndGet();