Phantom生成的"store"方法在运行时抛出ClassCastException。



我有以下幻影表定义:

package myPackage
import com.outworkers.phantom.CassandraTable
import com.outworkers.phantom.connectors.RootConnector
import com.outworkers.phantom.dsl._
import com.outworkers.phantom.keys.{PartitionKey, PrimaryKey}
import scala.concurrent.Future
case class KeysTwoThreeAndFour(myKeyTwo: Int, myKeyThree: String, myKeyFour: Int)
abstract class MyTable extends CassandraTable[MyTable, Int] with RootConnector {
  object myKeyOne extends IntColumn(this) with PartitionKey
  object myKeyTwo extends IntColumn(this) with PrimaryKey
  object myKeyThree extends StringColumn(this) with PrimaryKey
  object myKeyFour extends IntColumn(this) with PrimaryKey
  object myValue extends IntColumn(this)
  def insertValue(myKeyOne: Int, valuesMap: Map[KeysTwoThreeAndFour, Int]): Future[Unit] = {
    val resultFutures = for ((key: KeysTwoThreeAndFour, myValue) <- valuesMap) yield {
      store(myKeyOne, key.myKeyTwo, key.myKeyThree, key.myKeyFour, myValue).future()
    }

    Future.sequence(resultFutures).map { _ => () }
  }
}

这编译正常,但在运行时会引发以下异常:

java.lang.ClassCastException: scala.Tuple5 cannot be cast to scala.runtime.Nothing$
    at myPackage.MyTable$anon$macro$1$1.store(MyTable.scala:10)
    at com.outworkers.phantom.CassandraTable.store(CassandraTable.scala:125) ~[com.outworkers.phantom-dsl_2.11-2.7.6.jar:2.7.6]
    at myPackage.MyTable$$anonfun$2.apply(MyTable.scala:19)
    at myPackage.MyTable$$anonfun$2.apply(MyTable.scala:18)
    ...

我正在遵循Phantom表文档底部的示例,似乎有什么问题?问题是我有一个简单的Int作为我的"记录"类型而不是实际的类?

我正在使用phantom-dsl 2.7.6,Play Framework 2.3.10和Scala 2.11.11。

请注意,以下代码工作正常:

insert
.value(_.myKeyOne, myKeyOne)
.value(_.myKeyTwo, key.myKeyTwo)
.value(_.myKeyThree, key.myKeyThree)
.value(_.myKeyFour, key.myKeyFour)
.value(_.myValue, myValue)
.future()

谢谢。

似乎问题

是由于"记录"类型是基元而不是类; 换句话说,将我的 Int 包装在一个以该 Int 为唯一成员的案例类中解决了这个问题。

此外,Select 语句存在一个问题,该问题也已解决:

java.util.concurrent.ExecutionException: Boxed Error
    at com.outworkers.phantom.CassandraTable.fromRow(CassandraTable.scala:85) ~[com.outworkers.phantom-dsl_2.11-2.7.6.jar:2.7.6]
    at com.outworkers.phantom.SelectTable$$anonfun$select$1.apply(SelectTable.scala:24) ~[com.outworkers.phantom-dsl_2.11-2.7.6.jar:2.7.6]
    at com.outworkers.phantom.SelectTable$$anonfun$select$1.apply(SelectTable.scala:24) ~[com.outworkers.phantom-dsl_2.11-2.7.6.jar:2.7.6]
    at com.outworkers.phantom.builder.query.SelectQuery.fromRow(SelectQuery.scala:59) ~[com.outworkers.phantom-dsl_2.11-2.7.6.jar:2.7.6]
    at com.outworkers.phantom.builder.query.RootExecutableQuery$class.singleResult(ExecutableQuery.scala:176) ~[com.outworkers.phantom-dsl_2.11-2.7.6.jar:2.7.6]
    at com.outworkers.phantom.builder.query.SelectQuery.singleResult(SelectQuery.scala:33) ~[com.outworkers.phantom-dsl_2.11-2.7.6.jar:2.7.6]

最新更新