import com.couchbase.client.java.Bucket;
import com.couchbase.client.java.CouchbaseCluster;
import com.couchbase.client.java.document.Document;
import com.couchbase.client.java.document.LegacyDocument;
import com.couchbase.client.java.transcoder.LegacyTranscoder;
import com.couchbase.client.java.transcoder.Transcoder;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

public class Test {

    public static void main(String[] args) {

        String bucketName = "beer-sample";
        String bucketPassword = "";
        List<String> nodes = Arrays.asList("192.168.61.101");

        List<Transcoder<? extends Document, ?>> transcoders = new ArrayList<>();
        transcoders.add(new LegacyTranscoder(300));

        CouchbaseCluster cluster = CouchbaseCluster.create(nodes);
        Bucket bucket = cluster.openBucket(bucketName, bucketPassword, transcoders);

        String id = "my_user_id";
        User user = new User("Dean");
        LegacyDocument doc = LegacyDocument.create(id, user);
        bucket.upsert(doc);

        LegacyDocument found = bucket.get(id, LegacyDocument.class);
        System.out.println(((User) found.content()).getFirstname());

        bucket.close();
        cluster.disconnect();
    }

    static class User implements Serializable {

        private final String firstname;

        User(String firstname) {
            this.firstname = firstname;
        }

        public String getFirstname() {
            return firstname;
        }
    }
}