0

jsonシリアライザーを必要とするphantom-dslのコレクション列チュートリアルに従っています。

以下の実装では、次のエラー出力が得られます。

見つかった: org.dyne.danielsan.superchain.data.models.JsonVin

[エラー] 必須: org.json4s.JValue

[エラー] (展開すると) org.json4s.JsonAST.JValue

[エラー] コンパクト (レンダー (obj))

私が間違っている場所を指摘するのに役立ちます。問題は、AFAIK phantom-dsl ではカスタム タイプを定義する必要があることですが、json4s は JValue を期待しています...

import com.websudos.phantom.CassandraTable
import com.websudos.phantom.dsl._
import org.json4s.{NoTypeHints, _}
import org.json4s.jackson.JsonMethods._
import org.json4s.jackson.Serialization

case class Transaction(blockhash: String,
                       blocktime: Long,
                       confirmations: Int,
                       vout: List[Vout],
                       vin: List[Vin])

case class JsonVout(value: String,
                    n: String,
                    scriptPubKey: String)

case class JsonVin(coinbase: String,
                   sequence: String)

sealed class TransactionColumnFamily extends CassandraTable[TransactionColumnFamily, Transaction] {

  implicit val formats = Serialization.formats(NoTypeHints)

  override def fromRow(row: Row): Transaction = {
    Transaction(
      blockhash(row),
      blocktime(row),
      confirmations(row),
      vout(row),
      vin(row)
    )
  }

  object blockhash extends StringColumn(this) with PartitionKey[String]

  object blocktime extends LongColumn(this) with ClusteringOrder[Long] with Descending

  object confirmations extends IntColumn(this) with ClusteringOrder[Int] with Descending

  object vout extends JsonListColumn[TransactionColumnFamily, Transaction, Vout](this) {
    override def fromJson(obj: String): Vout = {
      parse(obj).extract[Vout]
    }

//This is where the first error arises

    override def toJson(obj: Vout): String = {
      compact(render(obj))
    }
  }

  object vin extends JsonListColumn[TransactionColumnFamily, Transaction, Vin](this) {
    override def fromJson(obj: String): Vin = {
      parse(obj).extract[Vin]
    }

//This is where the second error arises

    override def toJson(obj: JsonVin): String = {
      compact(render(obj))
    }
  }

}   

object TransactionColumnFamily extends TransactionColumnFamily with RootConnector {
  // some more stuff
  // some more stuff

}

訂正

フラビアンさん、コメントありがとうございます。あなたは正しいです。最後に、これは Json4s で作業するために必要なものです:

  object vout extends JsonListColumn[TransactionColumnFamily, Transaction, Vout](this) {
    override def fromJson(obj: String): Vout = {
      parse(obj).extract[Vout]
    }

    override def toJson(obj: Vout): String = {
      write(obj)
    }
   }

  object vin extends JsonListColumn[TransactionColumnFamily, Transaction, Vin](this) {
    override def fromJson(obj: String): Vin = {
      parse(obj).extract[Vin]
    }

    override def toJson(obj: Vin): String = {
      write(obj)
    }
  }
4

1 に答える 1