實例講解Springboot整合MongoDB進行CRUD操作的兩種方式

来源:https://www.cnblogs.com/larrydpk/archive/2020/04/20/12735620.html
-Advertisement-
Play Games

1 簡介 是最簡單的使用 的方式，而 是最流行的 資料庫。兩者在分散式、微服務架構中使用率極高，本文將用實例介紹如何在 中整合 的兩種方法： 和`MongoTemplate`。 代碼結構如下： 2 項目準備 2.1 啟動MongoDB實例 為了方便，使用 來啟動 ，詳細指導文檔請參考： "用Dock ...


1 簡介

Springboot是最簡單的使用Spring的方式，而MongoDB是最流行的NoSQL資料庫。兩者在分散式、微服務架構中使用率極高，本文將用實例介紹如何在Springboot中整合MongoDB的兩種方法：MongoRepository和MongoTemplate。

代碼結構如下：

code

2 項目準備

2.1 啟動MongoDB實例

為了方便，使用Docker來啟動MongoDB，詳細指導文檔請參考：用Docker安裝一個MongoDB最新版玩玩 ，這裡不再贅述。

2.2 引入相關依賴

主要的依賴為Web和MongoDB的starter，把下麵代碼加入到pom.xml中即可：

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

2.3 配置資料庫連接信息

與配置MySQL或Oracle一樣，MongoDB也需要配置連接信息，配置在application.properties中如下：

server.port=8080

spring.data.mongodb.authentication-database=admin
spring.data.mongodb.database=testdb
spring.data.mongodb.username=user
spring.data.mongodb.password=123456
spring.data.mongodb.host=localhost
spring.data.mongodb.port=27017

2.4 創建數據模型實體

創建User類如下：

package com.pkslow.mongo.model;

import org.springframework.data.annotation.Id;
import java.util.Date;

public class User {
    @Id
    private String userId;
    private String name;
    private Integer age;
    private Date createTime = new Date();

    public String getUserId() {
        return userId;
    }

    public void setUserId(String userId) {
        this.userId = userId;
    }

    public String getName() {
        return name;
    }

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

    public Integer getAge() {
        return age;
    }

    public void setAge(Integer age) {
        this.age = age;
    }

    public Date getCreateTime() {
        return createTime;
    }

    public void setCreateTime(Date createTime) {
        this.createTime = createTime;
    }
}

不需要在MongoDB中創建對應的Collections（表），當通過Web應用新增時會自動創建。

3 方式1：MongoRepository

3.1 定義數據訪問層UserRepository

使用過Spring Jpa的都清楚，Repository實際就是用於操作資料庫的類。在非關係型資料庫MongoDB的整合中，也是一樣的。Spring會幫我們實現好對應介面的方法，開發人員連SQL都不用寫，非常省心。代碼如下：

package com.pkslow.mongo.dal;

import com.pkslow.mongo.model.User;
import org.springframework.data.mongodb.repository.MongoRepository;
import org.springframework.stereotype.Repository;

@Repository
public interface UserRepository extends MongoRepository<User, String> {
}

註意MongoRepository後面接的泛型<User, String>第一個為實體類，第二個為主鍵ID。

3.2 實現Controller

Controller比較基礎，就不講解了，常用的註解是必須要掌握的，直接上代碼吧：

package com.pkslow.mongo.contrlloer;

import com.pkslow.mongo.dal.UserRepository;
import com.pkslow.mongo.model.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.List;

@RestController
@RequestMapping("/user")
public class UserController {
    @Autowired
    private final UserRepository userRepository;

    public UserController(UserRepository userRepository) {
        this.userRepository = userRepository;
    }

    @GetMapping("")
    public List<User> getAllUsers() {
        return userRepository.findAll();
    }

    @GetMapping("/{userId}")
    public User getByUserId(@PathVariable String userId) {
        return userRepository.findById(userId).orElse(new User());
    }

    @PostMapping("")
    public User addNewUser(@RequestBody User user) {
        return userRepository.save(user);
    }

    @DeleteMapping("/{userId}")
    public String delete(@PathVariable String userId) {
        User user = new User();
        user.setUserId(userId);
        userRepository.deleteById(userId);
        return "deleted: " + userId;
    }

    @PutMapping("")
    public User update(@RequestBody User user) {
        return userRepository.save(user);
    }
}

註意代碼沒有做異常情況的判斷和處理，這裡為了快速演示，就先不管了。

3.3 測試

用Postman測試後，每個介面均調用成功。就不一一截圖了。

repository.test

4 方式2：MongoTemplate

4.1 定義數據訪問層UserDAL

先定義介面為：

package com.pkslow.mongo.dal;

import com.pkslow.mongo.model.User;
import java.util.List;

public interface UserDAL {
    List<User> findAll();

    User findById(String userId);

    User save(User user);

    void deleteById(String userId);
}

然後實現該介面如下：

package com.pkslow.mongo.dal;

import com.pkslow.mongo.model.User;
import org.springframework.beans.factory.annotation.Autowired;
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.stereotype.Repository;
import java.util.List;

@Repository
public class UserDALImpl implements UserDAL {

    @Autowired
    private MongoTemplate template;

    @Override
    public List<User> findAll() {
        return template.findAll(User.class);
    }

    @Override
    public User findById(String userId) {
        return template.findById(userId,User.class);
    }

    @Override
    public User save(User user) {
        return template.save(user);
    }

    @Override
    public void deleteById(String userId) {
        Query query = new Query();
        query.addCriteria(Criteria.where("userId").is(userId));
        template.remove(query, User.class);
    }
}

4.2 實現另一個Controller

這個Controller的代碼與之前的基本一樣，只是數據訪問類不一樣，代碼如下：

package com.pkslow.mongo.contrlloer;

import com.pkslow.mongo.dal.UserDAL;
import com.pkslow.mongo.model.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.List;

@RestController
@RequestMapping("/userTemplate")
public class UserTemplateController {

    @Autowired
    private final UserDAL userDAL;

    public UserTemplateController(UserDAL userDAL) {
        this.userDAL = userDAL;
    }


    @GetMapping("")
    public List<User> getAllUsers() {
        return userDAL.findAll();
    }

    @GetMapping("/{userId}")
    public User getByUserId(@PathVariable String userId) {
        return userDAL.findById(userId);
    }

    @PostMapping("")
    public User addNewUser(@RequestBody User user) {
        return userDAL.save(user);
    }

    @DeleteMapping("/{userId}")
    public String delete(@PathVariable String userId) {
        User user = new User();
        user.setUserId(userId);
        userDAL.deleteById(userId);
        return "deleted: " + userId;
    }

    @PutMapping("")
    public User update(@RequestBody User user) {
        return userDAL.save(user);
    }
}

4.3 測試

測試一樣也是全部通過：

template.test

5 總結

本文通過實例講解瞭如何整合Springboot和MongoDB，主要有兩種方法：MongoRepository和MongoTemplate。代碼基本在文章中已經貼出來了，如果還不清楚，可以在南瓜慢說公眾號回覆<SpringbootMongoDB>獲取代碼。

歡迎訪問南瓜慢說 www.pkslow.com 獲取更多精彩文章！

歡迎關註微信公眾號<南瓜慢說>，將持續為你更新...

多讀書，多分享；多寫作，多整理。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 瀏覽器是多進程還是單進程?
    在前端面試時，面試官經常會問：瀏覽器是多進程還是單進程? 瀏覽器是多進程的，瀏覽器每一個 tab 標簽都代表一個獨立的進程（也不一定，因為多個空白 tab 標簽會合併成一個進程），瀏覽器內核（瀏覽器渲染進程）屬於瀏覽器多進程中的一種。 瀏覽器每個進程有多個線程，主要有以下線程 1）GUI 渲染線程: ...
  • 完全卸載VSCode--解決卸載重新安裝後還有原來配置的問題
    VSCode卸載後進行重新安裝，發現新安裝的還有原來的一些配置，卸載的不徹底，有時候也容易出問題，可按照如下方法卸載乾凈： 1.進入控制面板卸載VSCode，也可以在VSCode的安裝目錄下用程式自帶的卸載程式（這個沒有親自試過.....） 2.這樣卸載完後還有一些配置文件，要想完全卸載，還需要將一 ...
  • JavaScript連載5-數據轉換為Number與String、數字解析
    一、承接連載4 3.null和undefined沒有toString()方法，調用就會報錯 var num1 = undefined; console.log(num1.toString()); ​ var num2 = null; console.log(num2.toString()); 二、S ...
  • JavaScript中簡單的定時器
    定時器功能分析 核心思路: 定義一個變數,根據定時器,每秒執行一次,每次執行++自增操作 變數存儲的數值,就會每秒+1 現在需要的記錄效果,是每0.01秒,也就是10毫秒執行一次 根據累計的數值,執行進位 ms 如果達到 100,就是1秒 如果 秒 達到 60 就是 1分鐘 如果 分鐘 達到 60  ...
  • JavaScript與函數式編程
    JavaScript與函數式編程 絕大多數編程語言都會有函數的概念（或者說所有的？我不太確定），他們都可以做出類似的操作： 但是Javascript更適合函數式編程，因為函數對於js來說，是 一等公民 。 我們可以把匿名函數賦值給一個變數，比如： 然後我們可以將這個函數賦值給另一個變數： 這樣做和直 ...
  • 深入理解new運算符
    在 JavaScript 中，new 運算符創建一個用戶定義的對象類型的實例或具有構造函數的內置對象的實例。創建一個對象很簡單，為什麼我們還要多此一舉使用 new 運算符呢？它到底有什麼樣的魔力？ ...
  • 判斷Input上傳文件類型，文件大小
    判斷input上傳文件類型，文件大小。input獲取的size為位元組，判斷大小的時候需要把限制大小轉換為位元組 ...
  • 記錄：如何使用ASP.NET Core和EnityFramework Core實現 資料庫操作 和 資料庫實體 的項目分離
    前情提要： 現有一個網站框架，包括主體項目WebApp一個，包含 IIdentityUser 介面的基架項目 A。用於處理用戶身份驗證的服務 AuthenticationService 位於命名空間B。用於保存數據的實體 User : IIdentityUser 位置項目C。項目之間的關係是B和C依 ...
一周排行
    -Advertisement-
    Play Games
  • WPF 已知問題 監聽 WMI 事件導致觸摸失效
    示例項目結構 在 Visual Studio 中創建一個 WinForms 應用程式後，項目結構如下所示： MyWinFormsApp/ │ ├───Properties/ │ └───Settings.settings │ ├───bin/ │ ├───Debug/ │ └───Release/ ...
  • [STAThread]特性
    [STAThread] 特性用於需要與 COM 組件交互的應用程式，尤其是依賴單線程模型（如 Windows Forms 應用程式）的組件。在 STA 模式下，線程擁有自己的消息迴圈，這對於處理用戶界面和某些 COM 組件是必要的。 [STAThread] static void Main(stri ...
  • UWP WinUI3 傳入 AddHandler 的 RoutedEventHandler 類型與事件所需不匹配將拋出參數異常
    在WinForm中使用全局異常捕獲處理 在WinForm應用程式中，全局異常捕獲是確保程式穩定性的關鍵。通過在Program類的Main方法中設置全局異常處理，可以有效地捕獲並處理未預見的異常，從而避免程式崩潰。 註冊全局異常事件 [STAThread] static void Main() { / ...
  • .NET 多版本 WinForm 開源控制項庫 SunnyUI
    前言 給大家推薦一款開源的 Winform 控制項庫，可以幫助我們開發更加美觀、漂亮的 WinForm 界面。 項目介紹 SunnyUI.NET 是一個基於 .NET Framework 4.0+、.NET 6、.NET 7 和 .NET 8 的 WinForm 開源控制項庫，同時也提供了工具類庫、擴展 ...
  • .net core8 使用Swagger（附當前源碼）
    說明 該文章是屬於OverallAuth2.0系列文章，每周更新一篇該系列文章（從0到1完成系統開發）。 該系統文章，我會儘量說的非常詳細，做到不管新手、老手都能看懂。 說明：OverallAuth2.0 是一個簡單、易懂、功能強大的許可權+可視化流程管理系統。 有興趣的朋友，請關註我吧(*^▽^*) ...
  • WPF 什麼時候 VisualTreeHelper.GetDescendantBounds 將返回無窮大
    一、下載安裝 1.下載git 必須先下載並安裝git，再TortoiseGit下載安裝 git安裝參考教程：https://blog.csdn.net/mukes/article/details/115693833 2.TortoiseGit下載與安裝 TortoiseGit，Git客戶端，32/6 ...
  • C# 開源教程帶你輕鬆掌握數據結構與演算法
    前言 在項目開發過程中，理解數據結構和演算法如同掌握蓋房子的秘訣。演算法不僅能幫助我們編寫高效、優質的代碼，還能解決項目中遇到的各種難題。 給大家推薦一個支持C#的開源免費、新手友好的數據結構與演算法入門教程：Hello演算法。 項目介紹 《Hello Algo》是一本開源免費、新手友好的數據結構與演算法入門 ...
  • 第22篇 生成proto文件bat腳本
    1.生成單個Proto.bat內容 @rem Copyright 2016, Google Inc. @rem All rights reserved. @rem @rem Redistribution and use in source and binary forms, with or with ...
  • 記一次 .NET某上位機視覺程式 卡死分析
    一：背景 1. 講故事 前段時間有位朋友找到我，說他的窗體程式在客戶這邊出現了卡死，讓我幫忙看下怎麼回事？dump也生成了，既然有dump了那就上 windbg 分析吧。 二：WinDbg 分析 1. 為什麼會卡死 窗體程式的卡死，入口門檻很低，後續往下分析就不一定了，不管怎麼說先用 !clrsta ...
  • 醫學DICOM文件與PACS系統進行數據傳輸
    前言 人工智慧時代，人臉識別技術已成為安全驗證、身份識別和用戶交互的關鍵工具。 給大家推薦一款.NET 開源提供了強大的人臉識別 API，工具不僅易於集成，還具備高效處理能力。 本文將介紹一款如何利用這些API，為我們的項目添加智能識別的亮點。 項目介紹 GitHub 上擁有 1.2k 星標的 C# ...
所有分類