public class DomaTransactionItemWriteListener extends AbstractNablarchItemWriteListener
ItemWriteListener
レベルでDomaのトランザクション制御を行うNablarchItemWriteListener
の実装クラス。
前段に配置したDomaTransactionStepListener
からDomaのLocalTransaction
を取得し、トランザクション制御を行う。
ItemWriter
が正常に終了した場合には、トランザクションの確定(LocalTransaction.commit()
)を実行し、
その後にLocalTransaction
を開始(LocalTransaction.begin()
)する。
ItemWriter
でException
が発生した場合には、トランザクションの破棄(LocalTransaction.rollback()
を行う。
Constructor and Description |
---|
DomaTransactionItemWriteListener() |
Modifier and Type | Method and Description |
---|---|
void |
afterWrite(NablarchListenerContext context,
java.util.List<java.lang.Object> items)
ItemWriter.writeItems(List) の実行後の処理を行う。 |
void |
onWriteError(NablarchListenerContext context,
java.util.List<java.lang.Object> items,
java.lang.Exception ex)
ItemWriter.writeItems(List) でException が発生した場合の処理を行う。
本メソッドは、Java Batch(JSR352)の仕様により、Error 系が発生した場合はコールバックされない。 |
void |
setConnectionFactory(ConnectionFactoryFromDomaConnection connectionFactory)
コネクションファクトリを設定する。
|
beforeWrite
public void afterWrite(NablarchListenerContext context, java.util.List<java.lang.Object> items)
NablarchItemWriteListener
ItemWriter.writeItems(List)
の実行後の処理を行う。afterWrite
in interface NablarchItemWriteListener
afterWrite
in class AbstractNablarchItemWriteListener
context
- NablarchListenerContext
items
- 書き込み対象のオブジェクトpublic void onWriteError(NablarchListenerContext context, java.util.List<java.lang.Object> items, java.lang.Exception ex)
NablarchItemWriteListener
ItemWriter.writeItems(List)
でException
が発生した場合の処理を行う。
本メソッドは、Java Batch(JSR352)の仕様により、Error
系が発生した場合はコールバックされない。onWriteError
in interface NablarchItemWriteListener
onWriteError
in class AbstractNablarchItemWriteListener
context
- NablarchListenerContext
items
- 書き込み対象のオブジェクトex
- 発生したException
public void setConnectionFactory(ConnectionFactoryFromDomaConnection connectionFactory)
connectionFactory
- コネクションファクトリ