com.ibm.websphere.batch.devframework.datastreams.patternadapter

Interface JPAReaderPattern

public interface JPAReaderPattern

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.Object	fetchRecord(java.util.Iterator listIt) This method should retrieve values for the various columns for the current row from the given resultset object.
java.lang.String	getInitialLookupQuery() This method should return a JPQL query that will be used during setup of the stream to retrieve all relevant data that would be processed part of the job steps
java.lang.String	getRestartQuery(java.lang.String restartToken) This method gets called during Job Restart.
java.lang.String	getRestartTokens() This method gets called just before a checkpoint is taken.
void	initialize(java.util.Properties props) This method is invoked during the job setup phase.

Method Detail

initialize

void initialize(java.util.Properties props)

This method is invoked during the job setup phase.

Parameters:

props - properties provided in the xJCL

fetchRecord

java.lang.Object fetchRecord(java.util.Iterator listIt)

This method should retrieve values for the various columns for the current row from the given resultset object. Typically this data would be used to populate an intermediate object which would be returned

Parameters:

listIt -

Returns:

getInitialLookupQuery

java.lang.String getInitialLookupQuery()

This method should return a JPQL query that will be used during setup of the stream to retrieve all relevant data that would be processed part of the job steps

Returns:

object to be used during process step.

getRestartQuery

java.lang.String getRestartQuery(java.lang.String restartToken)

This method gets called during Job Restart. The restart token should be used to create an JPQL query that will retrieve previously unprocessed records. Typically the restart token would be the primary key in the table and the query would get all rows with primary key value > restarttoken

Parameters:

restartToken -

Returns:

The restart query

getRestartTokens

java.lang.String getRestartTokens()

This method gets called just before a checkpoint is taken.

Returns:

The method should return a string value identifying the last record read by the stream.