使用r2dbc-postgresql的事务

问题描述

我正在尝试在一个事务中生成同时执行2个postgresql命令的代码。 我的DB 2规则中有不同的规则顺序，我想在它们之间切换规则顺序。 我正在使用r2dbc-postgresql（v0.8.4）和spring-data-r2dbc（v1.1.1）。

我已经定义了DatabaseClient和TransactionalOperator并尝试使用该段代码：

public Mono<Void> insertRows() {
    return databaseClient.execute("update rules set rule_order = 2 where rule_order = 1")
            .fetch().rowsUpdated()
            .then(databaseClient.execute("update rules set rule_order = 1 where rule_order = 2")
                .fetch().rowsUpdated())
            .then()
            .as(transactionalOperator::transactional);
}

但是结果是这些命令一个接一个地运行，所以我完成了两个规则顺序为1的规则。

我在做什么错了，我该如何解决？

解决方法

不确定在这里有什么期望。

第一条语句将规则行更新为rule_order=2（update rules set rule_order = 2 where rule_order = 1）。第二个规则将规则更新为rule_order=1（update rules set rule_order = 1 where rule_order = 2）。