Below
snippet query for all the documents where “_id” is 1 or 3 or 4.
BasicDBObject
query = new BasicDBObject();
List<Integer>
ids = new ArrayList<Integer> ();
ids.add(1);
ids.add(3);
ids.add(4);
query.put("_id",
new BasicDBObject("$in", ids));
/*
Get all documents */
DBCursor
cursor = collection.find(query);
import java.net.UnknownHostException; import java.util.List; import java.util.ArrayList; import com.mongodb.BasicDBObject; import com.mongodb.DBCursor; import com.mongodb.MongoClient; import com.mongodb.DB; import com.mongodb.DBCollection; public class FindDocument { /* Step 1 : get mongoClient */ public static MongoClient getMongoClient(){ MongoClient mongoClient = null; try { mongoClient = new MongoClient( "localhost" , 27017 ); } catch (UnknownHostException e) { e.printStackTrace(); } return mongoClient; } public static void main(String args[]){ MongoClient mongoClient = getMongoClient(); /* Step 2: Connect to DB */ DB db = mongoClient.getDB("sample"); /*Step 3 : Get collection */ DBCollection collection = db.getCollection("employee"); /* Step 4 : Create Query object */ BasicDBObject query = new BasicDBObject(); List<Integer> ids = new ArrayList<Integer> (); ids.add(1); ids.add(3); ids.add(4); query.put("_id", new BasicDBObject("$in", ids)); /* Step 5 : Get all documents */ DBCursor cursor = collection.find(query); /* Step 6 : Print all documents */ while(cursor.hasNext()){ System.out.println(cursor.next()); } } }
Output
{ "_id" : 1.0 , "firstName" : "Joel" , "lastName" : "chelli"} { "_id" : 3.0 , "firstName" : "Gopi" , "lastName" : "Battu"} { "_id" : 4.0 , "firstName" : "Ritwik" , "lastName" : "Mohenthy"}
No comments:
Post a Comment