Spring整合MongoDB详细讲解（maven项目）

朴灿烈づ我的快乐病毒、 2022-09-23 12:52 231阅读 0赞

**pom.xml**

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      <modelVersion>4.0.0</modelVersion>
    
      <groupId>SpringMongo</groupId>
      <artifactId>SpringMongo</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <packaging>jar</packaging>
    
      <name>SpringMongo</name>
      <url>http://maven.apache.org</url>
    
      <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
      </properties>
    
      <dependencies>
        <dependency>
          <groupId>junit</groupId>
          <artifactId>junit</artifactId>
          <version>4.9</version>
          <scope>test</scope>
        </dependency>
        
        
    <dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-core</artifactId>
    <version>4.1.7.RELEASE</version>
    <exclusions>
     <exclusion>
    <groupId>commons-logging</groupId>
    <artifactId>commons-logging</artifactId>
     </exclusion>
    </exclusions>
     </dependency>
    <dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-mongodb</artifactId>
    <version>1.7.2.RELEASE</version>
    </dependency>
      </dependencies>
    </project>

**applicationContext.xml**

**User.java**

package com.springmongo.entity;
    import org.springframework.data.mongodb.core.mapping.Document;
    
    @Document(collection="users")
    public class User {
    private String name;
    private int age;
    public User() {
    }
    public User(String name, int age) {
    this.name = name;
    this.age = age;
    }
    public String getName() {
    return name;
    }
    public void setName(String name) {
    this.name = name;
    }
    public int getAge() {
    return age;
    }
    public void setAge(int age) {
    this.age = age;
    }
    
    @Override
    public String toString() {
    return "User [name=" + name + ", age=" + age + "]";
    }
    
    }

**App.java**

package com.springmongo;
    
    import java.util.List;
    import org.junit.Test;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    import org.springframework.data.domain.Sort;
    import org.springframework.data.domain.Sort.Direction;
    import org.springframework.data.domain.Sort.Order;
    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.data.mongodb.core.query.Update;
    import com.springmongo.entity.User;
    
    public class App 
    {
    private static MongoTemplate template;
    static{
    ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");
            template = (MongoTemplate) applicationContext.getBean("mongoTemplate");
    }
        @Test
        public void findAll(){
        List<User> list = template.findAll(User.class);
        for (User user : list) {
    System.out.println(user.toString());
    }
        }
        @Test
        public void findAllSortByAge(){
        Query query=new Query();
        query.with(new Sort(new Order(Direction.DESC,"age")));
        List<User> list = template.find(query,User.class);
        for (User user : list) {
    System.out.println(user.toString());
    }
        }
        @Test
        public void findByCondition(){
        List<User> list = template.find(new Query(Criteria.where("name").is("小宝").
        andOperator(Criteria.where("age").is(301))),
        User.class);
        for (User user : list) {
    System.out.println(user.toString());
    }
        }
        @Test
        public void limit(){
        List<User> list = template.find(new Query().skip(1).limit(3), User.class);
        for (User user : list) {
    System.out.println(user.toString());
    }
        }
        @Test
        public void count(){
        long count = template.count(new Query(Criteria.where("name").is("小宝")), User.class);
        System.out.println(count);
        }
        @Test
        public void update(){
        template.updateMulti(new Query(Criteria.where("age").gt(30)),
        new Update().set("name", "小宝"),
        User.class);
        findAll();
        }
        @Test
        public void insert(){
        User user=new User("小奇", 45);
        template.insert(user, "users");
        findAll();
        }
        @Test
        public void delete(){
        template.remove(new Query(Criteria.where("age").is(20)), User.class);
        findAll();
        }
    }