mongodb之java基本操作

mongodb由于其存储大量数据，支持高并发，弱事务的特性，受到很多程序人的喜欢。

对于java来说需要下载java-mongo的驱动包，类似mysql驱动包，里面包含java操作mongo的工具类。

驱动包版本为3.0以下的使用DBCollection。。。

驱动包版本为3.0以上的使用MongoCollection Document。。。

本人习惯使用3.0版本以下的，如下：

DBCollection类：指数据库中的集合，提供获取集合表的基本方法，在关系性数据库来说是表，非关系性数据库就是集合；

DBObject类：指集合中的一个文档，通俗来讲，数据库表中的一条记录值；

DBCursor类：指游标返回的文档集合。

使用：

连接服务

//连接到mongodb服务
Mongo mongo=new MongoClient("10.20.8.121",20000);
//连接到数据库
DB db=mongo.getDB("myMongoDB");
//对myMongoDB数据库中course集合进行操作
DBCollection course = db.getCollection("course");

插入

插入单条数据，主要有四种方式：

1.DBObject .append() 2. DBObject .put() 3. 通过map 4. 将json转换成DBObject对象

插入批量数据使用list

//第一种append
DBObject english = new BasicDBObject().append("name","english").append("score", 5).append("id",1);
course.insert(english);
//第二种put
DBObject math = new BasicDBObject();
math.put("id", 2);
math.put("name", "math");
math.put("score", 10);
course.insert(math);
//第三种map
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);
//第四种json
String json ="{'name':'chemistr
c0b4
y','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);
//查找学分大于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();