mongodb实现简单的增删改查

  package mongoDB;

  import java.net.UnknownHostException;

  import java.util.ArrayList;

  import java.util.List;

  import com.mongodb.BasicDBObject;

  import com.mongodb.DB;

  import com.mongodb.DBCollection;

  import com.mongodb.DBCursor;

  import com.mongodb.DBObject;

  import com.mongodb.Mongo;

  import com.mongodb.MongoException;  

 /**

  * java

  * mongodb的数据插入、读取、更新、删除

  */

  public class test{

     private static Mongo m = null;

     private static DB db = null;  

     //数据集合名称

     private static final String COLLECTION_NAME = "mcpang";  

     /*

      * 测试java处理mongodb的增、删、改、查操作

      */

     public static void main(String[] args) {

         //获取数据库连接

         startMongoDBConn();

         //保存数据

         createColData();

         //读取数据

         readColData();

         //更新数据

         updateColData();

         //读取数据

         readColData();

         //删除数据

         deleteColData();

         //读取数据

         readColData();

         //删除数据集

         db.getCollection(COLLECTION_NAME).drop();

        //关闭数据库连接

         stopMondoDBConn();  

     }  

     /**

      * 数据插入

      * 测试数据：

      * 【name:小李、age:30、address:北京】

      * 【name:小张、age:25、address:天津】

      * @return

      */

     private static void createColData(){

         DBCollection dbCol = db.getCollection(COLLECTION_NAME);

         System.out.println("向数据集中插入数据开始：");

         List<DBObject> dbList = new ArrayList<DBObject>();

         BasicDBObject doc1 = new BasicDBObject();

         doc1.put("name", "小李");

         doc1.put("age", 30);

         doc1.put("address", "北京");

         dbList.add(doc1);  

        BasicDBObject doc2 = new BasicDBObject();

        doc2.put("name", "小张");

        doc2.put("age", 25);

        doc2.put("address", "天津");

        dbList.add(doc2);  

        dbCol.insert(dbList);

        System.out.println("向数据集中插入数据完成！");

        System.out.println("------------------------------");

    }  

    /**

     * 数据读取

     */

    private static void readColData(){

        DBCollection dbCol = db.getCollection(COLLECTION_NAME);

        DBCursor ret = dbCol.find();

        System.out.println("从数据集中读取数据：");

        while(ret.hasNext()){

            BasicDBObject bdbObj = (BasicDBObject) ret.next();

            if(bdbObj != null){

                System.out.println("name:"+bdbObj.getString("name"));

                System.out.println("age:"+bdbObj.getInt("age"));

                System.out.println("address:"+bdbObj.getString("address"));

            }

        }

    }  

    /**

     * 数据更新

     * update(q, o, upsert, multi)

     * update(q, o, upsert, multi, concern)

     * update(arg0, arg1, arg2, arg3, arg4, arg5)

     * updateMulti(q, o)

     */

    private static void updateColData(){

        System.out.println("------------------------------");

        DBCollection dbCol = db.getCollection(COLLECTION_NAME);

        DBCursor ret = dbCol.find();

        BasicDBObject doc = new BasicDBObject();

        BasicDBObject res = new BasicDBObject();

        res.put("age", 40);

        System.out.println("将数据集中的所有文档的age修改成40！");

        doc.put("$set", res);

       dbCol.update(new BasicDBObject(),doc,false,true);

        System.out.println("更新数据完成！");

        System.out.println("------------------------------");

    }  

    /**

     * 数据删除

     */

    private static void deleteColData(){

        System.out.println("------------------------------");

       DBCollection dbCol = db.getCollection(COLLECTION_NAME);

        System.out.println("删除【小李】！");

        BasicDBObject doc = new BasicDBObject();

        doc.put("name", "小李");

        dbCol.remove(doc);

        System.out.println("------------------------------");

    }  

    /**

     * 关闭mongodb数据库连接

     */

    private static void stopMondoDBConn(){

        if (null != m) {

            if (null != db) {

                // 结束Mongo数据库的事务请求

                try {

                    db.requestDone();

                } catch(Exception e) {

                    e.printStackTrace();

                }

           }

            try

            {

                m.close();

            } catch(Exception e) {

                e.printStackTrace();

            }

            m = null;

            db = null;

        }

    }  

    /**

     * 获取mongodb数据库连接

     */

    private static void startMongoDBConn(){

        try {

            //Mongo(p1, p2):p1=>IP地址     p2=>端口

            m = new Mongo("127.0.0.1", 27017);

            //根据mongodb数据库的名称获取mongodb对象

            db = m.getDB("yyl");

            //校验用户密码是否正确

            if (!db.authenticate("yyl", "yyl123".toCharArray())){

                System.out.println("连接MongoDB数据库,校验失败！");

            }else{

                System.out.println("连接MongoDB数据库,校验成功！");

            }

        } catch (UnknownHostException e) {

            e.printStackTrace();

        } catch (MongoException e) {

            e.printStackTrace();

        }

    }

}