内容简介：MongoDB是一个高性能，开源，无模式的，基于分布式文件存储的文档型数据库，由C++语言编写，其名称来源取自“humongous”，是一种开源的文档数据库──NoSql数据库的一种。这篇文章主要介绍了Spring Boot中使用MongoDB数据库的方法,需要的朋友可以参考下
MongoDB数据库简介
简介
MongoDB是一个高性能，开源，无模式的，基于分布式文件存储的文档型数据库，由C++语言编写，其名称来源取自“humongous”，是一种开源的文档数据库──NoSql数据库的一种。NoSql，全称是 Not Only Sql,指的是非关系型的数据库。
特点
MongoDB数据库的特点是高性能、易部署、易使用，存储数据非常方便。主要功能特性有：
* 面向集合存储，易存储对象类型的数据。
* 模式自由。
* 支持动态查询。
* 支持完全索引，包含内部对象。
* 支持查询。
* 支持复制和故障恢复。
* 使用高效的二进制数据存储，包括大型对象（如视频等）。
* 自动处理碎片，以支持云计算层次的扩展性
* 支持RUBY，PYTHON，JAVA，C++，PHP等多种语言。
* 文件存储格式为BSON（一种JSON的扩展）
* 可通过网络访问
MongoDB是一个开源的NoSQL文档数据库，它使用一个JSON格式的模式（schema）替换了传统的基于表的关系数据。Spring Boot为使用 MongoDB 提供了很多便利，包括spring-boot-starter-data-mongodb 'Starter POM'。
引入spring-boot-starter-data-mongodb包，在pom.xml配置文件中增加如下内容（基于之前章节“Spring Boot 构建框架”中的pom.xml文件）：
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-mongodb</artifactId> </dependency>
注入一个自动配置的org.springframework.data.mongodb.MongoDbFactory来访问Mongo数据库。默认情况下，该实例将尝试使用URL： mongodb://localhost/test连接一个MongoDB服务器。
import org.springframework.data.mongodb.MongoDbFactory;
import com.mongodb.DB;
@Component
public class MyBean {
private final MongoDbFactory mongo;
@Autowired
public MyBean(MongoDbFactory mongo) {
this.mongo = mongo;
}
// ...
public void example() {
DB db = mongo.getDb();
// ...
}
}
可以通过设置spring.data.mongodb.uri来改变该url，或指定一个host/port。在application.properties中设置如下的属性：
spring.data.mongodb.host=mongoserver spring.data.mongodb.port=27017
注意：如果没有指定spring.data.mongodb.port，那将使用默认的端口27017。可以简单的从上面的示例中删除这一行。如果不使用Spring Data Mongo，可以注入com.mongodb.Mongo beans而不是使用MongoDbFactory。如果想全面控制MongoDB连接的建立，也可以声明自己的MongoDbFactory或Mongo，@Beans。
MongoDBTemplate
Spring Data Mongo提供了一个MongoTemplate类，它的设计和Spring的JdbcTemplate很相似。正如JdbcTemplate一样，Spring Boot会自动配置一个bean，你只需简单的注入它即可：
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.stereotype.Component;
@Component
public class MyBean {
private final MongoTemplate mongoTemplate;
@Autowired
public MyBean(MongoTemplate mongoTemplate) {
this.mongoTemplate = mongoTemplate;
}
// ...
}
应用集成MongoDB案例
在application.properties配置文件中添加内容如下：
spring.data.mongodb.uri=mongodb://name:pass@localhost:27017/test
多个IP集群采用以下配置：
spring.data.mongodb.uri=mongodb://user:pass@ip1:port1,ip2:port2/database
创建数据实体类，具体代码如下：
public class UserInfo implements Serializable {
private Long id;
private String userName;
private String passWord;
//getter、setter省略
}
创建实体类对应dao层，实现增删改查操作，具体代码如下：
@Component
public class UserInfoDaoImpl implements UserInfoDao {// UserInfoDao 自定义接口
@Autowired
private MongoTemplate mongoTemplate;
/**
* 创建对象
* @param user
*/
@Override
public void saveUser(UserInfo user) {
mongoTemplate.save(user);
}
/**
* 根据用户名查询对象
* @param userName
* @return
*/
@Override
public UserInfo findUserByUserName(String userName) {
Query query=new Query(Criteria.where("userName").is(userName));
UserInfo user = mongoTemplate.findOne(query , UserInfo.class);
return user;
}
/**
* 更新对象
* @param user
*/
@Override
public void updateUser(UserInfo user) {
Query query=new Query(Criteria.where("id").is(user.getId()));
Update update= new Update().set("userName", user.getUserName()).set("passWord", user.getPassWord());
//更新查询返回结果集的第一条
mongoTemplate.updateFirst(query,update,UserInfo.class);
//更新查询返回结果集的所有
// mongoTemplate.updateMulti(query,update,UserInfo.class);
}
/**
* 删除对象
* @param id
*/
@Override
public void deleteUserById(Long id) {
Query query=new Query(Criteria.where("id").is(id));
mongoTemplate.remove(query,UserInfo.class);
}
}
简单测试方法，具体代码如下：
@RunWith(SpringRunner.class)
@SpringBootTest
public class UserDaoTest {
@Autowired
private UserDao userDao;
@Test
public void testSaveUser() throws Exception {
UserInfo user=new UserInfo();
user.setId(2);
user.setUserName("路人甲");
user.setPassWord("123456");
userDao.saveUser(user);
}
@Test
public void findUserByUserName(){
UserInfo user= userDao.findUserByUserName("路人甲");
System.out.println("user is "+user);
}
@Test
public void updateUser(){
UserInfo user=new UserInfo();
user.setId(3);
user.setUserName("路人乙");
user.setPassWord("123456");
userDao.updateUser(user);
}
@Test
public void deleteUserById(){
userDao.deleteUserById(3);
}
}
登录MongoDB验证数据
使用mongoVUE工具来连接后直接图形化查看或登录服务器用命令来查看登录mongodb服务端，执行命令bin/mongo -host localhost -port 27017，切换至test库执行use test命令，查询userInfo集合数据，执行db.userInfo.find()查询数据。
以上所述就是小编给大家介绍的《Spring Boot中使用MongoDB数据库的方法》，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持！
猜你喜欢:
- Python 连接数据库的多种方法
- Java操作MongoDB数据库方法详解
- Oracle数据库查询重复数据及删除重复数据方法
- Go 语言 Web 编程：数据库应用方法
- 使用Node操作MongoDB数据库的方法
- 一个封装的Goland数据库操作方法集
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
500 Lines or Less
Amy Brown、Michael DiBernardo / 2016-6-28 / USD 35.00
This book provides you with the chance to study how 26 experienced programmers think when they are building something new. The programs you will read about in this book were all written from scratch t......一起来看看 《500 Lines or Less》 这本书的介绍吧!
