add 1 method to be compliant with Java 7

[cdmlib.git] / cdmlib-persistence / src / main / java / eu / etaxonomy / cdm / database / LocalH2.java

diff --git a/cdmlib-persistence/src/main/java/eu/etaxonomy/cdm/database/LocalH2.java b/cdmlib-persistence/src/main/java/eu/etaxonomy/cdm/database/LocalH2.java
index 2a6d7b4d4e32d8b12b2c6d95a13e89beac7b1107..e37ea0c51970d1a938ba1f968fc213a312122a43 100644 (file)
--- a/cdmlib-persistence/src/main/java/eu/etaxonomy/cdm/database/LocalH2.java
+++ b/cdmlib-persistence/src/main/java/eu/etaxonomy/cdm/database/LocalH2.java
@@ -10,19 +10,23 @@
 package eu.etaxonomy.cdm.database;\r
 \r
 import java.io.File;\r
+import java.io.IOException;\r
 import java.sql.Connection;\r
 import java.sql.Driver;\r
 import java.sql.DriverManager;\r
 import java.sql.SQLException;\r
 import java.util.Properties;\r
 \r
+import javax.sql.DataSource;\r
+\r
+import org.apache.commons.dbcp.BasicDataSource;\r
+import org.apache.commons.pool.impl.GenericObjectPool;\r
 import org.apache.log4j.Logger;\r
 import org.h2.tools.Server;\r
 import org.springframework.jdbc.CannotGetJdbcConnectionException;\r
-import org.springframework.jdbc.datasource.DriverManagerDataSource;\r
-//import org.springframework.jdbc.datasource.DriverManagerDataSource;\r
 \r
 import eu.etaxonomy.cdm.api.application.CdmApplicationUtils;\r
+import eu.etaxonomy.cdm.model.name.NomenclaturalCode;\r
 \r
 \r
 /**\r
@@ -32,13 +36,13 @@ import eu.etaxonomy.cdm.api.application.CdmApplicationUtils;
  *\r
  */\r
 \r
-public class LocalH2 extends DriverManagerDataSource {\r
+public class LocalH2 extends BasicDataSource {\r
        private static final Logger logger = Logger.getLogger(LocalH2.class);\r
        \r
        private String sep = System.getProperty("file.separator");\r
        \r
        /** url without database name */\r
-       protected String pureUrl = "jdbc:h2:tcp://localhost:9092/";\r
+       protected String pureUrl = "jdbc:h2:";\r
        /** database name */\r
        protected String dbName = "cdm";\r
        /** path, where database should be stored in the file system */\r
@@ -51,12 +55,16 @@ public class LocalH2 extends DriverManagerDataSource {
        protected boolean isSilent = true;\r
        /** default driver class name */\r
        protected String DEFAULT_DRIVER_CLASS_NAME = "org.h2.Driver";\r
+       String mode = H2Mode.EMBEDDED.toString();\r
+\r
+       private NomenclaturalCode nomenclaturalCode; \r
        \r
        /**\r
         * \r
         */\r
        public LocalH2() {\r
                setDriverClassName(DEFAULT_DRIVER_CLASS_NAME);\r
+               setLocalUrl();\r
        }\r
 \r
        /**\r
@@ -64,10 +72,24 @@ public class LocalH2 extends DriverManagerDataSource {
         * @throws CannotGetJdbcConnectionException\r
         */\r
        public LocalH2(String url) throws CannotGetJdbcConnectionException {\r
-               super(url);\r
+               super();\r
+               this.setUrl(url);\r
                setDriverClassName(DEFAULT_DRIVER_CLASS_NAME);\r
        }\r
 \r
+       /* FIXME This is a workaround to solve a problem with dbcp connection pooling.\r
+        * Remove this when dbcp connection pool gets configured correctly\r
+        * \r
+        * (non-Javadoc)\r
+        * @see org.apache.commons.dbcp.BasicDataSource#createDataSource()\r
+        */\r
+       @Override\r
+       protected synchronized DataSource createDataSource() throws SQLException {\r
+               super.createDataSource();\r
+               connectionPool.setWhenExhaustedAction(GenericObjectPool.WHEN_EXHAUSTED_GROW);\r
+               return dataSource;\r
+       }\r
+       \r
        /**\r
         * @param url\r
         * @param username\r
@@ -76,8 +98,9 @@ public class LocalH2 extends DriverManagerDataSource {
         */\r
        public LocalH2(String url, String username, String password)\r
                        throws CannotGetJdbcConnectionException {\r
-               super(url, username, password);\r
-               this.setDriverClassName(DEFAULT_DRIVER_CLASS_NAME);\r
+               this(url);\r
+               this.setUsername(username);\r
+               this.setPassword(password);\r
        }\r
 \r
        /**\r
@@ -89,12 +112,14 @@ public class LocalH2 extends DriverManagerDataSource {
         */\r
        public LocalH2(String driverClassName, String url, String username,\r
                        String password) throws CannotGetJdbcConnectionException {\r
-               super(driverClassName, url, username, password);\r
+               this(url, username, password);\r
+               this.setDriverClassName(driverClassName);\r
        }\r
 \r
 //** ********************************************************************************/\r
        \r
        public void init(){\r
+               logger.info("LocalH2init");\r
                if (true){   //starting sever is not necessary for H2\r
                        return;\r
                }\r
@@ -126,19 +151,9 @@ public class LocalH2 extends DriverManagerDataSource {
                                logger.info("Start H2Server"); \r
                                String[] args = new String[] { "-trace" };\r
                                h2Server = Server.createTcpServer(args).start();\r
-                               if (logger.isDebugEnabled()){\r
-                                       for (int i = 0; i < 10; i++){\r
-//                                             logger.info("DatabaseName " + i + ": " + h2Server.getDatabaseName(i, true));\r
-//                                             logger.info("DatabaseName " + i + ": " + h2Server.getDatabaseName(i, false));\r
-//                                             logger.info("DatabasePath " + i + ": " + h2Server.getDatabasePath(i, true));\r
-//                                             logger.info("DatabasePath " + i + ": " + h2Server.getDatabasePath(i, false));\r
-//                                             logger.info("DatabaseType " + i + ": " + h2Server.getDatabaseType(i));\r
-                                       }\r
-                               }\r
 //                             h2Server.setDatabaseName(0, getDbName());\r
 //                             h2Server.setDatabasePath(0,  getDatabasePath());\r
                                h2Server.start();\r
-//                             h2Server.checkRunning(true);\r
                        } catch (SQLException sqle1) {\r
                                logger.error("SQL Exception when starting Local H2Server: "+ sqle1);\r
                        } catch (RuntimeException e1) {\r
@@ -158,9 +173,14 @@ public class LocalH2 extends DriverManagerDataSource {
                }\r
        }\r
        \r
-       public static final String getDefaultPath(){\r
-               //String path = System.getProperty("user.dir");\r
-               File path = CdmApplicationUtils.getWritableResourceDir();\r
+       private static final String getDefaultPath(){\r
+               File path;\r
+               try {\r
+                       path = CdmApplicationUtils.getWritableResourceDir();\r
+               } catch (IOException e) {\r
+                       logger.error(e);\r
+                       throw new RuntimeException(e);\r
+               }\r
                String subPath = File.separator + "h2" + File.separator + "LocalH2"; \r
                return  path + subPath;\r
        }\r
@@ -196,6 +216,24 @@ public class LocalH2 extends DriverManagerDataSource {
                this.isStartServer = isStartServer;\r
        }\r
        \r
+       public void setLocalUrl(){\r
+               String dbName = "cdmLocal";\r
+               String localUrlString = pureUrl + "file:" + getDefaultPath() + "/" + dbName;\r
+               logger.info("setLocalUrl: " + localUrlString);\r
+               setUrl(localUrlString);\r
+       }\r
+       \r
+       public void setMode(String mode){\r
+               this.mode = mode;\r
+       }\r
+       \r
+       public String getMode(){\r
+               return mode;\r
+       }\r
+       \r
+       public void setNomenclaturalCode(NomenclaturalCode code){\r
+               this.nomenclaturalCode = code;\r
+       }\r
        \r
 \r
 }\r