Невозможно сделать схему в Кассандре с помощью фантомного-DSL

Question

Попытки создать схему в Кассандре, используя phantom-dsl для модульного тестирования после этого обучающей программы:

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

Database

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

Answer 1

Я обновил бы до фантома 2.0.0 в качестве примечания стороны. Далее, в вашем коде есть много улучшений, начиная с капитализации признаков.

Вы должны использовать database.create или database.createAsync, которые больше не требуют повторного прохождения неявного пространства ключей или сеанса. Имейте в виду, что этот API имеет версию 2.1.1 phantom-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()