SpringBoot整合MongoDB

来源:https://www.cnblogs.com/aitiknowledge/archive/2022/07/28/16529180.html
-Advertisement-
Play Games

NoSQL(Not Only SQL)，即反SQL運動或者是不僅僅SQL，指的是非關係型的資料庫，是一項全新的資料庫革命運動，是一種全新的思維註入 NoSQL優點 資料庫高併發讀寫 海量數據高效率存儲和訪問 資料庫高擴展性和高可用性 NoSQL缺點 資料庫事務一致性需求 資料庫的寫實時性和讀實時性需 ...


  • NoSQL(Not Only SQL)，即反SQL運動或者是不僅僅SQL，指的是非關係型的資料庫，是一項全新的資料庫革命運動，是一種全新的思維註入
  • NoSQL優點
    • 資料庫高併發讀寫
    • 海量數據高效率存儲和訪問
    • 資料庫高擴展性和高可用性
  • NoSQL缺點
    • 資料庫事務一致性需求
    • 資料庫的寫實時性和讀實時性需求
    • 複雜的SQL查詢，特別是奪標關聯查詢的需求
  • MongoDB概述
    • 由C++語言編寫，是一個基於分散式文件存儲的開源資料庫系統；在高負載的情況下，添加更多的節點，可以保證伺服器性能
    • MongoDB旨在為WEB應用提供可擴展的高性能數據存儲解決方案；將數據存儲為一個文檔，數據結構由鍵值對組成。MongoDB文檔類似於JSON對象欄位值可以包含其他問你當、數組及文檔數組
  • MongoDB特點
    • MongoDB是一個面向文檔存儲的資料庫，操作起來比較簡單和容易
    • MongoDB記錄總可以設置任何屬性的索引
    • 可以通過本地後者網路創建數據鏡像，這使得MongoDB有更強的擴展性
    • 如果負載的增減（需要跟多的存儲空間和更強的處理能力），它可以分佈在電腦網路中的其他節點上，這就是所謂的分片
    • MongoDB支持豐富的查詢表達式，查詢指令使用JSON形式的標記，可輕易查詢文檔中內嵌的對象和數組
    • MongoDB使用update()命令可以實現替換完成的文檔（數據）或者一些指定的數據欄位
    • MongoDB中的Map/reduce主要是用來對數據進行批量處理和聚合操作
    • Map和Reduce
      • Map函數調用emit(key, value)便利集合中所有的記錄，將key域value傳給Reduce函數進行處理
      • Map和Reduce函數是使用JavaScript編寫的，把那個可以通過db.runCommand或mapreduce命令來執行MapReduce操作
    • GridFS是MongoDB中的一個內置功能，可以用於存放大量的小文件
    • MongoDB允許在服務端執行腳本，可以用JavaScript編寫某個函數，直接在服務端執行，也可以把函數的定義存儲在服務端，下次直接調用即可
    • MongoDB支持跟中編程語言：RUBY、PYTHON、JAVA、C++、PHP、C#
    • 安裝簡單
  • MongoDB語法：略
  • SpringBoot整合MongoDB
    • 集成簡介：spring-data-mongodb提供了MongoTemplate和MongoRepository兩種方式訪問MongoDB；MongoTemplate操作靈活，MongoRepository操作簡單，不夠靈活
    • 添加相關依賴
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-mongodb</artifactId>
    <version>2.2.1.RELEASE</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
    <version>2.2.1.RELEASE</version>
</dependency>
<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <version>1.18.10</version>
</dependency>
<dependency>
    <groupId>joda-time</groupId>
    <artifactId>joda-time</artifactId>
    <version>2.10.1</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
    <exclusions>
        <exclusion>
            <groupId>org.junit.vintage</groupId>
            <artifactId>junit-vintage-engine</artifactId>
        </exclusion>
    </exclusions>
</dependency>
  • 添加配置
spring.data.mongodb.uri=mongodb://Your IP:27017/your database
  • 創建與集合對應的實體類
@Data
@Document("User")   // 表示操作的是your database下的User集合
public class User {
    @Id
    private String id;
    private String name;
    private Integer age;
}
  • 測試MongoTemplate訪問MongoDB（CRUD）
@SpringBootTest
public class MongoDBTest {
    @Autowired
    private MongoTemplate mongoTemplate;

    /** 新增 */
    @Test
    public void insert() {
        User user = new User();
        user.setName("xiansen");
        user.setAge(18);
        User u = mongoTemplate.insert(user);
        System.out.println("user = " + u);
    }
    /** 查詢所有記錄 */
    @Test
    public void findAll() {
        List<User> all = mongoTemplate.findAll(User.class);
        System.out.println("all = " + all);
    }
    /** ID查詢 */
    @Test
    public void findById() {
        User u = mongoTemplate.findById("rge8vcuxdfsfdfsdf", User.class);
        System.out.println("u = " + u);
    }
    /** 條件查詢 */
    @Test
    public void findUserList() {
        Query query = new Query(Criteria.where("name").is("xiansen").and("age").is(18));
        List<User> users = mongoTemplate.find(query, User.class);
        System.out.println("users = " + users);
    }
    /** 模糊查詢 */
    @Test
    public void findUserListByLike() {
        String name = "xian";
        String regex = String.format("%s%s%s", "^.*", name, ".*$");
        Pattern pattern = Pattern.compile(regex, Pattern.CASE_INSENSITIVE);  // 大小寫敏感
        Query query = new Query(Criteria.where("name").regex(pattern));   // 使用正則表達式實現模糊查詢
        List<User> users = mongoTemplate.find(query, User.class);
        System.out.println("users = " + users);
    }
    /** 分頁查詢 */
    @Test
    public void findPageUserList() {
        int current = 1;
        int limit = 3;
        String name = "xian";
        String regex = String.format("%s%s%s", "^.*", name, ".*$");
        Pattern pattern = Pattern.compile(regex, Pattern.CASE_INSENSITIVE);  // 大小寫敏感
        Query query = new Query(Criteria.where("name").regex(pattern));
        // 查詢的記錄數
        Long count = mongoTemplate.count(query, User.class);
        System.out.println("count = " + count);
        // 分頁查詢
        List<User> users = mongoTemplate.find(query.skip((current-1)*limit).limit(limit), User.class);
        System.out.println("users = " + users);
    }
    /** 修改 */
    @Test
    public void updateUser() {
        User u = mongoTemplate.findById("ds98h98sdhds6gt7u", User.class);
        u.setName("hello");
        u.setAge(20);
        Query query = new Query(Criteria.where("_id").is(u.getId()));
        Update update = new Update();
        update.set("name", u.getName());
        update.set("age", u.getAge());
        UpdateResult upsert = mongoTemplate.upsert(query, update, User.class);
        long modifiedCount = upsert.getModifiedCount();  // 影響的行數
        System.out.println("modifiedCount = " + modifiedCount);
    }
    /** 刪除 */
    @Test
    public void deleteUser() {
        Query query = new Query(Criteria.where("_id").is("ds98h98sdhds6gt7u"));
        DeleteResult remove = mongoTemplate.remove(query, User.class);
        long deletedCount = remove.getDeletedCount();  // 影響的行數
        System.out.println("deletedCount = " + deletedCount);
    }
}
  • 相比於MongoTemplate，MongoRepository實現CRUD操作，還需要創建一個繼承MongoRepository介面的介面，如
@Repository
public interface UserRepository extends MongoRepository<User, String> {}
  • 測試MongoRepository訪問MongoDB（CRUD）
@SpringBootTest
public class MongoDBTest {
    @Autowired
    private UserRepository userRepository;


    /** 新增 */
    @Test
    public void insert() {
        User user = new User();
        user.setName("xiansen");
        user.setAge(18);
        User u = userRepository.save(user);
        System.out.println("user = " + u);
    }
    /** 查詢所有記錄 */
    @Test
    public void findAll() {
        List<User> all = userRepository.findAll();
        System.out.println("all = " + all);
    }
    /** ID查詢 */
    @Test
    public void findById() {
        User u = userRepository.findById("rge8vcuxdfsfdfsdf").get();
        System.out.println("u = " + u);
    }
    /** 條件查詢 */
    @Test
    public void findUserList() {
        User user = new User();
        user.setName("xiansen");
        user.setAge(18);
        Example<User> userExample = Example.of(user);
        List<User> users = userRepository.findAll(userExample);
        System.out.println("users = " + users);
    }
    /** 模糊查詢 */
    @Test
    public void findUserListByLike() {
        User user = new User();
        user.setName("xian");
        user.setAge(18);
        ExampleMatcher matcher = ExampleMatcher.matching()
                .withStringMatcher(ExampleMatcher.StringMatcher.CONTAINING)    // 表示模糊查詢
                .withIgnoreCase(true);   // 忽略大小寫
        Example<User> userExample = Example.of(user, matcher);
        List<User> users = userRepository.findAll(userExample);
        System.out.println("users = " + users);
    }
    /** 分頁查詢 */
    @Test
    public void findPageUserList() {
        // 分頁設置參數
        Pageable pageable = PageRequest.of(0, 3);// 0表示第一頁
        User user = new User();
        user.setName("xiansen");
        user.setAge(18);
        Example<User> userExample = Example.of(user);
        Page<User> page = userRepository.findAll(userExample, pageable);
        System.out.println("page = " + page);
    }
    /** 修改 */
    @Test
    public void updateUser() {
        User u = userRepository.findById("ds98h98sdhds6gt7u").get();
        u.setName("hello");
        u.setAge(20);
        User user = userRepository.save(u);
        System.out.println("user = " + user);
    }
    /** 刪除 */
    @Test
    public void deleteUser() {
        userRepository.deleteById("ds98h98sdhds6gt7u");
    }
}

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

-Advertisement-
Play Games
更多相關文章
  • IOS OpenGL ES GPUImage 圖像閾值邊緣檢測GPUImageThresholdEdgeDetectionFilter
    目錄 一.簡介 二.效果演示 三.源碼下載 四.猜你喜歡 零基礎 OpenGL (ES) 學習路線推薦 : OpenGL (ES) 學習目錄 >> OpenGL ES 基礎 零基礎 OpenGL (ES) 學習路線推薦 : OpenGL (ES) 學習目錄 >> OpenGL ES 轉場 零基礎 O ...
  • JavaWeb-MVC、過濾器
    一、MVC架構圖 Model 業務處理：業務邏輯(Service) 數據持久層：CRUD(Dao) View 展示數據 提供連接發起Servlet請求(a,form,img....) Controller(Servlet) 接收用戶的請求:(req:請求參數，Session信息) 交給業務層處理對應 ...
  • SpringBoot（18）Spring Security
    1.認識Spring Security Spring Security提供了聲明式的安全訪問控制解決方案(僅支持基於Spring的應用程式)，對訪問許可權進行認證和授權，它基於Spring AOP和Servlet過濾器，提供了安全性方面的全面解決方案。 除常規的認證和授權外，它還提供了 ACLs、LD ...
  • 從零開始實現lmax-Disruptor隊列（六）Disruptor 解決偽共用、消費者優雅停止實現原理解析
    MyDisruptor V6版本介紹 在v5版本的MyDisruptor實現DSL風格的API後。按照計劃，v6版本的MyDisruptor作為最後一個版本，需要對MyDisruptor進行最終的一些細節優化。 v6版本一共做了三處優化： 解決偽共用問題 支持消費者線程優雅停止 生產者序列器中維護消 ...
  • day09-Java數組
    Java數組 9.稀疏數組 什麼是稀疏數組？ 當一個數組中大部分元素為0，或者為同一值的數組時，可以使用稀疏數組來保存該數組。 稀疏數組的處理方式是： 記錄數組一共有幾行幾列，有多少個不同的值 把具有不同值 的元素和行列及值記錄在一個小規模的數組中，從而縮小程式的規模 如下圖：左邊是原始數組，右邊是 ...
  • 線程的生命周期
    線程的生命周期 一、通用的java生命周期 ​ 線程的生命周期通常有五種狀態。這五種狀態分別是：新建狀態、就緒狀態、運行狀態、阻塞狀態和死亡狀態。 **新建狀態：**指的是線程已經被創建，但是還不允許分配 CPU 執行。 就緒狀態： 指的是線程可以分配 CPU 執行。在這種狀態下，真正的操作系統線程 ...
  • LVS+KeepAlived高可用部署實戰應用
    LVS+KeepAlived高可用部署實戰 1. 構建高可用集群 1.1 什麼是高可用集群 ​ 高可用集群（High Availability Cluster，簡稱HA Cluster），是指以減少服務中斷時間為目的得伺服器集群技術。它通過保護用戶得業務程式對外部間斷提供的服務，把因為軟體，硬體，認 ...
  • SpringBoot 增刪改查+文件上傳
    註：本文所用到的版本 MySql 8.0.28 SpringBoot 2.7.2 準備工作 ：建表 、pom.xml導入依賴 、application.yml 配置 建表 CREATE TABLE `rna` ( `id` int NOT NULL AUTO_INCREMENT, `name` va ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類