MongoDB——JDBC

-
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientOptions;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoDatabase;
public class MongoJdbc {
  /** 客户端连接池 */
  private static MongoClient mongoClient;
  /** 线程安全的数据库链接 */
  private static MongoDatabase mongoDatabase = null;
  /** 服务器信息 */
  private String repset;
  /** 数据库信息 */
  private String database;
  /** 用户名 */
  private String user;
  /** 密码 */
  private String password;
  /** 单个host允许链接的最大链接数 */
  private String connectionsPerHost;
  /** 线程队列数 */
  private String threadsAllowedToBlockForConnectionMultiplier;
  public void setRepset(String repset) {
    this.repset = repset;
  }
  public void setDatabase(String database) {
    this.database = database;
  }
  public void setUser(String user) {
    this.user = user;
  }
  public void setPassword(String password) {
    this.password = password;
  }
  public void setConnectionsPerHost(String connectionsPerHost) {
    this.connectionsPerHost = connectionsPerHost;
  }
  public void setThreadsAllowedToBlockForConnectionMultiplier(String threadsAllowedToBlockForConnectionMultiplier) {
    this.threadsAllowedToBlockForConnectionMultiplier = threadsAllowedToBlockForConnectionMultiplier;
  }
  private void init() {
    List<ServerAddress> serverAddressList = new ArrayList<ServerAddress>();
    if (this.repset == null || "".equals(this.repset)) {
      throw new MongodbException("未配置ip地址和端口号！");
    }
    if (this.connectionsPerHost == null || "".equals(this.connectionsPerHost)) {
      throw new MongodbException("未配置单个host允许链接的最大链接数！");
    }
    if (this.threadsAllowedToBlockForConnectionMultiplier == null || "".equals(this.threadsAllowedToBlockForConnectionMultiplier)) {
      throw new MongodbException("未配置线程队列数！");
    }
    if (this.user == null || "".equals(this.user)) {
      throw new MongodbException("未配置用户名！");
    }
    if (this.password == null || "".equals(this.password)) {
      throw new MongodbException("未配置密码！");
    }
    if (this.database == null || "".equals(this.database)) {
      throw new MongodbException("未配置库名！");
    }
    String[] hostPorts = this.repset.split(",");
    for (int i = 0; i < hostPorts.length; i++) {
      String[] hostPortArr = hostPorts[i].split(":");
      if (hostPortArr.length != 2) {
        throw new MongodbException("mongodb主机配置异常");
      }
      String host = hostPortArr[0];
      String port = hostPortArr[1];
      ServerAddress serverAddress = new ServerAddress(host, Integer.parseInt(port));
      serverAddressList.add(serverAddress);
    }
    MongoClientOptions mongoClientOptions = new MongoClientOptions.Builder().connectionsPerHost(Integer.parseInt(this.connectionsPerHost))
        .threadsAllowedToBlockForConnectionMultiplier(Integer.parseInt(this.threadsAllowedToBlockForConnectionMultiplier)).build();
    MongoCredential credential = MongoCredential.createCredential(this.user, this.database, this.password.toCharArray());
    mongoClient = new MongoClient(serverAddressList, Arrays.asList(credential), mongoClientOptions);
    mongoDatabase = mongoClient.getDatabase(database);
  }
  public MongoDatabase getMongodb() {
    if (null == mongoDatabase) {
      init();
    }
    return mongoDatabase;
  }
}
-