简介
MongoDB 是一个基于分布式文件存储的数据库。由 C++ 语言编写。旨在为 WEB 应用提供可扩展的高性能数据存储解决方案，官方解释。在NoSql数据库中还是比较优秀的一款数据库，且官方网站现在已经逐步开始支持中文版了。 MongoDB 中文版 https://www.mongodb.com/zh
之前MySql介绍了Spring Data Jpa，对于MongoDB，Spring也提供了强大的支持Spring Data MongoDB，这个项目提供了与MongoDB文档数据库的集成。Spring Data MongoDB 官方文档https://spring.io/projects/spring-data-mongodb
注意 在开始之前先开启你的mongod，对于mongodb安装启动有疑问的可以参考这里 Mac系统下安装MongoDB
快速导航
添加mongodb依赖
项目根目录 pom.xml 添加依赖 spring-boot-starter-data-mongodb
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
修改配置文件mongodb相关配置
-
mongo2.4以上版本：
uri: 数据库链接地址 mongodb://username:password@ip:host
-
mongo2.4以下版本：
host: 127.0.0.1port: 27017username: rootpassword: rootdatabase: test
application.yml
spring:
data:
mongodb:
uri: mongodb://127.0.0.1:27017
database: test
定义集合模型
在项目启动时候，以下定义的字段会对应到数据库中的数据结构，注意要添加@Document注解。
@Document: 标注于实体类上表明由mongo来维护该集合，默认集合名为类名还可手动指定集合名@Document(collection=user)@Id: 主键，自带索引由mongo生成对应mongo中的_id字段(ObjectId)@Indexed: 设置该字段索引，提高查询效率，设置参数(unique=true)为唯一索引，默认为false
package com.angelo;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.index.Indexed;
import org.springframework.data.mongodb.core.mapping.Document;
@Document
public class User {
@Id
private String id;
@Indexed
private String name;
private Integer age;
@Indexed(unique = true)
private String idCard;
public User() {
}
// 以下getter、setter方法，代码可以参考本节源码
}
创建继承于mongorepository的数据访问对象
创建UserRepository继承于MongoRepository，当然你也可以使用JpaRepository或MongoRepository，这些接口扩展了mongodb的CRUD操作的通用接口，此外还公开了底层持久化技术的功能，供我们扩展。
例如以下findById，MongoRepository提供的接口为Long类型，显然我这里使用mongodb自动生成的ObjectId，自然是不行了，因此扩展了该方法。
UserRepository.java
package com.angelo;
import org.springframework.data.mongodb.repository.MongoRepository;
import java.util.List;
public interface UserRepository extends MongoRepository<User, Long> {
User findById(String id);
List <User> deleteById(String id);
}
创建控制层实现对数据的增删改查
此处操作Mongodb的增删改查和之前讨论的MySql一样，以下给出代码示例
package com.angelo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
@RestController
public class UserController {
@Autowired
private UserRepository userRepository;
/**
* 查询用户列表
* @return
*/
@GetMapping(value = "/user/list")
public List<User> userList() {
return userRepository.findAll();
}
@GetMapping(value = "/user/info")
public User findUserById(@RequestParam("id") String id) {
return userRepository.findById(id);
}
/**
* 创建用户信息
*/
@PostMapping(value = "/user")
public User createUser(@RequestBody User params) {
User user = new User();
user.setName(params.getName());
user.setAge(params.getAge());
user.setIdCard(params.getIdCard());
return userRepository.save(user);
}
/**
* 更新用户信息
*/
@PutMapping(value = "/user/{id}")
public User updateUser(@PathVariable("id") String id, @RequestParam("name") String name, @RequestParam("age") Integer age,
@RequestParam("idCard") String idCard) {
User user = new User();
user.setId(id);
user.setName(name);
user.setAge(age);
user.setIdCard(idCard);
return userRepository.save(user);
}
/**
* 删除用户信息
* MongoRepository提供的原生方法会报deleteById(java.lang.long) in CurdRepository cannot be applied to (java.lang.string)，此处定义的id为String类型显然不符，在UserRepository接口中进行了重写，
*/
@DeleteMapping(value = "/user/{id}")
public void deleteUserById(@PathVariable("id") String id) {
userRepository.deleteById(id);
}
}