package main.java.com.couchbase;

import com.couchbase.client.java.CouchbaseCluster;
import com.couchbase.client.java.Cluster;
import com.couchbase.client.java.Bucket;
import com.couchbase.client.java.bucket.BucketManager;
import com.couchbase.client.java.document.JsonDocument;
import com.couchbase.client.java.document.json.JsonObject;
import com.couchbase.client.java.query.QueryResult;
import com.couchbase.client.java.query.Query;
import static com.couchbase.client.java.query.Select.select;
import com.couchbase.client.java.query.QueryParams;
import com.couchbase.client.java.query.consistency.ScanConsistency;
import static com.couchbase.client.java.query.dsl.Expression.i;
import static com.couchbase.client.java.query.dsl.Expression.x;
import static com.couchbase.client.java.query.dsl.Expression.s;

import java.util.logging.*;


/**
 * Created by subhashni on 8/28/14.
 */
public class QueryTest {
    public static void main(String[] args) {
        Logger logger = Logger.getLogger("com.couchbase.client");
        logger.setLevel(Level.FINEST);
        for(Handler h : logger.getParent().getHandlers()) {
            if(h instanceof ConsoleHandler){
                h.setLevel(Level.FINEST);
            }
        }
        // Connect to the Cluster
        Cluster cluster = CouchbaseCluster.fromConnectionString("couchbase://172.23.107.58");
        // Open the travel-sample bucket
        Bucket bucket = cluster.openBucket("travel-sample");

        for (int i = 0; i < 30; i++) {
            // Create a new airline (document)
            bucket.upsert(JsonDocument.create("airline" + i, JsonObject.create()
                            .put("id", "id" + i)
                            .put("type", "airline")
                            .put("name", "Couchbase Airways")
                            .put("iata", "CBX")
                            .put("icao", "CBX")
                            .put("callsign", "COUCH-BASE")
                            .put("country", "United States")
            ));
        }


        // Perform the Query
        QueryResult result = bucket.query(
                Query.simple(select("*").from(i(bucket.name())).where(x("iata").eq(s("CBX"))),
                        QueryParams.build().consistency(ScanConsistency.REQUEST_PLUS))
        );



        System.out.println("rows count:" + result.allRows().size()));
    }
 }