    001/*
    002 * Copyright (c) 2009 The openGion Project.
    003 *
    004 * Licensed under the Apache License, Version 2.0 (the "License");
    005 * you may not use this file except in compliance with the License.
    006 * You may obtain a copy of the License at
    007 *
    008 *     http://www.apache.org/licenses/LICENSE-2.0
    009 *
    010 * Unless required by applicable law or agreed to in writing, software
    011 * distributed under the License is distributed on an "AS IS" BASIS,
    012 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
    013 * either express or implied. See the License for the specific language
    014 * governing permissions and limitations under the License.
    015 */
    016package org.opengion.fukurou.process;
    017
    018import org.opengion.fukurou.system.OgRuntimeException ;         // 6.4.2.0 (2016/01/29)
    019import org.opengion.fukurou.util.Argument;
    020
    021import org.opengion.fukurou.util.StringUtil;
    022import org.opengion.fukurou.util.HybsEntry ;
    023import org.opengion.fukurou.system.LogWriter;
    024
    025import java.util.Hashtable;
    026import java.util.List;
    027import java.util.ArrayList;
    028import java.util.Map ;
    029import java.util.LinkedHashMap ;
    030
    031import javax.naming.Context;
    032import javax.naming.NamingEnumeration;
    033import javax.naming.NamingException;
    034import javax.naming.directory.DirContext;
    035import javax.naming.directory.InitialDirContext;
    036import javax.naming.directory.SearchControls;
    037import javax.naming.directory.SearchResult;
    038import javax.naming.directory.Attribute;
    039import javax.naming.directory.Attributes;
    040
    041/**
    042 * Process_LDAPReaderは、LDAPから読み取った内容を、LineModel に設定後、
    043 * 下流に渡す、FirstProcess インターフェースの実装クラスです。
    044 *
    045 * LDAPから読み取った内容より、LineModelを作成し、下流(プロセスチェインは、
    046 * チェインしているため、データは上流から下流へと渡されます。)に渡します。
    047 *
    048 * 引数文字列中にスペースを含む場合は、ダブルコーテーション("") で括って下さい。
    049 * 引数文字列の 『=』の前後には、スペースは挟めません。必ず、-key=value の様に
    050 * 繋げてください。
    051 *
    052 * @og.formSample
    053 *  Process_LDAPReader -attrs=uid,cn,officeName,ou,mail,belongOUID -orderBy=uid -filter=(&amp;(objectClass=person)(|(belongOUID=61200)(belongOUID=61100)))
    054 *
    055 *   [ -initctx=コンテキストファクトリ   ] ：初期コンテキストファクトリ (初期値:com.sun.jndi.ldap.LdapCtxFactory)
    056 *   [ -providerURL=サービスプロバイダリ ] ：サービスプロバイダリ       (初期値:ldap://ldap.opengion.org:389)
    057 *   [ -entrydn=取得元の名前             ] ：属性の取得元のオブジェクトの名前 (初期値:cn=inquiry-sys,o=opengion,c=JP)
    058 *   [ -password=取得元のパスワード      ] ：属性の取得元のパスワード   (初期値:******)
    059 *   [ -searchbase=コンテキストベース名  ] ：検索するコンテキストのベース名 (初期値:soouid=employeeuser,o=opengion,c=JP)
    060 *   [ -searchScope=検索範囲             ] ：検索範囲。『OBJECT』『ONELEVEL』『SUBTREE』のどれか(初期値:SUBTREE)
    061 *   [ -timeLimit=検索制限時間           ] ：結果が返されるまでのミリ秒数。0 の場合無制限(初期値:0)
    062 *   [ -attrs=属性の識別子               ] ：エントリと一緒に返される属性の識別子。null の場合すべての属性
    063 *   [ -columns=属性のカラム名           ] ：属性の識別子に対する別名。識別子と同じ場合は『,』のみで区切る。
    064 *   [ -maxRowCount=最大検索数           ] ：最大検索数(初期値:0[無制限])
    065 *   [ -match_XXXX=正規表現              ] ：指定のカラムと正規表現で一致時のみ処理( -match_LANG=ABC=[a-zA-Z]* など。)
    066 *   [ -filter=検索条件                  ] ：検索する LDAP に指定する条件
    067 *   [ -referral=REFERAL                 ] ：ignore/follow/throw
    068 *   [ -display=[false/true]             ] ：結果を標準出力に表示する(true)かしない(false)か(初期値:false[表示しない])
    069 *   [ -debug=[false/true]               ] ：デバッグ情報を標準出力に表示する(true)かしない(false)か(初期値:false[表示しない])
    070 *
    071 * @version  4.0
    072 * @author   Kazuhiko Hasegawa
    073 * @since    JDK5.0,
    074 */
    075public class Process_LDAPReader extends AbstractProcess implements FirstProcess {
    076        private static final String             INITCTX                 = "com.sun.jndi.ldap.LdapCtxFactory";
    077        private static final String             PROVIDER                = "ldap://ldap.opengion.org:389";
    078        private static final String             PASSWORD                = "password";
    079        private static final String             SEARCH_BASE             = "soouid=employeeuser,o=opengion,c=JP";
    080        private static final String             ENTRYDN                 = "cn=inquiry-sys,o=opengion,c=JP";     // 4.2.2.0 (2008/05/10)
    081        private static final String             REFERRAL                = ""; // 5.6.7.0 (2013/07/27)
    082
    083        // 検索範囲。OBJECT_SCOPE、ONELEVEL_SCOPE、SUBTREE_SCOPE のどれか 1 つ
    084        private static final String[]   SCOPE_LIST              = { "OBJECT","ONELEVEL","SUBTREE" };
    085        private static final String             SEARCH_SCOPE    = "SUBTREE";
    086
    087        private static final long               COUNT_LIMIT             = 0;                    // 返すエントリの最大数。0 の場合、フィルタを満たすエントリをすべて返す
    088        private static final boolean    RETURN_OBJ_FLAG = false;                // true の場合、エントリの名前にバインドされたオブジェクトを返す。false 場合、オブジェクトを返さない
    089        private static final boolean    DEREF_LINK_FLAG = false;                // true の場合、検索中にリンクを間接参照する
    090
    091        private String                  filter                          ;               // "employeeNumber=87019";
    092        private int                             timeLimit                       ;               // 結果が返されるまでのミリ秒数。0 の場合、無制限
    093        private String[]                attrs                           ;               // エントリと一緒に返される属性の識別子。null の場合、すべての属性を返す。空の場合、属性を返さない
    094        private String[]                columns                         ;               // 属性の識別子に対する、別名。識別子と同じ場合は、『,』のみで区切る。
    095
    096        private int                             executeCount            ;               // 検索/実行件数
    097        private int                     maxRowCount                     ;               // 最大検索数(0は無制限)
    098
    099        // 3.8.0.9 (2005/10/17) 正規表現マッチ
    100        private String[]                matchKey                        ;                       // 正規表現
    101        private boolean                 display                         ;                       // false:表示しない
    102        private boolean                 debug                           ;                       // 5.7.3.0 (2014/02/07) デバッグ情報
    103
    104        /** staticイニシャライザ後、読み取り専用にするので、ConcurrentHashMap を使用しません。 */
    105        private static final Map<String,String> MUST_PROPARTY   ;               // ［プロパティ］必須チェック用 Map
    106        /** staticイニシャライザ後、読み取り専用にするので、ConcurrentHashMap を使用しません。 */
    107        private static final Map<String,String> USABLE_PROPARTY ;               // ［プロパティ］整合性チェック Map
    108
    109        static {
    110                MUST_PROPARTY = new LinkedHashMap<>();
    111                MUST_PROPARTY.put( "filter",    "検索条件(必須) 例: (&(objectClass=person)(|(belongOUID=61200)(belongOUID=61100)))" );
    112
    113                USABLE_PROPARTY = new LinkedHashMap<>();
    114                USABLE_PROPARTY.put( "initctx",         "初期コンテキストファクトリ。" +
    115                                                                                        CR + " (初期値:com.sun.jndi.ldap.LdapCtxFactory)" );
    116                USABLE_PROPARTY.put( "providerURL",     "サービスプロバイダリ (初期値:ldap://ldap.opengion.org:389)" );
    117                USABLE_PROPARTY.put( "entrydn",         "属性の取得元のオブジェクトの名前。" +
    118                                                                                        CR + " (初期値:cn=inquiry-sys,o=opengion,c=JP)" );
    119                USABLE_PROPARTY.put( "password",                "属性の取得元のパスワード(初期値:******)" );
    120                USABLE_PROPARTY.put( "searchbase",      "検索するコンテキストのベース名。" +
    121                                                                                        CR + " (初期値:soouid=employeeuser,o=opengion,c=JP)" );
    122                USABLE_PROPARTY.put( "searchScope",     "検索範囲。『OBJECT』『ONELEVEL』『SUBTREE』のどれか。" +
    123                                                                                        CR + " (初期値:SUBTREE)" );
    124                USABLE_PROPARTY.put( "timeLimit",       "結果が返されるまでのミリ秒数。0 の場合無制限(初期値:0)" );
    125                USABLE_PROPARTY.put( "attrs",           "エントリと一緒に返される属性の識別子。null の場合すべての属性" );
    126                USABLE_PROPARTY.put( "columns",         "属性の識別子に対する別名。識別子と同じ場合は『,』のみで区切る。" );
    127                USABLE_PROPARTY.put( "maxRowCount",     "最大検索数(0は無制限)  (初期値:0)" );
    128                USABLE_PROPARTY.put( "match_",          "指定のカラムと正規表現で一致時のみ処理" +
    129                                                                                        CR + " ( -match_LANG=ABC=[a-zA-Z]* など。)" );
    130                USABLE_PROPARTY.put( "display",         "結果を標準出力に表示する(true)かしない(false)か" +
    131                                                                                        CR + "(初期値:false:表示しない)" );
    132                USABLE_PROPARTY.put( "debug",   "デバッグ情報を標準出力に表示する(true)かしない(false)か" +
    133                                                                                        CR + "(初期値:false:表示しない)" );             // 5.7.3.0 (2014/02/07) デバッグ情報
    134        }
    135
    136        private NamingEnumeration<SearchResult> nameEnum        ;                       // 4.3.3.6 (2008/11/15) Generics警告対応
    137        private LineModel                                               newData         ;
    138        private int                                                             count           ;
    139
    140        /**
    141         * デフォルトコンストラクター。
    142         * このクラスは、動的作成されます。デフォルトコンストラクターで、
    143         * super クラスに対して、必要な初期化を行っておきます。
    144         *
    145         */
    146        public Process_LDAPReader() {
    147                super( "org.opengion.fukurou.process.Process_LDAPReader",MUST_PROPARTY,USABLE_PROPARTY );
    148        }
    149
    150        /**
    151         * プロセスの初期化を行います。初めに一度だけ、呼び出されます。
    152         * 初期処理(ファイルオープン、ＤＢオープン等)に使用します。
    153         *
    154         * @og.rev 4.2.2.0 (2008/05/10) LDAP パスワード取得対応
    155         * @og.rev 5.3.4.0 (2011/04/01) StringUtil.nval ではなく、getProparty の 初期値機能を使う
    156         * @og.rev 5.6.7.0 (2013/07/27) REFERRAL対応
    157         *
    158         * @param   paramProcess データベースの接続先情報などを持っているオブジェクト
    159         */
    160        public void init( final ParamProcess paramProcess ) {
    161                final Argument arg = getArgument();
    162
    163                timeLimit       = arg.getProparty("timeLimit",timeLimit );                      // 5.3.4.0 (2011/04/01)
    164                maxRowCount     = arg.getProparty("maxRowCount",maxRowCount );          // 5.3.4.0 (2011/04/01)
    165                display         = arg.getProparty("display",display);
    166                debug           = arg.getProparty("debug",debug);                               // 5.7.3.0 (2014/02/07) デバッグ情報
    167
    168                // 属性配列を取得。なければゼロ配列
    169                attrs           = StringUtil.csv2Array( arg.getProparty("attrs") );
    170                if( attrs.length == 0 ) { attrs = null; }
    171
    172                // 別名定義配列を取得。なければ属性配列をセット
    173                columns         = StringUtil.csv2Array( arg.getProparty("columns") );
    174                if( columns.length == 0 ) { columns = attrs; }
    175
    176                // 属性配列が存在し、属性定義数と別名配列数が異なればエラー
    177                // 以降は、attrs == null か、属性定義数と別名配列数が同じはず。
    178                if( attrs != null && attrs.length != columns.length ) {
    179                        final String errMsg = "attrs と columns で指定の引数の数が異なります。" +
    180                                                " attrs=[" + arg.getProparty("attrs") + "] , columns=[" +
    181                                                arg.getProparty("columns") + "]" ;
    182                        throw new OgRuntimeException( errMsg );
    183                }
    184
    185                // 3.8.0.9 (2005/10/17) 正規表現マッチ
    186                final HybsEntry[] entry = arg.getEntrys( "match_" );
    187                final int len = entry.length;
    188                matchKey        = new String[columns.length];           // 正規表現
    189                for( int clm=0; clm<columns.length; clm++ ) {
    190                        matchKey[clm] = null;   // 判定チェック有無の初期化
    191                        for( int i=0; i<len; i++ ) {
    192                                if( columns[clm].equalsIgnoreCase( entry[i].getKey() ) ) {
    193                                        matchKey[clm] = entry[i].getValue();
    194                                }
    195                        }
    196                }
    197
    198                filter = arg.getProparty( "filter" ,filter );
    199
    200                final Hashtable<String,String> env = new Hashtable<>();
    201                // 6.4.1.1 (2016/01/16) PMD refactoring. Avoid declaring a variable if it is unreferenced before a possible exit point.
    202                final String initctx = arg.getProparty( "initctx " ,INITCTX );
    203                env.put(Context.INITIAL_CONTEXT_FACTORY, initctx);
    204                // 6.4.1.1 (2016/01/16) PMD refactoring. Avoid declaring a variable if it is unreferenced before a possible exit point.
    205                final String providerURL = arg.getProparty( "providerURL" ,PROVIDER );
    206                env.put(Context.PROVIDER_URL, providerURL);
    207                // 3.7.1.1 (2005/05/31)
    208                // 6.4.1.1 (2016/01/16) PMD refactoring. Avoid declaring a variable if it is unreferenced before a possible exit point.
    209                final String password = arg.getProparty( "password" ,PASSWORD );
    210        //      if( password != null && password.length() > 0 ) {
    211                        env.put(Context.SECURITY_CREDENTIALS, password);
    212        //      }
    213
    214                // 4.2.2.0 (2008/05/10) entrydn 属性の追加
    215                // 6.4.1.1 (2016/01/16) PMD refactoring. Avoid declaring a variable if it is unreferenced before a possible exit point.
    216                final String entrydn = arg.getProparty( "entrydn" ,ENTRYDN );   // 4.2.2.0 (2008/05/10)
    217        //      if( entrydn != null && entrydn.length() > 0 ) {
    218                        env.put(Context.SECURITY_PRINCIPAL  , entrydn);
    219        //      }
    220
    221                // 6.4.1.1 (2016/01/16) PMD refactoring. Avoid declaring a variable if it is unreferenced before a possible exit point.
    222                final String referral = arg.getProparty("referral",REFERRAL);  // 5.6.7.0 (2013/07/27)
    223                env.put( Context.REFERRAL, referral ); // 5.6.7.0 (2013/07/27)
    224
    225                try {
    226                        final DirContext ctx = new InitialDirContext(env);
    227                        // 6.4.1.1 (2016/01/16) PMD refactoring. Avoid declaring a variable if it is unreferenced before a possible exit point.
    228                        final String searchScope = arg.getProparty( "searchScope" ,SEARCH_SCOPE , SCOPE_LIST );
    229                        final SearchControls constraints = new SearchControls(
    230                                                                        changeScopeString( searchScope ),
    231                                                                        COUNT_LIMIT                     ,
    232                                                                        timeLimit                       ,
    233                                                                        attrs                           ,
    234                                                                        RETURN_OBJ_FLAG         ,
    235                                                                        DEREF_LINK_FLAG
    236                                                                                );
    237
    238                        // 6.4.1.1 (2016/01/16) PMD refactoring. Avoid declaring a variable if it is unreferenced before a possible exit point.
    239                        final String searchbase = arg.getProparty( "searchbase" ,SEARCH_BASE );
    240                        nameEnum = ctx.search( searchbase, filter, constraints );
    241
    242                } catch( final NamingException ex ) {
    243                        final String errMsg = "NamingException !"
    244                                        + ex.getMessage();                              // 5.1.8.0 (2010/07/01) errMsg 修正
    245                        throw new OgRuntimeException( errMsg,ex );
    246                }
    247        }
    248
    249        /**
    250         * プロセスの終了を行います。最後に一度だけ、呼び出されます。
    251         * 終了処理(ファイルクローズ、ＤＢクローズ等)に使用します。
    252         *
    253         * @param   isOK トータルで、OKだったかどうか[true:成功/false:失敗]
    254         */
    255        public void end( final boolean isOK ) {
    256                try {
    257                        if( nameEnum  != null ) { nameEnum.close() ;  nameEnum  = null; }
    258                }
    259                catch( final NamingException ex ) {
    260                        final String errMsg = "ディスコネクトすることが出来ません。";
    261                        throw new OgRuntimeException( errMsg,ex );
    262                }
    263        }
    264
    265        /**
    266         * このデータの処理において、次の処理が出来るかどうかを問い合わせます。
    267         * この呼び出し１回毎に、次のデータを取得する準備を行います。
    268         *
    269         * @return      処理できる:true / 処理できない:false
    270         */
    271        public boolean next() {
    272                try {
    273                        return nameEnum != null && nameEnum.hasMore() ;
    274                }
    275                catch( final NamingException ex ) {
    276                        final String errMsg = "ネクストすることが出来ません。";
    277                        throw new OgRuntimeException( errMsg,ex );
    278                }
    279        }
    280
    281        /**
    282         * 最初に、 行データである LineModel を作成します
    283         * FirstProcess は、次々と処理をチェインしていく最初の行データを
    284         * 作成して、後続の ChainProcess クラスに処理データを渡します。
    285         *
    286         * @og.rev 4.2.2.0 (2008/05/10) LDAP パスワード取得対応
    287         *
    288         * @param       rowNo   処理中の行番号
    289         *
    290         * @return      処理変換後のLineModel
    291         */
    292        public LineModel makeLineModel( final int rowNo ) {
    293                count++ ;
    294                try {
    295                        if( maxRowCount > 0 && maxRowCount <= executeCount ) { return null ; }
    296                        final SearchResult sRslt = nameEnum.next();             // 4.3.3.6 (2008/11/15) Generics警告対応
    297                        final Attributes att = sRslt.getAttributes();
    298
    299                        if( newData == null ) {
    300                                newData = createLineModel( att );
    301                                if( display ) { println( newData.nameLine() ); }
    302                        }
    303
    304                        final StringBuilder buf = new StringBuilder( BUFFER_MIDDLE );   // 6.1.0.0 (2014/12/26) refactoring
    305                        for( int i=0; i<attrs.length; i++ ) {
    306                                final Attribute attr = att.get(attrs[i]);
    307                                if( attr != null ) {
    308                                        final NamingEnumeration<?> vals = attr.getAll();        // 4.3.3.6 (2008/11/15) Generics警告対応
    309                                        buf.setLength(0);                                                                       // 6.1.0.0 (2014/12/26) refactoring
    310                                        if( vals.hasMore() ) { getDataChange( vals.next(),buf ) ;}      // 4.2.2.0 (2008/05/10)
    311                                        while( vals.hasMore() ) {
    312                                                buf.append( ',' ) ;                                                             // 6.0.2.5 (2014/10/31) char を append する。
    313                                                getDataChange( vals.next(),buf ) ;                              // 4.2.2.0 (2008/05/10)
    314                                        }
    315                                        // 3.8.0.9 (2005/10/17) 正規表現マッチしなければ、スルーする。
    316                                        final String value = buf.toString();
    317                                        final String key = matchKey[i];
    318                                        if( key != null && value != null && !value.matches( key ) ) {
    319                                                return null;
    320                                        }
    321                                        newData.setValue( i, value );
    322                                        executeCount++ ;
    323                                }
    324                        }
    325
    326                        newData.setRowNo( rowNo );
    327                        if( display ) { println( newData.dataLine() ); }
    328                }
    329                catch( final NamingException ex ) {
    330                        // 6.4.2.1 (2016/02/05) PMD refactoring.
    331                        // 6.9.8.0 (2018/05/28) FindBugs:null でないことがわかっている値の冗長な null チェック
    332                        // ※ 文字列連結は、内部で、StringBuilder.append しているので、null 判定は不要だが、null という文字列の出力を避けていた。
    333//                      final String errMsg = "データを処理できませんでした。[" + rowNo + "]件目" + CR
    334//                                      + newData != null ? newData.toString() : "" ;
    335                        final String errMsg = "データを処理できませんでした。[" + rowNo + "]件目" + CR
    336                                                                        + " newData=[" + newData + "]" + CR ;
    337
    338                        throw new OgRuntimeException( errMsg,ex );
    339                }
    340                return newData;
    341        }
    342
    343        /**
    344         * LDAPから取得したデータの変換を行います。
    345         *
    346         * 主に、バイト配列(byte[]) オブジェクトの場合、文字列に戻します。
    347         *
    348         * @og.rev 4.2.2.0 (2008/05/10) 新規追加
    349         *
    350         * @param       obj     主にバイト配列オブジェクト
    351         * @param       buf     元のStringBuilder
    352         *
    353         * @return      データを追加した StringBuilder
    354         */
    355        private StringBuilder getDataChange( final Object obj, final StringBuilder buf ) {
    356                if( obj == null ) { return buf; }
    357                else if( obj instanceof byte[] ) {
    358        //              buf.append( new String( (byte[])obj,"ISO-8859-1" ) );
    359                        final byte[] bb = (byte[])obj ;
    360                        char[] chs = new char[bb.length];
    361                        for( int i=0; i<bb.length; i++ ) {
    362                                chs[i] = (char)bb[i];
    363                        }
    364                        buf.append( chs );
    365                }
    366                else {
    367                        buf.append( obj ) ;
    368                }
    369
    370                return buf ;
    371        }
    372
    373        /**
    374         * 内部で使用する LineModel を作成します。
    375         * このクラスは、プロセスチェインの基点となりますので、新規 LineModel を返します。
    376         * Exception 以外では、必ず LineModel オブジェクトを返します。
    377         *
    378         * @param   att Attributesオブジェクト
    379         *
    380         * @return      データベースから取り出して変換した LineModel
    381         * @throws RuntimeException カラム名を取得できなかった場合。
    382         * @og.rtnNotNull
    383         */
    384        private LineModel createLineModel( final Attributes att ) {
    385                final LineModel model = new LineModel();
    386
    387                try {
    388                        // init() でチェック済み。attrs == null か、属性定義数と別名配列数が同じはず。
    389                        // attrs が null の場合は、全キー情報を取得します。
    390                        if( attrs == null ) {
    391                                final NamingEnumeration<String> nmEnum = att.getIDs();  // 4.3.3.6 (2008/11/15) Generics警告対応
    392                                final List<String> lst = new ArrayList<>();
    393                                try {
    394                                        while( nmEnum.hasMore() ) {
    395                                                lst.add( nmEnum.next() );               // 4.3.3.6 (2008/11/15) Generics警告対応
    396                                        }
    397                                }
    398                                finally {
    399                                        nmEnum.close();
    400                                }
    401                                attrs = lst.toArray( new String[lst.size()] );
    402                                columns = attrs;
    403                        }
    404
    405                        final int size = columns.length;
    406                        model.init( size );
    407                        for( int clm=0; clm<size; clm++ ) {
    408                                model.setName( clm,StringUtil.nval( columns[clm],attrs[clm] ) );
    409                        }
    410                }
    411                catch( final NamingException ex ) {
    412                        final String errMsg = "ResultSetMetaData から、カラム名を取得できませんでした。";
    413                        throw new OgRuntimeException( errMsg,ex );
    414                }
    415                return model;
    416        }
    417
    418        /**
    419         * スコープを表す文字列を SearchControls の定数に変換します。
    420         * 入力文字列は、OBJECT、ONELEVEL、SUBTREEです。変換する定数は、
    421         * SearchControls クラスの static 定数です。
    422         *
    423         * @param    scope スコープを表す文字列(OBJECT、ONELEVEL、SUBTREE)
    424         *
    425         * @return   SearchControlsの定数(OBJECT_SCOPE、ONELEVEL_SCOPE、SUBTREE_SCOPE)
    426         * @see      javax.naming.directory.SearchControls#OBJECT_SCOPE
    427         * @see      javax.naming.directory.SearchControls#ONELEVEL_SCOPE
    428         * @see      javax.naming.directory.SearchControls#SUBTREE_SCOPE
    429         */
    430        private int changeScopeString( final String scope ) {
    431                int rtnScope ;
    432                if( "OBJECT".equals( scope ) )        { rtnScope = SearchControls.OBJECT_SCOPE ; }
    433                else if( "ONELEVEL".equals( scope ) ) { rtnScope = SearchControls.ONELEVEL_SCOPE ; }
    434                else if( "SUBTREE".equals( scope ) )  { rtnScope = SearchControls.SUBTREE_SCOPE ; }
    435                else {
    436                        final String errMsg = "Search Scope in 『OBJECT』『ONELEVEL』『SUBTREE』Selected"
    437                                                        + "[" + scope + "]" ;
    438                        throw new OgRuntimeException( errMsg );
    439                }
    440                return rtnScope ;
    441        }
    442
    443        /**
    444         * プロセスの処理結果のレポート表現を返します。
    445         * 処理プログラム名、入力件数、出力件数などの情報です。
    446         * この文字列をそのまま、標準出力に出すことで、結果レポートと出来るような
    447         * 形式で出してください。
    448         *
    449         * @return   処理結果のレポート
    450         */
    451        public String report() {
    452                final String report = "[" + getClass().getName() + "]" + CR
    453                                + TAB + "Search Filter : " + filter + CR
    454                                + TAB + "Input Count   : " + count ;
    455
    456                return report ;
    457        }
    458
    459        /**
    460         * このクラスの使用方法を返します。
    461         *
    462         * @return      このクラスの使用方法
    463         * @og.rtnNotNull
    464         */
    465        public String usage() {
    466                final StringBuilder buf = new StringBuilder( BUFFER_LARGE )
    467                        .append( "Process_LDAPReaderは、LDAPから読み取った内容を、LineModel に設定後、"           ).append( CR )
    468                        .append( "下流に渡す、FirstProcess インターフェースの実装クラスです。"                                 ).append( CR )
    469                        .append( CR )
    470                        .append( "LDAPから読み取った内容より、LineModelを作成し、下流(プロセスチェインは、"          ).append( CR )
    471                        .append( "チェインしているため、データは上流から下流へと渡されます。)に渡します。"         ).append( CR )
    472                        .append( CR )
    473                        .append( "引数文字列中に空白を含む場合は、ダブルコーテーション(\"\") で括って下さい。"    ).append( CR )
    474                        .append( "引数文字列の 『=』の前後には、空白は挟めません。必ず、-key=value の様に"           ).append( CR )
    475                        .append( "繋げてください。"                                                                                                                             ).append( CR )
    476                        .append( CR ).append( CR )
    477                        .append( getArgument().usage() ).append( CR );
    478
    479                return buf.toString();
    480        }
    481
    482        /**
    483         * このクラスは、main メソッドから実行できません。
    484         *
    485         * @param       args    コマンド引数配列
    486         */
    487        public static void main( final String[] args ) {
    488                LogWriter.log( new Process_LDAPReader().usage() );
    489        }
    490}