【MongoDB】Springboot中MongoDB简单使用

Myth丶恋晨 2024-03-24 22:24 16阅读 0赞

#### 1. docker安装MongoDB ####

拉取镜像

docker pull mongo

创建容器

docker run -di --name mongo-service --restart=always -p 27017:27017 -v ~/data/mongodata:/data mongo

#### 2. 导入依赖 ####

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-mongodb</artifactId>
    </dependency>

#### 3. 配置文件 ####

`application.yml`

server:
      port: 9998
    spring:
      data:
        mongodb:
          host: 192.168.200.130
          port: 27017
          database: leadnews-history

#### 4. 实体类映射 ####

package com.mongo.pojo;
    
    import lombok.Data;
    import org.springframework.data.mongodb.core.mapping.Document;
    
    import java.io.Serializable;
    import java.util.Date;
    
    /**
     * <p>
     * 联想词表
     * </p>
     *
     * @author zsx
     */
    @Data
    @Document("ap_associate_words")
    public class ApAssociateWords implements Serializable {
        
    
        private static final long serialVersionUID = 1L;
    
        private String id;
    
        /**
         * 联想词
         */
        private String associateWords;
    
        /**
         * 创建时间
         */
        private Date createdTime;
    
    }

#### 5. 测试 ####

package com.zsx.mongo.test;
    
    
    import com.zsx.mongo.MongoApplication;
    import com.zsx.mongo.pojo.ApAssociateWords;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.data.domain.Sort;
    import org.springframework.data.mongodb.core.MongoTemplate;
    import org.springframework.data.mongodb.core.query.Criteria;
    import org.springframework.data.mongodb.core.query.Query;
    import org.springframework.test.context.junit4.SpringRunner;
    
    import java.util.Date;
    import java.util.List;
    
    @SpringBootTest(classes = MongoApplication.class)
    @RunWith(SpringRunner.class)
    public class MongoTest {
        
    
    
        @Autowired
        private MongoTemplate mongoTemplate;
    
        //保存
        @Test
        public void saveTest(){
        
            /*for (int i = 0; i < 10; i++) {
                ApAssociateWords apAssociateWords = new ApAssociateWords();
                apAssociateWords.setAssociateWords("黑马头条");
                apAssociateWords.setCreatedTime(new Date());
                mongoTemplate.save(apAssociateWords);
            }*/
            ApAssociateWords apAssociateWords = new ApAssociateWords();
            apAssociateWords.setAssociateWords("黑马直播");
            apAssociateWords.setCreatedTime(new Date());
            mongoTemplate.save(apAssociateWords);
    
        }
    
        //查询一个
        @Test
        public void saveFindOne(){
        
            ApAssociateWords apAssociateWords = mongoTemplate.findById("60bd973eb0c1d430a71a7928", ApAssociateWords.class);
            System.out.println(apAssociateWords);
        }
    
        //条件查询
        @Test
        public void testQuery(){
        
            Query query = Query.query(Criteria.where("associateWords").is("黑马头条"))
                    .with(Sort.by(Sort.Direction.DESC,"createdTime"));
            //query.with(Sort.by(Sort.Direction.DESC,"createdTime"));  //按createdTime倒序排序
            //query.limit(userSearchDto.getPageSize());  //查询多少条
            List<ApAssociateWords> apAssociateWordsList = mongoTemplate.find(query, ApAssociateWords.class);
            System.out.println(apAssociateWordsList);
        }
    
        @Test
        public void testDel(){
        
            mongoTemplate.remove(Query.query(Criteria.where("associateWords").is("黑马头条")),ApAssociateWords.class);
        }
    }

> tips: 使用navicat Premium 15以上版本，可以连接MongoDB 查看数据