我尝试使用r2dbc执行批量插入。
我已经看到从Spring Boot开始使用Databaseclient,这还不可能。
我尝试使用R2DBC SPI Statement
和and
方法来做到这一点,就像这样:
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{}
add
是执行批更新还是仅运行两个请求?
谢谢。