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.fukurou.db;
017    
018    import java.io.IOException;
019    import java.io.Reader;
020    import java.sql.Clob;
021    import java.sql.ResultSet;
022    import java.sql.ResultSetMetaData;
023    import java.sql.SQLException;
024    import java.sql.Types;
025    import java.sql.Date;
026    import java.sql.Timestamp;
027    import java.util.Locale;
028    
029    import org.opengion.fukurou.util.Closer;
030    import org.opengion.fukurou.util.HybsDateUtil;
031    import static org.opengion.fukurou.util.HybsConst.CR;                           // 6.1.0.0 (2014/12/26) refactoring
032    
033    /**
034     * ResultSet 縺ｮ繝??繧ｿ蜃ｦ逅?ｒ縺ｾ縺ｨ繧√◆繧ｯ繝ｩ繧ｹ縺ｧ縺吶?
035     * 縺薙％縺ｧ縺ｯ縲ヽesultSetMetaData 縺九ｉ縲√き繝ｩ繝?焚縲√き繝ｩ繝?錐(NAME蛻?縲?
036     * Type螻樊?繧貞叙蠕励＠縲ヽesultSet 縺ｧ縲∝?繧呈ｱゅａ繧区凾縺ｫ縲＾bject蝙九?
037     * 蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
038     * Object蝙九→縺励※縺ｯ縲，LOB縲ヽOWID縲ゝIMESTAMP 蝙九?縺ｿ蜿悶ｊ謇ｱ縺｣縺ｦ縺?∪縺吶?
039     *
040     * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?
041     * @og.group ?､?｢蛻ｶ蠕｡
042     *
043     * @version  6.0
044     * @author   Kazuhiko Hasegawa
045     * @since    JDK6.0,
046     */
047    public class ResultSetValue {
048    
049    //      /** 繧ｷ繧ｹ繝?Β萓晏ｭ倥?謾ｹ陦瑚ｨ伜捷繧偵そ繝?ヨ縺励∪縺吶?4.0.0.0(2007/10/17) */
050    //      private static final String CR = System.getProperty( "line.separator" );
051    
052            private final ResultSet resultSet ;                     // 蜀?Κ縺ｧ邂｡逅?☆繧?ResultSet 繧ｪ繝悶ず繧ｧ繧ｯ繝?
053            private final int               clmSize ;                       // 繧ｫ繝ｩ繝?し繧､繧ｺ
054            private final String[]  names ;                         // 繧ｫ繝ｩ繝?錐(ResultSetMetaData#getColumnLabel(int) 縺ｮ toUpperCase)
055            private final int[]             type ;                          // java.sql.Types 縺ｮ螳壽焚螳夂ｾｩ
056            private final boolean   useObj ;                        // 繧ｪ繝悶ず繧ｧ繧ｯ繝亥梛縺ｮ Type 縺悟ｭ伜惠縺吶ｋ縺九←縺?°縲?
057    
058            private final int[]             size ;                          // 繧ｫ繝ｩ繝?し繧､繧ｺ(ResultSetMetaData#getColumnDisplaySize(int))
059            private final boolean[] isWrit ;                        // 譖ｸ縺崎ｾｼ縺ｿ險ｱ蜿ｯ(ResultSetMetaData#isWritable(int))
060    
061            /**
062             * ResultSet 繧貞ｼ墓焚縺ｫ縺ｨ繧九さ繝ｳ繧ｹ繝医Λ繧ｯ繧ｿ
063             *
064             * 縺薙％縺ｧ縲√き繝ｩ繝?し繧､繧ｺ縲√き繝ｩ繝?錐縲）ava.sql.Types 縺ｮ螳壽焚螳夂ｾｩ 繧貞叙蠕励＠縺ｾ縺吶?
065             *
066             * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?
067             *
068             * @param       res 蜀?Κ縺ｧ邂｡逅?☆繧騎esultSet繧ｪ繝悶ず繧ｧ繧ｯ繝?
069             * @throws      java.sql.SQLException 繝??繧ｿ繝吶?繧ｹ繝ｻ繧｢繧ｯ繧ｻ繧ｹ繝ｻ繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷?
070             */
071            public ResultSetValue( final ResultSet res ) throws SQLException {
072                    resultSet = res;
073    
074                    final ResultSetMetaData metaData  = resultSet.getMetaData();
075                    clmSize = metaData.getColumnCount();
076                    names   = new String[clmSize];
077                    type    = new int[clmSize];
078                    size    = new int[clmSize];
079                    isWrit  = new boolean[clmSize];
080    
081                    boolean tempUseObj = false;                                             // 縺昴ｂ縺昴ｂ縲√が繝悶ず繧ｧ繧ｯ繝育ｳｻ縺ｮ繧ｫ繝ｩ繝?′縺ゅｋ縺九←縺?°
082                    for( int i=0; i<clmSize; i++ ) {
083                            final int tp = metaData.getColumnType( i+1 );
084                            type[i] = tp ;
085                            if( tp == Types.CLOB || tp == Types.ROWID || tp == Types.TIMESTAMP ) { tempUseObj = true; }
086                            names[i]  = metaData.getColumnLabel(i+1).toUpperCase(Locale.JAPAN) ;
087                            size[i]   = metaData.getColumnDisplaySize(i+1) ;
088                            isWrit[i] = metaData.isWritable(i+1) ;
089                    }
090                    useObj = tempUseObj ;
091            }
092    
093            /**
094             * ResultSetMetaData 縺ｧ豎ゅａ縺溘?繧ｫ繝ｩ繝?焚繧定ｿ斐＠縺ｾ縺吶?
095             *
096             * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?
097             *
098             * @return  繧ｫ繝ｩ繝?焚(繝??繧ｿ縺ｮ蛻玲焚)
099             */
100            public int getColumnCount() { return clmSize ; }
101    
102            /**
103             * 繧ｫ繝ｩ繝?錐驟榊?繧定ｿ斐＠縺ｾ縺吶?
104             *
105             * 驟榊?縺ｯ縲?縺九ｉ蟋九∪繧翫?繧ｫ繝ｩ繝?焚-1 縺ｾ縺ｧ縺ｮ譁?ｭ怜梛驟榊?縺ｫ險ｭ螳壹＆繧後∪縺吶?
106             * 繧ｫ繝ｩ繝?錐縺ｯ縲ヽesultSetMetaData#getColumnLabel(int) 繧?toUpperCase 縺励◆
107             * 螟ｧ譁?ｭ励′霑斐＆繧後∪縺吶?
108             *
109             * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?
110             *
111             * @return      繧ｫ繝ｩ繝?錐驟榊?
112             * @og.rtnNotNull
113             */
114            public String[] getNames() {
115                    return names.clone();
116            }
117    
118            /**
119             * 謖?ｮ壹?繧ｫ繝ｩ繝?分蜿ｷ縺ｮ繧ｫ繝ｩ繝?錐繧定ｿ斐＠縺ｾ縺吶?
120             *
121             * 繧ｫ繝ｩ繝?錐繧貞叙蠕励☆繧九?繧ｫ繝ｩ繝?分蜿ｷ縺ｯ縲?縺九ｉ蟋九∪繧翫?繧ｫ繝ｩ繝?焚-1 縺ｾ縺ｧ縺ｮ謨ｰ蟄励〒謖?ｮ壹＠縺ｾ縺吶?
122             * 繝??繧ｿ繝吶?繧ｹ荳翫?縲?縺九ｉ蟋九∪繧狗分蜿ｷ縺ｨ縺ｯ縲∫焚縺ｪ繧翫∪縺吶?
123             * 繧ｫ繝ｩ繝?錐縺ｯ縲ヽesultSetMetaData#getColumnLabel(int) 繧?toUpperCase 縺励◆
124             * 螟ｧ譁?ｭ励′霑斐＆繧後∪縺吶?
125             *
126             * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?
127             *
128             * @param   clmNo  繧ｫ繝ｩ繝?分蜿ｷ (0縺九ｉ蟋九∪繧翫?繧ｫ繝ｩ繝?焚-1縺ｾ縺ｧ縺ｮ謨ｰ蟄?
129             * @return  謖?ｮ壹?繧ｫ繝ｩ繝?分蜿ｷ縺ｮ繧ｫ繝ｩ繝?錐
130             */
131            public String getColumnName( final int clmNo ) {
132                    return names[clmNo];
133            }
134    
135    //      /**
136    //       * java.sql.Types 縺ｮ螳壽焚螳夂ｾｩ驟榊?繧定ｿ斐＠縺ｾ縺吶?
137    //       *
138    //       * 驟榊?縺ｯ縲?縺九ｉ蟋九∪繧翫?繧ｫ繝ｩ繝?焚-1 縺ｾ縺ｧ縺ｮint蝙矩?蛻励↓險ｭ螳壹＆繧後∪縺吶?
139    //       * Types 縺ｮ螳壽焚螳夂ｾｩ縺ｯ縲ヽesultSetMetaData#getColumnType(int) 縺ｮ蛟､縺ｧ縺吶?
140    //       *
141    //       * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?
142    //       *
143    //       * @return      繧ｫ繝ｩ繝?0?槭き繝ｩ繝?焚-1)縺ｫ蟇ｾ蠢懊＠縺溘?Types螳壽焚螳夂ｾｩ驟榊?
144    //       */
145    //      public int[] getSqlTypes() {
146    //              return type.clone();
147    //      }
148    
149            /**
150             * 謖?ｮ壹?繧ｫ繝ｩ繝?分蜿ｷ縺ｮjava.sql.Types 縺ｮ螳壽焚螳夂ｾｩ繧定ｿ斐＠縺ｾ縺吶?
151             *
152             * 驟榊?縺ｯ縲?縺九ｉ蟋九∪繧翫?繧ｫ繝ｩ繝?焚-1 縺ｾ縺ｧ縺ｮint蝙矩?蛻励↓險ｭ螳壹＆繧後∪縺吶?
153             * Types 縺ｮ螳壽焚螳夂ｾｩ縺ｯ縲ヽesultSetMetaData#getColumnType(int) 縺ｮ蛟､縺ｧ縺吶?
154             *
155             * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?
156             *
157             * @param   clmNo  繧ｫ繝ｩ繝?分蜿ｷ (0縺九ｉ蟋九∪繧翫?繧ｫ繝ｩ繝?焚-1縺ｾ縺ｧ縺ｮ謨ｰ蟄?
158             * @return      謖?ｮ壹?繧ｫ繝ｩ繝?分蜿ｷ縺ｮTypes螳壽焚
159             */
160            public int getSqlType( final int clmNo ) {
161                    return type[clmNo];
162            }
163    
164    //      /**
165    //       * 繧ｪ繝悶ず繧ｧ繧ｯ繝亥梛縺ｮ Type 縺悟ｭ伜惠縺吶ｋ縺九←縺?°[true:蟄伜惠縺吶ｋ/false:蟄伜惠縺励↑縺Ь繧定ｿ斐＠縺ｾ縺吶?
166    //       *
167    //       * 蝓ｺ譛ｬ逧?↓縺ｯ縲∝?繧呈ｱゅａ繧句?逅??蜀?Κ繝ｭ繧ｸ繝?け縺ｧ縺ｮ縺ｿ菴ｿ逕ｨ縺励∪縺吶?
168    //       * Types.CLOB 縲ゝypes.ROWID縲ゝypes.TIMESTAMP 縺後?Types螳夂ｾｩ縺ｫ蜷ｫ縺ｾ繧後※縺?ｋ蝣ｴ蜷医?
169    //       * true 繧定ｿ斐＠縺ｾ縺吶?
170    //       * 蜷ｫ縺ｾ繧後↑縺??蜷医?縲’alse 縺ｧ縺吶?
171    //       * 繧ｪ繝悶ず繧ｧ繧ｯ繝亥梛 縺悟ｭ伜惠縺吶ｋ蝣ｴ蜷医?蛟､繧呈ｱゅａ繧句?逅?↓縲∝ｰら畑縺ｮ繝｡繧ｽ繝?ラ縺悟ｿ?ｦ√↓縺ｪ繧翫∪縺吶?
172    //       * 蜷ｫ縺ｾ繧後↑縺??蜷医?縲ヾtring.valueOf( Object ) 縺ｧ豎ゅａ繧九％縺ｨ縺悟庄閭ｽ縺ｧ縺吶?
173    //       * 縺薙?蛟､繧貞盾閠?↓縲∝他縺ｳ蜃ｺ縺吶Γ繧ｽ繝?ラ繧貞､峨∴繧九％縺ｨ縺ｧ縲∝?逅??鬮倬?蛹悶ｒ蝗ｳ繧阪≧縺ｨ
174    //       * 閠?∴縺ｦ縺?∪縺吶?(蜉ｹ譫懊′縺ゅｋ縺九←縺?°縺ｯ縲∝愛繧翫∪縺帙ｓ縲?
175    //       *
176    //       * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?
177    //       *
178    //       * @return  繧ｪ繝悶ず繧ｧ繧ｯ繝亥梛縺ｮ Type 縺悟ｭ伜惠縺吶ｋ縺九←縺?°[true:蟄伜惠縺吶ｋ/false:蟄伜惠縺励↑縺Ь
179    //       */
180    //      public boolean useObjectType() {
181    //              return useObj;
182    //      }
183    
184            /**
185             * 繧ｫ繝ｩ繝??繧ｵ繧､繧ｺ縺ｮint驟榊?繧定ｿ斐＠縺ｾ縺吶?
186             *
187             * 驟榊?縺ｯ縲?縺九ｉ蟋九∪繧翫?繧ｫ繝ｩ繝?焚-1 縺ｾ縺ｧ縺ｮint蝙矩?蛻励↓險ｭ螳壹＆繧後∪縺吶?
188             * 繧ｫ繝ｩ繝??繧ｵ繧､繧ｺ縺ｯ縲ヽesultSetMetaData#getColumnDisplaySize(int) 縺ｮ蛟､縺ｧ縺吶?
189             *
190             * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?
191             *
192             * @return      繧ｫ繝ｩ繝??繧ｵ繧､繧ｺ縺ｮint驟榊?
193             * @og.rtnNotNull
194             */
195            public int[] getColumnDisplaySizes() {
196                    return size.clone();
197            }
198    
199            /**
200             * 謖?ｮ壹?繧ｫ繝ｩ繝?分蜿ｷ縺ｮ繧ｵ繧､繧ｺ繧定ｿ斐＠縺ｾ縺吶?
201             *
202             * 繧ｫ繝ｩ繝??繧ｵ繧､繧ｺ縺ｯ縲ヽesultSetMetaData#getColumnDisplaySize(int) 縺ｮ蛟､縺ｧ縺吶?
203             *
204             * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?
205             *
206             * @param   clmNo  繧ｫ繝ｩ繝?分蜿ｷ (0縺九ｉ蟋九∪繧翫?繧ｫ繝ｩ繝?焚-1縺ｾ縺ｧ縺ｮ謨ｰ蟄?
207             * @return      謖?ｮ壹?繧ｫ繝ｩ繝?分蜿ｷ縺ｮ繧ｵ繧､繧ｺ
208             */
209            public int getColumnDisplaySize( final int clmNo ) {
210                    return size[clmNo];
211            }
212    
213            /**
214             * 繧ｫ繝ｩ繝??譖ｸ縺崎ｾｼ縺ｿ蜿ｯ閭ｽ縺九←縺?°縺ｮboolean驟榊?繧定ｿ斐＠縺ｾ縺吶?
215             *
216             * 驟榊?縺ｯ縲?縺九ｉ蟋九∪繧翫?繧ｫ繝ｩ繝?焚-1 縺ｾ縺ｧ縺ｮint蝙矩?蛻励↓險ｭ螳壹＆繧後∪縺吶?
217             * 繧ｫ繝ｩ繝??譖ｸ縺崎ｾｼ縺ｿ蜿ｯ閭ｽ縺九←縺?°縺ｯ縲ヽesultSetMetaData#isWritable(int) 縺ｮ蛟､縺ｧ縺吶?
218             *
219             * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?
220             *
221             * @return      譖ｸ縺崎ｾｼ縺ｿ蜿ｯ閭ｽ縺九←縺?°縺ｮboolean驟榊?
222             * @og.rtnNotNull
223             */
224            public boolean[] isWritable() {
225                    return isWrit.clone();
226            }
227    
228            /**
229             * 謖?ｮ壹?譖ｸ縺崎ｾｼ縺ｿ蜿ｯ閭ｽ縺九←縺?°繧定ｿ斐＠縺ｾ縺吶?
230             *
231             * 繧ｫ繝ｩ繝??譖ｸ縺崎ｾｼ縺ｿ蜿ｯ閭ｽ縺九←縺?°縺ｯ縲ヽesultSetMetaData#isWritable(int) 縺ｮ蛟､縺ｧ縺吶?
232             *
233             * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?
234             *
235             * @param   clmNo  繧ｫ繝ｩ繝?分蜿ｷ (0縺九ｉ蟋九∪繧翫?繧ｫ繝ｩ繝?焚-1縺ｾ縺ｧ縺ｮ謨ｰ蟄?
236             * @return      譖ｸ縺崎ｾｼ縺ｿ蜿ｯ閭ｽ縺九←縺?°
237             */
238            public boolean isWritable( final int clmNo ) {
239                    return isWrit[clmNo];
240            }
241    
242            /**
243             * 繧ｫ繝ｼ繧ｽ繝ｫ繧堤樟蝨ｨ縺ｮ菴咲ｽｮ縺九ｉ鬆?婿蜷代↓1陦檎ｧｻ蜍輔＠縺ｾ縺吶?
244             *
245             * ResultSet#next() 繧貞他縺ｳ蜃ｺ縺励※縺?∪縺吶?
246             * 邨先棡縺ｯ,縺吶∋縺ｦ譁?ｭ怜?縺ｫ螟画鋤縺輔ｌ縺ｦ譬ｼ邏阪＆繧後∪縺吶?
247             *
248             * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?
249             *
250             * @return  譁ｰ縺励＞迴ｾ蝨ｨ縺ｮ陦後′譛牙柑縺ｧ縺ゅｋ蝣ｴ蜷医?true縲∬｡後′縺昴ｌ莉･荳雁ｭ伜惠縺励↑縺??蜷医?false
251             * @see         java.sql.ResultSet#next()
252             * @throws      java.sql.SQLException 繝??繧ｿ繝吶?繧ｹ繝ｻ繧｢繧ｯ繧ｻ繧ｹ繝ｻ繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷医?縺ｾ縺溘?縺薙?繝｡繧ｽ繝?ラ縺後け繝ｭ繝ｼ繧ｺ縺輔ｌ縺溽ｵ先棡繧ｻ繝?ヨ縺ｧ蜻ｼ縺ｳ蜃ｺ縺輔ｌ縺溷?蜷?
253             */
254            public boolean next() throws SQLException {
255                    return resultSet.next() ;
256            }
257    
258            /**
259             * 迴ｾ蝨ｨ縺ｮ繧ｫ繝ｼ繧ｽ繝ｫ菴咲ｽｮ縺ｫ縺ゅｋ繝ｬ繧ｳ繝ｼ繝峨?繧ｫ繝ｩ繝?分蜿ｷ縺ｮ繝??繧ｿ繧貞叙蠕励＠縺ｾ縺吶?
260             *
261             * ResultSet#getObject( clmNo+1 ) 繧貞他縺ｳ蜃ｺ縺励※縺?∪縺吶?
262             * 蠑墓焚縺ｮ繧ｫ繝ｩ繝?分蜿ｷ縺ｯ縲?縺九ｉ蟋九∪繧翫∪縺吶′縲ヽesultSet 縺ｮ繧ｫ繝ｩ繝??縺ｯ縲?縺九ｉ蟋九∪繧翫∪縺吶?
263             * 謖?ｮ壹?縲?縺九ｉ蟋九∪繧九き繝ｩ繝?分蜿ｷ縺ｧ縺吶?
264             * 邨先棡縺ｯ,縺吶∋縺ｦ譁?ｭ怜?縺ｫ螟画鋤縺輔ｌ縺ｦ霑斐＆繧後∪縺吶?
265             * 縺ｾ縺溘?null 繧ｪ繝悶ず繧ｧ繧ｯ繝医?蝣ｴ蜷医ｂ縲√ぞ繝ｭ譁?ｭ怜?縺ｫ螟画鋤縺輔ｌ縺ｦ霑斐＆繧後∪縺吶?
266             *
267             * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?: org.opengion.hayabusa.db.DBUtil#getValue( ResultSet , int , int ) 縺九ｉ遘ｻ蜍?
268             *
269             * @param   clmNo  繧ｫ繝ｩ繝?分蜿ｷ (0縺九ｉ蟋九∪繧翫?繧ｫ繝ｩ繝?焚-1縺ｾ縺ｧ縺ｮ謨ｰ蟄?
270             * @return  迴ｾ蝨ｨ陦後?繧ｫ繝ｩ繝?分蜿ｷ縺ｮ繝??繧ｿ(譁?ｭ怜?)
271             * @throws      java.sql.SQLException 繝??繧ｿ繝吶?繧ｹ繝ｻ繧｢繧ｯ繧ｻ繧ｹ繝ｻ繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷?
272             */
273            public String getValue( final int clmNo ) throws SQLException {
274                    final String val ;
275                    final Object obj = resultSet.getObject( clmNo+1 );
276                    if( obj == null ) {
277                            val = "";
278                    }
279                    else if( useObj ) {
280                            switch( type[clmNo] ) {
281                                    case Types.CLOB :               val = getClobData( (Clob)obj ) ;
282                                                                                    break;
283                                    case Types.ROWID:               val = resultSet.getString(clmNo+1);
284                                                                                    break;
285                                    case Types.TIMESTAMP :  val = HybsDateUtil.getDate( ((Timestamp)obj).getTime() , "yyyyMMddHHmmss" );
286                                                                                    break;
287                                    default :                               val = String.valueOf( obj );
288                                                                                    break;
289                            }
290                    }
291                    else {
292                            val = String.valueOf( obj );
293                    }
294    
295                    return val ;
296            }
297    
298            /**
299             * 迴ｾ蝨ｨ縺ｮ繧ｫ繝ｼ繧ｽ繝ｫ菴咲ｽｮ縺ｫ縺ゅｋ繝ｬ繧ｳ繝ｼ繝峨?蜈ｨ繧ｫ繝ｩ繝?ョ繝ｼ繧ｿ繧貞叙蠕励＠縺ｾ縺吶?
300             *
301             * #getValue( clmNo ) 繧偵?0縺九ｉ縲√き繝ｩ繝?焚-1 縺ｾ縺ｧ蜻ｼ縺ｳ蜃ｺ縺励※豎ゅａ縺滓枚蟄怜?驟榊?繧定ｿ斐＠縺ｾ縺吶?
302             *
303             * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?
304             *
305             * @return  迴ｾ蝨ｨ陦後?蜈ｨ繧ｫ繝ｩ繝?ョ繝ｼ繧ｿ縺ｮ譁?ｭ怜?驟榊?
306             * @throws      java.sql.SQLException 繝??繧ｿ繝吶?繧ｹ繝ｻ繧｢繧ｯ繧ｻ繧ｹ繝ｻ繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷?
307             */
308            public String[] getValues() throws SQLException {
309                    final String[] vals = new String[clmSize];
310    
311                    for( int i=0; i<clmSize; i++ ) {
312                            vals[i] = getValue( i );
313                    }
314    
315                    return vals ;
316            }
317    
318            /**
319             * 繧ｿ繧､繝励↓蠢懊§縺ｦ螟画鋤縺輔ｌ縺溘?Number繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ霑斐＠縺ｾ縺吶?
320             *
321             * 譚｡莉ｶ縺ｫ蠖薙※縺ｯ縺ｾ繧峨↑縺??蜷医?縲］ull 繧定ｿ斐＠縺ｾ縺吶?
322             * org.opengion.hayabusa.io.HybsJDBCCategoryDataset2 縺九ｉ遘ｻ蜍輔＠縺ｦ縺阪∪縺励◆縲?
323             * 縺薙ｌ縺ｯ縲∵､懃ｴ｢邨先棡繧偵げ繝ｩ繝募喧縺吶ｋ轤ｺ縺ｮ 蛟､繧貞叙蠕励☆繧狗ぜ縺ｮ繝｡繧ｽ繝?ラ縺ｧ縺吶?縺ｧ縲?
324             * 謨ｰ蛟､縺ｫ螟画鋤縺ｧ縺阪↑縺??蜷医?縲√お繝ｩ繝ｼ縺ｫ縺ｪ繧翫∪縺吶?
325             *
326             * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?: org.opengion.hayabusa.db.DBUtil#getNumber( int , Object ) 縺九ｉ遘ｻ蜍?
327             *
328             * @param   clmNo  繧ｫ繝ｩ繝?分蜿ｷ (0縺九ｉ蟋九∪繧翫?繧ｫ繝ｩ繝?焚-1縺ｾ縺ｧ縺ｮ謨ｰ蟄?
329             * @return      Number繧ｪ繝悶ず繧ｧ繧ｯ繝?譚｡莉ｶ縺ｫ蠖薙※縺ｯ縺ｾ繧峨↑縺??蜷医?縲］ull)
330             * @see         java.sql.Types
331             * @throws      java.sql.SQLException 繝??繧ｿ繝吶?繧ｹ繝ｻ繧｢繧ｯ繧ｻ繧ｹ繝ｻ繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷?
332             * @throws      RuntimeException 謨ｰ蟄怜､画鋤縺ｧ縺阪↑縺九▲縺溷?蜷医?
333             */
334            public Number getNumber( final int clmNo ) throws SQLException {
335                    final Object obj = resultSet.getObject( clmNo+1 );
336                    Number value = null;
337    
338                    switch( type[clmNo] ) {
339                            case Types.TINYINT:
340                            case Types.SMALLINT:
341                            case Types.INTEGER:
342                            case Types.BIGINT:
343                            case Types.FLOAT:
344                            case Types.DOUBLE:
345                            case Types.DECIMAL:
346                            case Types.NUMERIC:
347                            case Types.REAL: {
348                                    value = (Number)obj;
349                                    break;
350                            }
351                            case Types.DATE:
352                            case Types.TIME:  {
353                                    value = Long.valueOf( ((Date)obj).getTime() );
354                                    break;
355                            }
356                            // 5.6.2.1 (2013/03/08) Types.DATE 縺ｨ Types.TIMESTAMP 縺ｧ蜃ｦ逅?ｒ蛻?￠縺ｾ縺吶?
357                            case Types.TIMESTAMP: {
358                                    value = Long.valueOf( ((Timestamp)obj).getTime() );
359                                    break;
360                            }
361                            case Types.CHAR:
362                            case Types.VARCHAR:
363                            case Types.LONGVARCHAR: {
364                                    final String str = (String)obj;
365                                    try {
366                                            value = Double.valueOf(str);
367                                    }
368                                    catch (NumberFormatException ex) {
369                                            final String errMsg = "謨ｰ蟄怜､画鋤縺ｧ縺阪∪縺帙ｓ縺ｧ縺励◆縲Ｊn=" + str
370                                                                            + CR + ex.getMessage() ;
371                                            throw new RuntimeException( errMsg,ex );
372                                            // suppress (value defaults to null)
373                                    }
374                                    break;
375                            }
376                            default:
377                                    // not a value, can't use it (defaults to null)
378                                    break;
379                    }
380    
381                    return value;
382            }
383    
384            /**
385             * 繧ｫ繝ｩ繝??繧ｿ繧､繝励ｒ陦ｨ迴ｾ縺吶ｋ譁?ｭ怜?蛟､繧定ｿ斐＠縺ｾ縺吶?
386             *
387             * 縺薙?譁?ｭ怜?繧堤畑縺?※縲，CS繝輔ぃ繧､繝ｫ縺ｧ繧ｿ繧､繝励＃縺ｨ縺ｮ陦ｨ遉ｺ譁ｹ豕輔ｒ
388             * 謖?ｮ壹☆繧九％縺ｨ縺後〒縺阪∪縺吶?
389             * 迴ｾ譎らせ縺ｧ縺ｯ縲〃ARCHAR2,LONG,NUMBER,DATE,CLOB,NONE 縺ｮ縺ｩ繧後°縺ｫ縺ゅ※縺ｯ繧√∪縺吶?
390             *
391             * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?: org.opengion.hayabusa.db.DBUtil#type2ClassName( int ) 縺九ｉ遘ｻ蜍?
392             *
393             * @param   clmNo  繧ｫ繝ｩ繝?分蜿ｷ (0縺九ｉ蟋九∪繧翫?繧ｫ繝ｩ繝?焚-1縺ｾ縺ｧ縺ｮ謨ｰ蟄?
394             * @return      繧ｫ繝ｩ繝??繧ｿ繧､繝励ｒ陦ｨ迴ｾ縺吶ｋ譁?ｭ怜?蛟､
395             * @see         java.sql.Types
396             */
397            public String getClassName( final int clmNo ) {
398                    final String rtn ;
399    
400                    switch( type[clmNo] ) {
401                            case Types.CHAR:
402                            case Types.VARCHAR:
403                            case Types.BIT:
404                                    rtn = "VARCHAR2"; break;
405                            case Types.LONGVARCHAR:
406                                    rtn = "LONG"; break;
407                            case Types.TINYINT:
408                            case Types.SMALLINT:
409                            case Types.INTEGER:
410                            case Types.NUMERIC:
411                            case Types.BIGINT:
412                            case Types.FLOAT:
413                            case Types.DOUBLE:
414                            case Types.REAL:
415                            case Types.DECIMAL:
416                                    rtn = "NUMBER"; break;
417                            case Types.DATE:
418                            case Types.TIME:
419                            case Types.TIMESTAMP:
420                                    rtn = "DATE"; break;
421                            case Types.CLOB:
422                                    rtn = "CLOB"; break;
423                            default:
424                                    rtn = "NONE"; break;
425                    }
426    
427                    return rtn;
428            }
429    
430            /**
431             * Clob 繧ｪ繝悶ず繧ｧ繧ｯ繝医°繧画枚蟄怜?繧貞叙繧雁?縺励∪縺吶?
432             *
433             * @og.rev 6.0.4.0 (2014/11/28) 譁ｰ隕丈ｽ懈?: org.opengion.hayabusa.db.DBUtil#getClobData( Clob ) 縺九ｉ遘ｻ蜍?
434             *
435             * @param       clobData Clob繧ｪ繝悶ず繧ｧ繧ｯ繝?
436             * @return      Clob繧ｪ繝悶ず繧ｧ繧ｯ繝医°繧牙叙繧雁?縺励◆譁?ｭ怜?
437             * @throws      SQLException 繝??繧ｿ繝吶?繧ｹ繧｢繧ｯ繧ｻ繧ｹ繧ｨ繝ｩ繝ｼ
438             * @throws      RuntimeException 蜈･蜃ｺ蜉帙お繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷?
439             * @og.rtnNotNull
440             */
441            private String getClobData( final Clob clobData ) throws SQLException {
442                    if( clobData == null ) { return ""; }
443    
444                    final StringBuilder buf = new StringBuilder( 10000 );
445    
446                    Reader reader = null;
447                    try {
448                            reader = clobData.getCharacterStream();
449                            final char[] ch = new char[10000];
450                            int  len ;
451                            while( (len = reader.read( ch )) >= 0 ) {
452                                    buf.append( ch,0,len );
453                            }
454                    }
455                    catch( IOException ex ) {
456                            final String errMsg = "CLOB繝??繧ｿ縺ｮ隱ｭ縺ｿ霎ｼ縺ｿ縺ｫ螟ｱ謨励＠縺ｾ縺励◆縲?
457                                                                    + ex.getMessage() ;
458                            throw new RuntimeException( errMsg,ex );
459                    }
460                    finally {
461                            Closer.ioClose( reader );
462                    }
463                    return buf.toString();
464            }
465    }