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