Add Support to Upsert/Insert Ignore on PDB

- Fix method name.
feedzai · May 26, 2023 · 387e883 · 387e883
1 parent 67c8a01
commit 387e883
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/main/java/com/feedzai/commons/sql/abstraction/batch/AbstractBatch.java b/src/main/java/com/feedzai/commons/sql/abstraction/batch/AbstractBatch.java
@@ -471,8 +471,8 @@ public void flush() {
      * Flushes the pending batches ignoring duplicate entries.
      */
     public void flushUpsert() {
-        logger.trace("Start batch flushing ignoring duplicated entries.");
-        flush((this::processBatchIgnoring));
+        logger.trace("Start batch flushing upserting duplicated entries.");
+        flush((this::processBatchUpsert));
     }
 
     /**

diff --git a/src/main/java/com/feedzai/commons/sql/abstraction/batch/AbstractPdbBatch.java b/src/main/java/com/feedzai/commons/sql/abstraction/batch/AbstractPdbBatch.java
@@ -82,7 +82,7 @@ protected void processBatch(final DatabaseEngine de, final List<BatchEntry> batc
      * @param batchEntries              The list of batch entries to be flushed.
      * @throws DatabaseEngineException  If the operation failed.
      */
-    protected void processBatchIgnoring(final DatabaseEngine de, final List<BatchEntry> batchEntries) throws DatabaseEngineException {
+    protected void processBatchUpsert(final DatabaseEngine de, final List<BatchEntry> batchEntries) throws DatabaseEngineException {
         /*
          Begin transaction before the addBatch calls, in order to force the retry of the connection if it was lost during
          or since the last batch. Otherwise, the addBatch call that uses a prepared statement will fail.