最近開(kāi)發(fā)一些MongoDB+Spring Boot的項(xiàng)目，發(fā)現(xiàn)相較于MyBatis來(lái)說(shuō)，Spring Boot對(duì)于MongoDB進(jìn)行操作變化更多，所以總結(jié)一下使用mongoTemplate庫(kù)的知識(shí)點(diǎn)，以備以后查閱方便。

首先在項(xiàng)目中的pom.xml配置文件中添加如下依賴(lài)：

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-mongodb</artifactId></dependency>

在需要引入mongoTemplate對(duì)象的Service文件中添加該對(duì)象即可，如下所示：

public class JobService { // 引入mongoTemplate對(duì)象 @Autowired MongoTemplate mongoTemplate;

針對(duì)CURD操作，常用的API方法有如下4類(lèi)：

更新： save()。 查詢(xún)： findAll()、find()、findOne()。 更新操作：update()。 刪除操作: remove()。

下面以一個(gè)實(shí)際的CRUD例子來(lái)講解具體用法，在注釋中會(huì)給出語(yǔ)法。先還是創(chuàng)建一個(gè)數(shù)據(jù)類(lèi)，假設(shè)我們是對(duì)武俠劍客數(shù)據(jù)進(jìn)行操作，POJO對(duì)象的定義代碼如下所示。

/** * 武俠劍客類(lèi) */@Data@NoArgsConstructor@AllArgsConstructor@Document(collection = 'my_sworders')public class MySworder implements Serializable { // 劍客的ID @Id private String id; // 姓名 @Field private String name; // 生平描述 @Field private String description; // 絕招 @Field private String skill; // 創(chuàng)建時(shí)間 @Field private int created;}

其中特別注意的是，@Document是mongodb驅(qū)動(dòng)庫(kù)提供設(shè)置操作的文檔集合名稱(chēng)的注解，這里設(shè)置集合為my_sworders。然后針對(duì)這個(gè)劍客類(lèi)編寫(xiě)一個(gè)Service文件，命名為SworderService.java：

@Servicepublic class SworderService { @Autowired MongoTemplate mongoTemplate; /** * 添加一個(gè)劍客 * @param mySworder * @return */ public boolean add(MySworder mySworder) { long unixTime = System.currentTimeMillis() / 1000L; int nowUnixTime = (int) unixTime; mySworder.setCreated(nowUnixTime); /** * 語(yǔ)法：<T> T mongoTemplate.save(T objectToSave) * save方法用于保存數(shù)據(jù)對(duì)象，傳遞定義好的JavaBean即可，被保存的數(shù)據(jù)對(duì)象會(huì)作為返回值被返回。 * 類(lèi)似地，使用insert也可以達(dá)到保存數(shù)據(jù)的作用。 */ MySworder obj = mongoTemplate.save(mySworder); if (obj.getId() > 0) { return true; } else { return false; } } /** * 獲取所有劍客數(shù)據(jù) * @return */ public List<MySworder> findAll() { /** * 語(yǔ)法：<T> List<T> findAll(Class<T> entityClass) * finAll會(huì)返回所有entityClass對(duì)應(yīng)的數(shù)據(jù)集合的數(shù)據(jù)，相當(dāng)于MySQL中select * from xxx_table_name。 */ return mongoTemplate.findAll(MySworder.class); } public boolean update(MySworder mySworder) { // 創(chuàng)建查詢(xún)對(duì)象 Query query = Query.query(Criteria.where('id').is(mySworder.getId())); Update update = new Update(); update.set('name', mySworder.getName()); update.set('description', mySworder.getDescription()); update.set('skill', mySworder.getSkill()); /** * 語(yǔ)法：public UpdateResult updateFirst(Query query, UpdateDefinition update, Class<?> entityClass) * updateFirst用于更新第一個(gè)被匹配的數(shù)據(jù)，query參數(shù)是查詢(xún)條件對(duì)象，update是需要更新的數(shù)據(jù)對(duì)象，entityClass就是對(duì)應(yīng)的JavaBean對(duì)象（文檔集合類(lèi)） */ UpdateResult updateResult = mongoTemplate.updateFirst(query, update, MyArticle.class); if (updateResult.getModifiedCount() > 0) { return true; } else { return false; } } public boolean updateBatchByKeyWords(String searchKey,String replaceString) { // 創(chuàng)建模糊查詢(xún)對(duì)象 Pattern pattern = Pattern.compile('^.*' + searchKey + '.*$', Pattern.CASE_INSENSITIVE); Criteria criteria = Criteria.where('description').regex(pattern); Update update = new Update(); update.set('description', replaceString); Query query = new Query(); query.addCriteria(criteria); /** * 語(yǔ)法：public UpdateResult updateMulti(Query query, UpdateDefinition update, Class<?> entityClass) * updateMulti用于所有被匹配的數(shù)據(jù)，query參數(shù)是查詢(xún)條件對(duì)象，update是需要更新的數(shù)據(jù)對(duì)象，entityClass就是對(duì)應(yīng)的JavaBean對(duì)象（文檔集合類(lèi)） */ UpdateResult updateResult = mongoTemplate.updateMulti(query, update, MySworder.class); if (updateResult.getModifiedCount() > 0) { return true; } else { return false; } } public boolean delete(String id) { MySworder mySworder = new MySworder(); mySworder.setId(id); /** * 語(yǔ)法： DeleteResult remove(Object object) * 該方法用于刪除數(shù)據(jù)，一般都是傳遞一個(gè)主鍵ID即可 */ DeleteResult deleteResult = mongoTemplate.remove(mySworder); if (deleteResult.getDeletedCount() > 0) { return true; } else { return false; } } public MySworder details(String id) { Query query = Query.query(Criteria.where('id').is(id)); /*** <T> T findOne(Query query, Class<T> entityClass)** findOne就是根據(jù)查詢(xún)條件(query）獲取一條數(shù)據(jù)。*/ return mongoTemplate.findOne(query, MySworder.class); }}

其中模糊查詢(xún)是使用了regex方法，并使用匹配Pattern對(duì)象來(lái)保存需要被匹配的字符串。

如果是多條件查詢(xún)，則需要使用Query對(duì)象來(lái)保存多個(gè)查詢(xún)條件，具體代碼如下：

// 用于存儲(chǔ)條件對(duì)象Query query = new Query();Criteria nameCriteria = Criteria.where('name').is(loginUser.getName());Criteria passwordCriteria = Criteria.where('password').is(loginUser.getPassword());query.addCriteria(nameCriteria);query.addCriteria(passwordCriteria);MyUser hasUser = mongoTemplate.findOne(query, MyUser.class);Integer userId = hasUser.getId();

如果查詢(xún)條件很多，那么這個(gè)addCriteria的代碼段就會(huì)很長(zhǎng)，這個(gè)時(shí)候就考慮自己再封裝一個(gè)工具類(lèi)，把循環(huán)查詢(xún)條件和一些復(fù)雜查詢(xún)的過(guò)程給封裝成一個(gè)方法，這樣事半功倍。

到此這篇關(guān)于Spring Boot之搞定mongoTemplate的知識(shí)小結(jié)的文章就介紹到這了,更多相關(guān)Spring Boot搞定mongoTemplate內(nèi)容請(qǐng)搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！