我正在为使用dynamodb的spray.io项目编写一些specc2集成测试。我正在使用sbt-dynamodb将本地的dynamodb加载到环境中。在运行测试之前，我使用以下模式加载表。
trait DynamoDBSpec extends SpecificationLike {
val config = ConfigFactory.load()
val client = new AmazonDynamoDBClient(new DefaultAWSCredentialsProviderChain())
lazy val db = {
client.setEndpoint(config.getString("campaigns.db.endpoint"))
new DynamoDB(client)
}
override def map(fs: =>Fragments): Fragments =
Step(beforeAll) ^ fs ^ Step(afterAll)
protected def beforeAll() = {
//load my tables
}
protected def afterAll() = {
//delete my tables
}
}
然后，可以使用DynamoDBSpec扩展任何测试类，然后将创建表。一切正常，直到从多个测试类扩展DynamoDBSpec，在此期间它引发ResourceInUseException：“无法创建现有表”。原因是它们并行执行，因此它想同时执行表创建。
我试图通过在顺序模式下运行测试来克服它，但是beforeall和afterall仍然并行执行。
理想情况下，我认为最好在整个套件运行之前创建表，而不是每次调用Spec类，然后在整个套件完成后将它们拆除。有谁知道如何做到这一点？
有两种方法可以实现此目的。
您可以使用一个对象来同步数据库的创建
object Database {
lazy val config = ConfigFactory.load()
lazy val client =
new AmazonDynamoDBClient(new DefaultAWSCredentialsProviderChain())
// this will only be done once in
// the same jvm
lazy val db = {
client.setEndpoint(config.getString("campaigns.db.endpoint"))
val database = new DynamoDB(client)
// drop previous tables if any
// and create new tables
database.create...
database
}
}
// BeforeAll is a new trait in specs2 3.x
trait DynamoDBSpec extends SpecificationLike with BeforeAll {
//load my tables
def beforeAll = Database.db
}
如您所见，在此模型中，我们不会在规范完成时删除表（因为我们不知道是否已执行所有其他规范），而是在重新运行规范时才删除表。这实际上可能是一件好事，因为这将帮助您调查故障（如果有）。
在全局级别同步规范并最终进行适当清理的另一种方法是使用规范链接。
使用specs2 3.3，您可以使用创建规范之间的依赖关系links。这意味着您可以定义“套件”规范，该规范将用于：
例如
import org.specs2._
import specification._
import core.Fragments
import runner.SpecificationsFinder
// run this specification with `all` to execute
// all linked specifications
class Database extends Specification { def is =
"All database specifications".title ^ br ^
link(new Create).hide ^
Fragments.foreach(specs)(s => link(s) ^ br) ^
link(new Delete).hide
def specs = specifications(pattern = ".*Db.*")
}
// start the database with this specification
class Create extends Specification { def is = xonly ^
step("create database".pp)
}
// stop the database with this specification
class Delete extends Specification { def is = xonly ^
step("delete database".pp)
}
// an example of a specification using the database
// it will be invoked by the "Database" spec because
// its name matches ".*Db.*"
class Db1Spec extends Specification { def is = s2"""
test $db
"""
def db = { println("use the database - 1"); ok }
}
class Db2Spec extends Specification { def is = s2"""
test $db
"""
def db = { println("use the database - 2"); ok }
}
运行时：
sbt> test-only *Database* -- all
您应该会看到类似
create database
use the database - 1
use the database - 2
delete database
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句