    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.BufferedReader;
    019import java.io.IOException;
    020
    021import org.opengion.fukurou.util.StringUtil;
    022import org.opengion.hayabusa.common.HybsSystem;
    023import org.opengion.hayabusa.common.HybsSystemException;
    024import org.opengion.hayabusa.db.DBTableModelUtil;
    025import org.opengion.hayabusa.io.AbstractTableReader;
    026
    027/**
    028 * 指定の区切り記号(初期値:タブ区切り)ファイルの読み取りクラスです。
    029 *
    030 * 名前，データの入力部のみオーバーライドすれば，各種入力フォーマットに合わせた
    031 * サブクラスを実現する事が可能です。
    032 *
    033 * @og.group ファイル入力
    034 *
    035 * @version  4.0
    036 * @author   Kazuhiko Hasegawa
    037 * @since    JDK5.0,
    038 */
    039public class TableReader_Default extends AbstractTableReader {
    040        //* このプログラムのVERSION文字列を設定します。   {@value} */
    041        private static final String VERSION = "5.2.1.0 (2010/10/01)" ;
    042
    043        /**
    044         * DBTableModel から 各形式のデータを作成して,BufferedReader より読み取ります。
    045         * コメント/空行を除き、最初の行は、必ず項目名が必要です。
    046         * それ以降は、コメント/空行を除き、データとして読み込んでいきます。
    047         * このメソッドは、EXCEL 読み込み時に使用します。
    048         *
    049         * @og.rev 4.0.0.0 (2006/09/31) 新規追加
    050         * @see #isExcel()
    051         */
    052        @Override
    053        public void readDBTable() {
    054                String errMsg = "このクラスでは実装されていません。";
    055                throw new UnsupportedOperationException( errMsg );
    056        }
    057
    058        /**
    059         * DBTableModel から 各形式のデータを作成して,BufferedReader より読み取ります。
    060         * コメント/空行を除き、最初の行は、必ず項目名が必要です。
    061         * それ以降は、コメント/空行を除き、データとして読み込んでいきます。
    062         *
    063         * @og.rev 3.1.1.0 (2003/03/28) 同期メソッド(synchronized付き)を非同期に変更する。
    064         * @og.rev 3.5.4.2 (2003/12/15) writer の null チェックを廃止します。
    065         * @og.rev 3.5.4.3 (2004/01/05) 引数に、BufferedReader を受け取ル要に変更します。
    066         * @og.rev 3.5.4.5 (2004/01/23) カラム名の外部指定を優先して使用する。
    067         * @og.rev 5.1.6.0 (2010/05/01) readDBTableのエラーチェック強化
    068         * @og.rev 5.1.6.0 (2010/05/01) skipRowCountの追加
    069         * @og.rev 5.2.0.0 (2010/09/01) ""で囲われているデータに改行が入っていた場合の対応
    070         * @og.rev 5.2.1.0 (2010/10/01) AbstractTableReader.java と重複している箇所の対応
    071         *
    072         * @param   reader BufferedReaderオブジェクト
    073         */
    074        @Override
    075        public void readDBTable( final BufferedReader reader ) {
    076                try {
    077                        String line;
    078                        String[] names = null;
    079                        int numberOfRows = 0;
    080//                      char  sepa = separator.charAt( 0 );
    081                        char  sepa = getSeparator().charAt( 0 );        // 5.2.0.0 (2010/09/01)
    082
    083                        boolean nameNoSet = true;
    084                        table = DBTableModelUtil.newDBTable();
    085
    086                        // 3.5.4.5 (2004/01/23) カラム名の外部指定を優先して使用する。
    087                        if( columns != null && columns.length() > 0 ) {
    088                                names = StringUtil.csv2Array( columns );
    089                                table.init( names.length );
    090                                setTableDBColumn( names ) ;
    091                                nameNoSet = false;
    092                        }
    093
    094//                      int skip = skipRowCount;                                                // 5.1.6.0 (2010/05/01)
    095                        int skip = getSkipRowCount();                                   // 5.2.0.0 (2010/09/01)
    096                        while((line = reader.readLine()) != null) {
    097                                // 5.2.0.0 (2010/09/01) ""で囲われているデータに改行が入っていた場合の対応
    098//                              int quotCount = StringUtil.countChar( line, '"' );
    099//                              if( quotCount % 2 == 1 ) {
    100//                                      String addLine = null;
    101//                                      while(quotCount % 2 == 1 && (addLine = reader.readLine()) != null) {
    102//                                              line +=  HybsSystem.CR + addLine;
    103//                                              quotCount += StringUtil.countChar( addLine, '"' );
    104//                                      }
    105//                              }
    106                                // 5.2.1.0 (2010/10/01) findbugs 対策(文字列の + 連結と、奇数判定ロジック)
    107                                int quotCount = StringUtil.countChar( line, '"' );
    108                                if( quotCount % 2 != 0 ) {
    109                                        String addLine = null;
    110                                        StringBuilder buf = new StringBuilder( line );
    111                                        while(quotCount % 2 != 0 && (addLine = reader.readLine()) != null) {
    112                                                buf.append( HybsSystem.CR ).append( addLine );
    113                                                quotCount += StringUtil.countChar( addLine, '"' );
    114                                        }
    115                                        line = buf.toString();
    116                                }
    117
    118                                if( skip > 0 ) { skip--; continue; }         // 5.1.6.0 (2010/05/01)
    119                                if( line.length() == 0 ) { continue; }
    120                                if( line.charAt( 0 ) == '#' ) {
    121                                        String key = line.substring( 0,5 );
    122                                        if( nameNoSet && ( key.equalsIgnoreCase( "#NAME" ) )) {
    123                                                // 超イレギュラー処理 最初の TAB_SEPARATOR 以前の文字は無視する。
    124                                                String line2 = line.substring( line.indexOf( sepa )+1 );
    125                                                names = StringUtil.csv2Array( line2 ,sepa );
    126                                                table.init( names.length );
    127                                                setTableDBColumn( names ) ;
    128                                                nameNoSet = false;
    129                                        }
    130                                        else  { continue; }
    131                                }
    132                                else {
    133                                        if( nameNoSet ) {
    134                                                String errMsg = "#NAME が見つかる前にデータが見つかりました。";
    135                                                throw new HybsSystemException( errMsg );
    136                                        }
    137                                        if( numberOfRows < getMaxRowCount() ) {
    138                                                setTableColumnValues( readData( line,names.length ) );          // 5.2.1.0 (2010/10/01)
    139//                                              table.addColumnValues( readData( line,names.length ) );
    140                                                numberOfRows ++ ;
    141                                        }
    142                                        else {
    143                                                table.setOverflow( true );
    144                                        }
    145                                }
    146                        }
    147
    148                        // 5.1.6.0 (2010/05/01) readDBTableのエラーチェック強化
    149                        if( nameNoSet ) {
    150                                String errMsg = "ファイルから有効なデータが見つかりませんでした。";
    151                                throw new HybsSystemException( errMsg );
    152                        }
    153                }
    154                catch ( IOException ex ) {
    155                        String errMsg = "ファイル読込みエラー[" + reader + "]"  ;
    156                        throw new HybsSystemException( errMsg,ex );             // 3.5.5.4 (2004/04/15) 引数の並び順変更
    157                }
    158        }
    159}