public class MappingLdifReader<T> extends AbstractItemCountingItemStreamItemReader<T> implements ResourceAwareItemReaderItemStream<T>, org.springframework.beans.factory.InitializingBean
MappingLdifReader
は、LdifParser
を中心に構築された FlatFileItemReader
を応用したものです。これは、LdapAttributes
オブジェクトを POJO にマップする機能が標準の LdifReader
とは異なります。MappingLdifReader
には RecordMapper
の実装が必要です。マッピングが不要な場合は、代わりに LdifReader
を使用する必要があります。ItemProcessor
または任意の出力サービスによって必要に応じて消費および操作できる LdapAttributes
オブジェクトを返すだけです。
FlatFileItemReader
と同様に、strict
オプションは、処理前にリソースが存在する必要があるかどうかを区別します。false に設定された値の場合、例外がスローされる代わりに警告がログに記録されます。
コンストラクターと説明 |
---|
MappingLdifReader() |
修飾子と型 | メソッドと説明 |
---|---|
void | afterPropertiesSet() |
protected void | doClose() AbstractItemCountingItemStreamItemReader.doOpen() で開いたリソースを閉じます。 |
protected void | doOpen() 入力の読み取りを開始するために必要なリソースを開きます。 |
protected T | doRead() 入力から次の項目を読み取ります。 |
void | setRecordMapper(RecordMapper<T> recordMapper) オブジェクトマッパー用の Setter。 |
void | setRecordsToSkip(int recordsToSkip) ファイルの先頭でスキップする行数のパブリック setter。 |
void | setResource(org.springframework.core.io.Resource resource) |
void | setSkippedRecordsCallback(RecordCallbackHandler skippedRecordsCallback) RecordCallbackHandler 実装を使用して、スキップされたレコードに対してアクションを実行できます。 |
void | setStrict(boolean strict) 厳格モードでは、入力リソースが存在しない場合、リーダーは AbstractItemCountingItemStreamItemReader.open(org.springframework.batch.item.ExecutionContext) で例外をスローします。 |
close, getCurrentItemCount, isSaveState, jumpToItem, open, read, setCurrentItemCount, setMaxItemCount, setSaveState, update
getExecutionContextKey, setExecutionContextName, setName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, open, update
read
public void setStrict(boolean strict)
AbstractItemCountingItemStreamItemReader.open(org.springframework.batch.item.ExecutionContext)
で例外をスローします。strict
- デフォルトでは falsepublic void setSkippedRecordsCallback(RecordCallbackHandler skippedRecordsCallback)
RecordCallbackHandler
実装を使用して、スキップされたレコードに対してアクションを実行できます。skippedRecordsCallback
- アイテムが読み込まれる前に、最初のスキップされた行ごとに呼び出されます。public void setRecordsToSkip(int recordsToSkip)
recordsToSkip
- スキップする行数 public void setRecordMapper(RecordMapper<T> recordMapper)
recordMapper
- レコードをオブジェクトにマップします protected void doClose() throws java.lang.Exception
AbstractItemCountingItemStreamItemReader
AbstractItemCountingItemStreamItemReader.doOpen()
で開いたリソースを閉じます。AbstractItemCountingItemStreamItemReader<T>
の doClose
java.lang.Exception
- サブクラスがフレームワークによる解釈のためにチェック済み例外をスローできるようにします protected void doOpen() throws java.lang.Exception
AbstractItemCountingItemStreamItemReader
AbstractItemCountingItemStreamItemReader<T>
の doOpen
java.lang.Exception
- サブクラスがフレームワークによる解釈のためにチェック済み例外をスローできるようにします @Nullable protected T doRead() throws java.lang.Exception
AbstractItemCountingItemStreamItemReader
AbstractItemCountingItemStreamItemReader<T>
の doRead
null
java.lang.Exception
- サブクラスがフレームワークによる解釈のためにチェック済み例外をスローできるようにします public void setResource(org.springframework.core.io.Resource resource)
ResourceAwareItemReaderItemStream<T>
の setResource
public void afterPropertiesSet() throws java.lang.Exception
org.springframework.beans.factory.InitializingBean
の afterPropertiesSet
java.lang.Exception