海兴网站建设公司欧美风格网站模版

海兴网站建设公司,欧美风格网站模版,模具公司网站中品质见证怎么做,美术对网站开发有用吗解决的痛点在数据库事务操作中#xff0c;经常会出现“事务未按预期生效”的情况。 其中最常见的两类场景是#xff1a;同类内部方法调用导致事务代理未生效对事务边界的控制过度依赖 Transactional 注解下面举一个在开发中可能会遇到的一个事务失效的场景#xff1a;//保存…解决的痛点在数据库事务操作中经常会出现“事务未按预期生效”的情况。 其中最常见的两类场景是同类内部方法调用导致事务代理未生效对事务边界的控制过度依赖 Transactional 注解下面举一个在开发中可能会遇到的一个事务失效的场景//保存父方法 public void saveParentMethod() { //插入parent StockInfo stockInfo new StockInfo(); stockInfo.setProductId(parent); this.stockInfoMapper.insertSelective(stockInfo); //插入child this.saveChildStockInfo(); } //保存子方法 Transactional(rollbackFor Exception.class) public void saveChildStockInfo() { StockInfo stockInfo new StockInfo(); stockInfo.setProductId(child); this.stockInfoMapper.insertSelective(stockInfo); //制造异常 int i 1 / 0; }我们想当然的认为parent应该入库而child不应该然而实际情况是child也入库了。原因并不是事务失效而是Transactional根本没有生效。Spring 的事务是基于代理实现的同类内部方法调用不会经过代理因此事务注解不会被触发。OKTransactionHelper工具类就是解决类似的情况并且可以在一个类中使用private定义的私有方法同样能进行事务。TransactionHelper 的核心作用是 让事务控制从「依赖 Spring AOP 代理」转变为「显式、可控的代码级事务边界」。更适合以下场景复杂流程编排同类内部方法调用希望显式声明事务边界的位置使用方式Component RequiredArgsConstructor public class YourClass { // 构造注入TransactionHelper private final TransactionHelper transactionHelper; public ResultVoid executeBiz(TaskContext context) { // ... // 事务 transactionHelper.runInTransaction(() - { // 保存订单 saveOrder(order); // 更新库存数量 updateStore(128); }); return Result.ok(); } // 保存订单 private void saveOrder(Order order) { orderMapper.save(order) } // 更新库存数量 private void updateStore(int count) { storeMapper.updateCount(count); } }这里TransactionHelper充分利用了JDK8之后的函数式编程特点。把要进行事务的方法当做参数传入。最终利用spring的PlatformTransactionManager统一控制事务行为。注意runInTransaction 中的代码块不应再嵌套 Transactional 注解 否则容易造成事务传播语义混乱。TransactionHelper庐山真面目/** * 事务帮助类 * * author 老马 */ Slf4j Component RequiredArgsConstructor public class TransactionHelper { private final PlatformTransactionManager transactionManager; /** * -1 表示不覆盖 Spring 默认配置 */ public static final int DEFAULT_TIMEOUT TransactionDefinition.TIMEOUT_DEFAULT; /** * 原事务REQUIRED */ public T T runInTransaction(SupplierT supplier) { return execute(TransactionDefinition.PROPAGATION_REQUIRED, DEFAULT_TIMEOUT, supplier); } public void runInTransaction(Runnable runnable) { runInTransaction(DEFAULT_TIMEOUT, runnable); } public T T runInTransaction(int timeout, SupplierT supplier) { return execute(TransactionDefinition.PROPAGATION_REQUIRED, timeout, supplier); } public void runInTransaction(int timeout, Runnable runnable) { execute(TransactionDefinition.PROPAGATION_REQUIRED, timeout, () - { runnable.run(); return null; }); } /** * 新事务REQUIRES_NEW */ public T T runInNewTransaction(SupplierT supplier) { return execute(TransactionDefinition.PROPAGATION_REQUIRES_NEW, DEFAULT_TIMEOUT, supplier); } public void runInNewTransaction(Runnable runnable) { runInNewTransaction(DEFAULT_TIMEOUT, runnable); } public T T runInNewTransaction(int timeout, SupplierT supplier) { return execute(TransactionDefinition.PROPAGATION_REQUIRES_NEW, timeout, supplier); } public void runInNewTransaction(int timeout, Runnable runnable) { execute(TransactionDefinition.PROPAGATION_REQUIRES_NEW, timeout, () - { runnable.run(); return null; }); } /** * 通用事务执行逻辑 */ private T T execute(int propagation, int timeout, SupplierT supplier) { TransactionTemplate template buildTemplate(propagation, timeout); return template.execute(status - { try { return supplier.get(); } catch (RuntimeException e) { status.setRollbackOnly(); log.error(事务回滚propagation{}, timeout{}, propagation, timeout, e); throw e; } catch (Exception e) { status.setRollbackOnly(); log.error(事务回滚propagation{}, timeout{}, propagation, timeout, e); throw new RuntimeException(e); } catch (Throwable t) { status.setRollbackOnly(); log.error(事务回滚propagation{}, timeout{}, propagation, timeout, t); throw t; } }); } /** * 构建事务模板 */ private TransactionTemplate buildTemplate(int propagation, int timeout) { TransactionTemplate template new TransactionTemplate(transactionManager); template.setPropagationBehavior(propagation); // timeout -1 表示使用 Spring 默认配置 if (timeout ! DEFAULT_TIMEOUT) { template.setTimeout(timeout); } return template; } }补充说明为确保 Error / 非 RuntimeException 场景下事务同样回滚 execute 方法中统一捕获 Throwable 并显式标记 rollbackOnly。TransactionHelper不会吞异常 异常会继续向上抛出由上层统一处理 以避免出现“事务回滚但业务误以为成功”的问题。使用中特别注意⚠ 特别注意强约束TransactionHelper 基于 Spring 本地事务PlatformTransactionManager因此仅对【单一数据源】生效。如下代码是有效的DS(TableNameConstant.DATABASE_NAME_RTPAY) public void testTransaction() { transactionHelper.runInTransaction(() - { bizServiceHelpler.insertMerchant(); bizServiceHelpler.insertCity(); }); }在 DS 多数据源场景下同一个事务中禁止切换数据源不同数据源之间无法实现原子回滚如果业务需要跨数据源事务控制请使用 DS 框架提供的 DSTransactional或明确拆分为多个独立事务处理。