springboot集成mongo

大家可以关注我的微信公众号“秦川以北” 后续更多精彩实用内容分享

​在项目中配置，mongoDB数据库，spring整合

1. 引入pom依赖

<dependency>   
 <groupId>org.springframework.boot</groupId>   
 <artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
2. 在配置文件中配置mongo库信息

　　spring: 

 　　 data:   

    　　mongodb:     

        　　database: data     

　　 　　username: data     

　　 　　password: 1xxx

　　 　　host: localhost     

　　 　　port: 27017

3. 编写你要使用的mongo库中某个collection的实体类，我在这里用的是data

@Document(collection = "data")
@Data
public class DataMongoObject implements Serializable {
    private static final long serialVersionUID = 1L;
    /**
     * objectId,无需设值
     */
    @Id
    private String id;
​
    private String token;
    /**
     * 数据源名称
     */
    private String sourceName;
    /**
     * 数据源描述
     */
    private String sourceDesc;
​
    private String updateTime;
​
    private String dataType = "json";
    /**
     * 用户数据
     */
    private Object data;
​
}

　　这个实体类需要实现序列化接口

　　这里的@Document，说明使用的当前库中的那个collection

　　下面的@Data是lombok中的功能，根据你定义的字段自动注入setter和getter等方法

4. 编写操作mongo的接口

public interface DataRepository extends MongoRepository<DataMongoObject, String> {
​
    /**
     * 通过token进行数据查询,非GridFS
     *
     * @param token
     * @return
     */
    DataMongoObject findByToken(String token);
​
    /**
     * 通过sourceName进行查询
     *
     * @param sourceName
     * @param pageable
     * @return
     */
    Page<DataMongoObject> findBySourceName(String sourceName, Pageable pageable);
​
    @Override
    @Query(value = "{'updateTime':{'$gte':'1564478681215'}}")
    Page<DataMongoObject> findAll(Pageable pageable);
​
//    @Query(value = "{'requestArgs.website':?0}")
//    Page<DataMongoObject> findByRequestArsWebsite(String website, Pageable pageable);
}

　　编写自己的mongo操作类DataRepository继承MongoRepository

　　根据自己的需要些一些CRUD

　　@Query注解中时mongo的查询条件，

　　上面的意思是查询在1564478681215这个时间之后的数据

5. 编写你的实现类去写具体的CRUD逻辑，以及一些判断条件

如果你只是想使用mongoRepository已经定义好的操作方法，

这个步骤也可以省去，直接看第6步

@Slf4j
@Service
public class GridFsMongoService {
​
    @Autowired
    private DataRepository dataRepository;
​
    public void findAll(int pageNum,int pageSize) {
        Page<DataMongoObject> all1 = dataRepository.findAll(new PageRequest(--pageNum, pageSize));
    }
}

@Service注解表明这是一个bean，功能是上面第4步mongo操作接口的实现类

6. 编写controller，对数据进行访问

@Slf4j
@RestController
@RequestMapping("/api/mongo")
public class ParsedDataController {
    @Autowired
    private DataRepository dataRepository;
  /**
       * page从零开始的,这里做了处理,从1开始
       *
       * @param pageNum
       * @param pageSize
       * @return
       */
      @GetMapping("/data/all")
      public String findAll(Integer pageNum, Integer pageSize) {
          ResultInfo resultInfo = new ResultInfo();
          try {
              if (StringUtil.isEmpty(pageNum) || pageNum < 1 || pageNum >= Consts.MAX_SIZE) {
                  pageNum = Consts.DEFAULT_PAGE_NUM;
              }
  
              if (StringUtil.isEmpty(pageSize) || pageSize < 1 || pageSize >= Consts.MAX_SIZE) {
                  pageSize = Consts.DEFAULT_PAGE_SIZE;
              }
  
              Page<DataMongoObject> all = dataRepository.findAll(new PageRequest(--pageNum, pageSize));
              resultInfo.setSuccess(true);
              resultInfo.setDetail(all);
          } catch (Exception e) {
              LOGGER.error(e.getMessage(), e);
          }
          return resultInfo.toString();
      }
   }

关注公众号秦川以北

后续更多精彩实用内容分享！