1

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

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 注释的问题吗？有解决方法吗？

更新

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

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

2 回答 2

2

（我为这个答案之前的长时间谈话道歉）

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

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

如果你这样做：

@(RiakKey@field) guid: String

有用。

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

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按预期返回）

于 2013-02-06T20:34:27.843 回答
0

这是我针对该问题提出的解决方法。我不依赖注释，而是使用该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)
于 2013-02-06T18:05:11.450 回答