Spring Data读取Blob时Callable语句提前关闭的解决办法

问题根源 #

Spring Data JPA的@Procedure注解在返回Blob对象后，会立即关闭底层的CallableStatement。而SQL Server JDBC驱动的Blob实例依赖于打开的语句上下文，后续尝试读取Blob时就会触发"语句已关闭"的SQLException。

方案1：自定义Repository实现（推荐） #

通过自定义Repository实现类，在存储过程调用的同一个上下文内完成Blob到byte[]的转换，避免语句关闭后读取Blob的问题。

1. 修改Repository接口
   将返回类型从Blob改为byte[]：

public interface CarRepository extends Repository<Car, Long> {
    byte[] getReportData(String carTypes, LocalDate tradeDate);
}

2. 编写自定义实现类
   创建名为CarRepositoryImpl的实现类（Spring Data会自动识别接口名+Impl的命名规则），使用EntityManager直接调用存储过程并转换Blob：

@Repository
public class CarRepositoryImpl implements CarRepository {
    private final EntityManager entityManager;

    public CarRepositoryImpl(EntityManager entityManager) {
        this.entityManager = entityManager;
    }

    @Override
    public byte[] getReportData(String carTypes, LocalDate tradeDate) {
        StoredProcedureQuery query = entityManager.createStoredProcedureQuery("dbo.pValuation");
        
        // 注册存储过程参数
        query.registerStoredProcedureParameter("carTypes", String.class, ParameterMode.IN);
        query.registerStoredProcedureParameter("tradeDate", LocalDate.class, ParameterMode.IN);
        query.registerStoredProcedureParameter("reportData", Blob.class, ParameterMode.OUT);
        
        // 设置输入参数
        query.setParameter("carTypes", carTypes);
        query.setParameter("tradeDate", tradeDate);
        
        // 执行存储过程
        query.execute();
        
        // 读取输出参数并转换为byte[]
        Blob blob = (Blob) query.getOutputParameterValue("reportData");
        try {
            return blob.getBytes(1, (int) blob.length());
        } catch (SQLException e) {
            throw new RuntimeException("转换Blob到byte[]失败", e);
        } finally {
            // 释放Blob资源
            if (blob != null) {
                try {
                    blob.free();
                } catch (SQLException e) {
                    // 可添加日志记录
                }
            }
        }
    }
}

3. 修改服务层代码
   直接使用返回的byte[]即可，无需再处理Blob转换：

public Set<CarDto> getValuations(LocalDate date) {
    byte[] reportData = carRepository.getReportData("sedan,truck", date);
    return carRepository.getCarValuations(reportData);
}

方案2：调整JDBC驱动连接参数 #

通过设置SQL Server JDBC驱动的responseBuffering=full参数，让驱动将所有响应数据（包括Blob内容）缓冲到客户端内存，即使语句关闭后也能读取Blob。

在数据库连接URL中添加该参数：

spring:
  datasource:
    url: jdbc:sqlserver://your-db-host:1433;databaseName=your-db;responseBuffering=full
    username: your-username
    password: your-password
    driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver

注意：此方案会将Blob数据全部加载到内存，若返回的Blob体积过大，可能导致内存占用过高，需根据实际场景评估使用。

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