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.hayabusa.common;
017    
018    import org.opengion.fukurou.xml.HybsXMLSave;
019    import org.opengion.fukurou.util.Closer ;
020    
021    import java.sql.Connection;
022    import java.sql.SQLException;
023    
024    import java.io.Reader;
025    import java.io.BufferedReader;
026    import java.io.InputStreamReader;
027    import java.io.FileInputStream;
028    import java.io.InputStream;
029    import java.io.IOException;
030    import java.io.File;
031    import java.io.UnsupportedEncodingException;
032    
033    import java.util.List;
034    import java.util.ArrayList;
035    import java.util.Enumeration;
036    import java.util.jar.JarFile;
037    import java.util.jar.JarEntry;
038    import java.net.URL;
039    
040    /**
041     * ORACLE XDK 蠖｢蠑上?XML繝輔ぃ繧､繝ｫ繧定ｪｭ縺ｿ蜿悶▲縺ｦ縲√ョ繝ｼ繧ｿ繝吶?繧ｹ縺ｫ逋ｻ骭ｲ縺励∪縺吶?
042     * 襍ｷ蜍?螳溯｡?縺ｯ縲√さ繝ｳ繝?く繧ｹ繝郁ｪｭ縺ｿ蜿悶ｊ譎ゅ?蛻晏屓縺ｮ縺ｿ縺ｧ縺吶?GE12繝代Λ繝｡繝ｼ繧ｿ繧貞､画峩縺励◆
043     * 蝣ｴ蜷医?縲√さ繝ｳ繝?く繧ｹ繝医?繝ｪ繝ｭ繝ｼ繝峨′蠢?ｦ√〒縺吶?
044     * 逋ｻ骭ｲ縺ｮ螳溯｡梧怏辟｡縺ｮ蛻､譁ｭ縺ｯ縲√ヵ繧｡繧､繝ｫ縺ｮ譖ｴ譁ｰ譎ょ綾繧医ｊ蛻､譁ｭ縺励∪縺吶?(useTimeStamp=true 縺ｮ蝣ｴ蜷?
045     * 縺薙ｌ縺ｯ縲∬ｪｭ縺ｿ蜿悶ｊ繝輔ぃ繧､繝ｫ縺ｮ譖ｴ譁ｰ譎ょ綾縺後??舌〒縺ｪ縺??蜷医?隱ｭ縺ｿ蜿悶ｊ繧定｡後＞縺ｾ縺吶?
046     * 隱ｭ縺ｿ蜿悶ｊ縺悟ｮ御ｺ?＠縺溷?蜷医?縲∵峩譁ｰ譎ょ綾繧???縺ｫ險ｭ螳壹＠縺ｾ縺吶?
047     * 隱ｭ縺ｿ蜿悶ｋ繝輔ぃ繧､繝ｫ縺ｯ縲√け繝ｩ繧ｹ繝ｭ繝ｼ繝??縺ｮ繝ｪ繧ｽ繝ｼ繧ｹ縺ｨ縺励※蜿門ｾ励＆繧後∪縺吶?縺ｧ縲√け繝ｩ繧ｹ繝代せ縺?
048     * 險ｭ螳壹＆繧後※縺?ｋ蠢?ｦ√′縺ゅｊ縺ｾ縺吶?縺ｾ縺溘?繝輔ぃ繧､繝ｫ縺ｯ縲∵僑蠑ｵ蟄舌′ xml 縺ｧ縲ゞTF-8縺ｧ繧ｨ繝ｳ繧ｳ繝ｼ繝?
049     * 縺輔ｌ縺ｦ縺?ｋ蠢?ｦ√′縺ゅｊ縺ｾ縺吶?騾壼ｸｸ縺ｯ縲√ヵ繧｡繧､繝ｫ蜷阪′繝??繝悶Ν蜷阪→蜷御ｸ?↓縺励※縺翫￥蠢?ｦ√′
050     * 縺ゅｊ縺ｾ縺吶′縲ヽOWSET縺ｮtable螻樊?縺ｫ繝??繝悶Ν蜷阪ｒ繧ｻ繝?ヨ縺励※縺翫￥縺薙→繧ょ庄閭ｽ縺ｧ縺吶?
051     * 繝輔ぃ繧､繝ｫ縺ｮ逋ｻ骭ｲ鬆??縲∝次蜑??繧ｯ繝ｩ繧ｹ繝ｭ繝ｼ繝??縺ｮ讀懃ｴ｢鬆?↓縲∬ｦ九▽縺九▲縺溷?縺ｦ縺ｮ繝輔ぃ繧､繝ｫ繧?
052     * 逋ｻ骭ｲ縺励∪縺吶?繝??繧ｿ縺昴?繧ゅ?縺ｯ縲！NSERT 縺ｮ縺ｿ蟇ｾ蠢懊＠縺ｦ縺?∪縺吶?縺ｧ縲∝次蜑?匳骭ｲ鬆??辟｡隕悶＆繧後∪縺吶?
053     * 縺溘□縺励?諡｡蠑ｵXDK 蠖｢蠑上〒縲・XEC_SQL 繧ｿ繧ｰ繧剃ｽｿ逕ｨ縺励◆蝣ｴ蜷医?縲∫匳骭ｲ鬆?′蠖ｱ髻ｿ縺吶ｋ蜿ｯ閭ｽ諤ｧ縺後≠繧翫∪縺吶?
054     * 萓具ｼ哦E12.xml GE12 繝??繝悶Ν縺ｫ逋ｻ骭ｲ縺吶ｋXML繝輔ぃ繧､繝ｫ
055     * 逋ｻ骭ｲ譎ゅ↓縲∵里蟄倥?繝??繧ｿ縺ｮ遐ｴ譽?′蠢?ｦ√↑蝣ｴ蜷医?縲∵僑蠑ｵXDK 蠖｢蠑上?XML繝輔ぃ繧､繝ｫ繧?
056     * 菴懈?縺励※縺上□縺輔＞縲ゅ％繧後?縲・XEC_SQL 繧ｿ繧ｰ縺ｫ譖ｸ縺崎ｾｼ繧薙□SQL譁?ｒ螳溯｡後＠縺ｾ縺吶?
057     * 隧ｳ邏ｰ縺ｯ縲＋@link org.opengion.fukurou.xml.HybsXMLHandler HybsXMLHandler} 繧ｯ繝ｩ繧ｹ繧貞盾辣ｧ縺励※縺上□縺輔＞縲?
058     *
059     *   &lt;ROWSET tableName="XX" &gt;
060     *       &lt;EXEC_SQL&gt;                    譛??縺ｫ險倩ｼ峨＠縺ｦ縲∝?譛溷?逅?繝??繧ｿ繧ｯ繝ｪ繧｢遲?繧貞ｮ溯｡後＆縺帙ｋ縲?
061     *           delete from GEXX where YYYYY
062     *       &lt;/EXEC_SQL&gt;
063     *       &lt;ROW num="1"&gt;
064     *           &lt;繧ｫ繝ｩ繝?&gt;蛟､1&lt;/繧ｫ繝ｩ繝?&gt;
065     *             ?･?･?･
066     *           &lt;繧ｫ繝ｩ繝?&gt;蛟､n&lt;/繧ｫ繝ｩ繝?&gt;
067     *       &lt;/ROW&gt;
068     *        ?･?･?･
069     *       &lt;ROW num="n"&gt;
070     *          ?･?･?･
071     *       &lt;/ROW&gt;
072     *       &lt;EXEC_SQL&gt;                    譛?ｾ後↓險倩ｼ峨＠縺ｦ縲??逶ｮ縺ｮ險ｭ螳?謨ｴ蜷域?逋ｻ骭ｲ)繧定｡後≧縲?
073     *           update GEXX set AA='XX' , BB='XX' where YYYYY
074     *       &lt;/EXEC_SQL&gt;
075     *   &lt;ROWSET&gt;
076     *
077     * @og.rev 4.0.0.0 (2004/12/31) 譁ｰ隕丈ｽ懈?
078     * @og.group 蛻晄悄蛹?
079     *
080     * @version  4.0
081     * @author   Kazuhiko Hasegawa
082     * @since    JDK5.0,
083     */
084    public final class InitFileLoader {
085            private final String CLASSPATH ;
086            private final Connection connection ;
087            private boolean fileCommit = false;             // 繝輔ぃ繧､繝ｫ豈弱↓繧ｳ繝溘ャ繝亥?逅?ｒ陦後≧縺九←縺?°(true:陦後≧/false:陦後ｏ縺ｪ縺?
088    
089            /**
090             * 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧貞ｼ墓焚縺ｫ縺吶ｋ縲√さ繝ｳ繧ｹ繝医Λ繧ｯ繧ｿ繝ｼ縺ｧ縺吶?
091             * classPath="resource" 縺ｧ蛻晄悄蛹悶＆繧後◆ InitFileLoader 繧剃ｽ懈?縺励∪縺吶?
092             *
093             * @param       conn    逋ｻ骭ｲ逕ｨ繧ｳ繝阪け繧ｷ繝ｧ繝ｳ
094             */
095            public InitFileLoader( final Connection conn ) {
096                    this( conn,"resource" );
097            }
098    
099            /**
100             * 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ縺ｨ讀懃ｴ｢繝代せ繧呈欠螳壹＠縺ｦ讒狗ｯ峨☆繧九?繧ｳ繝ｳ繧ｹ繝医Λ繧ｯ繧ｿ繝ｼ縺ｧ縺吶?
101             * 蟇ｾ雎｡繝輔ぃ繧､繝ｫ縺ｯ縲…lassPath 縺ｧ謖?ｮ壹＆繧後◆蝣ｴ謇?ｒ縲√け繝ｩ繧ｹ繝ｭ繝ｼ繝??縺ｧ讀懃ｴ｢縺励∪縺吶?
102             * 縺薙％縺ｧ隕九▽縺九▲縺溘ヱ繧ｹ莉･荳九? XML繝輔ぃ繧､繝ｫ(諡｡蠑ｵ蟄舌?蟆乗枚蟄励〒縲?xml )繧呈､懃ｴ｢
103             * 縺励∪縺吶?縺薙?繝輔ぃ繧､繝ｫ蜷阪? 繝??繝悶Ν蜷?xml 蠖｢蠑上〒譬ｼ邏阪＠縺ｦ縺翫″縺ｾ縺吶?
104             *
105             * @param       conn    逋ｻ骭ｲ逕ｨ繧ｳ繝阪け繧ｷ繝ｧ繝ｳ
106             * @param classPath 蟇ｾ雎｡縺ｨ縺ｪ繧九ヵ繧｡繧､繝ｫ鄒､繧呈､懃ｴ｢縺吶ｋ縲√け繝ｩ繧ｹ繝代せ
107             */
108            public InitFileLoader( final Connection conn,final String classPath ) {
109                    connection      = conn ;
110                    CLASSPATH       = classPath;
111            }
112    
113            /**
114             * 繝輔ぃ繧､繝ｫ豈弱↓繧ｳ繝溘ャ繝亥?逅?ｒ陦後≧縺九←縺?°謖?ｮ壹＠縺ｾ縺?蛻晄悄蛟､:false[陦後ｏ縺ｪ縺Ь)縲?
115             * 蟇ｾ雎｡繝輔ぃ繧､繝ｫ豈弱↓縲√ョ繝ｼ繧ｿ繝吶?繧ｹ縺ｸ縺ｮ逋ｻ骭ｲ繧貞ｮ御ｺ?commit)縺吶ｋ縺九←縺?°繧呈欠螳壹＠縺ｾ縺吶?
116             * 騾壼ｸｸ縲，onnection 縺ｯ縲∥utoCommit 繧?false 縺ｫ險ｭ螳壹＠縲?ｼ台ｻｶ縺斐→縺ｮ蜃ｦ逅??陦後＞縺ｾ縺帙ｓ縲?
117             * 縺輔ｉ縺ｫ縲々ML繝輔ぃ繧､繝ｫ縺ｫ繧ら嶌莠帝未騾｣縺後≠繧句?蜷医′縺ゅｋ縺溘ａ縲∬､?焚繝輔ぃ繧､繝ｫ繧貞叙繧願ｾｼ繧??蜷医?縲?
118             * 縺昴ｌ繧峨ｒ荳?ｾ､縺ｨ縺励※蜃ｦ逅?＠縺溘＞繧ｱ繝ｼ繧ｹ繧ゅ≠繧翫∪縺吶?縺ｾ縺溘?蜷?ヵ繧｡繧､繝ｫ縺檎峡遶九＠縺ｦ縺?ｋ
119             * 蝣ｴ蜷医?縲∽ｻ悶?繝輔ぃ繧､繝ｫ蜿悶ｊ霎ｼ縺ｿ譎ゅ↓繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺ｦ繧ゅ?縺昴ｌ縺ｾ縺ｧ縺ｮ蛻??縲∝叙繧願ｾｼ縺ｿ縺溘＞
120             * 繧ｱ繝ｼ繧ｹ縺後≠繧翫∪縺吶?
121             * 縺薙％縺ｧ縺ｯ縲√ヵ繧｡繧､繝ｫ豈弱↓繧ｳ繝溘ャ繝医ｒ逋ｺ陦後☆繧九°縺ｩ縺?°繧呈欠螳壹〒縺阪∪縺吶?
122             * 蛻晄悄蛟､縺ｯ縲’alse[陦後ｏ縺ｪ縺Ь縺ｧ縺吶?
123             * 窶ｻ true 縺ｫ險ｭ螳壹＠縺溷?蜷医〒繧ゅ?騾比ｸｭ縺ｧ繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷医?縲√◎繧御ｻ･髯阪?蜃ｦ逅??縲?
124             * 邯咏ｶ壹＠縺ｾ縺帙ｓ縲ゅ◎繧御ｻ･蜑阪?蜃ｦ逅?′縲∫匳骭ｲ縺輔ｌ縺ｦ縺?ｋ縺?￠縺ｧ縺吶?
125             *
126             * @param fileCmt 繝輔ぃ繧､繝ｫ豈弱↓繧ｳ繝溘ャ繝亥?逅?ｒ陦後≧縺九←縺?° [true:陦後≧/false:陦後ｏ縺ｪ縺Ь
127             */
128            public void setFileCommit( final boolean fileCmt ) {
129                    fileCommit = fileCmt ;
130            }
131    
132            /**
133             * 蟇ｾ雎｡縺ｨ縺ｪ繧九ヵ繧｡繧､繝ｫ鄒､繧呈､懃ｴ｢縺励∪縺吶?
134             * 蟇ｾ雎｡繝輔ぃ繧､繝ｫ縺ｯ縲〉esource 繝輔か繝ｫ繝?↓ 繝??繝悶Ν蜷?xml 蠖｢蠑上〒譬ｼ邏阪＠縺ｦ縺翫″縺ｾ縺吶?
135             * 縺薙?繝輔か繝ｫ繝??繝輔ぃ繧､繝ｫ繧偵ヴ繝?け繧｢繝??縺励∪縺吶?
136             * useTimeStamp 螻樊?繧?true 縺ｫ險ｭ螳壹☆繧九→縲√％縺ｮ繝輔ぃ繧､繝ｫ縺ｮ繧ｿ繧､繝?せ繧ｿ繝ｳ繝励ｒ縲?
137             * 繧ｷ繧ｹ繝?Β繝代Λ繝｡繝ｼ繧ｿ螳夂ｾｩ(GE12) 縺ｫ繧ｻ繝?ヨ縺励∪縺吶?縺昴ｌ莉･髯阪?縺薙?繧ｿ繧､繝?せ繧ｿ繝ｳ繝励→
138             * 繝輔ぃ繧､繝ｫ繧呈ｯ碑ｼ?＠縺ｦ縲∝､画峩縺後↑縺代ｌ縺ｰ縲∫匳骭ｲ蜃ｦ逅?ｒ陦後＞縺ｾ縺帙ｓ縲?
139             *
140             * @og.rev 4.0.0.0 (2007/11/28) 繝｡繧ｽ繝?ラ縺ｮ謌ｻ繧雁?繧偵メ繧ｧ繝?け縺励∪縺吶?
141             * @og.rev 5.3.6.0 (2011/06/01) 螳溘ヵ繧ｩ繝ｫ繝??蝣ｴ蜷医?繝輔か繝ｫ繝?嚴螻､繧剃ｸ九ｋ蜃ｦ逅?ｒ霑ｽ蜉?
142             * @og.rev 5.5.2.6 (2012/05/25) JarFile 繧偵?Closer#zipClose( ZipFile ) 繝｡繧ｽ繝?ラ繧貞茜逕ｨ縺励※縲…lose 縺励∪縺吶?
143             * @og.rev 5.6.6.1 (2013/07/12) jar繝輔ぃ繧､繝ｫ縺ｮ蝣ｴ蜷医ｂ縲√ち繧､繝?せ繧ｿ繝ｳ繝礼ｮ｡逅??蟇ｾ雎｡縺ｨ縺励∪縺吶?
144             *
145             * @param useTimeStamp 繧ｿ繧､繝?せ繧ｿ繝ｳ繝励?邂｡逅?ｒ陦後≧縺九←縺?°[true:陦後≧/false:陦後ｏ縺ｪ縺Ь
146             */
147            public void loadInitFiles( final boolean useTimeStamp ) {
148                    List<File> fileList = new ArrayList<File>();
149    
150                    // 5.5.2.6 (2012/05/25) findbugs蟇ｾ蠢?
151                    JarFile jarFile = null;
152                    try {
153            //              System.out.println( "    ==========================" );
154    
155                            ClassLoader loader = Thread.currentThread().getContextClassLoader();
156                            Enumeration<URL> enume = loader.getResources( CLASSPATH );                // 4.3.3.6 (2008/11/15) Generics隴ｦ蜻雁ｯｾ蠢?
157                            while( enume.hasMoreElements() ) {
158                                    URL url = enume.nextElement();                                                          // 4.3.3.6 (2008/11/15) Generics隴ｦ蜻雁ｯｾ蠢?
159                                    // jar:file:/螳溘ョ繧｣繝ｬ繧ｯ繝医Μ 縺ｾ縺溘?縲’ile:/螳溘ョ繧｣繝ｬ繧ｯ繝医Μ
160                                    System.out.println( "      InitFileLoader Scan:[ " + url + " ]" );      // 5.6.6.1 (2013/07/12) 繝｡繝?そ繝ｼ繧ｸ蜃ｺ蜉?
161                                    String dir = url.getFile();
162                                    if( "jar".equals( url.getProtocol() ) ) {
163                                            // dir = file:/C:/webapps/gf/WEB-INF/lib/resource2.jar!/resource 蠖｢蠑上〒縺吶?
164                                            String jar = dir.substring(dir.indexOf( ':' )+1,dir.lastIndexOf( '!' ));
165                                            // jar = /C:/webapps/gf/WEB-INF/lib/resource2.jar 蠖｢蠑上↓蛻?ｊ蜃ｺ縺励∪縺吶?
166    
167                                            // 5.6.6.1 (2013/07/12) jar繝輔ぃ繧､繝ｫ繧ゅ?繧ｿ繧､繝?せ繧ｿ繝ｳ繝礼ｮ｡逅??蟇ｾ雎｡
168                                            File jarObj = new File( jar );
169                                            if( useTimeStamp && jarObj.lastModified() <= 0 ) {           // fileObj 縺ｯ縲）ar繝輔ぃ繧､繝ｫ縺ｮ縺薙→
170                                                    continue;
171                                            }
172    
173    //                                      JarFile jarFile = new JarFile( jar );
174                                            jarFile = new JarFile( jar );
175                                            Enumeration<JarEntry> flEnum = jarFile.entries() ;                // 4.3.3.6 (2008/11/15) Generics隴ｦ蜻雁ｯｾ蠢?
176                                            while( flEnum.hasMoreElements() ) {
177                                                    JarEntry ent = flEnum.nextElement();                            // 4.3.3.6 (2008/11/15) Generics隴ｦ蜻雁ｯｾ蠢?
178                                                    String file = ent.getName();
179                                                    if( ! ent.isDirectory() && file.endsWith( ".xml" ) ) {
180                                                            // // 5.6.6.1 (2013/07/12) jar繝輔ぃ繧､繝ｫ縺ｮ荳ｭ霄ｫ縺ｮ繧ｿ繧､繝?せ繧ｿ繝ｳ繝励?隕九↑縺??
181    //                                                      if( ! useTimeStamp || ent.getTime() > 0 ) {
182                                                                    String table = file.substring( file.lastIndexOf('/')+1,file.lastIndexOf('.') );
183                                                                    InputStream stream = null;
184                                                                    try {
185    //                                                                      System.out.println( "      " + url + file );
186                                                                            System.out.println( "        " + file );        // 5.6.6.1 (2013/07/12) 繝｡繝?そ繝ｼ繧ｸ螟画峩
187                                                                            stream = jarFile.getInputStream( ent ) ;
188                                                                            loadXML( stream,connection,table );
189                                                                    }
190    //                                                              catch( IOException ex ) {
191    //                                                                      String errMsg = "jar 縺ｮ XML繝輔ぃ繧､繝ｫ隱ｭ縺ｿ蜿悶ｊ譎ゅ↓繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺ｾ縺励◆縲?
192    //                                                                                      + HybsSystem.CR + ex.getMessage();
193    //                                                                      throw new RuntimeException( errMsg,ex );
194    //                                                              }
195                                                                    finally {
196                                                                            Closer.ioClose( stream );
197                                                                    }
198                                                                    if( fileCommit ) {
199                                                                            connection.commit();
200                                                                    }
201    //                                                      }
202                                                    }
203                                            }
204                                            fileList.add( jarObj );                 // 5.6.6.1 (2013/07/12) jar繝輔ぃ繧､繝ｫ繧ゅ?繧ｿ繧､繝?せ繧ｿ繝ｳ繝礼ｮ｡逅??蟇ｾ雎｡
205                                            Closer.zipClose( jarFile );             // 5.5.2.6 (2012/05/25) findbugs蟇ｾ蠢?
206                                            jarFile = null;                                 // 豁｣蟶ｸ邨ゆｺ?凾縺ｫ縲…lose() 縺鯉ｼ貞屓蜻ｼ縺ｰ繧後ｋ縺ｮ繧帝亟縺舌◆繧√?
207                                    }
208                                    else {
209    //                                      // dir = /C:/webapps/gf/WEB-INF/classes/resource/ 蠖｢蠑上〒縺吶?
210    //                                      File fileObj = new File( dir );
211    //                                      File[] list = fileObj.listFiles();
212    //                                      for( int i=0; i<list.length; i++ ) {
213    //                                              String file = list[i].getName() ;
214    //                                              if( list[i].isFile() && file.endsWith( ".xml" ) ) {
215    //                                                      if( ! useTimeStamp || list[i].lastModified() > 0 ) {
216    //                                                              String table = file.substring( file.lastIndexOf('/')+1,file.lastIndexOf('.') );
217    //                                                              InputStream stream = null;
218    //                                                              try {
219    //                                                                      stream = new FileInputStream( list[i] ) ;
220    //                                                                      System.out.println( "      " + url + file );
221    //                                                                      loadXML( stream,connection,table );
222    //                                                              }
223    //                                                              catch( IOException ex ) {
224    //                                                                      String errMsg = "dir 縺ｮ XML繝輔ぃ繧､繝ｫ隱ｭ縺ｿ蜿悶ｊ譎ゅ↓繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺ｾ縺励◆縲?
225    //                                                                                      + HybsSystem.CR + ex.getMessage();
226    //                                                                      throw new RuntimeException( errMsg,ex );
227    //                                                              }
228    //                                                              finally {
229    //                                                                      Closer.ioClose( stream );
230    //                                                              }
231    //                                                              if( fileCommit ) {
232    //                                                                      connection.commit();
233    //                                                                      if( !list[i].setLastModified( 0L ) ) {
234    //                                                                              String errMsg = "繧ｿ繧､繝?せ繧ｿ繝ｳ繝励?譖ｸ縺肴鋤縺医↓螟ｱ謨励＠縺ｾ縺励◆縲?
235    //                                                                                              + "file=" + file ;      // 5.1.8.0 (2010/07/01) errMsg 菫ｮ豁｣
236    //                                                                              System.out.println( errMsg );
237    //                                                                      }
238    //                                                              }
239    //                                                              else {
240    //                                                                      fileList.add( list[i] );
241    //                                                              }
242    //                                                      }
243    //                                              }
244    //                                      }
245                                            // 5.3.6.0 (2011/06/01) 螳溘ヵ繧ｩ繝ｫ繝??蝣ｴ蜷医?繝輔か繝ｫ繝?嚴螻､繧剃ｸ九ｋ蜃ｦ逅?ｒ霑ｽ蜉?
246                                            // dir = /C:/webapps/gf/WEB-INF/classes/resource/ 蠖｢蠑上〒縺吶?
247                                            File fileObj = new File( dir );
248                                            loadXMLDir( fileObj,useTimeStamp,fileList );
249                                    }
250                            }
251                            connection.commit();
252            //              System.out.println( "    ==========================" );
253                    }
254                    catch( SQLException ex ) {
255                            String errMsg = "SQL螳溯｡梧凾縺ｫ繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺ｾ縺励◆縲?
256                                            + HybsSystem.CR + ex.getMessage();
257                            Closer.rollback( connection );
258    //                      if( connection != null ) {
259    //                              Closer.rollback( connection );
260    //                              try { connection.rollback(); }
261    //                              catch( SQLException ex2 ) { errMsg += ex2.getMessage(); }
262    //                      }
263                            throw new RuntimeException( errMsg,ex );
264                    }
265                    catch( IOException ex ) {
266                            String errMsg = "XML繝輔ぃ繧､繝ｫ隱ｭ縺ｿ蜿悶ｊ譎ゅ↓繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺ｾ縺励◆縲?
267                                            + HybsSystem.CR + ex.getMessage();
268                            throw new RuntimeException( errMsg,ex );
269                    }
270                    finally {
271                            Closer.zipClose( jarFile );             // 5.5.2.6 (2012/05/25) findbugs蟇ｾ蠢?
272    
273                    // 5.3.6.0 (2011/06/01) finally 蜃ｦ逅?〒縲√ち繧､繝?せ繧ｿ繝ｳ繝励?譖ｸ縺肴鋤縺医ｒ陦後≧縲?
274    
275                    // commit 縺梧?蜉溘＠縺溷?蜷医?縺ｿ縲√ヵ繧｡繧､繝ｫ縺ｮ繧ｿ繧､繝?せ繧ｿ繝ｳ繝励?譖ｸ縺肴鋤縺医ｒ陦後≧縲?
276    //              if( ! fileCommit ) {
277    //                      File[] files = fileList.toArray( new File[fileList.size()] );
278    //                      for( int i=0; i<files.length; i++ ) {
279                            // 5.6.6.1 (2013/07/12) useTimeStamp=true 縺ｮ蝣ｴ蜷医?縺ｿ縲∵嶌縺肴鋤縺医∪縺吶?
280                            if( useTimeStamp ) {
281                                    for( File file : fileList ) {
282                                            if( !file.setLastModified( 0L ) ) {
283                                                    String errMsg = "繧ｿ繧､繝?せ繧ｿ繝ｳ繝励?譖ｸ縺肴鋤縺医↓螟ｱ謨励＠縺ｾ縺励◆縲?
284                                                                            + "file=" + file ;      // 5.1.8.0 (2010/07/01) errMsg 菫ｮ豁｣
285                                                    System.out.println( errMsg );
286                                            }
287                                    }
288                            }
289                    }
290            }
291    
292            /**
293             * XML繝輔か繝ｫ繝?繝輔ぃ繧､繝ｫ繧定ｪｭ縺ｿ蜿悶ｊ縲√ョ繝ｼ繧ｿ繝吶?繧ｹ縺ｫ霑ｽ蜉?INSERT)縺吶ｋ繝｡繧ｽ繝?ラ繧偵さ繝ｼ繝ｫ縺励∪縺吶?
294             *
295             * 縺薙％縺ｧ縺ｯ縲√ヵ繧ｩ繝ｫ繝?嚴螻､繧剃ｸ九ｋ縺溘ａ縺ｮ蜀崎ｵｷ蜃ｦ逅?ｒ陦後▲縺ｦ縺?∪縺吶?
296             * XML繝輔ぃ繧､繝ｫ縺ｯ縲＾RACLE XDK諡｡蠑ｵ繝輔ぃ繧､繝ｫ縺ｧ縺吶?繝??繝悶Ν蜷阪ｒ謖?ｮ壹☆繧九％縺ｨ縺ｧ縲?
297             * XML繝輔ぃ繧､繝ｫ繧偵ョ繝ｼ繧ｿ繝吶?繧ｹ縺ｫ逋ｻ骭ｲ縺吶ｋ縺薙→縺悟庄閭ｽ縺ｧ縺吶?
298             * ORACLE XDK諡｡蠑ｵ繝輔ぃ繧､繝ｫ繧??EXEC_SQL繧ｿ繧ｰ縺ｪ縺ｩ縺ｮ隧ｳ邏ｰ縺ｯ縲＋@link org.opengion.fukurou.xml.HybsXMLSave}
299             * 繧貞盾辣ｧ鬘倥＞縺ｾ縺吶?
300             *
301             * @og.rev 5.3.6.0 (2011/06/01) 螳溘ヵ繧ｩ繝ｫ繝??蝣ｴ蜷医?繝輔か繝ｫ繝?嚴螻､繧剃ｸ九ｋ蜃ｦ逅?ｒ霑ｽ蜉?
302             *
303             * @param       fileObj                 隱ｭ蜿門?縺ｮ繝輔ぃ繧､繝ｫ繧ｪ繝悶ず繧ｧ繧ｯ繝?
304             * @param       useTimeStamp    繧ｿ繧､繝?せ繧ｿ繝ｳ繝励?邂｡逅?ｒ陦後≧縺九←縺?°[true:陦後≧/false:陦後ｏ縺ｪ縺Ь
305             * @param       fileList                蜃ｦ逅?＠縺溘ヵ繧｡繧､繝ｫ繧剃ｿ晉ｮ｡縺励※縺翫￥List繧ｪ繝悶ず繧ｧ繧ｯ繝?
306             * @throws SQLException,IOException  繝??繧ｿ繝吶?繧ｹ繧｢繧ｯ繧ｻ繧ｹ繧ｨ繝ｩ繝ｼ縲√∪縺溘?縲√ョ繝ｼ繧ｿ蜈･蜃ｺ蜉帙お繝ｩ繝ｼ
307             */
308            private void loadXMLDir( final File fileObj , final boolean useTimeStamp , final List<File> fileList )
309                                                                                                                                                                    throws SQLException,IOException {
310                    // dir = /C:/webapps/gf/WEB-INF/classes/resource/ 蠖｢蠑上〒縺吶?
311                    File[] list = fileObj.listFiles();
312            //      Arrays.sort( list );
313                    for( int i=0; i<list.length; i++ ) {
314                            String file = list[i].getName() ;
315                            if( list[i].isFile() && file.endsWith( ".xml" ) ) {
316                                    if( ! useTimeStamp || list[i].lastModified() > 0 ) {
317                                            String table = file.substring( file.lastIndexOf('/')+1,file.lastIndexOf('.') );
318                                            InputStream stream = null;
319                                            try {
320                                                    System.out.println( "        " + list[i] );
321                                                    stream = new FileInputStream( list[i] ) ;
322                                                    loadXML( stream,connection,table );
323                                            }
324    //                                      catch( IOException ex ) {
325    //                                              String errMsg = "dir 縺ｮ XML繝輔ぃ繧､繝ｫ隱ｭ縺ｿ蜿悶ｊ譎ゅ↓繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺ｾ縺励◆縲?
326    //                                                              + HybsSystem.CR + ex.getMessage();
327    //                                              throw new RuntimeException( errMsg,ex );
328    //                                      }
329                                            finally {
330                                                    Closer.ioClose( stream );
331                                            }
332                                            if( fileCommit ) {
333                                                    connection.commit();
334                                            }
335                                            fileList.add( list[i] );
336                                    }
337                            }
338                            else {
339                                    loadXMLDir( list[i],useTimeStamp,fileList );
340                            }
341                    }
342            }
343    
344            /**
345             * XML繝輔ぃ繧､繝ｫ繧定ｪｭ縺ｿ蜿悶ｊ縲√ョ繝ｼ繧ｿ繝吶?繧ｹ縺ｫ霑ｽ蜉?INSERT)縺励∪縺吶?
346             *
347             * XML繝輔ぃ繧､繝ｫ縺ｯ縲＾RACLE XDK諡｡蠑ｵ繝輔ぃ繧､繝ｫ縺ｧ縺吶?繝??繝悶Ν蜷阪ｒ謖?ｮ壹☆繧九％縺ｨ縺ｧ縲?
348             * XML繝輔ぃ繧､繝ｫ繧偵ョ繝ｼ繧ｿ繝吶?繧ｹ縺ｫ逋ｻ骭ｲ縺吶ｋ縺薙→縺悟庄閭ｽ縺ｧ縺吶?
349             * ORACLE XDK諡｡蠑ｵ繝輔ぃ繧､繝ｫ繧??EXEC_SQL繧ｿ繧ｰ縺ｪ縺ｩ縺ｮ隧ｳ邏ｰ縺ｯ縲＋@link org.opengion.fukurou.xml.HybsXMLSave}
350             * 繧貞盾辣ｧ鬘倥＞縺ｾ縺吶?
351             *
352             * @param       stream  隱ｭ縺ｿ蜿悶ｋ繧ｹ繝医Μ繝ｼ繝?
353             * @param       conn    DB謗･邯壹?繧ｳ繝阪け繧ｷ繝ｧ繝ｳ
354             * @param       table   霑ｽ蜉?☆繧九ユ繝ｼ繝悶Ν蜷?
355             *
356             * @og.rev 5.6.6.1 (2013/07/12) 譖ｴ譁ｰ繧ｫ繧ｦ繝ｳ繝域焚繧ょ叙蠕励＠縺ｾ縺吶?
357             * @og.rev 5.6.7.0 (2013/07/27) HybsXMLSave 縺ｮ DDL?医ョ繝ｼ繧ｿ螳夂ｾｩ險?ｪ橸ｼ咼ata Definition Language?峨?蜃ｦ逅?ｻｶ謨ｰ霑ｽ蜉?
358             * @og.rev 5.6.9.2 (2013/10/18) EXEC_SQL 縺ｮ繧ｨ繝ｩ繝ｼ譎ゅ↓ Exception 繧堤匱陦後＠縺ｪ縺??
359             *
360             * @return      霑ｽ蜉?＆繧後◆莉ｶ謨ｰ
361             * @see org.opengion.fukurou.xml.HybsXMLSave
362             */
363            private int loadXML( final InputStream stream, final Connection conn,final String table )
364                    throws SQLException,UnsupportedEncodingException {
365    
366                    // InputStream 繧医ｊ縲々ML繝輔ぃ繧､繝ｫ繧定ｪｭ縺ｿ蜿悶ｊ縲》able 縺ｫ霑ｽ蜉?INSERT)縺励∪縺吶?
367                    Reader reader = new BufferedReader( new InputStreamReader( stream,"UTF-8" ) );
368                    HybsXMLSave save = new HybsXMLSave( conn,table );
369                    save.onExecErrException( false );               // 5.6.9.2 (2013/10/18) EXEC_SQL 縺ｮ繧ｨ繝ｩ繝ｼ譎ゅ↓ Exception 繧堤匱陦後＠縺ｪ縺??
370                    save.insertXML( reader );
371                    int insCnt = save.getInsertCount();
372                    int delCnt = save.getDeleteCount();
373                    int updCnt = save.getUpdateCount();             // 5.6.6.1 (2013/07/12) 譖ｴ譁ｰ繧ｫ繧ｦ繝ｳ繝域焚繧ょ叙蠕?
374                    int ddlCnt = save.getDDLCount();                // 5.6.7.0 (2013/07/27) DDL蜃ｦ逅?ｻｶ謨ｰ霑ｽ蜉?
375                    String tableName = save.getTableName() ;
376    
377    //              System.out.println( "          TABLE=[" + tableName + "]  DELETE=["+ delCnt +"] INSERT=[" + insCnt + "]" );
378    //              System.out.println( "          TABLE=[" + tableName + "]  DELETE=["+ delCnt +"] INSERT=[" + insCnt + "] UPDATE=[" + updCnt + "]" );
379                    System.out.println( "          TABLE=[" + tableName + "]  DELETE=["+ delCnt +"] INSERT=[" + insCnt + "] UPDATE=[" + updCnt + "] DDL=[" + ddlCnt + "]" );
380                    return insCnt;
381            }
382    }