    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.plugin.io;
    017
    018import java.io.File;                                                                            // 6.2.0.0 (2015/02/27)
    019import java.util.Arrays;                                                                        // 6.2.0.0 (2015/02/27)
    020
    021import org.opengion.fukurou.model.TableModelHelper;                     // 6.2.0.0 (2015/02/27) クラス名変更
    022import org.opengion.fukurou.model.EventReader_TEXT;                     // 6.2.0.0 (2015/02/27)
    023
    024import org.opengion.hayabusa.common.HybsSystemException;
    025import org.opengion.hayabusa.io.AbstractTableReader;            // 6.2.0.0 (2015/02/27)
    026
    027import static org.opengion.fukurou.system.HybsConst.CR ;                // 6.2.2.0 (2015/03/27)
    028
    029/**
    030 * POI による、EXCELバイナリファイルを読み取る実装クラスです。
    031 *
    032 * ファイル名、シート名を指定して、データを読み取ることが可能です。
    033 * 第一カラムが # で始まる行は、コメント行なので、読み飛ばします。
    034 * カラム名の指定行で、カラム名が null の場合は、その列は読み飛ばします。
    035 *
    036 * 入力形式は、openXML形式にも対応しています。
    037 * ファイルの内容に応じて、.xlsと.xlsxのどちらで読み取るかは、内部的に
    038 * 自動判定されます。
    039 *
    040 * @og.rev 3.5.4.8 (2004/02/23) 新規作成
    041 * @og.rev 4.3.6.7 (2009/05/22) ooxml形式対応
    042 * @og.rev 6.2.0.0 (2015/02/27) TableReader クラスの呼び出し元メソッドの共通化(EXCEL,TEXT)。新規
    043 * @og.group ファイル入力
    044 *
    045 * @version  4.0
    046 * @author   Kazuhiko Hasegawa
    047 * @since    JDK5.0,
    048 */
    049public class TableReader_Text extends AbstractTableReader {
    050        /** このプログラムのVERSION文字列を設定します。   {@value} */
    051        private static final String VERSION = "6.4.2.0 (2016/01/29)" ;
    052
    053        /**
    054         * デフォルトコンストラクター
    055         *
    056         * @og.rev 6.4.2.0 (2016/01/29) PMD refactoring. Each class should declare at least one constructor.
    057         */
    058        public TableReader_Text() { super(); }          // これも、自動的に呼ばれるが、空のメソッドを作成すると警告されるので、明示的にしておきます。
    059
    060        /**
    061         * DBTableModel から 各形式のデータを作成して,BufferedReader より読み取ります。
    062         * コメント/空行を除き、最初の行は、必ず項目名が必要です。
    063         * それ以降は、コメント/空行を除き、データとして読み込んでいきます。
    064         * このメソッドは、EXCEL 読み込み時に使用します。
    065         *
    066         * @og.rev 4.0.0.0 (2006/09/31) 新規追加
    067         * @og.rev 5.1.6.0 (2010/05/01) columns 処理 追加
    068         * @og.rev 5.1.6.0 (2010/05/01) skipRowCountの追加
    069         * @og.rev 5.1.8.0 (2010/07/01) Exception をきちっと記述(InvalidFormatException)
    070         * @og.rev 5.2.1.0 (2010/10/01) setTableColumnValues メソッドを経由して、テーブルにデータをセットする。
    071         * @og.rev 5.5.1.2 (2012/04/06) HeaderData を try の上にだし、エラーメッセージを取得できるようにする。
    072         * @og.rev 5.5.7.2 (2012/10/09) sheetNos 追加による複数シートのマージ読み取りサポート
    073         * @og.rev 5.5.8.2 (2012/11/09) HeaderData に デバッグフラグを渡します。
    074         * @og.rev 6.0.2.5 (2014/10/31) debug=true 時に、進捗が見えるようにします。
    075         * @og.rev 6.1.0.0 (2014/12/26) Excel関係改善
    076         * @og.rev 6.2.0.0 (2015/02/27) TableReader クラスの呼び出し元メソッドの共通化(EXCEL,TEXT)。新規
    077         * @og.rev 6.2.1.0 (2015/03/13) TableReaderModel を外部からセットします。
    078         * @og.rev 6.2.3.0 (2015/05/01) 行読み飛ばし nullSkipClm追加
    079         *
    080         * @param   file 読み取り元ファイル
    081         * @param   enc ファイルのエンコード文字列(未使用)
    082         */
    083        @Override
    084        public void readDBTable( final File file , final String enc ) {
    085                final boolean isDebug = isDebug();                      // 5.5.7.2 (2012/10/09) デバッグ情報
    086
    087                if( isDebug ) { System.out.println( " Filename=" + file ) ; }
    088
    089                final TableModelHelper helper = new TableModelHelper() {
    090
    091                        /**
    092                         * カラム名配列がそろった段階で、イベントが発生します。
    093                         *
    094                         * openGion での標準的な処理は、colNo==0 の時に、val の先頭が、#NAME
    095                         * で始まるレコードを、名前配列として認識します。
    096                         * #value( String,int,int ) で、この #NAME だけは、継続処理されます。
    097                         * その上で、#NAME レコードが終了した時点で、カラム名配列が完成するので
    098                         * そこで初めて、このメソッドが呼ばれます。
    099                         *
    100                         * @og.rev 6.0.3.0 (2014/11/13) 新規作成
    101                         * @og.rev 6.1.0.0 (2014/12/26) omitNames 属性を追加
    102                         *
    103                         * @param   names  カラム名配列
    104                         * @see         #value( String,int,int )
    105                         */
    106                        @Override
    107                        public void columnNames( final String[] names ) {
    108                                setTableDBColumn( names ) ;
    109                        }
    110
    111                        /**
    112                         * row にあるセルのオブジェクト値がそろった段階で、イベントが発生します。
    113                         *
    114                         * @og.rev 6.0.3.0 (2014/11/13) 新規作成
    115                         * @og.rev 6.2.1.0 (2015/03/13) setTableColumnValuesに、行番号を引数に追加
    116                         *
    117                         * @param   vals    文字列値の１行分の配列
    118                         * @param   rowNo   行番号(0～)
    119                         */
    120                        @Override
    121                        public void values( final String[] vals,final int rowNo ) {
    122                                if( isDebug && rowNo % 100 == 0 ) {
    123                                        System.out.println( "  No.[" + rowNo + "]=" + Arrays.toString( vals ) ) ;
    124                                }
    125                                setTableColumnValues( vals,rowNo );             // 6.2.1.0 (2015/03/13)
    126                        }
    127                };
    128
    129                helper.setDebug( isDebug );                                                     // 6.2.0.0 (2015/02/27)
    130                helper.setConstData( constKeys , constAdrs );           // 6.1.0.0 (2014/12/26) 外部から固定値情報を指定。
    131                helper.setNames( columns , isUseNumber() );                     // 6.1.0.0 (2014/12/26) 外部からカラム名配列を指定。
    132                helper.setSkipRowCount( getSkipRowCount() );            // 6.1.0.0 (2014/12/26) 外部からスキップ行数を指定。
    133                helper.setNullBreakClm( nullBreakClm );                         // 6.2.0.0 (2015/02/27) 外部からnullBreakClmを指定。
    134                helper.setNullSkipClm( nullSkipClm );                           // 6.2.3.0 (2015/05/01) 外部からnullSkipClmを指定。
    135
    136                final EventReader_TEXT reader = new EventReader_TEXT();
    137                reader.setSeparator( separator );                                       // 6.2.0.0 (2015/02/27) 外部からエンコードを指定。
    138                reader.setEncode( enc );                                                        // 6.2.0.0 (2015/02/27) 外部からエンコードを指定。
    139
    140                reader.eventReader( file , helper );
    141
    142                // 最後まで、#NAME が見つから無かった場合
    143                if( !helper.isNameSet() ) {
    144                        final String errMsg = "最後まで、#NAME が見つかりませんでした。"
    145                                                        + CR
    146                                                        + "ファイル形式が異なるか、もしくは損傷している可能性があります。"
    147                                                        + "Class=[Text], File=[" + file + "], Encode=[" + enc + "], Separator=[" + separator + "]"
    148                                                        + CR ;
    149                        throw new HybsSystemException( errMsg );
    150                }
    151
    152                if( isDebug ) { System.out.println( "  TableReader End." ) ; }
    153        }
    154}