JOOQ使用PostgreSQL在一个连接中进行多个选择计数

Question

我有一个表订阅，我想在一个连接中用JOOQ编写多个selectCount，并用不同的谓词连接到数据库。为此，我创建了一个查询列表：

List<Query> countQueries = channels.stream().map(c ->
                selectCount().from(SUBSCRIPTION)
                        .innerJoin(SENDER).on(SENDER.ID.equal(SUBSCRIPTION.SENDER_ID))
                        .innerJoin(CHANNEL).on(CHANNEL.ID.equal(SUBSCRIPTION.CHANNEL_ID))
                        .where(SENDER.CODE.equal(senderCode))
                        .and(CHANNEL.CODE.equal(c))
        ).collect(toList());

最后，我使用批处理启动了这个查询列表：

using(configuration).batch(countQueries).execute();

我原本希望在执行的返回值中包含上述查询的结果，但我得到了一个整数数组，其中填充了0个值。

这是使用JOOQ运行多个selectCount的正确方法吗？执行方法返回的整数数组的含义是什么？

我在JOOQ博客中查看了这个链接，讨论了“如何在一个查询中计算多个聚合函数”，但它只是关于SQL查询，没有JOOQ方言。

Answer 1

我原本希望在execute的返回值中包含上述查询的结果，但我得到了一个整数数组，其中填充了0个值。

批（）API只能用于DML查询（INSERT、UPDATE、DELETE），就像使用本机JDBC一样。我的意思是，您可以将查询作为批处理运行，但不能以这种方式获取结果。

我在JOOQ博客中查看了这个链接，讨论了“如何在一个查询中计算多个聚合函数”，但它只是关于SQL查询，没有JOOQ方言。

简单的SQL查询几乎总是从字面上翻译成jOOQ，因此您也可以将本文中的技术应用到您的案例中。事实上，你应该！运行这么多查询绝对不是一个好主意。

那么，让我们看看如何将这个简单的SQL示例从链接转换到您的案例：

Record record =
ctx.select(
      channels.stream()
              .map(c -> count().filterWhere(CHANNEL.CODE.equal(c)).as(c))
              .collect(toList())
   )
   .from(SUBSCRIPTION)
   .innerJoin(SENDER).on(SENDER.ID.equal(SUBSCRIPTION.SENDER_ID))
   .innerJoin(CHANNEL).on(CHANNEL.ID.equal(SUBSCRIPTION.CHANNEL_ID))
   .where(SENDER.CODE.equal(senderCode))
   .and(CHANNEL.CODE.in(channels)) // Not strictly necessary, but might speed up things
   .fetch();

这将产生一条包含所有计数值的记录。

一如既往，这是假设以下静态导入

import static org.jooq.impl.DSL.*;

当然，您也可以在特定情况下使用经典的分组方式。这可能会更快一些：

Result<?> result =
ctx.select(CHANNEL.CODE, count())
   .from(SUBSCRIPTION)
   .innerJoin(SENDER).on(SENDER.ID.equal(SUBSCRIPTION.SENDER_ID))
   .innerJoin(CHANNEL).on(CHANNEL.ID.equal(SUBSCRIPTION.CHANNEL_ID))
   .where(SENDER.CODE.equal(senderCode))
   .and(CHANNEL.CODE.in(channels)) // This time, you need to filter
   .groupBy(CHANNEL.CODE)
   .fetchOne();

现在，这将生成一个表，每个代码有一个计数值。或者，将其提取到地图中

Map<String, Integer> map =
ctx.select(CHANNEL.CODE, count())
   .from(SUBSCRIPTION)
   .innerJoin(SENDER).on(SENDER.ID.equal(SUBSCRIPTION.SENDER_ID))
   .innerJoin(CHANNEL).on(CHANNEL.ID.equal(SUBSCRIPTION.CHANNEL_ID))
   .where(SENDER.CODE.equal(senderCode))
   .and(CHANNEL.CODE.in(channels))
   .groupBy(CHANNEL.CODE)
   .fetchMap(CHANNEL.CODE, count());