Spring Boot中使用MongoDB数据库的方法

站长资源 2024/11/16 佚名

2 0 1

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数据库的方法，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对网站的支持！

spring,boot,mongodb数据库

广告合作：本站广告合作请联系QQ：858582 申请时备注：广告合作（否则不回）
免责声明：本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除！

评论“Spring Boot中使用MongoDB数据库的方法”

暂无评论...

www.wwsws.com 伏龙阁资源网

39,976影音资源

44,792技术资源

21,817软件资源

651,128站长资源

Spring Boot中使用MongoDB数据库的方法

window下安装配置mongodb的教程图解

MongoDB用Mongoose得到的对象不能增加属性完美解决方法(两种)

评论“Spring Boot中使用MongoDB数据库的方法”

RTX 5090要首发性能要翻倍！三星展示GDDR7显存

更新日志

友情链接

Spring Boot中使用MongoDB数据库的方法

window下安装配置mongodb的教程图解

MongoDB用Mongoose得到的对象不能增加属性完美解决方法(两种)

评论“Spring Boot中使用MongoDB数据库的方法”

RTX 5090要首发 性能要翻倍！三星展示GDDR7显存

更新日志

友情链接

RTX 5090要首发性能要翻倍！三星展示GDDR7显存