SpringBoot + mongodb 整合, 记录网站操作日志，常用查询操作

avatar 2018年09月03日20:39:48 6 9020 views
博主分享免费Java教学视频，B站账号：Java刘哥 ，长期提供技术问题解决、项目定制：本站商品点此
mongodb 是一种文档型数据库。跟 Redis 一样是非关系型数据库，Redis 属于那种小而快的数据库，常常用作缓存。

而如果我们需要存一些类似于日志的那种，可以尝试用 mongodb (当然也有人用 MySQL，就是有点慢)。我们尝试用 mongodb 来存储博客的日志信息。

本文主要介绍 SpringBoot 和 mongodb 整合，和基本的查询操作。


一、依赖和配置


创建 springboot 项目，引入 web 和 lombok，然后再添加 mongodb 依赖

1、pom.xml
  1. <!--mongodb-->
  2. <dependency>
  3.     <groupId>org.springframework.boot</groupId>
  4.     <artifactId>spring-boot-starter-data-mongodb</artifactId>
  5. </dependency>

类似 Spring Data JPA



2、application.properties
  1. spring.data.mongodb.uri=mongodb://localhost:27017/saysky

saysky是数据库名称，确保你本地启动了 mongodb


二、代码实例


1、日志实体
  1. package com.liuyanzhao.mongodb.model;
  3. import lombok.Data;
  5. import java.util.Date;
  7. /**
  8.  * 日志
  9.  * @author 言曌
  10.  * @date 2018/9/3 20:00
  11.  */
  12. @Data
  13. public class Log {
  15.     private Long id;
  17.     private Long userId;
  19.     private Integer type;
  21.     private String url;
  23.     private String desc;
  25.     private Date createTime;
  26. }



2、LogRepository
  1. package com.liuyanzhao.mongodb.dao;
  3. import com.liuyanzhao.mongodb.model.Log;
  4. import org.springframework.data.domain.Page;
  5. import org.springframework.data.domain.Pageable;
  6. import org.springframework.data.mongodb.repository.MongoRepository;
  7. import org.springframework.stereotype.Repository;
  9. import java.util.Date;
  10. import java.util.List;
  13. /**
  14.  * @author 言曌
  15.  * @date 2018/9/3 14:17
  16.  */
  17. @Repository
  18. public interface LogRepository extends  <Log, Long> {
  20.     /**
  21.      * 根据用户ID查询
  22.      * @param userId
  23.      * @return
  24.      */
  25.     List<Log> findByUserId(Long userId);
  27.     /**
  28.      * 根据描述查询
  29.      * @param desc
  30.      * @return
  31.      */
  32.     List<Log> findByDesc(String desc);
  34.     /**
  35.      * 根据创建日期范围查询
  36.      * @param startTime
  37.      * @param endTime
  38.      * @return
  39.      */
  40.     List<Log> findByCreateTimeBetween(Date startTime, Date endTime);
  43.     /**
  44.      * 根据描述查询
  45.      * 分页查询
  46.      * @param desc
  47.      * @return
  48.      */
  49.     Page<Log> findByDesc(String desc, Pageable pageable);
  51.     /**
  52.      * 根据创建日期范围查询
  53.      * 分页查询
  54.      * @param startTime
  55.      * @param endTime
  56.      * @return
  57.      */
  58.     Page<Log> findByCreateTimeBetween(Date startTime, Date endTime,Pageable pageable);
  60. }



3、测试类
  1. package com.liuyanzhao.mongodb.dao;
  3. import com.liuyanzhao.mongodb.model.Log;
  4. import org.junit.Test;
  5. import org.junit.runner.RunWith;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.boot.test.context.SpringBootTest;
  8. import org.springframework.data.domain.Page;
  9. import org.springframework.data.domain.PageRequest;
  10. import org.springframework.test.context.junit4.SpringRunner;
  12. import java.util.Date;
  15. /**
  16.  * @author 言曌
  17.  * @date 2018/9/3 14:21
  18.  */
  19. @SpringBootTest
  20. @RunWith(SpringRunner.class)
  21. public class LogRepositoryTest {
  23.     @Autowired
  24.     private LogRepository logRepository;
  26.     @Test
  27.     public void save() {
  28.         Log log = new Log();
  29.         log.setId(7L);
  30.         log.setType(1);
  31.         log.setDesc("更新用户");
  32.         log.setUserId(10002L);
  33.         log.setUrl("/user/update");
  34.         log.setCreateTime(new Date());
  35.         logRepository.save(log);
  36.     }
  38.     @Test
  39.     public void findById() {
  40.         Log Log = logRepository.findById(1L).get();
  41.         System.out.println(Log);
  42.     }
  45.     @Test
  46.     public void findByDes() {
  47.         //不分页
  48. //        List<Log> LogList = logRepository.findByDesc("添加用户");
  49. //        System.out.println(LogList);
  51.         //分页查询
  52.         //查询第1页，每页显示2条
  53.         PageRequest pageRequest = new PageRequest(0,2);
  54.         Page<Log> logPage = logRepository.findByDesc("添加用户",pageRequest);
  55.         System.out.println(logPage);
  56.     }
  59.     @Test
  60.     public void findByCreateTimeBetween() {
  61.         //根据时间区间查询
  62.         //不分页
  63.         Date createdAtStart = new Date(1535974057016L);
  64.         Date createdAtEnd = new Date(1535974145009L);
  65. //        List<Log> LogList = logRepository.findByCreateTimeBetween(createdAtStart,createdAtEnd);
  66. //        System.out.println(LogList);
  68.         //分页查询
  69.         //查询第1页，每页显示2条
  70.         PageRequest pageRequest = new PageRequest(0,2);
  71.         Page<Log> logPage = logRepository.findByCreateTimeBetween(createdAtStart,createdAtEnd,pageRequest);
  72.         System.out.println(logPage);
  73.     }
  75. }



我们通过mongodb可视化工具可以看到数据




三、更多查询


因为引入的 MongoRepository 是一种 JPA 框架，所以增删改查都很容易。

可以参考 Spring Data JPA 方法命名规范


































































































































方法关键字 示例 等价于SQL
And findByLastnameAndFirstname … where x.lastname = ?1 and x.firstname = ?2
Or findByLastnameOrFirstname … where x.lastname = ?1 or x.firstname = ?2
Is,Equals findByFirstname，findByFirstnameIs，findByFirstnameEquals … where x.firstname = ?1
Between findByStartDateBetween … where x.startDate between ?1 and ?2
LessThan findByAgeLessThan … where x.age < ?1
LessThanEqual findByAgeLessThanEqual … where x.age <= ?1
GreaterThan findByAgeGreaterThan … where x.age > ?1
GreaterThanEqual findByAgeGreaterThanEqual … where x.age >= ?1
After findByStartDateAfter … where x.startDate > ?1
Before findByStartDateBefore … where x.startDate < ?1
IsNull findByAgeIsNull … where x.age is null
IsNotNull,NotNull findByAge(Is)NotNull … where x.age not null
Like findByFirstnameLike … where x.firstname like ?1
NotLike findByFirstnameNotLike … where x.firstname not like ?1
StartingWith findByFirstnameStartingWith … where x.firstname like ?1（参数绑定附加%）
EndingWith findByFirstnameEndingWith … where x.firstname like ?1（参数与预先绑定%）
Containing findByFirstnameContaining … where x.firstname like ?1（参数绑定%）
OrderBy findByAgeOrderByLastnameDesc … where x.age = ?1 order by x.lastname desc
Not findByLastnameNot … where x.lastname <> ?1
In findByAgeIn(Collection ages) … where x.age in ?1
NotIn findByAgeNotIn(Collection ages) … where x.age not in ?1
True findByActiveTrue() … where x.active = true
False findByActiveFalse() … where x.active = false
IgnoreCase findByFirstnameIgnoreCase … where UPPER(x.firstame) = UPPER(?1)







历史上的今天
九月
03日
  • 微信
  • 交流学习，资料分享
  • weinxin
  • 个人淘宝
  • 店铺名：言曌博客咨询部

  • (部分商品未及时上架淘宝)
avatar

发表评论

avatar 登录者：匿名
匿名评论，评论回复后会有邮件通知

  

已通过评论：0   待审核评论数：0