クラス MappingLdifReader<T>

実装されたすべてのインターフェース:
ResourceAwareItemReaderItemStream<T>ItemReader<T>ItemStreamItemStreamReader<T>org.springframework.beans.factory.InitializingBean

public class MappingLdifReader<T> extends AbstractItemCountingItemStreamItemReader<T> implements ResourceAwareItemReaderItemStream<T>, org.springframework.beans.factory.InitializingBean
MappingLdifReader は、LdifParser を中心に構築された FlatFileItemReader を応用したものです。これは、LdapAttributes オブジェクトを POJO にマップする機能が標準の LdifReader とは異なります。

MappingLdifReaderRecordMapper の実装が必要です。マッピングが不要な場合は、代わりに LdifReader を使用する必要があります。ItemProcessor または任意の出力サービスによって必要に応じて消費および操作できる LdapAttributes オブジェクトを返すだけです。

FlatFileItemReader と同様に、strict オプションは、処理前にリソースの存在を要求するかどうかを区別します。値が false に設定されている場合、例外がスローされる代わりに警告がログに記録されます。

このリーダーはスレッドセーフではありません。

作成者:
Keith Barlow, Mahmoud Ben Hassine
  • コンストラクターの詳細

    • MappingLdifReader

      public MappingLdifReader()
  • メソッドの詳細

    • setStrict

      public void setStrict(boolean strict)
      厳格モードでは、入力リソースが存在しない場合、リーダーは AbstractItemCountingItemStreamItemReader.open(org.springframework.batch.item.ExecutionContext) で例外をスローします。
      パラメーター:
      strict - デフォルトでは false
    • setSkippedRecordsCallback

      public void setSkippedRecordsCallback(RecordCallbackHandler skippedRecordsCallback)
      RecordCallbackHandler 実装を使用して、スキップされたレコードに対してアクションを実行できます。
      パラメーター:
      skippedRecordsCallback - アイテムが読み込まれる前に、最初のスキップされた行ごとに呼び出されます。
    • setRecordsToSkip

      public void setRecordsToSkip(int recordsToSkip)
      ファイルの先頭でスキップする行数のパブリック setter。ファイルに有用な(列名)情報のないヘッダーが含まれていて、行の先頭にコメント区切り文字がない場合に使用できます。
      パラメーター:
      recordsToSkip - スキップする行数
    • setRecordMapper

      public void setRecordMapper(RecordMapper<T> recordMapper)
      オブジェクトマッパー用の Setter。このプロパティを設定する必要があります。
      パラメーター:
      recordMapper - レコードをオブジェクトにマップします
    • doClose

      protected void doClose() throws ExceptionSE
      クラスからコピーされた説明: AbstractItemCountingItemStreamItemReader
      AbstractItemCountingItemStreamItemReader.doOpen() で開いたリソースを閉じます。
      次で指定:
      クラス AbstractItemCountingItemStreamItemReader<T>doClose 
      例外:
      ExceptionSE - サブクラスがフレームワークによる解釈のためにチェック済み例外をスローできるようにします
    • doOpen

      protected void doOpen() throws ExceptionSE
      クラスからコピーされた説明: AbstractItemCountingItemStreamItemReader
      入力の読み取りを開始するために必要なリソースを開きます。
      次で指定:
      クラス AbstractItemCountingItemStreamItemReader<T>doOpen 
      例外:
      ExceptionSE - サブクラスがフレームワークによる解釈のためにチェック済み例外をスローできるようにします
    • doRead

      @Nullable protected T doRead() throws ExceptionSE
      クラスからコピーされた説明: AbstractItemCountingItemStreamItemReader
      入力から次の項目を読み取ります。
      次で指定:
      クラス AbstractItemCountingItemStreamItemReader<T>doRead 
      戻り値:
      データソースが使い果たされた場合、アイテムまたは null 
      例外:
      ExceptionSE - サブクラスがフレームワークによる解釈のためにチェック済み例外をスローできるようにします
    • setResource

      public void setResource(org.springframework.core.io.Resource resource)
      次で指定:
      インターフェース ResourceAwareItemReaderItemStream<T>setResource 
    • afterPropertiesSet

      public void afterPropertiesSet() throws ExceptionSE
      次で指定:
      インターフェース org.springframework.beans.factory.InitializingBeanafterPropertiesSet 
      例外:
      ExceptionSE