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.plugin.query;
017    
018    import org.opengion.hayabusa.common.HybsSystem;
019    import org.opengion.hayabusa.common.HybsSystemException;
020    import org.opengion.hayabusa.db.AbstractQuery;
021    import org.opengion.fukurou.util.ErrorMessage;
022    import org.opengion.fukurou.util.StringUtil;
023    import org.opengion.fukurou.util.Closer;
024    
025    import java.sql.CallableStatement;
026    import java.sql.SQLException;
027    
028    /**
029     * 荳?握逧?↑ PL/SQL繧偵さ繝ｼ繝ｫ縺吶ｋ縲＿uery 繧ｯ繝ｩ繧ｹ縺ｧ縺吶?
030     *
031     * java.sql.CallableStatement 繧堤畑縺?※縲√ョ繝ｼ繧ｿ繝吶?繧ｹ逋ｻ骭ｲ蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
032     * 蠑墓焚縺ｯ縲√◎縺ｮ縺ｾ縺ｾ驟榊?縺ｫ譬ｼ邏阪＠縺ｦ蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?繧ｨ繝ｩ繝ｼ譎ゅ?蜃ｦ逅?ｄ縲∵､懃ｴ｢邨先棡縺ｮ
033     * 蜿悶ｊ蜃ｺ縺励?蜃ｺ譚･縺ｾ縺帙ｓ縲?
034     * 蜀?Κ螟画焚縺ｮ蜿励￠貂｡縺励?繝?ヵ繧ｩ繝ｫ繝亥ｮ溯｣??縲、bstractQuery 繧ｯ繝ｩ繧ｹ繧堤ｶ呎価縺励※縺?ｋ
035     * 縺溘ａ,縺薙％縺ｧ縺ｯ縲‘xecute() 繝｡繧ｽ繝?ラ繧貞ｮ溯｣?＠縺ｦ縺?∪縺吶?
036     * 縺薙?繧ｯ繝ｩ繧ｹ縺ｧ縺ｯ縲√せ繝??繝医Γ繝ｳ繝域枚繧?execute() 縺吶ｋ莠九↓繧医ｊ,繝??繧ｿ繝吶?繧ｹ繧?
037     * 讀懃ｴ｢縺励◆邨先棡繧?DBTableModel 縺ｫ蜑ｲ繧雁ｽ薙※縺ｾ縺吶?
038     *
039     * 萓具ｼ?
040     *     Hybs迢ｬ閾ｪ縺ｮ繧ｹ繝??繧ｿ繧ｹ繧?お繝ｩ繝ｼ繝｡繝?そ繝ｼ繧ｸ縺ｪ縺ｩ縺ｮ蠑墓焚繧呈戟縺溘↑縺??
041     *     荳?握逧?↑PL/SQL繧辰ALL縺励∪縺吶?
042     *     names 螻樊?縺ｧ謖?ｮ壹☆繧九?縺ｯ縲．BTableModel縺ｮ繧ｫ繝ｩ繝?錐縺ｧ縲√◎縺ｮ蛟､縺碁?逡ｪ縺ｫ縲?
043     *     蠑墓焚(?險伜捷)縺ｮ蛟区園縺ｫ險ｭ螳壹＆繧後∪縺吶?
044     *     蠑墓焚縺後?? 縺ｧ縺ｪ縺??謇?↓縺ｯ縲∫峩謗･蛟､繧定ｨｭ螳壹＠縺溘ｊ縲＋&#064;繧ｫ繝ｩ繝?錐}縺ｧ縲?
045     *     繝ｪ繧ｯ繧ｨ繧ｹ繝亥､画焚繧偵そ繝?ヨ縺吶ｋ莠九ｂ蜿ｯ閭ｽ縺ｧ縺吶?
046     *     驕ｸ謚槭＆繧後◆繝??繧ｿ(陦?縺ｮ謨ｰ縺?￠縲∫ｹｰ繧願ｿ斐＠螳溯｡後＆繧後∪縺吶?
047     *     荳玖ｨ倥?萓九?縲√ユ繝ｼ繝悶Ν縺ｮ繧｢繝翫Λ繧､繧ｶ繧貞ｮ溯｡後＠縺ｦ縺?∪縺吶?
048     *
049     *   jsp/ORA08/result.jsp
050     *   &lt;og:query
051     *     displayMsg = &quot;&quot;
052     *     command    = &quot;{&#064;command}&quot;
053     *     names      = &quot;TABLE_OWNER,TABLE_NAME&quot;
054     *     queryType  = &quot;JDBCUpdate&quot; &gt;
055     *          { call DBMS_STATS.GATHER_TABLE_STATS( ?,? ) }
056     *   &lt;/og:query&gt;
057     *
058     * @og.group 繝??繧ｿ邱ｨ髮?
059     *
060     * @version  4.0
061     * @author   Kazuhiko Hasegawa
062     * @since    JDK5.0,
063     */
064    public class Query_JDBCUpdate extends AbstractQuery {
065            //* 縺薙?繝励Ο繧ｰ繝ｩ繝??VERSION譁?ｭ怜?繧定ｨｭ螳壹＠縺ｾ縺吶?       {@value} */
066            private static final String VERSION = "4.0.0.0 (2005/08/31)" ;
067    
068            /**
069             * 蠑墓焚驟榊?莉倥?繧ｯ繧ｨ繝ｪ繝ｼ繧貞ｮ溯｡後＠縺ｾ縺吶?
070             * 蜃ｦ逅??菴薙?, #execute() 縺ｨ蜷梧ｧ倥↓縲∝推繧ｵ繝悶け繝ｩ繧ｹ縺ｮ螳溯｣?↓萓晏ｭ倥＠縺ｾ縺吶?
071             * 縺薙ｌ縺ｯ縲￣reparedQuery 縺ｧ菴ｿ逕ｨ縺吶ｋ蠑墓焚繧帝?蛻励〒繧ｻ繝?ヨ縺吶ｋ繧ゅ?縺ｧ縺吶?
072             * select * from emp where deptno = ? and job = ? 縺ｪ縺ｩ縺ｮ PreparedQuery 縺ｮ
073             * ? 驛ｨ蛻??蠑墓焚繧?
074             * 鬆?分縺ｫ繧ｻ繝?ヨ縺励※縺?″縺ｾ縺吶?
075             *
076             * @og.rev 3.1.1.0 (2003/03/28) 蜷梧悄繝｡繧ｽ繝?ラ(synchronized莉倥″)繧帝撼蜷梧悄縺ｫ螟画峩縺吶ｋ縲?
077             * @og.rev 3.3.3.1 (2003/07/18) ?､?｢逋ｻ骭ｲ譎ゅ?蠕後ｍ繧ｹ繝壹?繧ｹ繧貞炎髯､縺吶ｋ縲?
078             * @og.rev 3.5.6.0 (2004/06/18) null縺ｫ蟇ｾ縺吶ｋ辟｡鬧?↑豈碑ｼ?ｒ蜑企勁縺励∪縺吶?
079             * @og.rev 3.8.0.8 (2005/10/03) 繧ｨ繝ｩ繝ｼ繝｡繝?そ繝ｼ繧ｸ縺ｮ蜃ｺ蜉幃?繧偵Γ繝?そ繝ｼ繧ｸ?飢uery縺ｫ螟画峩縺励∪縺吶?
080             *
081             * @param   args 繧ｪ繝悶ず繧ｧ繧ｯ繝医?蠑墓焚驟榊?
082             */
083            @Override
084            public void execute( final String[] args ) {
085                    CallableStatement callStmt = null ;
086                    try {
087                            callStmt  = getConnection().prepareCall( getStatement() );
088                            callStmt.setQueryTimeout( DB_MAX_QUERY_TIMEOUT );
089    
090                            if( args != null ) {
091                                    for( int i=0; i<args.length; i++ ) {
092                                            callStmt.setObject( i+1,StringUtil.rTrim( args[i] ) );
093                                    }
094                            }
095                            callStmt.execute();
096                            setErrorCode( ErrorMessage.OK );
097                    }
098                    catch ( SQLException ex ) {
099                            setErrorCode( ErrorMessage.EXCEPTION );
100                            String errMsg = ex.getMessage() + ":" + ex.getSQLState() + HybsSystem.CR
101                                                    + getStatement() + HybsSystem.CR;
102                            rollback();
103                            realClose();
104                            throw new HybsSystemException( errMsg,ex );             // 3.5.5.4 (2004/04/15) 蠑墓焚縺ｮ荳ｦ縺ｳ鬆?､画峩
105                    }
106                    finally {
107                            Closer.stmtClose( callStmt );
108                    }
109            }
110    }