Как опустить значения столбцов при выполнении массовой вставки 3.x?

У меня есть таблица JOURNAL, в которой столбец INSERT_DATE должен быть заполнен БД текущей датой и временем, когда запись вставлена. Я специально не использовал тип TIMESTAMP из-за его ограниченного диапазона.

class Journal(tag: Tag) extends Table[JournalEntry](tag, "JOURNAL") { 
   def id = column[Int]("ID", O.PrimaryKey, O.AutoInc)
   def insertDate = column[OffsetDateTime]("INSERT_DATE", SqlType("DateTime default CURRENT_TIMESTAMP"))(localDateTimeColumnType)
   def valueDate = column[OffsetDateTime]("VALUE_DATE", SqlType("DateTime"))(localDateTimeColumnType)
   def amount = column[Int]("AMOUNT")
   def note = column[String]("NOTE", O.Length(100))

   def * : ProvenShape[JournalEntry] = (id.?, insertDate.?, valueDate, amount, note) 
     <> ((JournalEntry.apply _).tupled, JournalEntry.unapply)
}

Я также реализую класс case:

case class JournalEntry(id: Option[Int], insertDate: Option[LocalDateTime], 
  valueDate: LocalDateTime, amount: Int, note: String)

Когда мое приложение запускается, я заполняю БД случайными тестовыми данными:

TableQuery[Journal] ++= Seq.fill(1000)(JournalEntry(None, Some(LocalDateTime.now()), 
   LocalDateTime.of(2006 + Random.nextInt(10), 1 + Random.nextInt(11), 
   1 + Random.nextInt(27),Random.nextInt(24), Random.nextInt(60)), Random.nextInt(),
   TestDatabase.randomString(100)))

Это работает, но INSERT_DATE устанавливается JVM, а не базой данных. В документах Slick говорится, что столбцы следует опускать, если вы хотите, чтобы было вставлено значение по умолчанию. Но я просто не понимаю, как я опускаю столбцы, если у меня есть класс case.

Я также нашел этот SO post, но мог не понять, как использовать его в моем контексте.

Любые идеи?


scala slick-3.0
person binford    schedule 05.06.2016    source источник

Ответы (2)


arrow_upward
2
arrow_downward

Документация Slick дает пример такого упущения прямо в первом фрагменте кода здесь . Следуйте инструкциям или ответу cvogt, и вы получите решение:

TableQuery[Journal].map(je => (je.id, je.valueDate, je.amount, je.note)) ++= Seq.fill(1000)((None, LocalDateTime.of(2006 + Random.nextInt(10), 1 + Random.nextInt(11), 1 + Random.nextInt(27),Random.nextInt(24), Random.nextInt(60)), Random.nextInt(), TestDatabase.randomString(100)))

person Max Plevako    schedule 21.06.2016
comment
У меня не работает: [error] Slick does not know how to map the given types. [error] Possible causes: T in Table[T] does not match your * projection. Or you use an unsupported type in a Query (e.g. scala List). [error] Required level: slick.lifted.FlatShapeLevel [error] Source type: (slick.lifted.Rep[Int], slick.lifted.Rep[java.time.LocalDateTime], slick.lifted.Rep[Int], slick.lifted.Rep[String]) [error] Unpacked type: T [error] Packed type: G [error] TableQuery[Journal].map(je => (je.id, je.valueDate, je.amount, je.note)) ++= - person binford; 08.07.2016

arrow_upward
1
arrow_downward

Я работаю следующим образом:

import java.time.{ ZonedDateTime, ZoneOffset}
import slick.profile.SqlProfile.ColumnOption.SqlType
import scala.concurrent.duration.Duration
import scala.concurrent.Await

implicit val zonedDateTimeType = MappedColumnType.base[ZonedDateTime, Timestamp](
    {dt =>Timestamp.from(dt.toInstant)},
    {ts =>ZonedDateTime.ofInstant(ts.toInstant, ZoneOffset.UTC)}
)

class Users(tag: Tag) extends Table[(String, ZonedDateTime)](tag, "users") {
    def name = column[String]("name")
    def createAt = column[ZonedDateTime]("create_at", SqlType("timestamp not null default CURRENT_TIMESTAMP"))
    def * = (name, createAt)
}

val users = TableQuery[Users]
val setup = DBIO.seq(
    users.schema.create,
    users.map(u => (u.name)) ++= Seq(("Amy"), ("Bob"), ("Chris"), ("Dave"))
Await.result(db.run(setup), Duration.Inf)

Здесь я не использую класс case, просто кортеж.

person user2829759    schedule 26.10.2016