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     */
016    package org.opengion.plugin.io;
017    
018    import java.io.BufferedReader;
019    import java.io.IOException;
020    
021    import org.opengion.fukurou.util.StringUtil;
022    import org.opengion.hayabusa.common.HybsSystem;
023    import org.opengion.hayabusa.common.HybsSystemException;
024    import org.opengion.hayabusa.db.DBTableModelUtil;
025    import 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     */
039    public 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             * 縺薙?繝｡繧ｽ繝?ラ縺ｯ縲・XCEL 隱ｭ縺ｿ霎ｼ縺ｿ譎ゅ↓菴ｿ逕ｨ縺励∪縺吶?
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) 蠑墓焚縺ｫ縲。ufferedReader 繧貞女縺大叙繝ｫ隕√↓螟画峩縺励∪縺吶?
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    }