EclipseLink JPA 2.1用户提供的连接

Question

我想使用Eclipse Link作为我的JPA引擎。我们正在使用java.sql.Connection的子类，我想知道我是否可以强制Eclipse Link使用我的连接。我想以编程方式设置连接对象。

类似于

MyConnection conn = new MyConnection(JDBC_URL, USR, PWD);
EntityManagerFactory factory = Persistence.createEntityManagerFactory(conn);

Answer 1

^{*此解决方案使用Spring框架。}

首先，您需要将连接封装在javax中。sql。数据源，例如：

import java.sql.Connection;
import java.sql.SQLException;

import org.springframework.jdbc.datasource.AbstractDataSource;

public class MyDataSource extends AbstractDataSource {

    private static final String JDBC_URL = "jdbc:mysql://localhost/test";
    private static final String USR = "root";
    private static final String PWD = "";

    public Connection getConnection() throws SQLException {
        return new MyConnection(JDBC_URL, USR, PWD);
    }

    public Connection getConnection(String username, String password)
            throws SQLException {
        return new MyConnection(JDBC_URL, USR, PWD);
    }
}

为了避免覆盖所有方法，可以在Spring中扩展现有类。

import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;

import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.orm.jpa.vendor.EclipseLinkJpaVendorAdapter;

public class Main {

    public static void main(String[] args) {
        LocalContainerEntityManagerFactoryBean bean =
                new LocalContainerEntityManagerFactoryBean();
        bean.setDataSource(new MyDataSource());
        bean.setPersistenceUnitName("TestPU");
        bean.setJpaVendorAdapter(new EclipseLinkJpaVendorAdapter());
        bean.afterPropertiesSet();

        EntityManagerFactory factory = bean.getNativeEntityManagerFactory();
        EntityManager em = factory.createEntityManager();
        em.getTransaction().begin();
        User user = new User();
        user.setFullname("Mister");
        em.persist(user);
        em.getTransaction().commit();
        em.close();
    }

}

注意事项

>

您可能需要在persistence.xml中添加下一个属性：

<property name="eclipselink.weaving" value="false"/>

我使用了一个独立的Maven项目来测试pom中的代码和依赖项。xml如下所示：

<dependencies>
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>5.1.31</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context</artifactId>
        <version>4.0.5.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-orm</artifactId>
        <version>4.0.5.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.eclipse.persistence</groupId>
        <artifactId>eclipselink</artifactId>
        <version>2.5.1</version>
    </dependency>
</dependencies>

或者，如果您愿意，所需的罐子：

mysql-connector-java-5.1.31.jar
spring-context-4.0.5.RELEASE.jar
spring-aop-4.0.5.RELEASE.jar
aopalliance-1.0.jar
spring-beans-4.0.5.RELEASE.jar
spring-core-4.0.5.RELEASE.jar
commons-logging-1.1.3.jar
spring-expression-4.0.5.RELEASE.jar
spring-orm-4.0.5.RELEASE.jar
spring-jdbc-4.0.5.RELEASE.jar
spring-tx-4.0.5.RELEASE.jar
eclipselink-2.5.1.jar
javax.persistence-2.1.0.jar
commonj.sdo-2.1.1.jar

Answer 2

您可以使用以下代码以编程方式设置自定义连接：

Map properties = new HashMap();

// Configure the internal EclipseLink connection pool
properties.put(JDBC_DRIVER, "oracle.jdbc.OracleDriver");
properties.put(JDBC_URL, "jdbc:oracle:thin:@localhost:1521:ORCL");
properties.put(JDBC_USER, "user-name");
properties.put(JDBC_PASSWORD, "password");
Persistence.createEntityManagerFactory("unit-name", properties);

经过快速的谷歌搜索，我在这里找到了这个答案：

http://eclipse.1072660.n5.nabble.com/Defining-persistence-xml-programatically-td2536.html

我不相信有一种方法可以迫使Eclipselink只使用java进行连接。sql。连接；至少不是现成的。您可以创建一个简单的实用方法来传递所述连接，并按照上面所述构建属性映射。

public Map convertConnectionToProperties(Connection conn) {
    // Do the mapping

    return theMap;
}

如果你看看这个链接，你会看到

createEntityManagerFactory(String persistenceUnitName) 
createEntityManagerFactory(String persistenceUnitName, Map properties) 

这就是它可以作为参数的全部内容。简而言之；如果不使用连接对象并将其调整为返回符合创建实体管理工厂（createEntityManagerFactory）可以接受的内容，那么您所要求的是不可能的。

class MyConnection {
     // Your code here
    
    public Map convertToMap() {
        // Do the mapping

        return theMap;
    }

    public String getPersistenceUnitName() {
        return "Some-Name";
    }
}

然后像这样利用它：

MyConnection conn = new MyConnection(JDBC_URL, USR, PWD);
EntityManagerFactory factory = Persistence.createEntityManagerFactory(conn.getPersistenceUnitName(), conn.convertToMap());