SpringBoot集成MongoDB的實現(xiàn)
1、MongoDB簡介
MongoDB 是一個開源的、高性能、無模式(schema-free)的文檔型數(shù)據(jù)庫,它屬于 NoSQL 數(shù)據(jù)庫的一種。MongoDB 的設計初衷是為了簡化開發(fā)和方便擴展,同時提供可擴展的高性能數(shù)據(jù)存儲解決方案。
以下是 MongoDB 的一些關鍵特點:
- 面向文檔:MongoDB 中的數(shù)據(jù)以文檔的形式存儲,這些文檔是鍵值對的集合,類似于 JSON 對象但使用的是 BSON(Binary JSON)格式,這使得它可以存儲復雜的數(shù)據(jù)類型。
- 無模式(Schema-less):與關系型數(shù)據(jù)庫不同,MongoDB 不需要預先定義固定的表結構,每個文檔可以有不同的字段和數(shù)據(jù)類型。
- 高可用性和擴展性:MongoDB 支持自動分片(sharding),這有助于水平擴展,能夠處理大量的數(shù)據(jù)和高并發(fā)訪問。
- 豐富的查詢語言:MongoDB 提供了強大的查詢能力,其語法接近于面向對象的查詢語言,支持復雜的查詢操作,包括排序、聚合等。
- 索引支持:為了加快查詢速度,MongoDB 支持對字段創(chuàng)建索引,包括單字段索引、復合索引、地理空間索引等。
- 復制和容錯:通過副本集(replica set),MongoDB 可以實現(xiàn)數(shù)據(jù)的冗余存儲,提高系統(tǒng)的可靠性和容錯能力。
- 易于使用和集成:MongoDB 提供了多種編程語言的驅動程序,方便開發(fā)者進行應用開發(fā),并且擁有圖形化管理工具如 Compass、Navicat、Studio 3T等來輔助數(shù)據(jù)庫管理和維護。
- 社區(qū)和支持:作為一個廣泛使用的數(shù)據(jù)庫系統(tǒng),MongoDB 擁有一個活躍的社區(qū)和官方提供的商業(yè)支持服務。
MongoDB 被設計用來滿足現(xiàn)代應用程序的需求,特別是那些需要處理大量非結構化或半結構化數(shù)據(jù)的應用場景,比如內容管理系統(tǒng)、實時分析、移動應用后端等。由于其靈活性和性能優(yōu)勢,MongoDB 成為許多開發(fā)者和企業(yè)的首選數(shù)據(jù)庫解決方案之一。
2、MongoDB安裝
Linux安裝
下載MongoDB Community Server
下載地址:https://www.mongodb.com/try/download/community
解壓后啟動MongoDB Server
#創(chuàng)建dbpath和logpath mkdir -p /mongodb/data /mongodb/log #進入mongodb目錄,啟動mongodb服務 bin/mongod --port=27017 --dbpath=/mongodb/data --logpath=/mongodb/log/mongodb.log
3、SpringBoot集成MongoDB
3.1、環(huán)境準備
1、引入依賴
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
完整依賴如下:
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.3.RELEASE</version>
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.9</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.68</version>
</dependency>
</dependencies>
2、配置
application.properties
# MongoDB spring.data.mongodb.host = 127.0.0.1 spring.data.mongodb.port = 27017 spring.data.mongodb.database = test spring.data.mongodb.auto-index-creation = true # 或者直接使用uri方式 #spring.data.mongodb.uri=mongodb://user:password@127.0.0.1:27017/test?authSource=admin # 打印mongoDB日志 logging.level.org.springframework.data.mongodb.core.MongoTemplate=DEBUG logging.level.org.mongodb.driver.connection=DEBUG
連接配置可參考文檔 https://www.mongodb.com/zh-cn/docs/manual/reference/connection-string/
3.2、文檔操作
1、新增實體
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Document(collection = "person") // 指定集合名稱
public class Person {
@Id // 映射文檔中的_id
private Long id;
private String name;
private Integer age;
}
2、添加集合文檔
集合操作時注入MongoTemplate
@SpringBootTest(classes = MongoApplication.class)
@RunWith(SpringRunner.class)
public class InsertTests {
@Resource
private MongoTemplate mongoTemplate;
@Test
public void testInsert() {
Person person = Person.builder().id(2L).name("river").age(18).build();
mongoTemplate.insert(person);
// 如果有就修改, 沒有就插入
mongoTemplate.save(Person.builder().id(2L).name("zhangsan").age(28).build());
// 批量寫入
List<Person> persons = new ArrayList<>();
for (int i = 100; i <= 150; i++) {
person = Person.builder().id(Long.valueOf(i)).name("lisi" + i).age(i).build();
persons.add(person);
}
mongoTemplate.insertAll(persons);
}
}
插入數(shù)據(jù)時: insert插入的_id 不能有重復,否則會報 DuplicateKeyException 提示主鍵重復; save對已存在的數(shù)據(jù)進行更新;
批處理操作時: insertAll可以一次性插入所有數(shù)據(jù),效率較高;save需遍歷所有數(shù)據(jù),一次插入或更新,效率較低。
3、查詢集合文檔
@Slf4j
@SpringBootTest(classes = MongoApplication.class)
@RunWith(SpringRunner.class)
public class QueryTests {
@Autowired
private MongoTemplate mongoTemplate;
@Test
public void find() {
// 查詢集合中的全部文檔數(shù)據(jù)
List<Person> personList = mongoTemplate.findAll(Person.class);
log.info("查詢結果:{}", personList);
// 查詢集合中指定的ID文檔數(shù)據(jù)
Person byId = mongoTemplate.findById(1L, Person.class);
log.info("查詢結果:{}", byId.toString());
// 根據(jù)條件查詢符合條件的文檔數(shù)據(jù)并返回第一條數(shù)據(jù)
Query query = new Query(Criteria.where("name").is("river"));
Person result = mongoTemplate.findOne(query, Person.class);
log.info("查詢結果:{}", result);
// 根據(jù)條件查詢所有符合條件的文檔
query = new Query(Criteria.where("age").gt(18));
List<Person> list = mongoTemplate.find(query, Person.class);
log.info("查詢結果:{}", list);
// 創(chuàng)建查詢對象,然后將條件對象添加到其中
Criteria criteria = Criteria.where("age").gt(18).lte(30);
query = new Query(criteria);
list = mongoTemplate.find(query, Person.class);
log.info("查詢結果:{}", list);
Criteria name = Criteria.where("name").is("zhangsan");
Criteria age = Criteria.where("age").is(18);
// 創(chuàng)建條件對象,將上面條件進行 AND 關聯(lián)
criteria = new Criteria().andOperator(name, age);
query = new Query(criteria);
list = mongoTemplate.find(query, Person.class);
log.info("查詢結果:{}", list);
// 從第5行開始,查詢3條數(shù)據(jù)返回
query = new Query(Criteria.where("age").is("20"))
.with(Sort.by("id"))
.limit(3).skip(5);
list = mongoTemplate.find(query, Person.class);
log.info("查詢結果:{}", list);
}
}
Criteria是標準查詢的接口,可以引用靜態(tài)的Criteria.where的把多個條件組合在一起,就可以輕松地將多個方法查詢連接起來,方便我們操作查詢語句。
4、更新集合文檔
@Slf4j
@SpringBootTest(classes = MongoApplication.class)
@RunWith(SpringRunner.class)
public class UpdateTests {
@Autowired
private MongoTemplate mongoTemplate;
@Test
public void update() {
Person person = mongoTemplate.findById(1L, Person.class);
person.setName("wangwu");
mongoTemplate.save(person);
Query query = new Query(Criteria.where("id").is(1L));
// 修改內容
Update update = new Update().set("name", "lisi");
UpdateResult updateResult = mongoTemplate.updateMulti(query, update, Person.class);
// // 只更新滿足條件的第一條記錄
// UpdateResult updateResult = mongoTemplate.updateFirst(query, update, Person.class);
// 沒有符合條件的記錄則插入數(shù)據(jù)
// // update.setOnInsert("id",11); // 指定_id
// updateResult = mongoTemplate.upsert(query, update, Person.class);
// 返回修改的記錄數(shù)
log.info("updateResult: {}", updateResult.getModifiedCount());
}
}
如果更新后的結果和更新前的結果是相同,返回0。
updateFirst() 只更新滿足條件的第一條記錄
updateMulti() 更新所有滿足條件的記錄
upsert() 沒有符合條件的記錄則插入數(shù)據(jù)
5、刪除集合文檔
@Slf4j
@SpringBootTest(classes = MongoApplication.class)
@RunWith(SpringRunner.class)
public class DeleteTests {
@Autowired
private MongoTemplate mongoTemplate;
@Test
public void delete() {
// 刪除id為1的記錄
Query query = new Query(Criteria.where("id").is(1L));
DeleteResult remove = mongoTemplate.remove(query, Person.class);
log.info("刪除的條數(shù)為:{}", remove.getDeletedCount());
// 刪除符合條件的單個文檔并返回刪除的文檔
query = new Query(Criteria.where("id").is(2L));
Person per = mongoTemplate.findAndRemove(query, Person.class);
log.info("刪除的文檔: {}", per);
}
}
3.3、去掉_class屬性
使用MongoTemplate寫入文檔時,會自動將_class屬性添加到文檔中,一般不需要使用_class屬性,可以配置去掉_class屬性。
@Configuration
public class MongoConfig {
@Bean("mongoTemplate")
public MongoTemplate mongoTemplate(MongoDbFactory mongoDbFactory, MongoMappingContext mongoMappingContext) {
DbRefResolver dbRefResolver = new DefaultDbRefResolver(mongoDbFactory);
MappingMongoConverter mappingMongoConverter = new MappingMongoConverter(dbRefResolver, mongoMappingContext);
// 去掉_class字段
mappingMongoConverter.setTypeMapper(new DefaultMongoTypeMapper(null));
return new MongoTemplate(mongoDbFactory, mappingMongoConverter);
}
}到此這篇關于SpringBoot集成MongoDB的實現(xiàn)的文章就介紹到這了,更多相關SpringBoot集成MongoDB內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
Java easyui樹形表格TreeGrid的實現(xiàn)代碼
這篇文章主要為大家詳細介紹了Java easyui樹形表格TreeGrid的實現(xiàn)代碼,具有一定的參考價值,感興趣的小伙伴們可以參考一下2017-03-03
SpringBoot項目優(yōu)雅的全局異常處理方式(全網(wǎng)最新)
這篇文章主要介紹了SpringBoot項目優(yōu)雅的全局異常處理方式(全網(wǎng)最新),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2021-04-04
java之CSV大批量數(shù)據(jù)入庫的實現(xiàn)
本文主要介紹了java之CSV大批量數(shù)據(jù)入庫的實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2023-02-02
Java Spring的數(shù)據(jù)庫開發(fā)詳解
這篇文章主要介紹了Spring的數(shù)據(jù)庫開發(fā),主要圍繞SpringJDBC和Spring Jdbc Template兩個技術來講解,文中有詳細的代碼示例,需要的小伙伴可以參考一下2023-04-04

