[Spring Data Mongo一]Spring Mongo Template操作MongoDB
MongoDB / houtizong 发布于 3年前 286
什么是Spring Data Mongo
Spring Data MongoDB项目对访问MongoDB的Java客户端API进行了封装，这种封装类似于Spring封装Hibernate和JDBC而提供的HibernateTemplate和JDBCTemplate，主要能力包括
1. 封装客户端跟MongoDB的链接管理
2. 文档-对象映射，通过注解:@Document(collection="collectionName")
3.对模版式的代码，进行了封装，类似于JDBCTemplate和HibernateTemplate
Spring Data Mongo在Spring中的基本配置
<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mongo="http://www.springframework.org/schema/data/mongo" xsi:schemaLocation="http://www.springframework.org/schema/data/mongo http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd"> <mongo:mongo replica-set="localhost:27018,localhost:27017,localhost:27019"> <mongo:options connections-per-host="200" threads-allowed-to-block-for-connection-multiplier="100" connect-timeout="1000" max-wait-time="1500" auto-connect-retry="true" socket-keep-alive="true" socket-timeout="1500" slave-ok="true" write-number="1" write-timeout="0" write-fsync="true"/> </mongo:mongo> <mongo:db-factory dbname="foolbar" username="" password="" mongo-ref="mongo"/> <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate"> <constructor-arg name="mongoDbFactory" ref="mongoDbFactory"/> </bean></beans>
说明：
1.其中的mongoTemplate是客户端操作MongoDB的主要类，它包含了增删改查功能以及其它一些操作，这些操作在以后的篇幅中会讲到
2.replica-set是副本集集群的MongoDB服务器的链接地址，以逗号分开，如果仅有一台服务器，使用host="localhost:27017”或者replica-set="localhost:27017"都可以，
3.mongo:options定义了链接属性和读写相关属性，以后再来完善这部分
Document和Collection注解
package com.tom.user.model;import org.bson.types.ObjectId;import org.springframework.data.annotation.Id;import org.springframework.data.mongodb.core.mapping.Document;@Document(collection = "users")public class User { @Id private ObjectId userId; private String name; private String passwd; public ObjectId getUserId() { return userId; } public void setUserId(ObjectId userId) { this.userId = userId; } public String getName() { return name; } public void setName(String name) { this.name = name; } public String getPasswd() { return passwd; } public void setPasswd(String passwd) { this.passwd = passwd; }} 上面的代码定义了一个类似于Hibernate实体Bean的POJO，在Hibernate它可以和数据库的一个表建立映射关系，但是在MongoDB中，一个集合中的文档的Field是任意的，因此POJO必须映射到文档一级(@Document)，同时注解中指明这个文档属于哪个集合(一个文档只能属于一个集合)。当使用MongoDBTemplate对POJO进行操作时，可以根据POJO的类型得到它要往那个集合中写文档
MongoDBTemplate简单CRUD操作
package com.tom.user.storage;import com.tom.user.model.User;import org.junit.Assert;import org.junit.Before;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;import org.springframework.data.mongodb.core.MongoTemplate;import org.springframework.data.mongodb.core.query.Criteria;import org.springframework.data.mongodb.core.query.Query;import org.springframework.data.mongodb.core.query.Update;import java.util.List;/*http://www.tuicool.com/articles/EFnyyehttp://www.mkyong.com/mongodb/spring-data-mongodb-hello-world-example/ */public class UserMongoDBStorageServiceTest2 { private ApplicationContext cxt = null; @Before public void setup() { cxt = new ClassPathXmlApplicationContext("applicationContext.xml"); } private void create() { drop(); MongoTemplate template = cxt.getBean("mongoTemplate", MongoTemplate.class); User user = new User(); user.setName("abc"); user.setPasswd("def"); template.insert(user); } public void query() { Query query = new Query(new Criteria("name").is("abc")); MongoTemplate template = cxt.getBean("mongoTemplate", MongoTemplate.class); List<User> users = template.find(query, User.class); Assert.assertEquals(1, users.size()); User user = users.get(0); Assert.assertEquals("abc", user.getName()); Assert.assertEquals("def", user.getPasswd()); } public void update() { Query query = new Query(new Criteria("name").is("abc")); MongoTemplate template = cxt.getBean("mongoTemplate", MongoTemplate.class); List<User> users = template.find(query, User.class); Assert.assertEquals(1, users.size()); User user = users.get(0); user.setPasswd("def-updated"); Update update = new Update(); update.set("passwd",user.getPasswd()); template.updateFirst(query, update, User.class); Assert.assertEquals("abc", user.getName()); } public void queryUpdate() { MongoTemplate template = cxt.getBean("mongoTemplate", MongoTemplate.class); List<User> users = template.findAll(User.class); Assert.assertEquals(1, users.size()); User user = users.get(0); Assert.assertEquals("abc", user.getName()); Assert.assertEquals("def-updated",user.getPasswd()); } public void drop() { MongoTemplate template = cxt.getBean("mongoTemplate", MongoTemplate.class); template.dropCollection(User.class); } @org.junit.Test public void testCRUD() { create(); query(); update(); queryUpdate(); drop(); }}
只对Update操作做下说明：
public void update() { Query query = new Query(new Criteria("name").is("abc")); MongoTemplate template = cxt.getBean("mongoTemplate", MongoTemplate.class); List<User> users = template.find(query, User.class); Assert.assertEquals(1, users.size()); User user = users.get(0); user.setPasswd("def-updated"); Update update = new Update(); update.set("passwd",user.getPasswd()); template.updateFirst(query, update, User.class); Assert.assertEquals("abc", user.getName()); }
User两个字段name和passwd，Update中只通过Update.set方法对passwd进行了更改，那么name这个属性在更新操作完成后是从文档中被删除了还是保留下来了？答案是保留下来了，并且值保持不变，这就为更新操作提供了很大的便利性，要改什么就在Update中指定什么，
Spring Data Mongo连接MongoDB服务器的参数
请勿发布不友善或者负能量的内容。与人为善，比聪明更重要！
技术博客集 - 网站简介：
前后端技术：
后端基于Hyperf2.1框架开发,前端使用Bootstrap可视化布局系统生成
网站主要作用：
1.编程技术分享及讨论交流，内置聊天系统;
2.测试交流框架问题，比如：Hyperf、Laravel、TP、beego;
3.本站数据是基于大数据采集等爬虫技术为基础助力分享知识，如有侵权请发邮件到站长邮箱，站长会尽快处理;
4.站长邮箱：[email protected];
文章归档
文章标签
友情链接
