mongodb java驱动包下载：https://github.com/mongodb/mongo-java-driver/downloads

本测试用例包括：查询数据库、查询聚类集合、查询数据、添加数据、添加多条数据、删除数据、修改数据操作，更多操作请使用者以此类推。

 完整工程下载地址：http://download.csdn.net/detail/linyu19872008/6913607

工程目录结构如图：

mongodb数据库管理类：

扫描二维码关注公众号，回复： 658638 查看本文章

import com.mongodb.Mongo;

/**
 * mongodb管理器
 * 
 * @author jacklin
 * 
 */
public class MongodbManager {

	private static Mongo mg = null;

	/**
	 * 获取mongodb
	 * 
	 * @return
	 */
	public synchronized static Mongo getMongo() {
		if (mg == null) {
			try {
				mg = new Mongo("localhost", 27017);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
		return mg;
	}

}

mongodb测试用例：

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.util.JSON;
import com.sun.mongodb.manager.MongodbManager;

/**
 * mongodb测试用例
 * 
 * @author jacklin
 * 
 */
public class Testcase {

	public static void main(String[] args) {

		// // 查询所有的Database
		// showDatabase();

		// // 查询所有的聚集集合
		// showCollections();

		// // 查询数据
		// find();

		// // 添加数据
		// add();

		// // 添加多条数据
		// addList();

		// // 删除数据
		// remove();

		// // 修改数据
		// modify();

	}

	/**
	 * 修改数据
	 */
	public static void modify() {

		Mongo mg = MongodbManager.getMongo();
		DB db = mg.getDB("test");
		DBCollection users = db.getCollection("user");

		DBObject userOld = new BasicDBObject();
		userOld.put("name", "jack");
		userOld.put("age", 24);

		DBObject userNew = new BasicDBObject();
		userNew.put("name", "jacky");
		userNew.put("age", 26);

		System.out.println(users.update(userOld, userNew));

	}

	/**
	 * 删除数据
	 */
	public static void remove() {

		Mongo mg = MongodbManager.getMongo();
		DB db = mg.getDB("test");
		DBCollection users = db.getCollection("user");

		DBObject user = new BasicDBObject();
		user.put("name", "hoojo");
		System.out.println(users.remove(user));
	}

	/**
	 * 添加多条数据
	 */
	public static void addList() {

		Mongo mg = MongodbManager.getMongo();
		DB db = mg.getDB("test");
		DBCollection users = db.getCollection("user");

		List<DBObject> list = new ArrayList<DBObject>();
		DBObject user1 = new BasicDBObject("name", "lucy");
		user1.put("age", 21);
		DBObject user2 = new BasicDBObject("name", "lily");
		user2.put("age", 22);
		list.add(user1);
		list.add(user2);
		// 添加List集合
		System.out.println(users.insert(list).getN());
	}

	/**
	 * 添加单条数据
	 */
	public static void add() {
		Mongo mg = MongodbManager.getMongo();
		DB db = mg.getDB("test");
		DBCollection users = db.getCollection("user");
		DBObject user = new BasicDBObject();
		user.put("name", "jack");
		user.put("age", 24);

		System.out.println(users.save(user).getN());

	}

	/**
	 * 查询数据
	 */
	public static void find() {
		Mongo mg = MongodbManager.getMongo();
		DB db = mg.getDB("test");
		DBCollection users = db.getCollection("user");

		// 查询所有的数据
		DBCursor cur = users.find();
		while (cur.hasNext()) {
			System.out.println("data:" + cur.next());
		}
		System.out.println("count:" + cur.count());
		System.out.println("cursorId:" + cur.getCursorId());
		System.out.println("json:" + JSON.serialize(cur));
	}

	/**
	 * 查询所有的聚集集合
	 */
	public static void showCollections() {
		Mongo mg = MongodbManager.getMongo();
		DB db = mg.getDB("test");
		for (String name : db.getCollectionNames()) {
			System.out.println("collectionName: " + name);
		}
	}

	/**
	 * 查询所有的Database
	 */
	public static void showDatabase() {
		Mongo mg = MongodbManager.getMongo();
		for (String name : mg.getDatabaseNames()) {
			System.out.println("dbName: " + name);
		}
	}

}