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.db;
017    
018    import java.util.Locale;
019    
020    /**
021     * 蜷?ョ繝ｼ繧ｿ繝吶?繧ｹ縺ｫ蟇ｾ蠢懊☆繧菊num蜷阪ｒ霑斐＠縺ｾ縺吶?
022     * 荳ｻ縺ｫ縲∝推繝??繧ｿ繝吶?繧ｹ縺ｫ縺翫￠繧矩未謨ｰ蜷阪?蟾ｮ逡ｰ繧貞精蜿弱☆繧九◆繧√?enum縺ｧ縺吶?
023     * 譛ｬ譚･縺ｯ縲∽ｺ呈鋤諤ｧ縺ｮ縺ゅｋ繝輔ぃ繝ｳ繧ｯ繧ｷ繝ｧ繝ｳ莉･螟悶?菴ｿ逕ｨ縺励↑縺?ｈ縺?↓縺励∪縺励ｇ縺??
024     * 縺ｾ縺溘?辟｡縺代ｌ縺ｰ莠呈鋤諤ｧ繝代ャ繧ｯ縺ｪ縺ｩ縺ｧ縲√ヵ繧｡繝ｳ繧ｯ繧ｷ繝ｧ繝ｳ繧貞ｮ夂ｾｩ縺励※縺励∪縺??繧?
025     * 荳?▽縺ｮ譁ｹ豕輔〒縺吶?
026     *
027     * <table border="1" frame="box" rules="all" >
028     *  <caption>蜷?ョ繝ｼ繧ｿ繝吶?繧ｹ縺ｫ縺翫￠繧矩未謨ｰ</caption>
029     *  <tr><th>繝??繧ｿ繝吶?繧ｹ蜷?</th><th>騾｣邨?/th><th>驛ｨ蛻?枚蟄怜?</th></tr>
030     *  <tr><td>{&#064;DBF.XXX}</td><td>CON </td><td>SUBSTR    </td></tr>
031     *  <tr><td>ORACLE         </td><td>||  </td><td>SUBSTR    </td></tr>
032     *  <tr><td>HSQL           </td><td>||  </td><td>SUBSTR    </td></tr>
033     *  <tr><td>POSTGRES       </td><td>||  </td><td>SUBSTR    </td></tr>
034     *  <tr><td>MYSQL          </td><td>||  </td><td>SUBSTR    </td></tr>
035     *  <tr><td>SQLSERVER      </td><td>+   </td><td>SUBSTRING </td></tr>
036     *  <tr><td>FIREBIRD       </td><td>||  </td><td>SUBSTR    </td></tr>
037     * </table>
038     *
039     * @og.rev 5.1.4.0 (2010/03/01) 譁ｰ隕丈ｽ懈?
040     *
041     * @version  5.0
042     * @author   Kazuhiko Hasegawa
043     * @since    JDK5.0,
044     */
045    public enum DBFunctionName {
046            // 蠑墓焚莉倥″enum螳夂ｾｩ?壹％縺薙↓縲∝ｿ?ｦ√↑髢｢謨ｰ縺悟｢励∴繧九◆縺ｳ縺ｫ縲∬ｿｽ蜉?＠縺ｦ縺?″縺ｾ縺吶?
047            //                        CON   SUBSTR
048              ORACLE        ( "||","SUBSTR" )
049            , HSQL          ( "||","SUBSTR" )
050            , POSTGRES      ( "||","SUBSTR" )
051            , MYSQL         ( "||","SUBSTR" )
052            , SQLSERVER     ( "+" ,"SUBSTRING" )
053            , FIREBIRD      ( "||","SUBSTR" ) ;
054    
055            private final String dbfCON ;
056            private final String dbfSUBSTR ;
057    
058            /**
059             * 繧ｳ繝ｳ繧ｹ繝医Λ繧ｯ繧ｿ繝ｼ(enum 縺ｮ蝣ｴ蜷医?縲｝rivate螳｣險?＆繧後ｋ)
060             *
061             * @og.rev 5.1.4.0 (2010/03/01) 譁ｰ隕丈ｽ懈?
062             *
063             * @param       con     隨ｬ荳?ｼ墓焚縺ｫ縺ｦ謖?ｮ?CON)
064             * @param       substr  隨ｬ荳?ｼ墓焚縺ｫ縺ｦ謖?ｮ?SUBSTR)
065             */
066            private DBFunctionName( final String con , final String substr ) {
067                    dbfCON    = con;
068                    dbfSUBSTR = substr;
069            }
070    
071            /**
072             * 蜈ｱ騾壹ヵ繧｡繝ｳ繧ｯ繧ｷ繝ｧ繝ｳ縺ｫ蟇ｾ蠢懊☆繧九ョ繝ｼ繧ｿ繝吶?繧ｹ蛟句挨縺ｮ繝輔ぃ繝ｳ繧ｯ繧ｷ繝ｧ繝ｳ蜷阪ｒ霑斐＠縺ｾ縺吶?
073             *
074             * @og.rev 5.1.4.0 (2010/03/01) 譁ｰ隕丈ｽ懈?
075             *
076             * @param   func 蜈ｱ騾壹ヵ繧｡繝ｳ繧ｯ繧ｷ繝ｧ繝ｳ
077             *
078             * @return  繝輔ぃ繝ｳ繧ｯ繧ｷ繝ｧ繝ｳ蜷?
079             */
080            public String getFunctionName( final String func ) {
081                    if( "NAME".equals( func ) ) { return toString(); }
082                    if( "CON".equals( func ) ) { return dbfCON; }
083                    if( "SUBSTR".equals( func ) ) { return dbfSUBSTR; }
084    
085                    return func;
086            }
087    
088            /**
089             * 繧ｷ繝ｼ繧ｱ繝ｳ繧ｹ蜷阪ｈ繧翫す繝ｼ繧ｱ繝ｳ繧ｹ繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ讀懃ｴ｢縺励?谺｡縺ｮ蛟､繧貞叙繧雁?縺励∪縺吶?
090             * DB縺ｫ蟇ｾ縺吶ｋ繧ｷ繝ｼ繧ｱ繝ｳ繧ｹ繧ｪ繝悶ず繧ｧ繧ｯ繝医?莠医ａ菴懈?縺輔ｌ縺ｦ縺?ｋ蠢?ｦ√′縺ゅｊ縺ｾ縺吶?
091             *
092             * 縺ｾ縺溘?MySQL縺ｮ蝣ｴ蜷医?縲√す繝ｼ繧ｱ繝ｳ繧ｹ繧ｪ繝悶ず繧ｧ繧ｯ繝医′螳溯｣?＆繧後※縺?↑縺?◆繧√?
093             * 蜀?Κ逧?↓縺ｯ縲∝ｼ墓焚縺ｮ繧ｷ繝ｼ繧ｱ繝ｳ繧ｹ蜷阪→蜷後§蜷榊燕縺ｮ繝??繝悶Ν縺九ｉ縲！nteger蝙九?
094             * "SEQID"縺ｨ縺?≧鬆?岼蜷阪ｒ讀懃ｴ｢縺吶ｋ縺薙→縺ｫ繧医ｊ縲√す繝ｼ繧ｱ繝ｳ繧ｹ繧偵お繝溘Η繝ｬ繝ｼ繝医＠縺ｦ縺?∪縺吶?
095             *
096             * @og.rev 5.1.9.0 (2010/08/01) 譁ｰ隕剰ｿｽ蜉?
097             *
098             * @param seqName 繧ｷ繝ｼ繧ｱ繝ｳ繧ｹ蜷?
099             * @param tran 繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ
100             *
101             * @return 繧ｷ繝ｼ繧ｱ繝ｳ繧ｹ逡ｪ蜿ｷ
102             */
103            public int getSequence( final String seqName, final Transaction tran ) {
104                    String sql = null;
105                    String[][] rtn = null;
106                    switch ( this ) {
107                            case ORACLE:
108                                    sql = "select " + seqName + ".nextval from dual";
109                                    break;
110                            case HSQL:
111                                    sql = "select next value for " + seqName + " from dual";
112                                    break;
113                            case POSTGRES:
114                                    sql = "select nextval('" + seqName + "')";
115                                    break;
116                            case MYSQL:
117                                    sql = "update " + seqName + " set SEQID = last_insert_id(SEQID+1)";
118                                    DBUtil.dbExecute( sql, new String[0], tran );
119                                    sql = "select last_insert_id()";
120                                    break;
121                            case SQLSERVER:
122                                    throw new RuntimeException( "迴ｾ蝨ｨ縲ヾQLSERVER縺ｧ縺ｯ繧ｷ繝ｼ繧ｱ繝ｳ繧ｹ讖溯?縺ｯ繧ｵ繝昴?繝医＆繧後※縺?∪縺帙ｓ縲? );
123                            case FIREBIRD:
124                                    sql = "select gen_id(" + seqName + ", 1) from rdb$database";
125                                    break;
126                            default:
127                                    throw new RuntimeException( "迴ｾ蝨ｨ縲√％縺ｮ繝??繧ｿ繝吶?繧ｹ縺ｧ縺ｯ繧ｷ繝ｼ繧ｱ繝ｳ繧ｹ讖溯?縺ｯ繧ｵ繝昴?繝医＆繧後※縺?∪縺帙ｓ縲? );
128                    }
129    
130                    rtn = DBUtil.dbExecute( sql, new String[0], tran );
131                    return Integer.valueOf( rtn[0][0] );
132            }
133    
134            /**
135             * 蜷?ョ繝ｼ繧ｿ繝吶?繧ｹ縺ｫ蟇ｾ蠢懊☆繧菊num蜷阪ｒ霑斐＠縺ｾ縺吶?
136             *
137             * @og.rev 5.1.4.0 (2010/03/01) 譁ｰ隕丈ｽ懈?
138             *
139             * @param   dbName 繝??繧ｿ繝吶?繧ｹ蜷?
140             *
141             * @return  繝??繧ｿ繝吶?繧ｹ縺ｫ蟇ｾ蠢懊☆繧菊num蜷?
142             */
143            public static DBFunctionName getDBName( final String dbName ) {
144                    String dbn = dbName.toUpperCase( Locale.JAPAN );
145    
146                    if(      dbn.indexOf( "ORACLE"          ) >= 0 ) { return DBFunctionName.ORACLE;     }
147                    else if( dbn.indexOf( "HSQL"            ) >= 0 ) { return DBFunctionName.HSQL;               }
148                    else if( dbn.indexOf( "POSTGRES"        ) >= 0 ) { return DBFunctionName.POSTGRES;   }
149                    else if( dbn.indexOf( "MYSQL"           ) >= 0 ) { return DBFunctionName.MYSQL;              }
150                    else if( dbn.indexOf( "SQLSERVER"       ) >= 0 ) { return DBFunctionName.SQLSERVER;  }
151                    else if( dbn.indexOf( "FIREBIRD"        ) >= 0 ) { return DBFunctionName.FIREBIRD;   }
152    
153                    final String errMsg = "蛻晄悄蛹匁凾縺ｫ縲∵欠螳壹? dbName 繧ｭ繝ｼ縺悟ｭ伜惠縺励∪縺帙ｓ縲?
154                                                    + "[" + dbn + "]" ;
155    
156                    throw new RuntimeException( errMsg );
157            }
158    
159            /**
160             * 蜷?ョ繝ｼ繧ｿ繝吶?繧ｹ縺ｫ蟇ｾ蠢懊☆繧九ヵ繧｡繝ｳ繧ｯ繧ｷ繝ｧ繝ｳ蜷阪ｒ霑斐＠縺ｾ縺吶?
161             *
162             * @og.rev 4.3.8.0 (2009/08/01) SUBSTR繧定ｿｽ蜉?
163             * @og.rev 5.1.2.0 (2010/01/01) MySQL蟇ｾ蠢?SUBSTRB蟒?ｭ｢(蟶ｳ逾ｨ繝??繧ｿ縺ｮ蛻?牡縺ｮ蜀?Κ蜃ｦ逅?喧縺ｫ莨ｴ縺?
164             * @og.rev 5.1.4.0 (2010/03/01) 繝??繧ｿ繝吶?繧ｹ蜷?縺ｧ縺ｯ縺ｪ縺上?dbid 縺ｧ蛻､譁ｭ縺吶ｋ繧医≧縺ｫ螟画峩
165             *
166             * @param   func 繝輔ぃ繝ｳ繧ｯ繧ｷ繝ｧ繝ｳ蜷?螳夂ｾｩ譁?ｭ?
167             * @param   dbid 謗･邯壼?ID
168             *
169             * @return  螳溘ヵ繧｡繝ｳ繧ｯ繧ｷ繝ｧ繝ｳ蜷?
170             */
171            public static String getFunctionName( final String func ,final String dbid ) {
172                    DBFunctionName dbName = DBFunctionName.getDBName( ConnectionFactory.getDBName( dbid ) );
173    
174                    return dbName.getFunctionName( func );
175            }
176    
177    }