我目前正在 Kotlin 中使用 Arrow.io,我很想在工作项目中使用该库(与 Spring Boot 一起)。我不太清楚如何正确解决的一个问题是事务管理。IO<A>.bracketCase(...)
在我看来,这是完成这项工作的正确工具。这是我目前正在研究的方法:
interface TransactionProvider {
fun startTransaction(): IO<Transaction>
}
interface Transaction {
fun commit(): IO<Unit>
fun rollback(): IO<Unit>
}
fun <A> TransactionProvider.runInTransaction(action: IO<A>): IO<A> =
startTransaction()
.bracketCase(::releaseTransaction) { action }
fun releaseTransaction(t: Transaction, exitCase: ExitCase<Throwable>): IO<Unit> =
when (exitCase) {
is ExitCase.Completed -> t.commit()
else -> t.rollback()
}
可悲的是,它并没有像我期望的那样工作:当在执行期间抛出异常时action
,我希望回滚。但事实并非如此(例如,以下测试失败):
@Test
internal fun `transaction rolls back on failure`() {
val transaction: Transaction =
mock {
on { commit() } doReturn IO.unit
on { rollback() } doReturn IO.unit
}
val transactionProvider: TransactionProvider =
mock{
on { startTransaction() } doReturn IO.just(transaction)
}
val exception = IllegalArgumentException("Here I am!")
val action = IO{ throw exception }
val result: Either<Throwable, Unit> =
transactionProvider
.runInTransaction(action)
.attempt()
.unsafeRunSync()
assertThat(result).isEqualTo(exception.left())
verify(transaction, never()).commit()
verify(transaction, times(1)).rollback()
}
我现在经常玩这个,无论我如何安排我的类型以及我将action
问题放在哪里 - 我永远不会bracketCase
回滚我的交易。我究竟做错了什么?有没有更好的方法来做到这一点?如果可能的话,我更喜欢不使用类型安全的方式unsafeRun
。