Spring Data MongoDB 一：入门篇（环境搭建简单的CRUD操作）

Posted 2020-10-11 起个名字好难

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Spring Data MongoDB 一：入门篇（环境搭建简单的CRUD操作）相关的知识，希望对你有一定的参考价值。

原文：http://blog.csdn.net/congcong68/article/details/44545253

一.简介

Spring Data MongoDB 项目提供与MongoDB文档数据库的集成。Spring Data MongoDB POJO的关键功能区域为中心的模型与MongoDB的DBCollection轻松地编写一个存储库交互数据访问。

二.Spring Data MongoDB的配置以及下载对应的Jar

1.安装MongoDb数据库，我们在上一篇就已经介绍过了，这边就不在介绍了，MongoDB 入门（安装与配置）

2.下载spring的spring-data的子项目两个jar，分别是spring-data-commons和spring-data-mongodb

http://projects.spring.io/spring-data-mongodb/

我这边下载是两个jar分别是：

spring-data-commons-1.7.2.RELEASE.jar

spring-data-mongodb-1.4.2.RELEASE.jar

3.下载mongoDb的java驱动jar包

http://central.maven.org/maven2/org/mongodb/mongo-java-driver/

这边有很多版本，下载自己对应得版本，我下载是：

mongo-java-driver-2.9.3.jar

技术分享

4.用Java测试一下MongoDB是否能正常连接

[java] view plain copy

public class TestMongodb {
@Test
public void testMongodb()
{
try{
// 连接到 mongodb 服务
Mongo mongo = new Mongo("127.0.0.1", 27017);
//根据mongodb数据库的名称获取mongodb对象 ,
DB db = mongo.getDB( "test" );
Set<String> collectionNames = db.getCollectionNames();
// 打印出test中的集合
for (String name : collectionNames) {
System.out.println("collectionName==="+name);
}
}catch(Exception e){
e.printStackTrace();
}

运行能获取test数据库下的集合，说明能正常连接数据库

技术分享

5.Spring的配置文件

1）applicationContext-mongo.xml

[html] view plain copy

<?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:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx" xmlns:util="http://www.springframework.org/schema/util"
xmlns:context="http://www.springframework.org/schema/context" xmlns:mongo="http://www.springframework.org/schema/data/mongo"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd
http://www.springframework.org/schema/data/mongo http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd">
<context:component-scan base-package="com.mongo" />
<context:property-placeholder location="classpath:jdbc.properties" />
<bean class="cn.mongo.util.SpringContextUtil"></bean>
<mongo:mongo id="mongo" replica-set="${mongo.replicaSet}">
<!--
connections-per-host: 每个主机答应的连接数（每个主机的连接池大小），当连接池被用光时，会被阻塞住
max-wait-time: 被阻塞线程从连接池获取连接的最长等待时间（ms）
connect-timeout:在建立（打开）套接字连接时的超时时间（ms）
socket-timeout:套接字超时时间;该值会被传递给Socket.setSoTimeout(int)
slave-ok:指明是否答应驱动从次要节点或者奴隶节点读取数据
-->
<mongo:options
connections-per-host="${mongo.connectionsPerHost}"
threads-allowed-to-block-for-connection-multiplier="${mongo.threadsAllowedToBlockForConnectionMultiplier}"
connect-timeout="${mongo.connectTimeout}"
max-wait-time="${mongo.maxWaitTime}"
auto-connect-retry="${mongo.autoConnectRetry}"
socket-keep-alive="${mongo.socketKeepAlive}"
socket-timeout="${mongo.socketTimeout}"
slave-ok="${mongo.slaveOk}"
write-number="${mongo.writeNumber}"
write-timeout="${mongo.riteTimeout}"
write-fsync="${mongo.writeFsync}"/>
</mongo:mongo>
<mongo:db-factory dbname="test" mongo-ref="mongo"/>
<bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
<constructor-arg name="mongoDbFactory" ref="mongoDbFactory"/>
</bean>
</beans>

2）jdbc.properties

[html] view plain copy

mongo.replicaSet=127.0.0.1:27017
mongo.connectionsPerHost=8
mongo.threadsAllowedToBlockForConnectionMultiplier=4
mongo.connectTimeout=1000
mongo.maxWaitTime=1500
mongo.autoConnectRetry=true
mongo.socketKeepAlive=true
mongo.socketTimeout=1500
mongo.slaveOk=true
mongo.writeNumber=1
mongo.riteTimeout=0
mongo.writeFsync=true

说明：

我们可以上官方网查看文档http://docs.spring.io/spring-data/data-mongo/docs/1.7.0.RC1/reference/html/#mongodb-connectors，这里面有说明怎么配置

技术分享

三.Spring 实现MongoDB的CRUD操作

1.实现一个基础接口，是比较通用的 MongoBase.java类

[java] view plain copy

public interface MongoBase<T> {
//添加
public void insert(T object,String collectionName);
//根据条件查找
public T findOne(Map<String,Object> params,String collectionName);
//查找所有
public List<T> findAll(Map<String,Object> params,String collectionName);
//修改
public void update(Map<String,Object> params,String collectionName);
//创建集合
public void createCollection(String collectionName);
//根据条件删除
public void remove(Map<String,Object> params,String collectionName);
}

2.实现一个实体类，我这边实现了User类

@Document注解，表示这个POJO最终要持久化为MongoDB中的document

[java] view plain copy

@Document
public class User implements Serializable {
/**
*
*/
private static final long serialVersionUID = 1L;
private String id;
private String name;
private int age;
private String password;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
}

3.实现UserDao类，就是实现User自己操作数据库的接口，这个UserDao也继承了MongoBase接口，我们这边UserDao没实现其他额外的接口

[java] view plain copy

public interface UserDao extends MongoBase<User>{
}

4.实现UserDaoImpl具体类，这边是实际操作数据库

[java] view plain copy

@Repository("userDaoImpl")
public class UserDaoImpl implements UserDao {
@Resource
private MongoTemplate mongoTemplate;
@Override
public void insert(User object,String collectionName) {
mongoTemplate.insert(object, collectionName);
}
@Override
public User findOne(Map<String,Object> params,String collectionName) {
return mongoTemplate.findOne(new Query(Criteria.where("id").is(params.get("id"))), User.class,collectionName);
}
@Override
public List<User> findAll(Map<String,Object> params,String collectionName) {
List<User> result = mongoTemplate.find(new Query(Criteria.where("age").lt(params.get("maxAge"))), User.class,collectionName);
return result;
}
@Override
public void update(Map<String,Object> params,String collectionName) {
mongoTemplate.upsert(new Query(Criteria.where("id").is(params.get("id"))), new Update().set("name", params.get("name")), User.class,collectionName);
}
@Override
public void createCollection(String name) {
mongoTemplate.createCollection(name);
}
@Override
public void remove(Map<String, Object> params,String collectionName) {
mongoTemplate.remove(new Query(Criteria.where("id").is(params.get("id"))),User.class,collectionName);
}

说明：

我们可以上官方网查看文档http://docs.spring.io/spring-data/data-mongo/docs/1.7.0.RC1/reference/html/#mongodb-connectors

mongoTemplate.upsert

技术分享

这边update里面提供了很多功能，可以根据条件进行修改，Criteria这个类也提供了where 、and、lt等，我们在查询年龄大于30的查出来，mongoTemplate.find(new Query(Criteria.where("age").lt(params.get("maxAge"))), User.class,collectionName);Criteria还很多

如图所示：

技术分享

4.实现测试类

我们这边为了节省时间，就没写服务类，我们直接调用dao就可以了，实现了TestUser.java类

1）添加并根据条件查找列表

[java] view plain copy

public class TestUser {
private static UserDao userDaoImpl;
private static ClassPathXmlApplicationContext app;
private static String collectionName;
@BeforeClass
public static void initSpring() {
try {
app = new ClassPathXmlApplicationContext(new String[] { "classpath:applicationContext-mongo.xml",
"classpath:spring-dispatcher.xml" });
userDaoImpl = (UserDao) app.getBean("userDaoImpl");
collectionName ="users";
} catch (Exception e) {
e.printStackTrace();
}
}
@Test
public void testAdd()
{
//添加一百个user
for(int i=0;i<100;i++){
User user =new User();
user.setId(""+i);
user.setAge(i);
user.setName("zcy"+i);
user.setPassword("zcy"+i);
userDaoImpl.insert(user,collectionName);
}
Map<String,Object> params=new HashMap<String,Object>();
params.put("maxAge", 50);
List<User> list=userDaoImpl.findAll(params,collectionName);
System.out.println("user.count()=="+list.size());
}