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 }