mysql - 使用 JPA EntityManagerFactory(JSE、EclipseLink、Tomcat)连接到运行时在网络服务器中选择的不同 mysql 模式，这可能吗？

Question

有没有办法在运行时重新创建已在 Web 应用程序中使用的 EntityManagerFactory？我想要的是告诉 entityManagerFactory 忘记最后一个数据库连接，并在 web 用户选择其他数据库(mysql 模式)时在运行时连接到新模式。或者不要忘记已经使用过的，但也使用一个新的连接到另一个尚未使用的 mysql 模式。这些模式具有完全相同的结构(表等)，但出于安全和其他原因针对不同的用户。这可能吗？

我正在使用 Vaadin 框架、Eclipselink 2.4.1、Mysql 5.5 和 Tomcat 7。我发现与我的情况相关的内容以及我已经尝试过的内容如下。我正在使用 Eclipselink 复合持久性单元，第二个成员始终相同，我想将第一个模式更改为例如“42_candidate”，当用户在已经连接其他模式(如“41_candidate”)后选择网页上的第 42 个候选者时".

private static EntityManager createEntityManagerForCandidateSchema(String candidateSchemaName) throws javax.persistence.PersistenceException {        

    System.out.println("createEntityManagerForCandidateSchema called");
    // set persistence unit properties
    HashMap<String,String> candidatePuProps = new HashMap<String,String>();
    candidatePuProps.put("javax.persistence.jdbc.url", "jdbc:mysql://localhost:3306/"+candidateSchemaName+"?useUnicode=true&amp;characterEncoding=UTF-8");

    HashMap<String,Map> compositePuProps = new HashMap<String,Map>();
    compositePuProps.put("election_model_candidate", candidatePuProps);

    Map puProps = new HashMap();
    puProps.put("eclipselink.logging.level", "FINEST");
    puProps.put("eclipselink.composite-unit.properties", compositePuProps);
    // puProps.put(PersistenceUnitProperties.SESSION_CUSTOMIZER, "com.beharbe.ui.ElectionSessionCustomizer");       

    boolean candidateDatabaseSchemaNotFound = false;
    try {
        EntityManagerFactory emf = javax.persistence.Persistence.createEntityManagerFactory("election_composite_pu",puProps);
        emf.close(); // to forget latest things
        emf = javax.persistence.Persistence.createEntityManagerFactory("election_composite_pu",puProps);            
        EntityManager em = emf.createEntityManager(compositePuProps);

...
public void selectionChanged(int newCandidatePersonId) {
    entityManager = Util.createEntityManagerForCandidateSchema(newCandidatePersonId);
    ...

(Eclipselink 复合 PU)wiki.eclipse.org/EclipseLink/UserGuide/sandbox/gelernter/Composite_Persistence_Units#Persistence_Unit_Properties

(动态持久化)dev.eclipse.org/svnroot/rt/org.eclipse.persistence/branches/2.1/trunk/examples/jpa.employee/eclipselink.example.jpa.employee.dynamic/src/example/Main.java

(EclipseLink - 如何在运行时配置数据库架构名称)www.rqna.net/qna/kxvmwy-jpa-eclipselink-how-to-configure-database-schema-name-at-runtime.html

(Eclipselink 与 Tomcat 教程)wiki.eclipse.org/EclipseLink/Examples/JPA/Tomcat_Web_Tutorial#Session_Customizer

(将 JPAContainer 与 Hibernate(Vaadin)结合使用)vaadin.com/book/-/page/jpacontainer.hibernate.html

(如何让一个 JPA 应用程序访问不同的数据库？)stackoverflow.com/questions/9315593/how-can-i-make-a-jpa-application-access-different-databases

(动态连接两个或多个数据库)stackoverflow.com/questions/9732750/connect-two-or-more-databases-dynamically?lq=1

(JPA - 使用多个数据源定义访问控制)www.rqna.net/qna/kqqihk-jpa-using-multiple-data-sources-to-define-access-control.html

JPA2 run-time database connection

JPA - EclipseLink - How to configure Database Schema name at runtime (Eclipselink SessionCustomizer)

也许我应该以某种方式使用 EclipseLink SessionCustomizer 来完成它？ (查看最新链接)

提前感谢您的帮助

---

同时我发现了一些东西，这可能是我必须使用的东西:

http://wiki.eclipse.org/EclipseLink/Examples/JPA/Auditing

我正在尝试这种方式，但它仍然连接到 EMF 第一次调用时首先连接的架构:

....
candidatePuProps.put(PersistenceUnitProperties.JDBC_URL, "jdbc:mysql://localhost:3306/"+candidateSchemaName+"?useUnicode=true&characterEncoding=UTF-8");
    candidatePuProps.put(PersistenceUnitProperties.EXCLUSIVE_CONNECTION_MODE, "Always");
    candidatePuProps.put(PersistenceUnitProperties.EXCLUSIVE_CONNECTION_IS_LAZY, "false");
...

Answer 1

如果你想访问两个不同的数据库/模式，你可以调用 createEntityManagerFactory() 传递一个属性映射到你的新连接。

要在代码中使用 EclipseLink 设置架构，您可以在定制器中设置 tableQualifier。要获得新的 EntityManagerFactory，您可以传递“eclipselink.session-name”属性。

您的代码看起来是正确的。您使用的是哪个版本的 EclipseLink？

去掉复合持久化单元，我想你好像只想连接到不同的数据库。复合持久性单元适用于跨数据库的关系。