SpringBoot整合MongoDB

摘要：本文介绍了 MongDB 的安装以及在 SpringBoot 中如何使用

MongoDB 的安装

---

这里使用 docker 来安装 MongoDB，首先进入 cmd，输入以下命令拉取镜像

bash

docker pull mongo

将 mongo 的镜像拉取下来之后，输入以下命令启动 mongo

bash

docker run -d -p 27017:27017 --name mongo --restart:always -e MONGO_INITDB_ROOT_USERNAME=username -e MONGO_INITDB_ROOT_PASSWORD=password

启动 mongo 后就可以使用了，可以使用 Robo 3T 来连接 mongo

在 SpringBoot 中使用 MongoDB

---

添加依赖

xml

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

在 application.properties 中配置

properties

spring.data.mongodb.host=127.0.0.1
spring.data.mongodb.authentication-database=admin
spring.data.mongodb.username=wellenzheng
spring.data.mongodb.password=11215858
spring.data.mongodb.port=27017
spring.data.mongodb.database=JavaBoy

创建 Book 实体类

java

package com.example.mongodb.bean;

/**
 * @author: WJZheng
 * @date: 2020/3/25 17:55
 * @description:
 */
public class Book {
    private Integer id;
    private String name;
    private String author;

    @Override
    public String toString() {
        return "Book{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", author='" + author + '\'' +
                '}';
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getAuthor() {
        return author;
    }

    public void setAuthor(String author) {
        this.author = author;
    }
}

两种方式操纵 MongoDB

MongoRepository<T, ID>

MongoRepository<T, ID> 使用的是 Spring Data 的处理方式

创建 BookDao 接口

我们可以看到，dao 接口只需要继承自 MongoRepository<T, ID> 即可，T 是实体类，ID 是实体类的主键。

java

package com.example.mongodb.dao;

import com.example.mongodb.bean.Book;
import org.springframework.data.mongodb.repository.MongoRepository;

import java.util.List;

/**
 * @author: WJZheng
 * @date: 2020/3/25 17:56
 * @description:
 */
public interface BookDao extends MongoRepository<Book, Integer> {
    List<Book> findBookByNameContaining(String s);
}

在 Test 中测试

java

package com.example.mongodb;

import com.example.mongodb.bean.Book;
import com.example.mongodb.dao.BookDao;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.mongodb.core.MongoTemplate;

import java.util.List;

@SpringBootTest
class MongodbApplicationTests {

    @Autowired
    BookDao bookDao;

    @Test
    void contextLoads() {
        Book book = new Book();
        book.setId(1);
        book.setName("ThreeBody");
        book.setAuthor("Liu Cixin");
        bookDao.insert(book);
    }

    @Test
    void test1(){
        List<Book> bookList = bookDao.findAll();
        System.out.println(bookList);
    }

    @Test
    void test2(){
        List<Book> bookList = bookDao.findBookByNameContaining("Three");
        System.out.println(bookList);
    }
}

MongoTemplate

MongoTemplate 直接注入进来使用即可

java

package com.example.mongodb;

import com.example.mongodb.bean.Book;
import com.example.mongodb.dao.BookDao;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.mongodb.core.MongoTemplate;

import java.util.List;

@SpringBootTest
class MongodbApplicationTests {
    
    @Autowired
    MongoTemplate mongoTemplate;

    @Test
    void test3(){
        Book book = new Book();
        book.setId(2);
        book.setName("BallLightning");
        book.setAuthor("Liu Cixin");
        mongoTemplate.insert(book);
    }

    @Test
    void test4(){
        List<Book> bookList = mongoTemplate.findAll(Book.class);
        System.out.println(bookList);
    }
}