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ù)用戶名查詢(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)文章
Spring MVC中基于自定義Editor的表單數(shù)據(jù)處理技巧分享
Spring MVC中基于自定義Editor的表單數(shù)據(jù)處理技巧。需要的朋友可以過(guò)來(lái)參考下，希望對(duì)大家有所幫助2013-12-12
Java synchronized關(guān)鍵字使用方式及特性解析
這篇文章主要介紹了Java synchronized關(guān)鍵字使用方式及特性解析,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-12-12
這篇文章主要介紹了maven 配置多個(gè)倉(cāng)庫(kù)的方法，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-08-08
Java實(shí)現(xiàn)經(jīng)典俄羅斯方塊游戲
俄羅斯方塊是一個(gè)最初由阿列克謝帕吉特諾夫在蘇聯(lián)設(shè)計(jì)和編程的益智類(lèi)視頻游戲。本文將利用Java實(shí)現(xiàn)這一經(jīng)典的小游戲，需要的可以參考一下2022-01-01
這篇文章主要介紹了JAVA代碼書(shū)寫(xiě)規(guī)范匯總,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-07-07
在日常的開(kāi)發(fā)工作中,處理數(shù)據(jù)庫(kù)查詢(xún)是一個(gè)非常常見(jiàn)的任務(wù),尤其是當(dāng)我們需要在復(fù)雜條件下篩選數(shù)據(jù)時(shí),如何編寫(xiě)高效、簡(jiǎn)潔且可維護(hù)的查詢(xún)邏輯顯得尤為重要,本文給大家介紹了QueryWrapper中or的使用技巧,需要的朋友可以參考下2024-10-10
本文給大家分享的是使用Java實(shí)現(xiàn)智能拼圖游戲的原理，以及實(shí)現(xiàn)的源碼，推薦給大家，有需要的小伙伴可以參考下。2015-03-03
解決IDEA的maven項(xiàng)目中沒(méi)有新建Servlet文件的選項(xiàng)問(wèn)題
這篇文章主要介紹了IDEA的maven項(xiàng)目中沒(méi)有新建Servlet文件的選項(xiàng)問(wèn)題及解決方法,本文給大家分享問(wèn)題原因就解決方法，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2020-09-09
Java并發(fā)編程之CountDownLatch原理詳解
這篇文章主要介紹了Java并發(fā)編程之CountDownLatch原理詳解,CountDownLatch類(lèi)中使用了一個(gè)繼承自AQS的共享鎖Sync對(duì)象,構(gòu)造CountDownLatch對(duì)象時(shí)會(huì)將傳入的線程數(shù)值設(shè)為AQS的state值,需要的朋友可以參考下2023-12-12
SpringBoot整合Lettuce redis過(guò)程解析
這篇文章主要介紹了SpringBoot整合Lettuce redis過(guò)程解析,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-10-10