package test1;

import java.util.Date;
import java.util.Set;

import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.Mongo;

public class ConnectionTest {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		Mongo mongo = new Mongo("localhost", 27017);

		// 连接名为yourdb的数据库，假如数据库不存在的话，mongodb会自动建立
		DB db = mongo.getDB("mytest");

		// 遍历所有集合的名字
		Set<String> colls = db.getCollectionNames();
		System.out.println("所有集合：");
		for (String s : colls) {
			System.out.println(s);
		}
		System.out.println("测试开始");
		// 从Mongodb中获得名为yourColleection的数据集合，如果该数据集合不存在，Mongodb会为其新建立
		DBCollection collection = db.getCollection("yourCollection");
		
		search(collection);
		System.out.println("Done");
	}
	
	
	public static void insert(DBCollection collection){
		System.out.println("插入");
		// 使用BasicDBObject对象创建一个mongodb的document,并给予赋值。
		BasicDBObject document = new BasicDBObject();
		document.put("id", 1001);
		document.put("msg", "hello world mongoDB in Java");
		// 将新建立的document保存到collection中去
		collection.insert(document);
	}
	
	public static void delete(DBCollection collection){
		System.out.println("删除");
		BasicDBObject query = new BasicDBObject();
		query.put("id", 1001);
		collection.remove(query);
	}

	
	public static void update(DBCollection collection){
		System.out.println("更新");
		BasicDBObject update = new BasicDBObject();
		update.put("id", 1002);
		update.put("time",new Date());
		collection.update(new BasicDBObject().append("id", 1001), update);
	}

	public static void search(DBCollection collection){
		System.out.println("查询");
		// 创建要查询的document
		BasicDBObject searchQuery = new BasicDBObject();
		searchQuery.put("id", 1001);
		// 使用collection的find方法查找document
		DBCursor cursor = collection.find();
		// 循环输出结果
		while (cursor.hasNext()) {
			System.out.println(cursor.next());
		}
	}
}

版权声明：本文为博主原创文章，未经博主允许不得转载。