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.util;
017    
018    import java.sql.Connection;
019    import java.sql.CallableStatement;
020    import java.sql.SQLException;
021    
022    /**
023     * <P>ApplicationInfo.java 縺ｯ縲∝?騾夂噪縺ｫ菴ｿ逕ｨ縺輔ｌ繧?蜀?Κ諠??繧呈?邏阪☆繧九が繝悶ず繧ｧ繧ｯ繝医〒縺吶?</P>
024     *
025     * 蜀?Κ諠??縺ｨ縺ｯ縲∵磁邯壹Θ繝ｼ繧ｶ繝ｼ縺ｮ繧ｯ繝ｩ繧､繧｢繝ｳ繝域ュ蝣ｱ縺ｨ縲∝ｮ溯｡檎憾豕√?繧｢繝励Μ繧ｱ繝ｼ繧ｷ繝ｧ繝ｳ諠??縺後≠繧翫∪縺吶?
026     *
027     * 繧ｯ繝ｩ繧､繧｢繝ｳ繝域ュ蝣ｱ縺ｨ縺ｯ縲?i=192.168.51.81,h=null,u=C12345" 逧?↑譁?ｭ怜?縺ｧ縲?
028     * i=縺ｮ蠕後ｍ縺ｫ IP繧｢繝峨Ξ繧ｹ縲”=縺ｮ蠕後ｍ縺ｫ繝帙せ繝亥錐縲「=縺ｮ蠕後ｍ縺ｫ繝ｦ繝ｼ繧ｶ繝ｼ蜷阪ｒ繧ｻ繝?ヨ縺励※縲?
029     * DBMS_APPLICATION_INFO.SET_CLIENT_INFO( "i=192.168.51.81,h=null,u=C12345" ) 繧?
030     * CALL 縺励∪縺吶?
031     *
032     * 繧｢繝励Μ繧ｱ繝ｼ繧ｷ繝ｧ繝ｳ諠??縺ｨ縺ｯ縲?o=SELECT,p=GEXXXX" 逧?↑譁?ｭ怜?縺ｧ縲｛=縺ｮ蠕後ｍ縺ｫ 謫堺ｽ懊?
033     * p=縺ｮ蠕後ｍ縺ｫ繝励Ο繧ｰ繝ｩ繝?D繧偵そ繝?ヨ縺励※縲?
034     * DBMS_APPLICATION_INFO.SET_MODULE( "GE0010","o=謫堺ｽ?p=繝励Ο繧ｰ繝ｩ繝?D" ) 繧?
035     * CALL 縺励∪縺吶?
036     *
037     * 縺薙?PL/SQL 繧剃ｽｿ逕ｨ縺吶ｋ繧ｳ繝阪け繧ｷ繝ｧ繝ｳ縺ｫ縺､縺?※螳溯｡後☆繧九→縲√い繧ｯ繧ｻ繧ｹ繝ｭ繧ｰ險倬鹸繧定｡後≧轤ｺ縺ｮ
038     * 諠??縺ｨ縺励※蜿悶ｊ蜃ｺ縺吶％縺ｨ縺悟庄閭ｽ縺ｫ縺ｪ繧翫∪縺吶?
039     * 遒ｺ隱阪?縲〃$SESSION 縺ｮ MODULE , ACTION , CLIENT_INFO 縺ｧ陦後＞縺ｾ縺吶?
040     *
041     * 縺薙?繧ｯ繝ｩ繧ｹ縺ｯ縲∝酔譛溷喧縺輔ｌ縺ｦ縺?∪縺帙ｓ縲?
042     *
043     * @og.rev 3.8.7.0 (2006/12/15) 譁ｰ隕剰ｿｽ蜉?
044     *
045     * @version  0.9.0      2000/10/12
046     * @author       Kazuhiko Hasegawa
047     * @since        JDK1.1,
048     */
049    public final class ApplicationInfo {
050            /** SET_CLIENT_INFO( "i=192.168.51.81,h=null,u=C12345" ) */
051            public static final String CLIENT_INFO = "{ call DBMS_APPLICATION_INFO.SET_CLIENT_INFO( ? ) }" ;
052            /** SET_MODULE( "GE0010","o=謫堺ｽ?p=繝励Ο繧ｰ繝ｩ繝?D" ) */
053            public static final String MODULE      = "{ call DBMS_APPLICATION_INFO.SET_MODULE( ?,? ) }" ;
054    
055            private String gamenId          = null;
056            private String clientInfo       = "";
057            private String moduleInfo       = "";
058    
059            /**
060             * 繝ｦ繝ｼ繧ｶ繝ｼID,IP繧｢繝峨Ξ繧ｹ,繝帙せ繝亥錐 繧呈欠螳壹＠縺ｦ縲√け繝ｩ繧､繧｢繝ｳ繝域ュ蝣ｱ繧定ｨｭ螳壹＠縺ｾ縺吶?
061             *
062             * 繧ｯ繝ｩ繧､繧｢繝ｳ繝域ュ蝣ｱ縺ｨ縺ｯ縲?i=192.168.51.81,h=null,u=C12345" 逧?↑譁?ｭ怜?縺ｧ縲?
063             * i=縺ｮ蠕後ｍ縺ｫ IP繧｢繝峨Ξ繧ｹ縲”=縺ｮ蠕後ｍ縺ｫ繝帙せ繝亥錐縲「=縺ｮ蠕後ｍ縺ｫ繝ｦ繝ｼ繧ｶ繝ｼ蜷阪ｒ繧ｻ繝?ヨ
064             * 縺励※縺?∪縺吶?
065             *
066             * @param       userId  繝ｦ繝ｼ繧ｶ繝ｼID
067             * @param       ipAdrs  IP繧｢繝峨Ξ繧ｹ
068             * @param       host    繝帙せ繝亥錐
069             */
070            public void setClientInfo( final String userId,final String ipAdrs,final String host ) {
071                    StringBuilder buf = new StringBuilder();
072                    append( "i=" , ipAdrs , buf );
073                    append( "h=" , host   , buf );
074                    append( "u=" , userId , buf );
075    
076                    clientInfo = buf.toString() ;
077            }
078    
079            /**
080             * 逕ｻ髱｢ID,謫堺ｽ?繝励Ο繧ｰ繝ｩ繝?D繧呈欠螳壹＠縺ｦ縲√い繝励Μ繧ｱ繝ｼ繧ｷ繝ｧ繝ｳ縺ｫ髢｢縺吶ｋ諠??繧定ｨｭ螳壹＠縺ｾ縺吶?
081             *
082             * 繧ｯ繝ｩ繧､繧｢繝ｳ繝域ュ蝣ｱ縺ｨ縺ｯ縲?o=SELECT,p=GEXXXX" 逧?↑譁?ｭ怜?縺ｧ縲?
083             * o=縺ｮ蠕後ｍ縺ｫ 謫堺ｽ懊?p=縺ｮ蠕後ｍ縺ｫ繝励Ο繧ｰ繝ｩ繝?D繧偵そ繝?ヨ縺励※縺?∪縺吶?
084             *
085             * @param       gamenId 逕ｻ髱｢ID
086             * @param       ope             繧ｪ繝壹Ξ繝ｼ繧ｷ繝ｧ繝ｳ(謫堺ｽ?
087             * @param       prgId   繝励Ο繧ｰ繝ｩ繝?D
088             */
089            public void setModuleInfo( final String gamenId,final String ope,final String prgId ) {
090                    this.gamenId    = gamenId       ;
091    
092                    StringBuilder buf = new StringBuilder();
093                    append( "o=" , ope   , buf );
094                    append( "p=" , prgId , buf );
095    
096                    moduleInfo = buf.toString() ;
097            }
098    
099            /**
100             * setModuleInfo 縺ｧ譛?ｾ後↓險ｭ螳壹＆繧後◆ 逕ｻ髱｢ID繧定ｿ斐＠縺ｾ縺吶?
101             *
102             * 縺ｪ縺ｫ繧りｨｭ螳壹＆繧後※縺?↑縺??譛溽憾諷九?縲］ull 縺ｧ縺吶?
103             *
104             * @return      逕ｻ髱｢ID
105             * @see #setModuleInfo( String,String,String )
106             */
107            public String getGamenId() {
108                    return gamenId ;
109            }
110    
111            /**
112             * key 縺ｨ val 繧帝?邨舌＠縺滓枚蟄怜?繧剃ｽ懈?縺励∪縺吶?
113             * 蠑墓焚縺ｮ val 縺?null 縺ｮ蝣ｴ蜷医?縲∽ｽ輔ｂ謫堺ｽ懊＠縺ｾ縺帙ｓ縲?
114             * buf 縺ｫ縺吶〒縺ｫ縺ｪ縺ｫ縺九′逋ｻ骭ｲ貂医∩縺ｮ蝣ｴ蜷医?縲?," 繧定ｿｽ蜉?＠縺ｦ縺九ｉ縲??邨舌＠縺ｾ縺吶?
115             *
116             * @param       key     繧ｭ繝ｼ
117             * @param       val     蛟､
118             * @param       buf     騾｣邨舌☆繧鬼tringBuilder繧ｪ繝悶ず繧ｧ繧ｯ繝?
119             */
120            private void append( final String key,final String val,final StringBuilder buf ) {
121                    if( val != null ) {
122                            if( buf.length() == 0 ) { buf.append( key ).append( val ); }
123                            else { buf.append( ',' ).append( key ).append( val ); }
124                    }
125            }
126    
127            /**
128             * 繧｢繧ｯ繧ｻ繧ｹ繝ｭ繧ｰ險倬鹸繧定｡後≧轤ｺ縺ｮ DBMS_APPLICATION_INFO.SET_CLIENT_INFO 縺ｨ縲?
129             * DBMS_APPLICATION_INFO.SET_MODULE 繧?CALL 縺励∪縺吶?
130             *
131             * SET_CLIENT_INFO( "i=192.168.51.81,h=null,u=C12345" ) 縺ｧ縺ｯ縲?
132             * 繧ｯ繝ｩ繧､繧｢繝ｳ繝域ュ蝣ｱ縺ｨ縺励※縲?i=192.168.51.81,h=null,u=C12345" 逧?↑譁?ｭ怜?縺ｧ縲?
133             * i=縺ｮ蠕後ｍ縺ｫ IP繧｢繝峨Ξ繧ｹ縲”=縺ｮ蠕後ｍ縺ｫ繝帙せ繝亥錐縲「=縺ｮ蠕後ｍ縺ｫ繝ｦ繝ｼ繧ｶ繝ｼ蜷阪ｒ繧ｻ繝?ヨ縺励※縺?∪縺吶?
134             *
135             * SET_MODULE( "GE0010","o=謫堺ｽ?p=繝励Ο繧ｰ繝ｩ繝?D" )縺ｧ縺ｯ縲?
136             * 繧｢繝励Μ繧ｱ繝ｼ繧ｷ繝ｧ繝ｳ縺ｫ髢｢縺吶ｋ諠??縺ｨ縺励※縲?o=謫堺ｽ?p=繝励Ο繧ｰ繝ｩ繝?D" 繧偵そ繝?ヨ縺励※縺?∪縺吶?
137             * 遒ｺ隱阪?縲〃$SESSION 縺ｮ MODULE , ACTION , CLIENT_INFO 縺ｧ陦後＞縺ｾ縺吶?
138             *
139             * @param   conn 謗･邯壼?(繧ｳ繝阪け繧ｷ繝ｧ繝ｳ)
140             */
141            public void callAppInfo( final Connection conn ) {
142                    CallableStatement callStmt ;
143                    try {
144                            callStmt = conn.prepareCall( CLIENT_INFO );
145                            callStmt.setString( 1,clientInfo );
146                            callStmt.executeUpdate();
147                            callStmt.close();
148    
149                            callStmt = conn.prepareCall( MODULE );
150                            callStmt.setString( 1,gamenId );
151                            callStmt.setString( 2,moduleInfo );
152                            callStmt.executeUpdate();
153                            callStmt.close();
154                    }
155                    catch (SQLException ex) {
156                            String errMsg = "螻･豁ｴ蜿朱寔蜃ｦ逅?ｒ螳溯｡後〒縺阪∪縺帙ｓ縺ｧ縺励◆縲?
157                                            + ex.getMessage() + ":" + ex.getSQLState() ;
158                            throw new RuntimeException( errMsg,ex );
159                    }
160            }
161    
162            /**
163             * 縺薙?謗･邯壹′縲￣reparedStatement#getParameterMetaData() 繧剃ｽｿ逕ｨ縺吶ｋ縺九←縺?°繧貞愛螳壹＠縺ｾ縺吶?
164             *
165             * PreparedStatement 縺ｫ蟇ｾ縺励※縲ヾtring蛹悶＆繧後◆ 謨ｰ蟄励↑縺ｩ繧?setObject( int,String ) 縺吶ｋ縺ｨ縺阪?
166             * ORACLE 縺ｨ SQLServer 縺ｯ縲√◎縺ｮ縺ｾ縺ｾ險ｭ螳壹☆繧後?縲∬?蜍慕噪縺ｫ螟画鋤縺輔ｌ縺ｾ縺吶?
167             * postgreSQL 縺ｧ縺ｯ縲￣arameterMetaData#getParameterType(int) 縺ｧ縲√き繝ｩ繝?ち繧､繝励ｒ蜿門ｾ励＠縲?
168             * setObject( int,String,int ) 縺吶ｋ蠢?ｦ√′縺ゅｊ縺ｾ縺吶?
169             * 縺昴?蛻､螳壹↓縲√％縺ｮ繝｡繧ｽ繝?ラ繧剃ｽｿ逕ｨ縺励∪縺吶?
170             * 縺薙?邨先棡縺ｯ縲√≠縺上∪縺ｧ縲∝推遞ｮ繝??繧ｿ繝吶?繧ｹ豈弱?螳溷慍隱ｿ譟ｻ縺ｮ邨先棡繧貞?縺ｫ縲∝愛螳夂ｵ先棡繧?
171             * 霑斐☆繧医≧縺ｫ縺励※縺?∪縺吶?
172             * ORACLE 縺ｮ蝣ｴ蜷医?縲∽ｽｿ逕ｨ縺励↑縺?false)縺瑚ｿ斐ｋ繧医≧縺ｫ險ｭ螳壹＠縺ｦ縺?∪縺吶?
173             * SQLServer 縺ｧ縺ｯ縲＾RACLE縺ｨ蜷梧ｧ倥↓縲’alse 繧定ｿ斐＠縺ｾ縺吶?
174             *
175             * @og.rev 4.0.0.0 (2007/09/25) 譁ｰ隕剰ｿｽ蜉?
176             * @og.rev 5.1.1.0 (2009/12/01) MySQL/PostgreSQL 蟇ｾ蠢?
177             * @og.rev 5.3.8.0 (2011/08/01) 蟒?ｭ｢( ConnectionFactory#useParameterMetaData(String) 縺ｫ遘ｻ蜍?)
178             *
179             * @param   conn 謗･邯壼?(繧ｳ繝阪け繧ｷ繝ｧ繝ｳ)
180             *
181             * @return      菴ｿ逕ｨ縺吶ｋ蝣ｴ蜷茨ｼ嗾rue / 縺昴?莉?false
182             */
183    //      public static boolean useParameterMetaData( final Connection conn ) {
184    ////            return false;
185    //
186    //              try {
187    //                      DatabaseMetaData meta = conn.getMetaData();
188    //                      String dbProductName = meta.getDatabaseProductName();
189    //
190    //      //              if( "ORACLE".equalsIgnoreCase( dbProductName ) ) { return false; }
191    //      //              if( "Microsoft SQL Server".equalsIgnoreCase( dbProductName ) ) { return false; }
192    //
193    //                      if( "PostgreSQL".equalsIgnoreCase( dbProductName ) ) { return true; }
194    //
195    //                      return false ;
196    //              }
197    //              catch (SQLException ex) {
198    //                      String errMsg = "DatabaseMetaData 縺九ｉ縲“etDatabaseProductName 繧貞叙蠕励〒縺阪∪縺帙ｓ縺ｧ縺励◆縲?
199    //                                      + ex.getMessage() + ":" + ex.getSQLState() ;
200    //                      throw new RuntimeException( errMsg,ex );
201    //              }
202    //      }
203    }