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 * å?ƒ‡ãƒ¼ã‚¿ãƒ™ã?スã«å¯¾å¿œã™ã‚‹enumåã‚’è¿”ã—ã¾ã™ã?
022 * 主ã«ã€å„ãƒ??タベã?スã«ãŠã‘る関数åã?差異をå¸åŽã™ã‚‹ãŸã‚ã?enumã§ã™ã?
023 * 本æ¥ã¯ã€äº’æ›æ€§ã®ã‚るファンクション以外ã?使用ã—ãªã?‚ˆã?«ã—ã¾ã—ょã??
024 * ã¾ãŸã?ç„¡ã‘ã‚Œã°äº’æ›æ€§ãƒ‘ックãªã©ã§ã€ãƒ•ã‚¡ãƒ³ã‚¯ã‚·ãƒ§ãƒ³ã‚’定義ã—ã¦ã—ã¾ã??ã‚?
025 * ä¸?¤ã®æ–¹æ³•ã§ã™ã?
026 *
027 * <table border="1" frame="box" rules="all" >
028 * <tr><th>ãƒ??タベã?スå?</th><th>連çµ?/th><th>部åˆ?–‡å—å?</th></tr>
029 * <tr><td>{@DBF.XXX}</td><td>CON </td><td>SUBSTR </td></tr>
030 * <tr><td>ORACLE </td><td>|| </td><td>SUBSTR </td></tr>
031 * <tr><td>HSQL </td><td>|| </td><td>SUBSTR </td></tr>
032 * <tr><td>POSTGRES </td><td>|| </td><td>SUBSTR </td></tr>
033 * <tr><td>MYSQL </td><td>|| </td><td>SUBSTR </td></tr>
034 * <tr><td>SQLSERVER </td><td>+ </td><td>SUBSTRING </td></tr>
035 * <tr><td>FIREBIRD </td><td>|| </td><td>SUBSTR </td></tr>
036 * </table>
037 *
038 * @og.rev 5.1.4.0 (2010/03/01) æ–°è¦ä½œæ?
039 *
040 * @version 5.0
041 * @author Kazuhiko Hasegawa
042 * @since JDK5.0,
043 */
044 public enum DBFunctionName {
045 // 引数付ãenum定義?šã“ã“ã«ã€å¿?¦ãªé–¢æ•°ãŒå¢—ãˆã‚‹ãŸã³ã«ã€è¿½åŠ?—ã¦ã?ã¾ã™ã?
046 // CON SUBSTR
047 ORACLE ( "||","SUBSTR" )
048 , HSQL ( "||","SUBSTR" )
049 , POSTGRES ( "||","SUBSTR" )
050 , MYSQL ( "||","SUBSTR" )
051 , SQLSERVER ( "+" ,"SUBSTRING" )
052 , FIREBIRD ( "||","SUBSTR" ) ;
053
054 private final String dbfCON ;
055 private final String dbfSUBSTR ;
056
057 /**
058 * コンストラクター(enum ã®å ´åˆã?ã€private宣è¨?•ã‚Œã‚‹)
059 *
060 * @og.rev 5.1.4.0 (2010/03/01) æ–°è¦ä½œæ?
061 *
062 * @param con 第ä¸?¼•æ•°ã«ã¦æŒ?®?CON)
063 * @param substr 第ä¸?¼•æ•°ã«ã¦æŒ?®?SUBSTR)
064 */
065 private DBFunctionName( final String con , final String substr ) {
066 dbfCON = con;
067 dbfSUBSTR = substr;
068 }
069
070 /**
071 * 共通ファンクションã«å¯¾å¿œã™ã‚‹ãƒ‡ãƒ¼ã‚¿ãƒ™ã?ス個別ã®ãƒ•ã‚¡ãƒ³ã‚¯ã‚·ãƒ§ãƒ³åã‚’è¿”ã—ã¾ã™ã?
072 *
073 * @og.rev 5.1.4.0 (2010/03/01) æ–°è¦ä½œæ?
074 *
075 * @param func 共通ファンクション
076 *
077 * @return ファンクションå?
078 */
079 public String getFunctionName( final String func ) {
080 if( "NAME".equals( func ) ) { return toString(); }
081 if( "CON".equals( func ) ) { return dbfCON; }
082 if( "SUBSTR".equals( func ) ) { return dbfSUBSTR; }
083
084 return func;
085 }
086
087 /**
088 * シーケンスåよりシーケンスオブジェクトを検索ã—ã?次ã®å€¤ã‚’å–ã‚Šå?ã—ã¾ã™ã?
089 * DBã«å¯¾ã™ã‚‹ã‚·ãƒ¼ã‚±ãƒ³ã‚¹ã‚ªãƒ–ジェクトã?予ã‚作æ?ã•ã‚Œã¦ã?‚‹å¿?¦ãŒã‚ã‚Šã¾ã™ã?
090 *
091 * ã¾ãŸã?MySQLã®å ´åˆã?ã€ã‚·ãƒ¼ã‚±ãƒ³ã‚¹ã‚ªãƒ–ジェクトãŒå®Ÿè£?•ã‚Œã¦ã?ªã?Ÿã‚ã?
092 * å†?ƒ¨çš?«ã¯ã€å¼•æ•°ã®ã‚·ãƒ¼ã‚±ãƒ³ã‚¹åã¨åŒã˜åå‰ã®ãƒ??ブルã‹ã‚‰ã€Integeråž‹ã?
093 * "SEQID"ã¨ã?†é ?›®åを検索ã™ã‚‹ã“ã¨ã«ã‚ˆã‚Šã€ã‚·ãƒ¼ã‚±ãƒ³ã‚¹ã‚’エミュレートã—ã¦ã?¾ã™ã?
094 *
095 * @og.rev 5.1.9.0 (2010/08/01) æ–°è¦è¿½åŠ?
096 *
097 * @param seqName シーケンスå?
098 * @param tran トランザクション
099 *
100 * @return シーケンス番å·
101 */
102 public int getSequence( final String seqName, final Transaction tran ) {
103 String sql = null;
104 String[][] rtn = null;
105 switch ( this ) {
106 case ORACLE:
107 sql = "select " + seqName + ".nextval from dual";
108 break;
109 case HSQL:
110 sql = "select next value for " + seqName + " from dual";
111 break;
112 case POSTGRES:
113 sql = "select nextval('" + seqName + "')";
114 break;
115 case MYSQL:
116 sql = "update " + seqName + " set SEQID = last_insert_id(SEQID+1)";
117 DBUtil.dbExecute( sql, new String[0], tran );
118 sql = "select last_insert_id()";
119 break;
120 case SQLSERVER:
121 throw new RuntimeException( "ç¾åœ¨ã€SQLSERVERã§ã¯ã‚·ãƒ¼ã‚±ãƒ³ã‚¹æ©Ÿè?ã¯ã‚µãƒã?トã•ã‚Œã¦ã?¾ã›ã‚“ã€? );
122 case FIREBIRD:
123 sql = "select gen_id(" + seqName + ", 1) from rdb$database";
124 break;
125 default:
126 throw new RuntimeException( "ç¾åœ¨ã€ã“ã®ãƒ??タベã?スã§ã¯ã‚·ãƒ¼ã‚±ãƒ³ã‚¹æ©Ÿè?ã¯ã‚µãƒã?トã•ã‚Œã¦ã?¾ã›ã‚“ã€? );
127 }
128
129 rtn = DBUtil.dbExecute( sql, new String[0], tran );
130 return Integer.valueOf( rtn[0][0] );
131 }
132
133 /**
134 * å?ƒ‡ãƒ¼ã‚¿ãƒ™ã?スã«å¯¾å¿œã™ã‚‹enumåã‚’è¿”ã—ã¾ã™ã?
135 *
136 * @og.rev 5.1.4.0 (2010/03/01) æ–°è¦ä½œæ?
137 *
138 * @param dbName ãƒ??タベã?スå?
139 *
140 * @return ãƒ??タベã?スã«å¯¾å¿œã™ã‚‹enumå?
141 */
142 public static DBFunctionName getDBName( final String dbName ) {
143 String dbn = dbName.toUpperCase( Locale.JAPAN );
144
145 if( dbn.indexOf( "ORACLE" ) >= 0 ) { return DBFunctionName.ORACLE; }
146 else if( dbn.indexOf( "HSQL" ) >= 0 ) { return DBFunctionName.HSQL; }
147 else if( dbn.indexOf( "POSTGRES" ) >= 0 ) { return DBFunctionName.POSTGRES; }
148 else if( dbn.indexOf( "MYSQL" ) >= 0 ) { return DBFunctionName.MYSQL; }
149 else if( dbn.indexOf( "SQLSERVER" ) >= 0 ) { return DBFunctionName.SQLSERVER; }
150 else if( dbn.indexOf( "FIREBIRD" ) >= 0 ) { return DBFunctionName.FIREBIRD; }
151
152 final String errMsg = "åˆæœŸåŒ–時ã«ã€æŒ‡å®šã? dbName ã‚ーãŒå˜åœ¨ã—ã¾ã›ã‚“ã€?
153 + "[" + dbn + "]" ;
154
155 throw new RuntimeException( errMsg );
156 }
157
158 /**
159 * å?ƒ‡ãƒ¼ã‚¿ãƒ™ã?スã«å¯¾å¿œã™ã‚‹ãƒ•ã‚¡ãƒ³ã‚¯ã‚·ãƒ§ãƒ³åã‚’è¿”ã—ã¾ã™ã?
160 *
161 * @og.rev 4.3.8.0 (2009/08/01) SUBSTRを追�
162 * @og.rev 5.1.2.0 (2010/01/01) MySQL対å¿?SUBSTRBå»?¢(帳票ãƒ??ã‚¿ã®åˆ?‰²ã®å†?ƒ¨å‡¦ç?Œ–ã«ä¼´ã?
163 * @og.rev 5.1.4.0 (2010/03/01) ãƒ??タベã?スå?ã§ã¯ãªãã?dbid ã§åˆ¤æ–ã™ã‚‹ã‚ˆã†ã«å¤‰æ›´
164 *
165 * @param func ファンクションå?定義æ–??
166 * @param dbid 接続å?ID
167 *
168 * @return 実ファンクションå?
169 */
170 public static String getFunctionName( final String func ,final String dbid ) {
171 DBFunctionName dbName = DBFunctionName.getDBName( ConnectionFactory.getDBName( dbid ) );
172
173 return dbName.getFunctionName( func );
174 }
175
176 }