mongodb之java基本操作

2018-01-24 10:29:57来源:网络收集作者:咖啡不加糖人点击

分享

[var1]

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 map = new HashMap();
map.put("name","physics" );
map.put("score", 10);
map.put("id", 3);
DBObject physics= new BasicDBObject(map);
course.insert(physics);
//第四种json
String json ="{'name':'chemistry','score':10,'id':4}";
DBObject chemistry =(DBObject)JSON.parse(json);
course.insert(chemistry);
//第五种批量插入多条记录
List courseList = new ArrayList();
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 list = new ArrayList();
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();

相关文章

    无相关信息

最新文章

123

最新摄影

闪念基因

微信扫一扫

第七城市微信公众平台