批量插入支持

Question

我尝试使用r2dbc执行批处理插入。

我已经看到，使用spring boot中的DatabaseClient，这还不可能实现。我尝试使用R2DBC SPI语句和and方法来实现这一点，如下所示：

java prettyprint-override">Mono.from(this.factory.create())
            .map(connection -> connection.createStatement(insertSQL))
            .map(statement -> {
                lines.forEach(line -> {
                    statement
                        .add()
                        .bind(0, line.getId())
                        ;
                });
                return statement;
            })
            .flatMap(statement -> Mono.from(statement.execute()));

我在日志上看到完成了两个插入请求。

2019-12-18 16:27:36.092 DEBUG [] 4133 --- [tor-tcp-epoll-1] io.r2dbc.postgresql.QUERY                : Executing query: insert into table(id) values ($1)
2019-12-18 16:27:36.116 DEBUG [] 4133 --- [tor-tcp-epoll-1] i.r.p.client.ReactorNettyClient          : Request:  Bind{}
2019-12-18 16:27:36.126 DEBUG [] 4133 --- [tor-tcp-epoll-1] io.r2dbc.postgresql.QUERY                : Executing query: insert into table(id) values ($1)
2019-12-18 16:27:36.130 DEBUG [] 4133 --- [tor-tcp-epoll-1] i.r.p.client.ReactorNettyClient          : Request:  Bind{}

添加是执行批更新还是只运行两个请求？

谢谢

Answer 1

有点晚，但我想总比没有好。我会说您的代码发出了两个单独的请求。使用数据库客户端，我想自从提出这个问题以来，它已经成熟了：

    Mono.from(connectionFactory.create())
        .map(connection -> connection.createBatch())
        .map(batch -> {
            batch.add("delete from table1");
            batch.add("delete from table2");
            batch.add("delete from table3");
            return batch.execute();
        })
        // Etc

运行上述操作时，将记录以下内容：
查询：[“从表1中删除”、“从表2中删除”、“从表3中删除”]绑定：[]