SpringBoot整合MongoDB

芥蓝炒牛肉 發表於 2019-11-25 12:10:00

<h2> MongoDB</h2>
MongoDB是 open-source NoSQL 文档数据库，它使用 JSON-like schema 而不是传统的 table-based 关系数据。 Spring Boot 提供了一些使用 MongoDB 的便利，包括<code>spring-boot-starter-data-mongodb</code>和<code>spring-boot-starter-data-mongodb-reactive</code>“Starters”。
<h3> 连接到 MongoDB 数据库</h3>
要访问 Mongo 数据库，可以 inject auto-configured <code>org.springframework.data.mongodb.MongoDbFactory</code>。默认情况下，实例尝试在<code>mongodb://localhost/test</code>处连接到 MongoDB 服务器。以下 example 显示如何连接到 MongoDB 数据库：
<div class="cnblogs_code">
<pre>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();
 // ...
 }

}</pre>
</div>
 
您可以设置<code>spring.data.mongodb.uri</code> property 来更改 URL 并配置其他设置，例如副本集，如以下 example 所示：
<div class="cnblogs_code">
<pre>spring.data.mongodb.uri=mongodb://user::12345,mongo2.example.com:23456/test</pre>
</div>
 
或者，当您使用 Mongo 2.x 时__，您可以指定<code>host</code>/<code>port</code>。例如，您可以在<code>application.properties</code>中声明以下设置：
<div class="cnblogs_code">
<pre>spring.data.mongodb.host=mongoserver
spring.data.mongodb.port=27017</pre>
</div>
 
如果你已经定义了自己的<code>MongoClient</code>，它将被用于 auto-configure 一个合适的<code>MongoDbFactory</code>。支持<code>com.mongodb.MongoClient</code>和<code>com.mongodb.client.MongoClient</code>。
<blockquote>
如果使用 Mongo 3.0 Java 驱动程序，则不支持<code>spring.data.mongodb.host</code>和<code>spring.data.mongodb.port</code>。在这种情况下，应使用<code>spring.data.mongodb.uri</code>来提供所有 configuration。
</blockquote>
<blockquote>
如果未指定<code>spring.data.mongodb.port</code>，则使用默认值<code>27017</code>。您可以从前面显示的 example 中删除此 line。
</blockquote>
<blockquote>
如果你不使用 Spring Data Mongo，你可以 inject <code>com.mongodb.MongoClient</code> beans 而不是<code>MongoDbFactory</code>。如果要完全控制建立 MongoDB 连接，还可以声明自己的<code>MongoDbFactory</code>或<code>MongoClient</code> bean。
</blockquote>
<blockquote>
如果您使用 reactive 驱动程序，则 SSL 需要 Netty。如果 Netty 可用，则 auto-configuration 会自动配置此工厂，并且尚未自定义要使用的工厂。
</blockquote>
<h3> MongoTemplate</h3>
Spring Data MongoDB提供了MongoTemplate class，其设计与 Spring 的<code>JdbcTemplate</code>非常相似。与<code>JdbcTemplate</code>，Spring Boot auto-configures _ bean 一样，您可以 inject 模板，如下所示：
<div class="cnblogs_code">
<pre>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;
}

// ...

}</pre>
</div>
<h3> Spring Data MongoDB Repositories</h3>
Spring Data 包括 MongoDB 的 repository 支持。与前面讨论的 JPA repositories 一样，基本原则是基于方法名称自动构造查询。
实际上，Spring Data JPA 和 Spring Data MongoDB 共享相同的 common 基础结构。您可以从之前获取 JPA example，假设<code>City</code>现在是 Mongo 数据 class 而不是 JPA <code>@Entity</code>，它的工作方式相同，如下面的示例所示：
<div class="cnblogs_code">
<pre>package com.example.myapp.domain;

import org.springframework.data.domain.*;
import org.springframework.data.repository.*;

public interface CityRepository extends Repository<City, Long> {

Page<City> findAll(Pageable pageable);

City findByNameAndStateAllIgnoringCase(String name, String state);

}</pre>
</div>
<h3>创建用户</h3>
<div class="cnblogs_code">
<pre>#docker exec -it mongo mongo admin
MongoDB shell version v4.2.1
connecting to: mongodb://127.0.0.1:27017/admin?compressors=disabled&gssapiServiceName=mongodb
Implicit session: session { "id" : UUID("7ff60ffe-767d-4982-bd97-6a872157cc05") }
MongoDB server version: 4.2.1
> db.createUser({ user:'admin',pwd:'123456',roles:[ { role:'userAdminAnyDatabase', db: 'admin'}]});
Successfully added user: {
 "user" : "admin",
 "roles" : [
 {
 "role" : "userAdminAnyDatabase",
 "db" : "admin"
 }
 ]
}
> db.auth('admin', '123456')
1
> use test;
switched to db test
>db.createUser({ user: 'test', pwd:'123456', roles: [ {role:"dbOwner",db:"test"}]});
Successfully added user: {
 "user" : "test",
 "roles" : [
 {
 "role" : "dbOwner",
 "db" : "test"
 }
 ]
}
> exit
bye</pre>
</div>
 配置
<div class="cnblogs_code">
<pre>spring:
application:
name: spring-boot-mongodb
data:
mongodb:
 uri: mongodb://test:123456@192.168.180.113:27017/test</pre>
</div>
 
构建项目
我们使用<code>IDEA</code>创建一个新的<code>SpringBoot</code>项目，在<code>pom.xml</code>配置文件内添加我们本章所需要的依赖，如下所示：
<div class="cnblogs_code">
<pre> <dependencies>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-data-mongodb</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>

 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-devtools</artifactId>
 <scope>runtime</scope>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
</dependencies></pre>
</div>
 根据<code>mongodb</code>的依赖我们可以看到<code>Spring</code>家族式的设计，把所有操作数据的依赖都进行归类到<code>spring-boot-starter-data-xxx</code>下，我们比较常用到的如：<code>spring-boot-starter-data-jpa</code>、<code>spring-boot-starter-data-redis</code>等。
<div>
<div>
MongoRepository
<code>spring-boot-starter-data-mongodb</code>确实采用了跟<code>spring-boot-starter-data-jpa</code>同样的方式来完成接口代理类的生成，并且提供了一些常用的单个对象操作的公共方法，<code>MongoRepository</code>接口作用与<code>JPARepository</code>一致，继承了该接口的<code>业务数据接口</code>就可以提供一个被<code>Spring IOC</code>托管的代理实现类，这样我们在注入<code>业务数据接口</code>时就会完成代理实现类的注入。 
废话不多说了，下面我们直接来创建一个名为UserRepository 的数据接口，该接口继承<code>MongoRepository<T,PK></code>，如下所示：

</div>
<div class="cnblogs_code">
<pre>public interface UserRepository extends MongoRepository<UserInfo,Long> {
}</pre>
</div>
<code>MongoRepository <T,PK></code>同样也是采用了两个泛型参数， <code>T</code>：实体类类型。 <code>PK</code>：<code>T</code>实体类内的主键类型，如：Long。
<h4>自定义实体类</h4>
<div class="cnblogs_code">
<pre>public class UserInfo {

@Id
private Long id;

private String username;

private String password;

public Long getId() {
 return id;
}

public void setId(Long 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 UserInfo(Long id, String username, String password) {
 this.id = id;
 this.username = username;
 this.password = password;
}
}</pre>
</div>
测试
<div class="cnblogs_code">
<pre>@RestController
public class UserController {

@Autowired
private UserRepository userRepository;

//http://localhost:8080/save
@GetMapping("save")
public String save(){
 UserInfo userInfo = new UserInfo(System.currentTimeMillis(),"用户"+System.currentTimeMillis(),"123");
 userRepository.save(userInfo);
 return "success";
}

//http://localhost:8080/getUserList
@GetMapping("getUserList")
public List<UserInfo> getUserList(){
 List<UserInfo> userInfoList = userRepository.findAll();
 return userInfoList;
}

//http://localhost:8080/delete?id=1525503798382
@GetMapping("delete")
public String delete(Long id){
 userRepository.deleteById(id);
 return "success";
}

//http://localhost:8080/update?id=1525503912550&username=111&password=222
@GetMapping("update")
public String update(Long id,String username,String password){
 UserInfo userInfo = new UserInfo(id,username,password);
 userRepository.save(userInfo);
 return "success";
}
}</pre>
</div>
<img src="https://img2018.cnblogs.com/i-beta/1829785/201911/1829785-20191125120825603-367097981.png" alt="">
 
 
<img src="https://img2018.cnblogs.com/i-beta/1829785/201911/1829785-20191125120903172-1909766123.png" alt="">
 
 <img id="uploading_image_75601" src="https://common.cnblogs.com/images/loading.gif" alt="">
 
 </div> 
来源：https://www.cnblogs.com/dalianpai/p/11925496.html

頁: [1]

琼殿技术论坛's Archiver

SpringBoot整合MongoDB