Java 連接 MongoDB 實現增刪改查完整指南

前言

在現代企業級應用開發中，MongoDB 作為一款高性能、無模式的文檔型數據庫，已成為 Java 開發者的熱門選擇。本文將詳細介紹如何使用 Spring Data MongoDB 的 MongoTemplate 實現數據庫的連接與增刪改查（CRUD）操作，並採用接口與實現類分離的設計模式，提升代碼的可維護性與擴展性。

核心依賴配置

在 pom.xml 中引入 Spring Data MongoDB 依賴：

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

數據訪問層設計

1. 定義統一操作接口

首先創建 AbstractRepository 接口，規範數據訪問的標準契約：

package com.dao;

import java.util.List;
import com.bean.Company;

public interface AbstractRepository {
    List<?> findAll(Class<?> entity);
    Company findOne(String id, Class<?> entity);
    void updateEntity(Company company);
    void delete(String id, Class<Company> clazz);
    void insert(Company company);
}

2. 實現具體數據操作邏輯

使用 @Repository 標註實現類，並注入 MongoTemplate 進行核心操作：

package com.dao;

import java.util.List;
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 com.bean.Company;

@Repository
public class RepositoryImpl implements AbstractRepository {

    @Autowired
    private MongoTemplate mongoTemplate;

    // 查詢所有數據
    @Override
    public List<?> findAll(Class<?> entity) {
        return mongoTemplate.findAll(entity);
    }

    // 根據 ID 查詢單條數據
    @Override
    public Company findOne(String id, Class<?> entity) {
        Query query = new Query(Criteria.where("id").is(id));
        return mongoTemplate.findOne(query, entity);
    }

    // 更新或保存數據（upsert 機制）
    @Override
    public void updateEntity(Company company) {
        mongoTemplate.save(company);
    }

    // 刪除指定 ID 的數據
    @Override
    public void delete(String id, Class<Company> clazz) {
        Query query = new Query(Criteria.where("id").is(id));
        Company company = mongoTemplate.findOne(query, clazz);
        if (company != null) {
            mongoTemplate.remove(company);
        }
    }

    // 新增數據
    @Override
    public void insert(Company company) {
        mongoTemplate.insert(company);
    }
}

關鍵技術點解析

MongoTemplate 核心方法

• findAll()：獲取集合中所有文檔，自動映射到實體類
• findOne()：結合 Query 與 Criteria 實現精確條件查詢
• save()：具備「存在則更新，不存在則插入」的 upsert 特性
• insert()：純插入操作，若文檔已存在則拋出異常
• remove()：根據對象或條件刪除文檔

查詢構建器模式

Query 與 Criteria 采用鏈式調用，構建靈活的查詢條件：

Query query = new Query(Criteria.where("fieldName").is(value));

最佳實踐建議

1. 索引優化：在頻繁查詢的字段（如 id、創建時間）創建索引
2. 投影查詢：使用 fields() 只返回所需字段，減少網絡傳輸
3. 分頁處理：大數據量場景下結合 skip() 與 limit() 實現分頁
4. 異常處理：統一捕獲 MongoException 並轉換為業務異常

總結

Spring Data MongoDB 的 MongoTemplate 提供了強大且靈活的數據操作能力，其 API 設計與關係型數據庫的 JdbcTemplate 理念一脈相承，降低了開發者的學習成本。通過接口隔離實現細節，不僅符合依賴倒置原則，也為後續遷移數據源或引入緩存層預留了擴展空間。