1つのDBIOの結果を別のものに渡す

Question

私はSlickが初めてで、1つのトランザクションで動作するように次の2つのクエリを書き直そうとしています。

def createEmail(email: String): DBIO[Email] = { 
    // We create a projection of just the email column, since we're not inserting a value for the id column 
    (emails.map(p => p.email) 
     returning emails.map(_.id) 
     into ((email, id) => Email(id, email)) 
    ) += email 
    } 

    def findEmail(email: String): DBIO[Option[Email]] = 
    emails.filter(_.email === email).result.headOption 

にはどうすれば安全に、すなわち、それらをチェーンすることができます：私の目標は、要素が 2.リターン既存の要素が存在するか、それは2つの機能があるのMySQL

から自動インクリメントを取り扱う作成する場合1. にチェックです。最初に存在をチェックし、オブジェクトがすでに存在するかどうかを返します。存在しない場合は作成し、新しい要素を1つのトランザクションに返します。

Answer 1

あなたは理解のために使用することができます

def findOrCreate(email: String) = { 
    (for { 
    found <- findEmail(email) 
    em <- found match { 
     case Some(e) => DBIO.successful(e) 
     case None => createEmail(email) 
    } 
    } yield em).transactionally 
} 

val result = db.run(findOrCreate("batman@gotham.gov")) 
// Future[Email] 

Answer 2

猫ライブラリの少しの助けを借りて：。

def findOrCreate(email: String): DBIO[Email] = { 
    OptionT(findEmail(email)).getOrElseF(createEmail(email)).transactionally 
}