import com.couchbase.client.java.Bucket;
import com.couchbase.client.java.Cluster;
import com.couchbase.client.java.CouchbaseCluster;
import com.couchbase.client.java.PersistTo;
import com.couchbase.client.java.ReplicateTo;
import com.couchbase.client.java.document.json.JsonArray;
import com.couchbase.client.java.document.json.JsonObject;
import com.couchbase.client.java.document.subdoc.DocumentFragment;
import com.couchbase.client.java.document.subdoc.ExtendDirection;
import com.couchbase.client.java.error.subdoc.PathExistsException;

public class ArraysAndDicts {

    // Creates a "fleet" array and pushes aircraft into it
    public static void main(String... args) {
        Cluster cluster = CouchbaseCluster.create("127.0.0.1");
        Bucket bucket = cluster.openBucket("travel-sample");

        // insert a fleet array if it does not exist
        DocumentFragment<JsonArray> fragment = DocumentFragment.create("airline_13633", "fleet", JsonArray.empty());
        try {
            bucket.insertIn(fragment, true, PersistTo.NONE, ReplicateTo.NONE);
        } catch (PathExistsException ex) {
            System.out.println("The array already exists, ignoring.");
        }

        // create fleet information
        DocumentFragment<JsonObject> aircraft1 = DocumentFragment.create("airline_13633", "fleet",
            JsonObject.create().put("name", "747-200B").put("heavy", true).put("engines", 4)
        );

        DocumentFragment<JsonObject> aircraft2 = DocumentFragment.create("airline_13633", "fleet",
            JsonObject.create().put("name", "737-200").put("engines", 2)
        );

        // append the aircraft information to the fleet array
        bucket.extendIn(aircraft1, ExtendDirection.BACK, false, PersistTo.NONE, ReplicateTo.NONE);
        bucket.extendIn(aircraft2, ExtendDirection.BACK, false, PersistTo.NONE, ReplicateTo.NONE);
    }
}