Helidon MP+Oracle 18c ATP高服务模式下ORA-12838错误求助

错误根源 #

Oracle ATP高服务模式（如TP/TPURGENT）默认启用并行事务处理，同一事务内先批量插入再批量删除（或反向操作）时，若涉及同一数据集相关对象，会触发ORA-12838——并行修改后，事务内后续操作试图读取/修改已被并行处理的对象，违反Oracle的并行事务约束。低服务模式因串行执行无此问题。

方案1：拆分事务，将插入/删除分属独立事务 #

容器管理事务下，默认REQUIRED传播特性会复用现有事务，需将插入、删除逻辑抽为独立方法并使用REQUIRES_NEW强制开启新事务，确保每步操作完成后自动提交，避免同一事务内的并行冲突。

代码调整 #

// 主方法：无需自身事务注解，内部调用独立事务方法
public void updateDeviceGroupMapCache(String flow, Map<String, Set<DeviceSummary>> deviceGroupMap, String deviceId) {
    List<DeviceGroupMapCache> insertedEntries = new ArrayList<>();
    List<DeviceGroupMapCache> deletedEntries = new ArrayList<>();

    // 拆分到独立事务执行
    batchInsert(insertedEntries, 1000);
    batchDelete(deletedEntries, 1000);
}

@Transactional(Transactional.TxType.REQUIRES_NEW)
public void batchInsert(List<DeviceGroupMapCache> entries, int batchSize) {
    int count = 0;
    for (DeviceGroupMapCache entry : entries) {
        entityManager.persist(entry);
        count++;
        if (count % batchSize == 0) {
            entityManager.flush();
            entityManager.clear();
        }
    }
    entityManager.flush();
    entityManager.clear();
}

@Transactional(Transactional.TxType.REQUIRES_NEW)
public void batchDelete(List<DeviceGroupMapCache> entries, int batchSize) {
    int count = 0;
    for (DeviceGroupMapCache entry : entries) {
        DeviceGroupMapCache reference = entityManager.getReference(DeviceGroupMapCache.class, entry.getDgmcId());
        entityManager.remove(reference);
        count++;
        if (count % batchSize == 0) {
            entityManager.flush();
            entityManager.clear();
        }
    }
    entityManager.flush();
    entityManager.clear();
}

关键说明 #

• REQUIRES_NEW会挂起当前事务（若存在），开启新事务执行操作，完成后自动提交再恢复原事务，彻底隔离插入/删除操作的事务上下文。
• 必须将批量操作设为公共方法，私有方法无法被容器事务代理拦截，若在同一类中调用，需通过Spring/Helidon的上下文获取自身代理对象，避免直接调用导致事务失效。

方案2：使用JDBC原生批量操作（绕过JPA缓存） #

若拆分事务不可行，直接用JDBC批量操作绕过JPA的实体跟踪和缓存，减少Oracle并行模式下的冲突概率。

代码示例（插入） #

@Transactional(Transactional.TxType.REQUIRED)
public void batchInsertViaJDBC(List<DeviceGroupMapCache> entries) {
    String sql = "INSERT INTO DEVICE_GROUP_MAP_CACHE (DGMC_ID, GROUP_ID, DEVICE_ID) VALUES (?, ?, ?)"; // 替换为实际表字段
    try (Connection conn = entityManager.unwrap(Connection.class)) {
        conn.setAutoCommit(false);
        try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
            int count = 0;
            for (DeviceGroupMapCache entry : entries) {
                pstmt.setString(1, entry.getDgmcId());
                pstmt.setString(2, entry.getGroupId());
                pstmt.setString(3, entry.getDeviceId());
                pstmt.addBatch();
                
                count++;
                if (count % 1000 == 0) {
                    pstmt.executeBatch();
                    conn.commit();
                    pstmt.clearBatch();
                }
            }
            pstmt.executeBatch();
            conn.commit();
        } catch (SQLException e) {
            conn.rollback();
            throw new RuntimeException("批量插入失败", e);
        }
    } catch (SQLException e) {
        throw new RuntimeException("获取数据库连接失败", e);
    }
}

批量删除同理 #

替换SQL为DELETE FROM DEVICE_GROUP_MAP_CACHE WHERE DGMC_ID = ?，设置对应参数即可。

关键说明 #

• 直接操作JDBC绕开JPA实体缓存，减少事务内的状态跟踪，每批次提交一次，避免大事务带来的锁和并行冲突。

方案3：调整Oracle ATP并行参数（备选） #

若业务允许牺牲部分性能，可修改会话级并行策略，关闭自动并行度：

ALTER SESSION SET PARALLEL_DEGREE_POLICY = MANUAL;

可在Helidon数据源初始化时执行该语句，或在代码中通过JDBC执行。此方案会降低高服务模式的性能优势，仅作为最后备选。

额外注意事项 #

• 容器管理事务下，禁止手动调用UserTransaction.commit()，容器会自动处理事务提交/回滚，手动调用会触发thread is already associated with a transaction错误。
• 批量操作时，flush()+clear()需配合使用，避免EntityManager缓存过多实体导致内存溢出，但无法替代事务提交。

内容的提问来源于stack exchange，提问作者chaitanya sagar gurujula