6.7.2. Transaction Loop Control Handler¶
Table of contents
This handler, in addition to repeatedly executing the processing of the subsequent handlers, performs transaction control, and commits the transaction at a certain number of repetitions, while the data to be processed is present in the data reader. By increasing the transaction commit interval, it is possible to improve the throughput of batch processing.
- Begin a transaction
- End a transaction (commit or rollback)
- Callback at the end of the transaction
The process flow is as follows.
6.7.2.2. Module list¶
<dependency>
<groupId>com.nablarch.framework</groupId>
<artifactId>nablarch-fw-standalone</artifactId>
</dependency>
<dependency>
<groupId>com.nablarch.framework</groupId>
<artifactId>nablarch-core-transaction</artifactId>
</dependency>
<!-- Only to control transactions to the database -->
<dependency>
<groupId>com.nablarch.framework</groupId>
<artifactId>nablarch-core-jdbc</artifactId>
</dependency>
6.7.2.3. Constraints¶
- Configure after Database Connection Management Handler
- When controlling a transaction in a database, a database connection for transaction management must exist in the thread.
6.7.2.4. Configure the transaction control target¶
This handler uses the factory class ( implementation class of TransactionFactory) configured in the transactionFactory property to obtain the control target of the transaction and manage it on the thread.
When managing on a thread, configure a name to identify the transaction.
By default, transaction is used but to use a different name, configure the name in the transactionName property.
Tip
To perform transaction control on the database configured with Database Connection Management Handler, configure the same value configured in DbConnectionManagementHandler#connectionName to transactionName property.
If a value is not configured in DbConnectionManagementHandler#connectionName, then the configuration of transactionName can be omitted.
Configure the handler by referring to the configuration file example given below.
<!-- Transaction control handler -->
<component class="nablarch.fw.handler.LoopHandler">
<property name="transactionFactory" ref="databaseTransactionFactory" />
<property name="transactionName" value="name" />
</component>
<!-- When performing the transaction control on the database, configure JdbcTransactionFactory -->
<component name="databaseTransactionFactory"
class="nablarch.core.db.transaction.JdbcTransactionFactory">
<!-- Property configuration is omitted -->
</component>
6.7.2.5. Specify the commit interval¶
Configure the commit interval for batch processing to commitInterval. As described in the summary, the throughput of the batch process can be improved by adjusting the commit interval.
A configuration example is shown below.
<component class="nablarch.fw.handler.LoopHandler">
<!-- Specify 1000 for commit interval -->
<property name="commitInterval" value="1000" />
</component>
6.7.2.6. Execute optional processing at the end of the transaction¶
This handler performs a callback process after subsequent handler processes.
The process to be called back is the handler that implements TransactionEventCallback among the handlers configured after this handler. If multiple handlers implement TransactionEventCallback, then the callback process is performed sequentially from the handler that has been configured earlier.
If a subsequent handler finishes the process normally, the callback process is executed in the same transaction as the subsequent handler. The processing performed in the callback process is collectively committed at the timing of the next commit.
If an exception or error occurs in the subsequent handlers and the transaction is rolled back, the callback process is performed after the rollback. Therefore, the callback process is performed in a new transaction and is committed when the callback has completed successfully.
Important
Note that if multiple handlers have implemented the callback process and an error or exception occurs during the callback process, the callback process for the remaining handlers is not performed.
An example is shown below.
- Creating a handler that performs the callback process
Create a handler that implements TransactionEventCallback as shown in the following implementation example.
Implement the callback process at the time of transaction commit in transactionNormalEnd, and implement the callback process at the time of transaction rollback in transactionAbnormalEnd.
public static class SampleHandler implements Handler<Object, Object>, TransactionEventCallback<Object> { @Override public Object handle(Object o, ExecutionContext context) { // Implement handler processing return context.handleNext(o); } @Override public void transactionNormalEnd(Object o, ExecutionContext ctx) { // Implements rollback process if the subsequent handler ends normally } @Override public void transactionAbnormalEnd(Throwable e, Object o, ExecutionContext ctx) { // Implement callback process during transaction rollback } }
- Build a handler queue
Configure the handler that implements callback process in the subsequent handler of this handler as follows.
<list name="handlerQueue"> <!-- Transaction control handler --> <component class="nablarch.fw.handler.LoopHandler"> <!-- Configuration of property is omitted --> </component> <!-- Handler that implements callback process --> <component class="sample.SampleHandler" /> </list>