Class LoadViaInsertStep

java.lang.Object

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

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

Direct Known Subclasses:

BulkInsertLoadStep

public class LoadViaInsertStep
extends AbstractLoadStep

Generic implementation of a LoadStep - that runs an Insert action for a specified table.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FIELD_DESTINATION_TABLE
static final String	FIELD_SKIP_UNIQUE_KEY_CHECK

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

session

Constructor Summary

Constructors

Constructor	Description
LoadViaInsertStep()

Method Summary

Modifier and Type	Method	Description
protected InputSource	getInputSource()
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.

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

Constructor Details

LoadViaInsertStep

public LoadViaInsertStep()

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

openTransaction

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

Overrides:

openTransaction in class AbstractLoadStep

Throws:

QException