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.taglib;
017    
018    import org.opengion.hayabusa.common.HybsSystem;
019    import org.opengion.hayabusa.common.HybsSystemException;
020    import org.opengion.hayabusa.db.DBTableModel;
021    import org.opengion.hayabusa.db.Query;
022    import org.opengion.hayabusa.resource.GUIInfo;
023    
024    import org.opengion.fukurou.util.StringUtil ;
025    import static org.opengion.fukurou.util.StringUtil.nval ;
026    
027    /**
028     * 縲仙ｻ?ｭ｢縲全QL譁?ｒ逶ｴ謗･謖?ｮ壹＠縺ｦ縲√ョ繝ｼ繧ｿ繝吶?繧ｹ縺ｫ霑ｽ蜉?譖ｴ譁ｰ/蜑企勁繧定｡後＞縺ｾ縺?queryType="JDBCPrepared")縲?
029     *
030     * 蟄伜惠繝√ぉ繝?け繧定｡後≧蝣ｴ蜷医?縲》ableExist 繧ｿ繧ｰ縺ｨ菴ｵ逕ｨ縺励※縺上□縺輔＞縲?
031     * 隍?尅縺ｪ蜃ｦ逅?′蠢?ｦ√↑蝣ｴ蜷医?縲∝ｾ捺擂繧医ｊ菴ｿ逕ｨ縺励※縺?∪縺吶?PLSQL繧辰ALL縺吶ｋ縲?
032     * plsqlUpdate繧ｿ繧ｰ繧剃ｽｿ逕ｨ縺励※縺上□縺輔＞縲?
033     *
034     * 窶ｻ 縺薙?繧ｿ繧ｰ縺ｯ縲ゝransaction 繧ｿ繧ｰ縺ｮ蟇ｾ雎｡縺ｧ縺吶?
035     *
036     * @og.formSample
037     * 笳丞ｽ｢蠑擾ｼ?lt;og:update command="窶ｦ" names="窶ｦ" queryType="JDBCPrepared" &gt;
038     *             {&#064;SQL}
039     *         &lt;/og:update&gt;
040     * 笳獣ody?壹≠繧?EVAL_BODY_BUFFERED:BODY繧定ｩ穂ｾ｡縺励?{&#064;XXXX} 繧定ｧ｣譫舌＠縺ｾ縺?
041     *
042     * 笳週ag螳夂ｾｩ??
043     *   &lt;og:update
044     *       queryType          縲仙ｻ?ｭ｢縲漸uery 繧堤匱陦後☆繧狗ぜ縺ｮ繧ｯ繝ｩ繧ｹID繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:JDBCPrepared)
045     *       command            縲慎AG縲代さ繝槭Φ繝?NEW,RENEW)繧偵そ繝?ヨ縺励∪縺?PlsqlUpdateTag,UpdateTag 縺ｮ蝣ｴ蜷医?縲・NTRY)
046     *       scope              縲慎AG縲代く繝｣繝?す繝･縺吶ｋ蝣ｴ蜷医?繧ｹ繧ｳ繝ｼ繝夕request/page/session/applicaton]繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:session)
047     *       displayMsg         縲慎AG縲第､懃ｴ｢邨先棡繧堤判髱｢荳翫↓陦ｨ遉ｺ縺吶ｋ繝｡繝?そ繝ｼ繧ｸ繝ｪ繧ｽ繝ｼ繧ｹID繧呈欠螳壹＠縺ｾ縺?(蛻晄悄蛟､:VIEW_DISPLAY_MSG[=])
048     *       names              縲慎AG縲善L/SQL繧貞茜逕ｨ縺吶ｋ蝣ｴ蜷医?蠑墓焚縺ｫ繧ｻ繝?ヨ縺吶∋縺?繝??繧ｿ縺ｮ蜷咲ｧｰ繧辰SV蠖｢蠑上〒隍?焚謖?ｮ壹＠縺ｾ縺?
049     *       quotCheck          縲慎AG縲代Μ繧ｯ繧ｨ繧ｹ繝域ュ蝣ｱ縺ｮ 繧ｯ繧ｩ繝ｼ繝?ぅ繧ｷ繝ｧ繝ｳ(') 蟄伜惠繝√ぉ繝?け繧貞ｮ滓命縺吶ｋ縺九←縺?°[true/false]繧定ｨｭ螳壹＠縺ｾ縺?蛻晄悄蛟､:USE_SQL_INJECTION_CHECK)
050     *       tableId            縲慎AG縲?騾壼ｸｸ縺ｯ菴ｿ縺?∪縺帙ｓ)邨先棡縺ｮDBTableModel繧偵?session縺ｫ逋ｻ骭ｲ縺吶ｋ縺ｨ縺阪?繧ｭ繝ｼ繧呈欠螳壹＠縺ｾ縺?
051     *       dbid               縲慎AG縲?騾壼ｸｸ縺ｯ菴ｿ縺?∪縺帙ｓ)Query繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ菴懈?縺吶ｋ譎ゅ?DB謗･邯唔D繧呈欠螳壹＠縺ｾ縺?
052     *       xssCheck           縲慎AG縲代Μ繧ｯ繧ｨ繧ｹ繝域ュ蝣ｱ縺ｮ HTMLTag髢句ｧ?邨ゆｺ?枚蟄?&gt;&lt;) 蟄伜惠繝√ぉ繝?け繧貞ｮ滓命縺吶ｋ縺九←縺?°[true/false]繧定ｨｭ螳壹＠縺ｾ縺?(蛻晄悄蛟､:USE_XSS_CHECK[=true])
053     *       debug              縲慎AG縲代ョ繝舌ャ繧ｰ諠??繧貞?蜉帙☆繧九°縺ｩ縺?°[true/false]繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:false)
054     *   &gt;   ... Body ...
055     *   &lt;/og:update&gt;
056     *
057     * 笳丈ｽｿ逕ｨ萓?
058     *    繝ｻ蠑墓焚/繝励Ο繧ｷ繧ｸ繝｣繝ｼ繧剃ｻ悶?JSP縺九ｉ貂｡縺吝?蜷?
059     *    縲芯opy.jsp縲?
060     *        &lt;og:value scope=&quot;session&quot; key=&quot;names&quot; value=&quot;CLM,NAME_JA,LABEL_NAME,KBSAKU,SYSTEM_ID,LANG&quot; /&gt;
061     *        &lt;og:value scope=&quot;session&quot; key=&quot;SQL&quot; &gt;
062     *          INSERT INTO GE41
063     *               (CLM,NAME_JA,LABEL_NAME,KBSAKU,SYSTEM_ID,LANG,
064     *               FGJ,DYSET,DYUPD,USRSET,USRUPD,PGUPD)
065     *          VALUES
066     *               (?,?,?,?,?,?,
067     *               &#39;1&#39;,&#39;{&#064;USER.YMDH}&#39;,&#39;{&#064;USER.YMDH}&#39;,&#39;{&#064;USER.ID}&#39;,&#39;{&#064;USER.ID}&#39;,&#39;{&#064;GUI.KEY}&#39;)
068     *        &lt;/og:value&gt;
069     *
070     *    縲親ntry.jsp縲?
071     *        &lt;og:update
072     *            command   = &quot;{&#064;command}&quot;
073     *            queryType = &quot;JDBCPrepared&quot;
074     *            names     = &quot;{&#064;names}&quot;  &gt;
075     *        {&#064;SQL}
076     *        &lt;/og:update&gt;
077     *
078     *        &lt;!-- 蜑咲判髱｢縺ｧ謖?ｮ壹?SQL譁?ｒ蜑企勁縺励∪縺吶?(scope=&quot;session&quot;縺ｪ縺ｮ縺ｧ蜑企勁縺悟ｿ?ｦ√?) --&gt;
079     *        &lt;og:value scope=&quot;session&quot; key=&quot;names&quot; command=&quot;REMOVE&quot; /&gt;
080     *        &lt;og:value scope=&quot;session&quot; key=&quot;SQL&quot;   command=&quot;REMOVE&quot; /&gt;
081     *
082     *    繝ｻ蠑墓焚/繝励Ο繧ｷ繧ｸ繝｣繝ｼ繧堤峩謗･譖ｸ縺丞?蜷?
083     *    縲親ntry.jsp縲?
084     *        &lt;og:update
085     *            command   = &quot;{&#064;command}&quot;
086     *            queryType = &quot;JDBCPrepared&quot;
087     *            names     = &quot;CLM,NAME_JA,LABEL_NAME,KBSAKU,SYSTEM_ID,LANG&quot;
088     *        &gt;
089     *            INSERT INTO GE41
090     *                (CLM,NAME_JA,LABEL_NAME,KBSAKU,SYSTEM_ID,LANG,
091     *                 FGJ,DYSET,DYUPD,USRSET,USRUPD,PGUPD)
092     *            VALUES
093     *                (?,?,?,?,?,?,
094     *                 &#39;1&#39;,&#39;{&#064;USER.YMDH}&#39;,&#39;{&#064;USER.YMDH}&#39;,&#39;{&#064;USER.ID}&#39;,&#39;{&#064;USER.ID}&#39;,&#39;{&#064;GUI.KEY}&#39;)
095     *        &lt;/og:update&gt;
096     *
097     * @og.rev 4.0.0.0 (2005/01/31) 蟒?ｭ｢
098     * @og.group (蟒?ｭ｢)?､?｢逋ｻ骭ｲ
099     *
100     * @deprecated 4.0.0 (2005/01/31) 蟒?ｭ｢縲ＵableUpdate 繧貞茜逕ｨ縺吶ｋ繧医≧縺ｫ縺励※縺上□縺輔＞縲?
101     * @version  4.0
102     * @author   Kazuhiko Hasegawa
103     * @since    JDK5.0,
104     */
105    @Deprecated public class UpdateTag extends QueryTag {
106            //* 縺薙?繝励Ο繧ｰ繝ｩ繝??VERSION譁?ｭ怜?繧定ｨｭ螳壹＠縺ｾ縺吶?       {@value} */
107            private static final String VERSION = "4.0.0.0 (2005/01/31)" ;
108    
109            private static final long serialVersionUID = 400020050131L ;
110    
111            /** command 蠑墓焚縺ｫ貂｡縺吩ｺ九?蜃ｺ譚･繧?繧ｳ繝槭Φ繝? 逋ｻ骭ｲ{@value} */
112            public static final String CMD_ENTRY  = "ENTRY" ;
113            /** command 蠑墓焚縺ｫ貂｡縺吩ｺ九?蜃ｺ譚･繧?繧ｳ繝槭Φ繝?繝ｪ繧ｹ繝? */
114            private static final String COMMAND_LIST = CMD_ENTRY;
115    
116            /**
117             * Taglib縺ｮ髢句ｧ九ち繧ｰ縺瑚ｦ九▽縺九▲縺溘→縺阪↓蜃ｦ逅?☆繧?doStartTag() 繧?繧ｪ繝ｼ繝舌?繝ｩ繧､繝峨＠縺ｾ縺吶?
118             *
119             * @return      蠕檎ｶ壼?逅??謖?､ｺ
120             */
121            @Override
122            public int doStartTag() {
123                    dyStart = System.currentTimeMillis();
124    
125                    table = (DBTableModel)getObject( tableId );
126                    if( table == null || table.getRowCount() == 0 ||
127                            ! check( command, COMMAND_LIST ) ) { return(SKIP_BODY); }
128                    return( EVAL_BODY_BUFFERED );   // Body 繧定ｩ穂ｾ｡縺吶ｋ縲? extends BodyTagSupport 譎?
129            }
130    
131            /**
132             * Taglib縺ｮ邨ゆｺ?ち繧ｰ縺瑚ｦ九▽縺九▲縺溘→縺阪↓蜃ｦ逅?☆繧?doEndTag() 繧?繧ｪ繝ｼ繝舌?繝ｩ繧､繝峨＠縺ｾ縺吶?
133             *
134             * @og.rev 3.5.5.8 (2004/05/20) ErrorMessage 繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ縲∵ｭ｣蟶ｸ邨ゆｺ?凾縲√け繝ｪ繧｢
135             *
136             * @return      蠕檎ｶ壼?逅??謖?､ｺ
137             */
138            @Override
139            public int doEndTag() {
140                    debugPrint();           // 4.0.0 (2005/02/28)
141    
142                    if( check( command, COMMAND_LIST ) ) {
143                            removeSessionAttribute( errMsgId );
144                    }
145    
146                    executeCount = getParameterRows().length ;              // 繝√ぉ繝?け陦後?謨ｰ縺檎匳骭ｲ莉ｶ謨ｰ縺ｨ莉ｮ螳?
147    
148                    // 4.0.0 (2005/01/31) 蜃ｦ逅?凾髢馴寔險?
149                    long dyTime = System.currentTimeMillis()-dyStart;
150    
151                    // 4.0.0 (2005/01/31) 繧ｻ繧ｭ繝･繝ｪ繝?ぅ繝√ぉ繝?け(繝??繧ｿ繧｢繧ｯ繧ｻ繧ｹ莉ｶ謨ｰ逋ｻ骭ｲ)
152                    GUIInfo guiInfo = (GUIInfo)getSessionAttribute( HybsSystem.GUIINFO_KEY );
153                    if( guiInfo != null ) { guiInfo.addWriteCount( executeCount,dyTime,sql ); }
154    
155                    return(EVAL_PAGE);
156            }
157    
158            /**
159             * Query 繧貞ｮ溯｡後＠縺ｾ縺吶?
160             *
161             * @og.rev 2.1.2.3 (2002/12/02) 繝??繧ｿ繝吶?繧ｹ譖ｴ譁ｰ譎ゅ↓縲∵峩譁ｰ繝輔Λ繧ｰ繧偵そ繝?ヨ縺吶ｋ繧医≧縺ｫ螟画峩
162             * @og.rev 3.4.0.0 (2003/09/01) 逋ｻ骭ｲ繧ｨ繝ｩ繝ｼ譎ゅ?繧ｭ繝ｼ縺ｨ蛟､繧定｡ｨ遉ｺ縺吶ｋ繧医≧縺ｫ螟画峩縲?
163             * @og.rev 3.5.0.0 (2003/09/17) 繧ｫ繝ｩ繝?錐縺ｧ縺ｯ縺ｪ縺上?繧ｫ繝ｩ繝?分蜿ｷ繧貞?縺ｫ豎ゅａ縺ｦ縺翫￥譁ｹ蠑上↓螟画峩縲?
164             * @og.rev 3.5.6.0 (2004/06/18) DBRowHeader 縺ｮ繝代ャ繧ｱ繝ｼ繧ｸ繝励Λ繧､繝吶?繝亥喧縺ｫ莨ｴ縺ｪ縺?､画峩
165             * @og.rev 4.0.0.0 (2005/01/31) getParameterRows() 繧剃ｽｿ逕ｨ縺吶ｋ繧医≧縺ｫ螟画峩
166             *
167             * @param   query 繧ｪ繝悶ず繧ｧ繧ｯ繝?
168             */
169            @Override
170            protected void execute( final Query query ) {
171                    // long st = System.currentTimeMillis();
172                    String[] values    = null;
173                    int row = 0;
174                    try {
175                            if( names == null ) {
176                                    query.execute( null );
177                            }
178                            else {
179                                    int[] rowNo = getParameterRows();               // 4.0.0 (2005/01/31)
180                                    if( rowNo.length > 0 ) {
181                                            int[] clmNo = getTableColumnNo( StringUtil.csv2Array( names ) );
182                                            values    = null;
183                                            // 騾??縺ｫDELETE縺励↑縺?→縲∬｡檎分蜿ｷ縺後★繧後※縺励∪縺??
184                                            for( int j=rowNo.length-1; j>=0; j-- ) {
185                                                    row = rowNo[j];
186                                                    values = getTableModelData( clmNo,row );        // 3.5.0.0
187                                                    query.execute( values );
188                                                    if( DBTableModel.DELETE_TYPE.equals( table.getModifyType( row ) ) ) {
189                                                            table.removeValue( row );
190                                                    }
191                                                    else {
192                                                            table.resetModify( row );
193                                                    }
194                                            }
195                                    }
196                            }
197    //                      if( query.getUpdateFlag() ) { query.commit(); }
198                            if( query.isUpdate() ) { query.commit(); }
199                    }
200                    catch( HybsSystemException ex ) {
201                            query.rollback();
202            // 3.4.0.0 (2003/09/01) 逋ｻ骭ｲ繧ｨ繝ｩ繝ｼ譎ゅ?繧ｭ繝ｼ縺ｨ蛟､繧定｡ｨ遉ｺ縺吶ｋ繧医≧縺ｫ螟画峩縲?
203                            String errMsg = "DATABASE ERROR! "
204                                    + "rowNo=[" + ( row ) + "] " + HybsSystem.CR
205                                    + "nameArray=[" + names + "]" + HybsSystem.CR
206                                    + "values=[" + StringUtil.array2csv( values ) + "]" + HybsSystem.CR ;
207                            throw new HybsSystemException( errMsg,ex );             // 3.5.5.4 (2004/04/15) 蠑墓焚縺ｮ荳ｦ縺ｳ鬆?､画峩
208                    }
209                    finally {
210                            if( query != null ) { query.close(); }
211                    }
212                    // System.out.println( ( System.currentTimeMillis() - st ) + " ms" );
213            }
214    
215            /**
216             *  繧ｫ繝ｩ繝?錐驟榊?(String[])繧医ｊ縲∝ｯｾ蠢懊☆繧九き繝ｩ繝?o驟榊?(int[])繧剃ｽ懈?縺励∪縺吶?
217             *
218             * @og.rev 3.5.0.0 (2003/09/17) 譁ｰ隕剰ｿｽ蜉?
219             *
220             * @param       nameArray 繧ｫ繝ｩ繝?錐驟榊?
221             *
222             * @return      繧ｫ繝ｩ繝?o驟榊?
223             */
224            private int[] getTableColumnNo( final String[] nameArray ) {
225                    int[] clmNo = new int[ nameArray.length ];
226                    for( int i=0; i<clmNo.length; i++ ) {
227                            clmNo[i] = table.getColumnNo( nameArray[i] );
228                    }
229                    return clmNo;
230            }
231    
232            /**
233             *  謖?ｮ壹?陦檎分蜿ｷ縺ｮ縲√き繝ｩ繝?o驟榊?(int[])縺ｫ蟇ｾ蠢懊＠縺溷?縺ｮ驟榊?繧定ｿ斐＠縺ｾ縺吶?
234             *
235             * 陦ｨ遉ｺ繝??繧ｿ縺ｮ HybsSystem.ROW_SEL_KEY 繧貞?縺ｫ縲?∈縺ｰ繧後◆ 陦後ｒ
236             * 蜃ｦ逅??蟇ｾ雎｡縺ｨ縺励∪縺吶?
237             *
238             * @og.rev 3.5.0.0 (2003/09/17) 繧ｫ繝ｩ繝?錐縺ｧ縺ｯ縺ｪ縺上?繧ｫ繝ｩ繝?分蜿ｷ繧貞女縺大叙繧九ｈ縺?↓菫ｮ豁｣縲?
239             *
240             * @param       clmNo   繧ｫ繝ｩ繝?o驟榊?
241             * @param       row             陦檎分蜿ｷ
242             *
243             * @return      陦檎分蜿ｷ縺ｨ繧ｫ繝ｩ繝?o驟榊?縺ｫ蟇ｾ蠢懊＠縺溘?蛟､縺ｮ驟榊?
244             */
245            private String[] getTableModelData( final int[] clmNo,final int row ) {
246                    String[] values = new String[ clmNo.length ];
247                    for( int i=0; i<values.length; i++ ) {
248                            values[i] = table.getValue( row,clmNo[i] ) ;
249                    }
250                    return values;
251            }
252    
253            /**
254             * 縲仙ｻ?ｭ｢縲漸uery 繧堤匱陦後☆繧狗ぜ縺ｮ繧ｯ繝ｩ繧ｹID繧呈欠螳壹＠縺ｾ縺?{@og.doc03Link queryType 蛻晄悄蛟､:JDBCPrepared})縲?
255             *
256             * @og.tag
257             * 逋ｻ骭ｲ繧貞ｮ溯｡後☆繧区焔谿ｵ縺ｯ縲＿uery 繧､繝ｳ繧ｿ繝ｼ繝輔ぉ繝ｼ繧ｹ縺ｮ螳溯｣?け繝ｩ繧ｹ縺ｫ縺ｪ繧翫∪縺吶?
258             * 縺薙?繧ｿ繧ｰ縺ｧ縺ｯ縲＿uery.execute( String[] ) 繝｡繧ｽ繝?ラ縺瑚､?焚蝗槫他縺ｰ繧後∪縺吶?
259             * 縺薙ｌ縺ｯ縲．BTableModel縺ｮ驕ｸ謚槭＆繧後◆陦後↓蟇ｾ縺励※縲∫ｹｰ繧願ｿ斐＠蜻ｼ縺ｰ繧後∪縺吶?
260             *
261             * 騾壼ｸｸ縲√％縺ｮ繧ｿ繧ｰ繧剃ｽｿ逕ｨ縺吶ｋ蝣ｴ蜷医?縲〈ueryType="JDBCPrepared" 繧呈欠螳壹＠縺ｾ縺吶?
262             *
263             * 繧ｿ繧ｰ縺ｫ繧医ｊ菴ｿ逕ｨ縺ｧ縺阪ｋ?丞?譚･縺ｪ縺?′縺ゅｊ縺ｾ縺吶′縲√％繧後?縲｛rg.opengion.hayabusa.db
264             * 莉･荳九? Query_**** 繧ｯ繝ｩ繧ｹ縺ｮ **** 繧剃ｸ弱∴縺ｾ縺吶?
265             * 縺薙ｌ繧峨?縲＿uery 繧､繝ｳ繧ｿ繝ｼ繝輔ぉ繝ｼ繧ｹ繧堤ｶ呎価縺励◆繧ｵ繝悶け繝ｩ繧ｹ縺ｧ縺吶?
266             * {@og.doc03Link queryType Query_**** 繧ｯ繝ｩ繧ｹ}
267             *
268             * @og.rev 3.5.4.2 (2003/12/15) JavaDoc繧ｳ繝｡繝ｳ繝育畑縺ｫ繝｡繧ｽ繝?ラ霑ｽ蜉??
269             *
270             * @param       id Query 繧堤匱陦後☆繧狗ぜ縺ｮ螳溘け繝ｩ繧ｹ ID
271             * @see         org.opengion.hayabusa.db.Query  Query縺ｮ繧ｵ繝悶け繝ｩ繧ｹ
272             * @see         org.opengion.hayabusa.db.Query#execute( String[] )
273             * @deprecated 繧ｯ繝ｩ繧ｹ縺悟ｻ?ｭ｢
274             */
275            @Deprecated public void setQueryType( final String id ) {
276                    super.setQueryType( nval( id,"JDBCPrepared" ) );
277            }
278    }