SpringBoot集成Mongodb的操作方法

更新時(shí)間：2024年11月09日 14:12:05 作者：小疙瘩的編程之路

本文介紹了MongoDB的基本概念、Docker安裝步驟、SpringBoot整合MongoDB的方法,以及MongoRepository和MongoTemplate的區(qū)別,感興趣的朋友一起看看吧

1.什么是mongoDB？

MongoDB是一種非關(guān)系型數(shù)據(jù)庫(kù)，被廣泛用于大型數(shù)據(jù)存儲(chǔ)和分布式系統(tǒng)的構(gòu)建。MongoDB支持的數(shù)據(jù)模型比傳統(tǒng)的關(guān)系型數(shù)據(jù)庫(kù)更加靈活，支持動(dòng)態(tài)查詢(xún)和索引，也支持json格式和bson格式的數(shù)據(jù)存儲(chǔ)，這種格式可以支持讀取和寫(xiě)入大量的數(shù)據(jù)。

2.Docker安裝mongoDB

2.1拉取鏡像

docker pull mongo:4.4

2.2創(chuàng)建mongo數(shù)據(jù)持久化目錄 (看自己愛(ài)好,放哪里都行)

mkdir -p /docker_volume/mongodb/data

2.3啟動(dòng)容器

docker run -itd --name mongo -v /docker_volume/mongodb/data:/data/db -p 27017:27017 mongo:4.4 --auth

2.4創(chuàng)建用戶(hù)

1.使用以下命令進(jìn)入容器的 MongoDB shell：

docker exec -it mongo mongo admin

2.創(chuàng)建一個(gè)用戶(hù)，mongo 默認(rèn)沒(méi)有用戶(hù)

    
db.createUser({
  user: 'root',
  pwd: 'xgd@123',
  roles: [
    { role: 'readWriteAnyDatabase', db: 'admin' },
    { role: 'dbAdminAnyDatabase', db: 'admin' }
  ]
});

命令解釋?zhuān)?/p>

-d：表示在后臺(tái)運(yùn)行容器，并返回容器 ID。

-i：表示交互式運(yùn)行容器，保留 STDIN 打開(kāi)。

--name mongo-service：為容器指定一個(gè)名稱(chēng)，這里為 mongo-service。

--restart=always：表示在容器退出后自動(dòng)重啟容器。

-p 27017:27017：將容器的 27017 端口映射到宿主機(jī)的 27017 端口。

-v ~/data/mongodata:/data：將宿主機(jī)的 ~/data/mongodata 目錄掛載到容器的 /data 目錄下，用于持久化存儲(chǔ)數(shù)據(jù)。

mongo：指定要運(yùn)行的鏡像名稱(chēng)，這里為官方的 MongoDB 鏡像。

3.SpringBoot整合MongoDB步驟

1.導(dǎo)入依賴(lài)

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

2.配置

spring:
  data:
    mongodb:
      host: 你的ip
      port: 27017
      username: root
      password: 123
      authenticationDatabase: admin
      database: test

3.操作MongoDB 第一種方式使用MongoTemplate‌工具類(lèi) 添加實(shí)體類(lèi)

import lombok.Data;
import org.springframework.data.mongodb.core.mapping.Document;
import java.io.Serializable;
import java.util.Date;
/**
 * 映射表 test_demo
 */
@Data
@Document("test_demo")
public class TestDemo implements Serializable {
    private static final long serialVersionUID = 1L;
    private String id;
    private String name;
    private Date birthDay;
}

測(cè)試

/**
 * MongoDB測(cè)試類(lèi)
 * */
@SpringBootTest(classes = MongoApplication.class)
@RunWith(SpringRunner.class)
public class MongoTest1 {
    @Autowired
    private MongoTemplate mongoTemplate;
    //保存
    @Test
    public void saveTest(){
        for (int i = 0; i < 10; i++) {
            TestDemo testDemo = new TestDemo();
            testDemo.setName("張三");
            testDemo.setBirthDay(new Date());
             mongoTemplate.save(testDemo);
        }
        TestDemo testDemo = new TestDemo();
        testDemo.setName("張三你吃飯了嗎");
        testDemo.setBirthDay(new Date());
        mongoTemplate.save(testDemo);
    }
    //查詢(xún)一個(gè)
    @Test
    public void saveFindOne(){
        TestDemo testDemo = mongoTemplate.findById("661743b77bee2f0a5739819d", TestDemo.class);
        System.out.println(testDemo);
        //TestDemo(id=661743b77bee2f0a5739819d, name=張三, birthDay=Thu Apr 11 09:58:15 CST 2024)
    }
    //條件查詢(xún)
    @Test
    public void testQuery(){
        //查詢(xún)字段name為張三的數(shù)據(jù)（多條件查詢(xún)）
        Query query = Query.query(Criteria.where("name").is("張三"))
                .with(Sort.by(Sort.Direction.DESC,"birthDay"));
        // 執(zhí)行查詢(xún) 模糊查詢(xún) 只查詢(xún)5條數(shù)據(jù)
        Query query1 = Query.query(Criteria.where("name").regex(".*?\\" + "張三" + ".*"));
        query.limit(5);
        List<TestDemo> list = mongoTemplate.find(query, TestDemo.class);
        List<TestDemo> list1 = mongoTemplate.find(query1, TestDemo.class);
        System.out.println("list:"+list);
        System.out.println("list1:"+list1);
    }
    //測(cè)試刪除
    @Test
    public void testDel(){
        mongoTemplate.remove(Query.query(Criteria.where("name").is("張三")),TestDemo.class);
    }
}

第二種方式使用繼承MongoRepository

添加實(shí)體類(lèi)

package com.xsp.spm.domain;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.index.Indexed;
import org.springframework.data.mongodb.core.mapping.Document;
/**
 * @Author：xsp
 * @Description:
 * @name：User
 * @Date：2024/9/14 17:24
 */
@Data
@Document(collection = "users")
public class User {
    @Id
    private String id;
    @Indexed(unique = true)
    private String name;
    private Integer age;
}

repository層

package com.xsp.spm.repository;
import com.xsp.spm.domain.User;
import org.springframework.data.mongodb.repository.MongoRepository;
import org.springframework.stereotype.Repository;
/**
 * @Author：xsp
 * @Description:
 * @name：UserRepository
 * @Date：2024/9/14 17:25
 */
@Repository
public interface UserRepository extends MongoRepository<User, String> {
}

controller層

package com.xsp.spm.controller;
import com.xsp.spm.domain.User;
import com.xsp.spm.repository.UserRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.web.bind.annotation.*;
/**
 * @Author：xsp
 * @Description:
 * @name：UserController
 * @Date：2024/9/14 17:26
 */
@RestController
public class UserController {
    @Autowired
    private UserRepository userRepository;
    // 添加
    @PostMapping
    public User createUser(@RequestBody User user) {
        return userRepository.save(user);
    }
    // 詳細(xì)
    @GetMapping("/{id}")
    public User getUser(@PathVariable String id) {
        return userRepository.findById(id).orElse(null);
    }
    // 刪除
    @DeleteMapping("/{id}")
    public void deleteUser(@PathVariable String id) {
        userRepository.deleteById(id);
    }
    // 修改
    @PutMapping("/{id}")
    public User updateUser(@PathVariable String id, @RequestBody User user) {
        User userFromDb = userRepository.findById(id).orElse(null);
        if (userFromDb != null) {
            userFromDb.setName(user.getName());
            userFromDb.setAge(user.getAge());
            return userRepository.save(userFromDb);
        }
        return null;
    }
    // 列表
    @GetMapping
    public Iterable<User> getAllUsers() {
        return userRepository.findAll();
    }
}

mongoDB 中MongoRepository和MongoTemplate的區(qū)別

MongoRepository‌：

特點(diǎn)‌：MongoRepository是Spring Data MongoDB的一部分，它提供了一種面向?qū)ο蟮姆绞絹?lái)操作MongoDB。通過(guò)繼承MongoRepository接口，可以很容易地實(shí)現(xiàn)CRUD操作和一些基本的查詢(xún)操作。這種方式不需要編寫(xiě)原生的查詢(xún)語(yǔ)句，使得操作更加簡(jiǎn)單和直觀(guān)‌1。

‌ 適用場(chǎng)景‌：當(dāng)查詢(xún)需求簡(jiǎn)單，可以通過(guò)方法名命名規(guī)則進(jìn)行快速的CRUD操作時(shí)，使用MongoRepository是一個(gè)不錯(cuò)的選擇。它適用于基本的CRUD操作和一些簡(jiǎn)單查詢(xún)，但如果需要執(zhí)行復(fù)雜的聚合或定制查詢(xún)，可能不夠靈活‌1。

MongoTemplate‌：

特點(diǎn)‌：MongoTemplate是Spring Data MongoDB中更低級(jí)別的工具，它提供了更豐富的操作方法，包括條件查詢(xún)、模糊查詢(xún)、分頁(yè)查詢(xún)、數(shù)據(jù)修改和刪除等。MongoTemplate允許更靈活的操作，包括原生的查詢(xún)語(yǔ)句，提供了更大的靈活性來(lái)處理復(fù)雜的查詢(xún)和數(shù)據(jù)操作‌2。

‌ 適用場(chǎng)景‌：當(dāng)需要執(zhí)行復(fù)雜的查詢(xún)或定制操作時(shí)，MongoTemplate可以彌補(bǔ)MongoRepository的不足。它適用于需要更多控制和靈活性的場(chǎng)景，如執(zhí)行復(fù)雜的聚合查詢(xún)或定制的數(shù)據(jù)處理任務(wù)‌

總結(jié)來(lái)說(shuō)，MongoRepository適合簡(jiǎn)單的CRUD操作和一些基本的查詢(xún)需求，而MongoTemplate則提供了更豐富的功能和更大的靈活性，適用于需要執(zhí)行復(fù)雜查詢(xún)或定制操作的場(chǎng)景。選擇使用哪一個(gè)取決于具體的應(yīng)用需求和技術(shù)棧‌