- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
CFSDN坚持开源创造价值,我们致力于搭建一个资源共享平台,让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章解决@Transaction注解导致动态切换更改数据库失效问题由作者收集整理,如果你对这篇文章有兴趣,记得点赞哟.
当给Controller方法加上@Transaction注解后,动态切换数据源就失效了,原因是每次@Before注解的方法运行之前,protected abstract Object determineCurrentLookupKey();就已经运行了,而这个方法是切换数据源的关键.
其实也算不上解决,就是不要在Controller方法上加事务注解,非要加事务,中间的Service层就不要省了.
为非public方法,这个时候@Transactional会实现.
失败的原理是:@Transactional是基于动态代理来实现的,非public的方法,他@Transactional的动态代理对象信息为空,所以不能回滚.
调用了@Transactional方法时,当你调用是,他也不会回滚 。
测试代码如下 。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
@Service
public
class
UserServiceImpl
extends
BaseServiceImpl<UserEntity>
implements
UserService {
@Autowired
private
UserMapper userMapper;
@Override
@Transactional
public
void
insertOne() {
UserEntity userEntity =
new
UserEntity();
userEntity.setUsername(
"Michael_C_2019"
);
//插入到数据库
userMapper.insertSelective(userEntity);
//手动抛出异常
throw
new
IndexOutOfBoundsException();
}
@Override
public
void
saveOne() {
insertOne();
}
}
|
失败的原理:@Transactional是基于动态代理对象来实现的,而在类内部的方法的调用是通过this关键字来实现的,没有经过动态代理对象,所以事务回滚失效.
没有在catch代码块里面重新抛出异常,事务也不会回滚.
代码如下:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
@Override
@Transactional
public
void
insertOne() {
try
{
UserEntity userEntity =
new
UserEntity();
userEntity.setUsername(
"Michael_C_2019"
);
//插入到数据库
userMapper.insertSelective(userEntity);
//手动抛出异常
throw
new
IndexOutOfBoundsException();
}
catch
(IndexOutOfBoundsException e) {
e.printStackTrace();
}
}
|
所以在阿里巴巴的Java开发者手册里面有明确规定,在 @Transactional的方法里面捕获了异常,必须要手动回滚, 。
代码如下:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
@Override
@Transactional
public
void
insertOne() {
try
{
UserEntity userEntity =
new
UserEntity();
userEntity.setUsername(
"Michael_C_2019"
);
//插入到数据库
userMapper.insertSelective(userEntity);
//手动抛出异常
throw
new
IndexOutOfBoundsException();
}
catch
(IndexOutOfBoundsException e) {
e.printStackTrace();
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
}
}
|
失败原理:这时候我们来看看spring的源码:
TransactionAspectSupport类里面的invokeWithinTransaction方法 。
1
|
TransactionAspectSupport
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
@Nullable
protected
Object invokeWithinTransaction(Method method,
@Nullable
Class<?> targetClass, TransactionAspectSupport.InvocationCallback invocation)
throws
Throwable {
TransactionAttributeSource tas =
this
.getTransactionAttributeSource();
TransactionAttribute txAttr = tas !=
null
? tas.getTransactionAttribute(method, targetClass) :
null
;
PlatformTransactionManager tm =
this
.determineTransactionManager(txAttr);
String joinpointIdentification =
this
.methodIdentification(method, targetClass, txAttr);
Object result;
if
(txAttr !=
null
&& tm
instanceof
CallbackPreferringPlatformTransactionManager) {
TransactionAspectSupport.ThrowableHolder throwableHolder =
new
TransactionAspectSupport.ThrowableHolder(
null
);
try
{
result = ((CallbackPreferringPlatformTransactionManager)tm).execute(txAttr, (status) -> {
TransactionAspectSupport.TransactionInfo txInfo =
this
.prepareTransactionInfo(tm, txAttr, joinpointIdentification, status);
Object var9;
try
{
Object var8 = invocation.proceedWithInvocation();
return
var8;
}
catch
(Throwable var13) {
if
(txAttr.rollbackOn(var13)) {
if
(var13
instanceof
RuntimeException) {
throw
(RuntimeException)var13;
}
throw
new
TransactionAspectSupport.ThrowableHolderException(var13);
}
throwableHolder.throwable = var13;
var9 =
null
;
}
finally
{
this
.cleanupTransactionInfo(txInfo);
}
return
var9;
});
if
(throwableHolder.throwable !=
null
) {
throw
throwableHolder.throwable;
}
else
{
return
result;
}
}
catch
(TransactionAspectSupport.ThrowableHolderException var19) {
throw
var19.getCause();
}
catch
(TransactionSystemException var20) {
if
(throwableHolder.throwable !=
null
) {
this
.logger.error(
"Application exception overridden by commit exception"
, throwableHolder.throwable);
var20.initApplicationException(throwableHolder.throwable);
}
throw
var20;
}
catch
(Throwable var21) {
if
(throwableHolder.throwable !=
null
) {
this
.logger.error(
"Application exception overridden by commit exception"
, throwableHolder.throwable);
}
throw
var21;
}
}
else
{
TransactionAspectSupport.TransactionInfo txInfo =
this
.createTransactionIfNecessary(tm, txAttr, joinpointIdentification);
result =
null
;
try
{
result = invocation.proceedWithInvocation();
}
catch
(Throwable var17) {
//异常时,在catch逻辑中回滚事务
this
.completeTransactionAfterThrowing(txInfo, var17);
throw
var17;
}
finally
{
this
.cleanupTransactionInfo(txInfo);
}
this
.commitTransactionAfterReturning(txInfo);
return
result;
}
}
|
他是通过捕获异常然后在catch里面进行事务的回滚的,所以如果你在自己的方法里面catch了异常,catch里面没有抛出新的异常,那么事务将不会回滚.
以上为个人经验,希望能给大家一个参考,也希望大家多多支持我.
原文链接:https://blog.csdn.net/m0_37659871/article/details/81672373 。
最后此篇关于解决@Transaction注解导致动态切换更改数据库失效问题的文章就讲到这里了,如果你想了解更多关于解决@Transaction注解导致动态切换更改数据库失效问题的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
我不明白注释之间的实际区别是什么javax.transaction.Transactional和org.springframework.transaction.annotation.Transacti
我不明白注释 javax.transaction.Transactional 和 org.springframework.transaction.annotation.Transactional 之间
我正在尝试删除一个节点。 我知道要先删除节点,我必须删除关系。 MATCH (n:`Dummy`) WHERE n.uuid='1aa41234-aaaa-xxxx-ffff-xxxx11xx0x62
假设我有一个共享钱包,可以为我和我的兄弟收集以太币。我们彼此分享这个钱包的 50%。 如果有一笔 ETH 交易进入这个钱包,是否有一种自动方式可以将收到的以太币自动发送到我的个人钱包和我兄弟的钱包,而
我已经阅读并重新阅读了文档 re: mnesia:activity/3、mnesia:activity/4 和 mnesia/transaction/2,但它们对我来说仍然像是一种晦涩难懂的外语。 在
精简版: 在 Firebase 事务(在 Java 中)中,如果我从 MutableData.getValue() 中得到意外的或不一致的(陈旧的)值,我应该如何进行错误检查并确保事务在必要时重复运行
使用 Spring 时@Transcational在服务层,我需要放置 在 xml 文件上。 我想知道 可以javax.jdo.annotations.Transactional像spring一样用在
这是我的情况。 我正在构建一个 RESTful Web 服务,从客户端接收数据,然后根据该数据创建一个事件,然后我想将这个新事件推送到 celery 以异步处理它。 我使用 Pyramid 构建 RE
这是我的情况。 我正在构建一个 RESTful web 服务,它从客户端接收数据,然后从该数据创建一个事件,然后我想将这个新事件推送到 celery 以异步处理它。 我使用 pyramid 构建 RE
当我启动 jetty 时,以下行出现在日志中: :INFO:oejpw.PlusConfiguration:No Transaction manager found - if your webapp
@Transactional(rollbackFor = someException.class) public void methodA() throws someException { t
我花了几个小时试图解决这个问题。谷歌和 Stackoverflow 也没有多大帮助。所以这里非常欢迎任何建议。 我正在尝试在更新两个相关表时对事务应用回滚逻辑: 一般的代码是: // ... $em
我在 Service 类中看到了一个方法,它被标记为 @Transactional,但它还在同一个类中调用了一些其他方法,这些方法没有被标记为 @Transactional。 这是否意味着对单独方法的
我目前正在使用 Microsoft Enterprise Library 5.0,我想知道下面的代码是否是处理事务的可接受方式。 我已经稍微简化了场景,但本质是我想在同一个事务中在不同的数据库中执行多
我已将以下服务方法注释为事务性: /* (non-Javadoc) * @see a.b.service.CustomerService#activateCustomer(a.b.m
以下是我的代码的一个代表性片段,其中在 transaction.Rollback() 处抛出了一个意外的异常,至少对我而言是这样。声明。 异常(exception)是类型 NHibernate.Tra
我试过将 COMMIT TRAN 放在 if else 循环中,但我仍然收到此错误。 我必须为一个类(class)招收一名学生。如果注册后的座位数为负数,我必须将其反转并打印一条消息说不能注册。我已经
我已经实现了一个具有事务的路由。当用户通过单击“后退”按钮移出这条路线时,我希望用户能够确认退出并丢失通过回滚事务所做的任何更改。 问题是,如果用户返回路由,Ember Data 会引发错误并指出:
当我从另一个事务方法调用一个事务方法时会发生什么,现在我的第二个事务方法已完成,并且它返回到第一个事务方法,不幸的是它失败了,所以它会回滚所有内容,意味着它会回滚第二个事务方法吗?交易方式改变..??
这个问题在这里已经有了答案: @Transactional method called from another method doesn't obtain a transaction (4 个回答)
我是一名优秀的程序员,十分优秀!