實例講解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
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類