Slick3.x でのTransactionの記述方法につきまして

Question

いつもお世話になっております。

Play Framework 2.5.x とSlick 3.1.x を利用しております。

slickのTransactionの処理の書き方について教えて頂きたく質問させていただきました。

1. seqリストを順番にSELECT
2. 1の結果データが無ければ、INSERT、1のデータがあれば例外

Transactionの範囲としては、seqのリストの開始から終了もしくは、例外が発生するまでと考えております。

いろいろなサイトを参考にして、記述してみたのですが、コンパイルでエラーが発生していまい、
どうのように記載したらよいか検討がつきませんでした。

Slickの記述方法がまだ、理解できていないのは十分承知の上、
皆様のお力を貸していただけないでしょうか。

大変、お手数をおかけしますが、記載方法をご教示いただけないでしょうか？

   // Example
    val insertIfNotExists = newUsers.map(m => {
      userTable.filter(f => f.id === m.id && f.sex === m.sex).exists.result.flatMap {
        case true => DBIO.successful(false)
        case false => (userTable += m).andThen(DBIO.successful(true))
      }
    }).head.transactionally

Answer 1

コンパイルエラーメッセージも貼るべきです。

が、予想としては、newUsersの名前から

    newUsers.map { (m: Seq[Long]) =>
        userTable.filter(f => f.id === m.id // <- Listにidのフィールドが無い

ためコンパイルエラーになっているのでは無いのでしょうか？

    newUsers.map { (m: Seq[Long]) =>
        userTable.filter(f => f.id.inSet(m)

にすれば大丈夫では無いでしょうか？

Answer 2

DBIO.failed() で常に失敗する DBIOAction が作れます。
また DBIO.sequence() で Seq[DBIOAction[]] を DBIOAction[Seq[]] に変換できます。

次のようになると思います。

   // Example
    val insertIfNotExists = DBIO.sequence {
      newUsers.map { m =>
        userTable.filter(f => f.id === m.id && f.sex === m.sex).exists.result.flatMap {
          case true => DBIO.failed(new RuntimeException(s"record already exists for id: ${m.id}"))
          case false => userTable += m
        }
      }
    }.transactionally

Comments

[退会済みユーザー]

いつもご教授ありがとうございます。

DBIO関連の使い方を早速調べさせて頂きました。

また、サンプルコードも誠にありがとうございました。