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数据库的方法，希望对大家有所帮助