Spring Data R2DBC - 在反应式存储库中构建自定义 postgresql 查询

Question

我有一个表，其中包含具有字符串 id、字符串 jobId 和字符串状态的实体。给定一个 jobId 和一个 ID 列表，我想查询该表并返回数据库中不存在的 ID 的 Flux。

如果我在 pgadmin 中手动执行以下查询，我可以成功地做到这一点：

SELECT a.id FROM (VALUES ('20191001_182447_1038'),('abc'),('fdjk')) AS a(id) LEFT JOIN (SELECT * FROM items WHERE job_id = '10a7a04a-aa67-499a-83eb-0cd3625fe27a') b ON a.id = b.id WHERE b.id IS null

返回的响应仅包含不存在的 id，“abc”和“fdjk”。

在我的 spring 数据仓库中，我定义了以下方法：

    @Query("SELECT a.id FROM (VALUES (:ids)) AS a(id) LEFT JOIN (SELECT * FROM items WHERE job_id = :jobId) b ON a.id = b.id WHERE b.id IS null")
    Flux<ItemId> getNotContains(@Param("jobId") String jobId, @Param("ids") Collection<String> ids);

问题是，当我运行代码时，查询被扩展为：

SELECT a.id FROM (VALUES ($1, $2, $3)) AS a(id) LEFT JOIN (SELECT * FROM items WHERE job_id = $251) b ON a.id = b.id WHERE b.id IS null]

这总是返回一个值，因为这些值被分组到一组括号中，而不是将我集合中的每个元素都包装在括号中。只是好奇是否有办法妥善处理。

编辑 实体类是：

@Data
@Table("items")
public class Item implements Persistable {

    @Id
    private String id;
    private String jobId;
    private String customerId;
    private Date queuedDate;
    private Date lastUpdated;
    private String destination;
    private String type;
    private Status status;
}

另外，我的仓库是：

public interface ItemRepository extends R2dbcRepository<Item, String>

R2dbcRepository 目前不支持更成熟的 spring 数据仓库的神奇魔力，所以你不能像 findByJobId 那样让它为你自动生成查询。

Answer 1

您可以通过将参数包装到 Object[] 中来强制使用括号，以将参数呈现为表达式列表。

interface MyRepo {
    @Query(…)
    Flux<ItemId> getNotContains(@Param("jobId") String jobId, @Param("ids") Collection<Object[]> ids);
}

MyRepo myRepo = …;
Collection<Object[]> ids = Arrays.asList(new Object[]{"1"}, new Object[]{"2"});

myRepo.getNotContains("foo", ids);

另见：

• NamedParameterUtils Javadoc