使用 Phantom Scala DSL 在 Cassandra 中创建模式答案

【问题标题】：Creating a schema in Cassandra using Phantom Scala DSL使用 Phantom Scala DSL 在 Cassandra 中创建模式
【发布时间】：2016-02-29 12:59:14
【问题描述】：

我已经写了这段代码

case class User(id: Int, gender: String, age: Int, occupation: String, zipCode: String)

object Defaults {
  val hosts = Seq("172.17.0.9")
  val Connector = ContactPoints(hosts).keySpace("Movies")
}

class MyDatabase(val keyspace: KeySpaceDef) extends com.websudos.phantom.db.DatabaseImpl(keyspace) {
  object users extends Users with keyspace.Connector
}

object MyDatabase extends MyDatabase(Defaults.Connector)
class Users extends CassandraTable[Users, User] {
  object id extends IntColumn(this) with PartitionKey[Int]
  object age extends IntColumn(this) with Index[Int]
  object gender extends StringColumn(this) with Index[String]
  object occupation extends StringColumn(this) with Index[String]
  object zipCode extends StringColumn(this) with Index[String]

  def fromRow(row: Row) : User = {
    User(
      row(id),
      row(gender),
      row(age),
      row(occupation),
      row(zipCode)
    )
  }
}

object Users extends Users with RootConnector {
  def store(user: User) : Future[ResultSet] = {
    insert
      .value(_.id, user.id)
      .value(_.gender, user.gender)
      .value(_.age, user.age)
      .value(_.occupation, user.occupation)
      .value(_.zipCode, user.zipCode)
      .consistencyLevel_=(ConsistencyLevel.ALL)
      .future()
  }

  def getById(id: Int) : Future[Option[User]] = {
    select.where(_.id eqs id).one()
  }
}

但是当我编译这个时，我得到一个错误。

Object creation impossible, since member session: Session in 
com.websudos.phantom.connectors.RootConnector is not defined; member space: 
KeySpace in com.websudos.phantom.connectors.RootConnector is not defined.

我还看到其他错误

[error] /Users/U/MyProjects/src/main/scala-2.11/com/abhi/MovieLensDataPreperation.scala:180: com.websudos.phantom.dsl.Row does not take parameters
[error]       row(id),
[error]          ^
[error] /Users/U/MyProjects/src/main/scala-2.11/com/abhi/MovieLensDataPreperation.scala:181: com.websudos.phantom.dsl.Row does not take parameters
[error]       row(gender),
[error]          ^
[error] /Users/U/MyProjects/src/main/scala-2.11/com/abhi/MovieLensDataPreperation.scala:182: com.websudos.phantom.dsl.Row does not take parameters
[error]       row(age),
[error]          ^
[error] /Users/U/MyProjects/src/main/scala-2.11/com/abhi/MovieLensDataPreperation.scala:183: com.websudos.phantom.dsl.Row does not take parameters
[error]       row(occupation),
[error]          ^
[error] /Users/U/MyProjects/src/main/scala-2.11/com/abhi/MovieLensDataPreperation.scala:184: com.websudos.phantom.dsl.Row does not take parameters
[error]       row(zipCode)
[error]          ^
[error] 5 errors found
[error] (compile:compileIncremental) Compilation failed

【问题讨论】：

我认为您应该再次阅读我的教程，您没有遵循 DSL 的结构，也没有提供应有的会话。您也没有使用真正有用的Database 实现。小事，但经历这将帮助你加快速度。您的Users 对象应该是一个名为ConcreteUsers 的类，这就是MyDatabase 下的users 字段应该扩展的内容，否则您将没有任何方法。 websudos.com/blog/post/…
感谢弗拉维安。我根据github.com/thiagoandrade6/cassandra-phantom/blob/master/src/… 此处的代码更改了我的实现，现在它好多了。但是我还有另一个问题。 stackoverflow.com/questions/35692508/…
我也回答过这个问题。
另外，阅读我对 Cassandra 索引的介绍：outworkers.com/blog/post/…。使用这么多Indexes 对性能真的很不利。

标签： scala phantom-dsl

【解决方案1】：

由于您已将 id、性别、年龄等定义为列，因此您应该像这样从行中提取值：

def fromRow(row: Row) : User = {
  User(
    id(row),
    gender(row),
    age(row),
    occupation(row),
    zipCode(row)
  )
}

【讨论】：