QRunIO/qqq
2
0
Fork 0
mirror of https://github.com/Kingsrook/qqq.git synced 2025-07-18 13:10:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixed to insert & update correct lists

Browse Source
This commit is contained in:
darin.kelkhoff
2022-11-16 14:42:19 -06:00
parent d2d32e5ab1
commit 3305fb76d5
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/etl/streamedwithfrontend/LoadViaInsertOrUpdateStep.java
View File

@ -80,7 +80,7 @@ public class LoadViaInsertOrUpdateStep extends AbstractLoadStep
InsertInput insertInput = new InsertInput(runBackendStepInput.getInstance()); InsertInput insertInput = new InsertInput(runBackendStepInput.getInstance());
insertInput.setSession(runBackendStepInput.getSession()); insertInput.setSession(runBackendStepInput.getSession());
insertInput.setTableName(tableMetaData.getName()); insertInput.setTableName(tableMetaData.getName());
insertInput.setRecords(runBackendStepInput.getRecords()); insertInput.setRecords(recordsToInsert);
getTransaction().ifPresent(insertInput::setTransaction); getTransaction().ifPresent(insertInput::setTransaction);
insertInput.setAsyncJobCallback(runBackendStepInput.getAsyncJobCallback()); insertInput.setAsyncJobCallback(runBackendStepInput.getAsyncJobCallback());
InsertOutput insertOutput = new InsertAction().execute(insertInput); InsertOutput insertOutput = new InsertAction().execute(insertInput);
@ -92,7 +92,7 @@ public class LoadViaInsertOrUpdateStep extends AbstractLoadStep
UpdateInput updateInput = new UpdateInput(runBackendStepInput.getInstance()); UpdateInput updateInput = new UpdateInput(runBackendStepInput.getInstance());
updateInput.setSession(runBackendStepInput.getSession()); updateInput.setSession(runBackendStepInput.getSession());
updateInput.setTableName(tableMetaData.getName()); updateInput.setTableName(tableMetaData.getName());
updateInput.setRecords(runBackendStepInput.getRecords()); updateInput.setRecords(recordsToUpdate);
getTransaction().ifPresent(updateInput::setTransaction); getTransaction().ifPresent(updateInput::setTransaction);
updateInput.setAsyncJobCallback(runBackendStepInput.getAsyncJobCallback()); updateInput.setAsyncJobCallback(runBackendStepInput.getAsyncJobCallback());
UpdateOutput updateOutput = new UpdateAction().execute(updateInput); UpdateOutput updateOutput = new UpdateAction().execute(updateInput);