dive4elements/river: flys-backend/src/main/java/de/intevation/flys/utils/DBCPConnectionProvider.java annotate

annotate flys-backend/src/main/java/de/intevation/flys/utils/DBCPConnectionProvider.java @ 5200:42bb6ff78d1b 2.9.11

Directly set the connectionInitSqls on the datasource Somehow the factory fails to set the connectionInitSqls if we add it to the dbcpProperties. So we now set it directly

author	Andre Heinecke <aheinecke@intevation.de>
date	Fri, 08 Mar 2013 11:48:33 +0100
parents	fb9dcc68b9c2
children

rev	line source
168 86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	1 /*
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	2 * Copyright 2004 The Apache Software Foundation.
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	3 *
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	4 * Licensed under the Apache License, Version 2.0 (the "License");
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	5 * you may not use this file except in compliance with the License.
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	6 * You may obtain a copy of the License at
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	7 *
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	8 * http://www.apache.org/licenses/LICENSE-2.0
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	9 *
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	10 * Unless required by applicable law or agreed to in writing, software
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	11 * distributed under the License is distributed on an "AS IS" BASIS,
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	13 * See the License for the specific language governing permissions and
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	14 * limitations under the License.
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	15 */
3336 0af4c8386ed0 Fixed broken package declaration in DBCPConnectionProvider. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 464 diff changeset	16 package de.intevation.flys.utils;
168 86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	17
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	18 import java.sql.Connection;
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	19 import java.sql.SQLException;
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	20
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	21 import java.util.Iterator;
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	22 import java.util.Properties;
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	23 import java.util.Map;
5200 42bb6ff78d1b Directly set the connectionInitSqls on the datasource Andre Heinecke <aheinecke@intevation.de> parents: 5193 diff changeset	24 import java.util.Collections;
42bb6ff78d1b Directly set the connectionInitSqls on the datasource Andre Heinecke <aheinecke@intevation.de> parents: 5193 diff changeset	25 import java.util.StringTokenizer;
168 86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	26
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	27 import org.apache.commons.dbcp.BasicDataSource;
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	28 import org.apache.commons.dbcp.BasicDataSourceFactory;
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	29
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	30 import org.apache.log4j.Logger;
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	31
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	32 import org.hibernate.HibernateException;
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	33
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	34 import org.hibernate.connection.ConnectionProviderFactory;
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	35 import org.hibernate.connection.ConnectionProvider;
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	36
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	37 import org.hibernate.cfg.Environment;
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	38
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	39 /**
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	40 * <p>A connection provider that uses an Apache commons DBCP connection pool.</p>
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	41 *
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	42 * <p>To use this connection provider set:<br>
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	43 * <code>hibernate.connection.provider_class org.hibernate.connection.DBCPConnectionProvider</code></p>
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	44 *
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	45 * <pre>Supported Hibernate properties:
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	46 * hibernate.connection.driver_class
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	47 * hibernate.connection.url
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	48 * hibernate.connection.username
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	49 * hibernate.connection.password
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	50 * hibernate.connection.isolation
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	51 * hibernate.connection.autocommit
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	52 * hibernate.connection.pool_size
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	53 * hibernate.connection (JDBC driver properties)</pre>
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	54 * <br>
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	55 * All DBCP properties are also supported by using the hibernate.dbcp prefix.
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	56 * A complete list can be found on the DBCP configuration page:
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	57 * <a href="http://jakarta.apache.org/commons/dbcp/configuration.html">http://jakarta.apache.org/commons/dbcp/configuration.html</a>.
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	58 * <br>
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	59 * <pre>Example:
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	60 * hibernate.connection.provider_class org.hibernate.connection.DBCPConnectionProvider
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	61 * hibernate.connection.driver_class org.hsqldb.jdbcDriver
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	62 * hibernate.connection.username sa
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	63 * hibernate.connection.password
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	64 * hibernate.connection.url jdbc:hsqldb:test
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	65 * hibernate.connection.pool_size 20
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	66 * hibernate.dbcp.initialSize 10
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	67 * hibernate.dbcp.maxWait 3000
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	68 * hibernate.dbcp.validationQuery select 1 from dual</pre>
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	69 *
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	70 * <p>More information about configuring/using DBCP can be found on the
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	71 * <a href="http://jakarta.apache.org/commons/dbcp/">DBCP website</a>.
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	72 * There you will also find the DBCP wiki, mailing lists, issue tracking
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	73 * and other support facilities</p>
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	74 *
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	75 * @see org.hibernate.connection.ConnectionProvider
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	76 * @author Dirk Verbeeck
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	77 */
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	78 public class DBCPConnectionProvider
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	79 implements ConnectionProvider
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	80 {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	81 private static Logger log = Logger.getLogger(DBCPConnectionProvider.class);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	82
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	83 private static final String PREFIX = "hibernate.dbcp.";
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	84
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	85 private BasicDataSource ds;
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	86
464 d37ccb04ab5d Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 184 diff changeset	87 // Old Environment property for backward-compatibility
168 86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	88 // (property removed in Hibernate3)
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	89 private static final String DBCP_PS_MAXACTIVE =
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	90 "hibernate.dbcp.ps.maxActive";
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	91
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	92 // Property doesn't exists in Hibernate2
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	93 private static final String AUTOCOMMIT =
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	94 "hibernate.connection.autocommit";
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	95
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	96 public void configure(Properties props) throws HibernateException {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	97 try {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	98 log.debug("Configure DBCPConnectionProvider");
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	99
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	100 // DBCP properties used to create the BasicDataSource
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	101 Properties dbcpProperties = new Properties();
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	102
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	103 // DriverClass & url
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	104 String jdbcDriverClass = props.getProperty(Environment.DRIVER);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	105 String jdbcUrl = props.getProperty(Environment.URL);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	106 dbcpProperties.put("driverClassName", jdbcDriverClass);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	107 dbcpProperties.put("url", jdbcUrl);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	108
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	109 // Username / password
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	110 String username = props.getProperty(Environment.USER);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	111 String password = props.getProperty(Environment.PASS);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	112 dbcpProperties.put("username", username);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	113 dbcpProperties.put("password", password);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	114
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	115 // Isolation level
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	116 String isolationLevel = props.getProperty(Environment.ISOLATION);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	117 if (isolationLevel != null
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	118 && (isolationLevel = isolationLevel.trim()).length() > 0) {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	119 dbcpProperties.put("defaultTransactionIsolation", isolationLevel);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	120 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	121
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	122 // Turn off autocommit (unless autocommit property is set)
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	123 String autocommit = props.getProperty(AUTOCOMMIT);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	124 if (autocommit != null
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	125 && (autocommit = autocommit.trim()).length() > 0) {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	126 dbcpProperties.put("defaultAutoCommit", autocommit);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	127 } else {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	128 dbcpProperties.put("defaultAutoCommit", String.valueOf(Boolean.FALSE));
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	129 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	130
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	131 // Pool size
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	132 String poolSize = props.getProperty(Environment.POOL_SIZE);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	133 if (poolSize != null
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	134 && (poolSize = poolSize.trim()).length() > 0
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	135 && Integer.parseInt(poolSize) > 0) {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	136 dbcpProperties.put("maxActive", poolSize);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	137 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	138
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	139 // Copy all "driver" properties into "connectionProperties"
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	140 Properties driverProps =
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	141 ConnectionProviderFactory.getConnectionProperties(props);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	142
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	143 if (driverProps.size() > 0) {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	144 StringBuilder connectionProperties = new StringBuilder();
464 d37ccb04ab5d Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 184 diff changeset	145 for (Iterator iter = driverProps.entrySet().iterator();
168 86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	146 iter.hasNext();
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	147 ) {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	148 Map.Entry entry = (Map.Entry)iter.next();
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	149 String key = (String)entry.getKey();
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	150 String value = (String)entry.getValue();
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	151 connectionProperties
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	152 .append(key)
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	153 .append('=')
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	154 .append(value);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	155 if (iter.hasNext()) {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	156 connectionProperties.append(';');
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	157 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	158 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	159 dbcpProperties.put(
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	160 "connectionProperties", connectionProperties.toString());
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	161 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	162
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	163 // Copy all DBCP properties removing the prefix
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	164 for (Iterator iter = props.entrySet().iterator() ; iter.hasNext() ;) {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	165 Map.Entry entry = (Map.Entry)iter.next();
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	166 String key = (String)entry.getKey();
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	167 if (key.startsWith(PREFIX)) {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	168 String property = key.substring(PREFIX.length());
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	169 String value = (String)entry.getValue();
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	170 dbcpProperties.put(property, value);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	171 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	172 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	173
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	174 // Backward-compatibility
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	175 if (props.getProperty(DBCP_PS_MAXACTIVE) != null) {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	176 dbcpProperties.put(
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	177 "poolPreparedStatements",
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	178 String.valueOf(Boolean.TRUE));
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	179 dbcpProperties.put(
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	180 "maxOpenPreparedStatements",
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	181 props.getProperty(DBCP_PS_MAXACTIVE));
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	182 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	183
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	184 // Some debug info
181 4d9984411b3f Commented out a debug block because it leaks the db password. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 168 diff changeset	185 /* // commented out, because it leaks the password
168 86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	186 if (log.isDebugEnabled()) {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	187 log.debug("Creating a DBCP BasicDataSource" +
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	188 " with the following DBCP factory properties:");
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	189 StringWriter sw = new StringWriter();
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	190 dbcpProperties.list(new PrintWriter(sw, true));
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	191 log.debug(sw.toString());
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	192 }
181 4d9984411b3f Commented out a debug block because it leaks the db password. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 168 diff changeset	193 */
168 86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	194
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	195 // Let the factory create the pool
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	196 ds = (BasicDataSource)BasicDataSourceFactory
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	197 .createDataSource(dbcpProperties);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	198
5200 42bb6ff78d1b Directly set the connectionInitSqls on the datasource Andre Heinecke <aheinecke@intevation.de> parents: 5193 diff changeset	199 // This needs to be done manually as it is somehow ignored
42bb6ff78d1b Directly set the connectionInitSqls on the datasource Andre Heinecke <aheinecke@intevation.de> parents: 5193 diff changeset	200 // by the BasicDataSourceFactory if you set it as a dbcpProperty
42bb6ff78d1b Directly set the connectionInitSqls on the datasource Andre Heinecke <aheinecke@intevation.de> parents: 5193 diff changeset	201 String connectionInitSqls = props.getProperty("connectionInitSqls");
42bb6ff78d1b Directly set the connectionInitSqls on the datasource Andre Heinecke <aheinecke@intevation.de> parents: 5193 diff changeset	202 if (connectionInitSqls != null) {
42bb6ff78d1b Directly set the connectionInitSqls on the datasource Andre Heinecke <aheinecke@intevation.de> parents: 5193 diff changeset	203 StringTokenizer tokenizer = new StringTokenizer(connectionInitSqls, ";");
42bb6ff78d1b Directly set the connectionInitSqls on the datasource Andre Heinecke <aheinecke@intevation.de> parents: 5193 diff changeset	204 ds.setConnectionInitSqls(Collections.list(tokenizer));
42bb6ff78d1b Directly set the connectionInitSqls on the datasource Andre Heinecke <aheinecke@intevation.de> parents: 5193 diff changeset	205 }
168 86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	206 // The BasicDataSource has lazy initialization
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	207 // borrowing a connection will start the DataSource
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	208 // and make sure it is configured correctly.
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	209
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	210 // Connection conn = ds.getConnection();
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	211 // conn.close();
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	212 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	213 catch (Exception e) {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	214 String message = "Could not create a DBCP pool";
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	215 log.fatal(message, e);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	216 if (ds != null) {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	217 BasicDataSource x = ds; ds = null;
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	218 try {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	219 x.close();
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	220 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	221 catch (SQLException sqle) {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	222 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	223 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	224 throw new HibernateException(message, e);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	225 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	226 log.debug("Configure DBCPConnectionProvider complete");
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	227 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	228
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	229 public Connection getConnection() throws SQLException {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	230 return ds.getConnection();
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	231 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	232
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	233 public void closeConnection(Connection conn) throws SQLException {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	234 conn.close();
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	235 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	236
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	237 public void close() throws HibernateException {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	238 try {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	239 if (ds != null) {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	240 BasicDataSource x = ds; ds = null;
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	241 x.close();
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	242 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	243 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	244 catch (SQLException sqle) {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	245 throw new HibernateException("Could not close DBCP pool", sqle);
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	246 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	247 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	248
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	249 public boolean supportsAggressiveRelease() {
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	250 return false;
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	251 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	252 }
86a1bd9cc50e More Hibernate/JPA stuff Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	253 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :

Mercurial > dive4elements > river

annotate flys-backend/src/main/java/de/intevation/flys/utils/DBCPConnectionProvider.java @ 5200:42bb6ff78d1b 2.9.11