package com.pb.test;
/**
 * 测试MongoDB数据库中查询所花费的时间（ms）
 * @author zoe
 * date 2012-12-26
 */
import java.io.BufferedReader;
import java.io.File;

import java.io.FileReader;
import java.net.UnknownHostException;

import java.util.regex.Pattern;

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

public class MyMongoDB {
	/*
	 * get DBCollction
	 * @return
	 */
	public static DBCollection getcoll() {
		Mongo mongo;
		try {
			mongo = new Mongo("localhost", 27017);
			DB db = mongo.getDB("working");

			DBCollection coll = db.getCollection("mytest");
			return coll;
		} catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return null;
	}
	/*
	 * 该方法是把txt文件中的数据，逐行存入到MongoDB数据库中
	 * 且每行中的数据只放入了一个字段中，若果是一行中的数据要放入多个字段中的话，还没有验证
	 */
	public static void add() {
		String url = "d:/file.txt";
		try {
			FileReader read = new FileReader(new File(url));
			BufferedReader br = new BufferedReader(read);
			StringBuffer sbf = new StringBuffer("");
			String line = null;
			int i = 0;
			DBCollection coll = getcoll();
			while ((line = br.readLine()) != null) {
				coll.insert(new BasicDBObject().append("name", line).append(
						"no", i++));
			}
			System.out.println(coll.getCount());
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	/*
	 * 无索引查询
	 */
	public static void query() {
		
		DBCollection coll=getcoll();
       
		BasicDBObject cond = new BasicDBObject();

		Pattern pattern = Pattern.compile("浙江.*$");
		long a = System.currentTimeMillis();
		cond.put("name", pattern);
		// cond.put("name","宁海中通电子科技有限公司" );
		DBCursor returns = coll.find(cond);
		int i = 0;
		while (returns.hasNext() && (++i < 25)) {
			System.out.println(returns.next());
		}
		long b = System.currentTimeMillis();
		System.out.println("所用时间 " + (b - a) + "毫秒");
}
	public static void main(String[] args) {
		query();
	}

	

}