import java.net.UnknownHostException;
import com.mongodb.Mongo;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.MongoException;


public class TestMongDBCase {

	/**
	 * @param args
	 * @throws MongoException 
	 * @throws UnknownHostException 
	 * 
	 */
	private static String host="localhost";
	private static int port=27017;
	private static String dbName="test";
	
	public static DBCollection getConnection(String host,int port,String dbName) 
		   throws UnknownHostException, MongoException{
		Mongo db = new Mongo(host, port);
		DBCollection coll=db.getDB(dbName).getCollection("testCollection");
		System.out.println(coll );
		return coll;
		
	}
	
	public void getOneData () throws  Exception{
		DBCollection coll=getConnection(host, port, dbName);
		DBObject myDoc = coll.findOne();
		System.out.println(myDoc);
	}
	
	public void getAllData () throws  Exception{
		DBCollection coll=getConnection(host, port, dbName);
		DBCursor myDoc = coll.find();
		while(myDoc.hasNext()){
			System.out.println(myDoc.next());
		}
	}
	
	
	public void getDeleteData () throws  Exception{
		DBCollection coll=getConnection(host, port, dbName);
		BasicDBObject delete = new BasicDBObject();
		delete.put("name", "MongoDB");
		 coll.remove(delete);
		 
	}
	public void getQuery () throws  Exception{
		DBCollection coll=getConnection(host, port, dbName);
		BasicDBObject query = new BasicDBObject();
		query.put("name", "MongoDB");
		DBCursor cur = coll.find(query);
		while(cur.hasNext()){
		 System.out.println(cur.next());
		}
	}
	
	public void addData () throws  Exception{
		BasicDBObject doc = new BasicDBObject();
		doc.put("name", "MongoDB");
		doc.put("type", "database");
		doc.put("count", 1);
		BasicDBObject info = new BasicDBObject();
		info.put("x", 203);
		info.put("y", 102);
		doc.put("info", info);
		DBCollection coll=getConnection(host, port, dbName);
		coll.insert(doc);
	}
	
	
	public static void main(String[] args) throws Exception {
		new TestMongDBCase ().getDeleteData();
		new TestMongDBCase ().getQuery();
		new TestMongDBCase ().getAllData();
		new TestMongDBCase ().getOneData();
		new TestMongDBCase ().addData();
		
			 
	}

}