java操作mongodb：基本的增删改查

package com.liuc.db;

import java.net.UnknownHostException;

import com.mongodb.DB;

import com.mongodb.DBCollection;

import com.mongodb.Mongo;

/**

 *

 * @brief MongoDBUtil.java 操作mongodb工具类

 * @attention 使用注意事项

 * @author liuchao

 * @date 2013-12-30

 * @note begin modify by 修改人 修改时间  修改内容摘要说明

 */

public class MongoDBUtil {

    /**

     *

        * \brief 无需认证获取数据库连接

        * @return

        * @attention 方法的使用注意事项

        * @author liuchao

        * @date 2013-12-30

        * @note  begin modify by 修改人 修改时间   修改内容摘要说明

     */

    public static DBCollection getDBConnectionWithoutAuth(String colName){

        try {

            Mongo mongo = new Mongo("localhost", 27017);

            DB db = mongo.getDB("liuchao");

            return db.getCollection(colName);

        } catch (UnknownHostException e) {

            e.printStackTrace();

            return null;

        }

    }

    /**

     *

            获取需认证获取数据库连接

            启动登录密码认证：

            登录数据库，添加用户

            use

            db.addUser('user1','pwd1');

            重启服务端开启认证服务

            mongod --auth --dbpath=D:\mongodb\db

            接下来登录就需要用户名密码认证了

            启动客户端：

            use admin;

            //进行登陆验证，如果不通过，是没有操作权限的了。

            db.auth('user1','pwd1');

     */

    public static DBCollection getDBConnectionWithAuth(String colName){

        try {

            Mongo mongo = new Mongo("localhost", 27017);

            DB db = mongo.getDB("liuchao");

            char[] pwd_char = "liuchao".toCharArray();

            boolean auth = db.authenticate("liuchao",pwd_char);//登陆验证，成功之后才能进行有效操作

            if(!auth){

                throw new RuntimeException();

            }

            return db.getCollection(colName);

        } catch (UnknownHostException e) {

            e.printStackTrace();

            return null;

        }

    }

    public static void main(String[] args) {

        System.out.println(getDBConnectionWithAuth("users"));

        System.out.println(getDBConnectionWithoutAuth("users"));

    }

}

package com.liuc.db;

import java.util.ArrayList;

import java.util.List;

import com.mongodb.BasicDBObject;

import com.mongodb.DBCollection;

import com.mongodb.DBCursor;

import com.mongodb.DBObject;

/**

 *

 * @brief MognoDBCURDUtil.java 增删改查工具类

 * @attention 使用注意事项

 * @author liuchao

 * @date 2013-12-30

 * @note begin modify by 修改人 修改时间 修改内容摘要说明

 */

public class MognoDBCURDUtil {

    /**

     *

     * \brief查询所有数据

     *

     * @attention 方法的使用注意事项

     * @author liuchao

     * @date 2013-12-30

     * @note begin modify by 修改人 修改时间 修改内容摘要说明

     */

    private static void queryAll(String collectionName) {

        DBCollection users = MongoDBUtil

                .getDBConnectionWithAuth(collectionName);

        // db游标

        DBCursor cur = users.find();

        System.out.println("数据总条数:" + users.count());

        while (cur.hasNext()) {

            System.out.println(cur.next());

        }

    }

    /**

     *

     * \brief 添加数据

     *

     * @param collectionName

     * @attention 方法的使用注意事项

     * @author liuchao

     * @date 2013-12-30

     * @note begin modify by 修改人 修改时间 修改内容摘要说明 save和insert的区别

     *       save函数实际就是根据参数条件,调用了insert或update函数.

     *       如果想插入的数据对象存在,insert函数会报错,而save函数是改变原来的对象;

     *       如果想插入的对象不存在,那么它们执行相同的插入操作. 这里可以用几个字来概括它们两的区别,即所谓"有则改之,无则加之".

     */

    public static void add(String collectionName, List<DBObject> list) {

        DBCollection users = MongoDBUtil

                .getDBConnectionWithAuth(collectionName);

        users.insert(list).getN();

    }

    /**

     *

        * \brief 更新

        * @param collectionName

        * @param source

        * @param target

        * @attention 方法的使用注意事项

        * @author liuchao

        * @date 2013-12-30

        * @note  begin modify by 修改人 修改时间   修改内容摘要说明

     */

    public static void update(String collectionName, DBObject source,

            DBObject target) {

        DBCollection users = MongoDBUtil

                .getDBConnectionWithAuth(collectionName);

        /**

         * true,//如果数据库不存在，是否添加

            false//多条修改

         */

        users.update(source, target, true, false);

    }

    /**

     *

        * \brief 删除

        * @param collectionName

        * @param obj

        * @attention 方法的使用注意事项

        * @author liuchao

        * @date 2013-12-30

        * @note  begin modify by 修改人 修改时间   修改内容摘要说明

     */

    public static void delete(String collectionName, DBObject delObj) {

        DBCollection users = MongoDBUtil

                .getDBConnectionWithAuth(collectionName);

        users.remove(delObj);

        //print("remove age >= 24: " + users.remove(new BasicDBObject("age", new BasicDBObject("$gte", 24))).getN());

    }

    /**

     *

        * \brief 带条件查询

        * @param collectionName

        * @param delObj

        * @attention 方法的使用注意事项

        * @author liuchao

        * @date 2013-12-30

        * @note  begin modify by 修改人 修改时间   修改内容摘要说明

     */

    public static void queryWithCondition(String collectionName, DBObject condition) {

        DBCollection users = MongoDBUtil

                .getDBConnectionWithAuth(collectionName);

        //users.find(new BasicDBObject("_id", new ObjectId("4de73f7acd812d61b4626a77"))).toArray()

        users.find(condition);

    }

}