在eclipselink中设置隔离级别

Question

我想使用eclipse链接设置隔离级别，我尝试了以下两种方法：

>

java.sql.连接

mgr = EMF.get().createEntityManager();
tx = mgr.getTransaction();
tx.begin();

java.sql.Connection connection = mgr.unwrap(java.sql.Connection.class);
connection.setTransactionIsolation(java.sql.Connection.TRANSACTION_READ_COMMITTED);
System.out.println("Connection: "+connection.getTransactionIsolation());
//prints TRANSACTION_READ_COMMITED as expected

org.eclipse.persistence.sessions.DatabaseLogin databaseLogin = new DatabaseLogin();
System.out.println("DatabaseLoging: "+databaseLogin.getTransactionIsolation());
//prints -1, representing transaction isolation is not set

Database aseLogin setTransationIsolation方法

mgr = EMF.get().createEntityManager();
tx = mgr.getTransaction();
tx.begin();

org.eclipse.persistence.sessions.DatabaseLogin databaseLogin = new DatabaseLogin();
databaseLogin.setTransactionIsolation(DatabaseLogin.TRANSACTION_READ_COMMITTED);
System.out.println("DatabaseLoging: "+databaseLogin.getTransactionIsolation());
//prints TRANSACTION_READ_COMMITED as expected

java.sql.Connection connection = mgr.unwrap(java.sql.Connection.class);
System.out.println("Connection: "+connection.getTransactionIsolation());
//prints TRANSACTION_REPEATABLE_READ

如您所见，getTransactionSolation（）方法的返回值之间存在一些不一致。我的问题是，在这两种情况下真正设置了哪种事务隔离？我知道eclipse链接在默认情况下使用不同的连接进行读写操作，即DatabaseLogin。setTransactionIsolation应该为两个连接设置隔离级别，那么为什么选择连接呢。getTransactionIsolation仍然返回另一个隔离级别？

我正在使用Application范围的EntityManager、JPA 2.0、Eclipse Link 2.5.2。
如果有更可取的方式设置事务隔离，请告诉我。

Answer 1

databaseLogin类是一个内部对象，EclipseLink使用它来配置访问数据库的方式以及用于配置这些连接的设置。直接对连接所做的任何更改都不会反映在DatabaseLogin实例中。

仅仅创建一个新的数据库登录实例并不能让您访问持久化单元正在使用的设置。您需要获得EntityManager/EMF下的会话使用的数据库登录。

Answer 2

在使用eclipse link稍作停顿后，我终于找到了如何设置事务隔离级别。
正如@Chris在他的回答中正确提到的那样，我需要获取会话使用的数据库登录。经过对eclipse链接会话的小研究，我发现我可以在自己的SessionCustomizer中更改会话属性，请参阅下面的代码：

package com.filip.blabla;
import org.eclipse.persistence.sessions.DatabaseLogin;
import org.eclipse.persistence.sessions.Session;
import org.eclipse.persistence.sessions.factories.SessionCustomizer;

public class DFSessionCustomizer implements SessionCustomizer {
        @Override
        public void customize(Session session) throws Exception {
            DatabaseLogin databaseLogin = (DatabaseLogin) session.getDatasourceLogin();
            databaseLogin.setTransactionIsolation(DatabaseLogin.TRANSACTION_READ_COMMITTED);
        }

}

在persistence.xml中设置SessionCustomizer

<property name="eclipselink.session.customizer" value="com.filip.blabla.DFSessionCustomizer"/>