MongoDB基础学习（二）MongoDB Java增删查改

Posted on feb. 2 2014

MongoDB基础学习（二）MongoDB Java增删查改 - MongoDB - 数据库技术 - 9SSSD.COM

9SSSD首页

热门搜索： MongoDB学习索引驱动

您的位置: 首页>数据库技术>MongoDB>MongoDB基础学习（二）MongoDB Java增删查改

MongoDB基础学习（二）MongoDB Java增删查改

2012-09-30 00:32 来源：博客园作者：archie2010 字号：T|T

[摘要]本文介绍MongoDB Java增加、删除、查询、修改数据记录，并提供详细的示例代码供参考。

操作

1、查询某张表（在MongoDB中称之为集合）的所有数据

Java代码DBTest.java View Row Code1package com.archie.mongodb;23import java.net.UnknownHostException;45import com.mongodb.DB;6import com.mongodb.DBCollection;7import com.mongodb.DBCursor;8import com.mongodb.DBObject;9import com.mongodb.Mongo;10import com.mongodb.MongoException;1112///13/ 查询指定数据库指定DBCollection集合中的所有数据14/ @author archie201015/16/ since 2012-9-29 下午10:40:2117//18public class DBTest {19public static void main(String[] args) throws UnknownHostException,20MongoException {21///22Mongo实例代表了一个数据库连接池23/ Mongo mg = new Mongo("localhost");24Mongo mg = new Mongo("localhost", 27017);25/*/26Mongo mg = new Mongo();2728// 获取名为“dbtest”的数据库对象29DB db = mg.getDB("dbtest");30// 查询该库中所有的集合 (相当于表)31for (String name : db.getCollectionNames()) {32System.out.println("Collection Name: " + name);33}34DBCollection users = db.getCollection("emp");35// 查询集合中所有的数据36DBCursor cur = users.find();37System.out.println("Record Count:" + cur.count());38while (cur.hasNext()) {39DBObject object = cur.next();40System.out.println(object);41// 取出对象中列表为字段名为'uname'和'upwd'的数据42System.out.println("uname:" + object.get("uname") + "\tupwd:"43+ object.get("upwd"));44}45}46}

运行结果：

MongoDB Java增删查改

2、对指定DBCollection集合的CRUD操作

Java代码DBUtil.java View Row Code1package com.archie.mongodb;23import java.net.UnknownHostException;45import com.mongodb.DB;6import com.mongodb.DBCollection;7import com.mongodb.Mongo;89///10/ 获得DBCollection集合的工具类11/ @author archie201012/13/ since 2012-9-29 下午10:54:4214//15public class DBUtil {1617public static Mongo mg=null;18public static DB db=null;19public static DBCollection collection;2021///22/ 获得DBCollection对象23/ @param dbName24/ @param colName25/ @return26//27public static DBCollection getDBCollection(String dbName,String colName){28if(mg==null){29try {30mg=new Mongo();31} catch (UnknownHostException e) {32e.printStackTrace();33}34}35if(db==null){36db=mg.getDB(dbName);37}38return db.getCollection(colName);39}40}

CRUDTest.java

View Row Code1package com.archie.mongodb;23import com.mongodb.BasicDBObject;4import com.mongodb.DBCollection;5import com.mongodb.DBCursor;6import com.mongodb.DBObject;78///9/ 对指定DBCollection集合的CRUD操作10/ @author archie201011/12/ since 2012-9-29 下午10:51:2413//14public class CRUDTest {15///16/ 增加17/ @param obj18//19public static void add(DBObject obj){20DBCollection coll=DBUtil.getDBCollection("dbtest", "emp");21coll.insert(obj);22}23///24/ 删除25/ @param obj26//27public static void delete(DBObject obj){28DBCollection coll=DBUtil.getDBCollection("dbtest", "emp");29coll.remove(obj);30}31///32/ 查询33//34public static void query(){35DBCollection coll=DBUtil.getDBCollection("dbtest", "emp");36// 查询集合中所有的数据37DBCursor cur = coll.find();38System.out.println("Record Count:" + cur.count());39while (cur.hasNext()) {40DBObject object = cur.next();41System.out.println(object);42// 取出对象中列表为'uname'和'upwd'的数据43System.out.println("uname:" + object.get("uname") + "\tupwd:"44+ object.get("upwd")+"\t_id:"+object.get("_id"));45}46}47///48/ 修改49/*/50public static void modify(DBObject orig,DBObject update){51DBCollection coll=DBUtil.getDBCollection("dbtest", "emp");52coll.update(orig, update, true, false);53}54public static void main(String[] args) {55DBObject empObj=new BasicDBObject();56empObj.put("uname", "teddy");57empObj.put("upwd", "123456");58//添加59add(empObj);60query();616263DBObject updateObj=new BasicDBObject();64updateObj.put("uname", "teddy");65updateObj.put("upwd", "3333");66//更新67modify(new BasicDBObject("uname","teddy"),updateObj);68System.out.println("-----------------------修改后-------------------");69query();7071//删除72delete(new BasicDBObject("uname","teddy"));73System.out.println("-----------------------删除后-------------------");74query();75}76}

运行效果：

MongoDB Java增删查改

示例代码下载

分享到：
QQ微博
QQ空间
新浪微博
白社会
人人网
开心网
豆瓣网
谷歌书签
百度搜藏

相关文章：
MongoDB基础学习（三）MongoDB shell 命令行的使用2012-10-07
MongoDB基础学习（一）安装配置2012-09-30
MongoDB学习(六) MongoDB索引用法和效率分析2012-09-11
MongoDB学习 (五) MongoDB文件存取操作2012-09-11
MongoDB学习(四) 用MongoDB的文档结构描述数据关系2012-09-11
MongoDB学习(三) MVC模式下通过Jqgrid表格操作MongoDB数据2012-09-11 热门搜索: MongoDB学习

上一篇：MongoDB基础学习（一）安装配置下一篇：MongoDB基础学习（三）MongoDB shell 命令行的使用