Springboot整合MongoDB進(jìn)行CRUD操作的兩種方式(實例代碼詳解)
1 簡介
Springboot是最簡單的使用Spring的方式，而MongoDB是最流行的NoSQL數(shù)據(jù)庫。兩者在分布式、微服務(wù)架構(gòu)中使用率極高，本文將用實例介紹如何在Springboot中整合MongoDB的兩種方法：MongoRepository和MongoTemplate。
代碼結(jié)構(gòu)如下：
2 項目準(zhǔn)備
2.1 啟動MongoDB實例
為了方便，使用Docker來啟動MongoDB，詳細(xì)指導(dǎo)文檔請參考：基于Docker的MongoDB實現(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ù)模型實體
創(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)建對應(yīng)的Collections（表），當(dāng)通過Web應(yīng)用新增時會自動創(chuàng)建。
3 方式1：MongoRepository
3.1 定義數(shù)據(jù)訪問層UserRepository
使用過Spring Jpa的都清楚，Repository實際就是用于操作數(shù)據(jù)庫的類。在非關(guān)系型數(shù)據(jù)庫MongoDB的整合中，也是一樣的。Spring會幫我們實現(xiàn)好對應(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>第一個為實體類，第二個為主鍵ID。
3.2 實現(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 測試
用Postman測試后，每個接口均調(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);
}
然后實現(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 實現(xiàn)另一個Controller
這個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 測試
測試一樣也是全部通過：
5 總結(jié)
本文通過實例講解了如何整合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)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要介紹了簡單了解JAVA變量類型及代碼實例,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-02-02
在本篇文章里小編給大家整理了一篇關(guān)于Java選擇排序法以及實例內(nèi)容，并做了詳細(xì)分析，有興趣的朋友們可以跟著學(xué)習(xí)下。2022-11-11
這篇文章主要介紹了json轉(zhuǎn)換成java對象示例,需要的朋友可以參考下2014-04-04
Java+Ajax實現(xiàn)的用戶名重復(fù)檢驗功能實例詳解
這篇文章主要介紹了Java+Ajax實現(xiàn)的用戶名重復(fù)檢驗功能,結(jié)合實例形式詳細(xì)分析了java針對用戶名提交的ajax數(shù)據(jù)庫查詢與重復(fù)檢查功能相關(guān)實現(xiàn)技巧與操作注意事項,需要的朋友可以參考下2018-12-12
這篇文章主要介紹了Java中的RabbitMQ交換機(jī)詳解,消息隊列是指利用高效可靠的消息傳遞機(jī)制進(jìn)行與平臺無關(guān)的數(shù)據(jù)交流,并基于數(shù)據(jù)通信來進(jìn)行分布式系統(tǒng)的集成,是在消息的傳輸過程中保存消息的容器,需要的朋友可以參考下2023-07-07
SpringBoot監(jiān)聽Nacos動態(tài)修改日志級別的操作方法
線上系統(tǒng)的日志級別一般都是 INFO 級別,有時候需要查看 WARN 級別的日志,所以需要動態(tài)修改日志級別,微服務(wù)項目中使用 Nacos 作為注冊中心,我們可以監(jiān)聽 Nacos 配置,修改日志級別,這篇文章主要介紹了SpringBoot監(jiān)聽Nacos動態(tài)修改日志級別的操作方法,需要的朋友可以參考下2023-12-12
這篇文章主要介紹了判斷java文件類型TikaToolKit的實例，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-10-10
java8新特性 stream流的方式遍歷集合和數(shù)組操作
這篇文章主要介紹了java8新特性 stream流的方式遍歷集合和數(shù)組操作，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-08-08
SpringBoot項目的配置文件中設(shè)置server.port不生效問題
這篇文章主要介紹了SpringBoot項目的配置文件中設(shè)置server.port不生效問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-11-11
這篇文章主要介紹了 Java應(yīng)用打包后運行需要注意編碼問題的相關(guān)資料,需要的朋友可以參考下2016-12-12