使用r2dbc-postgresql的事务

Question

我正在尝试生成一个在一个事务中同时执行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);
}

但结果是命令一个接一个地运行，所以我使用规则order = 1结束了这两个规则。

我做错了什么，我如何解决这个问题？

Answer 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)。