在R2DB中，处理表中的所有行是阻塞还是锁定？

Question

以下构造是否以任何可能的方式阻塞或锁定？这是使用R2DB的正确方式吗？否则，如何以被动方式处理表中的所有记录？

我关心的是在整个流量消耗之前数据库连接、表和Reactor线程发生了什么。如果我正在阻塞线程，或者我保持表锁定，或者数据库连接被阻塞。

目的是写一个表中所有行的批处理。对于每一行，我都要执行一个活动，该活动包括从外部web服务获取数据，并最终在同一个表中覆盖原始发票。

假设单行处理方法(在本例中为< code > recalculate invoice())是完全反应式的。

import org.springframework.r2dbc.core.DatabaseClient;
import org.springframework.stereotype.Repository;
import reactor.core.publisher.Mono;
import lombok.RequiredArgsConstructor;

@Repository
@RequiredArgsConstructor
public class DbConnector {
    private final DatabaseClient databaseClient;

    public Mono<Void> batchProcessing() {
        return databaseClient
                .sql("SELECT * FROM invoice")
                .fetch()
                .all()
                .delayElements(Duration.ofSeconds(10)) 
                // a costly operation with the data ...
                .then()
        ;
    }
}

Answer 1

您的代码段是完全被动的。它不会阻塞任何线程或数据库。这就是使用 R2DBC 的整个想法。

在幕后，R2DBC驱动程序将执行类似这样的操作:

Flux.usingWhen(connectionFactory.create(),
        connection -> 
            Flux.from(connection.createStatement("SELECT * FROM invoice").execute()),
        Connection::close);

一旦管道完成或出现错误，数据库连接将立即关闭。

您可以在此处阅读有关如何对此类查询应用背压的信息。