derby embedded db support initial commit; shutdown use case needs work

org.springframework.jdbc/src/main/java/org/springframework/jdbc/datasource/embedded/DerbyEmbeddedDatabaseConfigurer.java

@@ -0,0 +1,97 @@
+/*
+ * Copyright 2002-2009 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.springframework.jdbc.datasource.embedded;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.sql.SQLNonTransientConnectionException;
+
+import javax.sql.DataSource;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.derby.jdbc.EmbeddedDriver;
+import org.springframework.jdbc.datasource.SimpleDriverDataSource;
+import org.springframework.util.ClassUtils;
+
+/**
+ * {@link EmbeddedDatabaseConfigurer} for Apache Derby database.
+ * 
+ * @author Oliver Gierke
+ */
+public class DerbyEmbeddedDatabaseConfigurer implements EmbeddedDatabaseConfigurer {
+
+	private static final Log logger = LogFactory.getLog(DerbyEmbeddedDatabaseConfigurer.class);
+	
+	private static final String URL_TEMPLATE = "jdbc:derby:memory:%s;%s";
+
+	// Error codes that indicate successful shutdown
+	private static final String SHUTDOWN_CODE = "08006";
+
+	private static DerbyEmbeddedDatabaseConfigurer INSTANCE;
+
+	private DerbyEmbeddedDatabaseConfigurer() {
+	}
+
+	/**
+	 * Get the singleton {@link HsqlEmbeddedDatabaseConfigurer} instance.
+	 * @return the configurer
+	 * @throws ClassNotFoundException if HSQL is not on the classpath
+	 */
+	public static synchronized DerbyEmbeddedDatabaseConfigurer getInstance() throws ClassNotFoundException {
+		if (INSTANCE == null) {
+			ClassUtils.forName("org.apache.derby.jdbc.EmbeddedDriver", DerbyEmbeddedDatabaseConfigurer.class
+					.getClassLoader());
+			INSTANCE = new DerbyEmbeddedDatabaseConfigurer();
+		}
+		return INSTANCE;
+	}
+
+	public void configureConnectionProperties(ConnectionProperties properties, String databaseName) {
+		properties.setDriverClass(org.apache.derby.jdbc.EmbeddedDriver.class);
+		properties.setUrl(String.format(URL_TEMPLATE, databaseName, "create=true"));
+		properties.setUsername("sa");
+		properties.setPassword("");
+	}
+
+	@Override
+	public void shutdown(DataSource dataSource, String databaseName) {
+		Connection connection = null;
+		try {
+			SimpleDriverDataSource shutdownDataSource = new SimpleDriverDataSource();
+			shutdownDataSource.setDriverClass(EmbeddedDriver.class);
+			shutdownDataSource.setUrl(String.format(URL_TEMPLATE, databaseName, "shutdown=true"));
+			connection = shutdownDataSource.getConnection();
+		} catch (SQLException e) {
+			if (e instanceof SQLNonTransientConnectionException) {
+				SQLNonTransientConnectionException ex = (SQLNonTransientConnectionException) e;
+				if (!SHUTDOWN_CODE.equals(ex.getSQLState())) {
+					logException(e);
+				}
+			} else {
+				logException(e);
+			}
+		} finally {
+			JdbcUtils.closeConnection(connection);
+		}
+	}
+
+	private void logException(SQLException e) {
+		if (logger.isWarnEnabled()) {
+			logger.warn("Could not shutdown in-memory Derby database", e);
+		}
+	}
+}

org.springframework.jdbc/src/main/java/org/springframework/jdbc/datasource/embedded/EmbeddedDatabaseConfigurerFactory.java

@@ -33,6 +33,8 @@ final class EmbeddedDatabaseConfigurerFactory {
 				return HsqlEmbeddedDatabaseConfigurer.getInstance();
 			case H2:
 				return H2EmbeddedDatabaseConfigurer.getInstance();
+			case DERBY:
+				return DerbyEmbeddedDatabaseConfigurer.getInstance();
 			default:
 				throw new UnsupportedOperationException("Other embedded database types not yet supported");
 			}
@@ -41,7 +43,7 @@ final class EmbeddedDatabaseConfigurerFactory {
 					+ "] are not available in the classpath", e);
 		}
 	}
-	
+
 	private EmbeddedDatabaseConfigurerFactory() {
 	}
 

org.springframework.jdbc/src/main/java/org/springframework/jdbc/datasource/embedded/EmbeddedDatabaseType.java

@@ -21,5 +21,5 @@ package org.springframework.jdbc.datasource.embedded;
  * @author Oliver Gierke
  */
 public enum EmbeddedDatabaseType {
-	HSQL, H2;
+	HSQL, H2, DERBY;
 }