Ignite查询报错java.sql.SQLException: Transaction is already completed求助

可能原因 #

1. 连接复用与事务状态冲突：connectionManager.openConnection()如果复用了已参与过事务且未正确重置状态的连接，再次执行查询时原事务已完成，就会抛出该异常。Ignite JDBC Thin连接在事务结束后（提交/回滚），若未显式重置，后续操作会触发报错。
2. 隐式事务自动提交异常：Ignite默认模式下，查询可能触发隐式事务，若连接自动提交设置不当，或结果集未处理完成前连接被提前关闭，会导致事务提前终止。
3. 结果集处理耗时过长：databaseToDomain(rs)如果包含大量耗时操作（如复杂数据转换、外部调用），超出Ignite事务超时时间后，服务器端会自动结束事务，客户端再操作连接就会报错。
4. 资源释放逻辑不严谨：connectionManager.close(ps)或close(rs)的实现可能未正确释放资源，导致连接处于无效事务状态。

修复方案 #

1. 确保连接状态干净 #

修改load方法，获取连接后显式设置自动提交，避免隐式事务残留：

try {
    Connection conn = this.connectionManager.openConnection();
    // 显式开启自动提交，清除连接的事务残留状态
    conn.setAutoCommit(true);
    ps = conn.prepareStatement(sql);
    ps.setTimestamp(1, new Timestamp(timeOffset.getTime()));
    ps.setInt(2, partition);
    ps.setInt(3, ProcessStatus.PENDING.label());

    rs = ps.executeQuery();
    entities = this.databaseToDomain(rs);
}

如果使用连接池，必须在获取连接后重置事务状态，确保连接未绑定任何未完成的事务。

2. 修正资源释放逻辑 #

确保finally块中正确释放所有资源，若使用非池化连接需关闭连接：

finally {
    if (rs != null) {
        try { rs.close(); } catch (Exception ignore) {}
    }
    if (ps != null) {
        try { ps.close(); } catch (Exception ignore) {}
    }
    // 非连接池场景必须关闭连接
    if (conn != null) {
        try { conn.close(); } catch (Exception ignore) {}
    }
}

连接池场景下，无需关闭连接，但要保证归还到池中的连接已重置事务状态（如执行setAutoCommit(true)）。

3. 优化结果集处理逻辑 #

检查databaseToDomain(rs)实现，缩短结果集持有时间：

• 快速遍历结果集转换为实体，避免在遍历过程中执行阻塞操作
• 若转换逻辑复杂，可拆分步骤，先读取所有数据到内存再处理，尽快关闭结果集和Statement

4. 显式控制事务边界（若涉及更新操作） #

如果查询后需要执行更新，显式管理事务避免隐式事务的不确定性：

try {
    Connection conn = this.connectionManager.openConnection();
    conn.setAutoCommit(false);
    
    // 执行查询
    ps = conn.prepareStatement(sql);
    // ... 参数设置
    rs = ps.executeQuery();
    entities = this.databaseToDomain(rs);
    
    // 执行后续更新操作
    // ...
    
    conn.commit();
} catch (Exception e) {
    if (conn != null) {
        try { conn.rollback(); } catch (Exception ignore) {}
    }
    // 异常捕获逻辑
    Sentry.captureException(e);
    log.error(">>>> Load enforcers error: "+ e);
    throw e;
}

5. 调整Ignite事务超时配置 #

在Ignite配置中增加事务超时时间，避免因处理缓慢导致事务被自动关闭：

<bean class="org.apache.ignite.configuration.IgniteConfiguration">
    <property name="transactionConfiguration">
        <bean class="org.apache.ignite.configuration.TransactionConfiguration">
            <property name="defaultTxTimeout" value="30000"/> <!-- 30秒，根据实际场景调整 -->
        </bean>
    </property>
</bean>

验证建议 #

• 优先测试连接自动提交设置，确认是否解决异常
• 检查ConnectionManager的连接复用逻辑，确保连接状态重置
• 监控查询与结果转换的耗时，确认是否存在超时情况

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