JPA配置MySQL会话变量：适配MariaDB Galera Cluster最优方案

我来帮你梳理下在EclipseLink作为JPA提供者时，给每个数据库会话自动设置SET SESSION wsrep_sync_wait = 1的几种方案，以及最适合你的选择：

选项1：EclipseLink会话定制器（无效） #

你尝试的这个方案没生效，核心原因是SessionCustomizer的customize方法只会在EclipseLink初始化全局会话时执行一次，而不是每个EntityManager创建时都触发。后续新建立的数据库连接会话并不会继承这个初始化时的设置，所以你查询到的变量值始终是默认的0。

你的代码示例：

public class SessionCustomizerImpl implements org.eclipse.persistence.config.SessionCustomizer {
    private final static String WSREP_SYNC_WAIT_CHECK_SQL = "SHOW SESSION VARIABLES LIKE 'wsrep_sync_wait'";
    private final static String WSREP_SYNC_WAIT_SET_SQL = "SET SESSION wsrep_sync_wait = 1";
    @Override
    public void customize(Session session) throws Exception {
        Vector result = session.executeSQL(WSREP_SYNC_WAIT_CHECK_SQL);
        if ((result != null) && !result.isEmpty()) {
            session.executeNonSelectingSQL(WSREP_SYNC_WAIT_SET_SQL);
            // 检测到Galera连接；wsrep_sync_wait设为1
        } else {
            // 未检测到Galera连接；未设置wsrep_sync_wait
        }
    }
}

这个方案仅适用于全局会话的初始化配置，无法覆盖每个新的数据库连接会话，完全不符合你的需求，直接排除。

选项2：EntityManager工厂包装类（可行但有优化空间） #

这个方案确实能实现每个EntityManager创建时设置变量，但你担心的冗余问题是对的——SET SESSION属于会话级操作，根本不需要包裹在事务里。你可以修改代码去掉不必要的事务逻辑：

public class SyncWaitEntityManagerFactory implements Factory<EntityManager> {
    private final EntityManagerFactory emf;
    @Inject
    public SyncWaitEntityManagerFactory(EntityManagerFactory emf) {
        this.emf = emf;
    }
    @Override
    public EntityManager provide() {
        final EntityManager em = emf.createEntityManager();
        // 直接执行会话变量设置，无需事务
        em.createNativeQuery("SET SESSION wsrep_sync_wait = 1").executeUpdate();
        return em;
    }
    @Override
    public void dispose(EntityManager instance) {
        if (instance.isOpen()) {
            instance.close();
        }
    }
}

修改后虽然去掉了冗余的事务，但还是需要额外维护一个工厂包装类，代码量和后续维护成本相对较高，属于次优选择。

选项3：JDBC URL参数（最优推荐） #

这是最简便高效的方案，MySQL/MariaDB的JDBC原生支持通过sessionVariables参数直接在URL中设置会话变量，完全无需额外代码。

你的示例代码：

String jdbcUrl = "jdbc:mysql://db.example.test:3306/"+ JDBC_DB +"?sessionVariables=wsrep_sync_wait=1";
Properties p = new Properties();
p.put("javax.persistence.jdbc.url", jdbcUrl);
p.put("javax.persistence.jdbc.user", JDBC_USER);
p.put("javax.persistence.jdbc.password", JDBC_PASSWORD);
EntityManagerFactory emf = Persistence.createEntityManagerFactory("myPU", p);
EntityManager entityManager = emf.createEntityManager();

针对你担心的“无法捕获异常、不支持该变量的系统部署问题”，可以通过两个方式优化：

1. 兼容非Galera环境：通过配置文件（比如application.properties）区分部署环境，仅在Galera集群环境下添加sessionVariables=wsrep_sync_wait=1参数，非Galera环境则不配置，避免无效参数。
2. 处理驱动警告：MariaDB JDBC驱动遇到不支持的会话变量时，默认只会抛出SQLWarning而非致命异常，你可以添加驱动参数warnOnInvalidSessionVariable=false关闭警告，或者在代码中捕获并处理警告信息。

为什么这是最优方案？ #

• 配置层面解决问题，无需额外代码，维护成本极低
• 驱动原生支持，保证每个新连接都会自动设置变量，不会遗漏
• 没有额外的事务或查询开销，性能最优

总结 #

优先选择选项3（JDBC URL参数），如果需要兼容多环境，通过配置文件区分即可；如果必须要动态检测变量是否存在再设置，可以基于选项2的工厂类，在设置前先执行检测SQL，兼顾兼容性和功能需求。

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