在scala上使用couchbase java api :异步选择查询和映射结果

libraryDependencies += "com.couchbase.client" % "java-client" % "3.2.0"

import com.couchbase.client.java.Cluster
import com.couchbase.client.java.auth.PasswordAuthenticator

val cluster = Cluster.connect("couchbase://localhost")
cluster.authenticate(PasswordAuthenticator.create("username", "password"))

import com.couchbase.client.java.Bucket

val bucket = cluster.bucket("bucketName")

import com.couchbase.client.java.query.AsyncN1qlQueryResult

val query = "SELECT * FROM bucketName WHERE condition"
val result: AsyncN1qlQueryResult = bucket.async().query(query)

import scala.concurrent.ExecutionContext.Implicits.global

result.rows().forEach(row => {
  // 处理每一行的数据
})

import com.couchbase.client.java.document.json.JsonObject
import com.couchbase.client.java.document.json.JsonArray
import com.couchbase.client.java.document.json.JsonValue
import com.couchbase.client.java.document.json.JsonObject
import com.couchbase.client.java.document.json.JsonArray
import com.couchbase.client.java.query.N1qlQueryRow
import com.couchbase.client.java.query.AsyncN1qlQueryResult

val mapper = new ObjectMapper()

val scalaObjects: Seq[ScalaObject] = result.rows().map(row => {
  val json = row.value()
  val scalaObject = mapper.readValue(json.toString, classOf[ScalaObject])
  scalaObject
}).toSeq