import com.couchbase.client.java.Bucket; import com.couchbase.client.java.Cluster; import com.couchbase.client.java.CouchbaseCluster; import com.couchbase.client.java.document.JsonDocument; import com.couchbase.client.java.document.json.JsonObject; import com.couchbase.client.java.env.CouchbaseEnvironment; import com.couchbase.client.java.env.DefaultCouchbaseEnvironment; CouchbaseEnvironment env = DefaultCouchbaseEnvironment.builder() .build(); JsonObject jsonObject = JsonObject.create().put("key", "value"); JsonDocument document = JsonDocument.create("document-key", jsonObject); bucket.upsert(document); JsonDocument cachedDocument = bucket.get("document-key"); bucket.close(); cluster.disconnect(); JsonDocument cachedDocument = bucket.get("document-key"); System.out.println("Current Value: " + cachedDocument.content()); cachedDocument.content().put("key", "new-value"); JsonDocument updatedDocument = bucket.replace(cachedDocument); if (updatedDocument != null) { System.out.println("Update successful"); } else { System.out.println("Update failed due to concurrent modification"); }