java操作mongoDB查询的实例详解

try {

   System.out.println( "=========********测试3开始**********===========*************" );

   //先获取mongo库的集合DBCollection对象

   DBCollection data = (DBCollection) mongoClientService.getColectionByName( "mongo库集合名称" );

   BasicDBObject query3 = new BasicDBObject();

   query3.put( "name" , "Tom" ); //查找姓名为Tom

   //查询两个时间范围的，用map包装一下

   Map<String, Object> queryMap = new HashMap<>();

   queryMap.put( "$gt" , "1496911821071" );

   queryMap.put( "$lt" , "1496915447871" );

     query3.put( "timeStamp" , new BasicDBObject(queryMap));

     //模糊匹配rule查询

     query3.put( "businessRuleName" , new BasicDBObject( "$regex" , "rule" ));

     DBCursor result3 = data.find(query3);

   String resultCode = "4" ;

   if ( "4" .equals(resultCode)) {

     BasicDBList cond = new BasicDBList();

     cond.add( "0" );

     cond.add( "1" );

     cond.add( "2" );

     cond.add( "3" );

     query3.put( "resultCode" , new BasicDBObject( "$nin" , cond)); //查询resultCode不是0,1,2,3的

   }

     System.out.println(result3.count()); //count()方法得到查询到的记录数

     result3.skip( 10 ).limit( 20 ); //分页，skip():从第几条开始，limit():限制返回的条数

   while (result3.hasNext()) {

     DBObject dbObject = (DBObject) result3.next();

     System.out.println(JSON.serialize(dbObject));

     System.out.println( "------------" );

   }

   System.out.println(result3.count()); //

   System.out.println( "=========********测试3结束**********===========*************" );

} catch (Exception e) {

   e.printStackTrace();

   System.out.println( "---------测试3异常了----------" );

}