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

CE-1068 - Pass transaction throughout

Browse Source
This commit is contained in:
darin.kelkhoff
2024-04-29 12:13:58 -05:00
parent 29b8025c41
commit 3f16f4c0c3
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/model/scheduledjobs/customizers/ScheduledJobTableCustomizer.java
View File

@ -32,6 +32,7 @@ import java.util.Optional;
import java.util.Set; import java.util.Set;
import java.util.function.Predicate; import java.util.function.Predicate;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import com.kingsrook.qqq.backend.core.actions.QBackendTransaction;
import com.kingsrook.qqq.backend.core.actions.customizers.TableCustomizerInterface; import com.kingsrook.qqq.backend.core.actions.customizers.TableCustomizerInterface;
import com.kingsrook.qqq.backend.core.actions.tables.QueryAction; import com.kingsrook.qqq.backend.core.actions.tables.QueryAction;
import com.kingsrook.qqq.backend.core.exceptions.QException; import com.kingsrook.qqq.backend.core.exceptions.QException;
@ -58,6 +59,7 @@ import static com.kingsrook.qqq.backend.core.logging.LogUtils.logPair;
*******************************************************************************/ *******************************************************************************/
public class ScheduledJobTableCustomizer implements TableCustomizerInterface public class ScheduledJobTableCustomizer implements TableCustomizerInterface
{ {
private QBackendTransaction transaction = null;
/******************************************************************************* /*******************************************************************************
** **
@ -65,6 +67,7 @@ public class ScheduledJobTableCustomizer implements TableCustomizerInterface
@Override @Override
public List<QRecord> preInsert(InsertInput insertInput, List<QRecord> records, boolean isPreview) throws QException public List<QRecord> preInsert(InsertInput insertInput, List<QRecord> records, boolean isPreview) throws QException
{ {
transaction = insertInput.getTransaction();
validateConditionalFields(records, Collections.emptyMap()); validateConditionalFields(records, Collections.emptyMap());
return (records); return (records);
} }
@ -77,6 +80,7 @@ public class ScheduledJobTableCustomizer implements TableCustomizerInterface
@Override @Override
public List<QRecord> postInsert(InsertInput insertInput, List<QRecord> records) throws QException public List<QRecord> postInsert(InsertInput insertInput, List<QRecord> records) throws QException
{ {
transaction = insertInput.getTransaction();
scheduleJobsForRecordList(records); scheduleJobsForRecordList(records);
return (records); return (records);
} }
@ -89,6 +93,7 @@ public class ScheduledJobTableCustomizer implements TableCustomizerInterface
@Override @Override
public List<QRecord> preUpdate(UpdateInput updateInput, List<QRecord> records, boolean isPreview, Optional<List<QRecord>> oldRecordList) throws QException public List<QRecord> preUpdate(UpdateInput updateInput, List<QRecord> records, boolean isPreview, Optional<List<QRecord>> oldRecordList) throws QException
{ {
transaction = updateInput.getTransaction();
Map<Integer, QRecord> freshOldRecordsWithAssociationsMap = CollectionUtils.recordsToMap(freshlyQueryForRecordsWithAssociations(oldRecordList.get()), "id", Integer.class); Map<Integer, QRecord> freshOldRecordsWithAssociationsMap = CollectionUtils.recordsToMap(freshlyQueryForRecordsWithAssociations(oldRecordList.get()), "id", Integer.class);
validateConditionalFields(records, freshOldRecordsWithAssociationsMap); validateConditionalFields(records, freshOldRecordsWithAssociationsMap);
@ -169,6 +174,7 @@ public class ScheduledJobTableCustomizer implements TableCustomizerInterface
@Override @Override
public List<QRecord> postUpdate(UpdateInput updateInput, List<QRecord> records, Optional<List<QRecord>> oldRecordList) throws QException public List<QRecord> postUpdate(UpdateInput updateInput, List<QRecord> records, Optional<List<QRecord>> oldRecordList) throws QException
{ {
transaction = updateInput.getTransaction();
if(oldRecordList.isPresent()) if(oldRecordList.isPresent())
{ {
Set<Integer> idsWithErrors = getRecordIdsWithErrors(records); Set<Integer> idsWithErrors = getRecordIdsWithErrors(records);
@ -201,6 +207,7 @@ public class ScheduledJobTableCustomizer implements TableCustomizerInterface
@Override @Override
public List<QRecord> postDelete(DeleteInput deleteInput, List<QRecord> records) throws QException public List<QRecord> postDelete(DeleteInput deleteInput, List<QRecord> records) throws QException
{ {
transaction = deleteInput.getTransaction();
Set<Integer> idsWithErrors = getRecordIdsWithErrors(records); Set<Integer> idsWithErrors = getRecordIdsWithErrors(records);
unscheduleJobsForRecordList(records, idsWithErrors); unscheduleJobsForRecordList(records, idsWithErrors);
return (records); return (records);
@ -262,12 +269,13 @@ public class ScheduledJobTableCustomizer implements TableCustomizerInterface
/******************************************************************************* /*******************************************************************************
** **
*******************************************************************************/ *******************************************************************************/
private static List<QRecord> freshlyQueryForRecordsWithAssociations(List<QRecord> records) throws QException private List<QRecord> freshlyQueryForRecordsWithAssociations(List<QRecord> records) throws QException
{ {
List<Integer> idList = records.stream().map(r -> r.getValueInteger("id")).toList(); List<Integer> idList = records.stream().map(r -> r.getValueInteger("id")).toList();
return new QueryAction().execute(new QueryInput(ScheduledJob.TABLE_NAME) return new QueryAction().execute(new QueryInput(ScheduledJob.TABLE_NAME)
.withIncludeAssociations(true) .withIncludeAssociations(true)
.withTransaction(transaction)
.withFilter(new QQueryFilter(new QFilterCriteria("id", QCriteriaOperator.IN, idList)))) .withFilter(new QQueryFilter(new QFilterCriteria("id", QCriteriaOperator.IN, idList))))
.getRecords(); .getRecords();
} }