从Hibernate迁移至EclipseLink，如何实现XA数据库连接获取？

要在EclipseLink中实现你在Hibernate里的XA连接复用逻辑（从ThreadLocal获取XAConnection，无则从XADataSource创建，返回其Connection），可以通过自定义Connector来实现，具体步骤如下：

1. 自定义XA数据源Connector #

EclipseLink的连接获取逻辑由Connector接口定义，我们可以扩展DefaultConnector（EclipseLink内置的基础连接器），重写连接获取方法来匹配你的需求：

import org.eclipse.persistence.sessions.DefaultConnector;
import org.eclipse.persistence.sessions.DatabaseLogin;
import org.eclipse.persistence.sessions.Session;
import javax.sql.XADataSource;
import javax.sql.XAConnection;
import java.sql.Connection;
import java.sql.SQLException;

public class EclipseLinkXADataSourceConnector extends DefaultConnector {

    @Override
    public Connection connect(DatabaseLogin login, Session session) throws SQLException {
        Object dataSource = login.getDataSource();
        if (dataSource != null && dataSource instanceof XADataSource) {
            // 从ThreadLocal获取XAConnection
            XAConnection xaConnection = ThreadLocalXAConnection.get();
            if (xaConnection == null) {
                xaConnection = ((XADataSource) dataSource).getXAConnection();
            }
            return xaConnection.getConnection();
        }
        // 非XA数据源场景，调用父类默认逻辑
        return super.connect(login, session);
    }
}

2. 配置EclipseLink使用自定义Connector #

你需要将自定义Connector配置到EclipseLink会话中，有两种常用方式：

方式一：通过persistence.xml配置 #

在persistence.xml中添加会话自定义器的配置，再通过自定义器设置Connector：

<persistence-unit name="your-persistence-unit" transaction-type="JTA">
    <!-- 其他数据源、实体映射等配置 -->
    <properties>
        <property name="eclipselink.session.customizer" value="com.yourpackage.EclipseLinkXAConnectorCustomizer"/>
    </properties>
</persistence-unit>

然后实现会话自定义器类：

import org.eclipse.persistence.sessions.Session;
import org.eclipse.persistence.sessions.SessionCustomizer;

public class EclipseLinkXAConnectorCustomizer implements SessionCustomizer {
    @Override
    public void customize(Session session) throws Exception {
        EclipseLinkXADataSourceConnector customConnector = new EclipseLinkXADataSourceConnector();
        session.getLogin().setConnector(customConnector);
    }
}

方式二：代码直接配置 #

如果是通过代码创建EclipseLink会话，可以直接为Login对象设置自定义Connector：

DatabaseLogin login = new DatabaseLogin();
// 配置你的XA数据源
login.setDataSource(yourXADataSourceInstance);
// 设置自定义Connector
login.setConnector(new EclipseLinkXADataSourceConnector());

// 创建并初始化会话
Session session = org.eclipse.persistence.sessions.SessionManager.getManager().getSession(login, true, false);

关键说明 #

• 你原有的ThreadLocalXAConnection类可以直接复用，无需修改
• 确保你的XADataSource已正确配置（比如通过应用服务器JNDI注入或代码实例化）
• 该逻辑仅在数据源为XADataSource时生效，非XA场景会自动 fallback 到EclipseLink默认的连接获取逻辑

内容的提问来源于stack exchange，提问作者Atul D