备案控制台
探索云世界
开发者社区 数据库 文章 正文

SpringData操作MongoDB

2017-08-20 6572
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 MongoDB，通用型 2核4GB
推荐场景：
五天玩转MongoDB训练营
简介： 通过SpringData读写MongoDB基础操作
pom.xml添加依赖
<!-- MongoDB -->
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongo-java-driver</artifactId>
<version>3.0.4</version>
</dependency>
<!-- spring data -->
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-mongodb</artifactId>
<version>1.10.4.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-mongodb-cross-store</artifactId>
<version>1.2.1.RELEASE</version>
<type>jar</type>
<scope>compile</scope>
</dependency>


mongodb数据库源配置，mongodb-context.xml
<?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:p="http://www.springframework.org/schema/p"
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/data/mongo  
            http://www.springframework.org/schema/data/mongo/spring-mongo.xsd">

<!-- spring连接mongodb数据库的配置 -->
<mongo:mongo-client host=" 数据库IP" port=" 数据库端口 " credentials=" 数据库用户名 :数据库密码@数据库名称" id="mongo">
<mongo:client-options write-concern="SAFE" />
</mongo:mongo-client>

<mongo:db-factory id="mongoDbFactory" dbname="mongoTest" mongo-ref="mongo" />

<!-- 只要使用这个调用相应的方法操作 -->
<bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
<constructor-arg name="mongoDbFactory" ref="mongoDbFactory" />
</bean>

<bean id="memberDao" class="mongoDB.MemberDao" />
<bean id="bookDao" class="mongoDB.BookDao" />
</beans>


applicationContext.xml文件引入mongodb配置
<context:component-scan base-package="mongoDB" />
<!-- 导入mongodb的配置文件 -->
<import resource="mongodb-context.xml"/>


测试类-会员
import org.springframework.data.mongodb.core.mapping.DBRef;

public class Member
{
private String id;
private String username;
private String password;
@DBRef
private Book book;
public String getId()
{
return id;
}
public void setId(String id)
{
this.id = id;
}
public String getUsername()
{
return username;
}
public void setUsername(String username)
{
this.username = username;
}
public String getPassword()
{
return password;
}
public void setPassword(String password)
{
this.password = password;
}
public Book getBook()
{
return book;
}
public void setBook(Book book)
{
this.book = book;
}
}


测试类-书本
import org.springframework.data.mongodb.core.mapping.DBRef;

public class Book
{
private String id;
private String theName;
@DBRef
private Member member;
public String getId()
{
return id;
}
public void setId(String id)
{
this.id = id;
}
public String getTheName()
{
return theName;
}
public void setTheName(String theName)
{
this.theName = theName;
}
public Member getMember()
{
return member;
}
public void setMember(Member member)
{
this.member = member;
}
}


基于DAO，对接MongoTemplate
import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
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;

public abstract class MongoGenDao<T>
{
@Autowired
protected MongoTemplate mongoTemplate;

/**
 * 保存一个对象
 * 
 * @author http://www.chisalsoft.com
 */
public void save(T t)
{
this.mongoTemplate.save(t);
}

/**
 * 根据Id从Collection中查询对象
 * 
 * @author http://www.chisalsoft.com
 */
public T queryById(String id)
{
Query query = new Query();
Criteria criteria = Criteria.where("_id").is(id);
query.addCriteria(criteria);
return this.mongoTemplate.findOne(query, this.getEntityClass());
}

/**
 * 根据条件查询集合
 * 
 * @author http://www.chisalsoft.com
 */
public List<T> queryList(Query query)
{
return this.mongoTemplate.find(query, this.getEntityClass());
}

/**
 * 通过条件查询单个实体
 * 
 * @author http://www.chisalsoft.com
 */
public T queryOne(Query query)
{
return this.mongoTemplate.findOne(query, this.getEntityClass());
}

/**
 * 通过条件进行分页查询
 * 
 * @author http://www.chisalsoft.com
 */
public List<T> getPage(Query query, int start, int size)
{
query.skip(start);
query.limit(size);
List<T> lists = this.mongoTemplate.find(query, this.getEntityClass());
return lists;
}

/**
 * 根据条件查询库中符合记录的总数,为分页查询服务
 * 
 * @author http://www.chisalsoft.com
 */
public Long getPageCount(Query query)
{
return this.mongoTemplate.count(query, this.getEntityClass());
}

/**
 * 根据Id删除用户
 * 
 * @author http://www.chisalsoft.com
 */
public void deleteById(String id)
{
Criteria criteria = Criteria.where("_id").in(id);
if (null != criteria)
{
Query query = new Query(criteria);
if (null != query && this.queryOne(query) != null)
{
this.mongoTemplate.remove(query);
}
}
}

/**
 * 更新满足条件的第一个记录
 * 
 * @author http://www.chisalsoft.com
 */
public void updateFirst(Query query, Update update)
{
this.mongoTemplate.updateFirst(query, update, this.getEntityClass());
}

/**
 * 更新满足条件的所有记录
 * 
 * @author http://www.chisalsoft.com
 */
public void updateMulti(Query query, Update update)
{
this.mongoTemplate.updateMulti(query, update, this.getEntityClass());
}

/**
 * 查找更新,如果没有找到符合的记录,则将更新的记录插入库中
 * 
 * @author http://www.chisalsoft.com
 */
public void updateInser(Query query, Update update)
{
this.mongoTemplate.upsert(query, update, this.getEntityClass());
}

/**
 * 删除对象
 * 
 * @author http://www.chisalsoft.com
 */
public void delete(T t)
{
this.mongoTemplate.remove(t);
}

/**
 * 为属性自动注入bean服务
 * 
 * @author http://www.chisalsoft.com
 */
public void setMongoTemplate(MongoTemplate mongoTemplate)
{
this.mongoTemplate = mongoTemplate;
}

protected abstract Class<T> getEntityClass();
}


测试类DAO-BOOK
import java.util.List;

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 org.springframework.stereotype.Repository;

@Repository
public class BookDao extends MongoGenDao<Book>
{
/**
 * 分页查询 对应mongodb操作中的 db.book.find().skip(10).limit(10);
 * 
 * @author http://www.chisalsoft.com
 */
public List<Book> queryPage(Book book, Integer start, Integer size)
{
Query query = new Query();
// 此处可以增加分页查询条件Criteria.然后query.addCriteria(criteria);
return this.getPage(query, (start - 1) * size, size);
}

/**
 * 查询满足分页的记录总数
 * 
 * @author http://www.chisalsoft.com
 */
public Long queryPageCount(Book book)
{
Query query = new Query();
// 此处可以增加分页查询条件Criteria.然后query.addCriteria(criteria);
return this.getPageCount(query);
}

/**
 * 更新操作
 * 
 * @author http://www.chisalsoft.com
 */
public void updateFirst(Book book) throws Exception
{
Update update = new Update();
if (null == book.getId() || "".equals(book.getId().trim()))
{
// 如果主键为空,则不进行修改
throw new Exception("Update data Id is Null");
}
if (book.getTheName() != null)
{
update.set("theName", book.getTheName());
}
this.updateFirst(Query.query(Criteria.where("_id").is(book.getId())), update);
}

/**
 * 更新库中所有数据
 * 
 * @author http://www.chisalsoft.com
 */
public void updateMulti(Book book) throws Exception
{
Update update = new Update();
if (null == book.getId() || "".equals(book.getId().trim()))
{
// 如果主键为空,则不进行修改
throw new Exception("Update data Id is Null");
}
if (book.getTheName() != null)
{
update.set("theName", book.getTheName());
}
this.updateMulti(Query.query(Criteria.where("_id").is(book.getId())), update);
}

/**
 * 实现钩子方法,返回反射的类型
 * 
 * @author http://www.chisalsoft.com
 */
@Override
protected Class<Book> getEntityClass()
{
return Book.class;
}
}

测试类DAO-Member
import java.util.List;

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 org.springframework.stereotype.Repository;

@Repository
public class MemberDao extends MongoGenDao<Member>
{
/**
 * 分页查询 对应mongodb操作中的 db.member.find().skip(10).limit(10);
 * 
 * @author http://www.chisalsoft.com
 */
public List<Member> queryPage(Member member, Integer start, Integer size)
{
Query query = new Query();
return this.getPage(query, (start - 1) * size, size);
}

/**
 * 查询满足分页的记录总数
 * 
 * @author http://www.chisalsoft.com
 */
public Long queryPageCount(Member member)
{
Query query = new Query();
return this.getPageCount(query);
}

/**
 * 更新操作
 * 
 * @author http://www.chisalsoft.com
 */
public void updateFirst(Member member) throws Exception
{
Update update = new Update();
if (null == member.getId() || "".equals(member.getId().trim()))
{
// 如果主键为空,则不进行修改
throw new Exception("Update data Id is Null");
}
if (member.getUsername() != null)
{
update.set("username", member.getUsername());
}
if (member.getPassword() != null)
{
update.set("password", member.getPassword());
}
this.updateFirst(Query.query(Criteria.where("_id").is(member.getId())), update);
}

/**
 * 更新库中所有数据
 * 
 * @author http://www.chisalsoft.com
 */
public void updateMulti(Member member) throws Exception
{
Update update = new Update();
if (null == member.getId() || "".equals(member.getId().trim()))
{
// 如果主键为空,则不进行修改
throw new Exception("Update data Id is Null");
}
if (member.getUsername() != null)
{
update.set("username", member.getUsername());
}
if (member.getPassword() != null)
{
update.set("password", member.getPassword());
}
this.updateMulti(Query.query(Criteria.where("_id").is(member.getId())), update);
}

/**
 * 实现钩子方法,返回反射的类型
 * 
 * @author http://www.chisalsoft.com
 */
@Override
protected Class<Member> getEntityClass()
{
return Member.class;
}
}


测试类
import java.util.List;

import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.test.context.transaction.TransactionConfiguration;
import org.springframework.transaction.annotation.Transactional;

import api.BaseJunitTest;

@Transactional
@TransactionConfiguration(transactionManager="transactionManager",defaultRollback=false)
public class TestMongo extends BaseJunitTest
{
@Autowired
private MemberDao memberDao;

@Autowired
private BookDao bookDao;
@Test
public void execute() throws Exception
{
Member member = new Member();
member.setId("1");
member.setUsername("username1");
member.setPassword("password1");
memberDao.save(member);
}

@Test
public void save2() throws Exception
{
Member member = new Member();
member.setId("2");
member.setUsername("username1");
member.setPassword("password1");
Book book = new Book();
book.setId("1");
book.setTheName("book1");
member.setBook(book);
memberDao.save(member);
}

@Test
public void save3() throws Exception
{
Member member = new Member();
member.setId("3");
member.setUsername("username3");
member.setPassword("password3");
Book book = new Book();
book.setId("3");
book.setTheName("book3");
book.setMember(member);
member.setBook(book);
memberDao.save(member);//在Member和Book互相包含的情况下，若没有设置@DBRef，则此处会规模溢出
bookDao.save(book);
System.out.println("保存完成");
}
@Test
public void update() throws Exception
{
Member member = memberDao.queryById("1");
member.setUsername("username_1");
memberDao.updateFirst(member);
}
@Test
public void getMember() throws Exception
{
Member member = memberDao.queryById("3");
if(member == null)
{
System.out.println("没有这个会员");
}
else
{
System.out.println(member.getUsername());
if(member.getBook() == null)
{
System.out.println("该会员没有book");
}
else
{
System.out.println("该会员有book:"+member.getBook().getTheName());
}
}
}
@Test
public void getBook() throws Exception
{
Book book = bookDao.queryById("3");
if(book != null)
{
System.out.println(book.getTheName());
if(book.getMember() == null)
{
System.out.println("该book没有会员");
}
else
{
System.out.println("该book有会员:"+book.getMember().getUsername());
}
}
else
{
System.out.println("没有找到这本书");
}
}
@Test
public void deleteBook() throws Exception
{
List<Book> bookList = bookDao.queryList(new Query());
for(Book book:bookList)
{
bookDao.delete(book);
}
}
@Test
public void deleteMember() throws Exception
{
List<Member> memberList = memberDao.queryList(new Query());
for(Member member:memberList)
{
memberDao.delete(member);
}
}
@Test
public void queryBook() throws Exception
{
List<Book> bookList = bookDao.queryList(new Query());
if(bookList.size() == 0)
{
System.out.println("没有book");
}
else
{
for(Book book:bookList)
{
System.out.println(book.getTheName());
}
}
}
@Test
public void queryMember() throws Exception
{
List<Member> memberList = memberDao.queryList(new Query());
if(memberList.size() == 0)
{
System.out.println("没有会员");
}
else
{
for(Member member:memberList)
{
System.out.println(member.getUsername());
}
}
}
}
文章标签：
云数据库 MongoDB 版
Java
Spring
NoSQL
数据库
数据安全/隐私保护
MongoDB
数据格式
XML
关键词：
云数据库 MongoDB 版操作
Spring mongodb
云数据库 MongoDB 版springdata
springdata操作云数据库 MongoDB 版
相关实践学习
MongoDB数据库入门
MongoDB数据库入门实验。
快速掌握 MongoDB 数据库
本课程主要讲解MongoDB数据库的基本知识，包括MongoDB数据库的安装、配置、服务的启动、数据的CRUD操作函数使用、MongoDB索引的使用（唯一索引、地理索引、过期索引、全文索引等）、MapReduce操作实现、用户管理、Java对MongoDB的操作支持（基于2.x驱动与3.x驱动的完全讲解）。 通过学习此课程，读者将具备MongoDB数据库的开发能力，并且能够使用MongoDB进行项目开发。 &nbsp; 相关的阿里云产品：云数据库 MongoDB版 云数据库MongoDB版支持ReplicaSet和Sharding两种部署架构，具备安全审计，时间点备份等多项企业能力。在互联网、物联网、游戏、金融等领域被广泛采用。 云数据库MongoDB版（ApsaraDB for MongoDB）完全兼容MongoDB协议，基于飞天分布式系统和高可靠存储引擎，提供多节点高可用架构、弹性扩容、容灾、备份回滚、性能优化等解决方案。 产品详情: https://www.aliyun.com/product/mongodb
tonytonyyang
目录
相关文章
wljslmz
|
4月前
|
NoSQL JavaScript 前端开发
如何使用 Node.js 连接和操作 MongoDB 数据库？
如何使用 Node.js 连接和操作 MongoDB 数据库？
wljslmz
237 2
小万哥丶
|
3月前
|
NoSQL MongoDB Python
深入了解 Python MongoDB 操作：排序、删除、更新、结果限制全面解析
使用 sort() 方法对结果进行升序或降序排序。 sort() 方法接受一个参数用于“字段名”，一个参数用于“方向”（升序是默认方向）。
小万哥丶
68 0
热烈的马
|
4月前
|
NoSQL Java MongoDB
Spring Boot中MongoDB的使用和实战
Spring Boot中MongoDB的使用和实战
热烈的马
63 0
爱吃糖的范同学
|
24天前
|
缓存 NoSQL 关系型数据库
【MongoDB】MongoDB更新操作时是否立刻fsync到磁盘？
【4月更文挑战第2天】【MongoDB】MongoDB更新操作时是否立刻fsync到磁盘？
爱吃糖的范同学
15 0
阿里云云原生
|
25天前
|
消息中间件 NoSQL Kafka
云原生最佳实践系列 5：基于函数计算 FC 实现阿里云 Kafka 消息内容控制 MongoDB DML 操作
该方案描述了一个大数据ETL流程，其中阿里云Kafka消息根据内容触发函数计算（FC）函数，执行针对MongoDB的增、删、改操作。
阿里云云原生
434 2
MongoDB小助手
|
3月前
|
机器学习/深度学习 自然语言处理 NoSQL
一文读懂：怎样将 MongoDB 转变为预测数据库？操作详解来了！
技术讲解
MongoDB小助手
1837 2
一文读懂：怎样将 MongoDB 转变为预测数据库？操作详解来了！
不吃西红柿丶
|
3月前
|
存储 NoSQL MongoDB
Python小姿势 - Python操作MongoDB数据库
Python小姿势 - Python操作MongoDB数据库
不吃西红柿丶
53 0
CodeDevMaster
|
6月前
|
NoSQL API MongoDB
Python使用PyMongo4.x操作MongoDB总结
PyMongo是一个Python编程语言中用于连接和操作MongoDB数据库的库。它提供了丰富的功能和API，使开发者能够在Python中轻松地进行MongoDB的数据交互和管理。
CodeDevMaster
84 2
jerrywangsap
|
7月前
|
NoSQL JavaScript Java
MongoDB 入门教程系列之三：使用 Restful API 操作 MongoDB
MongoDB 入门教程系列之三：使用 Restful API 操作 MongoDB
jerrywangsap
83 0
jerrywangsap
|
7月前
|
存储 NoSQL Java
MongoDB 入门教程系列之二：使用 Spring Boot 操作 MongoDB
MongoDB 入门教程系列之二：使用 Spring Boot 操作 MongoDB
jerrywangsap
99 0

热门文章

最新文章

  • 1
    如何用MongoDB Atlas和大语言模型，高效构建企业级AI应用？
  • 2
    云原生最佳实践系列 5：基于函数计算 FC 实现阿里云 Kafka 消息内容控制 MongoDB DML 操作
  • 3
    mongodb 命令行连接及基础命令
  • 4
    【MongoDB】MongoDB 服务无法正常启动问题排查
  • 5
    直播预告：助力业务升级！《阿里云MongoDB数据迁移指导》线上研讨会
  • 6
    Python与NoSQL数据库（MongoDB、Redis等）面试问答
  • 7
    【MongoDB】如何在MongoDB中设计Schema？
  • 8
    【MongoDB】 MongoDB的副本集是什么？
  • 9
    【MongoDB】MongoDB 如何处理复杂的数据结构？
  • 10
    MongoDB 的数据关系
  • 1
    【spring（六）】WebSocket网络传输协议
    22
  • 2
    【spring（五）】SpringMvc总结 SSM整合流程
    32
  • 3
    【spring（四）】Spring事务管理和@Transactional注解
    32
  • 4
    Spring Boot 4.0：构建云原生Java应用的前沿工具
    51
  • 5
    Java 新手如何使用Spring MVC 中的查询字符串和查询参数
    23
  • 6
    Spring Boot的定时任务与异步任务
    53
  • 7
    通用Shell脚本执行Spring Boot项目Jar包
    29
  • 8
    Spring Batch学习记录及示例项目代码
    21
  • 9
    如何使用Spring Data JPA完成审计功能
    17
  • 10
    Spring Boot集成Redis启动失败【Caused by: java.lang.ClassNotFoundException: org.apache.commons.pool2.impl.G】
    45

    • 相关课程

    更多
  • MongoDB完全自学手册
  • 云数据库MongoDB版使用教程
  • 快速掌握 MongoDB 数据库
  • Spring Boot 2.5.x开发实战
  • MongoDB快速入门
  • Spring Cloud微服务架构设计与开发实战

    • 相关电子书

    更多
  • 云栖社区特邀专家徐雷Java Spring Boot开发实战系列课程（第20讲）：经典面试题与阿里等名企内部招聘求职面试技巧
  • 微服务架构模式与原理Spring Cloud开发实战
  • 阿里特邀专家徐雷Java Spring Boot开发实战系列课程（第18讲）：制作Java Docker镜像与推送到DockerHub和阿里云Docker仓库

    • 相关实验场景

    更多
  • 云数据库MongoDB快速入门
  • 5分钟上手Flink MySQL连接器
  • 如何开通MongoDB的专属集群
  • MongoDB数据库入门
  • 从零搭建Spring Boot的Hello World

    • 推荐镜像

    更多
  • mongodb
  • clickhouse
  • postgresql
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）