package com.moonlit.example;

import com.mongodb.BasicDBObject;
import com.mongodb.BulkWriteOperation;
import com.mongodb.BulkWriteResult;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.MongoClient;

public class MongodbTest {
    public static void main(String[] args) {
        MongoClient mongoClient = new MongoClient();
        DB db = mongoClient.getDB("mydb");
        DBCollection coll = db.getCollection("testCollection");
        
        // insert a document
        BasicDBObject doc = new BasicDBObject("name", "MongoDB")
                .append("type", "database")
                .append("count", 1)
                .append("info", new BasicDBObject("x", 123).append("y", 456));
        coll.insert(doc);
        
        // find the first document in a collection
        DBObject myDoc = coll.findOne();
        System.out.println(myDoc);
        
        // adding multiple documents
        for (int i = 1; i <= 100; i ++) {
            coll.insert(new BasicDBObject("i", i));
        }
        
        // counting documents in a collection
        System.out.println(coll.getCount());
        
        // using a cursor to get all collection
        DBCursor cursor = coll.find();
        try {
            while (cursor.hasNext())
                System.out.println(cursor.next());
        } finally {
            cursor.close();
        }
        
        // get a single document with a guery
        BasicDBObject query = new BasicDBObject("i", 23);
        cursor = coll.find(query);
        try {
            while (cursor.hasNext()) 
                System.out.println(cursor.next());
        } finally {
            cursor.close();
        }
        
        query = new BasicDBObject("j", new BasicDBObject("$ne", 93))
                .append("i", new BasicDBObject("$gt", 90));
        cursor = coll.find(query);
        try {
            while (cursor.hasNext())
                System.out.println(cursor.next());
        } finally {
            cursor.close();
        }
        
        query = new BasicDBObject("i", new BasicDBObject("$ne", 93).append("$gt", 90));
        
        cursor = coll.find(query);
        try {
            while (cursor.hasNext())
                System.out.println(cursor.next());
        } finally {
            cursor.close();
        }

//        // delete all 
//        cursor = coll.find();
//        try {
//            while (cursor.hasNext())
//                coll.remove(cursor.next());
//        } finally {
//            cursor.close();
//        }
//        
//        // count
//        System.out.println(coll.getCount());
        
//        BulkWriteOperation builder = coll.initializeOrderedBulkOperation();
//        builder.insert(new BasicDBObject("_id", 1));
//        builder.insert(new BasicDBObject("_id", 2));
//        builder.insert(new BasicDBObject("_id", 3));
        
//        builder.find(new BasicDBObject("_id", 1)).updateOne(new BasicDBObject("$set", new BasicDBObject("x", 123)));
//        builder.find(new BasicDBObject("_id", 2)).remove();
//        builder.find(new BasicDBObject("_id", 3)).replaceOne(new BasicDBObject("_id", 3).append("x", 4));
        
//        BulkWriteResult result = builder.execute();
        
        
    }
}