MongoDB操作类封装实例代码

package com.fun.mongodb; import com.fun.frame.SourceCode;import com.mongodb.MongoClient;import com.mongodb.MongoClientURI;import com.mongodb.MongoCredential;import com.mongodb.ServerAddress;import com.mongodb.client.MongoCollection;import com.mongodb.client.MongoDatabase;import org.bson.Document; import java.util.Arrays;import java.util.List; /** * mongo操作类的基础类 */public class MongoBase extends SourceCode {  /**  * 获取服务地址list  *  * @param addresses  * @return  */ public static List<ServerAddress> getServers(ServerAddress... addresses) {  return Arrays.asList(addresses); }  /**  * 获取服务地址  *  * @param host  * @param port  * @return  */ public static ServerAddress getServerAdress(String host, int port) {  return new ServerAddress(host, port); }  /**  * 获取认证list  *  * @param credentials  * @return  */ public static List<MongoCredential> getCredentials(MongoCredential... credentials) {  return Arrays.asList(credentials); }  /**  * 获取验证  *  * @param userName  * @param database  * @param password  * @return  */ public static MongoCredential getMongoCredential(String userName, String database, String password) {  return MongoCredential.createCredential(userName, database, password.toCharArray()); }  /**  * 获取mongo客户端  *  * @param addresses  * @param credentials  * @return  */ public static MongoClient getMongoClient(List<ServerAddress> addresses, List<MongoCredential> credentials) {  return new MongoClient(addresses, credentials); }  /**  * 连接mongo数据库  *  * @param mongoClient  * @param databaseName  * @return  */ public static MongoDatabase getMongoDatabase(MongoClient mongoClient, String databaseName) {  return mongoClient.getDatabase(databaseName); }  /**  * 连接mongo集  *  * @param mongoDatabase  * @param collectionName  * @return  */ public static MongoCollection<Document> getMongoCollection(MongoDatabase mongoDatabase, String collectionName) {  return mongoDatabase.getCollection(collectionName); }  /**  * 关闭数据库连接  *  * @param mongoClient  */ public static void MongoOver(MongoClient mongoClient) {  mongoClient.close(); }  /**  * 获取mongo客户端对象，通过servers和credentials对象创建  *  * @param mongoObject  * @return  */ public static MongoClient getMongoClient(MongoObject mongoObject) {  MongoClient mongoClient = new MongoClient(getServers(getServerAdress(mongoObject.host, mongoObject.port)), getCredentials(getMongoCredential(mongoObject.user, mongoObject.database, mongoObject.password)));  return mongoClient; }  /**  * 获取mongo客户端对象,通过uri方式连接  *  * @param mongoObject  * @return  */ public static MongoClient getMongoClientOnline(MongoObject mongoObject) {  String format = String.format("mongodb://%s:%s@%s:%d/%s", mongoObject.user, mongoObject.password, mongoObject.host, mongoObject.port, mongoObject.database);  return new MongoClient(new MongoClientURI(format)); }  /**  * 获取collection对象  *  * @param mongoObject  * @return  */ public static MongoCollection<Document> getCollection(MongoObject mongoObject, String collectionName) {  return getMongoClient(mongoObject).getDatabase(mongoObject.database).getCollection(collectionName); }  /**  * 获取collection对象  *  * @param mongoObject  * @return  */ public static MongoCollection<Document> getCollectionOnline(MongoObject mongoObject, String collectionName) {  return getMongoClientOnline(mongoObject).getDatabase(mongoObject.database).getCollection(collectionName); } }

package com.fun.mongodb;  import com.mongodb.MongoClient;import com.mongodb.client.MongoCollection;import org.bson.Document; /** * mongo数据库配置对象，针对单个数据服务，单个身份验证 */public class MongoObject extends MongoBase {   String host;   int port;   String user;   String password;   String database;   MongoClient mongoClient;   /**   * 创建数据连接   *   * @param host   * @param port   * @param user   * @param password   * @param database   */  public MongoObject(String host, int port, String user, String password, String database) {    this.host = host;    this.port = port;    this.user = user;    this.password = password;    this.database = database;    this.mongoClient = getMongoClient(this);  }   /**   * 创建数据库连接   *   * @param port   * @param host   * @param user   * @param password   * @param database   */  public MongoObject(int port, String host, String user, String password, String database) {    this.host = host;    this.port = port;    this.user = user;    this.password = password;    this.database = database;    this.mongoClient = getMongoClientOnline(this);  }   /**   * 获取colletion对象   *   * @param collectionName   * @return   */  public MongoCollection<Document> getMongoCollection(String collectionName) {    MongoClient mongoClientOnline = getMongoClientOnline(this);    return mongoClientOnline.getDatabase(database).getCollection(collectionName);  }    /**   * 关闭连接   */  public void over() {    MongoOver(this.mongoClient);  }} @Override  public MongoObject clone() {    return new MongoObject(this.host, this.port, this.user, this.password, this.database);  }  public MongoObject clone2() {    return new MongoObject(this.port, this.host, this.user, this.password, this.database);  }

 public static void main(String[] args) {    MongoObject ready = new MongoObject("*****", 5117, "fission_record", "fission_record", "fission_record");    MongoCollection<Document> app = ready.getMongoCollection("app_logs_20181109");    Document first = app.find().first();    output(first);    ready.over();  }