MongoDB操作类封装实例代码

前言

最近接到一个需求，要做mongodb打点数据的统计，在学习过mongodb的操作之后，封装了一个mongodb的操作类，分为两部分，基本思想是参照了自己写过的mysql的操作类。一个是基本的操作类，包括所有基本操作的静态方法，还有一个是mongoobject，就是具体操作的实现类。

以后再写如何用spring boot写一个简单的统计服务。

mongodb操作类封装

mongobase代码如下：

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);
 }
 
}

mongoobject的代码如下：

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();
  }

打印内容如下：

document{{_id=5be4ce052ce01b21b6c26a64, _class=com.fission.next.record.bean.apprecordbean, user_id=5482, action_type={"gameid":2,"userid":"5482"}, action_extern=datasta_game_starts, client_version=15, client_ip=114.5.146.239, client_imei=unknown, client_dev=xiaomi-redmi 5 plus, client_type=200, server_time=1541721601655, os_name=200, os_version=15, client_time=1541721577025}}

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对的支持。