package com.chm.mongo.mongo;

import java.util.Iterator;

import com.chm.mongo.db.MongodbConn;
import com.mongodb.BasicDBList;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;

import com.mongodb.DBObject;
import com.mongodb.MongoException;

import com.mongodb.WriteConcern;
import com.mongodb.WriteResult;

public class ProductMongo1 {
	
	private static DB db = MongodbConn.getConnection();
	
/*        */
	public int getCheck1(String name){
		
		DBCollection col = db.getCollection("Product");
		BasicDBObject cc = new BasicDBObject();
		cc.put("prodname", name);
		int res1 =0;
		String ss1 = null;
		DBCursor cursor = col.find(cc);
		
		while(cursor.hasNext())
		{
		
			System.out.println("**********prodname"+cursor.next().get("prodid"));
		DBObject ss =  cursor.next();
			 ss1 = (String) ss.get("prodid");
			System.out.println(ss1);
			
		}
		System.out.println(ss1);
		//System.out.println("**res**"+res1);
		
		
		return res1;
	}
	
	

	
	

	public static void main(String[] args) {
		ProductMongo1 pm = new ProductMongo1();
		String name= "Pampers Small";
		 pm.getCheck1(name);
	}
	

}