mongoDB入门（转）

转自：http://zhangxxheng.iteye.com  转载请注明出

心血来潮，看了看mongoDB 的相关内容，写了个入门级的demo.用来备忘！

一：如何安装mongoDB服务

1.下载mongodb的windows版本，有32位和64位版本，根据系统情况下载,下载地址：htp://www.mongodb.org/downloads 我这里的是 32 的

2.解压缩至F:/mongodb即可(这个位置 可以随便，就像平时安装软件解压一样没有特殊的要求)

3.创建数据库文件的存放位置，比如E:/mongodb/data/db。启动mongodb服务之前需要必须创建数据库文件的存放文件夹，否则命令不会自动创建，而且不能启动成功。默认文件夹路径为c:/data/db.使用系统默认文件夹路径时，启动服务无需加--dbpath 参数说明，但文件夹还要手工创建

4.打开cmd命令行，进入D:/mongodb/bin目录，输入如下的命令启动mongodb服务：

D:\Program Files\mongodb\bin>mongod.exe --dbpath D:/mongodb/data/db （此处注意是mongod.exe  不是 mongo.exe  ）

输入命令后屏幕上会显示 如下内容表示启动mongo服务成功了，如果要关闭该服务只需要关闭显示这些内容的窗口就行了。

 

Fri Aug 09 09:14:44 [initandlisten] MongoDB starting : pid=3708 port=27017 dbp

h=D:/mongodb/data/db 32-bit

 

** NOTE: when using MongoDB 32 bit, you are limited to about 2 gigabytes of da

 

**       see http://blog.mongodb.org/post/137788967/32-bit-limitations

**       with --dur, the limit is lower

 

Fri Aug 09 09:14:44 [initandlisten] db version v1.8.5, pdfile version 4.5

Fri Aug 09 09:14:44 [initandlisten] git version: 403c8dadcd56f68dcbe06013ecbfa

7b32a22ac

Fri Aug 09 09:14:44 [initandlisten] build sys info: windows sys.getwindowsvers

n(major=6, minor=0, build=6002, platform=2, service_pack='Service Pack 2') BOO

_LIB_VERSION=1_42

Fri Aug 09 09:14:44 [initandlisten] waiting for connections on port 27017

Fri Aug 09 09:14:44 [websvr] web admin interface listening on port 28017

Fri Aug 09 09:15:12 [initandlisten] connection accepted from 127.0.0.1:3059 #1

Fri Aug 09 09:15:12 [conn1] query zh.$cmd ntoreturn:1 command: { count: "testC

llection", query: {} } reslen:64 138ms

Fri Aug 09 09:15:12 [conn1] end connection 127.0.0.1:3059

Fri Aug 09 09:15:35 [initandlisten] connection accepted from 127.0.0.1:3060 #2

Fri Aug 09 09:15:35 [conn2] end connection 127.0.0.1:3060

Fri Aug 09 09:16:15 [initandlisten] connection accepted from 127.0.0.1:3061 #3

Fri Aug 09 09:16:15 [conn3] end connection 127.0.0.1:3061

Fri Aug 09 09:21:37 [initandlisten] connection accepted from 127.0.0.1:3085 #4

Fri Aug 09 09:21:37 [conn4] end connection 127.0.0.1:3085

Fri Aug 09 09:29:39 [initandlisten] connection accepted from 127.0.0.1:3124 #5

Fri Aug 09 09:29:39 [conn5] end connection 127.0.0.1:3124

到这里 就表示启动服务成功了，当然你下次开机或者关闭了这个窗口的时候 ，需要使用就必须再次使用启动服务的命令。

二：入门开发：

在进行开发之前需要导入包 ：mongo-2.10.1.jar

我这里有jar包，案例代码，pdf学习手册。

接下来可以进行开发了。

package com.cyou.mongdb.test;

import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import com.mongodb.BasicDBObject;
import com.mongodb.BasicDBObjectBuilder;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.Mongo;

public class MongoUser {

      private Mongo mongo = null;
      private DB db = null;
      private DBCollection conllection = null;

      /**
       * init:初始化mongo. <br/>
       *
       * @author zhangheng
       * @param host 主机
       * @param port 端口号
       * @since JDK 1.6
       */
      public void init(String host, int port, String dbName, String collectionName){
        try {
          if (mongo == null) {
            // 是使用本地地址和默认端口号相当于//mg = new Mongo("localhost", 27017)
            mongo = new Mongo();
          }

        } catch (UnknownHostException e) {
          // TODO Auto-generated catch block
          e.printStackTrace();
        }
        // 获取temp DB；如果默认没有创建，mongodb会自动创建
        db = mongo.getDB(dbName);
        // 获取users DBCollection；如果默认没有创建，mongodb会自动创建
        conllection = db.getCollection(collectionName);
      }

      /**
       * destroy:销毁mongo对象. <br/>
       *
       * @author zhangheng
       * @since JDK 1.6
       */
      public void destroy(){
        if (mongo != null) {
          mongo.close();
          mongo = null;
          db = null;
          conllection = null;
          // 通知垃圾回收机制回收
          System.gc();
        }
      }

      public DBObject getBDbObject(){
        return null;
      }

      /**
       * add:添加一个记录. <br/>
       *
       * @author zhangheng
       * @since JDK 1.6
       */
      //通过BasicDBObject的方式向mongo中插入数据
      public void addToBasicDBObject(BasicDBObject document,DBCollection dbCollection){
          dbCollection .insert(document);
      }
    //通过BasicDBObjectBuilder的方式向mongo中插入数据
      public void addToBasicDBObjectBuilder(BasicDBObjectBuilder document,DBCollection dbCollection){
          dbCollection .insert(document.get());
      }
      //通过Map的方式向mongo中插入数据
      public void addToMap(Map documentMap,DBCollection dbCollection){
          dbCollection .insert(new BasicDBObject(documentMap));
      }
      /**
       * cursorIterator:根据游标的位置输出遍历的集合. <br/>
       *
       * @author zhangheng
       * @param cur
       * @since JDK 1.6
       */
      public void cursorIterator(DBCursor cur){
        while (cur.hasNext()) {
          System.out.println(cur.next());
        }
      }

      /**
       * queryAll:查询集合中的所有元素). <br/>
       *
       * @author zhangheng
       * @param dbCollection
       * @return
       * @since JDK 1.6
       */
      public DBCursor queryAll(DBCollection dbCollection){
        DBCursor cur = dbCollection.find();
        return cur;
      }

      /**
       * getCount:获得文档中的记录条数. <br/>
       *
       * @author zhangheng
       * @param collection
       * @return
       * @since JDK 1.6
       */
      public long getCount(DBCollection collection){
        return collection.count();
      }

      /**
       * remove:根据DBCollection对象从集合中删除对象. <br/>
       *
       * @author zhangheng
       * @param dbObject 纪录
       * @param dbCollection 集合名
       * @since JDK 1.6
       */
      public void remove(DBObject dbObject, DBCollection dbCollection){
        dbCollection.remove(dbObject);
      }


      //更新
      public void update(BasicDBObject frontDBObject,BasicDBObject afartDBObject,DBCollection dbCollection){
          dbCollection.update(frontDBObject,afartDBObject);
      }
        // 第三个参数-----如果数据库不存在，是否添加
        // 第四个参数-----多条修改false
      public void motify(BasicDBObject frontDBObject, BasicDBObject afartDBObject,
          DBCollection dbCollection,boolean isExist,boolean allMotify){
        dbCollection.update(frontDBObject, afartDBObject, isExist, allMotify);
      }

      /**
       * find:根据DBCollection查找. <br/>
       *
       * @author zhangheng
       * @param dbObject
       * @param dbCollection
       * @return
       * @since JDK 1.6
       */
      public DBCursor getDocument(BasicDBObject dbObject, DBCollection dbCollection){
        return dbCollection.find(dbObject);
      }

      //获得第一条记录
      public DBObject getFirstDocument(DBCollection dbCollection){
          return dbCollection.findOne();
      }
      /**
       * setReadOnly:设置数据库是否为可读. <br/>
       *
       * @author zhangheng
       * @param db 数据库
       * @param bo true/false
       * @since JDK 1.6
       */
      public void setReadOnly(DB db, boolean bo){
        db.setReadOnly(bo);
      }

      public Mongo getMongo(){
        return mongo;
      }

      public DB getDb(String dbName){
        return db;
      }

      public DBCollection getUsers(){
        return conllection;
      }


    }

接下来我在这个类中建立里 main方法 用来测试。

添加的方法 ，把数据添加到数据库中

/**
       * main:进行一些测试. <br/>
       *
       * @author zhangheng
       * @param args
       * @since JDK 1.6
       */
      public static void main(String[] args){

try {
    mongoTest = new MongoUser();
    mongoTest.init(null, 0, "zh", "testConllection");

    System.out.println("集合中文档的数量"+mongoTest.getCount(mongoTest.conllection));
    System.out.println("==========================================================");
    //添加
    BasicDBObject document =   new BasicDBObject();
    document.put("name", "zhang");
    document.put("age", 20);
    document.put("sex", "famale");
    document.put("isStudents", true);
    mongoTest.addToBasicDBObject(document, mongoTest.conllection);

    BasicDBObjectBuilder  document1 =   new BasicDBObjectBuilder ();
    document1.append("name", "li").append("age", 22).append("sex", "male").append("isStudents", true);
    mongoTest.addToBasicDBObjectBuilder(document1, mongoTest.conllection);

    Map<String ,Object> document2 = new HashMap<String,Object>();
    document2.put("name", "zhang");
    document2.put("age", 21);
    document2.put("sex", "famale");
    document2.put("isStudents", true);
    mongoTest.addToMap(document2, mongoTest.conllection);


} catch (Exception e) {
} finally {
    mongoTest.destroy();
}

接下来分别是 查找 修改 删除 的测试在进行这些测试之前我 前调用了显示 全部记录的方法可以清晰的看见操作的结果。

//输出所有的数据信息
 DBCursor dbc =  mongoTest.queryAll(mongoTest.conllection);
 System.out.println("输出所有记录：");
 mongoTest.cursorIterator(dbc);

 查找的方法有一般有这几种，还有的没有列出来。

//查找
            //获得第一个位置上的记录
            DBObject getFirstOne = mongoTest.getFirstDocument(mongoTest.conllection);
            System.out.println("获得第一条记录"+getFirstOne.toString());

            System.out.println("===================");
            //根据指定的条件查询相应的值 此处为查询name 为 li 的记录 相当于sql中where 列= **；
            BasicDBObject query1 = new BasicDBObject();
            query1.put("name", "li");
            DBCursor dbCursor1 =mongoTest.getDocument(query1, mongoTest.conllection);
            while(dbCursor1.hasNext()){
                System.out.println("根据条件查询 ---1："+dbCursor1.next());
            }

            System.out.println("===================");
            //查询  介于 年龄在20 和 22 的 记录，相当于sql中的 where 条件中的in
            BasicDBObject query2 = new BasicDBObject();
            List list = new ArrayList();
            list.add(22);
            list.add(20);
            query2.put("age", new BasicDBObject("$in",list));
            DBCursor dbCursor2 =mongoTest.getDocument(query2, mongoTest.conllection);
            while(dbCursor2.hasNext()){
                System.out.println("根据条件查询 ---2"+dbCursor2.next());
            }


            System.out.println("===================");
            //根据大于小于查询  ">" (大于号) "$gt"  "<"(小于号)"$lt"
            //查询年龄大于21的值
            BasicDBObject query3 = new BasicDBObject();
            query3.put("age", new BasicDBObject("$gt",21));
            DBCursor dbCursor3 =mongoTest.getDocument(query3, mongoTest.conllection);
            while(dbCursor3.hasNext()){
                System.out.println("根据条件查询 ---3"+dbCursor3.next());
            }
            //查询年龄大于20 小于 22的值
            BasicDBObject query4 = new BasicDBObject();
            query4.put("age", new BasicDBObject("$gt",20).append("$lt", 22));
            DBCursor dbCursor4 =mongoTest.getDocument(query4, mongoTest.conllection);
            while(dbCursor4.hasNext()){
                System.out.println("根据条件查询 ---4"+dbCursor4.next());
            }

修改

System.out.println("===================");
//更新
//如果是更新整条数据的话，需要把所有的属性都要更新。如果其中的某个属性不写 的话 就是认为去掉该属性

BasicDBObject update1 =new BasicDBObject();
update1.put("name", "lily");
update1.put("age", 5);
update1.put("sex", "male");
update1.put("isStudents", false);
mongoTest.update(new BasicDBObject().append("name", "lily"), update1,mongoTest.conllection);

//在原来属性的基础添加值 更新 使用  "$inc"  类似于大于小于的比较
BasicDBObject update2 = new  BasicDBObject().append("$inc", new BasicDBObject().append("age", 7));
mongoTest.update(new BasicDBObject().append("name", "lily"), update2,mongoTest.conllection);


//利用set  改变某一属性的 值
BasicDBObject update3 = new  BasicDBObject().append("$set", new BasicDBObject().append("isStudents", true));
mongoTest.update(new BasicDBObject().append("name", "lily"), update3,mongoTest.conllection);

 删除 删除的方法写的比较简单。因为跟查找很像。$lt 表示 小于 前面说过

//删除 方法和 查找方法极为类似
            BasicDBObject remove1 = new BasicDBObject();
            remove1.put("age", new BasicDBObject("$lt",20));
            mongoTest.remove(remove1, mongoTest.conllection);

删除数据库中所有的记录，我用的方法是 查出来所有记录逐一删除

//先查询出所有的内容然后 删除
          DBCursor dbc1 =  mongoTest.queryAll(mongoTest.conllection);
          while(dbc1.hasNext()){
              mongoTest.remove(dbc1.next(), mongoTest.conllection);
          }

这里上传的附件限制大小，具体内容在<a style="font-size: 1em; line-height: 1.5;" href="http://download.csdn.net/detail/zhangxxheng/5899041">http://download.csdn.net/detail/zhangxxheng/5899041</a>