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             * 迴ｾ譎らせ縺ｧ縺ｯ縲¨AME,CON,SUBSTR 縺ｮ縺ｿ菴ｿ逕ｨ縺ｧ縺阪∪縺吶?
075             *
076             *
077             * @og.rev 5.1.4.0 (2010/03/01) 譁ｰ隕丈ｽ懈?
078             *
079             * @param   func 蜈ｱ騾壹ヵ繧｡繝ｳ繧ｯ繧ｷ繝ｧ繝ｳ
080             *
081             * @return  繝輔ぃ繝ｳ繧ｯ繧ｷ繝ｧ繝ｳ蜷?
082             */
083            public String getFunctionName( final String func ) {
084                    if( "NAME".equals(   func ) ) { return toString();      }
085                    if( "CON".equals(    func ) ) { return dbfCON;          }
086                    if( "SUBSTR".equals( func ) ) { return dbfSUBSTR;       }
087    
088                    return func;
089            }
090    
091            /**
092             * 繧ｷ繝ｼ繧ｱ繝ｳ繧ｹ蜷阪ｈ繧翫す繝ｼ繧ｱ繝ｳ繧ｹ繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ讀懃ｴ｢縺励?谺｡縺ｮ蛟､繧貞叙繧雁?縺励∪縺吶?
093             * DB縺ｫ蟇ｾ縺吶ｋ繧ｷ繝ｼ繧ｱ繝ｳ繧ｹ繧ｪ繝悶ず繧ｧ繧ｯ繝医?莠医ａ菴懈?縺輔ｌ縺ｦ縺?ｋ蠢?ｦ√′縺ゅｊ縺ｾ縺吶?
094             *
095             * 縺ｾ縺溘?MySQL縺ｮ蝣ｴ蜷医?縲√す繝ｼ繧ｱ繝ｳ繧ｹ繧ｪ繝悶ず繧ｧ繧ｯ繝医′螳溯｣?＆繧後※縺?↑縺?◆繧√?
096             * 蜀?Κ逧?↓縺ｯ縲∝ｼ墓焚縺ｮ繧ｷ繝ｼ繧ｱ繝ｳ繧ｹ蜷阪→蜷後§蜷榊燕縺ｮ繝??繝悶Ν縺九ｉ縲！nteger蝙九?
097             * "SEQID"縺ｨ縺?≧鬆?岼蜷阪ｒ讀懃ｴ｢縺吶ｋ縺薙→縺ｫ繧医ｊ縲√す繝ｼ繧ｱ繝ｳ繧ｹ繧偵お繝溘Η繝ｬ繝ｼ繝医＠縺ｦ縺?∪縺吶?
098             *
099             * @og.rev 5.1.9.0 (2010/08/01) 譁ｰ隕剰ｿｽ蜉?
100             *
101             * @param seqName 繧ｷ繝ｼ繧ｱ繝ｳ繧ｹ蜷?
102             * @param tran 繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ
103             *
104             * @return 繧ｷ繝ｼ繧ｱ繝ｳ繧ｹ逡ｪ蜿ｷ
105             */
106            public int getSequence( final String seqName, final Transaction tran ) {
107                    String sql = null;
108                    String[][] rtn = null;
109                    switch ( this ) {
110                            case ORACLE:
111                                    sql = "select " + seqName + ".nextval from dual";
112                                    break;
113                            case HSQL:
114                                    sql = "select next value for " + seqName + " from dual";
115                                    break;
116                            case POSTGRES:
117                                    sql = "select nextval('" + seqName + "')";
118                                    break;
119                            case MYSQL:
120                                    sql = "update " + seqName + " set SEQID = last_insert_id(SEQID+1)";
121                                    DBUtil.dbExecute( sql, new String[0], tran );
122                                    sql = "select last_insert_id()";
123                                    break;
124                            case SQLSERVER:
125                                    throw new RuntimeException( "迴ｾ蝨ｨ縲ヾQLSERVER縺ｧ縺ｯ繧ｷ繝ｼ繧ｱ繝ｳ繧ｹ讖溯?縺ｯ繧ｵ繝昴?繝医＆繧後※縺?∪縺帙ｓ縲? );
126                            case FIREBIRD:
127                                    sql = "select gen_id(" + seqName + ", 1) from rdb$database";
128                                    break;
129                            default:
130                                    throw new RuntimeException( "迴ｾ蝨ｨ縲√％縺ｮ繝??繧ｿ繝吶?繧ｹ縺ｧ縺ｯ繧ｷ繝ｼ繧ｱ繝ｳ繧ｹ讖溯?縺ｯ繧ｵ繝昴?繝医＆繧後※縺?∪縺帙ｓ縲? );
131                    }
132    
133                    rtn = DBUtil.dbExecute( sql, new String[0], tran );
134                    return Integer.valueOf( rtn[0][0] );
135            }
136    
137            /**
138             * 蜷?ョ繝ｼ繧ｿ繝吶?繧ｹ縺ｫ蟇ｾ蠢懊☆繧菊num蜷阪ｒ霑斐＠縺ｾ縺吶?
139             *
140             * @og.rev 5.1.4.0 (2010/03/01) 譁ｰ隕丈ｽ懈?
141             *
142             * @param   dbName 繝??繧ｿ繝吶?繧ｹ蜷?
143             *
144             * @return  繝??繧ｿ繝吶?繧ｹ縺ｫ蟇ｾ蠢懊☆繧菊num蜷?
145             */
146            public static DBFunctionName getDBName( final String dbName ) {
147                    String dbn = dbName.toUpperCase( Locale.JAPAN );
148    
149                    if(      dbn.indexOf( "ORACLE"          ) >= 0 ) { return DBFunctionName.ORACLE;     }
150                    else if( dbn.indexOf( "HSQL"            ) >= 0 ) { return DBFunctionName.HSQL;               }
151                    else if( dbn.indexOf( "POSTGRES"        ) >= 0 ) { return DBFunctionName.POSTGRES;   }
152                    else if( dbn.indexOf( "MYSQL"           ) >= 0 ) { return DBFunctionName.MYSQL;              }
153                    else if( dbn.indexOf( "SQLSERVER"       ) >= 0 ) { return DBFunctionName.SQLSERVER;  }
154                    else if( dbn.indexOf( "FIREBIRD"        ) >= 0 ) { return DBFunctionName.FIREBIRD;   }
155    
156                    final String errMsg = "蛻晄悄蛹匁凾縺ｫ縲∵欠螳壹? dbName 繧ｭ繝ｼ縺悟ｭ伜惠縺励∪縺帙ｓ縲?
157                                                    + "[" + dbn + "]" ;
158    
159                    throw new RuntimeException( errMsg );
160            }
161    
162            /**
163             * 蜷?ョ繝ｼ繧ｿ繝吶?繧ｹ縺ｫ蟇ｾ蠢懊☆繧九ヵ繧｡繝ｳ繧ｯ繧ｷ繝ｧ繝ｳ蜷阪ｒ霑斐＠縺ｾ縺吶?
164             *
165             * @og.rev 4.3.8.0 (2009/08/01) SUBSTR繧定ｿｽ蜉?
166             * @og.rev 5.1.2.0 (2010/01/01) MySQL蟇ｾ蠢?SUBSTRB蟒?ｭ｢(蟶ｳ逾ｨ繝??繧ｿ縺ｮ蛻?牡縺ｮ蜀?Κ蜃ｦ逅?喧縺ｫ莨ｴ縺?
167             * @og.rev 5.1.4.0 (2010/03/01) 繝??繧ｿ繝吶?繧ｹ蜷?縺ｧ縺ｯ縺ｪ縺上?dbid 縺ｧ蛻､譁ｭ縺吶ｋ繧医≧縺ｫ螟画峩
168             * @og.rev 5.7.7.2 (2014/06/20) DBF.NAME 譎ゅ?蜃ｦ逅??邁｡邏?喧
169             *
170             * @param   func 繝輔ぃ繝ｳ繧ｯ繧ｷ繝ｧ繝ｳ蜷?螳夂ｾｩ譁?ｭ?
171             * @param   dbid 謗･邯壼?ID
172             *
173             * @return  螳溘ヵ繧｡繝ｳ繧ｯ繧ｷ繝ｧ繝ｳ蜷?
174             */
175            public static String getFunctionName( final String func ,final String dbid ) {
176    //              DBFunctionName dbName = DBFunctionName.getDBName( ConnectionFactory.getDBName( dbid ) );
177    
178                    // 5.7.7.2 (2014/06/20) DBF.NAME 譎ゅ?蜃ｦ逅??邁｡邏?喧
179                    String dbName = ConnectionFactory.getDBName( dbid );
180                    if( "NAME".equals( func ) ) { return dbName; }
181                    else {
182                            return getDBName( dbName ).getFunctionName( func );
183                    }
184    
185    //              return dbName.getFunctionName( func );
186            }
187    }