대량 삽입 슬릭 3.x를 수행 할 때 열 값을 생략하는 방법은 무엇입니까?

Question

레코드가 삽입 될 때 현재 날짜와 시간으로 DB가 INSERT_DATE 열을 채워야하는 JOURNAL 테이블이 있습니다. 제한된 범위 때문에 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 class JournalEntry(id: Option[Int], insertDate: Option[LocalDateTime], 
    valueDate: LocalDateTime, amount: Int, note: String) 

, 나는 무작위 시험 데이터로 DB를 채울 :

이

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 docs는 기본값을 삽입하기를 원할 경우 열을 생략해야한다고 말합니다. 하지만 저는 사례 클래스가있는 경우 어떻게 열을 생략하는지 알지 못합니다.

나는 또한이 SO post을 발견했지만 내 맥락에서 사용하는 방법을 알아낼 수 없었다.

아이디어가 있으십니까?

Answer 1

Slick docs는 첫 번째 코드 단편 here에서 이러한 누락의 예를 보여줍니다. 단계 또는 the cvogt's answer에 따라 당신은 해결에 도달합니다

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)))

Answer 2

나는 다음과 같은 방식으로 작동 : 나는 여기에 단지 튜플을 경우 클래스를 사용하고 있지 않다

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) 

.