JPA结合HikariCP与PreparedStatement批量插入后同事务查询难题

核心问题在于：你用HikariCP直接获取JDBC连接执行的批量插入绕过了JPA的EntityManager上下文，且如果JDBC连接与JPA使用的连接不是同一个，在默认事务隔离级别（如REPEATABLE READ）下，JPA查询无法读取到同一事务内未提交的JDBC插入数据；即使是同一连接，JPA的一级缓存也会导致查询看不到新插入的数据。以下是不牺牲性能的优化方案：

方案1：复用JPA事务的数据库连接执行JDBC批量插入 #

直接从当前JPA EntityManager获取绑定到事务的JDBC连接，用该连接创建PreparedStatement执行批量插入。这样JDBC操作与JPA查询共享同一连接，同一事务内的操作完全可见，同时保留JDBC批量插入的高性能。

代码示例 #

@Transactional
public void batchInsertAndQuery() throws SQLException {
    // 从EntityManager获取当前事务的JDBC连接
    Connection connection = entityManager.unwrap(Connection.class);
    
    String insertSql = "INSERT INTO your_table (col1, col2) VALUES (?, ?)";
    try (PreparedStatement pstmt = connection.prepareStatement(insertSql)) {
        // 批量插入10万条数据
        for (int i = 0; i < 100000; i++) {
            pstmt.setString(1, "value_" + i);
            pstmt.setInt(2, i);
            pstmt.addBatch();
            
            // 每1000条执行一次批量提交，避免内存占用过高
            if (i % 1000 == 0 && i != 0) {
                pstmt.executeBatch();
                pstmt.clearBatch();
            }
        }
        // 执行剩余批次
        pstmt.executeBatch();
    }
    
    // 执行JPA联表查询，此时能读取到刚插入的数据
    String jpql = "SELECT t FROM YourEntity t JOIN t.relatedEntity r WHERE r.id = ?";
    List<YourEntity> result = entityManager.createQuery(jpql, YourEntity.class)
            .setParameter(1, 1L)
            .getResultList();
}

优势 #

• 完全保留JDBC批量插入的高性能，无需修改原有批量逻辑
• 同一连接下事务内操作天然可见，无需额外缓存刷新或隔离级别调整

方案2：改用JPA原生批量插入API #

如果可以替换手动JDBC代码，直接使用JPA的批量插入能力，通过配置批量参数保证性能，同时避免上下文不一致问题。插入后调用flush()将JPA缓存同步到数据库，即可在事务内查询到数据。

配置优化（以Hibernate为例） #

在persistence.xml或application.properties中添加：

# 设置批量插入大小
hibernate.jdbc.batch_size=1000
# 禁用JDBC自动提交（事务内已自动处理）
hibernate.connection.autocommit=false
# 开启批量插入优化
hibernate.order_inserts=true
hibernate.order_updates=true

代码示例 #

@Transactional
public void jpaBatchInsertAndQuery() {
    int batchSize = 1000;
    for (int i = 0; i < 100000; i++) {
        YourEntity entity = new YourEntity();
        entity.setCol1("value_" + i);
        entity.setCol2(i);
        entityManager.persist(entity);
        
        // 每batchSize条刷新一次，避免一级缓存溢出
        if (i % batchSize == 0 && i != 0) {
            entityManager.flush();
            entityManager.clear(); // 清除一级缓存，释放内存
        }
    }
    // 刷新剩余数据
    entityManager.flush();
    
    // 执行联表查询，数据已可见
    List<YourEntity> result = entityManager.createQuery(
            "SELECT t FROM YourEntity t JOIN t.relatedEntity r WHERE r.id = :rid",
            YourEntity.class)
            .setParameter("rid", 1L)
            .getResultList();
}

优势 #

• 完全基于JPA规范，代码更简洁，避免JDBC与JPA的上下文冲突
• 配置优化后性能与手动JDBC批量插入相当，且JPA会自动处理连接与缓存同步

方案3：调整EntityManager缓存与数据库隔离级别（不推荐） #

如果必须使用独立的JDBC连接，可通过以下方式解决，但会带来性能或一致性风险：

• 插入后调用entityManager.flush() + entityManager.clear()，清除JPA一级缓存，强制从数据库读取数据
• 将事务隔离级别调整为READ_UNCOMMITTED，允许读取未提交数据

劣势 #

• 隔离级别调整会降低数据一致性，增加脏读风险
• 频繁flush/clear会影响JPA缓存性能，不适用于大规模数据操作

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