Springboot整合MongoDB進(jìn)行CRUD操作的兩種方式(實(shí)例代碼詳解)

更新時(shí)間：2020年04月20日 10:05:11 作者：南瓜慢說

這篇文章主要介紹了Springboot整合MongoDB進(jìn)行CRUD操作的兩種方式,本文通過實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下

1 簡(jiǎn)介

Springboot是最簡(jiǎn)單的使用Spring的方式，而MongoDB是最流行的NoSQL數(shù)據(jù)庫。兩者在分布式、微服務(wù)架構(gòu)中使用率極高，本文將用實(shí)例介紹如何在Springboot中整合MongoDB的兩種方法：MongoRepository和MongoTemplate。

代碼結(jié)構(gòu)如下：

2 項(xiàng)目準(zhǔn)備

2.1 啟動(dòng)MongoDB實(shí)例

為了方便，使用Docker來啟動(dòng)MongoDB，詳細(xì)指導(dǎo)文檔請(qǐng)參考：基于Docker的MongoDB實(shí)現(xiàn)授權(quán)訪問的方法，這里不再贅述。

2.2 引入相關(guān)依賴

主要的依賴為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 配置數(shù)據(jù)庫連接信息

與配置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 創(chuàng)建數(shù)據(jù)模型實(shí)體

創(chuàng)建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中創(chuàng)建對(duì)應(yīng)的Collections（表），當(dāng)通過Web應(yīng)用新增時(shí)會(huì)自動(dòng)創(chuàng)建。

3 方式1：MongoRepository

3.1 定義數(shù)據(jù)訪問層UserRepository

使用過Spring Jpa的都清楚，Repository實(shí)際就是用于操作數(shù)據(jù)庫的類。在非關(guān)系型數(shù)據(jù)庫MongoDB的整合中，也是一樣的。Spring會(huì)幫我們實(shí)現(xiàn)好對(duì)應(yīng)接口的方法，開發(fā)人員連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>第一個(gè)為實(shí)體類，第二個(gè)為主鍵ID。

3.2 實(shí)現(xiàn)Controller

Controller比較基礎(chǔ)，就不講解了，常用的注解是必須要掌握的，直接上代碼吧：

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 測(cè)試

用Postman測(cè)試后，每個(gè)接口均調(diào)用成功。就不一一截圖了。

4 方式2：MongoTemplate

4.1 定義數(shù)據(jù)訪問層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);
}

然后實(shí)現(xiàn)該接口如下：

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 實(shí)現(xiàn)另一個(gè)Controller

這個(gè)Controller的代碼與之前的基本一樣，只是數(shù)據(jù)訪問類不一樣，代碼如下：

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 測(cè)試

測(cè)試一樣也是全部通過：

5 總結(jié)

本文通過實(shí)例講解了如何整合Springboot和MongoDB，主要有兩種方法：MongoRepository和MongoTemplate。代碼基本在文章中已經(jīng)貼出來了，需要的可以下載源代碼。

鏈接: https://pan.baidu.com/s/1bSu4rIkK4f7UIIWW_fZT7A 提取碼: 2uei

到此這篇關(guān)于Springboot整合MongoDB進(jìn)行CRUD操作的兩種方式的文章就介紹到這了,更多相關(guān)Springboot整合MongoDB crud 操作內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: