Package com.boomi.connector.util

Class BaseUpdateOperation

java.lang.Object

com.boomi.connector.util.ContextualOperation

com.boomi.connector.util.BaseOperation

com.boomi.connector.util.BaseUpdateOperation

All Implemented Interfaces:

Operation

Direct Known Subclasses:

BadInputStreamSampleOperation, CustomJsonRequestOperation, CustomJsonResponseOperation, DirectInputStreamSampleOperation, ImportableFieldsOperation, OutputStreamSampleOperation, OverrideableFieldOperation, RestOperation, SizeBasedRoutingOperation, SizeLimitedUpdateOperation, SplitJsonResponseOperation, WSExecuteOperation

public abstract class BaseUpdateOperation
extends BaseOperation

Utility base class for implementing a CREATE, UPDATE, UPSERT or EXECUTE Operation.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BaseUpdateOperation(OperationContext context)
protected	BaseUpdateOperation(BaseConnection<OperationContext> conn)

Method Summary

Modifier and Type	Method	Description
void	execute(OperationRequest request, OperationResponse response)	Executes an operation with the given request, passing results to the given response.
protected abstract void	executeUpdate(UpdateRequest request, OperationResponse response)	Actual implementation of this CREATE, UPDATE, or UPSERT Operation.

Methods inherited from class com.boomi.connector.util.ContextualOperation

getConnection, getContext

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseUpdateOperation

protected BaseUpdateOperation(OperationContext context)

BaseUpdateOperation

protected BaseUpdateOperation(BaseConnection<OperationContext> conn)

Method Detail

execute

public void execute(OperationRequest request,
                    OperationResponse response)

Executes an operation with the given request, passing results to the given response.

Any TrackedData received as part of a request should eventually be passed into the response. Any data not passed along will be marked as "failed" by the atom (thus, any thrown exceptions will cause all outstanding data to be marked as "failed"). There are 4 scenarios for input/output relationships, each of which can be handled conveniently via the ResponseUtil utility:

• Single Input(TrackedData) -> Single Output(Payload) - the common scenario where each input results in a single output. Each input TrackedData will be passed to the response with the relevant output using OperationResponse.addResult(com.boomi.connector.api.TrackedData, com.boomi.connector.api.OperationStatus, java.lang.String, java.lang.String, com.boomi.connector.api.Payload).
• Multiple Inputs(TrackedData) -> Single Output(Payload) - this scenario generally results from operations which take batches of input and return a single result status. Since multiple inputs are responsible for the single output, they should all be passed together to the response with the relevant output using OperationResponse.addCombinedResult(java.lang.Iterable<? extends com.boomi.connector.api.TrackedData>, com.boomi.connector.api.OperationStatus, java.lang.String, java.lang.String, com.boomi.connector.api.Payload).
• Single Input(TrackedData) -> Multiple Outputs(Payload) - this scenario generally results from query type operations where a single query returns many results. Since the same input is responsible for many outputs, the outputs should be passed to the response as a "partial" result using OperationResponse.addPartialResult(com.boomi.connector.api.TrackedData, com.boomi.connector.api.OperationStatus, java.lang.String, java.lang.String, com.boomi.connector.api.Payload) until all results have been processed, at which point the input should be passed to the response as "finished" using OperationResponse.finishPartialResult(com.boomi.connector.api.TrackedData).
• Single/Multiple Inputs(TrackedData) -> No Output(Payload) - this scenario may result from operations which return no response, such as a GET request with an id for which no object exists. Each input TrackedData should be passed to the response using OperationResponse.addEmptyResult(com.boomi.connector.api.TrackedData, com.boomi.connector.api.OperationStatus, java.lang.String, java.lang.String).

Base implementation redirects to executeUpdate(com.boomi.connector.api.UpdateRequest, com.boomi.connector.api.OperationResponse).

Specified by:

execute in interface Operation

Overrides:

execute in class BaseOperation

Parameters:

request - the current request for this operation. this object should be downcast to the request type for the relevant operation, one of GetRequest, DeleteRequest, QueryRequest or UpdateRequest (for CREATE,UPDATE, and UPSERT operations).

response - object which should be updated with the results of this operation (see comments above).

executeUpdate

protected abstract void executeUpdate(UpdateRequest request,
                                      OperationResponse response)

Actual implementation of this CREATE, UPDATE, or UPSERT Operation.

Parameters:

request - request given to execute(com.boomi.connector.api.OperationRequest, com.boomi.connector.api.OperationResponse), downcast to the correct type

response - response given to execute(com.boomi.connector.api.OperationRequest, com.boomi.connector.api.OperationResponse)