Scala案例类中无法识别Riak Java Client注释？

Question

我正在使用案例类在我们的应用程序中定义不同的数据“模型”。原因是为了便于使用 Jerkson（Scala 接口到 Jackson）。为了将我的 User 转换为 Riak 中的域对象，我在我的 guid 上使用了 @RiakKey 注释。我有以下内容：

case class User(
  @RiakKey val guid: String,

  @RiakIndex(name = "email") val email: String,

  val salt: String,

  val passwordHash: String,

  val emailHash: String,

  val firstName: String,

  val lastName: String,

  val suspended: Boolean=false,

  val created: Timestamp=now

)

当我对案例类执行域转换时，@RiakKey 无法识别。它抛出一个NoKeySpecifedException。这是我的转换器：

class UserConverter(val bucket: String) extends Converter[User] {

  def fromDomain(domainObject: User, vclock: VClock) = {
    val key = getKey(domainObject)

    if(key == null) throw new NoKeySpecifedException(domainObject)

    val kryo = new Kryo()
    kryo.register(classOf[User])

    val ob = new ObjectBuffer(kryo)
    val value = ob.writeObject(domainObject)

    RiakObjectBuilder.newBuilder(bucket, key)
        .withValue(value)
        .withVClock(vclock)
        .withContentType(Constants.CTYPE_OCTET_STREAM)
        .build()
  }
}

这是 Scala 中带有 Java 注释的问题吗？有解决办法吗？

更新

这里是创建和存储用户对象的位置，以及引用转换器的位置：

1)

val user = parse[User](body) // jerkson parse, body is a string of JSON
User.store(user)

2)

object User {

  val bucketName = "accounts-users"
  val bucket = DB.client.createBucket(bucketName).execute()

  def fetch(id: String) = bucket.fetch(id).execute().getValueAsString()

  def store(o: User) = bucket.store( o ).withConverter(new UserConverter(bucketName)).execute()

}

轨迹追踪

com.basho.riak.client.convert.NoKeySpecifedException
        at com.basho.riak.client.bucket.DefaultBucket.store(DefaultBucket.java:455)
        at com.threetierlogic.AccountService.models.User$.store(User.scala:58)
        at com.threetierlogic.AccountService.controllers.Users$$anonfun$routes$3.apply(Users.scala:54)
        at com.threetierlogic.AccountService.controllers.Users$$anonfun$routes$3.apply(Users.scala:51)

Answer 1

（对于这个答案之前的长时间谈话，我深表歉意）

在了解了更多关于 scala 的知识后，我发现使用 case 类你必须做一些不同的事情。

http://piotrbuda.eu/2012/10/scala-case-classes-and-annotations-part-1.html

如果你这样做：

@(RiakKey@field) guid: String

它有效。

我在 scala 中编写了一个小型测试程序，并且能够使用 DefaultBucket 中使用的静态 getKey() 方法提取带注释的密钥，该方法返回 null 并导致引发异常。

import com.basho.riak.client.convert.KeyUtil.getKey;

object Main {

  def main(args: Array[String]): Unit = {
    val u = User("my_key")
    val k = getKey(u)
    System.out.println(k);

  }
}

用户.scala

/* scala 2.9.1 would be scala.annotation.target.field */
import scala.annotation.meta.field
import com.basho.riak.client.convert.RiakKey;

case class User (@(RiakKey@field) guid: String)

输出：

我的钥匙

（而且，如果您将注释改回原来的样子，它会按预期返回null）

Answer 2

这是我针对该问题提出的解决方法。我不依赖注解，而是直接使用DefaultBucket.store 方法并手动指定一个键。

我的用户伴随对象：

object User {

  val bucketName = "accounts-users"
  val bucket = DB.client.createBucket(bucketName).execute()

  def store(key: String, o: User) = bucket.store(key, o).withConverter(new UserConverter(bucketName)).execute()

}

并使用它：

val user = parse[User](body)
User.store(user.guid, user)