Liaison à une base de données

1. Définition

Comme expliqué dans l’introduction, chaque table est définie par une classe qui étend la classe Table[T] où T est un tuple contenant autant d’éléments que de colonnes dans la table.

Cette table prend comme arguments un tag et un nom de table. C’est pour cela que la classe qui étend la classe Table[T] prend comme argument un tag et définit un nom de table.

Prenons comme exemple une table UTILISATEURS qui définit les colonnes suivantes :

Cette table étend donc le type Table[(Int, String, Option[String], Int, String)].

class Utilisateurs(tag: Tag) extends Table[(Int, String, 
Option[String], Int, String)](tag, "UTILISATEURS") { ... } 

Dans la classe qui définit la table, on définit les colonnes de cette dernière grâce à la méthode column[T] où T correspond au type de donnée souhaité dans la colonne. Les types suivants sont supportés par défaut :...

1. Récupération

Pour créer une requête destinée à récupérer l’intégralité des éléments d’une TableQuery[T], on utilise la méthode result.

Dans notre exemple, cela correspond à la requête SQL suivante :

println(utilisateurs.result.statements.mkString("\n")) 
// select "ID", "NOM", "PRENOM", "AGE", "EMAIL" from 
"UTILISATEURS" 

Lorsqu’on récupère tous les éléments de la table utilisateurs, on obtient les trois éléments créés lors de l’initialisation.

val recuperation = db.run(utilisateurs.result).map { result => 
 println(s"${result.length} utilisateurs enregistrés") 
 result.foreach(println) 
} 
// recuperation: scala.concurrent.Future[Unit] = Future(<not 
completed>) 
 
Await.result(recuperation, Duration.Inf) 
// 3 utilisateurs enregistrés 
// (1,Dubois,Some(Dimitri),29,ddubois@test.fr) 
// (2,Mercier,None,72,lmercier@test.fr) 
// (3,Polka,Some(Marie),65,mpolka@test.fr) 

Pour récupérer uniquement un ou plusieurs champs, on utilise la méthode map sur le result et on renvoie le ou les champs souhaités.

Dans notre exemple, pour récupérer uniquement les emails de la table utilisateurs, on utilise la fonction anonyme _.email dans la méthode map. Cela correspond à la requête suivante :

println(utilisateurs.map(_.email).result.statements.mkString("\n") 
) 
// select "EMAIL" from "UTILISATEURS" 

En lançant cette requête, on récupère les trois emails des éléments créés lors de l’initialisation.

val recuperationChamps =  
db.run(utilisateurs.map(_.email).result).map { result => 
 println("Emails des utilisateurs") 
 result.foreach(println) 
} 
// recuperationChamps: scala.concurrent.Future[Unit] = Future(<not completed>) 
 
Await.result(recuperationChamps, Duration.Inf) 
// Emails...