MongoDB接口类函数

标签：

1. /** 
2.   * 项目名：SpiderCrawler 
3.   * 文件名：MongoDBDaoImpl.java 
4.   * 描述：TODO(用一句话描述该文件做什么)  
5.   */  
6. package com.newsTest.dao.impl;  
7.   
8. import java.net.UnknownHostException;  //导入URL的相关Exception的jar包
9. import java.util.ArrayList;  
10.   
11. import com.newsTest.dao.MongoDBDao;    //导入接口类的定义
12. import com.mongodb.BasicDBObject;  
13. import com.mongodb.DB;  
14. import com.mongodb.DBCollection;  
15. import com.mongodb.DBCursor;          //导入游标 
16. import com.mongodb.DBObject;  
17. import com.mongodb.MongoClient;  
18. import com.mongodb.MongoClientOptions;  
19. import com.mongodb.MongoException;  
20. import com.mongodb.WriteResult;  
21.   
22. /** 
23.  * 类名： MongoDBDaoImpl 
24.  * 包名： com.newsTest.dao.impl 
25.  * 描述： TODO(这里用一句话描述这个类的作用)  
26.  */  
27. public class MongoDBDaoImpl implements MongoDBDao{  
28.  /*MongoDBDao是前面自己定义的接口，而非系统自带*/   
29.  /** 
30.  * MongoClient的实例代表数据库连接池，是线程安全的，可以被多线程共享，客户端在多线程条件下仅维持  一个实例即可 
31.  * Mongo是非线程安全的，目前mongodb API中已经建议用MongoClient替代Mongo 
32.  */  
33.  private MongoClient mongoClient = null;  
34.  /**  
35.  * 私有的构造函数 
36.  */  
37.  private MongoDBDaoImpl(){  
38.     if(mongoClient == null){  
39.        MongoClientOptions.Builder build = new MongoClientOptions.Builder();          
40.        build.connectionsPerHost(50); 
41.        //与目标数据库能够建立的最大connection数量为50  
42.        build.autoConnectRetry(true);   
43.        //自动重连数据库启动  
44.        build.threadsAllowedToBlockForConnectionMultiplier(50); 
45.       //如果当前所有的connection都在使用中，则每个connection上可以有50个线程排队等待  
46.   /* 
47.   * 一个线程访问数据库的时候，在成功获取到一个可用数据库连接之前的最长等待时间为2分钟 
48.   * 这里比较危险，如果超过maxWaitTime都没有获取到这个连接的话，该线程就会抛出Exception 
49.   * 故这里设置的maxWaitTime应该足够大，以免由于排队线程过多造成的数据库访问失败 
50.   */  
51.        build.maxWaitTime(1000*60*2);  
52.        build.connectTimeout(1000*60*1);    //与数据库建立连接的timeout设置为1分钟  
53.               
54.        MongoClientOptions myOptions = build.build();         
55.        try {  
56.            //数据库连接实例  
57.             mongoClient = new MongoClient("127.0.0.1", myOptions);            
58.        } catch (UnknownHostException e) {  
59.            // TODO 这里写异常处理的代码  
60.             e.printStackTrace();  
61.        } catch (MongoException e){  
62.             e.printStackTrace();  
63.        }  
64.               
65.      }  
66. } 

MongoDB接口类函数

标签：

原文地址：http://www.cnblogs.com/yedushusheng/p/4334016.html