scala - 使用 Phantom 向 Cassandra 插入值的便捷方式

Question

有谁知道通过 phatom-dsl 向 Cassandra 插入值的便捷方法？目前我正在这样做：

case class Entry(id: UUID, firstName: String, lastName: String)

sealed class EntryTable extends CassandraTable[EntryTable, Entry] {
  override val tableName = "entries"
  object id extends UUIDColumn(this) with Index[UUID]
  object firstName extends StringColumn(this)
  object lastName extends StringColumn(this)

  override def fromRow(r: dsl.Row): Entry = {
    Entry(id(r), firstName(r), firstName(r))
  }
}

object EntryTable extends EntryTable {
   private val connector = CassandraConnector.apply(Set(InetAddress.getByName("localhost")))
   implicit val keySpace = KeySpace("keyspace")

   def insert(e: Entry) = {
     connector.withSessionDo(implicit session => {
       insert().value(_.id, e.id)).value(_.firstName, e.firstName).value(_.lastName, e.lastName).future()
     }
   }
}

但我想做：

def insert(e: Entry) = {
  connector.withSessionDo(implicit session => {
    insert().value(e).future()
  }
}

当案例类有很多字段时，这会更方便。有任何想法吗？

Answer 1

您使用 API 略有错误，我们正在发布多个教程以公开“新”方式。同时，它的基本版本在这里可用，激活器模板中的这个分支也描述了你需要知道的一切。

具体来说，插入记录的方式在此处描述。