Couchbase Playground

Kotlin - Upsert

Given a document's key, you can use the collection.upsert() function to create/update a document in a collection.

See more at the SDK documentation on Kotlin Getting Started.

API reference can be found here.

To run this example, click the button in the top right corner of the code editor.

Code Editor

import com.couchbase.client.kotlin.Cluster
import com.couchbase.client.kotlin.query.execute
import kotlinx.coroutines.runBlocking

public fun main() {
    
    val connectionString = "couchbase://127.0.0.1"
    val username = "username"
    val password = "password"

    val cluster = Cluster.connect(connectionString, username, password)
    
    try {
        val bucket = cluster.bucket("travel-sample")
        val collection = bucket.defaultCollection()

        runBlocking {
          val content = mapOf( 
            "country" to "Iceland",
            "callsign" to "ICEAIR", 
            "iata" to "FI",
            "icao" to "ICE",
            "id" to 123,
            "name" to "Icelandair",
            "type" to "airline"
          )

          collection.upsert("airline_123", content)
          println("UPSERT SUCCESS")
          val getResult = collection.get("airline_123")
          println(getResult.contentAs<Map<String, Any?>>())
        }
    } finally {
      runBlocking { cluster.disconnect() }
    }
}

Kotlin - Upsert

Code Editor

Output