Class LoadViaInsertOrUpdateStep

java.lang.Object

com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.AbstractLoadStep

com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.LoadViaInsertOrUpdateStep

Direct Known Subclasses:

MergeDuplicatesLoadStep

public class LoadViaInsertOrUpdateStep
extends AbstractLoadStep

Generic implementation of a LoadStep - that runs Insert and/or Update actions for the destination table - where the presence or absence of the record's primaryKey field is the indicator for which to do. e.g., it assumes auto-generated ids, to be populated upon insert.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FIELD_DESTINATION_TABLE
static final String	FIELD_SKIP_UNIQUE_KEY_CHECK
protected List<QRecord>	recordsToInsert
protected List<QRecord>	recordsToUpdate

Fields inherited from class com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.AbstractLoadStep

session

Constructor Summary

Constructors

Constructor	Description
LoadViaInsertOrUpdateStep()

Method Summary

Modifier and Type	Method	Description
protected void	evaluateRecords(RunBackendStepInput runBackendStepInput)
protected InputSource	getInputSource()
void	insertAndUpdateRecords(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput)
Optional<QBackendTransaction>	openTransaction(RunBackendStepInput runBackendStepInput)
void	runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput)	Execute the backend step - using the request as input, and the result as output.
protected void	splitRecordsForInsertOrUpdate(List<QRecord> inputList, String primaryKeyFieldName, List<QRecord> insertList, List<QRecord> updateList)

Methods inherited from class com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.AbstractLoadStep

getOverrideRecordPipeCapacity, getTransaction, getTransformStep, postRun, preRun, setTransaction, setTransformStep, withTransformStep

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

FIELD_DESTINATION_TABLE

public static final String FIELD_DESTINATION_TABLE

See Also:

• Constant Field Values

FIELD_SKIP_UNIQUE_KEY_CHECK

public static final String FIELD_SKIP_UNIQUE_KEY_CHECK

See Also:

• Constant Field Values

recordsToInsert

protected List<QRecord> recordsToInsert

recordsToUpdate

protected List<QRecord> recordsToUpdate

Constructor Details

LoadViaInsertOrUpdateStep

public LoadViaInsertOrUpdateStep()

Method Details

getInputSource

protected InputSource getInputSource()

runOnePage

public void runOnePage(RunBackendStepInput runBackendStepInput,
 RunBackendStepOutput runBackendStepOutput)
                throws QException

Execute the backend step - using the request as input, and the result as output.

Specified by:

runOnePage in class AbstractLoadStep

Throws:

QException

insertAndUpdateRecords

public void insertAndUpdateRecords(RunBackendStepInput runBackendStepInput,
 RunBackendStepOutput runBackendStepOutput)
                            throws QException

Throws:

QException

openTransaction

public Optional<QBackendTransaction> openTransaction(RunBackendStepInput runBackendStepInput)
                                              throws QException

Overrides:

openTransaction in class AbstractLoadStep

Throws:

QException

evaluateRecords

protected void evaluateRecords(RunBackendStepInput runBackendStepInput)
                        throws QException

Throws:

QException

splitRecordsForInsertOrUpdate

protected void splitRecordsForInsertOrUpdate(List<QRecord> inputList,
 String primaryKeyFieldName,
 List<QRecord> insertList,
 List<QRecord> updateList)