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=8080spring.data.mongodb.authentication-database=adminspring.data.mongodb.database=testdbspring.data.mongodb.username=userspring.data.mongodb.password=123456spring.data.mongodb.host=localhostspring.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;@Repositorypublic 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;@Repositorypublic 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進行CRUD操作的兩種方式的文章就介紹到這了,更多相關(guān)Springboot整合MongoDB crud 操作內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！