トランザクション

API

1つのトランザクション内で複数のステートメントを実行する場合は、transaction 関数を使用します。

val players = listOf<Player>()
database.playerQueries.transaction {
  players.forEach { player ->
    database.playerQueries.insert(
      player_number = player.number,
      full_name = player.fullName
    )
  }
}

トランザクションから値を返すには、transactionWithResult 関数を使用します。

val players: List<Player> = database.playerQueries.transactionWithResult {
  database.playerQueries.selectAll().executeAsList()
}

ロールバック

トランザクション内で例外が発生すると、そのトランザクションはロールバックされます。トランザクション内の任意の場所で手動でロールバックすることも可能ですが、トランザクションが値を返す場合は、そのトランザクションが戻り値として返す値を指定する必要があります。

database.playerQueries.transaction {
  players.forEach { player ->
    if (player.number == 0) rollback()
    database.playerQueries.insert(
      player_number = player.number,
      full_name = player.fullName
    )
  }
}

val numberInserted: Int = database.playerQueries.transactionWithResult {
  players.forEach { player ->
    if (player.number == 0) rollback(0)
    database.playerQueries.insert(
      player_number = player.number,
      full_name = player.fullName
    )
  }
  players.size
}

コールバック

トランザクションが完了またはロールバックした後に実行されるコールバックを登録できます。

database.playerQueries.transaction {
  afterRollback { log("No players were inserted.") }
  afterCommit { log("${players.size} players were inserted.") }

  players.forEach { player ->
    database.playerQueries.insert(
      player_number = player.number,
      full_name = player.fullName
    )
  }
}