事务管理

事务是许多关系数据库都会提供的一个特性，它保证了一组复杂操作执行结果的强一致性，在一个事务中的操作，要么全部执行成功，要么全部失败。Ktorm 基于 JDBC 对事务提供了方便的支持。

useTransaction 函数

Database 类提供了一个名为 useTransaction 的函数，这个函数以一个闭包 (Transaction) -> T 作为参数。它在事务中执行闭包中的代码，如果执行成功，返回闭包函数的返回值，如果执行失败，则回滚事务。你可以这样调用它：

1
2
3

database.useTransaction { 
    // 在事务中执行一组操作
}

下面是一个使用事务的例子：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

class DummyException : Exception()

try {
    database.useTransaction {
        database.insert(Departments) {
            set(it.name, "administration")
            set(it.location, "Hong Kong")
        }

        assert(database.sequenceOf(Departments).count() == 3)

        throw DummyException()
    }

} catch (e: DummyException) {
    assert(database.sequenceOf(Departments).count() == 2)
}

在执行这段代码之前，Departments 表中已经有 2 条记录。这段代码开启了一个事务，在事务中插入了一条记录，插入成功后，我们断言现在表中的记录数是 3，然后抛出一个异常触发事务回滚，在事务回滚后，我们可以看到，表中的记录数又恢复为 2。这个例子可以清晰地看出事务的执行流程。

注意事项：

• 闭包中抛出的任何异常都会触发事务回滚，无论是 checked 还是 unchecked 异常（实际上，checked 异常是 Java 中才有的概念，Kotlin 中并不存在）。
• useTransaction 函数是可重入的，因此可以嵌套使用，但是内层并没有开启新的事务，而是与外层共享同一个事务。

事务管理器

有时，简单的 useTransaction 方法并不能满足你的需求。你可能希望对事务进行更精细的控制，比如指定事务的隔离级别，或者仅当符合特定条件的异常抛出时才回滚事务。这时，你可以使用 database.transactionManager 获取事务管理器完成你的操作，下面是一个例子：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

val transactionManager = database.transactionManager
val transaction = transactionManager.newTransaction(isolation = TransactionIsolation.READ_COMMITTED)
var throwable: Throwable? = null

try {
    // do something...
} catch (e: Throwable) {
    throwable = e
    throw e
} finally {
    try {
        if (shouldRollback(throwable)) transaction.rollback() else transaction.commit()
    } finally {
        transaction.close()
    }
}

TransactionManager 是一个接口，它可以有多种不同的实现。一般来说，使用 Database.connect 方法创建的 Database 对象默认会使用 JdbcTransactionManager 实现，这是基于原生 JDBC 提供的功能实现的事务管理器。Ktorm 还提供了 SpringManagedTransactionManager，这个实现自身并没有任何事务管理的功能，而是将事务管理委托给了 Spring 框架，具体请参考 Spring 支持的相关文档。