diff --git a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/AbstractTableSyncTransformStep.java b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/AbstractTableSyncTransformStep.java index 73a81b00..5b1bc1b7 100644 --- a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/AbstractTableSyncTransformStep.java +++ b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/AbstractTableSyncTransformStep.java @@ -164,12 +164,8 @@ public abstract class AbstractTableSyncTransformStep extends AbstractTransformSt /******************************************************************************* ** Record to store the config for this process - e.g., what fields & tables are used. *******************************************************************************/ - public record SyncProcessConfig(String sourceTable, String sourceTableKeyField, String destinationTable, String destinationTableForeignKey) + public record SyncProcessConfig(String sourceTable, String sourceTableKeyField, String destinationTable, String destinationTableForeignKey, boolean performInserts, boolean performUpdates) { - public static boolean performUpdates = true; - public static boolean performInserts = true; - - /******************************************************************************* ** artificial method, here to make jacoco see that this class is indeed @@ -180,74 +176,6 @@ public abstract class AbstractTableSyncTransformStep extends AbstractTransformSt System.out.println("noop"); } - - - /******************************************************************************* - ** Getter for performUpdates - ** - *******************************************************************************/ - public boolean getPerformUpdates() - { - return performUpdates; - } - - - - /******************************************************************************* - ** Setter for performUpdates - ** - *******************************************************************************/ - public void setPerformUpdates(boolean performUpdates) - { - SyncProcessConfig.performUpdates = performUpdates; - } - - - - /******************************************************************************* - ** Fluent setter for performUpdates - ** - *******************************************************************************/ - public SyncProcessConfig withPerformUpdates(boolean performUpdates) - { - SyncProcessConfig.performUpdates = performUpdates; - return (this); - } - - - - /******************************************************************************* - ** Getter for performInserts - ** - *******************************************************************************/ - public boolean getPerformInserts() - { - return performInserts; - } - - - - /******************************************************************************* - ** Setter for performInserts - ** - *******************************************************************************/ - public void setPerformInserts(boolean performInserts) - { - SyncProcessConfig.performInserts = performInserts; - } - - - - /******************************************************************************* - ** Fluent setter for performInserts - ** - *******************************************************************************/ - public SyncProcessConfig withPerformInserts(boolean performInserts) - { - SyncProcessConfig.performInserts = performInserts; - return (this); - } - } @@ -366,12 +294,12 @@ public abstract class AbstractTableSyncTransformStep extends AbstractTransformSt QRecord existingRecord = existingRecordsByForeignKey.get(sourceKeyValueInTargetFieldType); QRecord recordToStore; - if(existingRecord != null && config.getPerformUpdates()) + if(existingRecord != null && config.performUpdates) { recordToStore = existingRecord; okToUpdate.incrementCount(); } - else if(existingRecord == null && config.getPerformInserts()) + else if(existingRecord == null && config.performInserts) { recordToStore = new QRecord(); okToInsert.incrementCount(); diff --git a/qqq-backend-core/src/test/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/TableSyncProcessTest.java b/qqq-backend-core/src/test/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/TableSyncProcessTest.java index dbfba6d1..30fe95a9 100644 --- a/qqq-backend-core/src/test/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/TableSyncProcessTest.java +++ b/qqq-backend-core/src/test/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/TableSyncProcessTest.java @@ -204,7 +204,7 @@ class TableSyncProcessTest extends BaseTest @Override protected SyncProcessConfig getSyncProcessConfig() { - SyncProcessConfig syncProcessConfig = new SyncProcessConfig(TestUtils.TABLE_NAME_PERSON_MEMORY, "id", "peopleSync", "sourcePersonId"); + SyncProcessConfig syncProcessConfig = new SyncProcessConfig(TestUtils.TABLE_NAME_PERSON_MEMORY, "id", "peopleSync", "sourcePersonId", true, true); syncProcessConfig.noop(); return (syncProcessConfig); } @@ -231,4 +231,4 @@ class TableSyncProcessTest extends BaseTest getRecordPipe().addRecord(qRecords.get(4)); } } -} \ No newline at end of file +}