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

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 操作

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 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);
	}
}