Призрак 1.25.4 с Кассандрой

Question

Мне нужна помощь с реализацией модели уведомления с использованием фантома и кассандры. Что я сделал до сих пор:

import java.util.UUID

import com.websudos.phantom.dsl._
import com.websudos.phantom.connectors.Connector
import org.joda.time.DateTime

import scala.concurrent.Future

case class Notification(
  id:           UUID,
  userId:       UUID,
  timestamp:    DateTime,
  read:         Boolean,
  actionUser:   List[String],
  verb:         String,
  itemId:       UUID,
  collectionId: String
)

sealed class NotificationTable extends CassandraTable[NotificationTable, Notification] {

  object id extends UUIDColumn(this) with ClusteringOrder[UUID] with Ascending

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

  object timestamp extends DateTimeColumn(this) with ClusteringOrder[DateTime] with Descending

  object read extends BooleanColumn(this)

  object actionUser extends ListColumn[NotificationTable, Notification, String](this)

  object verb extends StringColumn(this)

  object itemId extends UUIDColumn(this)

  object collectionId extends StringColumn(this)

  def fromRow(row: Row): Notification =
    Notification(
      id(row),
      userId(row),
      timestamp(row),
      read(row),
      actionUser(row),
      verb(row),
      itemId(row),
      collectionId(row)
    )
}

object NotificationTable extends NotificationTable with Connector {

  override def keySpace: String = "test"
  implicit val keyspace: com.websudos.phantom.connectors.KeySpace = com.websudos.phantom.connectors.KeySpace("test")
  def insertItem(item: Notification): Future[ResultSet] =
    insert
      .value(_.id, item.id)
      .value(_.userId, item.userId)
      .value(_.timestamp, item.timestamp)
      .value(_.read, item.read)
      .value(_.actionUser, item.actionUser) 
      .value(_.verb, item.verb)
      .value(_.itemId, item.itemId)
      .value(_.collectionId, item.collectionId)
      .future()
}

Так или иначе, я должен определить два keyspacesодин для RootConnector и один для insert заявление. Это достаточно близко к этому примеру. Тем не менее, мой код не компилируется. Я знаю, что они используют абстрактный класс и, следовательно, он компилируется.

Мой вопрос: как мне использовать этот абстрактный класс? Я хочу просто вызвать оператор вставки из другого источника Scala.

Answer 1

Вы упускаете тот факт, что вы должны использовать RootConnector вместо случайного Connector черта там. Причина того, что этот класс является абстрактным, заключается в том, что его следует создавать только внутри Database объект.

Посмотрите этот урок для получения более подробной информации, но вкратце, обратите внимание на RootConnector миксин здесь:

abstract class ConcreteNotificationTable extends
  NotificationTable with RootConnector

А потом:

class MyDatabase(val connector: KeySpaceDef) extends Database(connector) {
  // And here you inject the real session and keyspace in the table
  object notifications extends ConcreteNotificationsTable with connector.Connector
}

Затем вы делаете что-то вроде этого:

object MyDatabase extends MyDatabase(ContactPoint.local.keySpace("my_app"))

И из любого другого исходного файла:

val notification = Notification(id, //etc...)
MyDatabase.notifications.insertItem(someNotification)

И даже лучше разделение проблем, как доступно в учебнике:

trait DbProvider extends DatabaseProvider {
  def database: MyDatabase
}
trait ProductionDbProvider extends DbProvider {
  // this would now point to your object
  override val database = MyDatabase
}

Тогда каждое место, которое нуждается в базе данных, должно быть смешано либо DbProvider или напрямую ProductionDbProvider, Прочитайте учебник для более подробной информации, это не супер тривиальная тема, и все детали уже есть.

Answer 2

Пытаться:

import java.util.UUID

import com.websudos.phantom.dsl._
import com.websudos.phantom.connectors.Connector
import org.joda.time.DateTime

import scala.concurrent.Future

case class Notification(
  id:           UUID,
  userId:       UUID,
  timestamp:    DateTime,
  read:         Boolean,
  actionUser:   List[String],
  verb:         String,
  itemId:       UUID,
  collectionId: String
)

//use normal class
class NotificationTable extends CassandraTable[NotificationTable, Notification] {

  object id extends UUIDColumn(this) with ClusteringOrder[UUID] with Ascending

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

  object timestamp extends DateTimeColumn(this) with ClusteringOrder[DateTime] with Descending

  object read extends BooleanColumn(this)

  object actionUser extends ListColumn[NotificationTable, Notification, String](this)

  object verb extends StringColumn(this)

  object itemId extends UUIDColumn(this)

  object collectionId extends StringColumn(this)

  def fromRow(row: Row): Notification =
    Notification(
      id(row),
      userId(row),
      timestamp(row),
      read(row),
      actionUser(row),
      verb(row),
      itemId(row),
      collectionId(row)
    )
}

//use abstract
abstract class NotificationTable extends NotificationTable with Connector {

  def insertItem(item: Notification): Future[ResultSet] =
    insert
      .value(_.id, item.id)
      .value(_.userId, item.userId)
      .value(_.timestamp, item.timestamp)
      .value(_.read, item.read)
      .value(_.actionUser, item.actionUser) 
      .value(_.verb, item.verb)
      .value(_.itemId, item.itemId)
      .value(_.collectionId, item.collectionId)
      .future()
}