Thursday 5 March 2015

mongoDB : javaAPI : in operator example


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"}



Prevoius                                                 Next                                                 Home

No comments:

Post a Comment