X-Git-Url: https://juplo.de/gitweb/?p=hibernate4-maven-plugin;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fplugins%2Fhibernate%2FSimpleConnectionProvider.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fplugins%2Fhibernate%2FSimpleConnectionProvider.java;h=36fe5614ba0e3589145a3767c64afd521022cd81;hp=0000000000000000000000000000000000000000;hb=4940080670944a15916c68fb294e18a6bfef12d5;hpb=fdda82a6f76deefd10f83da89d7e82054e3c3ecd

diff --git a/src/main/java/de/juplo/plugins/hibernate/SimpleConnectionProvider.java b/src/main/java/de/juplo/plugins/hibernate/SimpleConnectionProvider.java
new file mode 100644
index 00000000..36fe5614
--- /dev/null
+++ b/src/main/java/de/juplo/plugins/hibernate/SimpleConnectionProvider.java
@@ -0,0 +1,249 @@
+package de.juplo.plugins.hibernate;
+
+import java.sql.Connection;
+import java.sql.Driver;
+import java.sql.DriverManager;
+import java.sql.DriverPropertyInfo;
+import java.sql.SQLException;
+import java.sql.SQLFeatureNotSupportedException;
+import java.util.Properties;
+import java.util.logging.Logger;
+import org.apache.maven.plugin.MojoFailureException;
+import org.apache.maven.plugin.logging.Log;
+import static org.eclipse.aether.repository.AuthenticationContext.PASSWORD;
+import static org.eclipse.aether.repository.AuthenticationContext.USERNAME;
+import org.hibernate.boot.registry.classloading.spi.ClassLoaderService;
+import static org.hibernate.cfg.AvailableSettings.DRIVER;
+import static org.hibernate.cfg.AvailableSettings.PASS;
+import static org.hibernate.cfg.AvailableSettings.URL;
+import static org.hibernate.cfg.AvailableSettings.USER;
+import org.hibernate.engine.jdbc.connections.spi.ConnectionProvider;
+import static org.hibernate.jpa.AvailableSettings.JDBC_DRIVER;
+import static org.hibernate.jpa.AvailableSettings.JDBC_PASSWORD;
+import static org.hibernate.jpa.AvailableSettings.JDBC_URL;
+import static org.hibernate.jpa.AvailableSettings.JDBC_USER;
+
+/**
+ *
+ * @author Kai Moritz
+ */
+class SimpleConnectionProvider implements ConnectionProvider
+{
+  private final Log log;
+
+  private Connection connection;
+
+
+  SimpleConnectionProvider(Log log)
+  {
+    this.log = log;
+  }
+
+
+  void open(ClassLoaderService classLoaderService, Properties properties)
+      throws
+        MojoFailureException
+  {
+
+    String driver = (String)
+        (properties.containsKey(DRIVER)
+            ? properties.getProperty(DRIVER)
+            : properties.getProperty(JDBC_DRIVER)
+            );
+    String url = (String)
+        (properties.containsKey(URL)
+            ? properties.getProperty(URL)
+            : properties.getProperty(JDBC_URL)
+            );
+    String user = (String)
+        (properties.containsKey(USER)
+            ? properties.getProperty(USER)
+            : properties.getProperty(JDBC_USER)
+            );
+    String password = (String)
+        (properties.containsKey(PASS)
+            ? properties.getProperty(PASS)
+            : properties.getProperty(JDBC_PASSWORD)
+            );
+
+    if (driver == null || url == null || user == null)
+    {
+      log.info("No connection opened, because connection information is incomplete");
+      log.info("Driver-Class: " + driver);
+      log.info("URL: " + url);
+      log.info("User: " + user);
+      return;
+    }
+
+    try
+    {
+      Class driverClass = classLoaderService.classForName(driver);
+
+      log.debug("Registering JDBC-driver " + driverClass.getName());
+      DriverManager
+          .registerDriver(new DriverProxy((Driver) driverClass.newInstance()));
+
+      log.debug(
+          "Opening JDBC-connection to " + properties.getProperty(URL) +
+          " as " + properties.getProperty(USERNAME) +
+          " with password " + properties.getProperty(PASSWORD)
+          );
+    
+      connection = DriverManager.getConnection(url, user, password);
+    }
+    catch (Exception e)
+    {
+      throw new MojoFailureException("Could not open the JDBC-connection", e);
+    }
+  }
+
+  void close()
+  {
+    if (connection == null)
+      return;
+
+    log.debug("Closing the JDBC-connection.");
+    try
+    {
+      connection.close();
+    }
+    catch (SQLException e)
+    {
+      log.error("Error while closing the JDBC-connection: " + e.getMessage());
+    }
+  }
+
+  @Override
+  public Connection getConnection() throws SQLException
+  {
+    log.debug("Connection aquired.");
+
+    if (connection == null)
+      throw new SQLException("No connection available, because of insufficient connection information!");
+
+    return connection;
+  }
+
+  @Override
+  public void closeConnection(Connection conn) throws SQLException
+  {
+    log.debug("Connection released");
+  }
+
+  @Override
+  public boolean supportsAggressiveRelease()
+  {
+    return false;
+  }
+
+  @Override
+  public boolean isUnwrappableAs(Class unwrapType)
+  {
+    return false;
+  }
+
+  @Override
+  public <T> T unwrap(Class<T> unwrapType)
+  {
+    throw new UnsupportedOperationException("Not supported.");
+  }
+
+  /**
+   * Needed, because DriverManager won't pick up drivers, that were not
+   * loaded by the system-classloader!
+   * See:
+   * http://stackoverflow.com/questions/288828/how-to-use-a-jdbc-driver-fromodifiedm-an-arbitrary-location
+   */
+  static final class DriverProxy implements Driver
+  {
+    private final Driver target;
+
+    DriverProxy(Driver target)
+    {
+      if (target == null)
+        throw new NullPointerException();
+      this.target = target;
+    }
+
+    public java.sql.Driver getTarget()
+    {
+      return target;
+    }
+
+    @Override
+    public boolean acceptsURL(String url) throws SQLException
+    {
+      return target.acceptsURL(url);
+    }
+
+    @Override
+    public java.sql.Connection connect(
+        String url,
+        java.util.Properties info
+      )
+      throws
+        SQLException
+    {
+      return target.connect(url, info);
+    }
+
+    @Override
+    public int getMajorVersion()
+    {
+      return target.getMajorVersion();
+    }
+
+    @Override
+    public int getMinorVersion()
+    {
+      return target.getMinorVersion();
+    }
+
+    @Override
+    public DriverPropertyInfo[] getPropertyInfo(
+        String url,
+        Properties info
+      )
+      throws
+        SQLException
+    {
+      return target.getPropertyInfo(url, info);
+    }
+
+    @Override
+    public boolean jdbcCompliant()
+    {
+      return target.jdbcCompliant();
+    }
+
+    /**
+     * This Method cannot be annotated with @Override, becaus the plugin
+     * will not compile then under Java 1.6!
+     */
+    public Logger getParentLogger() throws SQLFeatureNotSupportedException
+    {
+      throw new SQLFeatureNotSupportedException("Not supported, for backward-compatibility with Java 1.6");
+    }
+
+    @Override
+    public String toString()
+    {
+      return "Proxy: " + target;
+    }
+
+    @Override
+    public int hashCode()
+    {
+      return target.hashCode();
+    }
+
+    @Override
+    public boolean equals(Object obj)
+    {
+      if (!(obj instanceof DriverProxy))
+        return false;
+      DriverProxy other = (DriverProxy) obj;
+      return this.target.equals(other.target);
+    }
+  }
+}