mongodb高级操作及在Java企业级开发中的应用.

Java连接mongoDB

package org.dennisit.mongodb.study;import com.mongodb.BasicDBObject;import com.mongodb.DB;import com.mongodb.DBCollection;import com.mongodb.Mongo;/** * * MongoDBUtil.java * *功 能： Java连接MongoDB小Demo(连接并插入一条数据) *类 名： MongoDBUtil * * ver変更日角色担当者変更内容 *────────────────────────────────────────────── * V1.00 2013-1-16 Demo模块 苏若年初版 * *Copyright (c) 2013 dennisit corporation All Rights Reserved. ** Email:<a href=”mailto:DennisIT@163.com”>发送邮件</a> * MongoDBUtil { main(String[] args) {Mongo mongo = null;try {//通过连接字符串得到一个数据库实例的连接mongo = new Mongo(“127.0.0.1”,27017);} catch (Exception e) {e.printStackTrace();}//获得一个数据库对象,mydb为数据库民称DB db = mongo.getDB(“mydb”);//指定安全授权信息[mydb数据库的用户名为mydbusr,密码为123]db.authenticate(“mydbusr”, “123”.toCharArray());//声明一个collection对象DBCollection collection = db.getCollection(“user”);//声明一个document文档对象,用户存储数据BasicDBObject doc = new BasicDBObject();doc.put(“name”, “suruonian”);doc.put(“email”, “dennisit@163.com”);BasicDBObject experience = new BasicDBObject();experience.put(“year of 2012”, “i work in hangzhou”);experience.put(“year of 2013”, “i work in shenzhen”);doc.put(“work experience”, experience);//调用collection的insert方法,将数据持久化到磁盘上.collection.insert(doc);System.out.println(“test data insert finish “);}}这时登录到mydb.查看> db.user.find({},{_id:0});{ “name” : “suruonian”, “email” : “dennisit@163.com”, “work experience” : { “year of 2012” : “i work in hangzhou”, “year of 2013” : “i work in shenzhen” } }>

mongoDB查询数据

通过findOne()查询一条数据

//连接到mongodb//获得一个数据库对象,mydb为数据库民称DB db = mongo.getDB(“mydb”);//指定安全授权信息[mydb数据库的用户名为mydbusr,密码为123]db.authenticate(“mydbusr”, “123”.toCharArray());//声明一个collection对象DBCollection collection = db.getCollection(“user”);DBObject userdoc= collection.findOne();System.out.println(“查询到的一条记录为:” + userdoc);

mongoDB更新数据

//连接到mongodb//声明collection对象DBCollection collection = db.getCollection(“user”);//定义一个查询对象,DBObject updateAim = new BasicDBObject();updateAim.put(“name”, “suruonian”);System.out.println(“通过用户名查找到的对象为:” + collection.findOne(updateAim));//定义一个更新对象,类似于set语句DBObject updatedValue = new BasicDBObject();updatedValue.put(“name”, “dennisit”);//db.user.update({name：”suruonian”},{$set:{name：dennisit}});DBObject updateSetValue = new BasicDBObject(“$set”,updatedValue);//将查询对象和更新对象作为参数传给update来完成更新.collection.update(updateAim, updateSetValue);System.out.println(“更新后查询到的一条记录为:” + collection.findOne());

mongoDB删除数据

//连接到mongodb//声明collection对象DBCollection collection = db.getCollection(“user”);//定义一个查询对象,DBObject aimObj = new BasicDBObject();aimObj.put(“name”, “dennisit”);System.out.println(“通过用户名查找到的对象为:” + collection.findOne(aimObj));collection.remove(aimObj);System.out.println(“删除后查询到的一条记录为:” + collection.findOne());

MonggoDB保证事物的一致性

//声明collection对象DBCollection collection = db.getCollection(“user”);//开始事务控制db.requestStart();//事务相关操作//结束事物控制db.requestDone();

MongoDB库级别操作

获取连接的IP地址

mongo.getAddress();

mongo.getDatabaseNames();

mongo.dropDatabase(“testdb”);

代码演示

我想，旅行需要孤独，需要一个人慢慢体会，静静思考。