MySQL调用mongodb事务回滚_SpringBoot整合MongoDB，在多数据源下实现事务回滚。
項目中用到了MongoDB，準(zhǔn)備用來存儲業(yè)務(wù)數(shù)據(jù)，前提是要實現(xiàn)事務(wù)，保證數(shù)據(jù)一致性，MongoDB從4.0開始支持事務(wù)，提供了面向復(fù)制集的多文檔事務(wù)特性。能滿足在多個操作，文檔，集合，數(shù)據(jù)庫之間的事務(wù)性，事務(wù)的特性。多文檔事務(wù)在4.0版本僅支持復(fù)制集，對分片集群的事務(wù)性支持計劃在4.2版本中實現(xiàn)。由于我也算是一個java小白，沒怎么弄清java事務(wù)機制，于是先建了個測試項目進行測試。在本例中可以看到多數(shù)據(jù)源下事務(wù)的使用，請重點關(guān)注后面記錄的爬坑記。
Mongo Transaction
項目介紹
springboot 2.1.3
MongoDB 4.0.3
本項目主要為了測試MongoDB事務(wù),由于正式項目還用了其它數(shù)據(jù)源，所以加入了 Oracle, MySQL的事務(wù)，包括多數(shù)據(jù)源的配置和使用
使用說明
1.導(dǎo)入MongoDB的依賴
org.springframework.boot
spring-boot-starter-data-mongodb
2.配置MongoDB的連接
spring:
# mongodb 連接
data:
mongodb:
uri: mongodb://192.168.0.68:27017,192.168.0.69:27017,192.168.0.70:27017/glcloud?replicaSet=rs0
database: glcloud
3.編寫entity類
當(dāng)id設(shè)置為 ObjectId 類型和添加 @Id 注解時時，MongoDB數(shù)據(jù)庫會自動生成主鍵，我們在保存對象時就不用設(shè)置id的值
MongoUnit
/**
* 用戶
* @author muyuer 182443947@qq.com
* @version 1.0
* @date 2019-02-25 09:10
*/
@Data
@Document(collection = "test_unit")
public class MongoUnit {
private static final long serialVersionUID = 1L;
/**
* Id
*/
@Id
private ObjectId id;
/**
* unitId
*/
private String unitId;
/**
* unitName
*/
private String unitName;
}
MongoUser
package com.example.demo.entity.mongo;
import lombok.Data;
import org.bson.types.ObjectId;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;
/**
* 用戶
* @author muyuer 182443947@qq.com
* @version 1.0
* @date 2019-02-25 09:10
*/
@Data
@Document(collection = "test_user")
public class MongoUser {
private static final long serialVersionUID = 1L;
/**
* Id
*/
@Id
private ObjectId id;
/**
* userId
*/
private String userId;
/**
* userName
*/
private String userName;
/**
* unitId 關(guān)聯(lián)testUser
*/
private String unitId;
}
4.編寫dao層的方法
只需繼承MongoRepository即可。
package com.example.demo.repository.mongo;
import com.example.demo.entity.mongo.MongoUser;
import org.springframework.data.mongodb.repository.MongoRepository;
/**
* @author muyuer 182443947@qq.com
* @version 1.0
* @date 2019-02-25 09:10
*/
public interface MongoUserRepository extends MongoRepository {
}
package com.example.demo.repository.mongo;
import com.example.demo.entity.mongo.MongoUnit;
import org.springframework.data.mongodb.repository.MongoRepository;
/**
* @author muyuer 182443947@qq.com
* @version 1.0
* @date 2019-02-25 09:10
*/
public interface MongoUnitRepository extends MongoRepository {
}
5.Service層
package com.example.demo.service.mongo.impl;
import com.example.demo.common.SystemException;
import com.example.demo.entity.mongo.MongoUser;
import com.example.demo.repository.mongo.MongoUserRepository;
import com.example.demo.service.mongo.MongoUserService;
import com.example.demo.common.R;
import com.example.demo.common.RUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
/**
* @author muyuer 182443947@qq.com
* @version 1.0
* @date 2019-02-25 09:10
*/
@Service
@Slf4j
public class MongoUserServiceImpl implements MongoUserService {
@Autowired
MongoUserRepository mongoUserRepository;
/**
* 新增
* @param mongoUser
* @return
*/
@Override
public R save(MongoUser mongoUser) {
MongoUser mongoUserSave = mongoUserRepository.save(mongoUser);
log.info("用戶信息保存：testUserSave = "+ mongoUserSave);
return RUtil.success("");
}
@Override
@Transactional(value = "MONGO_TRANSACTION_MANAGER", propagation = Propagation.REQUIRED)
public R bathSave(String unitId, Boolean rollBack) {
for (int i = 0; i <= 10; i++) {
//注釋這段則可以正常添加數(shù)據(jù)，測試回滾則throw異常信息
if (unitId.equals("003") && rollBack) {
throw new SystemException("測試回滾故意拋出的異常");
}
MongoUser user = new MongoUser();
user.setUserId(unitId + "U0" + i);
user.setUserName("用戶" + i);
user.setUnitId(unitId);
save(user);
}
return RUtil.success("");
}
}
package com.example.demo.service.mongo.impl;
import com.example.demo.enums.REnum;
import com.example.demo.common.SystemException;
import com.example.demo.entity.mongo.MongoUnit;
import com.example.demo.repository.mongo.MongoUnitRepository;
import com.example.demo.service.mongo.MongoUnitService;
import com.example.demo.service.mongo.MongoUserService;
import com.example.demo.common.R;
import com.example.demo.common.RUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
/**
* @author muyuer 182443947@qq.com
* @version 1.0
* @date 2019-02-25 09:10
*/
@Service
@Slf4j
public class MongoUnitServiceImpl implements MongoUnitService {
@Autowired
MongoUnitRepository mongoUnitRepository;
@Autowired
MongoUserService mongoUserService;
/**
* 新增
*
* @param unit
* @return
*/
@Override
public R save(MongoUnit unit) {
MongoUnit mongoUnitSave = mongoUnitRepository.save(unit);
log.info("單位信息保存：testUnitSave = " + mongoUnitSave);
return RUtil.success("");
}
@Override
@Transactional(value = "MONGO_TRANSACTION_MANAGER")
public R bathSave(Boolean rollBack) {
try {
for (int i = 0; i < 4; i++) {
MongoUnit unit = new MongoUnit();
unit.setUnitId("00" + i);
unit.setUnitName("單位" + i);
mongoUserService.bathSave(unit.getUnitId(),rollBack);
save(unit);
}
return RUtil.success("");
} catch (SystemException e) {
log.error("保存數(shù)據(jù)失敗：msg: {}", e.getMessage());
throw new SystemException(REnum.ERROR.getCode(), "保存數(shù)據(jù)失敗 Error:" + e.getMessage());
}
}
}
6.Controller
package com.example.demo.controller;
import com.example.demo.enums.DbTypeEnum;
import com.example.demo.service.mongo.MongoUserService;
import com.example.demo.common.R;
import com.example.demo.service.primary.PrimaryUserService;
import com.example.demo.service.slave.SlaveUserService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
/**
* @author muyuer 182443947@qq.com
* @date 2019-02-25 10:59
*/
@RestController
@Slf4j
@RequestMapping(path="test/user")
public class TestUserController {
@Autowired
MongoUserService mongoUserService;
@Autowired
PrimaryUserService primaryUserService;
@Autowired
SlaveUserService slaveUserService;
/**
* 新增
* @param dbType
* @param unitId
* @param rollBack
* @return
*/
@PostMapping("/bathSave/{dbType}/{unitId}/{rollBack}")
public R bathSave(@PathVariable DbTypeEnum dbType, @PathVariable String unitId, @PathVariable Boolean rollBack){
switch (dbType) {
case MONGO:
return mongoUserService.bathSave(unitId, rollBack);
case PRIMARY:
return primaryUserService.bathSave(unitId, rollBack);
default:
return slaveUserService.bathSave(unitId, rollBack);
}
}
}
package com.example.demo.controller;
import com.example.demo.enums.DbTypeEnum;
import com.example.demo.service.mongo.MongoUnitService;
import com.example.demo.common.R;
import com.example.demo.service.primary.PrimaryUnitService;
import com.example.demo.service.slave.SlaveUnitService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
/**
* @author muyuer 182443947@qq.com
* @date 2019-02-25 10:59
*/
@RestController
@Slf4j
@RequestMapping(path="test/unit")
public class TestUnitController {
@Autowired
MongoUnitService mongoUnitService;
@Autowired
PrimaryUnitService primaryUnitService;
@Autowired
SlaveUnitService slaveUnitService;
/**
* 新增
* @param dbType 數(shù)據(jù)庫
* @param rollBack 是否回滾
* @return
*/
@PostMapping("/bathSave/{dbType}/{rollBack}")
public R bathSave(@PathVariable DbTypeEnum dbType, @PathVariable Boolean rollBack) {
switch (dbType) {
case MONGO:
return mongoUnitService.bathSave(rollBack);
case PRIMARY:
return primaryUnitService.bathSave(rollBack);
default:
return slaveUnitService.bathSave(rollBack);
}
}
}
測試
PostMan post 地址
在實際應(yīng)用中爬過的坑
1.MongoDB的版本必須是4.0
2.MongoDB事務(wù)功能必須是在多副本集的情況下才能使用，否則報錯"Sessions are not supported by the MongoDB cluster to which this client is connected"，4.2版本會支持分片事務(wù)。
3.事務(wù)控制只能用在已存在的集合中，也就是集合需要手工添加不會由jpa創(chuàng)建會報錯"Cannot create namespace glcloud.test_user in multi-document transaction."
4.多數(shù)據(jù)源時需要指定事務(wù) @Transactional(value = "transactionManager") 如果只有1個數(shù)據(jù)源不需要指定value
5.事務(wù)注解到類上時，該類的所有 public 方法將都具有該類型的事務(wù)屬性，但一般都是注解到方法上便于實現(xiàn)更精確的事務(wù)控制
6.事務(wù)傳遞性，事務(wù)子方法上不必添加事務(wù)注解，如果子方法也提供api調(diào)用可用注解propagation = Propagation.REQUIRED也就是繼承調(diào)用它的事務(wù)，如果沒有事務(wù)則新起一個事務(wù)
7.啟動類上的@EnableTransactionManagement注解，并不是像網(wǎng)上所說必需添加的注解，因為spring boot 默認(rèn)開始了這個注解的。
8.有人說：注解必須是@Transactional(rollbackFor = { Exception.class }) 測試并不需要rollbackFor = { Exception.class },因為本例中自定義異常類繼承自RuntimeException spring boot事物默認(rèn)在遇到RuntimeException不論rollbackFor的異常是啥，都會進行事務(wù)的回滾,加上rollbackFor=Exception.class,可以讓事物在遇到非運行時異常時也回滾
具體rollbackFor用法可參考:
參考文檔
總結(jié)
以上是生活随笔為你收集整理的MySQL调用mongodb事务回滚_SpringBoot整合MongoDB，在多数据源下实现事务回滚。的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： word2013插入excel对象报错_
- 下一篇： mysql左键关联_MySQL的：左键删