Slick - Long 到 java.sql.Timestamp 的隐式转换

Question

光滑 2.1 斯卡拉 2.11.7

无法获得 Long java.sql.Timestamp 或 java.sql.Date 工作的隐式转换。我让他们为其他转换工作，例如 JodaTime.DateTime java.sql.Timestamp...

例如查询返回错误：

org.postgresql.util.PSQLException: ERROR: operator does not exist: 
timestamp with time zone >= bigint Hint: No operator matches 
the given name and argument type(s). You might need to add explicit type casts. 
Position: 325

这些是隐含的，它们肯定被正确导入以在范围内：

implicit val LongToTimestamp = MappedColumnType.base[Long, Timestamp](
longTS => new Timestamp(longTS),
sqlTS => sqlTS.getTime
)

implicit val LongToDate = MappedColumnType.base[Long, java.sql.Date](
longTS => new java.sql.Date(longTS),
sqlDate => sqlDate.getTime
)

我也尝试过使用 java.lang.Long 代替：

implicit val LongToTimestamp = MappedColumnType.base[java.lang.Long, Timestamp](
longTS => new Timestamp(longTS),
sqlTS => sqlTS.getTime
)

implicit val LongToDate = MappedColumnType.base[java.lang.Long, java.sql.Date](
longTS => new java.sql.Date(longTS),
sqlDate => sqlDate.getTime
)

我在这里缺少什么？谢谢！

--

附加信息：

查询方法定义为（queued is a java.sql.Timestamp）：

def getJobs(jobTypeId: Short, onOrAfter: DateTime): Seq[JobRow] = {
 val q1 = for{j <- Jobs if j.jobTypeId === jobTypeId && j.queued >= onOrAfter.getMillis} yield j
 db.withSession{ implicit s =>
   q1.buildColl[Seq]
 }
}

表定义：

class Jobs(tag: Tag) extends Table[JobRow](tag, "job") {

def jobId = column[Long]("job_id", O.PrimaryKey, O.NotNull)

def jobTypeId = column[Short]("job_type_id", O.NotNull)

def queued = column[Long]("queued", O.NotNull)

def * = (jobId, jobTypeId, queued) <>((JobRow.apply _).tupled, JobRow.unapply_ )

def pk = primaryKey("job_pk", jobId)
}

Answer 1

您的问题是 Postgres 中的基础 queued 列不是 bigint 而是 timestamp with time zone。但是，在 Slick 的 Jobs 表定义中，您说该列是 Long。 Slick 已经知道如何将 Long 绑定到查询，因此它永远不会尝试使用您的隐式将 Long 转换为它确实知道如何绑定的另一种类型。

理想情况下，您只需使用 sql.Timestamp 作为您的 Jobs.queued 列类型（这就是您对查询 sn-p 的评论似乎表明您 认为它是）：

def queued = column[Timestamp]("queued", O.NotNull)
// As opposed to your example where this is
// def queued = column[Long]("queued", O.NotNull)

或者，您可以为 to_timestamp(double) 创建一个 Slick 包装器：

val toTimestamp = SimpleFunction.unary[Double, Timestamp]("to_timestamp")
val q1 = for {
  j <- Jobs
  if j.jobTypeId === jobTypeId && j.queued >= toTimestamp(onOrAfter.getMillis)
} yield j

最后，您可以将自动转换添加到 Postgres DB 以进行转换。