From 387e883e4b79a63fea223ffcb064f18fcb91696c Mon Sep 17 00:00:00 2001
From: Victor Camargo <victor.camargo@feedzai.com>
Date: Fri, 26 May 2023 12:06:36 +0100
Subject: [PATCH] Add Support to Upsert/Insert Ignore on PDB

- Fix method name.
---
 .../feedzai/commons/sql/abstraction/batch/AbstractBatch.java  | 4 ++--
 .../commons/sql/abstraction/batch/AbstractPdbBatch.java       | 2 +-
 2 files changed, 3 insertions(+), 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
index 26c2e4da..f092e42e 100644
--- 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
index a7f2095e..faca27fc 100644
--- 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.