Slick2.1にて、ManyToMany(多対多)を実現する方法例
今回の実装では、User *---* Project というリレーションを実現します。
val user = Users.findById(1).get val projects = user.projects // SQL走る val projects2 = user.projects // ここでは、キャッシュされた結果が返るためSQLは走らない
上記のように、アクセス可能で、初期アクセス時のみにSQLが発行されるような使用としています。
■Dao.scala
package models
import scala.slick.lifted.TableQuery
private[models] trait DAO {
val Users = TableQuery[Users]
val Projects = TableQuery[Projects]
val ProjectUserMap = TableQuery[ProjectUserMap]
}
■User.scala
package models
import java.sql.Timestamp
import play.api.db.slick.Config.driver.simple._
// define dto
case class User(id: Long, name: String){
// ##############################
// user.projects という形で、アクセス可能
// また、キャッシュされるため、２度めのアクセスの際にはSQLは走らない
// ##############################
val projectCache = collection.mutable.Map[Long, List[Product]]()
def projects(implicit session: Session) = {
projectCache.getOrElseUpdate(this.id, ProjectUserMap.projects(this.id))
}
}
// define table schema
class Users(tag: Tag) extends Table[User](tag, "users") with DAO{
def id = column[Long]("id", O.PrimaryKey, O.AutoInc)
def name = column[String]("name", O.NotNull)
def * = (id, name) <> (User.tupled, User.unapply)
def idx = index("idx_token", token ,unique = true)
}
object Users extends DAO {
def findById(id: Long)(implicit s: Session): Option[User] = {
Users.filter { _.id === id }.firstOption
}
def insert(user: User)(implicit s: Session) {
Users += user
}
}
■Project.scala
package models
import java.sql.Timestamp
import play.api.db.slick.Config.driver.simple._
// define dto
case class Project(id: Long, name: String, description: String){
// ##############################
// project.users という形で、アクセス可能
// また、キャッシュされるため、２度めのアクセスの際にはSQLは走らない
// ##############################
val userCache = collection.mutable.Map[Long, List[Product]]()
def users(implicit session: Session) = {
userCache.getOrElseUpdate(this.id, ProjectUserMap.users(this.id))
}
}
// define table schema
class Projects(tag: Tag) extends Table[Project](tag, "projects") with DAO{
def id = column[Long]("id", O.PrimaryKey, O.AutoInc)
def name = column[String]("name", O.NotNull)
def description = column[String]("description", O.NotNull)
def * = (id, name, description) <> (Project.tupled, Project.unapply)
}
// define companion Object
object Projects extends DAO {
def findById(id: Long)(implicit s: Session): Option[Project] = {
Projects.filter { _.id === id }.firstOption
}
}
■ProjectUser.scala
package models
import java.sql.Timestamp
import models.Projects._
import play.api.db.slick.Config.driver.simple._
// define dto
case class ProjectUser(user_id: Long, project_id: Long)
// define table schema
class ProjectUserMap(tag: Tag) extends Table[ProjectUser](tag, "projects_users") with DAO{
def user_id = column[Long]("user_id")
def project_id = column[Long]("project_id")
def * = (user_id, project_id) <> (ProjectUser.tupled, ProjectUser.unapply)
def userFK = foreignKey("user2projectFK", user_id, Users)(u => u.id)
def projectFK = foreignKey("project2userFK", project_id, Projects)(p => p.id)
}
// define companion Object
object ProjectUserMap extends DAO {
def projects(user_id: Long)(implicit s: Session) = {
ProjectUserMap.filter { _.user_id === user_id }.flatMap(_.projectFK).list
}
def users(project_id: Long)(implicit s: Session) = {
ProjectUserMap.filter { _.project_id === project_id }.flatMap(_.userFK).list
}
}
↓以下、使い方
■Application.scala
package controllers
import models._
import play.api.mvc._
import play.api.db.slick._
import play.api.Play.current
object Application extends Controller{
def index = DBAction { implicit rc =>
val user = Users.findById(1).get
val projects = user.projects // SQL走る
val projects2 = user.projects // ここでは、キャッシュされた結果が返るためSQLは走らない
Ok("test")
}
}
取得する列の指定など、拡張は今回は盛り込んでません！
ご指摘、などあればコメントお願い致します！！
