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.xml;
017    
018    import org.opengion.fukurou.util.Closer;
019    import org.opengion.fukurou.util.LogWriter;
020    import org.opengion.fukurou.db.DBUtil;
021    
022    import java.io.Reader;
023    import java.io.BufferedReader;
024    import java.io.InputStreamReader;
025    import java.io.FileInputStream;
026    import java.util.Map;
027    import java.util.List;
028    import java.util.ArrayList;
029    import java.util.regex.Pattern;
030    import java.util.regex.Matcher;
031    import java.util.Arrays;
032    import java.util.Locale;
033    
034    import java.sql.DriverManager;
035    import java.sql.Connection;
036    import java.sql.Statement;
037    import java.sql.PreparedStatement;
038    import java.sql.ParameterMetaData;
039    import java.sql.DatabaseMetaData;
040    import java.sql.SQLException;
041    
042    /**
043     * 縺薙?繧ｯ繝ｩ繧ｹ縺ｯ縲√が繝ｩ繧ｯ繝ｫ XDK縺ｮ oracle.xml.sql.dml.OracleXMLSave 繧ｯ繝ｩ繧ｹ縺ｨ
044     * 縺ｻ縺ｼ蜷梧ｧ倥?逶ｮ逧?〒菴ｿ逕ｨ縺ｧ縺阪ｋ繧ｯ繝ｩ繧ｹ縺ｧ縺吶?
045     * 諡｡蠑ｵXDK蠖｢蠑上?XML繝輔ぃ繧､繝ｫ繧定ｪｭ縺ｿ霎ｼ縺ｿ縲√ョ繝ｼ繧ｿ繝吶?繧ｹ縺ｫ INSERT 縺励∪縺吶?
046     *
047     * 諡｡蠑ｵXDK蠖｢蠑上?蜈?→縺ｪ繧?繧ｪ繝ｩ繧ｯ繝ｫ XDK(Oracle XML Developer's Kit)縺ｫ縺､縺?※縺ｯ縲∽ｻ･荳九?
048     * 繝ｪ繝ｳ繧ｯ繧貞盾辣ｧ鬘倥＞縺ｾ縺吶?
049     * <a href="http://otn.oracle.co.jp/software/tech/xml/xdk/index.html" target="_blank" >
050     * XDK(Oracle XML Developer's Kit)</a>
051     *
052     * 縺薙?繧ｯ繝ｩ繧ｹ縺ｧ縺ｯ縲｀AP 繧堤匳骭ｲ縺吶ｋ[ setDefaultMap( Map ) ]縺薙→縺ｫ繧医ｊ縲?
053     * XML繝輔ぃ繧､繝ｫ縺ｫ蟄伜惠縺励↑縺?き繝ｩ繝?ｒ蛻晄悄蛟､縺ｨ縺励※險ｭ螳壹☆繧九％縺ｨ縺悟庄閭ｽ縺ｫ縺ｪ繧翫∪縺吶?
054     * 萓九∴縺ｰ縲∫匳骭ｲ譌･繧??逋ｻ骭ｲ閠??縺ｾ縺溘?縲√ユ繝ｳ繝励Ξ繝ｼ繝医ｈ繧雁推繧ｷ繧ｹ繝?ΒID豈弱↓
055     * 逋ｻ骭ｲ縺吶ｋ縺ｪ縺ｩ縺ｧ縺吶?
056     * 蜷梧ｧ倥↓縲∬ｪｭ縺ｿ蜿悶▲縺?XML繝輔ぃ繧､繝ｫ縺ｮ諠??繧呈嶌縺肴鋤縺医ｋ讖溯?[ setAfterMap( Map ) ]繝｡繧ｽ繝?ラ
057     * 縺ｫ繧医ｊ縲√き繝ｩ繝??蛟､縺ｮ鄂ｮ縺肴鋤縺医ｂ蜿ｯ閭ｽ縺ｧ縺吶?
058     *
059     * 諡｡蠑ｵXDK蠖｢蠑上?蜈?→縺ｪ繧?繧ｪ繝ｩ繧ｯ繝ｫ XDK(Oracle XML Developer's Kit)縺ｫ縺､縺?※縺ｯ縲∽ｻ･荳九?
060     * 繝ｪ繝ｳ繧ｯ繧貞盾辣ｧ鬘倥＞縺ｾ縺吶?
061     * <a href="http://otn.oracle.co.jp/software/tech/xml/xdk/index.html" target="_blank" >
062     * XDK(Oracle XML Developer's Kit)</a>
063     *
064     * 諡｡蠑ｵXDK蠖｢蠑上→縺ｯ縲ヽOW 莉･螟悶↓縲ヾQL蜃ｦ逅?畑繧ｿ繧ｰ(EXEC_SQL)繧呈戟縺､ XML 繝輔ぃ繧､繝ｫ縺ｧ縺吶?
065     * 縺ｾ縺溘?逋ｻ骭ｲ縺吶ｋ繝??繝悶Ν(table)繧?ROWSET繧ｿ繧ｰ縺ｮ螻樊?諠??縺ｨ縺励※莉倅ｸ弱☆繧九％縺ｨ縺後〒縺阪∪縺吶?
066     * (螟ｧ譁?ｭ怜ｰ乗枚蟄励↓豕ｨ諢?
067     * 縺薙ｌ縺ｯ縲√が繝ｩ繧ｯ繝ｫXDK縺ｧ蜃ｦ逅?☆繧句?蜷医?辟｡隕悶＆繧後∪縺吶?縺ｧ縲∝酔讒倥↓謇ｱ縺?％縺ｨ縺悟?譚･縺ｾ縺吶?
068     * 縺薙?縲・XEC_SQL 縺ｯ縲√◎繧後◎繧後? XML繝??繧ｿ繧偵ョ繝ｼ繧ｿ繝吶?繧ｹ縺ｫ逋ｻ骭ｲ縺吶ｋ髫帙↓縲?
069     * SQL蜃ｦ逅?ｒ閾ｪ蜍慕噪縺ｫ豬√☆轤ｺ縺ｮ縲ヾQL譁?ｒ險倩ｼ峨＠縺ｾ縺吶?
070     * 縺薙?蜃ｦ逅??縲√う繝吶Φ繝域ｯ弱↓螳溯｡後＆繧後ｋ轤ｺ縲√◎縺ｮ驟咲ｽｮ鬆??驥崎ｦ√〒縺吶?
071     * 縺薙?繧ｿ繧ｰ縺ｯ縲∬､?焚險倩ｿｰ縺吶ｋ縺薙→繧ょ?譚･縺ｾ縺吶′縲。ODY驛ｨ縺ｫ縺ｯ縲?ｼ代▽縺ｮSQL譁??縺ｿ險倩ｿｰ縺励∪縺吶?
072     *
073     *   &lt;ROWSET tableName="XX" &gt;
074     *       &lt;EXEC_SQL&gt;                    譛??縺ｫ險倩ｼ峨＠縺ｦ縲∝?譛溷?逅?繝??繧ｿ繧ｯ繝ｪ繧｢遲?繧貞ｮ溯｡後＆縺帙ｋ縲?
075     *           delete from GEXX where YYYYY
076     *       &lt;/EXEC_SQL&gt;
077     *       &lt;MERGE_SQL&gt;                   縺薙?SQL譁?〒 UPDATE縺励※縲∫ｵ先棡縺鯉ｼ蝉ｻｶ縺ｪ繧迂NSERT繧定｡後＞縺ｾ縺吶?
078     *           update GEXX set AA=[AA] , BB=[BB] where CC=[CC]
079     *       &lt;/MERGE_SQL&gt;
080     *       &lt;ROW num="1"&gt;
081     *           &lt;繧ｫ繝ｩ繝?&gt;蛟､1&lt;/繧ｫ繝ｩ繝?&gt;
082     *             ?･?･?･
083     *           &lt;繧ｫ繝ｩ繝?&gt;蛟､n&lt;/繧ｫ繝ｩ繝?&gt;
084     *       &lt;/ROW&gt;
085     *        ?･?･?･
086     *       &lt;ROW num="n"&gt;
087     *          ?･?･?･
088     *       &lt;/ROW&gt;
089     *       &lt;EXEC_SQL&gt;                    譛?ｾ後↓險倩ｼ峨＠縺ｦ縲??逶ｮ縺ｮ險ｭ螳?謨ｴ蜷域?逋ｻ骭ｲ)繧定｡後≧縲?
090     *           update GEXX set AA='XX' , BB='XX' where YYYYY
091     *       &lt;/EXEC_SQL&gt;
092     *   &lt;ROWSET&gt;
093     *
094     * @version  4.0
095     * @author   Kazuhiko Hasegawa
096     * @since    JDK5.0,
097     */
098    public class HybsXMLSave implements TagElementListener {
099            /** 繧ｷ繧ｹ繝?Β萓晏ｭ倥?謾ｹ陦瑚ｨ伜捷繧偵そ繝?ヨ縺励∪縺吶?     */
100            private static final String CR = System.getProperty("line.separator");
101    
102            private String tableName                = null;
103            private String[] keyColumns             = null;
104            private Connection connection   = null;
105            private PreparedStatement insPstmt      = null;         // INSERT逕ｨ縺ｮ PreparedStatement
106            private PreparedStatement updPstmt      = null;         // UPDATE逕ｨ縺ｮ PreparedStatement
107            private ParameterMetaData insMeta       = null;
108            private ParameterMetaData updMeta       = null;
109            private int insCnt              = 0;
110            private int updCnt              = 0;
111            private int delCnt              = 0;
112            private int ddlCnt              = 0;                                    // 5.6.7.0 (2013/07/27) DDL譁??繧ｫ繧ｦ繝ｳ繧ｿ繝ｼ
113            private Map<String,String>        defaultMap      = null;
114            private Map<String,String>        afterMap        = null;
115            private List<String>              updClms         = null;
116            private String[]                        insClms         = null;
117            private String                          lastSQL         = null;         // 5.6.6.1 (2013/07/12) 繝?ヰ繝?げ逕ｨ縲よ怙蠕後↓菴ｿ逕ｨ縺励◆SQL譁?
118    
119            private final boolean useParamMetaData ;        // 4.0.0.0 (2007/09/25)
120    
121            // UPDATE譎ゅ? [XXX] 繧貞叙繧雁?縺励∪縺吶?\w 縺ｯ縲∝腰隱樊ｧ区?譁?ｭ? [a-zA-Z_0-9]縺ｨ蜷後§
122            private static final Pattern pattern = Pattern.compile( "\\[\\w*\\]" );
123    
124            // 5.6.9.2 (2013/10/18) EXEC_SQL 縺ｮ繧ｨ繝ｩ繝ｼ繧堤┌隕悶☆繧九°縺ｩ縺?°繧呈欠螳壹〒縺阪∪縺吶?
125            private boolean isExecErrException = true;                      // true 縺ｯ縲√お繝ｩ繝ｼ譎ゅ↓ Exception 繧堤匱陦後＠縺ｾ縺吶?
126    
127            /**
128             * 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧呈欠螳壹＠縺ｦ縲√が繝悶ず繧ｧ繧ｯ繝医ｒ讒狗ｯ峨＠縺ｾ縺吶?
129             * 繝??繝悶Ν蜷阪?縲∵僑蠑ｵXDK蠖｢蠑上?ROWSET繧ｿ繧ｰ縺ｮtableName螻樊?縺ｫ
130             * 險倩ｿｰ縺励※縺翫￥蠢?ｦ√′縺ゅｊ縺ｾ縺吶?
131             *
132             * @param       conn    繝??繧ｿ繝吶?繧ｹ謗･邯?
133             */
134            public HybsXMLSave( final Connection conn ) {
135                    this( conn,null );
136            }
137    
138            /**
139             * 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ縺ｨ繝??繝悶Ν蜷阪ｒ謖?ｮ壹＠縺ｦ縲√が繝悶ず繧ｧ繧ｯ繝医ｒ讒狗ｯ峨＠縺ｾ縺吶?
140             * 縺薙％縺ｧ謖?ｮ壹☆繧九ユ繝ｼ繝悶Ν蜷阪?縲√ョ繝輔か繝ｫ繝医ユ繝ｼ繝悶Ν縺ｨ縺?≧謇ｱ縺?〒縺吶?
141             * 諡｡蠑ｵXDK蠖｢蠑上?ROWSET繧ｿ繧ｰ縺ｮtableName螻樊?縺ｫ繝??繝悶Ν蜷阪′險倩ｿｰ縺輔ｌ縺ｦ縺?ｋ蝣ｴ蜷医?縲?
142             * 縺昴■繧峨′蜆ｪ蜈医＆繧後∪縺吶?
143             *
144             * @og.rev 4.0.0.0 (2007/09/25) ParameterMetaData 繧剃ｽｿ逕ｨ縺励◆繝代Λ繝｡繝ｼ繧ｿ險ｭ螳夊ｿｽ蜉??
145             * @og.rev 5.3.8.0 (2011/08/01) useParamMetaData 繧?縺薙?繧ｯ繝ｩ繧ｹ縺ｧ逶ｴ謗･蜿門ｾ励☆繧九?(PostgreSQL蟇ｾ蠢?
146             *
147             * @param       conn    繝??繧ｿ繝吶?繧ｹ謗･邯?
148             * @param       table   繝??繝悶Ν蜷?ROWSET繧ｿ繧ｰ縺ｮtable螻樊?縺梧悴險ｭ螳壽凾縺ｫ菴ｿ逕ｨ)
149             */
150            public HybsXMLSave( final Connection conn,final String table ) {
151                    connection = conn;
152                    tableName  = table;
153    //              useParamMetaData = ApplicationInfo.useParameterMetaData( conn );
154                    useParamMetaData = useParameterMetaData( connection );          // 5.3.8.0 (2011/08/01)
155            }
156    
157            /**
158             * EXEC_SQL 縺ｮ繧ｨ繝ｩ繝ｼ譎ゅ↓ Exception 繧堤匱陦後☆繧九°縺ｩ縺?°繧呈欠螳壹〒縺阪∪縺?蛻晄悄蛟､:true)縲?
159             * true 繧呈欠螳壹☆繧九→縲√お繝ｩ繝ｼ譎ゅ↓縺ｯ縲?RuntimeException 繧?throw 縺励∪縺吶?
160             * false 縺ｫ縺吶ｋ縺ｨ縲∵ｨ呎ｺ悶お繝ｩ繝ｼ蜃ｺ蜉帙↓縺ｮ縺ｿ縲∝?蜉帙＠縺ｾ縺吶?
161             * 縺薙?繝輔Λ繧ｰ縺ｯ縲・XEC_SQL 縺ｮ縺ｿ譛牙柑縺ｧ縺吶?縺昴ｌ莉･螟悶?繧ｿ繝悶?蜃ｦ逅?〒縺ｯ縲√お繝ｩ繝ｼ縺檎匱逕溘☆繧九→
162             * 縺昴?譎らせ縺ｧ縲・xception 繧堤匱陦後＠縺ｦ縲∝?逅?ｒ邨ゆｺ?＠縺ｾ縺吶?
163             * 蛻晄悄蛟､縺ｯ縲》rue(Exception 繧堤匱陦後☆繧? 縺ｧ縺吶?
164             *
165             * @og.rev 5.6.9.2 (2013/10/18) 譁ｰ隕剰ｿｽ蜉?
166             *
167             * @param flag true:Exception 繧堤匱陦後☆繧?false:讓呎ｺ悶お繝ｩ繝ｼ蜃ｺ蜉帙↓蜃ｺ蜉帙☆繧?
168             */
169            public void onExecErrException( final boolean flag ) {
170                    isExecErrException = flag;
171            }
172    
173            /**
174             * &lt;ROWSET&gt; 繧ｿ繧ｰ縺ｮ荳?分譛??縺ｫ蜻ｼ縺ｳ蜃ｺ縺輔ｌ縺ｾ縺吶?
175             * ROWSET 縺ｮ螻樊?縺ｧ縺ゅｋ縲》able 螻樊?縺ｨ縲‥bid 螻樊? 繧偵?TagElement 縺ｮ
176             * get 繝｡繧ｽ繝?ラ縺ｧ蜿門ｾ励〒縺阪∪縺吶?
177             * 蜿門ｾ玲凾縺ｮ繧ｭ繝ｼ縺ｯ縲√◎繧後◇繧後?"TABLE" 縺ｨ "DBID" 縺ｧ縺吶?
178             *
179             * @param tag 繧ｿ繧ｰ繧ｨ繝ｬ繝｡繝ｳ繝?
180             * @see org.opengion.fukurou.xml.TagElement
181             * @see HybsXMLHandler#setTagElementListener( TagElementListener )
182             */
183            public void actionInit( final TagElement tag ) {
184                    String table = tag.get( "tableName" );
185                    if( table != null ) { tableName = table; }
186            }
187    
188            /**
189             * &lt;ROW&gt; 繧ｿ繧ｰ縺ｮ endElement 蜃ｦ逅?ｯ弱↓蜻ｼ縺ｳ蜃ｺ縺輔ｌ縺ｾ縺吶?
190             * 縺薙? Listener 繧偵そ繝?ヨ縺吶ｋ縺薙→縺ｫ繧医ｊ縲∬｡後ョ繝ｼ繧ｿ繧貞叙蠕鈴?蠎ｦ縲?
191             * TagElement 繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ菴懈?縺励?縺薙?繝｡繧ｽ繝?ラ縺悟他縺ｳ蜃ｺ縺輔ｌ縺ｾ縺吶?
192             *
193             * @og.rev 4.0.0.0 (2007/05/09) ParameterMetaData 繧剃ｽｿ逕ｨ縺励◆繝代Λ繝｡繝ｼ繧ｿ險ｭ螳夊ｿｽ蜉??
194             * @og.rev 4.0.0.0 (2007/09/25) isOracle 縺九ｉ useParamMetaData 縺ｫ螟画峩
195             * @og.rev 4.3.7.0 (2009/06/01) HSQLDB蟇ｾ蠢?
196             * @og.rev 5.3.8.0 (2011/08/01) useParamMetaData  setNull 蟇ｾ蠢?PostgreSQL蟇ｾ蠢?
197             * @og.rev 5.6.6.1 (2013/07/12) lastSQL 蟇ｾ蠢懊?繝?ヰ繝?げ逕ｨ縺ｫ縲∵怙蠕後↓菴ｿ逕ｨ縺励◆SQL譁?ｒ谿九＠縺ｾ縺吶?
198             *
199             * @param tag 繧ｿ繧ｰ繧ｨ繝ｬ繝｡繝ｳ繝?
200             * @see org.opengion.fukurou.xml.TagElement
201             * @see HybsXMLHandler#setTagElementListener( TagElementListener )
202             */
203            public void actionRow( final TagElement tag ) {
204                    tag.setAfterMap( afterMap );
205    
206                    String[] vals = null;                   // 5.6.6.1 (2013/07/12) 繝?ヰ繝?げ逕ｨ
207                    try {
208                            // 譖ｴ譁ｰSQL(MERGE_SQL繧ｿ繧ｰ)縺悟ｭ伜惠縺吶ｋ蝣ｴ蜷医?蜃ｦ逅?
209                            int tempCnt = 0;
210                            if( updPstmt != null ) {
211    //                              String[] vals = tag.getValues( updClms );
212                                    vals = tag.getValues( updClms );                                                // 5.6.6.1 (2013/07/12) 繝?ヰ繝?げ逕ｨ
213                                    for( int j=0; j<vals.length; j++ ) {
214                                            // 4.3.7.0 (2009/06/01) HSQLDB蟇ｾ蠢懊?遨ｺ譁?ｭ励?蝣ｴ蜷?ull縺ｫ鄂ｮ謠帙∴
215                                            if( vals[j] != null && vals[j].length() == 0 ){
216                                                    vals[j] = null;
217                                            }
218    
219                                            // 4.0.0.0 (2007/09/25) ParameterMetaData 繧剃ｽｿ逕ｨ縺励◆繝代Λ繝｡繝ｼ繧ｿ險ｭ螳夊ｿｽ蜉?
220                                            if( useParamMetaData ) {
221                                                    int type = updMeta.getParameterType( j+1 );
222                                                    // 5.3.8.0 (2011/08/01) setNull 蟇ｾ蠢?
223    //                                              updPstmt.setObject( j+1,vals[j],type );
224                                                    String val = vals[j];
225                                                    if( val == null || val.isEmpty() ) {
226                                                            updPstmt.setNull( j+1, type );
227                                                    }
228                                                    else {
229                                                            updPstmt.setObject( j+1, val, type );
230                                                    }
231                                            }
232                                            else {
233                                                    updPstmt.setObject( j+1,vals[j] );
234                                            }
235    
236                                    }
237                                    tempCnt = updPstmt.executeUpdate();
238                                    if( tempCnt > 1 ) {
239                                            String errMsg = "Update 繧ｭ繝ｼ縺碁㍾隍?＠縺ｦ縺?∪縺吶?"
240                                                            + "TABLE=[" + tableName + "] ROW=["
241                                                            + tag.getRowNo() + "]" + CR
242                                                            + " SQL=[" + lastSQL + "]" + CR                         // 5.6.6.1 (2013/07/12) 繝?ヰ繝?げ逕ｨ
243                                                            + tag.toString() + CR
244                                                            + Arrays.toString( vals ) + CR ;                        // 5.6.6.1 (2013/07/12) 繝?ヰ繝?げ逕ｨ
245                                            throw new RuntimeException( errMsg );
246                                    }
247                                    updCnt += tempCnt;
248                            }
249                            // 譖ｴ譁ｰ縺?0莉ｶ縺ｮ蝣ｴ蜷医?縲！NSERT蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
250                            if( tempCnt == 0 ) {
251                                    // 蛻晏屓INSERT譎ゅ?繧ｿ繧ｰ繧医ｊ縲．B逋ｻ骭ｲSQL譁?ｒ讒狗ｯ峨＠縺ｾ縺吶?
252                                    if( insPstmt == null ) {
253                                            insClms = tag.getKeys();
254    //                                      String sql = insertSQL( insClms,tableName );
255    //                                      insPstmt = connection.prepareStatement( sql );
256                                            lastSQL    = insertSQL( insClms,tableName );            // 5.6.6.1 (2013/07/12) 繝?ヰ繝?げ逕ｨ
257                                            insPstmt = connection.prepareStatement( lastSQL );
258                                            // 4.0.0.0 (2007/09/25) ParameterMetaData 繧剃ｽｿ逕ｨ縺励◆繝代Λ繝｡繝ｼ繧ｿ險ｭ螳夊ｿｽ蜉?
259                                            if( useParamMetaData ) { insMeta = insPstmt.getParameterMetaData(); }
260                                    }
261    //                              String[] vals = tag.getValues( insClms );
262                                    vals = tag.getValues( insClms );                                                // 5.6.6.1 (2013/07/12) 繝?ヰ繝?げ逕ｨ
263                                    for( int j=0; j<vals.length; j++ ) {
264                                            // 4.3.7.0 (2009/06/01) HSQLDB蟇ｾ蠢懊?遨ｺ譁?ｭ励?蝣ｴ蜷?ull縺ｫ鄂ｮ謠帙∴
265                                            if( vals[j] != null && vals[j].length() == 0 ){
266                                                    vals[j] = null;
267                                            }
268    
269                                            // 4.0.0.0 (2007/09/25) ParameterMetaData 繧剃ｽｿ逕ｨ縺励◆繝代Λ繝｡繝ｼ繧ｿ險ｭ螳夊ｿｽ蜉?
270                                            if( useParamMetaData ) {
271                                                    int type = insMeta.getParameterType( j+1 );
272                                                    // 5.3.8.0 (2011/08/01) setNull 蟇ｾ蠢?
273    //                                              insPstmt.setObject( j+1,vals[j],type );
274                                                    String val = vals[j];
275                                                    if( val == null || val.isEmpty() ) {
276                                                            insPstmt.setNull( j+1, type );
277                                                    }
278                                                    else {
279                                                            insPstmt.setObject( j+1, val, type );
280                                                    }
281                                            }
282                                            else {
283                                                    insPstmt.setObject( j+1,vals[j] );
284                                            }
285                                    }
286                                    insCnt += insPstmt.executeUpdate();
287                            }
288                    }
289                    catch( SQLException ex ) {
290                            String errMsg = "DB逋ｻ骭ｲ繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺ｾ縺励◆縲?
291                                                    + "TABLE=[" + tableName + "] ROW=["
292                                                    + tag.getRowNo() + "]" + CR
293                                                    + " SQL=[" + lastSQL + "]" + CR                         // 5.6.6.1 (2013/07/12) 繝?ヰ繝?げ逕ｨ
294                                                    + tag.toString() + CR
295                                                    + Arrays.toString( vals ) + CR                          // 5.6.6.1 (2013/07/12) 繝?ヰ繝?げ逕ｨ
296                                                    + ex.getMessage() + ":" + ex.getSQLState() + CR ;
297                            throw new RuntimeException( errMsg,ex );
298                    }
299            }
300    
301            /**
302             * &lt;EXEC_SQL&gt; 繧ｿ繧ｰ縺ｮ endElement 蜃ｦ逅?ｯ弱↓蜻ｼ縺ｳ蜃ｺ縺輔ｌ縺ｾ縺吶?
303             * getBody 繝｡繧ｽ繝?ラ繧剃ｽｿ逕ｨ縺励※縲√％縺ｮ繧ｿ繧ｰ縺ｮBODY驛ｨ縺ｮ譁?ｭ怜?繧貞叙蠕励＠縺ｾ縺吶?
304             * 縺薙? Listener 繧偵そ繝?ヨ縺吶ｋ縺薙→縺ｫ繧医ｊ縲・XEC_SQL 繝??繧ｿ繧貞叙蠕鈴?蠎ｦ縲?
305             * TagElement 繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ菴懈?縺励?縺薙?繝｡繧ｽ繝?ラ縺悟他縺ｳ蜃ｺ縺輔ｌ縺ｾ縺吶?
306             * EXEC_SQL 繧ｿ繧ｰ縺ｧ縺ｯ縲‥elete譁?ｄupdate譁?↑縺ｩ縲∫音谿翫↑蜑榊?逅?ｄ蠕悟?逅?畑縺ｮ SQL縺ｨ
307             * DDL?医ョ繝ｼ繧ｿ螳夂ｾｩ險?ｪ橸ｼ咼ata Definition Language?峨?蜃ｦ逅?↑縺ｩ繧りｨ倩ｿｰ縺ｧ縺阪∪縺吶?
308             * 縺薙％縺ｧ縺ｯ邁｡譏鍋噪縺ｫ縲∽ｽ輔°螳溯｡後＆繧後◆蝣ｴ蜷医?縲‥elete 蜃ｦ逅?→閠?∴縲∝炎髯､繧ｫ繧ｦ繝ｳ繝医ｒ蜉?ｮ励＠縲?
309             * 0莉ｶ縺ｧ蟶ｰ縺｣縺ｦ縺阪◆蝣ｴ蜷医↓縲．DL縺悟ｮ溯｡後＆繧後◆縺ｨ閠?∴縲．DL繧ｫ繧ｦ繝ｳ繝医ｒ?具ｼ代＠縺ｾ縺吶?
310             * 縺溘□縺励?0莉ｶ delete 繧り?縺医ｉ繧後ｋ縺溘ａ縲ヾQL譁??蜈磯?譁?ｭ励↓繧医ｋ繝√ぉ繝?け縺ｯ蜈･繧後※縺翫″縺ｾ縺吶?
311             *
312             * @og.rev 5.6.6.1 (2013/07/12) lastSQL 蟇ｾ蠢懊?繝?ヰ繝?げ逕ｨ縺ｫ縲∵怙蠕後↓菴ｿ逕ｨ縺励◆SQL譁?ｒ谿九＠縺ｾ縺吶?
313             * @og.rev 5.6.7.0 (2013/07/27) DDL?医ョ繝ｼ繧ｿ螳夂ｾｩ險?ｪ橸ｼ咼ata Definition Language?峨?蜃ｦ逅?ｻｶ謨ｰ霑ｽ蜉?
314             * @og.rev 5.6.9.2 (2013/10/18) EXEC_SQL 縺ｮ繧ｨ繝ｩ繝ｼ譎ゅ↓ Exception 繧堤匱陦後☆繧九°縺ｩ縺?°繧呈欠螳?
315             *
316             * @param tag 繧ｿ繧ｰ繧ｨ繝ｬ繝｡繝ｳ繝?
317             * @see org.opengion.fukurou.xml.TagElement
318             * @see HybsXMLHandler#setTagElementListener( TagElementListener )
319             */
320            public void actionExecSQL( final TagElement tag ) {
321                    Statement execSQL = null ;
322                    try {
323    //                      String sql = tag.getBody();
324                            lastSQL = tag.getBody();                // 5.6.6.1 (2013/07/12) 繝?ヰ繝?げ逕ｨ
325                            execSQL = connection.createStatement();
326    //                      delCnt += execSQL.executeUpdate( sql ) ;
327    
328                            // 5.6.7.0 (2013/07/27) DDL?医ョ繝ｼ繧ｿ螳夂ｾｩ險?ｪ橸ｼ咼ata Definition Language?峨?蜃ｦ逅?ｻｶ謨ｰ霑ｽ蜉?
329    //                      delCnt += execSQL.executeUpdate( lastSQL ) ;
330                            int cnt = execSQL.executeUpdate( lastSQL ) ;
331                            if( cnt > 0 ) { delCnt += cnt; }                             // 莉ｶ謨ｰ縺瑚ｿ斐ｌ縺ｰ縲．DL縺ｧ縺ｪ縺?◆繧√?蜑企勁謨ｰ繧貞刈邂?
332                            else {
333                                    String sql = lastSQL.trim().toUpperCase( Locale.JAPAN );
334                                    if( !sql.startsWith( "DELETE" ) && !sql.startsWith( "INSERT" ) && !sql.startsWith( "UPDATE" ) ) {
335                                            ddlCnt ++ ;
336                                    }
337                            }
338                    }
339                    catch( SQLException ex ) {
340                            String errMsg = "DB逋ｻ骭ｲ繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺ｾ縺励◆縲?
341                                                    + "TABLE=[" + tableName + "] ROW=["
342                                                    + tag.getRowNo() + "]" + CR
343                                                    + " SQL=[" + lastSQL + "]" + CR                         // 5.6.6.1 (2013/07/12) 繝?ヰ繝?げ逕ｨ
344                                                    + tag.toString() + CR
345                                                    + ex.getMessage() + ":" + ex.getSQLState() + CR ;
346    
347                            // 5.6.9.2 (2013/10/18) EXEC_SQL 縺ｮ繧ｨ繝ｩ繝ｼ譎ゅ↓ Exception 繧堤匱陦後☆繧九°縺ｩ縺?°繧呈欠螳?
348    
349                            if( isExecErrException ) {
350                                    throw new RuntimeException( errMsg,ex );
351                            }
352                            else {
353                                    System.err.println( errMsg );
354                            }
355                    }
356                    finally {
357                            Closer.stmtClose( execSQL );
358                    }
359            }
360    
361            /**
362             * &lt;MERGE_SQL&gt; 繧ｿ繧ｰ縺ｮ endElement 蜃ｦ逅?凾縺ｫ蜻ｼ縺ｳ蜃ｺ縺輔ｌ縺ｾ縺吶?
363             * getBody 繝｡繧ｽ繝?ラ繧剃ｽｿ逕ｨ縺励※縲√％縺ｮ繧ｿ繧ｰ縺ｮBODY驛ｨ縺ｮ譁?ｭ怜?繧貞叙蠕励＠縺ｾ縺吶?
364             * MERGE_SQL繧ｿ繧ｰ縺ｯ縲√?繝ｼ繧ｸ蜃ｦ逅?＠縺溘＞繝??繧ｿ驛ｨ繧医ｊ繧ゆｸ贋ｽ阪↓險倩ｿｰ縺励※縺翫￥
365             * 蠢?ｦ√′縺ゅｊ縺ｾ縺吶′縲∽ｸｭ髢馴Κ縺ｫ隍?焚蝗櫁ｨ倩ｿｰ縺励※繧よｧ九＞縺ｾ縺帙ｓ縲?
366             * 縺薙?繧ｿ繧ｰ縺檎樟繧後ｋ縺ｾ縺ｧ縺ｯ縲！NSERT 縺ｮ縺ｿ螳溯｡後＆繧後∪縺吶?縺薙?繧ｿ繧ｰ莉･髯阪?縲?
367             * 荳?率 UPDATE 縺励?邨先棡縺??蝉ｻｶ縺ｮ蝣ｴ蜷医?縲！NSERT縺吶ｋ豬√ｌ縺ｫ縺ｪ繧翫∪縺吶?
368             * 螳悟?縺ｫ INSERT 縺ｮ縺ｿ縺ｧ縺ゅｋ繝??繧ｿ繧貞燕蜊翫↓縲ゞPDATE/INSERT繧定｡後≧
369             * 繝??繧ｿ繧貞ｾ悟濠縺ｫ縲√◎縺ｮ髢薙↓縲｀ERGE_SQL 繧ｿ繧ｰ繧貞?繧後ｋ縺薙→縺ｧ縲∫┌諢丞袖縺ｪ
370             * UPDATE 繧帝∩縺代ｋ縺薙→縺悟庄閭ｽ縺ｧ縺吶?
371             * 縺薙? Listener 繧偵そ繝?ヨ縺吶ｋ縺薙→縺ｫ繧医ｊ縲｀ERGE_SQL 繝??繧ｿ繧貞叙蠕鈴?蠎ｦ縲?
372             * TagElement 繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ菴懈?縺励?縺薙?繝｡繧ｽ繝?ラ縺悟他縺ｳ蜃ｺ縺輔ｌ縺ｾ縺吶?
373             *
374             * @og.rev 4.0.0.0 (2007/05/09) ParameterMetaData 繧剃ｽｿ逕ｨ縺励◆繝代Λ繝｡繝ｼ繧ｿ險ｭ螳夊ｿｽ蜉??
375             * @og.rev 4.0.0.0 (2007/09/25) isOracle 縺九ｉ useParamMetaData 縺ｫ螟画峩
376             * @og.rev 5.6.6.1 (2013/07/12) lastSQL 蟇ｾ蠢懊?繝?ヰ繝?げ逕ｨ縺ｫ縲∵怙蠕後↓菴ｿ逕ｨ縺励◆SQL譁?ｒ谿九＠縺ｾ縺吶?
377             *
378             * @param tag 繧ｿ繧ｰ繧ｨ繝ｬ繝｡繝ｳ繝?
379             * @see org.opengion.fukurou.xml.TagElement
380             * @see HybsXMLHandler#setTagElementListener( TagElementListener )
381             */
382            public void actionMergeSQL( final TagElement tag ) {
383                    if( updPstmt != null ) {
384                            String errMsg = "MERGE_SQL繧ｿ繧ｰ縺後?隍?焚蝗櫁ｨ倩ｿｰ縺輔ｌ縺ｦ縺?∪縺吶?"
385                                                    + "TABLE=[" + tableName + "] ROW=["
386                                                    + tag.getRowNo() + "]" + CR
387                                                    + " SQL=[" + lastSQL + "]" + CR                         // 5.6.6.1 (2013/07/12) 繝?ヰ繝?げ逕ｨ
388                                                    + tag.toString() + CR;
389                            throw new RuntimeException( errMsg );
390                    }
391    
392                    String orgSql = tag.getBody();
393                    Matcher matcher = pattern.matcher( orgSql );
394                    updClms = new ArrayList<String>();
395                    while( matcher.find() ) {
396                            // 縺薙％縺ｧ縺ｯ縲ーXXX]縺ｫ繝槭ャ繝√☆繧狗ぜ縲∝燕蠕後?[]繧貞叙繧企勁縺阪∪縺吶?
397                            updClms.add( orgSql.substring( matcher.start()+1,matcher.end()-1 ) );
398                    }
399    //              String sql = matcher.replaceAll( "?" );
400                    lastSQL = matcher.replaceAll( "?" );            // 5.6.6.1 (2013/07/12) 繝?ヰ繝?げ逕ｨ
401    
402                    try {
403    //                      updPstmt = connection.prepareStatement( sql );
404                            updPstmt = connection.prepareStatement( lastSQL );
405                            // 4.0.0.0 (2007/09/25) ParameterMetaData 繧剃ｽｿ逕ｨ縺励◆繝代Λ繝｡繝ｼ繧ｿ險ｭ螳夊ｿｽ蜉?
406                            if( useParamMetaData ) { updMeta = updPstmt.getParameterMetaData(); }
407                    }
408                    catch( SQLException ex ) {
409                            String errMsg = "Statement菴懈?譎ゅ↓繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺ｾ縺励◆縲?
410                                                    + "TABLE=[" + tableName + "] ROW=["
411                                                    + tag.getRowNo() + "]" + CR
412                                                    + " SQL=[" + lastSQL + "]" + CR                         // 5.6.6.1 (2013/07/12) 繝?ヰ繝?げ逕ｨ
413                                                    + tag.toString() + CR
414                                                    + ex.getMessage() + ":" + ex.getSQLState() + CR ;
415                            throw new RuntimeException( errMsg,ex );
416                    }
417            }
418    
419            /**
420             * UPDATE,DELETE 繧定｡後≧蝣ｴ蜷医? WHERE 譚｡莉ｶ縺ｫ縺ｪ繧九く繝ｼ驟榊?
421             * 縺薙?繧ｭ繝ｼ縺ｮ AND 譚｡莉ｶ縺ｧ繧ｫ繝ｩ繝?ｒ迚ｹ螳壹＠縲ゞPDATE,DELETE 縺ｪ縺ｩ縺ｮ蜃ｦ逅?ｒ
422             * 陦後＞縺ｾ縺吶?
423             *
424             * @param       keyCols WHERE譚｡莉ｶ縺ｫ縺ｪ繧九く繝ｼ驟榊?
425             */
426            public void setKeyColumns( final String[] keyCols ) {
427                    keyColumns = new String[keyCols.length];
428                    System.arraycopy( keyCols,0,keyColumns,0,keyColumns.length );
429            }
430    
431            /**
432             * XML繝輔ぃ繧､繝ｫ繧定ｪｭ縺ｿ蜿悶ｋ蜑阪↓謖?ｮ壹☆繧九き繝ｩ繝?→蛟､縺ｮ繝壹い(繝槭ャ繝?諠??繧偵そ繝?ヨ縺励∪縺吶?
433             *
434             * 縺薙?繧ｫ繝ｩ繝?→蛟､縺ｮ繝壹い縺ｮ繝槭ャ繝励?縲√が繝悶ず繧ｧ繧ｯ繝域ｧ狗ｯ牙燕縺ｫ險ｭ螳壹＆繧後ｋ轤ｺ縲?
435             * XML繝輔ぃ繧､繝ｫ縺ｫ繧ｭ繝ｼ縺悟ｭ伜惠縺励※縺?ｋ蝣ｴ蜷医?縲∝?縺梧嶌縺榊､峨ｏ繧翫∪縺吶?(XML蜆ｪ蜈?
436             * XML繝輔ぃ繧､繝ｫ縺ｫ繧ｭ繝ｼ縺悟ｭ伜惠縺励※縺?↑縺??蜷医?縲√％縺薙〒謖?ｮ壹☆繧貴ap縺ｮ蛟､縺?
437             * 蛻晄悄險ｭ螳壼?縺ｨ縺励※菴ｿ逕ｨ縺輔ｌ縺ｾ縺吶?
438             * 縺薙％縺ｧ謖?ｮ壹☆繧?Map 縺ｫ LinkedHashMap 繧剃ｽｿ逕ｨ縺吶ｋ蝣ｴ蜷医?繧ｫ繝ｩ繝??繧?
439             * 謖?ｮ壹☆繧九％縺ｨ縺悟?譚･縺ｾ縺吶?
440             *
441             * @param       map     蛻晄悄險ｭ螳壹☆繧九き繝ｩ繝?ョ繝ｼ繧ｿ繝槭ャ繝?
442             * @see #setAfterMap( Map )
443             */
444            public void setDefaultMap( final Map<String,String> map ) { defaultMap = map; }
445    
446            /**
447             * XML繝輔ぃ繧､繝ｫ繧定ｪｭ縺ｿ蜿悶▲縺溷ｾ後〒謖?ｮ壹☆繧九き繝ｩ繝?→蛟､縺ｮ繝壹い(繝槭ャ繝?諠??繧偵そ繝?ヨ縺励∪縺吶?
448             *
449             * 縺薙?繧ｫ繝ｩ繝?→蛟､縺ｮ繝壹い縺ｮ繝槭ャ繝励?縲√が繝悶ず繧ｧ繧ｯ繝域ｧ狗ｯ牙ｾ後↓險ｭ螳壹＆繧後ｋ轤ｺ縲?
450             * XML繝輔ぃ繧､繝ｫ縺ｮ繧ｭ繝ｼ縺ｮ蟄伜惠縺ｫ髢｢菫ゅ↑縺上?Map縺ｮ繧ｭ繝ｼ縺ｨ蛟､縺御ｽｿ逕ｨ縺輔ｌ縺ｾ縺吶?(Map蜆ｪ蜈?
451             * null 繧定ｨｭ螳壹＠縺溷?蜷医?縲√↑縺ｫ繧ょ?逅?＆繧後∪縺帙ｓ縲?
452             *
453             * @param map   蠕瑚ｨｭ螳壹☆繧九き繝ｩ繝?ョ繝ｼ繧ｿ繝槭ャ繝?
454             * @see #setDefaultMap( Map )
455             */
456            public void setAfterMap( final Map<String,String> map ) { afterMap = map; }
457    
458            /**
459             * 繝??繧ｿ繝吶?繧ｹ縺ｫ霑ｽ蜉??逅?INSERT)繧定｡後＞縺ｾ縺吶?
460             *
461             * 蜈医↓謖?ｮ壹＆繧後◆繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧堤畑縺?※縲∵欠螳壹?繝??繝悶Ν縺ｫ INSERT 縺励∪縺吶?
462             * 蠑墓焚縺ｫ縺ｯ縲々ML繝輔ぃ繧､繝ｫ繧呈欠螳壹＠縺溘Μ繝ｼ繝??繧偵そ繝?ヨ縺励∪縺吶?
463             * 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ縺ｯ縲∫ｵゆｺ?ｾ後?繧ｳ繝溘ャ繝医＆繧後∪縺吶?(close 縺輔ｌ縺ｾ縺帙ｓ縲?
464             * 繝ｪ繝ｼ繝??縺ｮ繧ｯ繝ｭ繝ｼ繧ｺ縺ｯ縲√％縺薙〒縺ｯ陦後▲縺ｦ縺?∪縺帙ｓ縲?
465             *
466             * @og.rev 5.1.1.0 (2009/11/11) insMeta , updMeta 縺ｮ繧ｯ繝ｪ繧｢(豌嶺ｼ代ａ)
467             *
468             * @param       reader  XML繝輔ぃ繧､繝ｫ繧呈欠螳壹☆繧九Μ繝ｼ繝??
469             */
470            public void insertXML( final Reader reader ) {
471                    try {
472                            HybsXMLHandler handler = new HybsXMLHandler();
473                            handler.setTagElementListener( this );
474                            handler.setDefaultMap( defaultMap );
475    
476                            handler.parse( reader );
477                    }
478                    finally {
479                            Closer.stmtClose( insPstmt );
480                            Closer.stmtClose( updPstmt );
481                            insPstmt = null;
482                            updPstmt = null;
483                            insMeta = null;         // 5.1.1.0 (2009/11/11)
484                            updMeta = null;         // 5.1.1.0 (2009/11/11)
485                    }
486            }
487    
488            /**
489             * 繧､繝ｳ繧ｵ繝ｼ繝育畑縺ｮSQL譁?ｒ菴懈?縺励∪縺吶?
490             *
491             * @param       columns 繧､繝ｳ繧ｵ繝ｼ繝医☆繧九き繝ｩ繝?錐
492             * @param       tableName       繧､繝ｳ繧ｵ繝ｼ繝医☆繧九ユ繝ｼ繝悶Ν蜷?
493             *
494             * @return      繧､繝ｳ繧ｵ繝ｼ繝育畑縺ｮSQL譁?
495             */
496            private String insertSQL( final String[] columns,final String tableName ) {
497                    if( tableName == null ) {
498                            String errMsg = "tableName 縺後そ繝?ヨ縺輔ｌ縺ｦ縺?∪縺帙ｓ縲? + CR
499                                                    + "tableName 縺ｯ縲√さ繝ｳ繧ｹ繝医Λ繧ｯ繧ｿ縺ｧ謖?ｮ壹☆繧九°縲ヽOWSET縺ｮtableName螻樊?縺ｧ"
500                                                    + "謖?ｮ壹＠縺ｦ縺翫￥蠢?ｦ√′縺ゅｊ縺ｾ縺? + CR ;
501                            throw new RuntimeException( errMsg );
502                    }
503    
504                    StringBuilder sql = new StringBuilder();
505                    sql.append( "INSERT INTO " ).append( tableName );
506                    sql.append( " ( " );
507                    sql.append( columns[0] );
508                    for( int i=1; i<columns.length; i++ ) {
509                            sql.append( "," ).append( columns[i] );
510                    }
511                    sql.append( " ) VALUES ( " );
512                    sql.append( "?" );
513                    for( int i=1; i<columns.length; i++ ) {
514                            sql.append( "," ).append( "?" );
515                    }
516                    sql.append( " )" );
517    
518                    return sql.toString();
519            }
520    
521            /**
522             * 繝??繧ｿ繝吶?繧ｹ縺ｫ霑ｽ蜉?＠縺滉ｻｶ謨ｰ繧定ｿ斐＠縺ｾ縺吶?
523             *
524             * @return 逋ｻ骭ｲ莉ｶ謨ｰ
525             */
526            public int getInsertCount() { return insCnt; }
527    
528            /**
529             * 繝??繧ｿ繝吶?繧ｹ繧呈峩譁ｰ縺励◆莉ｶ謨ｰ繧定ｿ斐＠縺ｾ縺吶?
530             * 縺薙ｌ縺ｯ縲∵僑蠑ｵXDK蠖｢蠑上〒縲｀ERGE_SQL 繧ｿ繧ｰ繧剃ｽｿ逕ｨ縺励◆蝣ｴ蜷医?譖ｴ譁ｰ蜃ｦ逅?ｻｶ謨ｰ繧?
531             * 蜷郁ｨ医＠縺溷?繧定ｿ斐＠縺ｾ縺吶?
532             *
533             * @return 譖ｴ譁ｰ莉ｶ謨ｰ
534             */
535            public int getUpdateCount() { return updCnt; }
536    
537            /**
538             * 繝??繧ｿ繝吶?繧ｹ縺ｫ螟画峩(譖ｴ譁ｰ縲∝炎髯､繧貞性繧?縺励◆莉ｶ謨ｰ繧定ｿ斐＠縺ｾ縺吶?
539             * 縺薙ｌ縺ｯ縲∵僑蠑ｵXDK蠖｢蠑上〒縲・XEC_SQL 繧ｿ繧ｰ繧剃ｽｿ逕ｨ縺励◆蝣ｴ蜷医?螳溯｡御ｻｶ謨ｰ繧貞粋險医＠縺?
540             * 蛟､繧定ｿ斐＠縺ｾ縺吶?
541             * 繧医▲縺ｦ縲∵峩譁ｰ縺九?霑ｽ蜉?°縲∝炎髯､縺九?縲∝愛繧翫∪縺帙ｓ縺後?騾壼ｸｸ 逋ｻ骭ｲ蜑阪↓蜑企勁縺吶ｋ
542             * 繧ｱ繝ｼ繧ｹ縺ｧ菴ｿ繧上ｌ繧九％縺ｨ縺九ｉ縲‥eleteCount 縺ｨ縺励※縺?∪縺吶?
543             *
544             * @return 螟画峩莉ｶ謨ｰ(荳ｻ縺ｫ縲∝炎髯､莉ｶ謨ｰ)
545             */
546            public int getDeleteCount() { return delCnt; }
547    
548            /**
549             * 繝??繧ｿ繝吶?繧ｹ縺ｫDDL?医ョ繝ｼ繧ｿ螳夂ｾｩ險?ｪ橸ｼ咼ata Definition Language?牙?逅?＠縺滉ｻｶ謨ｰ繧定ｿ斐＠縺ｾ縺吶?
550             * 縺薙ｌ縺ｯ縲∵僑蠑ｵXDK蠖｢蠑上〒縲・XEC_SQL 繧ｿ繧ｰ繧剃ｽｿ逕ｨ縺励◆蝣ｴ蜷医?螳溯｡御ｻｶ謨ｰ繧貞粋險医＠縺?
551             * 蛟､繧定ｿ斐＠縺ｾ縺吶?
552             * EXEC_SQL 縺ｧ縺ｯ縲∫匳骭ｲ蜑阪↓蜑企勁縺吶ｋ delete 蜃ｦ逅?ｂ縲・XEC_SQL 繧ｿ繧ｰ繧剃ｽｿ逕ｨ縺励※螳溯｡後＠縺ｾ縺吶′
553             * 縺昴?蜃ｦ逅?→蛻?￠縺ｦ繧ｫ繧ｦ繝ｳ繝医＠縺ｾ縺吶?
554             *
555             * @og.rev 5.6.7.0 (2013/07/27) DDL?医ョ繝ｼ繧ｿ螳夂ｾｩ險?ｪ橸ｼ咼ata Definition Language?峨?蜃ｦ逅?ｻｶ謨ｰ霑ｽ蜉?
556             *
557             * @return DDL?医ョ繝ｼ繧ｿ螳夂ｾｩ險?ｪ橸ｼ咼ata Definition Language?牙?逅?＠縺滉ｻｶ謨ｰ
558             */
559            public int getDDLCount() { return ddlCnt; }
560    
561            /**
562             * 螳滄圀縺ｫ逋ｻ骭ｲ縺輔ｌ縺?繝??繝悶Ν蜷阪ｒ霑斐＠縺ｾ縺吶?
563             *
564             * 繝??繝悶Ν蜷阪?縲∵僑蠑ｵXDK蠖｢蠑上?ROWSET繧ｿ繧ｰ縺ｮtableName螻樊?縺ｫ
565             * 險倩ｿｰ縺励※縺翫￥縺九?繧ｳ繝ｳ繧ｹ繝医Λ繧ｯ繧ｿ繝ｼ縺ｧ蠑墓焚縺ｨ縺励※貂｡縺励∪縺吶?
566             * 荳｡譁ｹ謖?ｮ壹＆繧後◆蝣ｴ蜷医?縲ヽOWSET繧ｿ繧ｰ縺ｮtableName螻樊?縺悟━蜈医＆繧後∪縺吶?
567             * 縺薙％縺ｧ縺ｮ霑斐ｊ蛟､縺ｯ縲∝ｮ滄圀縺ｫ菴ｿ逕ｨ縺輔ｌ縺?繝??繝悶Ν蜷阪〒縺吶?
568             *
569             * @return 螟画峩莉ｶ謨ｰ(荳ｻ縺ｫ縲∝炎髯､莉ｶ謨ｰ)
570             */
571            public String getTableName() { return tableName; }
572    
573            /**
574             * 縺薙?謗･邯壹′縲￣reparedStatement#getParameterMetaData() 繧剃ｽｿ逕ｨ縺吶ｋ縺九←縺?°繧貞愛螳壹＠縺ｾ縺吶?
575             * 譛ｬ譚･縺ｯ縲，onnectionFactory#useParameterMetaData(String)繧剃ｽｿ縺?∋縺阪□縺後?dbid 縺檎┌縺?◆繧√?逶ｴ謗･蜿門ｾ励＠縺ｾ縺吶?
576             *
577             * @og.rev 5.3.8.0 (2011/08/01) 譁ｰ隕丈ｽ懈? ( ApplicationInfo#useParameterMetaData(Connection) 縺九ｉ繧ｳ繝斐? )
578             * @og.rev 5.6.7.0 (2013/07/27) ProductName 縺ｯ縲．BUtil 邨檎罰縺ｧ蜿門ｾ励☆繧九?
579             *
580             * @param   conn 謗･邯壼?(繧ｳ繝阪け繧ｷ繝ｧ繝ｳ)
581             *
582             * @return      菴ｿ逕ｨ縺吶ｋ蝣ｴ蜷茨ｼ嗾rue / 縺昴?莉?false
583             */
584            private static boolean useParameterMetaData( final Connection conn ) {
585    
586                    String dbProductName = DBUtil.getProductName( conn );
587    
588                    return "PostgreSQL".equalsIgnoreCase( dbProductName ) ;
589    
590    //              try {
591    //                      DatabaseMetaData meta = conn.getMetaData();
592    //                      String dbProductName = meta.getDatabaseProductName();
593    //
594    //                      if( "PostgreSQL".equalsIgnoreCase( dbProductName ) ) { return true; }
595    //
596    //                      return false ;
597    //              }
598    //              catch( SQLException ex ) {
599    //                      String errMsg = "DatabaseMetaData 縺九ｉ縲“etDatabaseProductName 繧貞叙蠕励〒縺阪∪縺帙ｓ縺ｧ縺励◆縲?
600    //                                      + ex.getMessage() + ":" + ex.getSQLState() ;
601    //                      throw new RuntimeException( errMsg,ex );
602    //              }
603            }
604    
605            /**
606             * 繝?せ繝育畑縺ｮ繝｡繧､繝ｳ繝｡繧ｽ繝?ラ
607             *
608             * Usage: java org.opengion.fukurou.xml.HybsXMLSave USER PASSWD URL TABLE FILE [ENCODE] [DRIVER]
609             *    USER    : DB謗･邯壹Θ繝ｼ繧ｶ繝ｼ(GE)
610             *    PASSWD  : DB謗･邯壹ヱ繧ｹ繝ｯ繝ｼ繝?GE)
611             *    URL     : DB謗･邯哽DBC繝峨Λ繧､繝振RL(jdbc:oracle:thin:@localhost:1521:HYBS
612             *    TABLE   : 逋ｻ骭ｲ縺吶ｋ繝??繝悶ΝID(GE21)
613             *    FILE    : 逋ｻ骭ｲ縺吶ｋORACLE XDK 蠖｢蠑?XML繝輔ぃ繧､繝ｫ(GE21.xml)
614             *    [ENCODE]: 繝輔ぃ繧､繝ｫ縺ｮ繧ｨ繝ｳ繧ｳ繝ｼ繝?蛻晄悄蛟､:UTF-8
615             *    [DRIVER]: JDBC繝峨Λ繧､繝舌? 蛻晄悄蛟､:oracle.jdbc.OracleDriver
616             *
617             * 窶ｻ 繝輔ぃ繧､繝ｫ縺悟ｭ伜惠縺励↑縺九▲縺溷?蜷医?FileNotFoundException 繧?RuntimeException 縺ｫ螟画鋤縺励※縲》hrow 縺励∪縺吶?
618             * 窶ｻ 謖?ｮ壹?繧ｨ繝ｳ繧ｳ繝ｼ繝峨′蟄伜惠縺励↑縺九▲縺溷?蜷医?UnsupportedEncodingException 繧?RuntimeException 縺ｫ螟画鋤縺励※縲》hrow 縺励∪縺吶?
619             *
620             * @og.rev 5.1.1.0 (2009/12/01) MySQL蟇ｾ蠢?譏守､ｺ逧?↓縲ゝRANSACTION_READ_COMMITTED 繧呈欠螳壹☆繧九?
621             * @og.rev 5.6.7.0 (2013/07/27) DDL?医ョ繝ｼ繧ｿ螳夂ｾｩ險?ｪ橸ｼ咼ata Definition Language?峨?蜃ｦ逅?ｻｶ謨ｰ霑ｽ蜉?
622             *
623             * @param       args    繧ｳ繝槭Φ繝牙ｼ墓焚驟榊?
624             * @throws ClassNotFoundException 繧ｯ繝ｩ繧ｹ繧定ｦ九▽縺代ｋ縺薙→縺後〒縺阪↑縺九▲縺溷?蜷医?
625             * @throws SQLException 繝??繧ｿ繝吶?繧ｹ謗･邯壹お繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷医?
626             */
627            public static void main( final String[] args )
628                            throws ClassNotFoundException , SQLException {
629                    if( args.length < 5 ) {
630                            LogWriter.log( "Usage: java org.opengion.fukurou.xml.HybsXMLSave USER PASSWD URL TABLE FILE [ENCODE] [DRIVER]" );
631                            LogWriter.log( "   USER  : DB謗･邯壹Θ繝ｼ繧ｶ繝ｼ(GE)" );
632                            LogWriter.log( "   PASSWD: DB謗･邯壹ヱ繧ｹ繝ｯ繝ｼ繝?GE)" );
633                            LogWriter.log( "   URL   : DB謗･邯哽DBC繝峨Λ繧､繝振RL(jdbc:oracle:thin:@localhost:1521:HYBS)" );
634                            LogWriter.log( "   TABLE : 逋ｻ骭ｲ縺吶ｋ繝??繝悶ΝID(GE21)" );
635                            LogWriter.log( "   FILE  : 逋ｻ骭ｲ縺吶ｋORACLE XDK 蠖｢蠑?XML繝輔ぃ繧､繝ｫ(GE21.xml)" );
636                            LogWriter.log( " [ ENCODE: 繝輔ぃ繧､繝ｫ縺ｮ繧ｨ繝ｳ繧ｳ繝ｼ繝?蛻晄悄蛟､:UTF-8 ]" );
637                            LogWriter.log( " [ DRIVER: JDBC繝峨Λ繧､繝舌? 蛻晄悄蛟､:oracle.jdbc.OracleDriver ]" );
638                            return ;
639                    }
640    
641                    String user   = args[0] ;
642                    String passwd = args[1] ;
643                    String url    = args[2] ;
644                    String table  = args[3] ;
645                    String file   = args[4] ;
646                    String encode = ( args.length == 6 ) ? args[5] : "UTF-8"  ;
647                    String driver = ( args.length == 7 ) ? args[6] : "oracle.jdbc.OracleDriver"  ;
648    
649                    Class.forName(driver);
650    
651                    Connection conn = DriverManager.getConnection( url,user,passwd );
652                    Reader reader = null;
653                    int insCnt;
654                    int updCnt;
655                    int delCnt;
656                    int ddlCnt;                     // 5.6.7.0 (2013/07/27) DDL蜃ｦ逅?ｻｶ謨ｰ霑ｽ蜉?
657                    try {
658                            conn.setAutoCommit( false );
659                            conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);  // 5.1.1.0 (2009/12/01)
660                            HybsXMLSave save = new HybsXMLSave( conn,table );
661    
662                            reader = new BufferedReader(new InputStreamReader(
663                                                                    new FileInputStream( file ) ,encode ));
664                            save.insertXML( reader );
665                            insCnt = save.getInsertCount();
666                            updCnt = save.getUpdateCount();
667                            delCnt = save.getDeleteCount();
668                            ddlCnt = save.getDDLCount();            // 5.6.7.0 (2013/07/27) DDL蜃ｦ逅?ｻｶ謨ｰ霑ｽ蜉?
669    
670                            Closer.commit( conn );
671                    }
672                    // FileNotFoundException , UnsupportedEncodingException
673                    catch( java.io.FileNotFoundException ex ) {
674                            String errMsg = "繝輔ぃ繧､繝ｫ縺悟ｭ伜惠縺励∪縺帙ｓ縲? + ex.getMessage()
675                                                            + CR + "Table=[" + table + "] File =[" + file + "]" ;
676                            throw new RuntimeException( errMsg,ex );
677                    }
678                    catch( java.io.UnsupportedEncodingException ex ) {
679                            String errMsg = "謖?ｮ壹?繧ｨ繝ｳ繧ｳ繝ｼ繝峨′蟄伜惠縺励∪縺帙ｓ縲? + ex.getMessage()
680                                                            + CR + "Table=[" + table + "] Encode =[" + encode + "]" ;
681                            throw new RuntimeException( errMsg,ex );
682                    }
683                    finally {
684                            Closer.ioClose( reader );
685                            Closer.connClose( conn );
686                    }
687    
688                    System.out.println( "XML File[" + file + "] Into [" + table + "] Table" );
689                    System.out.println( "   Insert Count : [" + insCnt + "]" );
690                    System.out.println( "   Update Count : [" + updCnt + "]" );
691                    System.out.println( "   Delete Count : [" + delCnt + "]" );
692                    System.out.println( "   DDL    Count : [" + ddlCnt + "]" );
693            }
694    }