java操作mongoDBCRUD

java连接mongoDB，增删改查操作等等

package com.jialin.mongodb;

import java.net.UnknownHostException;

import org.bson.types.objectId;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;

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;
import com.mongodb.QueryOperators;
import com.mongodb.util.JSON;

public class mongoDB4crud {

	private Mongo mg = null;
	private DB db;
	private DBCollection users;
	private DBCollection coll;

	@Before
	public void init（） {
		try {
			// mg = new Mongo（）; // 默认为本机27017端口
			mg = new Mongo（“192.168.40.128“ 27017）;
		} catch （UnknownHostException e） {
			e.printStackTrace（）;
		} catch （MongoException e） {
			e.printStackTrace（）;
		}
		// 获取temp DB；如果默认没有创建，mongodb会自动创建
		db = mg.getDB（“temp“）;
		// 获取users DBCollection；如果默认没有创建，mongodb会自动创建
		users = db.getCollection（“users“）;
		
		// 获取coll DBCollection；如果默认没有创建，mongodb会自动创建
		coll = db.getCollection（“coll“）;

	}

	public void print（object o） {
		System.out.println（o）;
	}

	@After
	public void destory（） {
		if （mg != null）
			mg.close（）;
		mg = null;
		db = null;
		users = null;
		System.gc（）;
	}

	@Test
	public void queryAll（） {
		print（“查询coll的所有数据：“）;
		// db游标
		DBCursor cur1 = coll.find（）;
		while （cur1.hasNext（）） {
			print（cur1.next（））;
		}
		
		print（“------------------“）;
		print（“查询users的所有数据：“）;
		// db游标
		DBCursor cur2 = users.find（）;
		while （cur2.hasNext（）） {
			print（cur2.next（））;
		}
	}

	@Test
	public void add（） {
		// 先查询所有数据
		queryAll（）;
		print（“count: “ + users.count（））;
		//new 一个BasicDBobject对象doc
		DBobject doc = new BasicDBobject（）;
		//赋值
		doc.put（“name“ “MongoDB“）;
		doc.put（“type“ “database“）;
		doc.put（“count“ 1）;
		//又new 一个BasicDBobject对象info
		DBobject info = new BasicDBobject（）;
		info.put（“x“ 203）;
		info.put（“y“ 102）;
		//把info放入doc
		doc.put（“info“ info）;
		//向testCollection表中插入一条数据
		coll.insert（doc）;
		
		//查询一条数据
	    DBobject myDoc = coll.findOne（）;
	    print（myDoc）;
		
		// 查询下数据，看看是否添加成功
		print（“count: “ + coll.count（））;
		queryAll（）;

	}

	@Test
	public void remove（） {
		queryAll（）;
		print（“删除id = 51b96ef1b8ab45fd6567d33c：“
				+ users.remove（
						new BasicDBobject（“_id“ new objectId（
								“51b96ef1b8ab45fd6567d33c“）））.getN（））;
		print（“remove age >= 24: “
				+ users.remove（
						new BasicDBobject（“age“ new BasicDBobject（“$gte“ 24）））
						.getN（））;
	}

	@Test
	public void modify（） {
		print（“修改：“
				+ users.update（
						new BasicDBobject（“_id“ new objectId（
								“51b97269b8ab972c005e0424“））
						new BasicDBobject（“name“ “jialin“））.getN（））;
		print（“修改：“
				+ users.update（
						new BasicDBobject（“_id“ new objectId（
								“51b97273b8ab19d9a9aafbcb“））
						new BasicDBobject（“age“ 100） true// 如果数据库不存在，是否添加
			

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     目录           0  2013-06-13 10:48  test_mongoDB1\
     文件         492  2013-06-14 09:14  test_mongoDB1\.classpath
     文件         389  2013-06-13 10:41  test_mongoDB1\.project
     目录           0  2013-06-13 10:41  test_mongoDB1\.settings\
     文件         598  2013-06-13 10:41  test_mongoDB1\.settings\org.eclipse.jdt.core.prefs
     目录           0  2013-06-14 09:14  test_mongoDB1\bin\
     目录           0  2013-06-14 09:14  test_mongoDB1\bin\com\
     目录           0  2013-06-14 09:14  test_mongoDB1\bin\com\jialin\
     目录           0  2013-06-14 09:14  test_mongoDB1\bin\com\jialin\mongodb\
     文件        7682  2013-06-14 09:18  test_mongoDB1\bin\com\jialin\mongodb\mongoDB4crud.class
     文件        2178  2013-06-14 09:14  test_mongoDB1\bin\com\jialin\mongodb\Test.class
     目录           0  2013-06-13 14:48  test_mongoDB1\lib\
     文件       45024  2013-06-13 14:48  test_mongoDB1\lib\hamcrest-core-1.3.jar
     文件      245039  2013-06-13 14:48  test_mongoDB1\lib\junit-4.11.jar
     文件      388540  2013-06-13 10:56  test_mongoDB1\lib\mongo-2.9.3.jar
     文件      831826  2013-06-13 10:48  test_mongoDB1\lib\mongo-java-driver-2.9.3-javadoc.jar
     文件      388540  2013-06-13 10:48  test_mongoDB1\lib\mongo-java-driver-2.9.3.jar
     目录           0  2013-06-13 14:35  test_mongoDB1\src\
     目录           0  2013-06-13 14:35  test_mongoDB1\src\com\
     目录           0  2013-06-13 14:42  test_mongoDB1\src\com\jialin\
     目录           0  2013-06-13 14:35  test_mongoDB1\src\com\jialin\mongodb\
     文件        6550  2013-06-14 09:18  test_mongoDB1\src\com\jialin\mongodb\mongoDB4crud.java
     文件         879  2013-06-13 14:42  test_mongoDB1\src\com\jialin\mongodb\Test.java