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
  • 如何基於surging跨網關跨語言進行緩存降級
    基於.NET Framework 4.8 開發的深度學習模型部署測試平臺，提供了YOLO框架的主流系列模型，包括YOLOv8~v9，以及其系列下的Det、Seg、Pose、Obb、Cls等應用場景，同時支持圖像與視頻檢測。模型部署引擎使用的是OpenVINO™、TensorRT、ONNX runti... ...
  • 十年沉澱，重啟開發之路
    十年沉澱，重啟開發之路 十年前，我沉浸在開發的海洋中，每日與代碼為伍，與演算法共舞。那時的我，滿懷激情，對技術的追求近乎狂熱。然而，隨著歲月的流逝，生活的忙碌逐漸占據了我的大部分時間，讓我無暇顧及技術的沉澱與積累。 十年間，我經歷了職業生涯的起伏和變遷。從初出茅廬的菜鳥到逐漸嶄露頭角的開發者，我見證了 ...
  • C#.NET體系圖文概述—2024最全總結
    C# 是一種簡單、現代、面向對象和類型安全的編程語言。.NET 是由 Microsoft 創建的開發平臺，平臺包含了語言規範、工具、運行，支持開發各種應用，如Web、移動、桌面等。.NET框架有多個實現，如.NET Framework、.NET Core（及後續的.NET 5+版本），以及社區版本M... ...
  • 班級擂臺（光榮）榜 - 極簡教育小工具
    前言 本文介紹瞭如何使用三菱提供的MX Component插件實現對三菱PLC軟元件數據的讀寫，記錄了使用電腦模擬，模擬PLC，直至完成測試的詳細流程，並重點介紹了在這個過程中的易錯點，供參考。 用到的軟體： 1. PLC開發編程環境GX Works2，GX Works2下載鏈接 https:// ...
  • web server apache tomcat11-31-websocket
    前言 整理這個官方翻譯的系列，原因是網上大部分的 tomcat 版本比較舊，此版本為 v11 最新的版本。 開源項目 從零手寫實現 tomcat minicat 別稱【嗅虎】心有猛虎，輕嗅薔薇。 系列文章 web server apache tomcat11-01-官方文檔入門介紹 web serv ...
  • day31-jQuery
    1、jQuery介紹 jQuery是什麼 jQuery是一個快速、簡潔的JavaScript框架，是繼Prototype之後又一個優秀的JavaScript代碼庫（或JavaScript框架）。jQuery設計的宗旨是“write Less，Do More”，即倡導寫更少的代碼，做更多的事情。它封裝 ...
  • aardio爬蟲) 實戰篇：逆向有道翻譯web介面
    前言 之前的文章把js引擎(aardio封裝庫) 微軟開源的js引擎(ChakraCore))寫好了，這篇文章整點js代碼來測一下bug。測試網站：https://fanyi.youdao.com/index.html#/ 逆向思路 逆向思路可以看有道翻譯js逆向（MD5加密，AES加密）附完整源碼 ...
  • 面試官：這就是你理解的Java多線程基礎？
    引言 現代的操作系統（Windows，Linux，Mac OS）等都可以同時打開多個軟體（任務），這些軟體在我們的感知上是同時運行的，例如我們可以一邊瀏覽網頁，一邊聽音樂。而CPU執行代碼同一時間只能執行一條，但即使我們的電腦是單核CPU也可以同時運行多個任務，如下圖所示，這是因為我們的 CPU 的 ...
  • Python文本統計與分析從基礎到進階
    掌握使用Python進行文本英文統計的基本方法，並瞭解如何進一步優化和擴展這些方法，以應對更複雜的文本分析任務。 ...
  • Redis多數據源，看這篇就夠了
    背景 Redis多數據源常見的場景： 分區數據處理：當數據量增長時，單個Redis實例可能無法處理所有的數據。通過使用多個Redis數據源，可以將數據分區存儲在不同的實例中，使得數據處理更加高效。 多租戶應用程式：對於多租戶應用程式，每個租戶可以擁有自己的Redis數據源，以確保數據隔離和安全性。 ...
所有分類