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.xml.sax.InputSource;
019    import org.xml.sax.SAXException;
020    import org.xml.sax.Attributes;
021    import org.xml.sax.helpers.DefaultHandler;
022    
023    import javax.xml.parsers.SAXParserFactory;
024    import javax.xml.parsers.SAXParser;
025    import javax.xml.parsers.ParserConfigurationException;
026    
027    import java.io.Reader;
028    import java.io.IOException;
029    import java.util.Map;
030    
031    /**
032     * 縺薙?繧ｯ繝ｩ繧ｹ縺ｯ縲∵僑蠑ｵ繧ｪ繝ｩ繧ｯ繝ｫ XDK蠖｢蠑上?XML繝輔ぃ繧､繝ｫ繧貞?逅?☆繧九ワ繝ｳ繝峨Λ縺ｧ縺吶?
033     * 繧ｪ繝ｩ繧ｯ繝ｫXDK蠖｢蠑上?XML縺ｨ縺ｯ縲∽ｸ玖ｨ倥?繧医≧縺ｪ ROWSET 繧偵ヨ繝??縺ｨ縺吶ｋ ROW 縺ｮ
034     * 髮?∪繧翫〒?代Ξ繧ｳ繝ｼ繝峨ｒ陦ｨ縺励?蜷СOW縺ｫ縺ｯ縲√き繝ｩ繝?錐繧偵く繝ｼ縺ｨ縺吶ｋXML縺ｫ縺ｪ縺｣縺ｦ縺?∪縺吶?
035     *
036     *   &lt;ROWSET&gt;
037     *       &lt;ROW num="1"&gt;
038     *           &lt;繧ｫ繝ｩ繝?&gt;蛟､1&lt;/繧ｫ繝ｩ繝?&gt;
039     *             ?･?･?･
040     *           &lt;繧ｫ繝ｩ繝?&gt;蛟､n&lt;/繧ｫ繝ｩ繝?&gt;
041     *       &lt;/ROW&gt;
042     *        ?･?･?･
043     *       &lt;ROW num="n"&gt;
044     *          ?･?･?･
045     *       &lt;/ROW&gt;
046     *   &lt;ROWSET&gt;
047     *
048     * 縺薙?蠖｢蠑上〒縺ゅｌ縺ｰ縲々DK(Oracle XML Developer's Kit)繧貞茜逕ｨ縺吶ｌ縺ｰ縲?撼蟶ｸ縺ｫ邁｡蜊倥↓
049     * 繝??繧ｿ繝吶?繧ｹ縺ｨXML繝輔ぃ繧､繝ｫ縺ｨ縺ｮ莠､謠帙′蜿ｯ閭ｽ縺ｧ縺吶?
050     * <a href="http://otn.oracle.co.jp/software/tech/xml/xdk/index.html" target="_blank" >
051     * XDK(Oracle XML Developer's Kit)</a>
052     *
053     * 諡｡蠑ｵXDK蠖｢蠑上→縺ｯ縲ヽOW 莉･螟悶↓縲ヾQL蜃ｦ逅?畑繧ｿ繧ｰ(EXEC_SQL)繧呈戟縺､ XML 繝輔ぃ繧､繝ｫ縺ｧ縺吶?
054     * 縺ｾ縺溘?逋ｻ骭ｲ縺吶ｋ繝??繝悶Ν(table)繧?ROWSET繧ｿ繧ｰ縺ｮ螻樊?諠??縺ｨ縺励※莉倅ｸ弱☆繧九％縺ｨ縺後〒縺阪∪縺吶?
055     * (螟ｧ譁?ｭ怜ｰ乗枚蟄励↓豕ｨ諢?
056     * 縺薙ｌ縺ｯ縲√が繝ｩ繧ｯ繝ｫXDK縺ｧ蜃ｦ逅?☆繧句?蜷医?辟｡隕悶＆繧後∪縺吶?縺ｧ縲∝酔讒倥↓謇ｱ縺?％縺ｨ縺悟?譚･縺ｾ縺吶?
057     * 縺薙?縲・XEC_SQL 縺ｯ縲√◎繧後◎繧後? XML繝??繧ｿ繧偵ョ繝ｼ繧ｿ繝吶?繧ｹ縺ｫ逋ｻ骭ｲ縺吶ｋ髫帙↓縲?
058     * SQL蜃ｦ逅?ｒ閾ｪ蜍慕噪縺ｫ豬√☆轤ｺ縺ｮ縲ヾQL譁?ｒ險倩ｼ峨＠縺ｾ縺吶?
059     * 縺薙?蜃ｦ逅??縲√う繝吶Φ繝域ｯ弱↓螳溯｡後＆繧後ｋ轤ｺ縲√◎縺ｮ驟咲ｽｮ鬆??驥崎ｦ√〒縺吶?
060     * 縺薙?繧ｿ繧ｰ縺ｯ縲∬､?焚險倩ｿｰ縺吶ｋ縺薙→繧ょ?譚･縺ｾ縺吶′縲。ODY驛ｨ縺ｫ縺ｯ縲?ｼ代▽縺ｮSQL譁??縺ｿ險倩ｿｰ縺励∪縺吶?
061     *
062     *   &lt;ROWSET tableName="XX" &gt;
063     *       &lt;EXEC_SQL&gt;                    譛??縺ｫ險倩ｼ峨＠縺ｦ縲∝?譛溷?逅?繝??繧ｿ繧ｯ繝ｪ繧｢遲?繧貞ｮ溯｡後＆縺帙ｋ縲?
064     *           delete from GEXX where YYYYY
065     *       &lt;/EXEC_SQL&gt;
066     *       &lt;MERGE_SQL&gt;                   縺薙?SQL譁?〒 UPDATE縺励※縲∫ｵ先棡縺鯉ｼ蝉ｻｶ縺ｪ繧迂NSERT繧定｡後＞縺ｾ縺吶?
067     *           update GEXX set AA=[AA] , BB=[BB] where CC=[CC]
068     *       &lt;/MERGE_SQL&gt;
069     *       &lt;ROW num="1"&gt;
070     *           &lt;繧ｫ繝ｩ繝?&gt;蛟､1&lt;/繧ｫ繝ｩ繝?&gt;
071     *             ?･?･?･
072     *           &lt;繧ｫ繝ｩ繝?&gt;蛟､n&lt;/繧ｫ繝ｩ繝?&gt;
073     *       &lt;/ROW&gt;
074     *        ?･?･?･
075     *       &lt;ROW num="n"&gt;
076     *          ?･?･?･
077     *       &lt;/ROW&gt;
078     *       &lt;EXEC_SQL&gt;                    譛?ｾ後↓險倩ｼ峨＠縺ｦ縲??逶ｮ縺ｮ險ｭ螳?謨ｴ蜷域?逋ｻ骭ｲ)繧定｡後≧縲?
079     *           update GEXX set AA='XX' , BB='YY' where CC='ZZ'
080     *       &lt;/EXEC_SQL&gt;
081     *   &lt;ROWSET&gt;
082     *
083     * DefaultHandler 繧ｯ繝ｩ繧ｹ繧呈僑蠑ｵ縺励※縺?ｋ轤ｺ縲??蟶ｸ縺ｮ蜃ｦ逅?→蜷梧ｧ倥↓縲∽ｽｿ逕ｨ縺ｧ縺阪∪縺吶?
084     *
085     *      InputSource input = new InputSource( reader );
086     *      HybsXMLHandler hndler = new HybsXMLHandler();
087     *
088     *      SAXParserFactory f = SAXParserFactory.newInstance();
089     *      SAXParser parser = f.newSAXParser();
090     *      parser.parse( input,hndler );
091     *
092     * 縺ｾ縺溘?荳願ｨ倥?蜃ｦ逅?◎縺ｮ繧ゅ?繧堤ｰ｡逡･蛹悶＠縺溘Γ繧ｽ繝?ラ:parse( Reader ) 繧呈戟縺｣縺ｦ縺?ｋ縺溘ａ縲?
093     * 騾壼ｸｸ縺昴?繝｡繧ｽ繝?ラ繧剃ｽｿ逕ｨ縺励∪縺吶?
094     *
095     * HybsXMLHandler 縺ｫ縺ｯ縲ゝagElementListener 繧偵そ繝?ヨ縺吶ｋ縺薙→縺後〒縺阪∪縺吶?
096     * 縺薙ｌ縺ｯ縲ヽOW 豈弱↓ 蜀?Κ諠??繧?TagElement 繧ｪ繝悶ず繧ｧ繧ｯ繝亥喧縺励?action( TagElement )
097     * 縺悟他縺ｳ蜃ｺ縺輔ｌ縺ｾ縺吶?縺薙? Listener 繧剃ｻ九＠縺ｦ縲?ｼ代Ξ繧ｳ繝ｼ繝峨★縺､蜃ｦ逅?☆繧九％縺ｨ縺?
098     * 蜿ｯ閭ｽ縺ｧ縺吶?
099     *
100     * @version  4.0
101     * @author   Kazuhiko Hasegawa
102     * @since    JDK5.0,
103     */
104    public class HybsXMLHandler extends DefaultHandler {
105            /** 繧ｷ繧ｹ繝?Β萓晏ｭ倥?謾ｹ陦瑚ｨ伜捷繧偵そ繝?ヨ縺励∪縺吶?     */
106            private static final String CR = System.getProperty("line.separator");
107    
108            /** 縺薙?繝上Φ繝峨Λ縺ｮ繝医ャ繝励ち繧ｰ蜷?       {@value}        */
109            public static final     String ROWSET           = "ROWSET";
110            /** 縺薙?繝上Φ繝峨Λ縺ｧ蜿悶ｊ謇ｱ縺医ｋ ROWSET繧ｿ繧ｰ縺ｮ螻樊?         */
111            public static final     String ROWSET_TABLE = "tableName";
112    
113            /** 縺薙?繝上Φ繝峨Λ縺ｧ蜿悶ｊ謇ｱ縺医ｋ繧ｿ繧ｰ蜷?   {@value}        */
114            public static final     String ROW                      = "ROW";
115            /** 縺薙?繝上Φ繝峨Λ縺ｧ蜿悶ｊ謇ｱ縺医ｋ ROW繧ｿ繧ｰ縺ｮ螻樊?    {@value}        */
116            public static final     String ROW_NUM          = "num";
117            /** 縺薙?繝上Φ繝峨Λ縺ｧ蜿悶ｊ謇ｱ縺医ｋ繧ｿ繧ｰ蜷?   {@value}        */
118            public static final     String EXEC_SQL         = "EXEC_SQL";
119            /** 縺薙?繝上Φ繝峨Λ縺ｧ蜿悶ｊ謇ｱ縺医ｋ繧ｿ繧ｰ蜷?   {@value}        */
120            public static final     String MERGE_SQL        = "MERGE_SQL";
121    
122            private Map<String,String>        defaultMap      = null;
123            private TagElementListener listener     = null;
124            private TagElement              element         = null;
125            private String                  key                     = null;
126            private StringBuilder   body            = null;
127            private boolean                 bodyIn          = false;
128            private int                             level           = 0;
129    
130            /**
131             *      繝代?繧ｹ蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
132             *      騾壼ｸｸ縺ｮ繝代?繧ｹ蜃ｦ逅??邁｡譏薙Γ繧ｽ繝?ラ縺ｫ縺ｪ縺｣縺ｦ縺?∪縺吶?
133             *
134             * @param reader 繝代?繧ｹ蜃ｦ逅?畑縺ｮReader繧ｪ繝悶ず繧ｧ繧ｯ繝?
135             */
136            public void parse( final Reader reader ) {
137                    try {
138                            SAXParserFactory fact = SAXParserFactory.newInstance();
139                            SAXParser parser = fact.newSAXParser();
140    
141                            InputSource input = new InputSource( reader );
142    
143                            try {
144                                    parser.parse( input,this );
145                            }
146                            catch( SAXException ex ) {
147                                    if( ! "END".equals( ex.getMessage() ) ) {
148                                            String errMsg = "XML繝代?繧ｹ繧ｨ繝ｩ繝ｼ key=" + key + CR
149                                                                    + "element=" + element + CR
150                                                                    + ex.getMessage() ;
151                                            if( body != null ) {
152                                                    errMsg = errMsg + CR + body.toString();
153                                            }
154                                            throw new RuntimeException( errMsg,ex );
155                                    }
156                            }
157                    }
158                    catch( ParserConfigurationException ex1 ) {
159                            String errMsg = "SAXParser 縺ｮ繧ｳ繝ｳ繝輔ぅ繧ｰ繝ｬ繝ｼ繧ｷ繝ｧ繝ｳ縺梧ｧ狗ｯ峨〒縺阪∪縺帙ｓ縲?
160                                                    + "key=" + key + CR + ex1.getMessage();
161                            throw new RuntimeException( errMsg,ex1 );
162                    }
163                    catch( SAXException ex2 ) {
164                            String errMsg = "SAXParser 縺梧ｧ狗ｯ峨〒縺阪∪縺帙ｓ縲?
165                                                    + "key=" + key + CR + ex2.getMessage();
166                            throw new RuntimeException( errMsg,ex2 );
167                    }
168                    catch( IOException ex3 ) {
169                            String errMsg = "InputSource 縺ｮ隱ｭ縺ｿ蜿悶ｊ譎ゅ↓繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺ｾ縺励◆縲?
170                                                    + "key=" + key + CR + ex3.getMessage();
171                            throw new RuntimeException( errMsg,ex3 );
172                    }
173            }
174    
175            /**
176             * 蜀?Κ縺ｫ TagElementListener 繧堤匳骭ｲ縺励∪縺吶?
177             * 縺薙ｌ縺ｯ縲?lt;ROW&gt; 繧ｿ繧ｰ縺ｮ endElement 蜃ｦ逅?ｯ弱↓蜻ｼ縺ｳ蜃ｺ縺輔ｌ縺ｾ縺吶?
178             * 縺､縺ｾ繧翫?陦後ョ繝ｼ繧ｿ繧貞叙蠕鈴?蠎ｦ縲ゝagElement 繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ菴懈?縺励?
179             * 縺薙? TagElementListener 縺ｮ action( TagElement ) 繝｡繧ｽ繝?ラ繧貞他縺ｳ蜃ｺ縺励∪縺吶?
180             * 菴輔ｂ繧ｻ繝?ヨ縺励↑縺??縺ｾ縺溘?縲］ull 縺後そ繝?ヨ縺輔ｌ縺溷?蜷医?縲∽ｽ輔ｂ縺励∪縺帙ｓ縲?
181             *
182             * @param listener TagElementListener繧ｪ繝悶ず繧ｧ繧ｯ繝?
183             */
184            public void setTagElementListener( final TagElementListener listener ) {
185                    this.listener = listener;
186            }
187    
188            /**
189             * TagElement 繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ菴懈?縺吶ｋ譎ゅ? 蛻晄悄繧ｫ繝ｩ繝?蛟､繧定ｨｭ螳壹＠縺ｾ縺吶?
190             * TagElements 繧ｪ繝悶ず繧ｧ繧ｯ繝医?縲々ML繝輔ぃ繧､繝ｫ繧医ｊ菴懈?縺吶ｋ轤ｺ縲??逶ｮ(繧ｫ繝ｩ繝?繧?
191             * XML繝輔ぃ繧､繝ｫ縺ｮROW螻樊?縺ｫ謖√▲縺ｦ縺?ｋ鬆?岼縺ｨ蛟､縺ｧ菴懈?縺輔ｌ縺ｾ縺吶?
192             * 縺薙?繧ｫ繝ｩ繝?錐繧偵?螟夜Κ縺九ｉ蛻晄悄險ｭ螳壹☆繧九％縺ｨ縺悟庄閭ｽ縺ｧ縺吶?
193             * 縺昴?蝣ｴ蜷医?縺薙％縺ｧ逋ｻ骭ｲ縺励◆繧ｫ繝ｩ繝??(Map縺ｫ縲´inkedHashMap 繧剃ｽｿ逕ｨ縺励◆蝣ｴ蜷?
194             * 縺御ｿ晄戟縺輔ｌ縺ｾ縺吶?縺ｾ縺溘?ROW螻樊?縺ｫ蟄伜惠縺励↑縺?き繝ｩ繝?′縺ゅｌ縺ｰ縲∝?縺ｨ縺ｨ繧ゅ↓
195             * 蛻晄悄蛟､縺ｨ縺励※險ｭ螳壹＠縺ｦ縺翫￥縺薙→縺悟庄閭ｽ縺ｧ縺吶?
196             * 縺ｪ縺翫?縺薙％縺ｧ縺ｮMap縺ｯ縲∫峩謗･險ｭ螳壹＠縺ｦ縺?∪縺吶?縺ｧ縲√＃豕ｨ諢上￥縺?＆縺??
197             *
198             * @param       map     蛻晄悄繧ｫ繝ｩ繝??繝??
199             */
200            public void setDefaultMap( final Map<String,String> map ) {
201                    defaultMap = map;
202            }
203    
204            /**
205             * 隕∫ｴ??縺ｮ譁?ｭ励ョ繝ｼ繧ｿ縺ｮ騾夂衍繧貞女縺大叙繧翫∪縺吶?
206             * 繧､繝ｳ繧ｿ繝輔ぉ繝ｼ繧ｹ ContentHandler 蜀?? characters 繝｡繧ｽ繝?ラ繧偵が繝ｼ繝舌?繝ｩ繧､繝峨＠縺ｦ縺?∪縺吶?
207             * 蜷?枚蟄励ョ繝ｼ繧ｿ繝√Ε繝ｳ繧ｯ縺ｫ蟇ｾ縺励※迚ｹ谿翫↑繧｢繧ｯ繧ｷ繝ｧ繝ｳ (繝弱?繝峨∪縺溘?繝舌ャ繝輔ぃ縺ｸ縺ｮ繝??繧ｿ縺ｮ霑ｽ蜉??
208             * 繝??繧ｿ縺ｮ繝輔ぃ繧､繝ｫ縺ｸ縺ｮ蜃ｺ蜉帙↑縺ｩ) 繧貞ｮ溯｡後☆繧九％縺ｨ縺後〒縺阪∪縺吶?
209             *
210             * @param       buffer  譁?ｭ励ョ繝ｼ繧ｿ驟榊?
211             * @param       start   驟榊?蜀??髢句ｧ倶ｽ咲ｽｮ
212             * @param       length  驟榊?縺九ｉ隱ｭ縺ｿ蜿悶ｉ繧後ｋ譁?ｭ玲焚
213             * @see org.xml.sax.helpers.DefaultHandler#characters(char[] , int , int )
214             */
215            @Override
216            public void characters( final char[] buffer, final int start, final int length ) throws SAXException {
217                    if( ! ROW.equals( key ) && ! ROWSET.equals( key ) && length > 0 ) {
218                            body.append( buffer,start,length );
219                            bodyIn = true;
220                    }
221            }
222    
223            /**
224             * 隕∫ｴ??髢句ｧ矩?遏･繧貞女縺大叙繧翫∪縺吶?
225             * 繧､繝ｳ繧ｿ繝輔ぉ繝ｼ繧ｹ ContentHandler 蜀?? startElement 繝｡繧ｽ繝?ラ繧偵が繝ｼ繝舌?繝ｩ繧､繝峨＠縺ｦ縺?∪縺吶?
226             * 繝代?繧ｵ縺ｯ XML 譁?嶌蜀??蜷?ｦ∫ｴ??蜑阪〒縺薙?繝｡繧ｽ繝?ラ繧貞他縺ｳ蜃ｺ縺励∪縺吶?
227             * 蜷?startElement 繧､繝吶Φ繝医↓縺ｯ蟇ｾ蠢懊☆繧?endElement 繧､繝吶Φ繝医′縺ゅｊ縺ｾ縺吶?
228             * 縺薙ｌ縺ｯ縲∬ｦ∫ｴ?′遨ｺ縺ｧ縺ゅｋ蝣ｴ蜷医ｂ螟峨ｏ繧翫∪縺帙ｓ縲ょｯｾ蠢懊☆繧?endElement 繧､繝吶Φ繝医?蜑阪↓縲?
229             * 隕∫ｴ??繧ｳ繝ｳ繝?Φ繝??驛ｨ縺碁?逡ｪ縺ｫ蝣ｱ蜻翫＆繧後∪縺吶?
230             * 縺薙％縺ｧ縺ｯ縲√ち繧ｰ縺後Ξ繝吶Ν?謎ｻ･荳翫?蝣ｴ蜷医?縲∽ｸ贋ｽ阪ち繧ｰ縺ｮ蜀?ｮｹ縺ｨ縺励※蜿悶ｊ謇ｱ縺?∪縺吶?繧医▲縺ｦ縲?
231             * 繧ｿ繧ｰ縺ｫ蜷榊燕遨ｺ髢薙′螳夂ｾｩ縺輔ｌ縺ｦ縺?ｋ蝣ｴ蜷医?縺昴?螻樊?縺ｯ蜑企勁縺励∪縺吶?
232             *
233             * @param       namespace       蜷榊燕遨ｺ髢??ｵ?ｲ?ｩ
234             * @param       localName       蜑咲ｽｮ菫ｮ鬟ｾ蟄舌ｒ蜷ｫ縺ｾ縺ｪ縺?Ο繝ｼ繧ｫ繝ｫ蜷阪?蜷榊燕遨ｺ髢灘?逅?′陦後ｏ繧後↑縺??蜷医?遨ｺ譁?ｭ怜?
235             * @param       qname           蜑咲ｽｮ菫ｮ鬟ｾ蟄舌ｒ謖√▽菫ｮ鬟ｾ蜷阪?菫ｮ鬟ｾ蜷阪ｒ菴ｿ逕ｨ縺ｧ縺阪↑縺??蜷医?遨ｺ譁?ｭ怜?
236             * @param       attributes      隕∫ｴ?↓莉伜刈縺輔ｌ縺溷ｱ樊?縲ょｱ樊?縺悟ｭ伜惠縺励↑縺??蜷医?遨ｺ縺ｮ Attributes繧ｪ繝悶ず繧ｧ繧ｯ繝?
237             * @see org.xml.sax.helpers.DefaultHandler#startElement(String , String , String , Attributes )
238             */
239            @Override
240            public void startElement(final String namespace, final String localName,
241                                                             final String qname, final Attributes attributes) throws SAXException {
242                    if( ROWSET.equals( qname ) ) {
243                            if( listener != null ) {
244                                    element = new TagElement( ROWSET,defaultMap );
245                                    element.put( ROWSET_TABLE,attributes.getValue( ROWSET_TABLE ) );
246                                    listener.actionInit( element );
247                            }
248                            element = null;
249                    }
250                    else if( ROW.equals( qname ) ) {
251                            element = new TagElement( ROW,defaultMap );
252                            String num = attributes.getValue( ROW_NUM );
253                            element.setRowNo( num );
254                    }
255                    else if( EXEC_SQL.equals( qname ) ) {
256                            element = new TagElement( EXEC_SQL );
257                    }
258                    else if( MERGE_SQL.equals( qname ) ) {
259                            element = new TagElement( MERGE_SQL );
260                    }
261    
262                    if( level <= 2 ) {
263                            key = qname;
264                            body = new StringBuilder();
265                    }
266                    else {
267                            // 繝ｬ繝吶Ν??莉･荳翫?繧ｿ繧ｰ縺ｯ荳贋ｽ阪ち繧ｰ縺ｮ蜀?ｮｹ縺ｨ縺励※謇ｱ縺?∪縺吶?
268                            body.append( "<" ).append( qname );
269                            int len = attributes.getLength();
270                            for( int i=0; i<len; i++ ) {
271                                    // 蜷榊燕遨ｺ髢薙?螳｣險??縲∝炎髯､縺励※縺翫″縺ｾ縺吶?縺ゅ￥縺ｾ縺ｧ繝??繧ｿ縺ｨ縺励※蜿悶ｊ謇ｱ縺?ぜ縺ｧ縺吶?
272                                    String attr = attributes.getQName(i);
273                                    if( ! attr.startsWith( "xmlns:" ) ) {
274                                            body.append( " " );
275                                            body.append( attr ).append( "=\"" );
276                                            body.append( attributes.getValue(i) ).append( "\"" );
277                                    }
278                            }
279                            body.append( ">" );
280                    }
281    
282                    bodyIn = false;         // 蜈･繧悟ｭ千憾縺ｮ繧ｿ繧ｰ縺ｮBODY驛ｨ縺ｮ譛臥┌
283                    level ++ ;
284            }
285    
286            /**
287             * 隕∫ｴ??邨ゆｺ??遏･繧貞女縺大叙繧翫∪縺吶?
288             * 繧､繝ｳ繧ｿ繝輔ぉ繝ｼ繧ｹ ContentHandler 蜀?? endElement 繝｡繧ｽ繝?ラ繧偵が繝ｼ繝舌?繝ｩ繧､繝峨＠縺ｦ縺?∪縺吶?
289             * SAX 繝代?繧ｵ縺ｯ縲々ML 譁?嶌蜀??蜷?ｦ∫ｴ??邨ゅｏ繧翫↓縺薙?繝｡繧ｽ繝?ラ繧貞他縺ｳ蜃ｺ縺励∪縺吶?
290             * 蜷?endElement 繧､繝吶Φ繝医↓縺ｯ蟇ｾ蠢懊☆繧?startElement 繧､繝吶Φ繝医′縺ゅｊ縺ｾ縺吶?
291             * 縺薙ｌ縺ｯ縲∬ｦ∫ｴ?′遨ｺ縺ｧ縺ゅｋ蝣ｴ蜷医ｂ螟峨ｏ繧翫∪縺帙ｓ縲?
292             *
293             * @param       namespace       蜷榊燕遨ｺ髢?URI
294             * @param       localName       蜑咲ｽｮ菫ｮ鬟ｾ蟄舌ｒ蜷ｫ縺ｾ縺ｪ縺?Ο繝ｼ繧ｫ繝ｫ蜷阪?蜷榊燕遨ｺ髢灘?逅?′陦後ｏ繧後↑縺??蜷医?遨ｺ譁?ｭ怜?
295             * @param       qname   蜑咲ｽｮ菫ｮ鬟ｾ蟄舌ｒ謖√▽ XML 1.0 菫ｮ鬟ｾ蜷阪?菫ｮ鬟ｾ蜷阪ｒ菴ｿ逕ｨ縺ｧ縺阪↑縺??蜷医?遨ｺ譁?ｭ怜?
296             * @see org.xml.sax.helpers.DefaultHandler#endElement(String , String , String )
297             */
298            @Override
299            public void endElement(final String namespace, final String localName, final String qname) throws SAXException {
300                    level -- ;
301                    if( ROW.equals( qname ) ) {
302                            if( listener != null ) {
303                                    listener.actionRow( element );
304                            }
305                            element = null;
306                    }
307                    else if( EXEC_SQL.equals( qname ) ) {
308                            element.setBody( body.toString().trim() );
309                            if( listener != null ) {
310                                    listener.actionExecSQL( element );
311                            }
312                            element = null;
313                    }
314                    else if( MERGE_SQL.equals( qname ) ) {
315                            element.setBody( body.toString().trim() );
316                            if( listener != null ) {
317                                    listener.actionMergeSQL( element );
318                            }
319                            element = null;
320                    }
321                    else if( level <= 2 ) {
322                            if( element != null ) {
323                                    element.put( key , body.toString().trim() );
324                            }
325                    }
326                    else {
327                            if( bodyIn ) {
328                                    body.append( "</" ).append( qname ).append( ">" );
329                            }
330                            else {
331                                    body.insert( body.length()-1, " /" );           // 繧ｿ繧ｰ縺ｮ譛?ｾ後ｒ " />" 縺ｨ縺吶ｋ縲?
332                            }
333                    }
334            }
335    }