java 操作mongoDB(DBobject,非spring data)

  上篇博客介绍了Java操作MongoDB进行对文件的处理。现在来介绍一下对文档的处理。和对文件的处理一样，也是通过java驱动中提供的几个类相互作用完成的。这几个类分别是：
      DBCollection类：指定数据库中指定集合的实例，提供了增删改查等一系列操作。在关系型数据库中，对数据的增删改查操作是建立在表的基础上的，在mongodb中是建立在集合的基础上进行的。
      DBObject接口：DBObject是键值的映射，因此，可以将DBObject的实现类作为查询的返回结果，也可以作为查询条件
      DBCursor：游标，返回结果的集合。
    下面是部分实例：

[java] view
plain copy

Mongo mongo = new Mongo();  

DB db = mongo.getDB("myMongoDB");  

DBCollection course = db.getCollection("course");//对myMongoDB数据库中course集合进行操作  

  

  

  

//添加操作  

//下面分别是创建文档的几种方式：1. .append()  2. .put()   3. 通过map   4. 将json转换成DBObject对象  

DBObject english = new BasicDBObject().append("name","english").append("score", 5).append("id",1);  

course.insert(english);  

          

DBObject math = new BasicDBObject();  

math.put("id", 2);  

math.put("name", "math");  

math.put("score", 10);  

course.insert(math);  

          

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

map.put("name","physics" );  

map.put("score", 10);  

map.put("id", 3);  

DBObject physics= new BasicDBObject(map);  

course.insert(physics);  

          

String json ="{'name':'chemistry','score':10,'id':4}";  

DBObject chemistry =(DBObject)JSON.parse(json);  

course.insert(chemistry);  

          

List<DBObject> courseList = new ArrayList<DBObject>();  

DBObject chinese = new BasicDBObject().append("name","chinese").append("score", 10).append("id", 5);  

DBObject history = new BasicDBObject().append("name", "history").append("score", 10).append("id", 6);  

courseList.add(chinese);  

courseList.add(history);  

course.insert(courseList);  

          

//添加内嵌文档  

String json2 =" {'name':'english','score':10,'teacher':[{'name':'柳松','id':'1'},{'name':'柳松松','id':2}]}";  

DBObject english2= (DBObject)JSON.parse(json);  

course.insert(english2);  

          

List<DBObject> list = new ArrayList<DBObject>();  

list.add(new BasicDBObject("name","柳松").append("id",1));  

list.add(new BasicDBObject("name","柳松松").append("id",2));  

DBObject english3= new BasicDBObject().append("name","english").append("score",10).append("teacher",list);  

          

          

//查询  

//查询所有、查询一个文档、条件查询  

DBCursor cur = course.find();  

while(cur.hasNext()){  

      DBObject document = cur.next();  

      System.out.println(document.get("name"));  

  }  

          

DBObject document = course.findOne();  

String name=(String)document.get("name");  

System.out.println(name);  

          

          

//查询学分=5的  

DBObject query1 = new BasicDBObject("score",5);  

DBObject query2 = new BasicDBObject("score",new BasicDBObject("$gte",5));  

DBCursor cur2 = course.find(query2);  

//条件表达式：$ge(>)  $get(>=)  $lt(<)  $lte(<=)  $ne(<>)  $in  $nin  $all $exists $or  $nor $where $type等等  

          

  

//查找并修改       

DBObject newDocument = course.findAndModify(new BasicDBObject("score",5), new BasicDBObject("score",15));  

  

//更新操作        

//q：更新条件  o:更新后的对象  

course.update(new BasicDBObject("score",10), new BasicDBObject("test",15));  

course.update(new BasicDBObject("score",15), new BasicDBObject("$set",new BasicDBObject("isRequired",true)));  

//两个的区别是，第一个更新是将{"test":15}这个文档替换原来的文档，  

//第二个更新添加了条件表达式$set，是在原来文档的基础上添加"isRequired"这个键  

//条件表达式：$set  $unset  $push  $inc  $push $push  $addToSet  $pull $pullAll  $pop等等  

  

//当_id相同时，执行save方法相当于更新操作  

course.save(new BasicDBObject("name","math").append("_id", 1));  

course.save(new BasicDBObject("name","数学").append("_id", 1));  

  

          

          

//删除符合条件的文档  

course.remove(new BasicDBObject("score",15));  

          

//删除集合及所有文档  

course.drop();<span style="font-family:Arial, Helvetica, sans-serif;"><span style="white-space: normal;">  

</span></span>  

        上面只是介绍了一些简单的操作，具体复杂的查询更新可以根据需求再去查找文档资料。其实，不管操作简单还是复杂，其核心都是对DBObject和DBCollection的操作，主要掌握DBObject如何构造键值对，以及一些条件表达式。