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.db.DBSysArg;
023    import org.opengion.hayabusa.db.DBUserArg;
024    import org.opengion.hayabusa.resource.GUIInfo;
025    
026    import org.opengion.fukurou.util.ErrorMessage;
027    import org.opengion.fukurou.util.StringUtil ;
028    import static org.opengion.fukurou.util.StringUtil.nval ;
029    
030    /**
031     * PLSQL繧辰ALL縺励※繝??繧ｿ繝吶?繧ｹ縺ｫ繧｢繧ｯ繧ｻ繧ｹ縺吶ｋ繧ｿ繧ｰ縺ｧ縺吶?
032     * queryType = "JDBCPLSQL" 縺後?讓呎ｺ悶〒逕ｨ諢上＆繧後※縺?∪縺吶?
033     * queryType 縺ｨ 螳滄圀縺ｮJava繧ｯ繝ｩ繧ｹ縺ｨ縺ｮ髢｢騾｣莉倥￠縺ｯ縲√す繧ｹ繝?Β繝ｪ繧ｽ繝ｼ繧ｹ縺ｮ Query_JDBCPLSQL 螻樊?縺ｧ縺吶?
034     *
035     * DBTableModel蜀??繝??繧ｿ繧?驟榊?縺ｧPL/SQL縺ｫ貂｡縺励※DB逋ｻ骭ｲ縺励∪縺吶?
036     *
037     * 窶ｻ 縺薙?繧ｿ繧ｰ縺ｯ縲ゝransaction 繧ｿ繧ｰ縺ｮ蟇ｾ雎｡縺ｧ縺吶?
038     *
039     * @og.formSample
040     * 笳丞ｽ｢蠑擾ｼ?lt;og:plsqlUpdate command="窶ｦ" names="窶ｦ" dbType="窶ｦ" queryType="JDBCPLSQL" &gt;{plsql(?,?,?,?,?)} &lt;og:plsqlUpdate&gt;
041     * 笳獣ody?壹≠繧?EVAL_BODY_BUFFERED:BODY繧定ｩ穂ｾ｡縺励?{&#064;XXXX} 繧定ｧ｣譫舌＠縺ｾ縺?
042     *
043     * 笳週ag螳夂ｾｩ??
044     *   &lt;og:plsqlUpdate
045     *       queryType          縲慎AG縲漸uery 繧堤匱陦後☆繧狗ぜ縺ｮ繧ｯ繝ｩ繧ｹID繧呈欠螳壹＠縺ｾ縺?{@og.doc03Link queryType 蛻晄悄蛟､:JDBCPLSQL})
046     *       command            縲慎AG縲代さ繝槭Φ繝?NEW,RENEW)繧偵そ繝?ヨ縺励∪縺?PlsqlUpdateTag,UpdateTag 縺ｮ蝣ｴ蜷医?縲・NTRY)
047     *       scope              縲慎AG縲代く繝｣繝?す繝･縺吶ｋ蝣ｴ蜷医?繧ｹ繧ｳ繝ｼ繝夕request/page/session/applicaton]繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:session)
048     *       maxRowCount        縲慎AG縲?騾壼ｸｸ縺ｯ菴ｿ縺?∪縺帙ｓ)繝??繧ｿ縺ｮ譛?､ｧ隱ｭ縺ｿ霎ｼ縺ｿ莉ｶ謨ｰ繧呈欠螳壹＠縺ｾ縺?(蛻晄悄蛟､:DB_MAX_ROW_COUNT[=1000])(0:[辟｡蛻ｶ髯疹)
049     *       skipRowCount       縲慎AG縲?騾壼ｸｸ縺ｯ菴ｿ縺?∪縺帙ｓ)繝??繧ｿ縺ｮ隱ｭ縺ｿ蟋九ａ縺ｮ蛻晄悄蛟､繧呈欠螳壹＠縺ｾ縺?
050     *       notfoundMsg        縲慎AG縲第､懃ｴ｢邨先棡縺後ぞ繝ｭ莉ｶ縺ｮ蝣ｴ蜷医↓陦ｨ遉ｺ縺吶ｋ繝｡繝?そ繝ｼ繧ｸ繝ｪ繧ｽ繝ｼ繧ｹID繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:MSG0077[蟇ｾ雎｡繝??繧ｿ縺ｯ縺ゅｊ縺ｾ縺帙ｓ縺ｧ縺励◆])
051     *       names              縲慎AG縲善L/SQL繧貞茜逕ｨ縺吶ｋ蝣ｴ蜷医?蠑墓焚縺ｫ繧ｻ繝?ヨ縺吶∋縺?繝??繧ｿ縺ｮ蜷咲ｧｰ繧辰SV蠖｢蠑上〒隍?焚謖?ｮ壹＠縺ｾ縺?
052     *       dbType             縲慎AG縲漸uery繧ｪ繝悶ず繧ｧ繧ｯ繝医↓貂｡縺吝ｼ墓焚縺ｮ繧ｿ繧､繝怜ｮ夂ｾｩ(萓?type蜷浩ARRAY)
053     *       selectedAll        縲慎AG縲代ョ繝ｼ繧ｿ繧貞?莉ｶ驕ｸ謚樊ｸ医∩縺ｨ縺励※蜃ｦ逅?☆繧九°縺ｩ縺?°[true/false]繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:false)
054     *       tableId            縲慎AG縲?騾壼ｸｸ縺ｯ菴ｿ縺?∪縺帙ｓ)邨先棡縺ｮDBTableModel繧偵?session縺ｫ逋ｻ骭ｲ縺吶ｋ縺ｨ縺阪?繧ｭ繝ｼ繧呈欠螳壹＠縺ｾ縺?
055     *       dbid               縲慎AG縲?騾壼ｸｸ縺ｯ菴ｿ縺?∪縺帙ｓ)Query繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ菴懈?縺吶ｋ譎ゅ?DB謗･邯唔D繧呈欠螳壹＠縺ｾ縺?
056     *       stopError          縲慎AG縲善LSQL/SQL蜃ｦ逅?お繝ｩ繝ｼ縺ｮ譎ゅ↓蜃ｦ逅?ｒ荳ｭ豁｢縺吶ｋ縺九←縺?°[true/false]繧定ｨｭ螳壹＠縺ｾ縺?蛻晄悄蛟､:true)
057     *       tableModelCommit   縲慎AG縲代ユ繝ｼ繝悶Ν繝｢繝?Ν縺ｮ遒ｺ螳壼?逅?ｒ陦後≧縺九←縺?°[true/false]繧定ｨｭ螳壹＠縺ｾ縺?蛻晄悄蛟､:true)
058     *       debug              縲慎AG縲代ョ繝舌ャ繧ｰ諠??繧貞?蜉帙☆繧九°縺ｩ縺?°[true/false]繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:false)
059     *   &gt;   ... Body ...
060     *   &lt;/og:plsqlUpdate&gt;
061     *
062     * 笳丈ｽｿ逕ｨ萓?
063     *    繝ｻ蠑墓焚/繝励Ο繧ｷ繧ｸ繝｣繝ｼ繧剃ｻ悶?JSP縺九ｉ貂｡縺吝?蜷?
064     *    縲芯opy.jsp縲?
065     *        &lt;og:hidden name=&quot;names&quot; value=&quot;UNIQ,USRID,ECNO,EDBN&quot; /&gt;
066     *        &lt;og:hidden name=&quot;SQL&quot; value=&quot;{ call RKP0271E.RK0271E( ?,?,?,?,? ) }&quot; /&gt;
067     *    縲親ntry.jsp縲?
068     *        &lt;og:plsqlUpdate
069     *            command    = "{&#064;command}"
070     *            names      = "{&#064;names}"         竊単L/SQL縺ｫ貂｡縺吝ｼ墓焚(驟榊?)縺ｮ繧ｫ繝ｩ繝?錐
071     *            dbType     = "RK0271ARG"             竊単L/SQL縺ｫ貂｡縺吝ｼ墓焚(驟榊?)縺ｮ螳夂ｾｩ繝輔ぃ繧､繝ｫ蜷?
072     *            queryType  = "JDBCPLSQL" &gt;
073     *        {&#064;SQL}                              竊辰ALL縺吶ｋPL/SQL
074     *        &lt;/og:plsqlUpdate&gt;
075     *
076     *    繝ｻ蠑墓焚/繝励Ο繧ｷ繧ｸ繝｣繝ｼ繧堤峩謗･譖ｸ縺丞?蜷?
077     *    縲親ntry.jsp縲?
078     *        &lt;og:plsqlUpdate
079     *            command    = "{&#064;command}"
080     *            names      = "UNIQ,USRID,ECNO,EDBN"  竊単L/SQL縺ｫ貂｡縺吝ｼ墓焚(驟榊?)縺ｮ繧ｫ繝ｩ繝?錐
081     *            dbType     = "RK0271ARG"             竊単L/SQL縺ｫ貂｡縺吝ｼ墓焚(驟榊?)縺ｮ螳夂ｾｩ繝輔ぃ繧､繝ｫ蜷?
082     *            queryType  = "JDBCPLSQL" &gt;
083     *        { call RKP0271E.RK0271E( ?,?,?,?,? )}    竊辰ALL縺吶ｋPL/SQL
084     *        &lt;/og:plsqlUpdate&gt;
085     *
086     *    ?懶ｼ懷盾閠?ｼ橸ｼ?
087     *    繝ｻRKP0271E.RK0271E( ?,?,?,?,? )縺ｮ?｢??｣縺ｮ諢丞袖
088     *        (RKP0271E.spc)------------------------------------------------------------
089     *        CREATE OR REPLACE PACKAGE RKP0271E AS
090     *        PROCEDURE RK0271E(
091     *             P_KEKKA    OUT    NUMBER           -- 1蛟狗岼縺ｮ?｢??｣竍堤ｵ先棡 0:豁｣蟶ｸ 1:隴ｦ蜻?2:逡ｰ蟶ｸ
092     *            ,P_ERRMSGS  OUT    ERR_MSG_ARRAY    -- 2蛟狗岼縺ｮ?｢??｣竍偵お繝ｩ繝ｼ繝｡繝?そ繝ｼ繧ｸ驟榊?
093     *            ,P_NAMES     IN    VARCHAR2         -- 3蛟狗岼縺ｮ?｢??｣竍偵き繝ｩ繝?錐繝√ぉ繝?け逕ｨ譁?ｭ怜?
094     *            ,P_SYSARGS   IN    SYSARG_ARRAY     -- 4蛟狗岼縺ｮ?｢??｣竍堤匳骭ｲ譚｡莉ｶ驟榊?(謾ｹ蟒?A:霑ｽ蜉?C:螟画峩/D:蜑企勁)遲峨′?ｾ?ｯ??＆繧後∪縺?
095     *            ,P_RK0271    IN    RK0271ARG_ARRAY  -- 5蛟狗岼縺ｮ?｢??｣竍堤匳骭ｲ繝??繧ｿ驟榊?
096     *
097     *    繝ｻRK0271ARG縺ｮ螳夂ｾｩ縺ｮ莉墓婿
098     *        (RK0271ARG.sql)------------------------------------------------------------
099     *        DROP TYPE RK0271ARG_ARRAY;
100     *        CREATE OR REPLACE TYPE RK0271ARG AS OBJECT
101     *        (
102     *             UNIQ                VARCHAR2(11)
103     *            ,USRID               VARCHAR2(5)
104     *            ,ECNO                VARCHAR(7)
105     *            ,EDBN                VARCHAR(2)
106     *        ) ;
107     *        /
108     *        CREATE OR REPLACE TYPE RK0271ARG_ARRAY AS VARRAY(100) OF RK0271ARG;
109     *        /
110     *
111     * @og.group ?､?｢逋ｻ骭ｲ
112     *
113     * @version  4.0
114     * @author   Kazuhiko Hasegawa
115     * @since    JDK5.0,
116     */
117    public class PlsqlUpdateTag extends QueryTag {
118            //* 縺薙?繝励Ο繧ｰ繝ｩ繝??VERSION譁?ｭ怜?繧定ｨｭ螳壹＠縺ｾ縺吶?       {@value} */
119            private static final String VERSION = "5.5.5.2 (2012/08/10)" ;
120    
121            private static final long serialVersionUID = 555220120810L ;
122    
123            /** command 蠑墓焚縺ｫ貂｡縺吩ｺ九?蜃ｺ譚･繧?繧ｳ繝槭Φ繝? 逋ｻ骭ｲ{@value} */
124            public static final String CMD_ENTRY  = "ENTRY" ;
125            /** command 蠑墓焚縺ｫ貂｡縺吩ｺ九?蜃ｺ譚･繧?繧ｳ繝槭Φ繝?繝ｪ繧ｹ繝? */
126            private static  final String COMMAND_LIST = CMD_ENTRY;
127    
128            /** 蠑墓焚縺ｮ繧ｿ繧､繝怜ｮ夂ｾｩ  */
129            protected String  userDBType = null;
130    
131            // 3.5.2.0 (2003/10/20) 蜀?Κ繧ｪ繝悶ず繧ｧ繧ｯ繝医ち繧､繝怜錐繧?繧ｷ繧ｹ繝?Β繝代Λ繝｡繝ｼ繧ｿ 縺ｧ螳夂ｾｩ縺励∪縺吶?
132            private static final String SYSARG = "SYSARG";
133            private boolean selectedAll = false;
134            
135            private boolean isTableModelCommit = true; // 5.5.5.2 (2012/08/10)
136    
137            /**
138             * Taglib縺ｮ髢句ｧ九ち繧ｰ縺瑚ｦ九▽縺九▲縺溘→縺阪↓蜃ｦ逅?☆繧?doStartTag() 繧?繧ｪ繝ｼ繝舌?繝ｩ繧､繝峨＠縺ｾ縺吶?
139             *
140             * @return      蠕檎ｶ壼?逅??謖?､ｺ
141             */
142            @Override
143            public int doStartTag() {
144                    dyStart = System.currentTimeMillis();
145    
146                    table = (DBTableModel)getObject( tableId );
147                    if( table == null || table.getRowCount() == 0 ||
148                            ! check( command, COMMAND_LIST ) ) { return(SKIP_BODY); }
149    
150                    startQueryTransaction( tableId );               // 3.6.0.8 (2004/11/19)
151                    return( EVAL_BODY_BUFFERED );   // Body 繧定ｩ穂ｾ｡縺吶ｋ縲? extends BodyTagSupport 譎?
152            }
153    
154            /**
155             * Taglib縺ｮ邨ゆｺ?ち繧ｰ縺瑚ｦ九▽縺九▲縺溘→縺阪↓蜃ｦ逅?☆繧?doEndTag() 繧?繧ｪ繝ｼ繝舌?繝ｩ繧､繝峨＠縺ｾ縺吶?
156             *
157             * @og.rev 3.1.1.2 (2003/04/04) Tomcat4.1 蟇ｾ蠢懊?release2() 繧?doEndTag()縺ｧ蜻ｼ縺ｶ縲?
158             * @og.rev 3.5.5.2 (2004/04/02) TaglibUtil.makeHTMLErrorTable 繝｡繧ｽ繝?ラ繧貞茜逕ｨ
159             * @og.rev 3.6.0.8 (2004/11/19) DBTableModel 繧偵そ繝ｼ繝悶☆繧区凾縺ｫ縲√ヨ繝ｩ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ繝√ぉ繝?け繧定｡後＞縺ｾ縺吶?
160             * @og.rev 3.6.1.0 (2005/01/05) 繧ｪ繝ｼ繝舌?繝輔Ο繝ｼ譎ゅ→逋ｻ骭ｲ莉ｶ謨ｰ縺ｮ陦ｨ遉ｺ繧偵さ繝｡繝ｳ繝医＠縺ｾ縺吶?
161             * @og.rev 4.3.3.0 (2008/09/22) 讀懃ｴ｢邨先棡繧偵?"DB.ERR_CODE" 繧ｭ繝ｼ縺ｧ繝ｪ繧ｯ繧ｨ繧ｹ繝医↓繧ｻ繝?ヨ縺吶ｋ縲?
162             * @og.rev 4.3.3.0 (2008/09/22) 螻樊? stopError 縺ｮ險ｭ螳壹↓繧医ｊ縲゛SP蜃ｦ逅?ｒ荳ｭ豁｢縺吶ｋ縺九←縺?°繧貞宛蠕｡縺励∪縺吶?
163             * @og.rev 4.3.5.7 (2009/03/22) 繧｢繧ｯ繧ｻ繧ｹ繧ｫ繧ｦ繝ｳ繝井ｸ榊?蜷亥ｯｾ蠢?
164             *
165             * @return      蠕檎ｶ壼?逅??謖?､ｺ
166             */
167            @Override
168            public int doEndTag() {
169                    debugPrint();           // 4.0.0 (2005/02/28)
170    
171                    String label = HybsSystem.BR;                           // 讀懃ｴ｢縺励↑縺九▲縺溷?蜷医?
172                    if( check( command, COMMAND_LIST ) ) {
173    
174                            // 3.5.5.2 (2004/04/02) TaglibUtil.makeHTMLErrorTable 繝｡繧ｽ繝?ラ繧貞茜逕ｨ
175                            String err = TaglibUtil.makeHTMLErrorTable( errMessage,getResource() );
176                            if( err != null && err.length() > 0 ) {
177                                    if( errCode >= ErrorMessage.NG ) {           // 逡ｰ蟶ｸ縺ｮ蝣ｴ蜷?
178                                            label = err;
179                                    }
180                                    setSessionAttribute( errMsgId,errMessage );
181                            }
182                            else {
183                                    removeSessionAttribute( errMsgId );
184                            }
185                            // 4.3.3.0 (2008/09/22) 讀懃ｴ｢邨先棡繧偵?"DB.ERR_CODE" 繧ｭ繝ｼ縺ｧ繝ｪ繧ｯ繧ｨ繧ｹ繝医↓繧ｻ繝?ヨ縺吶ｋ縲?
186                            setRequestAttribute( "DB.ERR_CODE", String.valueOf( errCode ) );
187    
188                            // 3.6.0.8 (2004/11/19) 繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ繝√ぉ繝?け繧定｡後＞縺ｾ縺吶?
189                            // 4.0.0.0 (2007/11/29) 蜈･繧悟ｭ進f 縺ｮ邨ｱ蜷?
190                            if( table != null && ! commitTableObject( tableId, table ) ) {
191                                    jspPrint( "PlsqlUpdateTag Query蜃ｦ逅?′蜑ｲ繧願ｾｼ縺ｾ繧後∪縺励◆縲?BTableModel 縺ｯ逋ｻ骭ｲ縺励∪縺帙ｓ縲? );
192                                    return (SKIP_PAGE);
193                            }
194                    }
195    
196                    jspPrint( label );
197    
198    //              int rtnCode = EVAL_PAGE;
199    //              if( errCode >= ErrorMessage.NG )  {  // 逡ｰ蟶ｸ
200    //                      rtnCode = SKIP_PAGE;
201    //              }
202    //              else {
203    //                      rtnCode = EVAL_PAGE;
204    //              }
205    
206                    // 4.0.0 (2005/01/31) 蜃ｦ逅?凾髢馴寔險?
207                    long dyTime = System.currentTimeMillis()-dyStart;
208    
209                    // 4.0.0 (2005/01/31) 繧ｻ繧ｭ繝･繝ｪ繝?ぅ繝√ぉ繝?け(繝??繧ｿ繧｢繧ｯ繧ｻ繧ｹ莉ｶ謨ｰ逋ｻ骭ｲ)
210                    GUIInfo guiInfo = (GUIInfo) getSessionAttribute( HybsSystem.GUIINFO_KEY );
211                    executeCount = getParameterRows().length ; // 4.3.5.7 (2009/03/16) 繧｢繧ｯ繧ｻ繧ｹ莉ｶ謨ｰ荳榊?蜷亥ｯｾ蠢懊?繝√ぉ繝?け陦後→莉ｮ螳?
212                    if( guiInfo != null ) { guiInfo.addWriteCount( executeCount,dyTime,sql ); }
213                    // 4.3.3.0 (2008/09/22) 螻樊? stopError 縺ｮ險ｭ螳壹↓繧医ｊ縲∝?逅?ｒ荳ｭ豁｢縺吶ｋ縺九ｒ蛻､譁ｭ縺励∪縺吶?
214                    int rtnCode = ( ( errCode >= ErrorMessage.NG ) && ( stopError ) ) ? SKIP_PAGE : EVAL_PAGE;
215                    return( rtnCode );
216            }
217    
218            /**
219             * 繧ｿ繧ｰ繝ｪ繝悶が繝悶ず繧ｧ繧ｯ繝医ｒ繝ｪ繝ｪ繝ｼ繧ｹ縺励∪縺吶?
220             * 繧ｭ繝｣繝?す繝･縺輔ｌ縺ｦ蜀榊茜逕ｨ縺輔ｌ繧九?縺ｧ縲√ヵ繧｣繝ｼ繝ｫ繝峨?蛻晄悄險ｭ螳壹ｒ陦後＞縺ｾ縺吶?
221             *
222             * @og.rev 2.0.0.4 (2002/09/27) 繧ｫ繧ｹ繧ｿ繝?ち繧ｰ縺ｮ release() 繝｡繧ｽ繝?ラ繧偵?霑ｽ蜉?
223             * @og.rev 3.1.1.2 (2003/04/04) Tomcat4.1 蟇ｾ蠢懊?release2() 繧?doEndTag()縺ｧ蜻ｼ縺ｶ縲?
224             * @og.rev 3.5.2.0 (2003/10/20) sysDBType 蟒?ｭ｢縲４YSARG 縺ｯ縲√す繧ｹ繝?Β繝代Λ繝｡繝ｼ繧ｿ 縺ｧ螳夂ｾｩ縺励∪縺吶?
225             * @og.rev 5.5.5.2 (2012/08/10) isTableModelCommit霑ｽ蜉?
226             *
227             */
228            @Override
229            protected void release2() {
230                    super.release2();
231                    userDBType      = null;
232                    selectedAll     = false;
233                    isTableModelCommit = true; // 5.5.5.2 (2012/08/10)
234            }
235    
236            /**
237             * Query 繧貞ｮ溯｡後＠縺ｾ縺吶?
238             *
239             * @og.rev 2.1.2.3 (2002/12/02) 繝??繧ｿ繝吶?繧ｹ譖ｴ譁ｰ譎ゅ↓縲∵峩譁ｰ繝輔Λ繧ｰ繧偵そ繝?ヨ縺吶ｋ繧医≧縺ｫ螟画峩
240             * @og.rev 3.5.0.0 (2003/09/17) 繧ｫ繝ｩ繝?錐縺ｧ縺ｯ縺ｪ縺上?繧ｫ繝ｩ繝?分蜿ｷ繧貞?縺ｫ豎ゅａ縺ｦ縺翫￥譁ｹ蠑上↓螟画峩縲?
241             * @og.rev 3.5.2.0 (2003/10/20) 蜀?Κ繧ｪ繝悶ず繧ｧ繧ｯ繝医ち繧､繝怜錐繧?繧ｷ繧ｹ繝?Β繝代Λ繝｡繝ｼ繧ｿ 縺ｧ螳夂ｾｩ縺励∪縺吶?
242             * @og.rev 3.5.4.2 (2003/12/15) HTMLTableViewForm 繧ｯ繝ｩ繧ｹ蜷榊､画峩(竍?ViewForm_HTMLTable)
243             * @og.rev 3.5.6.0 (2004/06/18) DBRowHeader 縺ｮ繝代ャ繧ｱ繝ｼ繧ｸ繝励Λ繧､繝吶?繝亥喧縺ｫ莨ｴ縺ｪ縺?､画峩
244             * @og.rev 4.0.0.0 (2005/01/31) setArguments 蟒?ｭ｢縲＿uery#execute 縺ｫ縲∝ｼ墓焚繧偵☆縺ｹ縺ｦ霑ｽ蜉?
245             * @og.rev 4.3.0.0 (2008/07/22) DBSysArg縺ｮ蠑墓焚縺ｫ譌･莉倥?PG縲√Θ繝ｼ繧ｶ繝ｼID繧定ｿｽ蜉?
246             * @og.rev 5.5.5.2 (2012/08/10) isTableModelCommit縺ｫ繧医ｋ繝??繝悶Ν繝｢繝?Ν遒ｺ螳壼?逅??繧ｳ繝ｳ繝医Ο繝ｼ繝ｫ
247             *
248             * @param   query 繧ｪ繝悶ず繧ｧ繧ｯ繝?
249             */
250            @Override
251            protected void execute( final Query query ) {
252                    try {
253                            if( names == null ) {
254                                    String errMsg = "names 螻樊?縺後?險ｭ螳壹＆繧後※縺?∪縺帙ｓ縲? + HybsSystem.CR
255                                                            + sql + HybsSystem.CR ;
256                                    throw new HybsSystemException( errMsg );                // 3.5.5.4 (2004/04/15) 蠑墓焚縺ｮ荳ｦ縺ｳ鬆?､画峩
257                            }
258                            else {
259                                    int[] rowNo = getParameterRows();
260                                    int rowCount = rowNo.length ;
261                                    if( rowCount > 0 ) {
262                                            String[] nameArray = StringUtil.csv2Array( names );
263                                            int[]    clmNo     = getTableColumnNo( nameArray );             // 3.5.0.0
264    
265                                            String curdate = HybsSystem.getDate( "yyyyMMddHHmmss" );        // 4.3.0.0
266                                            String pgid = getGUIInfoAttri( "KEY" );                                         // 4.3.0.0
267                                            String userid = getUser().getAttribute( "ID" );                         // 4.3.0.0
268    
269                                            DBSysArg[]  sysArg  = new DBSysArg[rowCount];
270                                            DBUserArg[] userArg = new DBUserArg[rowCount];
271                                            for( int i=0; i<rowCount; i++ ) {
272                                                    int    row  = rowNo[i];
273                                                    String cdkh = table.getModifyType( row );
274    //                                              sysArg[i]  = new DBSysArg( SYSARG,row,cdkh );           // 3.5.2.0 // 4.3.0.0
275                                                    sysArg[i]  = new DBSysArg( SYSARG,row,cdkh,curdate,pgid,userid );
276                                                    String[] values = getTableModelData( clmNo,row );       // 3.5.0.0
277                                                    userArg[i] = new DBUserArg( userDBType,nameArray,values );
278                                            }
279                                            query.execute( names,userDBType + "_ARRAY",sysArg,userArg );
280                                            errCode = query.getErrorCode();
281                                            errMessage = query.getErrorMessage();
282    
283                                            if( errCode < ErrorMessage.NG ) {            // 逡ｰ蟶ｸ莉･螟悶?蝣ｴ蜷?
284                                                    query.commit();
285                                                    if( isTableModelCommit ) { // 5.5.5.2 (2012/08/10))
286                                                            for( int j=rowCount-1; j>=0; j-- ) {
287                                                                    int row = rowNo[j];
288                                                                    if( DBTableModel.DELETE_TYPE.equals( table.getModifyType( row ) ) ) {
289                                                                            table.removeValue( row );
290                                                                    }
291                                                                    else {
292                                                                            table.resetModify( row );
293                                                                    }
294                                                            }
295                                                    }
296                                            }
297                                            else {
298                                                    query.rollback();
299                                            }
300                                    }
301                            }
302                    }
303                    catch( HybsSystemException ex ) {
304                            query.rollback();
305                            throw ex;
306                    }
307                    finally {
308                            if( query != null ) { query.close(); }
309                    }
310            }
311    
312            /**
313             *  繧ｫ繝ｩ繝?錐驟榊?(String[])繧医ｊ縲∝ｯｾ蠢懊☆繧九き繝ｩ繝?o驟榊?(int[])繧剃ｽ懈?縺励∪縺吶?
314             *
315             * @og.rev 3.5.0.0 (2003/09/17) 譁ｰ隕剰ｿｽ蜉?
316             *
317             * @param       nameArray 繧ｫ繝ｩ繝?錐驟榊?
318             *
319             * @return      繧ｫ繝ｩ繝?o驟榊?
320             */
321            private int[] getTableColumnNo( final String[] nameArray ) {
322                    int[] clmNo = new int[ nameArray.length ];
323                    for( int i=0; i<clmNo.length; i++ ) {
324                            clmNo[i] = table.getColumnNo( nameArray[i] );
325                    }
326                    return clmNo;
327            }
328    
329            /**
330             *  謖?ｮ壹?陦檎分蜿ｷ縺ｮ縲√き繝ｩ繝?o驟榊?(int[])縺ｫ蟇ｾ蠢懊＠縺溷?縺ｮ驟榊?繧定ｿ斐＠縺ｾ縺吶?
331             *
332             * 陦ｨ遉ｺ繝??繧ｿ縺ｮ HybsSystem.ROW_SEL_KEY 繧貞?縺ｫ縲?∈縺ｰ繧後◆ 陦後ｒ
333             * 蜃ｦ逅??蟇ｾ雎｡縺ｨ縺励∪縺吶?
334             *
335             * @og.rev 3.5.0.0 (2003/09/17) 繧ｫ繝ｩ繝?錐縺ｧ縺ｯ縺ｪ縺上?繧ｫ繝ｩ繝?分蜿ｷ繧貞女縺大叙繧九ｈ縺?↓菫ｮ豁｣縲?
336             *
337             * @param       clmNo 繧ｫ繝ｩ繝?o驟榊?
338             * @param       row   陦檎分蜿ｷ
339             *
340             * @return      陦檎分蜿ｷ縺ｨ繧ｫ繝ｩ繝?o驟榊?縺ｫ蟇ｾ蠢懊＠縺溘?蛟､縺ｮ驟榊?
341             */
342            private String[] getTableModelData( final int[] clmNo,final int row ) {
343                    String[] values = new String[ clmNo.length ];
344                    for( int i=0; i<values.length; i++ ) {
345                            values[i] = table.getValue( row,clmNo[i] ) ;
346                            // NUMBER 繧ｿ繧､繝励?繧ｭ繝｣繧ｹ繝医お繝ｩ繝ｼ繧帝亟縺千ぜ縺ｮ蟇ｾ蠢?
347                            if( values[i] != null && values[i].length() == 0 ) { values[i] = null; }
348                    }
349                    return values;
350            }
351    
352            /**
353             * 陦ｨ遉ｺ繝??繧ｿ縺ｮ HybsSystem.ROW_SEL_KEY 繧貞?縺ｫ縲?∈縺ｰ繧後◆ 陦後ｒ蜃ｦ逅??蟇ｾ雎｡縺ｨ縺励∪縺吶?
354             *
355             * @og.rev 4.0.0.0 (2005/01/31) getParameterRows() 繧剃ｽｿ逕ｨ縺吶ｋ繧医≧縺ｫ螟画峩
356             *
357             * @return      驕ｸ謚櫁｡後?驟榊?
358             */
359            @Override
360            protected int[] getParameterRows() {
361                    final int[] rowNo ;
362                    if( selectedAll ) {
363                            int rowCnt = table.getRowCount();               // 3.5.5.7 (2004/05/10)
364                            rowNo = new int[ rowCnt ];
365                            for( int i=0; i<rowCnt; i++ ) {
366                                    rowNo[i] = i;
367                            }
368                    } else {
369                            rowNo = super.getParameterRows();               // 4.0.0 (2005/01/31)
370                    }
371                    return rowNo ;
372            }
373    
374            /**
375             * 縲慎AG縲漸uery繧ｪ繝悶ず繧ｧ繧ｯ繝医↓貂｡縺吝ｼ墓焚縺ｮ繧ｿ繧､繝怜ｮ夂ｾｩ(萓?type蜷浩ARRAY)縲?
376             *
377             * @og.tag
378             * 縺薙％縺ｧ縺ｯ縲》ype 螳夂ｾｩ縺ｮPL/SQL蜷阪ｒ謖?ｮ壹＠縺ｾ縺吶?
379             * 陦後ｒ陦ｨ縺咎?蛻励?縲》ype蜷浩ARRAY 縺ｨ縺?≧蜷咲ｧｰ縺ｧ縺吶?
380             *
381             * @param  type 螳夂ｾｩ縺ｮPL/SQL蜷?
382             */
383            public void setDbType( final String type ) {
384                    userDBType = getRequestParameter( type );
385            }
386    
387            /**
388             * 縲慎AG縲代ョ繝ｼ繧ｿ繧貞?莉ｶ驕ｸ謚樊ｸ医∩縺ｨ縺励※蜃ｦ逅?☆繧九°縺ｩ縺?°[true/false]繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:false)縲?
389             *
390             * @og.tag
391             * 蜈ｨ縺ｦ縺ｮ繝??繧ｿ繧帝∈謚樊ｸ医∩繝??繧ｿ縺ｨ縺励※謇ｱ縺｣縺ｦ蜃ｦ逅?＠縺ｾ縺吶?
392             * 蜈ｨ莉ｶ蜃ｦ逅?☆繧句?蜷医↓縲?true/false)繧呈欠螳壹＠縺ｾ縺吶?
393             * 蛻晄悄蛟､縺ｯ false 縺ｧ縺吶?
394             *
395             * @param  all 繝??繧ｿ繧貞?莉ｶ驕ｸ謚樊ｸ医∩ [true:蜈ｨ莉ｶ驕ｸ謚樊ｸ医∩/false:騾壼ｸｸ]
396             */
397            public void setSelectedAll( final String all ) {
398                    selectedAll = nval( getRequestParameter( all ),selectedAll );
399            }
400    
401            /**
402             * 縲慎AG縲漸uery 繧堤匱陦後☆繧狗ぜ縺ｮ繧ｯ繝ｩ繧ｹID繧呈欠螳壹＠縺ｾ縺?{@og.doc03Link queryType 蛻晄悄蛟､:JDBCPLSQL})縲?
403             *
404             * @og.tag
405             * 蠑墓焚謖?ｮ壹?INSERT/UPDATE譁?ｒ螳溯｡後☆繧句?蜷医?縲〈ueryType 螻樊?繧剃ｽｿ逕ｨ縺励∪縺吶?
406             * 縺薙?繧ｿ繧ｰ縺ｧ縺ｯ縲‘xecute( String ,String , DBSysArg[] , DBUserArg[] )繧貞ｮ溯｡後＠縺ｾ縺吶?
407             * 莉｣陦ｨ逧?↑繧ｯ繝ｩ繧ｹ縺ｨ縺励※縲?JDBCPLSQL" 縺梧ｨ呎ｺ悶〒逕ｨ諢上＆繧後※縺?∪縺吶?
408             *
409             * 繧ｿ繧ｰ縺ｫ繧医ｊ菴ｿ逕ｨ縺ｧ縺阪ｋ/蜃ｺ譚･縺ｪ縺?′縺ゅｊ縺ｾ縺吶′縲√％繧後?縲｛rg.opengion.hayabusa.db
410             * 莉･荳九? Query_**** 繧ｯ繝ｩ繧ｹ縺ｮ **** 繧剃ｸ弱∴縺ｾ縺吶?
411             * 縺薙ｌ繧峨?縲＿uery 繧､繝ｳ繧ｿ繝ｼ繝輔ぉ繝ｼ繧ｹ繧堤ｶ呎価縺励◆繧ｵ繝悶け繝ｩ繧ｹ縺ｧ縺吶?
412             * {@og.doc03Link queryType Query_**** 繧ｯ繝ｩ繧ｹ}
413             *
414             * @og.rev 3.5.4.2 (2003/12/15) JavaDoc繧ｳ繝｡繝ｳ繝育畑縺ｫ繝｡繧ｽ繝?ラ霑ｽ蜉??
415             *
416             * @param       id Query 繧堤匱陦後☆繧狗ぜ縺ｮ螳溘け繝ｩ繧ｹ ID
417             * @see         org.opengion.hayabusa.db.Query  Query縺ｮ繧ｵ繝悶け繝ｩ繧ｹ
418             * @see         org.opengion.hayabusa.db.Query#execute( String ,String , DBSysArg[] , DBUserArg[] )
419             */
420            @Override
421            public void setQueryType( final String id ) {
422                    super.setQueryType( nval( id,"JDBCPLSQL" ) );
423            }
424            
425            /**
426             * 縲慎AG縲代ユ繝ｼ繝悶Ν繝｢繝?Ν縺ｫ蟇ｾ縺吶ｋ遒ｺ螳壼?逅?ｒ陦後≧縺九←縺?°繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:true)縲?
427             *
428             * @og.tag
429             * PlsqlUpdate繧ｿ繧ｰ縺ｧ縲√お繝ｩ繝ｼ縺後↑縺九▲縺溷?蜷医?騾壼ｸｸ縲√ユ繝ｼ繝悶Ν繝｢繝?Ν縺ｮ謾ｹ蟒?↓蠕薙▲縺ｦ蜃ｦ逅?′陦後ｏ繧後∪縺吶?
430             * ?域隼蟒ゥ縺ｫ縺､縺?※縺ｯ蜑企勁蜃ｦ逅?ｒ陦後＞縲√◎縺ｮ莉悶↓縺､縺?※縺ｯ謾ｹ蟒?ｒ蜈?↓謌ｻ縺呻ｼ?
431             *
432             * 縺薙?繝代Λ繝｡繝ｼ繧ｿ繧断alse縺ｫ謖?ｮ壹☆繧九→縲√ユ繝ｼ繝悶Ν繝｢繝?Ν縺ｫ蟇ｾ縺吶ｋ蜃ｦ逅?ｒ陦後＞縺ｾ縺帙ｓ縲?
433             * 縺薙ｌ縺ｯ縲∽ｾ九∴縺ｰPL/SQL縺ｧ繧ｨ繝ｩ繝ｼ繝√ぉ繝?け縺ｮ縺ｿ繧定｡後＞縺溘＞蝣ｴ蜷医↓譛牙柑縺ｧ縺吶?
434             * 蛻晄悄蛟､縺ｯtrue(蜃ｦ逅?ｒ陦後≧?峨〒縺吶?
435             *
436             * @og.rev 5.5.5.2 (2012/08/10) 譁ｰ隕丈ｽ懈?
437             *
438             * @param  flag 繝??繝悶Ν繝｢繝?Ν縺ｫ蟇ｾ縺吶ｋ蜃ｦ逅?ｒ陦後≧縺九←縺?°
439             */
440            public void setTableModelCommit( final String flag ) {
441                    isTableModelCommit = nval( getRequestParameter( flag ),isTableModelCommit );
442            }
443    
444            /**
445             * 縺薙?繧ｪ繝悶ず繧ｧ繧ｯ繝医?譁?ｭ怜?陦ｨ迴ｾ繧定ｿ斐＠縺ｾ縺吶?
446             * 蝓ｺ譛ｬ逧?↓繝?ヰ繝?げ逶ｮ逧?↓菴ｿ逕ｨ縺励∪縺吶?
447             *
448             * @return 縺薙?繧ｯ繝ｩ繧ｹ縺ｮ譁?ｭ怜?陦ｨ迴ｾ
449             */
450            @Override
451            public String toString() {
452                    return org.opengion.fukurou.util.ToString.title( this.getClass().getName() )
453                                    .println( "VERSION"             ,VERSION        )
454                                    .println( "selectedAll" ,selectedAll    )
455                                    .fixForm().toString()
456                            + HybsSystem.CR
457                            + super.toString() ;
458            }
459    }