Java Mongo Drivers Normal Authentication 一般驗證

OS ： win7
mongoDB  ：   2.6
MongoDB Drivers ：  2.12.2
Language：Java


package global.db;

import java.net.UnknownHostException;
import java.util.Arrays;

import javassist.bytecode.stackmap.TypeData.ClassName;

import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.beans.factory.config.BeanDefinition;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import org.springframework.context.annotation.Scope;

import com.mongodb.DB;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientOptions;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;

/**
 * @author hua
 * 處理 mongoDB 基礎連線建立 
 */
@Configuration
@Scope(BeanDefinition.SCOPE_SINGLETON)
public class MongoConnection {

private static Logger logger = Logger.getLogger(ClassName.class);

@Value("${mongo.host}")
private String host;

@Value("${mongo.port}")
private int port;

@Value("${mongo.dbName}")
private String dbName;

@Value("${mongo.user}")
private String user;

@Value("${mongo.pwd}")
private String pwd;

private MongoClient mongoClient;

public MongoConnection() throws UnknownHostException {
super();
}

/**
* 建立連線
*/
private void buildConnection()throws UnknownHostException{
try {
MongoCredential credential = MongoCredential.createMongoCRCredential(this.user, this.dbName, this.pwd.toCharArray());
MongoClientOptions options = getOption();
ServerAddress address = new ServerAddress(this.host, this.port);
mongoClient = new MongoClient(address, Arrays.asList(credential), options);
logger.info("--------------------MongoDB 驗證成功");
} catch (UnknownHostException e) {
logger.error("MongoDB 建立連線失敗!");
if(mongoClient != null){
mongoClient.close();
}
throw e;
}
}
//線程等待數量  * 主機最大連線數  = pool 數量
protected MongoClientOptions getOption(){
return new MongoClientOptions.Builder()
       .threadsAllowedToBlockForConnectionMultiplier(300) //線程等待的數量
       .connectionsPerHost(10) //主機最大連線數
       .connectTimeout(5000)
       .build();
}

/** 取得DB操作物件
* @return
* @throws UnknownHostException
*/
public DB getDB() throws UnknownHostException {
synchronized (this) {
if(mongoClient == null){
buildConnection();
}
}
return mongoClient.getDB(this.dbName);
}
}

Note :

•  mongo 現在版本，建議使用MongoClientOptions 而不要再使用MongoOptions。

參考文件：

• MongoClientOptions.Builder
• MongoClientOptions
• Class MongoCredential

MongoDB MongoClient 與 Mongo

OS ： win7
mongoDB  ：   2.6
MongoDB Drivers ：  2.12.2
Language：Java

• MongoClient 與 Mongo 是mongoDB Driver  是連線管理物件，具有連線池功用。
• Mongo 目前 Drivers API 有提到，請不要再使用Mongo，而因改用MongoClient來建立連線。
  
  此段引用mongoDB官方API 文件
  
  Mongo(MongoURI uri)
  
  Deprecated.
  

  Replaced by MongoClient.MongoClient(MongoClientURI)
  
  可以看見，文件告知改用MongoClient吧。
  
• MongoClient 繼承自  Mongo。

參考：

• MongoClient
• Mongo

spring bean scope annotation

@Configuration
@Scope(BeanDefinition.SCOPE_SINGLETON)
public class MongoConnection {
    .
    .
    .
}


SCOPE

• BeanDefinition.SCOPE_SINGLETON     or  "singleton "
• BeanDefinition.SCOPE_PROTOTYPE    or   "prototype "
• "request"
• "session" 
• "globalSession "

Reference 

• Spring bean scope annotation example