1

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

如果我在 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，让它为你自动生成查询。

4

1 回答 1

2

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

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);

也可以看看：

于 2019-10-02T22:55:17.393 回答