sdk-connection-scala.scala

// Couchbase SDK connection singleton — Scala
// Copy and adapt for your application.
//
// Dependencies (build.sbt):
//   libraryDependencies += "com.couchbase.client" %% "scala-client" % "1.7.0"

import com.couchbase.client.scala._
import com.couchbase.client.scala.json.JsonObject
import com.couchbase.client.scala.query.QueryOptions
import scala.concurrent.duration._
import scala.util.{Failure, Success, Try}

// --- Configuration ---
object CouchbaseConfig {
  val host:       String = "localhost"          // or "cb.xxxxx.cloud.couchbase.com" for Capella
  val user:       String = "app-service-user"
  val password:   String = "AppSecret123!"
  val bucket:     String = "myapp"
  val scope:      String = "_default"
  val collection: String = "_default"
  // Use "couchbases://" for TLS (required for Capella, recommended for production)
  val scheme:     String = "couchbase"
}

object CouchbaseConnection {
  // Lazy val — initialized once on first access, thread-safe by the JVM
  lazy val cluster: Cluster = {
    val c = Cluster.connect(
      s"${CouchbaseConfig.scheme}://${CouchbaseConfig.host}",
      CouchbaseConfig.user,
      CouchbaseConfig.password
    ).get  // throws on failure — handle in production with match/recover

    c.bucket(CouchbaseConfig.bucket).waitUntilReady(10.seconds)
    c
  }

  lazy val collection: Collection =
    cluster
      .bucket(CouchbaseConfig.bucket)
      .scope(CouchbaseConfig.scope)
      .collection(CouchbaseConfig.collection)

  /** Call on application shutdown to release resources. */
  def close(): Unit = cluster.disconnect()
}

// --- Usage example ---
object Main extends App {
  import CouchbaseConnection._

  // KV upsert
  collection.upsert("doc_1", JsonObject("type" -> "example", "value" -> 42)) match {
    case Success(_)   => println("Upserted")
    case Failure(err) => println(s"Upsert failed: $err")
  }

  // KV get
  collection.get("doc_1") match {
    case Success(result) => println(result.contentAs[JsonObject].get)
    case Failure(err)    => println(s"Get failed: $err")
  }

  // SQL++ query
  cluster.query(
    "SELECT * FROM `myapp`._default._default WHERE type = $type LIMIT 5",
    QueryOptions().parameters(
      com.couchbase.client.scala.query.QueryParameters.Named("type" -> "example")
    )
  ) match {
    case Success(result) =>
      result.rowsAs[JsonObject].get.foreach(println)
    case Failure(err) =>
      println(s"Query failed: $err")
  }

  close()
}