• R/O
  • SSH
  • HTTPS

opengion: 提交


Commit MetaInfo

修訂1838 (tree)
時間2020-02-14 16:04:06
作者chatrun

Log Message

(empty log message)

Change Summary

差異

--- trunk/opengionV7/uap/webapps/gf/src/org/opengion/fukurou/db/ConnectionFactory.java (revision 1837)
+++ trunk/opengionV7/uap/webapps/gf/src/org/opengion/fukurou/db/ConnectionFactory.java (revision 1838)
@@ -21,16 +21,16 @@
2121 import static org.opengion.fukurou.system.HybsConst.CR; // 6.1.0.0 (2014/12/26) refactoring
2222 import static org.opengion.fukurou.system.HybsConst.BUFFER_MIDDLE; // 6.4.3.3 (2016/03/04)
2323
24+ // import java.util.concurrent.ExecutorService; // 7.1.0.0 (2020/01/20)
25+ // import java.util.concurrent.Executors; // 7.1.0.0 (2020/01/20)
26+ // import java.util.concurrent.Future; // 7.1.0.0 (2020/01/20)
27+ // import java.util.concurrent.Callable; // 7.1.0.0 (2020/01/20)
28+ // import java.util.concurrent.TimeUnit; // 7.1.0.0 (2020/01/20)
29+ // import java.util.concurrent.ExecutionException; // 7.1.0.0 (2020/01/20)
30+ // import java.util.concurrent.TimeoutException; // 7.1.0.0 (2020/01/20)
31+ // import java.util.concurrent.CancellationException; // 7.1.0.0 (2020/01/20)
2432 import java.util.concurrent.ConcurrentMap; // 6.4.3.3 (2016/03/04)
2533 import java.util.concurrent.ConcurrentHashMap;
26-import java.util.concurrent.ExecutorService; // 7.1.0.0 (2020/01/20)
27-import java.util.concurrent.Executors; // 7.1.0.0 (2020/01/20)
28-import java.util.concurrent.Future; // 7.1.0.0 (2020/01/20)
29-import java.util.concurrent.Callable; // 7.1.0.0 (2020/01/20)
30-import java.util.concurrent.TimeUnit; // 7.1.0.0 (2020/01/20)
31-import java.util.concurrent.ExecutionException; // 7.1.0.0 (2020/01/20)
32-import java.util.concurrent.TimeoutException; // 7.1.0.0 (2020/01/20)
33-import java.util.concurrent.CancellationException; // 7.1.0.0 (2020/01/20)
3434 import java.util.Locale;
3535 import java.util.Properties;
3636 import java.sql.Connection;
@@ -414,7 +414,7 @@
414414 // class ConnectionPool extends AbstractObjectPool<Connection> {
415415 private static final class ConnectionPool extends AbstractObjectPool<Connection> {
416416 private final transient EDbid edbid;
417- private final static int TIMEOUT = 3; // 7.1.0.0 (2020/01/20)
417+ private final static int TIMEOUT = 10; // 7.1.0.0 (2020/01/20)
418418
419419 /**
420420 * DatabaseConfig と、dbid を指定して作成する コンストラクター
@@ -515,28 +515,29 @@
515515 prop.put ( "password", edbid.getPassword() );
516516
517517 // 7.1.0.0 (2020/01/20) Connection 作成時のタイムアウトを用意します。
518- if( TIMEOUT > 0 ) {
519- DriverManager.setLoginTimeout( TIMEOUT );
520- // このExecutorService はConnection を取得する一発物なので、シャットダウンしておく。
521- final ExecutorService executor = Executors.newSingleThreadExecutor(); // 7.1.0.0 (2020/01/20)
522- final Future<Connection> future = executor.submit(
523- new Callable<Connection>() {
524- @Override
525- public Connection call() throws SQLException {
526- return DriverManager.getConnection( edbid.getUrl(), prop );
527- }
528- }
529- );
530- try {
531- conn = future.get( TIMEOUT, TimeUnit.SECONDS );
532- }
533- finally {
534- executor.shutdown(); // 正常なシャットダウン
535- }
536- }
537- else {
518+ // if( TIMEOUT > 0 ) {
519+ // DriverManager.setLoginTimeout( TIMEOUT );
520+ // // このExecutorService はConnection を取得する一発物なので、シャットダウンしておく。
521+ // final ExecutorService executor = Executors.newSingleThreadExecutor(); // 7.1.0.0 (2020/01/20)
522+ // final Future<Connection> future = executor.submit(
523+ // new Callable<Connection>() {
524+ // @Override
525+ // public Connection call() throws SQLException {
526+ // return DriverManager.getConnection( edbid.getUrl(), prop );
527+ // }
528+ // }
529+ // );
530+ // try {
531+ // conn = future.get( TIMEOUT, TimeUnit.SECONDS );
532+ // }
533+ // finally {
534+ // executor.shutdown(); // 正常なシャットダウン
535+ // }
536+ // }
537+ // else {
538+ DriverManager.setLoginTimeout( TIMEOUT ); // 7.1.0.0 (2020/01/20)
538539 conn = DriverManager.getConnection( edbid.getUrl(), prop );
539- }
540+ // }
540541
541542 // conn = DriverManager.getConnection( edbid.getUrl(), prop );
542543 // conn.setReadOnly( true );
@@ -562,12 +563,12 @@
562563 Closer.connClose( conn );
563564 throw new OgRuntimeException( errMsg,ex ); // 3.5.5.4 (2004/04/15) 引数の並び順変更
564565 }
565- catch( final InterruptedException | TimeoutException | CancellationException | ExecutionException ex ) {
566- final String errMsg = "コネクト時にタイムアウトが発生しました。" + CR
567- + "DBID=[" + edbid.getDbidKey() + "]" ;
568- Closer.connClose( conn );
569- throw new OgRuntimeException( errMsg,ex );
570- }
566+ // catch( final InterruptedException | TimeoutException | CancellationException | ExecutionException ex ) {
567+ // final String errMsg = "コネクト時にタイムアウトが発生しました。" + CR
568+ // + "DBID=[" + edbid.getDbidKey() + "]" ;
569+ // Closer.connClose( conn );
570+ // throw new OgRuntimeException( errMsg,ex );
571+ // }
571572 }
572573
573574 /**
Show on old repository browser