Passer le résultat d'un DBIO dans un autre

Question

Je suis nouveau sur Slick et j'essaie de réécrire les deux requêtes suivantes pour travailler en une seule transaction. Mon but est de vérifier si 1. éléments existent 2. retour élément existant ou en créer, il gère autoincrement de MySQL

Les deux fonctions sont les suivantes:

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 

Comment puis-je les enchaîner en toute sécurité, par exemple. pour exécuter d'abord vérifier l'existence, retourner si l'objet existe déjà et s'il n'existe pas alors le créer et retourner le nouvel élément dans une transaction?

Answer 1

Vous pouvez utiliser une pour la compréhension:

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

Avec un peu d'aide de la bibliothèque de chats.

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