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 java.sql.ResultSet;
019    import java.sql.SQLException;
020    import java.sql.Statement;
021    
022    import org.opengion.fukurou.util.Closer;
023    import org.opengion.fukurou.util.ErrorMessage;
024    import org.opengion.hayabusa.common.HybsSystem;
025    import org.opengion.hayabusa.common.HybsSystemException;
026    import org.opengion.hayabusa.db.AbstractQuery;
027    
028    /**
029     * 謖?ｮ壹?SQL譁?ｒ螳溯｡後＠縺ｦ縲∵､懃ｴ｢縺吶ｋ Query 繧ｯ繝ｩ繧ｹ縺ｧ縺吶?
030     *
031     * java.sql.Statement 繧堤畑縺?※縲√ョ繝ｼ繧ｿ繝吶?繧ｹ讀懃ｴ｢蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
032     * 蠑墓焚縺ｯ辟｡縺励〒縺吶?(荳弱∴繧峨ｌ縺欖QL譁?ｒ螳溯｡後＠縺ｾ縺吶?)
033     * 蜀?Κ螟画焚縺ｮ蜿励￠貂｡縺励?繝?ヵ繧ｩ繝ｫ繝亥ｮ溯｣??縲、bstractQuery 繧ｯ繝ｩ繧ｹ繧堤ｶ呎価縺励※縺?ｋ
034     * 縺溘ａ,縺薙％縺ｧ縺ｯ縲‘xecute() 繝｡繧ｽ繝?ラ繧貞ｮ溯｣?＠縺ｦ縺?∪縺吶?
035     * 縺薙?繧ｯ繝ｩ繧ｹ縺ｧ縺ｯ縲√せ繝??繝医Γ繝ｳ繝域枚繧?execute() 縺吶ｋ莠九↓繧医ｊ,繝??繧ｿ繝吶?繧ｹ繧?
036     * 讀懃ｴ｢縺励◆邨先棡繧?DBTableModel 縺ｫ蜑ｲ繧雁ｽ薙※縺ｾ縺吶?
037     *
038     * @og.formSample
039     * &lt;og:query command=&quot;{&#064;command}&quot; debug=&quot;false&quot;&gt;
040     *     &lt;!-- 蜈磯?縺ｮ繧ｫ繝ｩ繝?錐縺後?&quot;WRITABLE&quot; 縺ｮ蝣ｴ蜷医?&#39;true&#39; or &#39;1&#39; 縺ｧ縲∵嶌縺崎ｾｼ縺ｿ險ｱ蜿ｯ縺御ｸ弱∴繧?&#39;2&#39; 縺ｧ繝√ぉ繝?け貂医∩縺ｫ縺ｪ繧翫∪縺吶?--&gt;
041     *         select KBSAKU AS WRITABLE,
042     *                 CLM,NAME_JA,LABEL_NAME,KBSAKU,SYSTEM_ID,LANG,FGJ
043     *         from GE41
044     *     &lt;og:where&gt;
045     *         &lt;og:and value = &quot;FGJ         in  (&#39;0&#39;,&#39;1&#39;)&quot;         /&gt;
046     *         &lt;og:and value = &quot;SYSTEM_ID   like &#39;{&#064;SYSTEM_ID}%&#39;&quot;  /&gt;
047     *         &lt;og:and value = &quot;LANG        like &#39;{&#064;LANG}%&#39;&quot;       /&gt;
048     *         &lt;og:and value = &quot;CLM         like &#39;{&#064;CLM}%&#39;&quot;        /&gt;
049     *         &lt;og:and value = &quot;KBSAKU      =    &#39;{&#064;KBSAKU}&#39;&quot;      /&gt;
050     *     &lt;/og:where&gt;
051     *     &lt;og:appear startKey = &quot;order by&quot; value = &quot;{&#064;ORDER_BY}&quot;
052     *                 defaultVal = &quot;SYSTEM_ID,CLM,LANG&quot; /&gt;
053     * &lt;/og:query&gt;
054     *
055     * @og.group 繝??繧ｿ陦ｨ遉ｺ
056     * @og.group 繝??繧ｿ邱ｨ髮?
057     *
058     * @version  4.0
059     * @author   Kazuhiko Hasegawa
060     * @since    JDK5.0,
061     */
062    public class Query_JDBC extends AbstractQuery {
063            //* 縺薙?繝励Ο繧ｰ繝ｩ繝??VERSION譁?ｭ怜?繧定ｨｭ螳壹＠縺ｾ縺吶?       {@value} */
064            private static final String VERSION = "4.0.0.0 (2005/08/31)" ;
065    
066            /**
067             * 繧ｯ繧ｨ繝ｪ繝ｼ繧貞ｮ溯｡後＠縺ｾ縺吶?
068             * 繧ｻ繝?ヨ縺輔ｌ縺ｦ縺?ｋ繧ｹ繝??繝医Γ繝ｳ繝域枚蟄怜?縺ｨ縺昴?繧ｿ繧､繝励′蜷医▲縺ｦ縺?↑縺??蜷医?,
069             * 繧ｨ繝ｩ繝ｼ縺ｫ縺ｪ繧翫∪縺吶?
070             * 螳溯｡檎ｵ先棡縺ｯ縲．BTableModel 縺ｫ繧ｻ繝?ヨ縺輔ｌ縺ｾ縺吶?
071             *
072             * @og.rev 3.8.0.8 (2005/10/03) 繧ｨ繝ｩ繝ｼ繝｡繝?そ繝ｼ繧ｸ縺ｮ蜃ｺ蜉幃?繧偵Γ繝?そ繝ｼ繧ｸ?飢uery縺ｫ螟画峩縺励∪縺吶?
073             *
074             */
075            @Override
076            public void execute() {
077                    Statement stmt = null ;
078                    ResultSet resultSet = null ;
079                    try {
080                            stmt = getConnection().createStatement();
081                            stmt.setQueryTimeout( DB_MAX_QUERY_TIMEOUT );
082    
083                            boolean status = stmt.execute( getStatement() );
084    
085                            if( status ) {
086                                    resultSet = stmt.getResultSet();
087                                    createTableModel( resultSet );
088                                    setUpdateFlag( false );
089                            }
090                            else {
091                                    setExecuteCount( stmt.getUpdateCount() );
092                            }
093                            setErrorCode( ErrorMessage.OK );
094                    }
095                    catch ( SQLException ex ) {
096                            setErrorCode( ErrorMessage.EXCEPTION );
097                            String errMsg = ex.getMessage() + ":" + ex.getSQLState() + HybsSystem.CR
098                                                    + getStatement() + HybsSystem.CR;
099                            rollback();
100                            realClose();
101                            throw new HybsSystemException( errMsg,ex );             // 3.5.5.4 (2004/04/15) 蠑墓焚縺ｮ荳ｦ縺ｳ鬆?､画峩
102                    }
103                    finally {
104                            Closer.resultClose( resultSet );
105                            Closer.stmtClose( stmt );
106                    }
107            }
108    }