Add persistence of todo table

Author: s10a137g

.gitignore

@@ -12,3 +12,4 @@ docker/db/data/
 .bloop
 .bsp
 .project
+.DS_Store

app/lib/persistence/package.scala

@@ -3,14 +3,14 @@
   * 
   */
 
-package lib
+// package lib
 
 package object persistence {
 
   val default = onMySQL
 
   object onMySQL {
     implicit lazy val driver = slick.jdbc.MySQLProfile
-    object UserRepository extends UserRepository
+    object TodoRepository extends TodoRepository
   }
 }

app/model/todo/Todo.scala

@@ -0,0 +1,56 @@
+/**
+  * This is a sample of Todo Application.
+  * 
+  */
+
+package model.todo
+
+import ixias.model._
+import ixias.util.EnumStatus
+
+import java.time.LocalDateTime
+
+// ユーザーを表すモデル
+//~~~~~~~~~~~~~~~~~~~~
+import Todo._
+case class Todo(
+  id:        Option[Id],
+  categoryId: Long,
+  title:      String,
+  body:      String,
+  state:     Status,
+  updatedAt: LocalDateTime = NOW,
+  createdAt: LocalDateTime = NOW
+) extends EntityModel[Id]
+
+// コンパニオンオブジェクト
+//~~~~~~~~~~~~~~~~~~~~~~~~
+object Todo {
+
+  val  Id = the[Identity[Id]]
+  type Id = Long @@ Todo
+  type WithNoId = Entity.WithNoId [Id, Todo]
+  type EmbeddedId = Entity.EmbeddedId[Id, Todo]
+
+  // ステータス定義
+  //~~~~~~~~~~~~~~~~~
+  sealed abstract class Status(val code: Short, val name: String) extends EnumStatus
+  object Status extends EnumStatus.Of[Status] {
+    case object TODO extends Status(code = 0,   name = "TODO")
+    case object PROGRESS extends Status(code = 1,   name = "進行中")
+    case object COMPLETE   extends Status(code = 2, name = "完了")
+  }
+
+  // INSERT時のIDがAutoincrementのため,IDなしであることを示すオブジェクトに変換
+  def apply(categoryId: Long, title: String, body: String, state: Status): WithNoId = {
+    new Entity.WithNoId(
+      new Todo(
+        id    = None,
+        categoryId  = categoryId,
+        title = title,
+        body   = body,
+        state = state
+      )
+    )
+  }
+}

app/persistence/TodoRepository.scala

@@ -0,0 +1,68 @@
+/**
+  * This is a sample of Todo Application.
+  * 
+  */
+
+package persistence
+
+import scala.concurrent.Future
+import ixias.persistence.SlickRepository
+import model.todo.Todo
+import slick.jdbc.JdbcProfile
+import db.TodoTable
+
+// TodoRepository: TodoTableへのクエリ発行を行うRepository層の定義
+//~~~~~~~~~~~~~~~~~~~~~~
+case class TodoRepository[P <: JdbcProfile]()(implicit val driver: P)
+  extends SlickRepository[Todo.Id, Todo, P]
+  with db.SlickResourceProvider[P] {
+
+  import api._
+
+  /**
+    * Get Todo Data
+    */
+  def get(id: Id): Future[Option[EntityEmbeddedId]] =
+    RunDBAction(TodoTable, "slave") { _
+      .filter(_.id === id)
+      .result.headOption
+  }
+
+  /**
+    * Add Todo Data
+   */
+  def add(entity: EntityWithNoId): Future[Id] =
+    RunDBAction(TodoTable) { slick =>
+      slick returning slick.map(_.id) += entity.v
+    }
+
+  /**
+   * Update Todo Data
+   */
+  def update(entity: EntityEmbeddedId): Future[Option[EntityEmbeddedId]] =
+    RunDBAction(TodoTable) { slick =>
+      val row = slick.filter(_.id === entity.id)
+      for {
+        old <- row.result.headOption
+        _   <- old match {
+          case None    => DBIO.successful(0)
+          case Some(_) => row.update(entity.v)
+        }
+      } yield old
+    }
+
+  /**
+   * Delete Todo Data
+   */
+  def remove(id: Id): Future[Option[EntityEmbeddedId]] =
+    RunDBAction(TodoTable) { slick =>
+      val row = slick.filter(_.id === id)
+      for {
+        old <- row.result.headOption
+        _   <- old match {
+          case None    => DBIO.successful(0)
+          case Some(_) => row.delete
+        }
+      } yield old
+    }
+}

app/persistence/db/SlickResourceProvider.scala

@@ -0,0 +1,20 @@
+/**
+  * This is a sample of Todo Application.
+  * 
+  */
+
+package persistence.db
+
+import slick.jdbc.JdbcProfile
+
+// Tableを扱うResourceのProvider
+//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+trait SlickResourceProvider[P <: JdbcProfile] {
+
+  implicit val driver: P
+  object TodoTable extends TodoTable
+  // --[ テーブル定義 ] --------------------------------------
+  lazy val AllTables = Seq(
+    TodoTable
+  )
+}

app/persistence/db/TodoTable.scala

@@ -0,0 +1,61 @@
+/**
+  * This is a sample of Todo Application.
+  * 
+  */
+
+package persistence.db
+
+import java.time.LocalDateTime
+import slick.jdbc.JdbcProfile
+import ixias.persistence.model.Table
+
+import model.todo.Todo
+
+// TodoTable: Todoテーブルへのマッピングを行う
+//~~~~~~~~~~~~~~
+case class TodoTable[P <: JdbcProfile]()(implicit val driver: P)
+  extends Table[Todo, P] {
+  import api._
+
+  // Definition of DataSourceName
+  //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+  lazy val dsn = Map(
+    "master" -> DataSourceName("ixias.db.mysql://master/Todo"),
+    "slave"  -> DataSourceName("ixias.db.mysql://slave/Todo")
+  )
+
+  // Definition of Query
+  //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+  class Query extends BasicQuery(new Table(_)) {}
+  lazy val query = new Query
+
+  // Definition of Table
+  //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+  class Table(tag: Tag) extends BasicTable(tag, "Todo") {
+    import Todo._
+    // Columns
+    /* @1 */ def id        = column[Id]            ("id",         O.UInt64, O.PrimaryKey, O.AutoInc)
+    /* @2 */ def categoryId = column[Long]         ("category_id", O.UInt64)
+    /* @3 */ def title     = column[String]        ("title",       O.Utf8Char255)
+    /* @4 */ def body      = column[String]        ("body",       O.Utf8Char255)
+    /* @5 */ def state     = column[Status]        ("state",      O.UInt8)
+    /* @6 */ def updatedAt = column[LocalDateTime] ("updated_at", O.TsCurrent)
+    /* @7 */ def createdAt = column[LocalDateTime] ("created_at", O.Ts)
+
+    type TableElementTuple = (
+      Option[Id], Long, String, String, Status, LocalDateTime, LocalDateTime
+    )
+
+    // DB <=> Scala の相互のmapping定義
+    def * = (id.?, categoryId, title,body, state, updatedAt, createdAt) <> (
+      // Tuple(table) => Model
+      (t: TableElementTuple) => Todo(
+        t._1, t._2, t._3, t._4, t._5, t._6, t._7
+      ),
+      // Model => Tuple(table)
+      (v: TableElementType) => Todo.unapply(v).map { t => (
+        t._1, t._2, t._3, t._4, t._5, LocalDateTime.now(), t._7
+      )}
+    )
+  }
+}

app/persistence/package.scala

@@ -0,0 +1,17 @@
+/**
+  * This is a sample of Todo Application.
+  * 
+  */
+
+
+package persistence
+
+package object persistence {
+
+  val default = onMySQL
+  
+  object onMySQL {
+    implicit lazy val driver = slick.jdbc.MySQLProfile
+    object TodoRepository extends TodoRepository
+  }
+}