Spring Boot R2DBC调用PostgreSQL自定义函数报SQL语法错误求助

1. 修正参数类型不匹配问题 #

Repository方法传入的Long accountId对应PostgreSQL的bigint类型，但你的自定义函数参数定义为integer，类型不兼容会触发语法解析错误：

• 方案一：修改PostgreSQL函数的参数类型为bigint

create function get_valid_virtual_relations(accountid bigint)
    returns TABLE(authority_id integer, expire_at timestamp without time zone)
    language plpgsql
as
$$
BEGIN
    RETURN QUERY SELECT ...; -- 保留原有查询逻辑
END;
$$;

• 方案二：若业务允许accountId在32位整数范围内，修改Repository方法参数为Integer

Flux<VirtualAuthority> getVirtualAuthority(@NonNull Integer accountId);

2. 补全@Query中的字段映射 #

@Query语句中的SELECT ...不能省略，必须明确写出函数返回的所有字段，且要与VirtualAuthority实体的属性对应（字段名不一致时需加别名）：

@Query("SELECT authority_id AS authorityId, expire_at FROM get_valid_virtual_relations(:accountId)")
Flux<VirtualAuthority> getVirtualAuthority(@NonNull Long accountId);

3. 验证函数本身的可用性 #

直接在PostgreSQL客户端执行SELECT * FROM get_valid_virtual_relations(1)，确认函数能正常返回数据，排除函数自身的语法或逻辑错误。

4. 确保参数绑定正确 #

若编译时未保留方法参数名，需用@Param注解显式指定参数名，避免R2DBC无法正确绑定参数：

Flux<VirtualAuthority> getVirtualAuthority(@NonNull @Param("accountId") Long accountId);

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