mongoDB 4.0 事务

官网：mongoDB中，对单文档的操做是原子性的。例如 insertOne， updateOne等操做。所以建议使用嵌入式文档来实现事务需求，而不是规范化的跨文档设计。可是业务上例如三方数据依赖的需求每每使用嵌入式文档不是理想中的那么方便。因此4.0开始提供了对 副本集多文档事务的支持，注意是 副本集，也就是说 单server是不生效的。

接下来的测试须要集群环境，赖得搭建，因此使用mongoDB Cloud提供的Altas的免费集群。

建立测试数据

• user

• info

建立springboot项目

添加依赖

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.1.5.RELEASE</version>
</parent>

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>fastjson</artifactId>
        <version>1.2.58</version>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-mongodb</artifactId>
    </dependency>
</dependencies>

• 链接mongoDB

这里涉及到了 Write Concern，推荐阅读 MongoDB writeConcern原理解析
w=majority：数据写入到副本集大多数成员后向客户端发送确认，适用于对数据安全性要求比较高的场景，该选项会下降写入性能
w=1：默认的writeConcern，数据写入到Primary就向客户端发送确认
Read Concern推荐阅读 MongoDB readConcern 原理解析

spring.data.mongodb.uri=mongodb+srv://vulgar:761341@cluster0-t16it.mongodb.net/vulgar_test?retryWrites=true&w=majority

配置mongoDB事务管理

@Configuration
public class MongoTransactionConfiguration {

    @Bean
    MongoTransactionManager mongoTransactionManager(MongoDbFactory factory) {
        return new MongoTransactionManager(factory);
    }
}

建立对应实体类

• User.class

@Data
@Document(collection = "user")
public class User implements Serializable {
    private static final long serialVersionUID = -7257487638617643262L;

    private String username;

    private String password;

    private String sex;

    private Integer age;

    private String email;
}

• Info.class

@Data
@Document(collection = "info")
public class Info implements Serializable {
    private static final long serialVersionUID = 4494527542566322152L;

    private String username;

    private String description;
}

建立测试SERVICE

@Slf4j
@Service("mongoService")
public class MongoService {

    @Autowired
    private MongoTemplate mongoTemplate;

    @Transactional(rollbackFor = ArithmeticException.class)
    public void updateWithTransaction() {
        Query query = new Query(Criteria.where("username").is("vulgar-cd"));
        Update update = new Update();
        update.set("age", 10);
        mongoTemplate.updateFirst(query, update, User.class);
        User user = mongoTemplate.findOne(query, User.class);
        log.info("user is {}", JSON.toJSON(user));
        update = new Update();
        update.set("description", "hahahaha");
        mongoTemplate.updateFirst(query, update, Info.class);
        Info info = mongoTemplate.findOne(query, Info.class);
        log.info("info is {}", JSON.toJSON(info));
        //测试事务回滚
        int i = 1/0;
    }
}

建立测试CONTROLLER

@Slf4j
@RestController
public class MongoController {

    @Resource(name = "mongoService")
    private MongoService mongoService;

    @GetMapping("/transaction")
    public void updateWithTransaction() {
        mongoService.updateWithTransaction();
    }
}

启动引用程序

能够看到程序连上了集群，而后在终端执行curl http://localhost:8080/transaction能够看到以下日志

最后查看mongoDB中的数据，能够看到数据没有被更改。

上面建立的MongoService中的updateWithTransaction上添加了spring提供的@Transactional注解，因此mongoDB的事务能够和mysql的事务统一管理。