使用 Couchbase 4.5 玩 Framework 2.5
Play Framework 2.5 with Couchbase 4.5
我目前正在使用 Play Framework 作为数据库,我想使用 Couchbase 4.5(目前处于测试阶段,但应该不是问题)。
这是我的问题:
在 Couchbase 文档中,他们建议仅使用一个 CoucbaseCluster 实例和一个 Bucket 实例。
但是我如何在启动时建立这些实例并在我的所有控制器中全局使用它们。
到目前为止,我已经知道我必须使用依赖注入,但我不知道如何实现这一点。
等一下,写这篇文章我意识到带有这些实例的某种全局对象是老式的。我必须将这些实例注入到我所有应该使用它们的控制器中,对吗?
如有任何帮助,我们将不胜感激!
所以,经过一些修补,我让它工作了:
我用我的桶创建了一个单例class
@Singleton
class CouchbaseConnectionPool @Inject() (appLifecycle: ApplicationLifecycle){
val cluster=CouchbaseCluster.create("127.0.0.1")
val dataBucket=cluster.openBucket("data")
val fileBucket=cluster.openBucket("files")
appLifecycle.addStopHook { () =>
cluster.disconnect()
Future.successful(())
}
}
控制器看起来像这样
class DirectDBAccess @Inject() (pool:CouchbaseConnectionPool) extends Controller {
def listAll(dbtype:String) = Action {
val result:N1qlQueryResult = pool.dataBucket.query(N1qlQuery.simple("select bucket.* from bucket where type=\""+dbtype+"\""))
val data=result.allRows().mkString(",")
val total=result.allRows().length
val response="{data:["+data+"],total:"+total+"}"
Ok(response).as("application/json")
}
}
为了最终将它们绑定在一起,我添加了
bind(classOf[CouchbaseConnectionPool]).asEagerSingleton()
到 module.scala 并且有效!
我目前正在使用 Play Framework 作为数据库,我想使用 Couchbase 4.5(目前处于测试阶段,但应该不是问题)。
这是我的问题: 在 Couchbase 文档中,他们建议仅使用一个 CoucbaseCluster 实例和一个 Bucket 实例。 但是我如何在启动时建立这些实例并在我的所有控制器中全局使用它们。 到目前为止,我已经知道我必须使用依赖注入,但我不知道如何实现这一点。
等一下,写这篇文章我意识到带有这些实例的某种全局对象是老式的。我必须将这些实例注入到我所有应该使用它们的控制器中,对吗?
如有任何帮助,我们将不胜感激!
所以,经过一些修补,我让它工作了:
我用我的桶创建了一个单例class
@Singleton
class CouchbaseConnectionPool @Inject() (appLifecycle: ApplicationLifecycle){
val cluster=CouchbaseCluster.create("127.0.0.1")
val dataBucket=cluster.openBucket("data")
val fileBucket=cluster.openBucket("files")
appLifecycle.addStopHook { () =>
cluster.disconnect()
Future.successful(())
}
}
控制器看起来像这样
class DirectDBAccess @Inject() (pool:CouchbaseConnectionPool) extends Controller {
def listAll(dbtype:String) = Action {
val result:N1qlQueryResult = pool.dataBucket.query(N1qlQuery.simple("select bucket.* from bucket where type=\""+dbtype+"\""))
val data=result.allRows().mkString(",")
val total=result.allRows().length
val response="{data:["+data+"],total:"+total+"}"
Ok(response).as("application/json")
}
}
为了最终将它们绑定在一起,我添加了
bind(classOf[CouchbaseConnectionPool]).asEagerSingleton()
到 module.scala 并且有效!