Home > Database > Mysql Tutorial > java操作mongodb:基本的增删改查

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

WBOY
Release: 2016-06-07 15:23:00
Original
1663 people have browsed it

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"));
	}
}
Copy after login
基本增删改查操作类:
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);
	}
}
Copy after login

代码下载:http://download.csdn.net/detail/shanhuhau/6788957
Related labels:
source:php.cn
Statement of this Website
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
Popular Tutorials
More>
Latest Downloads
More>
Web Effects
Website Source Code
Website Materials
Front End Template