如何使用带有叛变 API 的夸库斯反应式 mysql 客户端的交易在 mysql 中插入和获取最后插入的 id

Question

我将如何创建事务，插入行，提交事务并获取最后插入的id。所以该方法应该返回一个Uni<Integer>。我是叛变 API 的新手，我以前使用过vertx.io链接未来的处理程序机制，因此重新调整自己以使用 muttiny api 有点困难。我已经检查了文档，并认为类似于以下代码片段的内容应该有效，但是我对如何使其工作并从最后一个查询返回Uni<Integer>而不是从tx.commit()中返回Uni<Void>感到困惑

return this.client.begin()
.flatMap(tx -> tx
.preparedQuery("INSERT INTO person (firstname,lastname) VALUES ($1,$2)")
.execute(Tuple.of(person.getFirstName(),person.getLastName()))
.onItem().produceUni(id-> tx.query("SELECT LAST_INSERT_ID()"))
.onItem().produceUni(res -> tx.commit())
.onFailure().recoverWithUni(ex-> tx.rollback())
);

Answer 1

试试这个：

return client.begin().onItem().produceUni(tx -> tx
.preparedQuery("INSERT INTO person (firstname,lastname) VALUES ($1,$2)").execute(Tuple.of(person.getFirstName(),person.getLastName()))
.onItem().produceUni(id -> tx.query("SELECT LAST_INSERT_ID()").execute())
.onItem().apply(rows -> rows.iterator().next().getInteger(0))
.onItem().produceUni(item -> tx.commit().on().item().produceUni(v -> Uni.createFrom().item(item)))
.on().failure().recoverWithUni(throwable -> {
return tx.rollback().on().failure().recoverWithItem((Void) null)
.on().item().produceUni(v -> Uni.createFrom().failure(throwable));
})
);

SqlClientHelper将在未来的版本中进入Quarkus(希望是1.6(。您将能够简化为：

return SqlClientHelper.inTransactionUni(client, tx -> tx
.preparedQuery("INSERT INTO person (firstname,lastname) VALUES ($1,$2)").execute(Tuple.of(person.getFirstName(),person.getLastName()))
.onItem().produceUni(id -> tx.query("SELECT LAST_INSERT_ID()").execute())
.onItem().apply(rows -> rows.iterator().next().getInteger(0))
);