0

尝试phantom-dsl按照本教程在 cassandra 中创建用于单元测试的模式：

http://outworkers.com/blog/post/phantom-tips-3-understanding-phantom-connectors

我在尝试自动生成架构时遇到了这个问题

[ERROR] /home/.../test/BaseCassandraSpec.scala:54: error: not enough arguments for method autocreate: (keySpace: com.websudos.phantom.connectors.KeySpace)
com.websudos.phantom.builder.query.CreateQuery.Default[com.neruti.db.models.ConcreteUserModel,com.neruti.User].
[ERROR] Unspecified value parameter keySpace.
[ERROR] Await.result(database.userModel.autocreate().future(),10.seconds)

有什么建议吗？

当前使用版本1.29.6

BaseCassandraSpec

import com.neruti.User
import com.neruti.db.models._
import com.neruti.db.databases._
import com.neruti.db.services._
import com.neruti.db.Connector._    
import org.scalatest._
import org.scalatest.{BeforeAndAfterAll,FlatSpec,Matchers,ShouldMatchers}
import org.scalatest.concurrent.ScalaFutures
import org.scalamock.scalatest.MockFactory
import scala.concurrent.duration._
import scala.concurrent.{Await, Future}
import scala.concurrent.ExecutionContext.Implicits.global

 override protected def beforeAll(): Unit = {
    Await.result(database.userModel.autocreate().future(),10.seconds)
   }

数据库

class UserDatabase (val connector: KeySpaceDef){
  object userModel extends ConcreteUserModel with connector.Connector
}

object ProductionDb extends UserDatabase(connector)

trait ProductionDatabaseProvider {
  def database: UserDatabase
}

trait ProductionDatabase extends ProductionDatabaseProvider {
  override val database = ProductionDb
}

object testDB extends UserDatabase(testConnector)

trait testDatabaseProvider {
  def database: UserDatabase
}

trait testDatabase extends testDatabaseProvider{
  override val database = testDB
}

连接器

package com.neruti.db

import com.neruti.db.models._

import com.websudos.phantom.database.Database
import com.websudos.phantom.connectors.ContactPoints
import com.websudos.phantom.dsl.KeySpaceDef

object Connector {



    // TODO: these key value pairs shld get from HOCON config file
      val host= Seq("127.0.0.1")
      val port = 9042
      val keySpace: String = "nrt_entities"
      //  val inet = InetAddress.getByName

      lazy val connector = ContactPoints(host,port).withClusterBuilder(
        _.withCredentials("dev", "nrtDev1989")
      ).keySpace(keySpace)

      //  embedded cassandra is not supported anymore.  Check phantom-sbt.
      //    lazy val testConnector: KeySpaceDef = ContactPoint.embedded.keySpace(keySpace)
      lazy val testConnector: KeySpaceDef = ContactPoints(host,port).noHeartbeat().keySpace(keySpace)
    }
4

1 回答 1

0

作为旁注，我会升级到 phantom 2.0.0。接下来，您的代码有很多需要改进的地方，首先是特征的大写。

您应该使用database.createor database.createAsync，它不再需要您重新传递隐式键空间或会话。请记住，此 API 是2.1.1phantom-dsl 的版本，可在 Maven Central 上找到。

package com.neruti.db

import com.neruti.db.models._

import com.outworkers.phantom.connectors.ContactPoints
import com.outworkers.phantom.dsl._

object Connector {



    // TODO: these key value pairs shld get from HOCON config file
      val host= Seq("127.0.0.1")
      val port = 9042
      val keySpace: String = "nrt_entities"
      //  val inet = InetAddress.getByName

      lazy val connector = ContactPoints(host,port).withClusterBuilder(
        _.withCredentials("dev", "nrtDev1989")
      ).keySpace(keySpace)

      lazy val testConnector: KeySpaceDef = ContactPoints(host, port).noHeartbeat().keySpace(keySpace)
    }


class MyDb(override val connector: CassandraConnection) extends Database(connector) {
  ... tables
}

object TestMyDb extends MyDb(Connector.testConnector)

import com.outworkers.phantom.dsl.context
// Now this will only require an execution context, nothing more
TestMyDb.create()
于 2017-01-30T23:28:38.263 回答