springboot2 连接mongodb4

比眉伴天荒 2023-07-24 11:32 10阅读 0赞

[Win10 安装 MongoDB4][Win10 _ MongoDB4]

**创建项目时引入mongodb**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhdmVxaW5n_size_16_color_FFFFFF_t_70][]

**项目结构**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhdmVxaW5n_size_16_color_FFFFFF_t_70 1][]

**pom.xml**

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

**application.yml**

spring:
      data:
        mongodb:
          database: spring
          uri: mongodb://127.0.0.1:27017

**Programmer.java (Bean)**

package com.heibaiying.springboot.bean;
    
    import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    import org.springframework.data.annotation.Id;
    
    import java.util.Date;
    
    /**
     * @author : heibaiying
     */
    @Data
    @AllArgsConstructor
    @NoArgsConstructor
    public class Programmer {
    
        @Id
        private String name;
    
        private Integer age;
    
        private Float salary;
    
        private Date birthday;
    
        private Boolean flag;
    }

**ProgrammerRepository.java (Dao)**

package com.heibaiying.springboot.repository;
    
    import com.heibaiying.springboot.bean.Programmer;
    import org.springframework.data.mongodb.repository.MongoRepository;
    
    /**
     * @author : heibaiying
     * @description : jpa 方式查询 对于mongo而言 更推荐这种查询方式 比起原生的语法更加简洁
     */
    public interface ProgrammerRepository extends MongoRepository<Programmer, String> {
    
        void deleteAllByName(String name);
    
        Programmer findAllByName(String names);
    
        Programmer findByNameAndAge(String name, Integer age);
    
    }

**MongoJPATests.java (基于MongoRepository的方式)**

package com.heibaiying.springboot;
    
    import com.heibaiying.springboot.bean.Programmer;
    import com.heibaiying.springboot.repository.ProgrammerRepository;
    import org.junit.Assert;
    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.test.context.junit4.SpringRunner;
    
    import java.util.ArrayList;
    import java.util.Date;
    import java.util.List;
    import java.util.Optional;
    
    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class MongoJPATests {
    
        @Autowired
        private ProgrammerRepository repository;
    
        @Test
        public void insert() {
            // 单条插入
            repository.save(new Programmer("python", 23, 21832.34f, new Date(), true));
            // 批量插入
            List<Programmer> programmers = new ArrayList<Programmer>();
            programmers.add(new Programmer("java", 21, 52200.21f, new Date(), false));
            programmers.add(new Programmer("Go", 34, 500.21f, new Date(),false));
            repository.saveAll(programmers);
        }
    
        // 条件查询
        @Test
        public void select() {
            Programmer java = repository.findByNameAndAge("java", 21);
            Assert.assertEquals(java.getSalary(), 52200.21f, 0.01);
        }
    
    
        // 更新数据
        @Test
        public void MUpdate() {
            repository.save(new Programmer("Go", 8, 500.21f, new Date(), false));
            Programmer go = repository.findAllByName("Go");
            Assert.assertEquals(go.getAge(), new Integer(8));
        }
    
        // 删除指定数据
        @Test
        public void delete() {
            repository.deleteAllByName("python");
            Optional<Programmer> python = repository.findById("python");
            Assert.assertFalse(python.isPresent());
        }
    
    }

**MongoOriginalTests.java (基于MongoTemplate的方式)**

package com.heibaiying.springboot;
    
    import com.heibaiying.springboot.bean.Programmer;
    import com.mongodb.client.result.DeleteResult;
    import com.mongodb.client.result.UpdateResult;
    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.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.ArrayList;
    import java.util.Date;
    import java.util.List;
    
    import static org.springframework.data.mongodb.core.query.Criteria.where;
    import static org.springframework.data.mongodb.core.query.Query.query;
    import static org.springframework.data.mongodb.core.query.Update.update;
    
    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class MongoOriginalTests {
    
        @Autowired
        private MongoTemplate mongoTemplate;
    
        @Test
        public void insert() {
            // 单条插入
            mongoTemplate.insert(new Programmer("xiaoming", 12, 5000.21f, new Date(),true));
            List<Programmer> programmers = new ArrayList<Programmer>();
            // 批量插入
            programmers.add(new Programmer("xiaohong", 21, 52200.21f, new Date(),false));
            programmers.add(new Programmer("xiaolan", 34, 500.21f, new Date(),false));
            mongoTemplate.insert(programmers, Programmer.class);
        }
    
        // 条件查询
        @Test
        public void select() {
            Criteria criteria = new Criteria();
            criteria.andOperator(where("name").is("xiaohong"), where("age").is(21));
            Query query = new Query(criteria);
            Programmer one = mongoTemplate.findOne(query, Programmer.class);
            System.out.println(one);
        }
    
    
        // 更新数据
        @Test
        public void MUpdate() {
            UpdateResult updateResult = mongoTemplate.updateMulti(query(where("name").is("xiaoming")), update("age", 35), Programmer.class);
            System.out.println("更新记录数：" + updateResult.getModifiedCount());
        }
    
        // 删除指定数据
        @Test
        public void delete() {
            DeleteResult result = mongoTemplate.remove(query(where("name").is("xiaolan")), Programmer.class);
            System.out.println("影响记录数：" + result.getDeletedCount());
            System.out.println("是否成功：" + result.wasAcknowledged());
        }
    
    }

jpa支持很多方法命名规则来自动生成查询语句

<table> 
 <thead> 
  <tr> 
   <th>Keyword</th> 
   <th>Sample</th> 
   <th>Logical result</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>After</td> 
   <td>findByBirthdateAfter(Date date)</td> 
   <td>{“birthdate” : {“$gt” : date}}</td> 
  </tr> 
  <tr> 
   <td>GreaterThan</td> 
   <td>findByAgeGreaterThan(int age)</td> 
   <td>{“age” : {“$gt” : age}}</td> 
  </tr> 
  <tr> 
   <td>GreaterThanEqual</td> 
   <td>findByAgeGreaterThanEqual(int age)</td> 
   <td>{“age” : {“$gte” : age}}</td> 
  </tr> 
  <tr> 
   <td>Before</td> 
   <td>findByBirthdateBefore(Date date)</td> 
   <td>{“birthdate” : {“$lt” : date}}</td> 
  </tr> 
  <tr> 
   <td>LessThan</td> 
   <td>findByAgeLessThan(int age)</td> 
   <td>{“age” : {“$lt” : age}}</td> 
  </tr> 
  <tr> 
   <td>LessThanEqual</td> 
   <td>findByAgeLessThanEqual(int age)</td> 
   <td>{“age” : {“$lte” : age}}</td> 
  </tr> 
  <tr> 
   <td>Between</td> 
   <td>findByAgeBetween(int from, int to)</td> 
   <td>{“age” : {“$gt” : from, “$lt” : to}}</td> 
  </tr> 
  <tr> 
   <td>In</td> 
   <td>findByAgeIn(Collection ages)</td> 
   <td>{“age” : {“$in” : [ages…]}}</td> 
  </tr> 
  <tr> 
   <td>NotIn</td> 
   <td>findByAgeNotIn(Collection ages)</td> 
   <td>{“age” : {“$nin” : [ages…]}}</td> 
  </tr> 
  <tr> 
   <td>IsNotNull, NotNull</td> 
   <td>findByFirstnameNotNull()</td> 
   <td>{“firstname” : {“$ne” : null}}</td> 
  </tr> 
  <tr> 
   <td>IsNull, Null</td> 
   <td>findByFirstnameNull()</td> 
   <td>{“firstname” : null}</td> 
  </tr> 
  <tr> 
   <td>Like, StartingWith, EndingWith</td> 
   <td>findByFirstnameLike(String name)</td> 
   <td>{“firstname” : name} (name as regex)</td> 
  </tr> 
  <tr> 
   <td>NotLike, IsNotLike</td> 
   <td>findByFirstnameNotLike(String name)</td> 
   <td>{“firstname” : { “$not” : name }} (name as regex)</td> 
  </tr> 
  <tr> 
   <td>Containing on String</td> 
   <td>findByFirstnameContaining(String name)</td> 
   <td>{“firstname” : name} (name as regex)</td> 
  </tr> 
  <tr> 
   <td>NotContaining on String</td> 
   <td>findByFirstnameNotContaining(String name)</td> 
   <td>{“firstname” : { “$not” : name}} (name as regex)</td> 
  </tr> 
  <tr> 
   <td>Containing on Collection</td> 
   <td>findByAddressesContaining(Address address)</td> 
   <td>{“addresses” : { “$in” : address}}</td> 
  </tr> 
  <tr> 
   <td>NotContaining on Collection</td> 
   <td>findByAddressesNotContaining(Address address)</td> 
   <td>{“addresses” : { “$not” : { “$in” : address}}}</td> 
  </tr> 
  <tr> 
   <td>Regex</td> 
   <td>findByFirstnameRegex(String firstname)</td> 
   <td>{“firstname” : {“$regex” : firstname }}</td> 
  </tr> 
  <tr> 
   <td>(No keyword)</td> 
   <td>findByFirstname(String name)</td> 
   <td>{“firstname” : name}</td> 
  </tr> 
  <tr> 
   <td>Not</td> 
   <td>findByFirstnameNot(String name)</td> 
   <td>{“firstname” : {“$ne” : name}}</td> 
  </tr> 
  <tr> 
   <td>Near</td> 
   <td>findByLocationNear(Point point)</td> 
   <td>{“location” : {“$near” : [x,y]}}</td> 
  </tr> 
  <tr> 
   <td>Near</td> 
   <td>findByLocationNear(Point point, Distance max)</td> 
   <td>{“location” : {“$near” : [x,y], “$maxDistance” : max}}</td> 
  </tr> 
  <tr> 
   <td>Near</td> 
   <td>findByLocationNear(Point point, Distance min, Distance max)</td> 
   <td>{“location” : {“$near” : [x,y], “$minDistance” : min, “$maxDistance” : max}}</td> 
  </tr> 
  <tr> 
   <td>Within</td> 
   <td>findByLocationWithin(Circle circle)</td> 
   <td>{“location” : {“$geoWithin” : {“$center” : [ [x, y], distance]}}}</td> 
  </tr> 
  <tr> 
   <td>Within</td> 
   <td>findByLocationWithin(Box box)</td> 
   <td>{“location” : {“$geoWithin” : {“$box” : [ [x1, y1], x2, y2]}}}</td> 
  </tr> 
  <tr> 
   <td>IsTrue, True</td> 
   <td>findByActiveIsTrue()</td> 
   <td>{“active” : true}</td> 
  </tr> 
  <tr> 
   <td>IsFalse, False</td> 
   <td>findByActiveIsFalse()</td> 
   <td>{“active” : false}</td> 
  </tr> 
  <tr> 
   <td>Exists</td> 
   <td>findByLocationExists(boolean exists)</td> 
   <td>{“location” : {“$exists” : exists }}</td> 
  </tr> 
 </tbody> 
</table>

![20200414010840915.png][]

转自源码：

[https://github.com/heibaiying/spring-samples-for-all][https_github.com_heibaiying_spring-samples-for-all]

[https://github.com/heibaiying/spring-samples-for-all/tree/master/spring-boot/spring-boot-mongodb][https_github.com_heibaiying_spring-samples-for-all_tree_master_spring-boot_spring-boot-mongodb]

spring boot mongodb英文文档

[https://docs.spring.io/spring-boot/docs/2.2.6.RELEASE/reference/htmlsingle/\#boot-features-mongodb][https_docs.spring.io_spring-boot_docs_2.2.6.RELEASE_reference_htmlsingle_boot-features-mongodb]

spring boot mongodb中文文档

[https://docshome.gitbooks.io/springboot/content/pages/spring-boot-features.html\#boot-features-mongodb][https_docshome.gitbooks.io_springboot_content_pages_spring-boot-features.html_boot-features-mongodb]

MongoDB官方文档

[https://docs.mongodb.com/][https_docs.mongodb.com]

MongoDB 教程

[https://www.runoob.com/mongodb/mongodb-tutorial.html][https_www.runoob.com_mongodb_mongodb-tutorial.html]

MongoDB中文网

[https://www.mongodb.org.cn/][https_www.mongodb.org.cn]

MongoDB教程

[https://www.mongodb.org.cn/tutorial/][https_www.mongodb.org.cn_tutorial]

[spring 5.x 系列第9篇 —— 整合mongodb (xml配置方式)][spring 5.x _9_ _ _mongodb _xml]

[spring 5.x 系列第10篇 —— 整合mongodb (代码配置方式)][spring 5.x _10_ _ _mongodb]

[MongoDB 基本使用][MongoDB]  
[MongoDB 索引详解][MongoDB 1]  
[MongoDB 聚合管道][MongoDB 2]  
[MongoDB 高可用基础之副本集][MongoDB 3]  
[MongoDB 高可用集群架构][MongoDB 4]

[Win10 _ MongoDB4]: https://blog.csdn.net/haveqing/article/details/105300928
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhdmVxaW5n_size_16_color_FFFFFF_t_70]: /images/20230528/d5c1573f46cc48639d727bf8ad8307f5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhdmVxaW5n_size_16_color_FFFFFF_t_70 1]: /images/20230528/6d432aef22774ba08806d460bf5eb8e7.png
[20200414010840915.png]: /images/20230528/3c86a0fe96d6499192d0e2882a455eee.png
[https_github.com_heibaiying_spring-samples-for-all]: https://github.com/heibaiying/spring-samples-for-all
[https_github.com_heibaiying_spring-samples-for-all_tree_master_spring-boot_spring-boot-mongodb]: https://github.com/heibaiying/spring-samples-for-all/tree/master/spring-boot/spring-boot-mongodb
[https_docs.spring.io_spring-boot_docs_2.2.6.RELEASE_reference_htmlsingle_boot-features-mongodb]: https://docs.spring.io/spring-boot/docs/2.2.6.RELEASE/reference/htmlsingle/#boot-features-mongodb
[https_docshome.gitbooks.io_springboot_content_pages_spring-boot-features.html_boot-features-mongodb]: https://docshome.gitbooks.io/springboot/content/pages/spring-boot-features.html#boot-features-mongodb
[https_docs.mongodb.com]: https://docs.mongodb.com/
[https_www.runoob.com_mongodb_mongodb-tutorial.html]: https://www.runoob.com/mongodb/mongodb-tutorial.html
[https_www.mongodb.org.cn]: https://www.mongodb.org.cn/
[https_www.mongodb.org.cn_tutorial]: https://www.mongodb.org.cn/tutorial/
[spring 5.x _9_ _ _mongodb _xml]: https://blog.csdn.net/m0_37809146/article/details/86679023
[spring 5.x _10_ _ _mongodb]: https://blog.csdn.net/m0_37809146/article/details/86679057
[MongoDB]: https://blog.csdn.net/m0_37809146/article/details/104000172
[MongoDB 1]: https://blog.csdn.net/m0_37809146/article/details/104000200
[MongoDB 2]: https://blog.csdn.net/m0_37809146/article/details/104000223
[MongoDB 3]: https://blog.csdn.net/m0_37809146/article/details/104000274
[MongoDB 4]: https://blog.csdn.net/m0_37809146/article/details/104000348