如何在Spring中将JdbcTemplate转换为Flux？

Question

我有一个返回列表的现有服务

我如何将下面的示例转换为通量，这样我的结果就可以流式传输，而不必在内存中聚集所有项目？

@RestController
public class BookingInfoServlet {
    @Autowired
    private JdbcTemplate jdbc;

    @GetMapping(value = "/export", produces = APPLICATION_JSON_VALUE)
    public List<Item> export(String productType) {
        List<Item> list = new ArrayList<>();

        for (int i = 0; i < jdbc.count(); i++) {
            List<String> refIds = jdbc.queryForList("SELECT ref_id FROM products where type = ? LIMIT 1000 OFFSET = ?", String.class, productType, i);
            for (String id : refIds) {
                Map map = jdbc.queryForMap("SELECT <anything> ... where some_id = ?, id);
                Item item = new Item();
                item.setName(map.get("name"));
                item.setCode(map.getCode("code"));
                item.set...
                list.add(item);
            }

            //TODO how to convert to Flux here and already send the chunks back into the stream?
        }

        return list; //TODO how to convert to Flux?
    }
}

第一个问题：这里我首先将第一个查询的所有结果提取到内存中，然后在内存中迭代并形成我所有的Item，然后返回整个列表。

因此我试图返回Flux

由于没有asyncmysqljava驱动程序，我可能必须将数据库查找分页为1000个块，然后准备1000个项目并已经将它们流式传输回客户端。然后获取接下来的1000个项目。但是我如何直接将它们放入流中？




Answer 1

  public Flux<Item> export(String productType) {
    int pageSize = 1000;
    int count = jdbc.count();
    return Flux.range(0, count / pageSize) //page numbers
        .flatMapIterable(pageNumber ->
            jdbc.queryForList("SELECT ref_id FROM products where type = ? LIMIT ? OFFSET = ?",
                String.class,
                productType,
                pageSize,
                pageNumber * pageSize))
        .map(id -> {
          Map map = jdbc.queryForMap("SELECT <anything> ... where some_id = ?", id);
          Item item = new Item();
          //
          //
          return item;
        });
  }