SpringBoot和Mongodb集成的权威总结

package com.cloud.storage.dao;

import java.util.List;

import org.apache.log4j.Logger;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;

import com.mongodb.DBCollection;

/**
* spring mongodb抽象父类，封装一些常用的方法
*
* @author Administrator
*
* @param <T>
*/
public abstract class MongodbBaseDao<T> {

   Logger log = Logger.getLogger(this.getClass());
   // spring mongodb 集成操作类
   protected MongoTemplate mongoTemplate;

   // 链接本地数据库并创建数据表
   public void CreateCollection(String collectionName) {
       try {
           log.info("Collection created successfully");
       } catch (Exception e) {
           System.err.println(e.getClass().getName() + ": " + e.getMessage());
       }
   }

   // 获取数据表
   public DBCollection GetCollection(String collectionName) {
       DBCollection coll = null;
       try {
           coll = mongoTemplate.getCollection(collectionName);
           return coll;
       } catch (Exception e) {
           System.err.println(e.getClass().getName() + ": " + e.getMessage());
       }
       return coll;
   }

   // 通过条件查询实体(集合)
   public List<T> Listfind(Query query) {
       return mongoTemplate.find(query, this.getEntityClass());
   }

   // 通过一定的条件查询一个实体
   public T findOne(Query query) {
       return (T) mongoTemplate.findOne(query, this.getEntityClass());
   }

   // 通过条件查询更新数据
   public void update(Query query, Update update) {
       mongoTemplate.upsert(query, update, this.getEntityClass());
   }

   // 保存一个对象到mongodb
   public T save(T bean) {
       mongoTemplate.save(bean);
       return bean;
   }

   // 通过ID获取记录
   public T get(String id) {
       return (T) mongoTemplate.findById(id, this.getEntityClass());
   }

   // 通过ID获取记录,并且指定了集合名
   public T get(String id, String collectionName) {
       return (T) mongoTemplate.findById(id, this.getEntityClass(), collectionName);
   }

// 获取需要操作的实体类class
protected abstract Class getEntityClass();

// spring容器注入mongodbTemplate
protected abstract void setMongoTemplate(MongoTemplate mongoTemplate);

}
添加依赖包如下：

       <dependency>
           <groupId>org.mongodb</groupId>
           <artifactId>mongo-java-driver</artifactId>
           <version>3.4.0</version>
       </dependency>

<dependency>
           <groupId>org.springframework.data</groupId>
           <artifactId>spring-data-mongodb</artifactId>
           <version>1.10.6.RELEASE</version>
       </dependency>

SpringBoot和Mongodb集成的权威总结

猜你喜欢