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 org.opengion.fukurou.util.AbstractObjectPool;
019    import org.opengion.fukurou.util.ApplicationInfo;
020    import org.opengion.fukurou.util.Closer;
021    
022    import java.util.Map;
023    import java.util.HashMap;
024    import java.util.Locale;
025    import java.util.Properties;
026    import java.sql.Connection;
027    import java.sql.SQLException;
028    import java.sql.DriverManager;
029    import java.sql.DatabaseMetaData;
030    
031    /**
032     * 繝??繧ｿ繝吶?繧ｹ縺ｮ繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ蜿門ｾ励☆繧狗ぜ縺ｫ菴ｿ逕ｨ縺吶ｋ?後ヵ繧｡繧ｯ繝医Μ繧ｯ繝ｩ繧ｹ縺ｧ縺吶?
033     *
034     * Connection.connection() 繝｡繧ｽ繝?ラ縺ｧ?靴onnection繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ蜿門ｾ励＠縺ｾ縺吶?
035     * Connection#close() 繝｡繧ｽ繝?ラ縺ｧ?悟?驛ｨ逧?↓ ConnectionFactory 縺ｫ繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ謌ｻ縺?
036     * 莠九↓繧医▲縺ｦ,Connection繧ｪ繝悶ず繧ｧ繧ｯ繝医?繝励?繝ｪ繝ｳ繧ｰ繧定｡後↑縺｣縺ｦ縺?∪縺吶?
037     *
038     * 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝医??後?繝ｼ繝ｫ縺九ｉ雋ｸ縺怜?縺励∪縺吶?
039     * 縺､縺ｾ繧奇ｼ瑚ｲｸ縺怜?縺嶺ｸｭ縺ｫ縺ｯ,繝励?繝ｫ縺ｫ縺ｯ?後が繝悶ず繧ｧ繧ｯ繝医?谿九▲縺ｦ縺?∪縺帙ｓ縲?
040     * 縺昴?迥ｶ諷九〒,繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒclose()縺励↑縺??蜷医?,繧ｪ繝悶ず繧ｧ繧ｯ繝医′遐ｴ譽?＆繧後※,
041     * 雋ｸ縺怜?縺嶺ｸｭ繧ｫ繧ｦ繝ｳ繝医→螳滄圀縺ｮ繧ｪ繝悶ず繧ｧ繧ｯ繝域焚縺碁｣溘＞驕輔＞,繝ｪ繧ｽ繝ｼ繧ｹ縺御ｸ崎ｶｳ縺励∪縺吶?
042     * 蠢?★,菴懈?縺励◆繧ｪ繝悶ず繧ｧ繧ｯ繝医?,close()繝｡繧ｽ繝?ラ繧貞他縺ｳ蜃ｺ縺励※,繝励?繝ｫ縺ｫ霑斐＠縺ｦ荳九＆縺??
043     *
044     * 繧ｷ繧ｹ繝?Β繝ｪ繧ｽ繝ｼ繧ｹ縺ｮ USE_DB_APPLICATION_INFO=true 縺ｮ蝣ｴ蜷医?繧ｳ繝阪け繧ｷ繝ｧ繝ｳ縺ｫ繧｢繝励Μ繧ｱ繝ｼ繧ｷ繝ｧ繝ｳ
045     * 諠??繧定ｿｽ險倥☆繧九◆繧√?ApplicationInfo繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ菴ｿ逕ｨ縺励∪縺吶?
046     * 縺薙?繧ｪ繝悶ず繧ｧ繧ｯ繝医?縲）sp/common/session-init.jsp 縺ｫ縺ｦ繝ｦ繝ｼ繧ｶ繝ｼ諠??縺ｨ繧｢繝励Μ繧ｱ繝ｼ繧ｷ繝ｧ繝ｳ
047     * 諠??繧堤判髱｢繧｢繧ｯ繧ｻ繧ｹ縺斐→縺ｫ險ｭ螳壹＠縺ｾ縺吶?
048     *
049     * @og.group ?､?｢/Shell蛻ｶ蠕｡
050     * @og.rev 4.0.0.0 (2007/10/16) 繝代ャ繧ｱ繝ｼ繧ｸ遘ｻ蜍?hayabusa/db 竍?fukurou/db)
051     *
052     * @version  4.0
053     * @author   Kazuhiko Hasegawa
054     * @since    JDK5.0,
055     */
056    public final class ConnectionFactory {
057            private static final Map<String,ConnectionPool> map = new HashMap<String,ConnectionPool>();
058    
059            // 4.0.0.0 (2007/10/10) 繧ｭ繝｣繝?す繝･縺輔ｌ縺溘?蛻晄悄ConnectionPool 繧剃ｽｿ逕ｨ
060            // 4.0.0.0 (2007/10/29) 蛻晄悄蛟､繧偵％縺薙〒繧ｻ繝?ヨ縺吶ｋ
061            private static  String  DBID = "DEFAULT";
062            private static  ConnectionPool DEF_POOL ;
063    
064            // 4.0.0.0 (2007/10/17) 繧ｷ繧ｹ繝?Β萓晏ｭ倥?謾ｹ陦瑚ｨ伜捷繧偵そ繝?ヨ縺励∪縺吶?
065            private static final String CR = System.getProperty( "line.separator" );
066    
067            // 4.0.0.0 (2007/10/25) hayabusa萓晏ｭ倥ｒ蛻?ｋ縺溘ａ縺ｫ霑ｽ蜉?＠縺ｾ縺?
068            private static final int BUFFER_MIDDLE = 200;
069    
070            private static DatabaseConfig  dbc;
071    
072            /**
073             *  繝?ヵ繧ｩ繝ｫ繝医さ繝ｳ繧ｹ繝医Λ繧ｯ繧ｿ繝ｼ繧恥rivate縺ｫ縺励※縲?
074             *  繧ｪ繝悶ず繧ｧ繧ｯ繝医?逕滓?繧偵＆縺帙↑縺?ｈ縺?↓縺吶ｋ縲?
075             *
076             */
077            private ConnectionFactory() {
078            }
079    
080            /**
081             * 蛻晄悄蛹悶Γ繧ｽ繝?ラ縺ｧ縺吶?
082             * <pre>
083             * ??隨ｬ莠悟ｼ墓焚縺ｫXML繝輔ぃ繧､繝ｫ繧偵け繝ｩ繧ｹ繝ｭ繝ｼ繝?渕蠎輔°繧峨?逶ｸ蟇ｾ繝代せ縺ｧ謖?ｮ壹＠縺溷?蜷医?
084             * 縲??縺昴?XML繧貞茜逕ｨ縺励※DBConfig繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ菴懈?縺励∪縺吶?萓具ｼ咾onnectionFactory.init( CONTEXT_NAME, "../DBConfig.xml")
085             * 縲??null縺ｮ蝣ｴ蜷医?WEB-INF/DBConfig.xml繧貞茜逕ｨ縺励∪縺吶?萓具ｼ咾onnectionFactory.init( CONTEXT_NAME, null)
086             * ??繧ｭ繝｣繝?す繝･蛻晄悄ConnectionPool縺ｮ繧ｭ繝ｼ繧定ｨｭ螳壹＠縺ｦ繧ｭ繝｣繝?す繝･繝励?繝ｫ繧剃ｽ懊ｊ縺ｾ縺吶?
087             * 縲??縺薙?蛟､縺系ull縺ｮ蝣ｴ蜷医?"DEFAULT"縺瑚ｨｭ螳壹＆繧後∪縺吶?
088             * </pre>
089             * 
090             * <strong>縺薙?繧ｯ繝ｩ繧ｹ繧貞茜逕ｨ縺吶ｋ蝣ｴ蜷医?蠢?★譛??縺ｫ縺薙?繝｡繧ｽ繝?ラ繧貞ｮ溯｡後☆繧句ｿ?ｦ√′縺ゅｊ縺ｾ縺吶?</strong>
091             * 繧ｭ繝｣繝?す繝･縺ｨDBConfig繧ｪ繝悶ず繧ｧ繧ｯ繝医?蜷梧悄蛹悶?縺輔ｌ縺ｦ縺?↑縺??縺ｧ蛻晄悄蛹紋ｻ･螟悶〒縺ｮ蛻ｩ逕ｨ縺ｯ驕ｿ縺代※荳九＆縺??
092             *
093             * @og.rev 4.0.0.0 (2007/11/05) 譁ｰ隕丈ｽ懈?
094             *
095             * @param defPoolKey  蛻晄悄DBID蜷?null縺ｮ蝣ｴ蜷医?縲?DEFAULT")
096             * @param xmlFileName DBConfig.xml繝輔ぃ繧､繝ｫ縺ｮ繝輔ぃ繧､繝ｫ蜷?null縺ｮ蝣ｴ蜷医?縲仝EB-INF/DBConfig.xml)
097             */
098            public static void init( final String defPoolKey, final String xmlFileName ) {
099                    // DBConfig繧ｪ繝悶ず繧ｧ繧ｯ繝医?菴懈?
100                    if( xmlFileName == null || xmlFileName.length() == 0 ) {
101                            dbc = new DatabaseConfig();
102                    }
103                    else {
104                            dbc = new DatabaseConfig( xmlFileName );
105                    }
106    
107                    if( defPoolKey == null || defPoolKey.length() == 0 || dbc.getDbid( defPoolKey ) == null ) {
108                            DBID = "DEFAULT";
109                    }
110                    else {
111                            DBID = defPoolKey;
112                    }
113                    EDbid edbid = dbc.getDbid( DBID );
114                    if( edbid == null ) {
115                            final String errMsg = "蛻晄悄蛹匁凾縺ｫ縲∵欠螳壹?DBID繧ｭ繝ｼ縺悟ｭ伜惠縺励∪縺帙ｓ縲?
116                                    + "[Key ="
117                                    + DBID
118                                    + "]";
119                            throw new RuntimeException( errMsg );
120                    }
121    
122                    DEF_POOL = new ConnectionPool( edbid );
123            }
124    
125            /**
126             * 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ蜿門ｾ励＠縺ｾ縺吶?
127             * 驕?＞蛻晄悄蛹悶ｒ陦後↑縺?ｺ九↓繧医ｊ,螳滄圀縺ｫ蠢?ｦ√→縺ｪ繧九∪縺ｧ繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝医?
128             * 菴懈?縺励∪縺帙ｓ縲?
129             * 譛?､ｧ繝励?繝ｫ謨ｰ縺ｫ驕斐＠縺ｦ,縺ｪ縺翫°縺､,縺吶∋縺ｦ縺ｮConnection縺瑚ｲｸ縺怜?縺嶺ｸｭ縺ｮ蝣ｴ蜷?
130             *
131             * @og.rev 2.1.1.3 (2002/11/22) 繧ｳ繝阪け繧ｷ繝ｧ繝ｳID 縺?null 縺ｮ蝣ｴ蜷医↓ DEFAULT 縺九ｉ謇?ｾ励☆繧九ｈ縺?↓螟画峩縲?
132             * @og.rev 3.1.0.0 (2003/03/20) Hashtable 繧剃ｽｿ逕ｨ縺励※縺?ｋ邂?園縺ｧ縲?撼蜷梧悄縺ｧ繧よｧ九ｏ縺ｪ縺?ｮ?園繧偵?HashMap 縺ｫ鄂ｮ謠帙∴縲?
133             * @og.rev 3.5.6.2 (2004/07/05) 譁?ｭ怜?縺ｮ騾｣邨舌↓StringBuilder繧剃ｽｿ逕ｨ縺励∪縺吶?
134             * @og.rev 3.8.7.0 (2006/12/15) 繧｢繧ｯ繧ｻ繧ｹ繝ｭ繧ｰ蜿門ｾ励?轤ｺ,ApplicationInfo繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ險ｭ螳?
135             * @og.rev 3.8.8.2 (2007/01/26) USE_DB_APPLICATION_INFO 竍?pool.useApplicationInfo() 螟画峩
136             * @og.rev 4.0.0.0 (2007/10/10) 繧ｭ繝｣繝?す繝･縺輔ｌ縺溘?蛻晄悄ConnectionPool 繧剃ｽｿ逕ｨ
137             * @og.rev 4.1.0.1 (2008/01/21) 逋ｻ骭ｲ譎ゅ↓縲∝､ｧ譁?ｭ励↓螟画鋤縺吶ｋ縲?
138             *
139             * @param   dbid 謗･邯壼?ID
140             * @param   appInfo 繧｢繝励Μ諠??繧ｪ繝悶ず繧ｧ繧ｯ繝?
141             *
142             * @return  繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝?
143             */
144            public static Connection connection( final String dbid , final ApplicationInfo appInfo ) {
145                    ConnectionPool pool ;
146                    if( dbid == null || dbid.length() == 0 || DBID.equalsIgnoreCase( dbid ) ) {
147                            pool = DEF_POOL ;
148                    }
149                    else {
150                            String udbid = dbid.toUpperCase( Locale.JAPAN );        // 螟ｧ譁?ｭ怜喧
151                            synchronized( map ) {
152                                    pool = map.get( udbid );
153                                    // 謗･邯唔D縺後?map 縺ｫ蟄伜惠縺励↑縺??蜷?
154                                    if( pool == null ) {
155                                            EDbid edbid = dbc.getDbid( udbid );
156                                            if( edbid == null ) {
157                                                    final String errMsg = "謖?ｮ壹?DBID繧ｭ繝ｼ縺悟ｭ伜惠縺励∪縺帙ｓ縲?
158                                                            + "[Key ="
159                                                            + udbid
160                                                            + "]";
161                                                    throw new RuntimeException( errMsg );
162                                            }
163                                            pool = new ConnectionPool( edbid );
164                                            map.put( udbid,pool );
165                                    }
166                            }
167                    }
168    
169                    Connection conn = pool.newInstance();
170    
171                    // 3.8.7.0 (2006/12/15) 繧｢繧ｯ繧ｻ繧ｹ繝ｭ繧ｰ蜿門ｾ励?轤ｺ,ApplicationInfo繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ菴ｿ逕ｨ
172                    // 3.8.8.2 (2007/01/26) ORACLE 莉･螟悶?縲∽ｽｿ逕ｨ縺励∪縺帙ｓ縲?
173                    // 4.0.0.0 (2007/11/29) 蜈･繧悟ｭ進f 縺ｮ邨ｱ蜷?
174                    if( appInfo != null && pool.useApplicationInfo() ) {
175                            appInfo.callAppInfo( conn );
176                    }
177                    return conn;
178            }
179    
180            /**
181             * 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ繝励?繝ｫ縺ｫ謌ｻ縺励∪縺吶?
182             * Connection繧ｪ繝悶ず繧ｧ繧ｯ繝医?,close()繝｡繧ｽ繝?ラ縺ｧ,閾ｪ蛻??霄ｫ繧?ConnectionFactory 縺ｮ
183             * 繝励?繝ｫ縺ｫ謌ｻ縺励∪縺吶?
184             * 縺昴ｌ莉･螟悶? 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ繝励?繝ｫ縺ｫ謌ｻ縺吝?蜷医?,縺薙?繝｡繧ｽ繝?ラ繧剃ｽｿ逕ｨ縺励∪縺吶?
185             *
186             * @og.rev 2.1.1.3 (2002/11/22) 繧ｳ繝阪け繧ｷ繝ｧ繝ｳID 縺?null 縺ｮ蝣ｴ蜷医↓ DEFAULT 縺九ｉ謇?ｾ励☆繧九ｈ縺?↓螟画峩縲?
187             * @og.rev 4.0.0.0 (2007/10/10) 繧ｭ繝｣繝?す繝･縺輔ｌ縺溘?蛻晄悄ConnectionPool 繧剃ｽｿ逕ｨ
188             * @og.rev 4.1.0.1 (2008/01/21) 逋ｻ骭ｲ譎ゅ↓縲∝､ｧ譁?ｭ励↓螟画鋤縺吶ｋ縲?
189             *
190             * @param   conn 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝?
191             * @param   dbid 謗･邯壼?ID
192             */
193            public static void close( final Connection conn,final String dbid ) {
194                    if( conn != null ) {
195                            if( dbid == null || dbid.length() == 0 || DBID.equalsIgnoreCase( dbid ) ) {
196                                    DEF_POOL.release( conn ) ;
197                            }
198                            else {
199                                    String udbid = dbid.toUpperCase( Locale.JAPAN );        // 螟ｧ譁?ｭ怜喧
200                                    synchronized( map ) {
201                                            ConnectionPool pool = map.get( udbid );
202                                            if( pool != null ) {
203                                                    pool.release( conn );
204                                            }
205                                    }
206                            }
207                    }
208            }
209    
210            /**
211             * 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ迚ｩ逅?噪縺ｫ蜑企勁(繧ｯ繝ｭ繝ｼ繧ｺ)謌ｻ縺励∪縺吶?
212             * 縺薙ｌ縺ｯ縲√さ繝阪け繧ｷ繝ｧ繝ｳ遲峨′繧ｨ繝ｩ繝ｼ繧定ｵｷ縺薙＠縺溷?蜷医↓縲√?繝ｼ繝ｫ縺ｫ謌ｻ縺吶?縺ｧ縺ｯ縺ｪ縺上?
213             * 謗･邯壹ｒ髢峨§繧句?蜷医↓縲∽ｽｿ逕ｨ縺輔ｌ縺ｾ縺吶?
214             *
215             * @og.rev 2.1.1.3 (2002/11/22) 繧ｳ繝阪け繧ｷ繝ｧ繝ｳID 縺?null 縺ｮ蝣ｴ蜷医↓ DEFAULT 縺九ｉ謇?ｾ励☆繧九ｈ縺?↓螟画峩縲?
216             * @og.rev 4.0.0.0 (2007/10/10) 繧ｭ繝｣繝?す繝･縺輔ｌ縺溘?蛻晄悄ConnectionPool 繧剃ｽｿ逕ｨ
217             * @og.rev 4.1.0.1 (2008/01/21) 逋ｻ骭ｲ譎ゅ↓縲∝､ｧ譁?ｭ励↓螟画鋤縺吶ｋ縲?
218             *
219             * @param   conn 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝?
220             * @param   dbid 謗･邯壼?ID
221             */
222            public static void remove( final Connection conn,final String dbid ) {
223                    if( conn != null ) {
224                            if( dbid == null || dbid.length() == 0 || DBID.equalsIgnoreCase( dbid ) ) {
225                                    DEF_POOL.remove( conn ) ;
226                            }
227                            else {
228                                    String udbid = dbid.toUpperCase( Locale.JAPAN );        // 螟ｧ譁?ｭ怜喧
229                                    synchronized( map ) {
230                                            ConnectionPool pool = map.get( udbid );
231                                            if( pool != null ) {
232                                                    pool.remove( conn );
233                    //                              map.put( udbid,pool );
234                                            }
235                                    }
236                            }
237                    }
238            }
239    
240            /**
241             * 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ螳滄圀縺ｫ縺吶∋縺ｦ繧ｯ繝ｭ繝ｼ繧ｺ縺励∪縺吶?
242             * 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繝励?繝ｫ縺ｮ蜀咲ｷｨ謌舌ｄ?檎ｮ｡逅??縺ｫ繧医ｋ蠑ｷ蛻ｶ繧ｯ繝ｭ繝ｼ繧ｺ縺ｫ菴ｿ逕ｨ縺励∪縺吶?
243             *
244             * 繧ｯ繝ｭ繝ｼ繧ｺ縺ｫ螟ｱ謨?繧ｳ繝阪け繧ｷ繝ｧ繝ｳ縺瑚ｲｸ縺怜?縺嶺ｸｭ)縺ｮ蝣ｴ蜷医?,蜀?Κ逧?↓
245             * DB_CLOSE_RETRY_TIME 縺?￠蠕?ｩ溘＠縺ｦ, DB_CLOSE_RETRY_COUNT 蝗樊焚縺?￠,隧ｦ陦後＠縺ｾ縺吶?
246             * 縺昴ｌ縺ｧ繧ゅけ繝ｭ繝ｼ繧ｺ縺ｧ縺阪↑縺??蜷医?, RuntimeException 繧?throw 縺励∪縺吶?
247             *
248             * @og.rev 4.0.0.0 (2005/01/31) 繝ｭ繧ｸ繝?け隕狗峩縺励? pool.clear() 縺ｧ縲∝渕譛ｬ逧?↓縺ｯ縺吶∋縺ｦ蜑企勁縺輔ｌ縺ｾ縺吶?
249             * @og.rev 4.0.0.0 (2007/10/10) 繧ｭ繝｣繝?す繝･縺輔ｌ縺溘?蛻晄悄ConnectionPool 繧剃ｽｿ逕ｨ
250             */
251            public static void realClose() {
252                    synchronized( DEF_POOL ) {
253                            if( ! DEF_POOL.isEmpty() ) {
254                                    DEF_POOL.clear();
255                            }
256                    }
257    
258                    final ConnectionPool[] pools ;
259                    synchronized( map ) {
260                            if( map.isEmpty() ) { return; }
261    
262                            pools = map.values().toArray( new ConnectionPool[map.size()] ) ;
263                            map.clear();
264                    }
265    
266                    ConnectionPool pool ;
267                    for( int i=0; i<pools.length ; i++ ) {
268                            pool = pools[i];
269                            if( pool != null && ! pool.isEmpty() ) {
270                                    pool.clear();
271                            }
272                    }
273            }
274    
275            /**
276             * ConnectionFactory 縺ｮ迴ｾ蝨ｨ縺ｮ迥ｶ豕?隧ｳ邏ｰ繝｡繝?そ繝ｼ繧ｸ)繧定ｿ斐＠縺ｾ縺吶?
277             * 縺薙ｌ縺ｯ?後さ繝阪け繧ｷ繝ｧ繝ｳ繝励?繝ｫ縺ｮ謨ｰ(譛?､ｧ蛟､?御ｽ懈?貂医∩謨ｰ縺ｪ縺ｩ)繧堤｢ｺ隱阪☆繧狗ぜ縺ｮ繧ゅ?縺ｧ縺吶?
278             *
279             * @og.rev 4.0.0.0 (2007/10/10) 繧ｭ繝｣繝?す繝･縺輔ｌ縺溘?蛻晄悄ConnectionPool 繧剃ｽｿ逕ｨ
280             *
281             * @return  迴ｾ蝨ｨ縺ｮ迥ｶ諷玖｡ｨ遉ｺ
282             */
283            public static String information() {
284                    return information( true );
285            }
286    
287            /**
288             * ConnectionFactory 縺ｮ迴ｾ蝨ｨ縺ｮ迥ｶ豕√ｒ霑斐＠縺ｾ縺吶?
289             * 縺薙ｌ縺ｯ?後さ繝阪け繧ｷ繝ｧ繝ｳ繝励?繝ｫ縺ｮ謨ｰ(譛?､ｧ蛟､?御ｽ懈?貂医∩謨ｰ縺ｪ縺ｩ)繧堤｢ｺ隱阪☆繧狗ぜ縺ｮ繧ゅ?縺ｧ縺吶?
290             * 蠑墓焚縺ｫ繧医ｊ隧ｳ邏ｰ繝｡繝?そ繝ｼ繧ｸ縺九←縺?°繧呈欠螳壹〒縺阪∪縺吶?
291             *
292             * @og.rev 4.0.0.0 (2007/10/10) 繧ｭ繝｣繝?す繝･縺輔ｌ縺溘?蛻晄悄ConnectionPool 繧剃ｽｿ逕ｨ
293             * @og.rev 5.3.4.0 (2011/04/01) 隧ｳ邏ｰ繝｡繝?そ繝ｼ繧ｸ逕ｨ蠑墓焚繧定ｿｽ蜉?
294             * @og.rev 5.6.7.3 (2013/08/23) 闍･蟷ｲ縺ｮ菫ｮ豁｣
295             *
296             * @param       isDetail        隧ｳ邏ｰ繝｡繝?そ繝ｼ繧ｸ縺九←縺?° [true:隧ｳ邏ｰ繝｡繝?そ繝ｼ繧ｸ/false:邁｡譏薙Γ繝?そ繝ｼ繧ｸ]
297             *
298             * @return  迴ｾ蝨ｨ縺ｮ迥ｶ諷玖｡ｨ遉ｺ
299             */
300            public static String information(final boolean isDetail ) {
301                    // 4.0.0.0 (2007/10/25) hybs縺ｨ縺ｮ萓晏ｭ倬未菫ゅｒ蠑ｱ繧√ｋ縺溘ａ縲?
302                    final StringBuilder strBuf = new StringBuilder( BUFFER_MIDDLE );
303    
304                    strBuf.append( "<b>縲燭onnection Information縲?/b>" ).append( CR );       // 5.6.7.3 (2013/08/23) 闍･蟷ｲ縺ｮ菫ｮ豁｣
305    
306                    int rtnCnt = 0;
307                    synchronized( DEF_POOL ) {
308                            if( ! DEF_POOL.isEmpty() ) {
309                                    rtnCnt += DEF_POOL.size();
310                                    // 5.3.4.0 (2011/04/01) 隧ｳ邏ｰ繝｡繝?そ繝ｼ繧ｸ逕ｨ蠑墓焚繧定ｿｽ蜉?
311                                    if( isDetail ) {
312                                            strBuf.append( DEF_POOL.toString() );
313                                            strBuf.append( "<br /><hr />" );
314                                    }
315                                    else {
316                                            strBuf.append( DEF_POOL.dbidInfo() );
317                                    }
318                            }
319                    }
320    
321                    ConnectionPool[] pools = null;
322                    synchronized( map ) {
323                            if( !map.isEmpty() ) {
324                                    pools = map.values().toArray( new ConnectionPool[map.size()] ) ;
325                            }
326                    }
327    
328                    if( pools != null ) {
329                            for( int i=0; i<pools.length ; i++ ) {
330                                    ConnectionPool pool = pools[i];
331                                    if( pool != null && ! pool.isEmpty() ) {
332                                            rtnCnt += pool.size();
333                                            // 5.3.4.0 (2011/04/01) 隧ｳ邏ｰ繝｡繝?そ繝ｼ繧ｸ逕ｨ蠑墓焚繧定ｿｽ蜉?
334                                            if( isDetail ) {
335                                                    strBuf.append( pool.toString() );
336                                                    strBuf.append( "<br /><hr />" );
337                                            }
338                                            else {
339                                                    strBuf.append( pool.dbidInfo() );
340                                            }
341                                    }
342                            }
343                    }
344    
345                    strBuf.append( CR );
346    
347                    return strBuf.toString();
348            }
349    
350            /**
351             * 縺薙?謗･邯壹′縲￣reparedStatement#getParameterMetaData() 繧剃ｽｿ逕ｨ縺吶ｋ縺九←縺?°繧貞愛螳壹＠縺ｾ縺吶?
352             *
353             * PreparedStatement 縺ｫ蟇ｾ縺励※縲ヾtring蛹悶＆繧後◆ 謨ｰ蟄励↑縺ｩ繧?setObject( int,String ) 縺吶ｋ縺ｨ縺阪?
354             * ORACLE 縺ｨ SQLServer 縺ｯ縲√◎縺ｮ縺ｾ縺ｾ險ｭ螳壹☆繧後?縲∬?蜍慕噪縺ｫ螟画鋤縺輔ｌ縺ｾ縺吶?
355             * postgreSQL 縺ｧ縺ｯ縲￣arameterMetaData#getParameterType(int) 縺ｧ縲√き繝ｩ繝?ち繧､繝励ｒ蜿門ｾ励＠縲?
356             * setObject( int,String,int ) 縺吶ｋ蠢?ｦ√′縺ゅｊ縺ｾ縺吶?
357             * 縺昴?蛻､螳壹↓縲√％縺ｮ繝｡繧ｽ繝?ラ繧剃ｽｿ逕ｨ縺励∪縺吶?
358             * 縺薙?邨先棡縺ｯ縲√≠縺上∪縺ｧ縲∝推遞ｮ繝??繧ｿ繝吶?繧ｹ豈弱?螳溷慍隱ｿ譟ｻ縺ｮ邨先棡繧貞?縺ｫ縲∝愛螳夂ｵ先棡繧?
359             * 霑斐☆繧医≧縺ｫ縺励※縺?∪縺吶?
360             * ORACLE 縺ｮ蝣ｴ蜷医?縲∽ｽｿ逕ｨ縺励↑縺?false)縺瑚ｿ斐ｋ繧医≧縺ｫ險ｭ螳壹＠縺ｦ縺?∪縺吶?
361             * SQLServer 縺ｧ縺ｯ縲＾RACLE縺ｨ蜷梧ｧ倥↓縲’alse 繧定ｿ斐＠縺ｾ縺吶?
362             *
363             * 縺薙?繝｡繧ｽ繝?ラ縺ｯ縲∝?縲??ApplicationInfo#useParameterMetaData(Connection) 縺ｫ譛峨▲縺溘ｂ縺ｮ繧?
364             * EDbid 縺九ｉ蜿門ｾ励☆繧九ｈ縺?↓菫ｮ豁｣縺励◆繧ゅ?縺ｧ縺吶?
365             *
366             * @og.rev 5.3.8.0 (2011/08/01) 譁ｰ隕剰ｿｽ蜉?
367             *
368             * @param dbid 謗･邯壼?ID
369             *
370             * @return      [true:菴ｿ逕ｨ縺吶ｋ/false:縺昴?莉望
371             */
372            public static boolean useParameterMetaData( final String dbid ) {
373                    final String udbid ;
374                    if( dbid == null || dbid.length() == 0 ) {
375                            udbid = DBID ;
376                    }
377                    else {
378                            udbid = dbid.toUpperCase( Locale.JAPAN );       // 螟ｧ譁?ｭ怜喧
379                    }
380    
381                    EDbid edbid = dbc.getDbid( udbid );
382    
383                    return edbid.useParamMetaData();
384            }
385    
386            /**
387             * 謗･邯壼?縺ｮDB蜷阪↓蟇ｾ蠢懊＠縺溘?enum (DBName) 繧定ｿ斐＠縺ｾ縺?toUpperCase)縲?
388             *
389             * @og.rev 5.1.4.0 (2010/03/01) getDBFullName 縺ｮ莉｣繧上ｊ縺ｫ譁ｰ隕丈ｽ懈?
390             * @og.rev 5.7.7.2 (2014/06/20) 譛??縺ｮ蜿門ｾ玲凾縺ｮ繧ｨ繝ｩ繝ｼ蝗樣∩
391             *
392             * @param dbid 謗･邯壼?ID
393             *
394             * @return  謗･邯壼?縺ｮDB蜷?
395             */
396            public static String getDBName( final String dbid ) {
397                    final String dbName;
398    
399                    if( dbid == null || dbid.length() == 0 || DBID.equalsIgnoreCase( dbid ) ) {
400                            dbName = DEF_POOL.getDBName();
401                    }
402                    else {
403                            String udbid = dbid.toUpperCase( Locale.JAPAN );        // 螟ｧ譁?ｭ怜喧
404                            ConnectionPool pool = null;
405                            synchronized( map ) {
406                                    pool = map.get( udbid );
407                                    if( pool == null ) {
408    //                                      close( connection( dbid, null ), dbid );        // 5.7.7.2 (2014/06/20) 譛??縺ｮ蜿門ｾ玲凾縺ｮ繧ｨ繝ｩ繝ｼ蝗樣∩
409                                            connection( dbid, null );       // 繝?Α繝ｼ縺ｧ縲√さ繝阪け繝医☆繧九?
410                                            pool = map.get( udbid );        // 繧ゅ≧荳?ｺｦ縲∬ｨｭ螳壹☆繧九?
411                                    }
412                            }
413                            if( pool != null ) {
414                                    dbName = pool.getDBName();
415                            }
416                            else {
417                                    final String errMsg = "謖?ｮ壹?DBID繧ｭ繝ｼ縺ｫ蟇ｾ蠢懊☆繧九ョ繝ｼ繧ｿ繝吶?繧ｹ蜷阪ｒ蜿門ｾ怜?譚･縺ｾ縺帙ｓ縲?
418                                            + "[Key =" + dbid + "]";
419                                    throw new RuntimeException( errMsg );
420                            }
421                    }
422    
423                    return dbName.toUpperCase( Locale.JAPAN );
424            }
425    }
426    
427    /**
428     * ConnectionPool 縺ｯ縲、bstractObjectPool 繧堤ｶ呎価縺励◆ 繧ｪ繝悶ず繧ｧ繧ｯ繝医?繝ｼ繝ｫ縺ｧ縺吶?
429     *
430     * 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ繝励?繝ｫ縺吶ｋ縺薙→縺ｫ繧医ｊ縲，onnectionFactory 縺ｧ
431     * 邂｡逅?☆繧?Map 繧ｪ繝悶ず繧ｧ繧ｯ繝医?螳滓?縺ｨ縺励※縲∝推ID豈弱? 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧偵く繝ｼ繝励＠縺ｾ縺吶?
432     *
433     * @og.group ?､?｢/Shell蛻ｶ蠕｡
434     *
435     * @version  4.0
436     * @author   Kazuhiko Hasegawa
437     * @since    JDK5.0,
438     */
439    class ConnectionPool extends AbstractObjectPool<Connection> {
440            private final transient EDbid edbid;
441    
442            // 4.0.0.0 (2007/10/17) 繧ｷ繧ｹ繝?Β萓晏ｭ倥?謾ｹ陦瑚ｨ伜捷繧偵そ繝?ヨ縺励∪縺吶?
443            private static final String CR = System.getProperty( "line.separator" );
444    
445            /**
446             *  DBID 繧呈欠螳壹＠縺ｦ菴懈?縺吶ｋ 繧ｳ繝ｳ繧ｹ繝医Λ繧ｯ繧ｿ繝ｼ
447             *  DBID 繧偵く繝ｼ縺ｫ?､ HybsSystem.sys 繝｡繧ｽ繝?ラ縺ｮ繝??繧ｿ繝吶?繧ｹ螟画焚繧貞叙蠕励＠縺ｾ縺吶?
448             *  蜿門ｾ励☆繧九?縺ｯ?､ DBID + _DB_URL?柔DB_USER?柔DB_PASSWD?柔DB_MINCOUNT?柔DB_MAXCOUNT
449             *  縺ｧ縺吶?
450             *  DBID 縺?null 縺ｮ蝣ｴ蜷医???DEFAULT" 縺御ｽｿ逕ｨ縺輔ｌ縺ｾ縺吶?
451             *
452             * @og.rev 3.5.4.3 (2004/01/05) 繧ｭ繝｣繝?す繝･縺ｮ蟇ｿ蜻ｽ繧呈欠螳?
453             * @og.rev 3.5.4.7 (2004/02/06) DBID 縺ｮ繧ｼ繝ｭ繧ｹ繝医Μ繝ｳ繧ｰ繝√ぉ繝?け霑ｽ蜉?
454             * @og.rev 4.0.0.0 (2007/10/10) 繧ｭ繝｣繝?す繝･縺輔ｌ縺溘?蛻晄悄ConnectionPool 繧剃ｽｿ逕ｨ
455             * @og.rev 4.0.0.0 (2007/10/25) DB險ｭ螳壽ュ蝣ｱ縺ｮXML蛹悶↓莨ｴ縺?､画峩
456             *
457             * @param   edbid 謗･邯壼?諠??繧ｪ繝悶ず繧ｧ繧ｯ繝?
458             */
459            public ConnectionPool( final EDbid edbid ) {
460                    // 4.0.0.0 XML蛹悶↓莨ｴ縺?Ο繝ｼ繝牙?繧貞､画峩
461                    this.edbid      =       edbid;
462                    init( edbid.getMincount(),edbid.getMaxcount(),true,edbid.getPooltime() );
463            }
464    
465            /**
466             * 繧ｪ繝悶ず繧ｧ繧ｯ繝医?繝ｼ繝ｫ縺九ｉ蜑企勁縺吶ｋ縺ｨ縺阪↓蜻ｼ縺ｰ繧後∪縺吶?
467             * 縺薙?繝｡繧ｽ繝?ラ縺ｧ蜷?が繝悶ず繧ｧ繧ｯ繝医＃縺ｨ縺ｮ邨ゆｺ??逅?ｒ陦後＞縺ｾ縺吶?
468             * 萓九∴縺ｰ?､繝??繧ｿ繝吶?繧ｹ繧ｳ繝阪け繧ｷ繝ｧ繝ｳ縺ｧ縺ゅｌ縺ｰ?､close() 蜃ｦ逅?↑縺ｩ縺ｧ縺吶?
469             *
470             * @og.rev 3.5.4.8 (2004/02/23) SQLException 縺ｯ辟｡隕悶＠縺ｾ縺吶?
471             * @og.rev 3.5.6.0 (2004/06/18) synchronized 繧定ｧ｣髯､縺励∪縺吶?
472             *
473             * @param  obj 邨ゆｺ??逅?ｒ陦後≧繧ｪ繝悶ず繧ｧ繧ｯ繝?
474             */
475            protected void objectFinal( final Connection obj ) {
476                    Closer.connClose( obj );
477            }
478    
479            /**
480             * 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ菴懈?縺励∪縺吶?
481             * DriverManager.getConnection 縺ｫ繧医ｊ菴懈?縺輔ｌ縺櫃onnection 繧?Connection 縺ｧ
482             * 繝ｩ繝?ヴ繝ｳ繧ｰ縺励∪縺吶?
483             * Connection繧ｪ繝悶ず繧ｧ繧ｯ繝医?,close()繝｡繧ｽ繝?ラ縺ｧ,閾ｪ蛻??霄ｫ繧?ConnectionFactory 縺ｮ
484             * 繝励?繝ｫ縺ｫ謌ｻ縺励∪縺吶?
485             *
486             * @og.rev 3.3.3.3 (2003/08/06) 繧ｳ繝阪け繧ｷ繝ｧ繝ｳ縺ｫ蟇ｾ縺励※縲《etTransactionIsolation 繧偵?險ｭ螳壹＠縺ｦ縺翫￥縲?
487             * @og.rev 3.5.2.0 (2003/10/20) 謗･邯壽ュ蝣ｱ縺ｫ縲√ョ繝ｼ繧ｿ繝吶?繧ｹ蜷阪?繝峨Λ繧､繝仙錐諠??繧定ｿｽ蜉?☆繧九?
488             * @og.rev 3.5.6.0 (2004/06/18) synchronized 繧定ｧ｣髯､縺励∪縺吶?
489             * @og.rev 3.8.8.2 (2007/01/26) useAppInfo 繧定ｨｭ螳壹＠縺ｾ縺吶?
490             * @og.rev 4.0.0.0 (2007/10/30) 菫晄戟諠??繧ｪ繝悶ず繧ｧ繧ｯ繝亥喧縺ｫ莨ｴ縺?､画峩
491             * @og.rev 5.1.2.0 (2010/01/01) MySQL蟇ｾ蠢?譏守､ｺ逧?↓縲ゝRANSACTION_READ_COMMITTED 繧呈欠螳壹☆繧九?
492             * @og.rev 5.5.2.0 (2012/05/01) properties蟇ｾ蠢?
493             *
494             * @return  繧ｳ繝阪け繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝?
495             */
496            protected Connection createInstance() {
497                    Connection conn = null;
498                    try {
499            //              DriverManager.setLogWriter( HybsSystem.out );                   // 繝峨Λ繧､繝舌?縺ｮ繝ｭ繧ｰ
500    
501                            // 5.5.2.0 (2012/05/01) property縺ｮ霑ｽ蜉??逅?→縲∵磁邯壹?properties蛹?
502                            Properties prop = new Properties (edbid.getProps());
503                            prop.put ( "user", edbid.getUser() );
504                            prop.put ( "password", edbid.getPassword() );
505    
506                            conn = DriverManager.getConnection( edbid.getUrl(), prop );
507            //              conn.setReadOnly( true );
508                            conn.setReadOnly( edbid.isReadonly() );
509    
510                            conn.setAutoCommit( false );
511                            conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);  // 蛻晄悄蛟､
512            //              ((OracleConnection)conn).setDefaultExecuteBatch(1);  // 蛻晄悄蛟､
513            //              ((OracleConnection)conn).setDefaultRowPrefetch(20);  // 蛻晄悄蛟､
514    
515                            // 3.5.2.0 (2003/10/20) 謗･邯壽ュ蝣ｱ縺ｫ縲√ョ繝ｼ繧ｿ繝吶?繧ｹ蜷阪?繝峨Λ繧､繝仙錐諠??繧定ｿｽ蜉?☆繧九?
516                            // 4.0.0.0 (2007/10/26) 逋ｻ骭ｲ蜈医ｒ繧ｪ繝悶ず繧ｧ繧ｯ繝亥喧
517                            if( edbid.getDbProductName() == null ) {
518                                    DatabaseMetaData meta = conn.getMetaData();
519                                    edbid.setMetaDataInfo( meta );
520                            }
521                            return conn ;
522                    }
523                    catch ( SQLException ex ) {
524                            String errMsg = "繧ｳ繝阪け繝医☆繧九％縺ｨ縺悟?譚･縺ｾ縺帙ｓ縲? + CR
525                                                    + "DBID=[" + edbid.getDbidKey() + "]" + CR
526                                                    + ex.getMessage() + " , status=" + ex.getSQLState();
527                            Closer.connClose( conn );
528                            throw new RuntimeException( errMsg,ex );                // 3.5.5.4 (2004/04/15) 蠑墓焚縺ｮ荳ｦ縺ｳ鬆?､画峩
529                    }
530            }
531    
532            /**
533             * 繧｢繧ｯ繧ｻ繧ｹ繝ｭ繧ｰ蜿門ｾ励?轤ｺ縺ｮDBMS_APPLICATION_INFO縺ｮ菴ｿ逕ｨ蜿ｯ蜷ｦ繧貞叙蠕励＠縺ｾ縺?蛻晄悄蛟､:true)縲?
534             *
535             * 繝??繧ｿ繝吶?繧ｹ縺ｸ縺ｮ繧｢繧ｯ繧ｻ繧ｹ繝ｭ繧ｰ蜿門ｾ励?轤ｺ縲√お繝ｳ繧ｸ繝ｳ縺ｧ謗･邯壹☆繧九さ繝阪け繧ｷ繝ｧ繝ｳ縺ｫ縺､縺?※
536             * DBMS_APPLICATION_INFO.SET_CLIENT_INFO 縺ｨ SET_MODULE 繧貞他縺ｳ蜃ｺ縺励※縺?∪縺吶?
537             * 縺薙?蜃ｦ逅??縲＾RACLE縺ｨ縺ｮ謗･邯壹?縺ｿ譛牙柑縺ｧ縺吶?縺ｧ縲∵磁邯壼?繝??繧ｿ繝吶?繧ｹ縺?ORACLE 莉･螟悶?
538             * false 繧定ｿ斐＠縺ｾ縺吶?
539             * ORACLE 縺ｮ蝣ｴ蜷医?縲√す繧ｹ繝?Β繝ｪ繧ｽ繝ｼ繧ｹ縺ｮ USE_DB_APPLICATION_INFO 螻樊?縺ｮ險ｭ螳壼?繧?
540             * 霑斐＠縺ｾ縺吶?
541             * 縺薙?險ｭ螳壼?縺ｮ蛻晄悄蛟､縺ｯ縲》rue 縺ｧ縺吶?
542             *
543             * @og.rev 3.8.8.2 (2007/01/26) 譁ｰ隕剰ｿｽ蜉?
544             *
545             * @return  true:菴ｿ逕ｨ縺吶ｋ/false:菴ｿ逕ｨ縺励↑縺?
546             */
547            public boolean useApplicationInfo() { return edbid.isApplicationInfo(); }
548    
549            /**
550             * 謗･邯壼?縺ｮDB蜷阪ｒ霑斐＠縺ｾ縺吶?
551             *
552             * @og.rev 4.3.7.0 (2009/06/01) 譁ｰ隕丈ｽ懈?
553             *
554             * @return  謗･邯壼?縺ｮDB蜷?
555             */
556            public String getDBName() {
557                    return edbid.getDbProductName();
558            }
559    
560            /**
561             * 謗･邯壼?縺ｮDB繝舌?繧ｸ繝ｧ繝ｳ繧定ｿ斐＠縺ｾ縺吶?
562             *
563             * @og.rev 4.3.7.0 (2009/06/01) 譁ｰ隕丈ｽ懈?
564             *
565             * @return 謗･邯壼?縺ｮDB繝舌?繧ｸ繝ｧ繝ｳ
566             */
567            public String getDBVersion() {
568                    return edbid.getDbProductVersion();
569            }
570    
571            /**
572             * 謗･邯壼?縺ｮ邁｡譏薙↑蜀?Κ諠??繧定ｿ斐＠縺ｾ縺吶?
573             *
574             * @og.rev 5.3.4.0 (2011/04/01) toString() 縺ｮ邁｡譏鍋沿
575             *
576             * @return 謗･邯壼?縺ｮ邁｡譏薙↑蜀?Κ諠??
577             */
578            public String dbidInfo() {
579                    return edbid.info();
580            }
581    
582            /**
583             * 蜀?Κ迥ｶ豕√ｒ邁｡譏鍋噪縺ｫ陦ｨ迴ｾ縺励◆譁?ｭ怜?繧定ｿ斐＠縺ｾ縺吶?
584             * DBID?酋RL?酋SER?上?繝ｼ繝ｫ繧ｵ繧､繧ｺ 繧定ｿ斐＠縺ｾ縺吶?
585             *
586             * @og.rev 3.5.2.0 (2003/10/20) 謗･邯壽ュ蝣ｱ縺ｫ縲√ョ繝ｼ繧ｿ繝吶?繧ｹ蜷阪?繝峨Λ繧､繝仙錐諠??繧定ｿｽ蜉?☆繧九?
587             * @og.rev 3.5.6.6 (2004/08/23) 蜷梧悄蛹匁婿豕輔ｒ邨ｱ荳?☆繧狗ぜ縲《ynchronized 繧偵▽縺代∪縺吶?(蛻･騾?隕∵､懆ｨ?
588             * @og.rev 4.0.0.0 (2007/10/29) EDbid縺ｮtoString繧貞他縺ｶ繧医≧縺ｫ螟画峩
589             *
590             * @return   縺薙?繧ｪ繝悶ず繧ｧ繧ｯ繝医?繝ｼ繝ｫ縺ｮ譁?ｭ怜?陦ｨ迴ｾ
591             */
592            @Override
593            public String toString() {
594                    StringBuilder buf = new StringBuilder();
595                    buf.append( edbid.toString() );
596                    buf.append( super.toString() );
597                    return buf.toString();
598            }
599    }