SpringBoot分散式檔案儲存資料庫mongod

2023-09-12 18:03:53

1、mongodb服務

mongodb的安裝支援windows和linux等平臺，具體在不同平臺的下載安裝請檢視相關大佬博文。

2、建立springboot專案

此處通過idea工具建立，springboot選擇2.7.0版本，具體不再描述。

3、新增mongodb依賴

Spring Data MongDB 是Spring Data的下的一個模組，在springboot中整合mongodb就需要新增Spring Data MongDB的依賴，新增Spring Data MongDB依賴的方式有兩種：

建立springboot專案時勾選Spring Data MongoDB

在pom.xml檔案中新增Spring Data MongoDB依賴

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

4、application.yml設定

spring:
data:
mongodb:
uri: mongodb://127.0.0.1:27017/mongodb_test

或

spring:
data:
mongodb:
host: 127.0.0.1 #指定MongoDB服務地址
port: 27017 #指定埠，預設就為27017
database: mongodb #指定使用的資料庫(集合)
authentication-database: admin # 登入認證的邏輯庫名
username: admin #使用者名稱
password: abc123456 #密碼

mongodb資料庫與mysql不一樣 mysql 一個普通使用者可以管理多個資料庫，但是mongo每一個庫都有一個獨立的管理使用者，連線時需要輸入對應使用者密碼。

5、實體類

@Data
@Document(collection = "article") //指定要對應的檔名（表名）
@Accessors(chain = true) //鏈式存取
public class Article {
    /**
     * 文章主鍵
     */
    @Id
    private String id;
    /**
     * 文章名
     */
    private String name;
    /**
     * 文章內容
     */
    private String content;
}

@Data
@Document(collection = "book")
public class Book {
    @Id
    private String id;
    private String name;
    private String type;
    private String description;
}

其中註解含義如下：

@Document，檔案是 MongoDB 中最基本的資料單元，由鍵值對組成，類似於 JSON 格式，可以儲存不同欄位，欄位的值可以包括其他檔案，陣列和檔案陣列；
@Id（主鍵）：用來將成員變數的值對映為檔案的_id的值；
@Indexed（索引）：索引是一種特殊的資料結構，儲存在一個易於遍歷讀取的資料集合中，能夠對資料庫檔案中的資料進行排序。索引能極大提高檔案查詢效率，如果沒有設定索引，MongoDB 會遍歷集合中的整個檔案，選取符合查詢條件的檔案記錄。這種查詢效率是非常低的；
@Field（欄位）：檔案中的欄位，類似於 MySql 中的列；
@Aggregation（聚合）：聚合主要用於資料處理，例如統計平均值、求和等；

6、通過MongoRepository實現增刪改查

持久層繼承MongoRepository

public interface ArticleRepository extends MongoRepository<Article,String> {
    /**
     * 根據id查詢文章
     * @param id
     * @return
     */
    List<Article> findByid(String id);
}

注意，介面需要起名findBy + 主鍵名，否則會報找不到屬性的錯誤。

業務層

@Service
@RequiredArgsConstructor
public class ArticleService {
    private final ArticleRepository articleRepository;
    /**
     * 新增文章
     *
     * @param article
     * @return
     */
    public int create(Article article) {
        Article save = articleRepository.save(article);
        return 1;
    }
    /**
     * 刪除文章
     *
     * @param ids
     */
    public int delete(List<String> ids) {
        List<Article> deleteList = new ArrayList<>();
        for(String id:ids){
            Article article = new Article();
            article.setId(id);
            deleteList.add(article);
        }
        articleRepository.deleteAll(deleteList);
        return ids.size();
    }
    /**
     * 查詢文章
     * @param id
     * @return
     */
    public List<Article> get(String id) {
        return articleRepository.findByid(id);
    }
}

控制層

@RestController
@RequestMapping("/article")
@RequiredArgsConstructor
public class ArticleController {
    private final ArticleService articleService;
    @PostMapping("/create")
    public String create(@RequestBody Article article) {
        int result = articleService.create(article);
        if (result > 0) {
            return "文章建立成功";
        } else {
            return "文章建立失敗";
        }
    }
    @PostMapping("/delete")
    public String delete(@RequestParam("ids") List<String> ids) {
        int count = articleService.delete(ids);
        if (count > 0) {
            return "刪除了" + count + "篇文章";
        } else {
            return "刪除文章失敗";
        }
    }
    @PostMapping("/get")
    public List<Article> get(String id) {
        List<Article> list = articleService.get(id);
        return list;
    }
}

7、通過MongoTemplate實現增刪改查

業務層

@Service
@RequiredArgsConstructor
public class BookService {
    private final MongoTemplate mongoTemplate;
    /**
     * 新增文章
     *
     * @param book
     * @return
     */
    public int create(Book book) {
        Book save = mongoTemplate.save(book);
        return 1;
    }
    /**
     * 刪除文章
     *
     * @param id
     */
    public int delete(String id) {
        List<Book> deleteList = new ArrayList<>();
        Query query = new Query();
        query.addCriteria(Criteria.where("id").is(id));
        mongoTemplate.remove(query,Book.class);
        return 1;
    }
    /**
     * 查詢文章
     * @param id
     * @return
     */
    public Book get(String id) {
        Book byId = mongoTemplate.findById(id, Book.class);
        return byId;
    }
}

控制層

@RestController
@RequestMapping("/book")
@RequiredArgsConstructor
public class BookController {
    private final BookService bookService;
    @PostMapping("/create")
    public String create(@RequestBody Book book) {
        int result = bookService.create(book);
        if (result > 0) {
            return "圖書建立成功";
        } else {
            return "圖書建立失敗";
        }
    }
    @PostMapping("/delete")
    public String delete(@RequestParam("id") String id) {
        int count = bookService.delete(id);
        if (count > 0) {
            return "刪除了" + count + "篇圖書";
        } else {
            return "刪除圖書失敗";
        }
    }
    @PostMapping("/get")
    public Book get(String id) {
        Book book = bookService.get(id);
        return book;
    }
}

注意：通過mongoTemplate查詢時，實體類的id欄位型別需為String型別，否則查詢為null。