starter-data-mongodb

pom依赖

1. <!--mongo依赖-->
2. <dependency>
3.      <groupId>org.springframework.boot</groupId>
4.      <artifactId>spring-boot-starter-data-mongodb</artifactId>
5. </dependency>
7. <!--测试依赖-->
8. <dependency>
9.      <groupId>org.springframework.boot</groupId>
10.      <artifactId>spring-boot-starter-test</artifactId>
11.      <scope>test</scope>
12. </dependency>

复制代码

mongodb yml连接信息

1. spring:
2.   data:
3.     mongodb:
4.       uri: mongodb://admin:admin@192.168.98.128:27017/articledb?authSource=admin

复制代码

springboot主方法

不必要排除mongodb，利用spring自带的mongo连接

1. @SpringBootApplication
2. @Slf4j
3. public class SpringbootApplication {
4.     public static void main(String[] args) {  SpringApplication.run(SpringbootApplication.class, args);
5.     }
6. }

复制代码

mongo实体类

对应具体mongo collection

1. @Document(collection  = "BalanceTest") //集合名称
2. @Data
3. public class BalanceEntity implements Serializable {
4.     //主键标识,该属性的值会自动对应MongoDB的主键字段_id,如果该属性名就叫"id"则该注解可以省略,否则必须写
5.     @Id //主键
6.     private String id;
7.     //该属性对应MongoDB字段的名字,如果一致,则无需该注解
8.     @Field("articleid")
9.     private int articleId;
10.     private String content;
11.     private Date createTime;
12. }

复制代码

dao层

MongoRepository<T, ID>中ID为主键范例

1. //MongoRepository<T, ID>中ID为主键类型
2. public interface BalanceRepository extends MongoRepository<BalanceEntity, String> {
4.     //ArticleId为需要查询的字段
5.     Page<BalanceEntity> findByArticleId(String parentid,Pageable pageable);
6. }

复制代码

service层

调用dao层或者利用mongoTemplate方法

1. import org.springframework.data.domain.Page;
2. import org.springframework.data.domain.PageRequest;
3. import org.springframework.data.mongodb.core.MongoTemplate;
4. import org.springframework.data.mongodb.core.query.Criteria;
5. import org.springframework.data.mongodb.core.query.Query;
6. import org.springframework.data.mongodb.core.query.Update;
7. import org.springframework.stereotype.Service;
8. @Service
9. public class BalanceService {
10.     @Autowired
11.     private BalanceRepository balanceRepository;
13.     @Autowired
14.     private MongoTemplate mongoTemplate;
16.     public void saveBalance(BalanceEntity balanceEntity) {
17.         balanceRepository.save(balanceEntity);
18.     }
20.     public void updateBalance(BalanceEntity balanceEntity) {
21.         balanceRepository.save(balanceEntity);
22.     }
24.     /**
25.      * 根据id删除评论
26.      */
27.     public void deleteCommentById(String id){
28.         //调用dao
29.         balanceRepository.deleteById(id);
30.     }
32.     /**
33.      * 查询所有评论
34.      */
35.     public List<BalanceEntity> findCommentList(){
36.         //调用dao
37.         return balanceRepository.findAll();
38.     }
40.     /**
41.      * 根据id查询评论
42.      */
43.     public BalanceEntity findCommentById(String id){
44.         //调用dao
45.         return balanceRepository.findById(id).get();
46.     }
48.     /**
49.      * 分页条件查询
50.      */
51.     public Page<BalanceEntity> findByArticleId(String articleId, int page, int size) {
52.         return balanceRepository.findByArticleId(articleId,PageRequest.of(page-1,size));
53.     }
55.     /**
56.      * 自增更新
57.      */
58.     public void updateIncrementArticleId(String id){
59.         //  查询条件
60.         Query query = Query.query(Criteria.where("_id").is(id));
61.         //  更新条件
62.         Update update = new Update();
63.         //需要自增的字段
64.         update.inc("articleId");
65.         mongoTemplate.updateFirst(query,update,BalanceEntity.class);
66.     }
67. }

复制代码

测试类，调用server层

1. @RunWith(SpringRunner.class)
2. @SpringBootTest
3. public class BalanceServiceTest {
5.     @Autowired
6.     private BalanceService balanceService;
8.     @Test
9.     public void testFindCommentList() {
10.         List<BalanceEntity> commentList = balanceService.findCommentList();
11.         System.out.println(commentList);
12.     }
14.     @Test
15.     public void testFindCommentById() {
16.         BalanceEntity commentById = balanceService.findCommentById("672f82baba8fda7d061e2097");
17.         System.out.println(commentById);
18.     }
20.     @Test
21.     public void testSaveComment(){
22.         BalanceEntity balanceEntity =new BalanceEntity();
23.         balanceEntity.setContent("测试添加的数据");
24.         balanceEntity.setCreateTime(new Date());
25.         balanceEntity.setArticleId(1003);
27.         balanceService.saveBalance(balanceEntity);
29.     }
31.     @Test
32.     public void findByArticleId() {
33.         Page<BalanceEntity> page = balanceService.findByArticleId("3", 1, 2);
34.         System.out.println(page.getTotalElements());
35.         System.out.println(page.getContent());
36.     }
38.     @Test
39.     public void updateIncrementArticleId() {
40.         balanceService.updateIncrementArticleId("67657f30c1e6c51645a0be55");
41.     }
42. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。