SpringBoot整合MongoDB實(shí)現(xiàn)文檔存儲(chǔ)功能
一、MongoDB 簡(jiǎn)介
MongoDB（來(lái)自于英文單詞“Humongous”，中文含義為“龐大”）是可以應(yīng)用于各種規(guī)模的企業(yè)、各個(gè)行業(yè)以及各類(lèi)應(yīng)用程序的開(kāi)源數(shù)據(jù)庫(kù)?；诜植际轿募鎯?chǔ)的數(shù)據(jù)庫(kù)。由C++語(yǔ)言編寫(xiě)。旨在為 WEB 應(yīng)用提供可擴(kuò)展的高性能數(shù)據(jù)存儲(chǔ)解決方案。MongoDB 是一個(gè)高性能，開(kāi)源，無(wú)模式的文檔型數(shù)據(jù)庫(kù)，是當(dāng)前 NoSql 數(shù)據(jù)庫(kù)中比較熱門(mén)的一種。
MongoDB 是一個(gè)介于關(guān)系數(shù)據(jù)庫(kù)和非關(guān)系數(shù)據(jù)庫(kù)之間的產(chǎn)品，是非關(guān)系數(shù)據(jù)庫(kù)當(dāng)中功能最豐富，最像關(guān)系數(shù)據(jù)庫(kù)的。他支持的數(shù)據(jù)結(jié)構(gòu)非常松散，是類(lèi)似 json 的 bjson 格式，因此可以存儲(chǔ)比較復(fù)雜的數(shù)據(jù)類(lèi)型。MongoDB 最大的特點(diǎn)是他支持的查詢(xún)語(yǔ)言非常強(qiáng)大，其語(yǔ)法有點(diǎn)類(lèi)似于面向?qū)ο蟮牟樵?xún)語(yǔ)言，幾乎可以實(shí)現(xiàn)類(lèi)似關(guān)系數(shù)據(jù)庫(kù)單表查詢(xún)的絕大部分功能，而且還支持對(duì)數(shù)據(jù)建立索引。
傳統(tǒng)的關(guān)系數(shù)據(jù)庫(kù)一般由數(shù)據(jù)庫(kù)（database）、表（table）、記錄（record）三個(gè)層次概念組成，MongoDB 是由數(shù)據(jù)庫(kù)（database）、集合（collection）、文檔對(duì)象（document）三個(gè)層次組成。MongoDB 對(duì)于關(guān)系型數(shù)據(jù)庫(kù)里的表，但是集合中沒(méi)有列、行和關(guān)系概念，這體現(xiàn)了模式自由的特點(diǎn)。
MongoDB 中的一條記錄就是一個(gè)文檔，是一個(gè)數(shù)據(jù)結(jié)構(gòu)，由字段和值對(duì)組成。MongoDB 文檔與 JSON 對(duì)象類(lèi)似。字段的值有可能包括其它文檔、數(shù)組以及文檔數(shù)組。MongoDB 支持 OS X、Linux 及 Windows 等操作系統(tǒng)，并提供了 Python，PHP，Ruby，Java及 C++ 語(yǔ)言的驅(qū)動(dòng)程序，社區(qū)中也提供了對(duì) Erlang 及 .NET 等平臺(tái)的驅(qū)動(dòng)程序。
MongoDB 的適合對(duì)大量或者無(wú)固定格式的數(shù)據(jù)進(jìn)行存儲(chǔ)，比如：日志、緩存等。對(duì)事物支持較弱，不適用復(fù)雜的多文檔（多表）的級(jí)聯(lián)查詢(xún)。文中演示 Mongodb 版本為 3.5。
二、MongoDB 的增刪改查
Spring Boot 對(duì)各種流行的數(shù)據(jù)源都進(jìn)行了封裝，當(dāng)然也包括了 Mongodb,下面給大家介紹如何在 Spring Boot 中使用 Mongodb：
1、pom 包配置
pom 包里面添加spring-boot-starter-data-mongodb包引用
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
</dependencies>
2、在 application.properties 中添加配置
spring.data.mongodb.uri=mongodb://name:pass@localhost:27017/test
多個(gè) IP 集群可以采用以下配置：
spring.data.mongodb.uri=mongodb://user:pwd@ip1:port1,ip2:port2/database
3、創(chuàng)建數(shù)據(jù)實(shí)體
public class User implements Serializable {
private static final long serialVersionUID = -3258839839160856613L;
private Long id;
private String userName;
private String passWord;
//getter、setter省略
}4、創(chuàng)建實(shí)體的增刪改查操作
Repository 層實(shí)現(xiàn)了 User 對(duì)象的增刪改查
Component
public class UserRepositoryImpl implements UserRepository {
@Autowired
private MongoTemplate mongoTemplate;
/**
* 創(chuàng)建對(duì)象
* @param user
*/
@Override
public void saveUser(User user) {
mongoTemplate.save(user);
}
/**
* 根據(jù)用戶(hù)名查詢(xún)對(duì)象
* @param userName
* @return
*/
@Override
public User findUserByUserName(String userName) {
Query query=new Query(Criteria.where("userName").is(userName));
User user = mongoTemplate.findOne(query , User.class);
return user;
}
/**
* 更新對(duì)象
* @param user
*/
@Override
public long updateUser(User user) {
Query query=new Query(Criteria.where("id").is(user.getId()));
Update update= new Update().set("userName", user.getUserName()).set("passWord", user.getPassWord());
//更新查詢(xún)返回結(jié)果集的第一條
UpdateResult result =mongoTemplate.updateFirst(query,update,User.class);
//更新查詢(xún)返回結(jié)果集的所有
// mongoTemplate.updateMulti(query,update,UserEntity.class);
if(result!=null)
return result.getMatchedCount();
else
return 0;
}
/**
* 刪除對(duì)象
* @param id
*/
@Override
public void deleteUserById(Long id) {
Query query=new Query(Criteria.where("id").is(id));
mongoTemplate.remove(query,User.class);
}
}5、開(kāi)發(fā)對(duì)應(yīng)的測(cè)試方法
@RunWith(SpringRunner.class)
@SpringBootTest
public class UserDaoTest {
@Autowired
private UserDao userDao;
@Test
public void testSaveUser() throws Exception {
UserEntity user=new UserEntity();
user.setId(2l);
user.setUserName("小明");
user.setPassWord("fffooo123");
userDao.saveUser(user);
}
@Test
public void findUserByUserName(){
UserEntity user= userDao.findUserByUserName("小明");
System.out.println("user is "+user);
}
@Test
public void updateUser(){
UserEntity user=new UserEntity();
user.setId(2l);
user.setUserName("天空");
user.setPassWord("fffxxxx");
userDao.updateUser(user);
}
@Test
public void deleteUserById(){
userDao.deleteUserById(1l);
}
}6、查看驗(yàn)證結(jié)果
可以使用工具 MongoVUE 工具來(lái)連接后直接圖形化展示查看，也可以登錄服務(wù)器用命令來(lái)查看
1）登錄 mongos
bin/mongo -host localhost -port 20000
2）切換到 test 庫(kù)
use test
3）查詢(xún) user 集合數(shù)據(jù)
db.user.find()
根據(jù)3查詢(xún)的結(jié)果來(lái)觀察測(cè)試用例的執(zhí)行是否正確。
到此 Spring Boot 對(duì)應(yīng) MongoDB 的增刪改查功能已經(jīng)全部實(shí)現(xiàn)。
三、多數(shù)據(jù)源 MongoDB 的使用
接下來(lái)實(shí)現(xiàn) MongoDB 多數(shù)據(jù)源的使用
1、pom 包配置
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
</dependency>
</dependencies>
2、配置兩條數(shù)據(jù)源
如下：
mongodb.primary.uri=mongodb://192.168.0.75:20000 mongodb.primary.database=primary mongodb.secondary.uri=mongodb://192.168.0.75:20000 mongodb.secondary.database=secondary
3、配置兩個(gè)庫(kù)的數(shù)據(jù)源
封裝讀取以 Mongodb 開(kāi)頭的兩個(gè)配置文件
@Data
@ConfigurationProperties(prefix = "mongodb")
public class MultipleMongoProperties {
private MongoProperties primary = new MongoProperties();
private MongoProperties secondary = new MongoProperties();
}
配置不同包路徑下使用不同的數(shù)據(jù)源
第一個(gè)庫(kù)的封裝
@Configuration
@EnableMongoRepositories(basePackages = "com.neo.model.repository.primary",mongoTemplateRef = PrimaryMongoConfig.MONGO_TEMPLATE)
public class PrimaryMongoConfig {
protected static final String MONGO_TEMPLATE = "primaryMongoTemplate";
}
第二個(gè)庫(kù)的封裝
@Configuration
@EnableMongoRepositories(basePackages = "com.neo.model.repository.secondary",mongoTemplateRef = SecondaryMongoConfig.MONGO_TEMPLATE)
public class SecondaryMongoConfig {
protected static final String MONGO_TEMPLATE = "secondaryMongoTemplate";
}
讀取對(duì)應(yīng)的配置信息并且構(gòu)造對(duì)應(yīng)的 MongoTemplate
@Configuration
public class MultipleMongoConfig {
@Autowired
private MultipleMongoProperties mongoProperties;
@Primary
@Bean(name = PrimaryMongoConfig.MONGO_TEMPLATE)
public MongoTemplate primaryMongoTemplate() throws Exception {
return new MongoTemplate(primaryFactory(this.mongoProperties.getPrimary()));
}
@Bean
@Qualifier(SecondaryMongoConfig.MONGO_TEMPLATE)
public MongoTemplate secondaryMongoTemplate() throws Exception {
return new MongoTemplate(secondaryFactory(this.mongoProperties.getSecondary()));
}
@Bean
@Primary
public MongoDbFactory primaryFactory(MongoProperties mongo) throws Exception {
return new SimpleMongoDbFactory(new MongoClient(mongo.getHost(), mongo.getPort()),
mongo.getDatabase());
}
@Bean
public MongoDbFactory secondaryFactory(MongoProperties mongo) throws Exception {
return new SimpleMongoDbFactory(new MongoClient(mongo.getHost(), mongo.getPort()),
mongo.getDatabase());
}
}兩個(gè)庫(kù)的配置信息已經(jīng)完成。
4、創(chuàng)建兩個(gè)庫(kù)分別對(duì)應(yīng)的對(duì)象和 Repository
對(duì)應(yīng)可以共用
public class User implements Serializable {
private static final long serialVersionUID = -3258839839160856613L;
private String id;
private String userName;
private String passWord;
public User(String userName, String passWord) {
this.userName = userName;
this.passWord = passWord;
}
}
對(duì)應(yīng)的 Repository
public interface PrimaryRepository extends MongoRepository<PrimaryMongoObject, String> {
}
繼承了 MongoRepository 會(huì)默認(rèn)實(shí)現(xiàn)很多基本的增刪改查，省了很多自己寫(xiě) Repository 層的代碼
Secondary 和上面的代碼類(lèi)似就不貼出來(lái)了
5、最后測(cè)試
@RunWith(SpringRunner.class)
@SpringBootTest
public class MuliDatabaseTest {
@Autowired
private PrimaryRepository primaryRepository;
@Autowired
private SecondaryRepository secondaryRepository;
@Test
public void TestSave() {
System.out.println("************************************************************");
System.out.println("測(cè)試開(kāi)始");
System.out.println("************************************************************");
this.primaryRepository
.save(new PrimaryMongoObject(null, "第一個(gè)庫(kù)的對(duì)象"));
this.secondaryRepository
.save(new SecondaryMongoObject(null, "第二個(gè)庫(kù)的對(duì)象"));
List<PrimaryMongoObject> primaries = this.primaryRepository.findAll();
for (PrimaryMongoObject primary : primaries) {
System.out.println(primary.toString());
}
List<SecondaryMongoObject> secondaries = this.secondaryRepository.findAll();
for (SecondaryMongoObject secondary : secondaries) {
System.out.println(secondary.toString());
}
System.out.println("************************************************************");
System.out.println("測(cè)試完成");
System.out.println("************************************************************");
}
}到此，MongoDB 多數(shù)據(jù)源的使用已經(jīng)完成。
以上就是SpringBoot整合MongoDB實(shí)現(xiàn)文檔存儲(chǔ)功能的詳細(xì)內(nèi)容，更多關(guān)于SpringBoot MongoDB文檔存儲(chǔ)的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
Springboot?Vue實(shí)現(xiàn)單點(diǎn)登陸功能示例詳解
這篇文章主要為大家介紹了Springboot?Vue實(shí)現(xiàn)單點(diǎn)登陸功能示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-01-01
java阻塞隊(duì)列BlockingQueue詳細(xì)解讀
這篇文章主要介紹了java阻塞隊(duì)列BlockingQueue詳細(xì)解讀,在新增的Concurrent包中,BlockingQueue很好的解決了多線程中,如何高效安全“傳輸”數(shù)據(jù)的問(wèn)題,通過(guò)這些高效并且線程安全的隊(duì)列類(lèi),為我們快速搭建高質(zhì)量的多線程程序帶來(lái)極大的便利,需要的朋友可以參考下2023-10-10
MyBatis標(biāo)簽獲取數(shù)組或集合長(zhǎng)度的實(shí)現(xiàn)方式
本文介紹了四種常見(jiàn)的編程表達(dá)式：判斷列表長(zhǎng)度、遍歷數(shù)組、獲取數(shù)組或列表的元素（注意字符串拼接時(shí)的安全性）以及總結(jié),在使用這些表達(dá)式時(shí),應(yīng)注意參數(shù)類(lèi)型與表達(dá)式中使用的類(lèi)型相匹配,以確保代碼的正確性和安全性2025-10-10
java中的Io(input與output)操作總結(jié)(三)
這一節(jié)我們來(lái)講Scanner類(lèi)和PrintWriter類(lèi)的用法,感興趣的朋友可以了解下2013-01-01
這篇文章主要介紹了如何基于JAVA讀取yml配置文件指定key內(nèi)容,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-01-01
springboot整合shiro實(shí)現(xiàn)登錄驗(yàn)證授權(quán)的過(guò)程解析
這篇文章主要介紹了springboot整合shiro實(shí)現(xiàn)登錄驗(yàn)證授權(quán)，本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2022-01-01
這篇文章主要為大家詳細(xì)介紹了java處理日期的工具類(lèi)DateUtil，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2020-10-10
Java String創(chuàng)建對(duì)象實(shí)例解析
這篇文章主要介紹了Java String創(chuàng)建對(duì)象實(shí)例解析，分享了相關(guān)代碼示例，小編覺(jué)得還是挺不錯(cuò)的，具有一定借鑒價(jià)值，需要的朋友可以參考下2018-02-02
Java中鎖的實(shí)現(xiàn)和內(nèi)存語(yǔ)義淺析
這篇文章主要給大家介紹了關(guān)于Java中鎖的實(shí)現(xiàn)和內(nèi)存語(yǔ)義的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2018-11-11
Java網(wǎng)絡(luò)編程之UDP網(wǎng)絡(luò)通信詳解
這篇文章主要為大家詳細(xì)介紹了Java網(wǎng)絡(luò)編程中的UDP網(wǎng)絡(luò)通信的原理與實(shí)現(xiàn)，文中的示例代碼講解詳細(xì)，具有一定的借鑒價(jià)值，需要的可以參考一下2022-09-09