SpringBoot整合MongoDB實現(xiàn)文檔存儲功能
一、MongoDB 簡介
MongoDB（來自于英文單詞“Humongous”，中文含義為“龐大”）是可以應用于各種規(guī)模的企業(yè)、各個行業(yè)以及各類應用程序的開源數(shù)據(jù)庫?；诜植际轿募鎯Φ臄?shù)據(jù)庫。由C++語言編寫。旨在為 WEB 應用提供可擴展的高性能數(shù)據(jù)存儲解決方案。MongoDB 是一個高性能，開源，無模式的文檔型數(shù)據(jù)庫，是當前 NoSql 數(shù)據(jù)庫中比較熱門的一種。
MongoDB 是一個介于關系數(shù)據(jù)庫和非關系數(shù)據(jù)庫之間的產(chǎn)品，是非關系數(shù)據(jù)庫當中功能最豐富，最像關系數(shù)據(jù)庫的。他支持的數(shù)據(jù)結(jié)構(gòu)非常松散，是類似 json 的 bjson 格式，因此可以存儲比較復雜的數(shù)據(jù)類型。MongoDB 最大的特點是他支持的查詢語言非常強大，其語法有點類似于面向?qū)ο蟮牟樵冋Z言，幾乎可以實現(xiàn)類似關系數(shù)據(jù)庫單表查詢的絕大部分功能，而且還支持對數(shù)據(jù)建立索引。
傳統(tǒng)的關系數(shù)據(jù)庫一般由數(shù)據(jù)庫（database）、表（table）、記錄（record）三個層次概念組成，MongoDB 是由數(shù)據(jù)庫（database）、集合（collection）、文檔對象（document）三個層次組成。MongoDB 對于關系型數(shù)據(jù)庫里的表，但是集合中沒有列、行和關系概念，這體現(xiàn)了模式自由的特點。
MongoDB 中的一條記錄就是一個文檔，是一個數(shù)據(jù)結(jié)構(gòu)，由字段和值對組成。MongoDB 文檔與 JSON 對象類似。字段的值有可能包括其它文檔、數(shù)組以及文檔數(shù)組。MongoDB 支持 OS X、Linux 及 Windows 等操作系統(tǒng)，并提供了 Python，PHP，Ruby，Java及 C++ 語言的驅(qū)動程序，社區(qū)中也提供了對 Erlang 及 .NET 等平臺的驅(qū)動程序。
MongoDB 的適合對大量或者無固定格式的數(shù)據(jù)進行存儲，比如：日志、緩存等。對事物支持較弱，不適用復雜的多文檔（多表）的級聯(lián)查詢。文中演示 Mongodb 版本為 3.5。
二、MongoDB 的增刪改查
Spring Boot 對各種流行的數(shù)據(jù)源都進行了封裝，當然也包括了 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
多個 IP 集群可以采用以下配置：
spring.data.mongodb.uri=mongodb://user:pwd@ip1:port1,ip2:port2/database
3、創(chuàng)建數(shù)據(jù)實體
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)建實體的增刪改查操作
Repository 層實現(xiàn)了 User 對象的增刪改查
Component
public class UserRepositoryImpl implements UserRepository {
@Autowired
private MongoTemplate mongoTemplate;
/**
* 創(chuàng)建對象
* @param user
*/
@Override
public void saveUser(User user) {
mongoTemplate.save(user);
}
/**
* 根據(jù)用戶名查詢對象
* @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;
}
/**
* 更新對象
* @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());
//更新查詢返回結(jié)果集的第一條
UpdateResult result =mongoTemplate.updateFirst(query,update,User.class);
//更新查詢返回結(jié)果集的所有
// mongoTemplate.updateMulti(query,update,UserEntity.class);
if(result!=null)
return result.getMatchedCount();
else
return 0;
}
/**
* 刪除對象
* @param id
*/
@Override
public void deleteUserById(Long id) {
Query query=new Query(Criteria.where("id").is(id));
mongoTemplate.remove(query,User.class);
}
}5、開發(fā)對應的測試方法
@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、查看驗證結(jié)果
可以使用工具 MongoVUE 工具來連接后直接圖形化展示查看，也可以登錄服務器用命令來查看
1）登錄 mongos
bin/mongo -host localhost -port 20000
2）切換到 test 庫
use test
3）查詢 user 集合數(shù)據(jù)
db.user.find()
根據(jù)3查詢的結(jié)果來觀察測試用例的執(zhí)行是否正確。
到此 Spring Boot 對應 MongoDB 的增刪改查功能已經(jīng)全部實現(xiàn)。
三、多數(shù)據(jù)源 MongoDB 的使用
接下來實現(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、配置兩個庫的數(shù)據(jù)源
封裝讀取以 Mongodb 開頭的兩個配置文件
@Data
@ConfigurationProperties(prefix = "mongodb")
public class MultipleMongoProperties {
private MongoProperties primary = new MongoProperties();
private MongoProperties secondary = new MongoProperties();
}
配置不同包路徑下使用不同的數(shù)據(jù)源
第一個庫的封裝
@Configuration
@EnableMongoRepositories(basePackages = "com.neo.model.repository.primary",mongoTemplateRef = PrimaryMongoConfig.MONGO_TEMPLATE)
public class PrimaryMongoConfig {
protected static final String MONGO_TEMPLATE = "primaryMongoTemplate";
}
第二個庫的封裝
@Configuration
@EnableMongoRepositories(basePackages = "com.neo.model.repository.secondary",mongoTemplateRef = SecondaryMongoConfig.MONGO_TEMPLATE)
public class SecondaryMongoConfig {
protected static final String MONGO_TEMPLATE = "secondaryMongoTemplate";
}
讀取對應的配置信息并且構(gòu)造對應的 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());
}
}兩個庫的配置信息已經(jīng)完成。
4、創(chuàng)建兩個庫分別對應的對象和 Repository
對應可以共用
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;
}
}
對應的 Repository
public interface PrimaryRepository extends MongoRepository<PrimaryMongoObject, String> {
}
繼承了 MongoRepository 會默認實現(xiàn)很多基本的增刪改查，省了很多自己寫 Repository 層的代碼
Secondary 和上面的代碼類似就不貼出來了
5、最后測試
@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("測試開始");
System.out.println("************************************************************");
this.primaryRepository
.save(new PrimaryMongoObject(null, "第一個庫的對象"));
this.secondaryRepository
.save(new SecondaryMongoObject(null, "第二個庫的對象"));
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("測試完成");
System.out.println("************************************************************");
}
}到此，MongoDB 多數(shù)據(jù)源的使用已經(jīng)完成。
以上就是SpringBoot整合MongoDB實現(xiàn)文檔存儲功能的詳細內(nèi)容，更多關于SpringBoot MongoDB文檔存儲的資料請關注腳本之家其它相關文章！
相關文章
Spring MVC中基于自定義Editor的表單數(shù)據(jù)處理技巧分享
Spring MVC中基于自定義Editor的表單數(shù)據(jù)處理技巧。需要的朋友可以過來參考下，希望對大家有所幫助2013-12-12
這篇文章主要介紹了Java synchronized關鍵字使用方式及特性解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-12-12
這篇文章主要介紹了maven 配置多個倉庫的方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-08-08
俄羅斯方塊是一個最初由阿列克謝帕吉特諾夫在蘇聯(lián)設計和編程的益智類視頻游戲。本文將利用Java實現(xiàn)這一經(jīng)典的小游戲，需要的可以參考一下2022-01-01
這篇文章主要介紹了JAVA代碼書寫規(guī)范匯總,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-07-07
在日常的開發(fā)工作中,處理數(shù)據(jù)庫查詢是一個非常常見的任務,尤其是當我們需要在復雜條件下篩選數(shù)據(jù)時,如何編寫高效、簡潔且可維護的查詢邏輯顯得尤為重要,本文給大家介紹了QueryWrapper中or的使用技巧,需要的朋友可以參考下2024-10-10
本文給大家分享的是使用Java實現(xiàn)智能拼圖游戲的原理，以及實現(xiàn)的源碼，推薦給大家，有需要的小伙伴可以參考下。2015-03-03
解決IDEA的maven項目中沒有新建Servlet文件的選項問題
這篇文章主要介紹了IDEA的maven項目中沒有新建Servlet文件的選項問題及解決方法,本文給大家分享問題原因就解決方法，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-09-09
Java并發(fā)編程之CountDownLatch原理詳解
這篇文章主要介紹了Java并發(fā)編程之CountDownLatch原理詳解,CountDownLatch類中使用了一個繼承自AQS的共享鎖Sync對象,構(gòu)造CountDownLatch對象時會將傳入的線程數(shù)值設為AQS的state值,需要的朋友可以參考下2023-12-12
這篇文章主要介紹了SpringBoot整合Lettuce redis過程解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-10-10