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

Slick - implicit conversion of Long to java.sql.Timestamp

光滑 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是一个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]
 }
}

table定义:

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

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

理想情况下,您只需使用 sql.Timestamp 作为您的 Jobs.queued 列类型(您对查询片段的评论似乎表明您 think它是):

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 数据库以进行转换。