Mercurial > dive4elements > gnv-client
annotate geo-backend/src/main/java/de/intevation/gnv/geobackend/sde/connectionpool/ArcSDEConnectionPool.java @ 265:e5379e129799
Fixed issue 34
geo-backend/trunk@215 c6561f87-3c4e-4783-a992-168aeb5c3f6f
| author | Tim Englich <tim.englich@intevation.de> |
|---|---|
| date | Tue, 13 Oct 2009 13:20:26 +0000 |
| parents | e4eacd613356 |
| children | ff1b7967e6b9 |
| rev | line source |
|---|---|
|
130
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
1 package de.intevation.gnv.geobackend.sde.connectionpool; |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
2 |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
3 import java.sql.Connection; |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
4 import java.util.Properties; |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
5 |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
6 import org.apache.commons.pool.PoolableObjectFactory; |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
7 import org.apache.commons.pool.impl.GenericObjectPool; |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
8 import org.apache.log4j.Logger; |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
9 |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
10 import de.intevation.gnv.geobackend.base.connectionpool.ConnectionPool; |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
11 import de.intevation.gnv.geobackend.base.connectionpool.exception.ConnectionException; |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
12 |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
13 /** |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
14 *This is the ArcSDE specific implementation of the Interface ConnectionPool |
| 265 | 15 * |
|
130
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
16 * @author Tim Englich <tim.englich@intevation.de> |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
17 */ |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
18 public class ArcSDEConnectionPool implements ConnectionPool { |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
19 |
| 265 | 20 /** |
|
130
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
21 * the logger, used to log exceptions and additonaly information |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
22 */ |
| 265 | 23 private static Logger log = Logger |
| 24 .getLogger(ArcSDEPoolableObjectFactory.class); | |
|
130
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
25 |
| 265 | 26 /** |
| 27 * The Pool which stores the Connections to the ArcSDE Backend | |
| 28 */ | |
| 29 private GenericObjectPool pool = null; | |
| 30 | |
| 31 /** | |
| 32 * @see de.intevation.gnv.geobackend.base.connectionpool.ConnectionPool#closeConnection(java.lang.Object) | |
| 33 */ | |
| 34 public void closeConnection(Connection connection) | |
| 35 throws ConnectionException { | |
| 36 | |
| 37 try { | |
| 38 // TODO: Muss Connection geschlossen werden? | |
| 39 this.pool.returnObject(connection); | |
| 40 } catch (Exception e) { | |
| 41 log.error(e, e); | |
| 42 throw new ConnectionException(e); | |
| 43 } | |
| 44 | |
| 45 } | |
| 46 | |
| 47 /** | |
| 48 * @see de.intevation.gnv.geobackend.base.connectionpool.ConnectionPool#getConnection(java.lang.String) | |
| 49 */ | |
| 50 public synchronized Connection getConnection(String connectionID) | |
| 51 throws ConnectionException { | |
| 52 try { | |
| 53 Object object = this.pool.borrowObject(); | |
| 54 | |
| 55 if (object instanceof Connection) { | |
| 56 return (Connection) object; | |
| 57 } else { | |
| 58 throw new ConnectionException( | |
| 59 "Created Object is not an java.sql.Connection"); | |
| 60 } | |
| 61 | |
| 62 } catch (Exception e) { | |
| 63 log.error(e, e); | |
| 64 throw new ConnectionException(e); | |
| 65 } | |
| 66 } | |
| 67 | |
| 68 /** | |
| 69 * @see de.intevation.gnv.geobackend.base.connectionpool.ConnectionPool#initialize(java.util.Properties) | |
| 70 */ | |
| 71 public void initialize(Properties properties) { | |
| 72 log.info("ArcSDEConnectionPool.initialize has been called"); | |
| 73 log.info("ConnectionPool will be initialized"); | |
| 74 | |
| 75 PoolableObjectFactory poolableObjectFactory = new ArcSDEPoolableObjectFactory( | |
| 76 properties); | |
| 77 | |
| 78 int maxActive = Integer.parseInt(properties.getProperty("maxActive", | |
| 79 "10")); | |
| 80 long maxWait = Long.parseLong(properties.getProperty("maxWait", | |
| 81 "" + GenericObjectPool.DEFAULT_MAX_WAIT)); | |
| 82 int maxIdle = Integer.parseInt(properties.getProperty("maxIdle", | |
| 83 "" + GenericObjectPool.DEFAULT_MAX_IDLE)); | |
| 84 int minIdle = Integer.parseInt(properties.getProperty("minIdle", | |
| 85 "" + GenericObjectPool.DEFAULT_MIN_IDLE)); | |
| 86 boolean testOnBorrow = Boolean.parseBoolean(properties.getProperty( | |
| 87 "testOnBorrow", "" + GenericObjectPool.DEFAULT_TEST_ON_BORROW)); | |
| 88 boolean testOnReturn = Boolean.parseBoolean(properties.getProperty( | |
| 89 "testOnReturn", "" + GenericObjectPool.DEFAULT_TEST_ON_RETURN)); | |
| 90 long timeBetweenEvictionRunsMillis = Long | |
| 91 .parseLong(properties | |
| 92 .getProperty( | |
| 93 "timeBetweenEvictionRunsMillis", | |
| 94 "" | |
| 95 + GenericObjectPool.DEFAULT_TIME_BETWEEN_EVICTION_RUNS_MILLIS)); | |
| 96 int numTestsPerEvictionRun = Integer.parseInt(properties.getProperty( | |
| 97 "numTestsPerEvictionRun", | |
| 98 "" + GenericObjectPool.DEFAULT_NUM_TESTS_PER_EVICTION_RUN)); | |
| 99 long minEvictableIdleTimeMillis = Long | |
| 100 .parseLong(properties | |
| 101 .getProperty( | |
| 102 "minEvictableIdleTimeMillis", | |
| 103 "" | |
| 104 + GenericObjectPool.DEFAULT_SOFT_MIN_EVICTABLE_IDLE_TIME_MILLIS)); | |
| 105 boolean testWhileIdle = Boolean.parseBoolean(properties | |
| 106 .getProperty("testWhileIdle", | |
| 107 "" + GenericObjectPool.DEFAULT_TEST_WHILE_IDLE)); | |
| 108 | |
| 109 log.info("Maximum Number of active Connections: " + maxActive); | |
| 110 log.info("Maximum Number of waiting: " + maxWait); | |
| 111 log.info("Maximum Number of idle: " + maxIdle); | |
| 112 log.info("Minimum Number of idle: " + minIdle); | |
| 113 log.info("TestOnBorrow: " + testOnBorrow); | |
| 114 log.info("TestOnReturn: " + testOnReturn); | |
| 115 log.info("TimeBetweenEvictionRunsMillis: " + timeBetweenEvictionRunsMillis); | |
| 116 log.info("NumTestsPerEvictionRun: " + numTestsPerEvictionRun); | |
| 117 log.info("MinEvictableIdleTimeMillis: " + minEvictableIdleTimeMillis); | |
| 118 log.info("TestWhileIdle: " + testWhileIdle); | |
| 119 | |
| 120 this.pool = new GenericObjectPool(poolableObjectFactory, maxActive, | |
| 121 GenericObjectPool.DEFAULT_WHEN_EXHAUSTED_ACTION, maxWait, | |
| 122 maxIdle, minIdle, testOnBorrow, testOnReturn, | |
| 123 timeBetweenEvictionRunsMillis, numTestsPerEvictionRun, | |
| 124 minEvictableIdleTimeMillis, testWhileIdle); | |
|
130
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
125 } |
|
e4eacd613356
Implementierung Datenzugriff auf die ArcSDE über java.sql. Methodiken
Tim Englich <tim.englich@intevation.de>
parents:
diff
changeset
|
126 } |