在春季有条件地配置事务管理器时如何使用事务注释？

Question

我在我的 spring 项目中使用了多个数据源。 我在项目启动时通过手动配置启用/禁用它们。 一次他们都可能是活跃的 所以 transactionManager bean 可能处于活动状态。

我在spring配置类中通过@Conditional注解实现。 当我在方法上使用禁用事务注释时，我有 NoSuchBeanDefinitionException。

当我有条件地定义 transactionManager bean 时，如何在方法上使用 transactional annotioan？

archiveTransactionManager bean 不是由 @Conditional 注释创建的，我希望 spring 跳过检查条件事务管理器的 bean 验证。

对于条件 sessionFactory bean，我将 Autowired 注释中的 'required' 参数设置为 false 以防止 spring 抛出 NoSuchBeanDefinitionException 但我应该为 @Transactional 做什么？

配置类

    @Bean("archiveTransactionManager")
    @Conditional(ArchiveCondition.class)
    public HibernateTransactionManager archiveTransactionManager() {
        HibernateTransactionManager transactionManager = new HibernateTransactionManager();
        transactionManager.setSessionFactory(archiveSessionFactory());
        return transactionManager;
    }

事务方法

    @Transactional(value = "archiveTransactionManager", readOnly = true)
    private List<DocumentItem> loadArchivedDocumentItem() {...}

用法

if(GeneralSetting.isArchive)
   documentService.loadArchivedDocumentItem();

当前结果：

org.springframework.beans.factory.NoSuchBeanDefinitionException: No bean named 'archiveTransactionManager' available: No matching PlatformTransactionManager bean found for qualifier 'archiveTransactionManager' - neither qualifier match nor bean name match!

我希望在它们不是由条件创建的某些情况下对条件 transactionManager bean 进行 spring 跳过 bean 验证。

Answer 1

我实现了一个无操作的 SessionFactory 并在 archive_mode 被禁用时在 spring 配置类中实例化它：

SpringConfig.java

    @Bean("archiveSessionFactory")
    public SessionFactory archiveSessionFactory() {
        return ServerConf.ARCHIVE_MODE ? createNormalSessionFactory() : new DummySessionFactory();
    }

    @Bean("archiveTransactionManager")
    public HibernateTransactionManager archiveTransactionManager() {
        HibernateTransactionManager transactionManager = new HibernateTransactionManager();
        transactionManager.setSessionFactory(archiveSessionFactory());
        return transactionManager;
    }

DummySessionFactory.java

public class DummySessionFactory implements SessionFactory {
...
    // These two methods call in spring initializing and we have to implement them
    @Override
    public Metamodel getMetamodel() {
       return new MetamodelImpl(null);
    }

    @Override
    public Map<String, Object> getProperties() {
       return null;
    }

    //Throw suitable exception in other methods
    @Override
    public Session getCurrentSession() throws HibernateException {
        throw new HibernateException("Desired mode is Disabled");
    }
...
}

Answer 2

我会将其视为后备方案，您必须在失败后恢复。在这种情况下，有一个方法调用方法用

注释

@Transactional(value = "archiveTransactionManager", readOnly = true)

如果失败（或异常），调用带有注释的方法

@Transactional(value = "alternativeTransactionManager", readOnly = true)

public void doSomething() {
    try {
        tryFirst();
    } catch (Exception e) {
        tryAlternative();
    }
}

@Transactional(value = "archiveTransactionManager", readOnly = true)
public void tryFirst() {

}

@Transactional(value = "alternativeTransactionManager", readOnly = true)
public void tryAlternative() {

}

请记住，您必须同时声明它们。

Answer 3

您使用了错误的注解来命名 bean。 @Qualifier 用于注入点指定名称。您需要使用@Bean 为bean 命名。所以你的 bean 定义需要看起来像这样：

@Bean("archiveTransactionManager")
@Conditional(ArchiveCondition.class)
public HibernateTransactionManager archiveTransactionManager() {
  HibernateTransactionManager transactionManager = new HibernateTransactionManager();
  transactionManager.setSessionFactory(archiveSessionFactory());
  return transactionManager;
}