Springboot Mongo db方法不回滚事务

Question

您好，我在代码库中使用 2 个 mongo 模板 我的代码使用 mongo 模板和 Spring 存储库 class.save() 将数据保存在 mongo db 中。在具有 @Transactional 的方法中，即使代码执行中发生一些错误，也不会回滚数据库更改。 下面是我的 mongoconfig 配置的片段

@Configuration
@EnableMongoAuditing
@EnableMongoRepositories
public class MongoConfig extends AbstractMongoClientConfiguration {

    @Value("${common.db.name}")
    private String dbName;

    @Value("${SPRING_DATA_MONGODB_URI}")
    private String dbUrl;

    public String getDbName() {
        return dbName;
    }

    public void setDbName(String dbName) {
        this.dbName = dbName;
    }
    @Override
    protected String getDatabaseName() {
        return dbName;
    }

    /**
     *  Below bean is created as we want to make our code transactional.
     * @param dbFactory
     * @return
     */
    @Bean(name="primaryTransactionManager")
    MongoTransactionManager transactionManager(MongoDatabaseFactory dbFactory) {
        MongoTransactionManager transactionManager = new MongoTransactionManager(dbFactory);
        transactionManager.setRollbackOnCommitFailure(true);
        return transactionManager;
    }

    @Override
    public MongoClient mongoClient() {
        ConnectionString connectionString = new ConnectionString(dbUrl);
        MongoClientSettings mongoClientSettings = MongoClientSettings.builder().applyConnectionString(connectionString).build();
        return MongoClients.create(mongoClientSettings);
    }

    @Bean(name="primaryMongoTemplate")
    public MongoTemplate mongoTemplate() {
        return new MongoTemplate(mongoClient(), getDbName());
    }
}

@Configuration
@EnableMongoRepositories
public class SecondaryMongoConfig {

    @Value("${common.secondary.db.name}")
    private String dbName;

    @Value("${COMMON_SECONDARY_SPRING_DATA_MONGODB_URI}")
    private String mongoDBURI;

    public String getMongoDBURI() {
        return mongoDBURI;
    }

    public void setMongoDBURI(String mongoDBURI) {
        this.mongoDBURI = mongoDBURI;
    }

    public String getDbName() {
        return dbName;
    }

    public void setDbName(String dbName) {
        this.dbName = dbName;
    }

    /**
     * Below bean is created as we want to make our code transactional.
     * @param dbFactory
     * @return
     */
    @Bean(name="secondaryTransactionManager")
    MongoTransactionManager transactionManager(MongoDatabaseFactory dbFactory) {
        MongoTransactionManager transactionManager = new MongoTransactionManager(dbFactory);
        transactionManager.setRollbackOnCommitFailure(true);
        return new MongoTransactionManager(dbFactory);
    }
    
    @Bean(name="secondaryMongoClient")
    public MongoClient secondaryMongoClient() {
        ConnectionString connectionString = new ConnectionString(getMongoDBURI());
        MongoClientSettings mongoClientSettings = MongoClientSettings.builder()
                .applyConnectionString(connectionString)
                .build();

        return MongoClients.create(mongoClientSettings);
    }

    @Bean(name="secondaryMongoTemplate")
    public MongoTemplate secondaryMongoTemplate() {
        return new MongoTemplate(secondaryMongoClient(), getDbName());
    }
}

下面是我用 @Transactional 注释的方法的示例代码片段

    @Override
    @Transactional(transactionManager = "primaryTransactionManager",rollbackFor = {Exception.class})
    public String addNewRecipe() throws Exception{
        RecipesDAO recipesDao = new RecipesDAO();
        recipesDao.setResourceId(UUID.randomUUID().toString());
        recipeRepository.save(recipesDao);
        throw new Exception();
    //  return "dummy";
    }

Answer 1

是我必须使用的代码片段，以便在代码执行流程中发生异常时回滚事务

@Bean(name="primaryMongoTemplate")
    public MongoTemplate mongoTemplate() {
        MongoTemplate primaryMongoTemplate = new MongoTemplate(mongoClient(), getDbName());
        primaryMongoTemplate.setSessionSynchronization(SessionSynchronization.ALWAYS);
        return primaryMongoTemplate;
    }

    @Bean(name="secondaryMongoTemplate")
    public MongoTemplate secondaryMongoTemplate() {
        MongoTemplate secondaryMongoTemplate = new MongoTemplate(secondaryMongoClient(), getDbName());
        secondaryMongoTemplate.setSessionSynchronization(SessionSynchronization.ALWAYS);
        return secondaryMongoTemplate;
    }

在检查了我的类 MongoConfig.java 中使用的类的每个方法后，我得到了解决方案。下面 无论何时创建新的或修改 mongodb 文档的代码都存在，例如用于立即创建或修改文档的 somerepository.save(s) 代码，但通过添加primaryMongoTemplate.setSessionSynchronization(SessionSynchronization.ALWAYS); 和 secondaryMongoTemplate.setSessionSynchronization(SessionSynchronization.ALWAYS);
代码等待完整的执行流程，并检查该执行流程中是否发生异常。只有在检查执行流程中没有发生异常后，它才会创建或修改文档。