Mongodb 연결 방법 학습

프로젝트 에 mongodb 를 사용 해 야 합 니 다. 소개 에 따 르 면 mongodb 의 연결 은 연결 탱크 의 사 고 를 사용 하여 하나의 인 스 턴 스 만 유지 할 수 있 습 니 다.
레 퍼 런 스http://blog.csdn.net/sheismylife/article/details/7090526의 코드 는 자신의 mongodb 연결 탱크 제어 류 를 완성 합 니 다.
package cn.cnic.jingshao.mongodbapp.util;

import java.net.UnknownHostException;

import com.mongodb.DB;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.mongodb.MongoOptions;

public class MongoDBUtil {
	//   Mongo  
	private Mongo mongo;
	
	//      
	private MongoDBUtil(){}
	
	private static class InnerHolder{
		static final MongoDBUtil INSTANCE = new MongoDBUtil();
	}
	
	public static MongoDBUtil getInstance(){
		return InnerHolder.INSTANCE;
	}
	
	/**
	 *    Mongodb  
	 * @throws UnknownHostException
	 * @throws MongoException
	 */
	public void init() throws UnknownHostException, MongoException{
		int poolSize = ConfigUtil.getInstance().getPoolSize(); //            
		
		if(poolSize == -1){
			poolSize = 10000;
		}
		
		System.setProperty("MONGO.POOLSIZE", String.valueOf(poolSize));
		
		if(this.mongo == null){
			//System.out.println("1st init Mongo instance"); //mongo        
			
			//                 
			String serverIp = ConfigUtil.getInstance().getServerIP();
			int portNum = ConfigUtil.getInstance().getPortNum();
			
			mongo = new Mongo(serverIp, portNum);
			MongoOptions options = mongo.getMongoOptions();
			options.autoConnectRetry = true;
			options.connectionsPerHost = poolSize;
		}
	}
	
	/**
	 *   DB  
	 * @param dbName
	 * @return
	 */
	public DB getDB(String dbName){
		if(dbName != null && !dbName.equals("")){
			return this.mongo.getDB(dbName);
		}else{
			return null;
		}
	}
	
	/**
	 *   Mongodb
	 */
	public void close(){
		if(this.mongo != null){
			this.mongo.close();
			this.mongo = null;
		}
	}
}

좋은 웹페이지 즐겨찾기