如何在Spring JPA中获取PostgreSQL返回的游标集数据？

刚好之前处理过PostgreSQL返回多个REF CURSOR的场景，在Spring JPA里确实需要绕开一些默认的实体映射逻辑，下面给你两个实用的思路和具体实现步骤：

因为Spring JPA底层依赖JDBC，直接用JdbcTemplate处理游标会更灵活，毕竟游标属于JDBC层面的资源。步骤如下：

1. 确保连接配置支持游标：在你的PostgreSQL连接URL里加上allowResultSetAccessToExternalResources=true（新版本PostgreSQL驱动可能默认支持，但加上更稳妥）。
2. 编写JDBC调用逻辑：通过JdbcTemplate获取连接，执行查询后逐个提取游标并读取数据。

示例代码：

@Autowired
private JdbcTemplate jdbcTemplate;

@Transactional // 必须在事务内操作游标，否则会提前关闭
public Map<String, List<?>> fetchAllCursorData() {
    String sql = "select * from ga_rpt_movement(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) as result";
    
    Map<String, List<?>> resultMap = new HashMap<>();
    
    jdbcTemplate.execute(sql, (Connection conn) -> {
        try (PreparedStatement stmt = conn.prepareStatement(sql)) {
            // 按顺序设置所有输入参数
            stmt.setString(1, "CODE");
            stmt.setString(2, "2018-5-10");
            stmt.setString(3, "2018-5-10");
            stmt.setString(4, "2018-5-10");
            stmt.setString(5, "C");
            stmt.setString(6, "STAT1");
            stmt.setString(7, "2018-5-10");
            stmt.setString(8, "2018-5-10");
            stmt.setString(9, "12344");
            stmt.setString(10, "A");
            stmt.setString(11, "T");
            stmt.setString(12, "34");
            stmt.setInt(13, 25);
            stmt.setInt(14, 50);
            stmt.setString(15, "M");
            stmt.setString(16, "1");
            stmt.setString(17, "firstname");
            stmt.setInt(18, 0);
            stmt.setInt(19, 10);
            
            // 执行查询，获取包含游标的ResultSet
            try (ResultSet rs = stmt.executeQuery()) {
                // 你已知游标名称，可以直接按名称抓取数据
                // 处理p_cr_personstatus游标
                try (ResultSet cursorRs = conn.createStatement().executeQuery("FETCH ALL IN \"p_cr_personstatus\"")) {
                    List<PersonStatus> personStatusList = new ArrayList<>();
                    while (cursorRs.next()) {
                        // 映射字段到实体类，示例字段请替换成实际字段
                        PersonStatus status = new PersonStatus();
                        status.setId(cursorRs.getLong("id"));
                        status.setName(cursorRs.getString("status_name"));
                        personStatusList.add(status);
                    }
                    resultMap.put("personstatus", personStatusList);
                }
                
                // 同理处理其他三个游标
                try (ResultSet cursorRs = conn.createStatement().executeQuery("FETCH ALL IN \"p_cr_identification\"")) {
                    List<Identification> identificationList = new ArrayList<>();
                    // 字段映射逻辑...
                    resultMap.put("identification", identificationList);
                }
                
                try (ResultSet cursorRs = conn.createStatement().executeQuery("FETCH ALL IN \"p_cr_phone\"")) {
                    List<Phone> phoneList = new ArrayList<>();
                    // 字段映射逻辑...
                    resultMap.put("phone", phoneList);
                }
                
                try (ResultSet cursorRs = conn.createStatement().executeQuery("FETCH ALL IN \"p_cr_count\"")) {
                    List<Count> countList = new ArrayList<>();
                    // 字段映射逻辑...
                    resultMap.put("count", countList);
                }
            }
        } catch (SQLException e) {
            throw new RuntimeException("处理游标数据失败", e);
        }
        return null;
    });
    
    return resultMap;
}

如果想尽量贴合JPA的使用习惯，可以用StoredProcedureQuery来注册输入输出参数，不过需要提前定义结果集映射。

1. 定义实体类的结果集映射：在实体类上用@SqlResultSetMapping标注游标返回字段和实体的映射关系，比如：

@Entity
@SqlResultSetMapping(
    name = "PersonStatusMapping",
    classes = @ConstructorResult(
        targetClass = PersonStatus.class,
        columns = {
            @ColumnResult(name = "id", type = Long.class),
            @ColumnResult(name = "status_name", type = String.class)
            // 替换成游标实际返回的字段
        }
    )
)
public class PersonStatus {
    // 实体类属性和构造函数（要和@ConstructorResult的字段顺序匹配）
    private Long id;
    private String name;
    
    public PersonStatus(Long id, String name) {
        this.id = id;
        this.name = name;
    }
    
    // getter、setter...
}

2. 编写JPA调用逻辑：通过EntityManager创建StoredProcedureQuery，注册参数并执行：

@PersistenceContext
private EntityManager entityManager;

@Transactional
public void callProcedureAndFetchCursors() {
    StoredProcedureQuery query = entityManager.createStoredProcedureQuery("ga_rpt_movement");
    
    // 注册并设置所有输入参数（顺序要和函数定义一致）
    query.registerStoredProcedureParameter(1, String.class, ParameterMode.IN);
    query.setParameter(1, "CODE");
    query.registerStoredProcedureParameter(2, String.class, ParameterMode.IN);
    query.setParameter(2, "2018-5-10");
    // ... 依次注册并设置剩下的17个输入参数
    
    // 注册输出游标参数，类型为REF_CURSOR
    query.registerStoredProcedureParameter("p_cr_personstatus", void.class, ParameterMode.REF_CURSOR);
    query.registerStoredProcedureParameter("p_cr_identification", void.class, ParameterMode.REF_CURSOR);
    query.registerStoredProcedureParameter("p_cr_phone", void.class, ParameterMode.REF_CURSOR);
    query.registerStoredProcedureParameter("p_cr_count", void.class, ParameterMode.REF_CURSOR);
    
    // 执行存储过程
    query.execute();
    
    // 获取每个游标对应的结果列表（需要指定之前定义的映射名称）
    List<PersonStatus> personStatusList = query.getResultList("p_cr_personstatus");
    List<Identification> identificationList = query.getResultList("p_cr_identification");
    List<Phone> phoneList = query.getResultList("p_cr_phone");
    List<Count> countList = query.getResultList("p_cr_count");
    
    // 后续业务逻辑处理...
}

• 事务必须开启：游标只能在活跃的事务中访问，所以一定要给方法加上@Transactional注解，否则游标会被提前关闭。
• 驱动版本：确保使用的PostgreSQL JDBC驱动版本在42.2及以上，旧版本对REF_CURSOR的支持可能有问题。
• 资源清理：所有ResultSet、Statement都要用try-with-resources包裹，避免数据库资源泄漏。

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