SpringBoot使用JdbcTemplate和TransactionTemplate 控制事务

在Spring框架中，TransactionTemplate是一个用于编程式事务管理的工具，它允许你显式地控制事务的边界和行为。与声明式事务管理（如使用@Transactional注解）相比，编程式事务管理提供了更细粒度的事务控制。

以下是一个使用TransactionTemplate来控制事务的示例，其中涉及到JdbcTemplate来执行多条SQL语句：

1. 配置数据源和JdbcTemplate：确保你的Spring Boot应用已经配置了数据源和JdbcTemplate。这通常是通过在application.properties或application.yml文件中提供数据源信息，并在你的配置类中注入JdbcTemplate来实现的。
2. 创建TransactionTemplate Bean：在你的配置类中，创建一个TransactionTemplate的Bean。你需要提供一个PlatformTransactionManager，它定义了事务的传播行为、隔离级别、超时等。

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.support.TransactionTemplate;

@Configuration
public class AppConfig {

    @Autowired
    private DataSource dataSource; // 假设你已经配置了一个DataSource Bean

    @Bean
    public JdbcTemplate jdbcTemplate() {
        return new JdbcTemplate(dataSource);
    }

    @Bean
    public PlatformTransactionManager transactionManager(DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean
    public TransactionTemplate transactionTemplate(PlatformTransactionManager transactionManager) {
        return new TransactionTemplate(transactionManager);
    }
}

3. 在服务类中使用TransactionTemplate：在你的服务类中，注入TransactionTemplate和JdbcTemplate，然后使用TransactionTemplate的execute方法来执行一个包含多条SQL语句的事务性操作。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.support.TransactionCallback;
import org.springframework.transaction.support.TransactionTemplate;

@Service
public class MyService {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    @Autowired
    private TransactionTemplate transactionTemplate;

    public void executeMultipleQueriesInTransaction() {
        transactionTemplate.execute(new TransactionCallback<Void>() {
            @Override
            public Void doInTransaction(org.springframework.transaction.support.TransactionStatus status) {
                try {
                    String insertQuery1 = "INSERT INTO your_table1 (column1, column2) VALUES (?, ?)";
                    String insertQuery2 = "INSERT INTO your_table2 (column1, column2) VALUES (?, ?)";

                    // 执行第一个插入操作
                    jdbcTemplate.update(insertQuery1, "value1_1", "value1_2");

                    // 执行第二个插入操作
                    jdbcTemplate.update(insertQuery2, "value2_1", "value2_2");

                    // 你可以在这里添加更多的SQL操作

                    // 如果所有操作都成功，事务将自动提交
                    return null; // 对于Void返回类型，返回null即可

                } catch (Exception e) {
                    // 如果发生异常，可以标记事务回滚
                    status.setRollbackOnly();
                    throw e; // 重新抛出异常以便上层处理（可选）
                }
            }
        });
    }
}

在这个示例中，executeMultipleQueriesInTransaction方法使用TransactionTemplate的execute方法来执行一个包含两个插入操作的事务。如果在事务执行过程中发生异常，事务将被回滚。如果所有操作都成功完成，事务将自动提交。

请注意，当在TransactionCallback的doInTransaction方法中发生异常时，你可以选择捕获异常并处理它（例如，记录日志），然后决定是否通过调用TransactionStatus.setRollbackOnly()来回滚事务。在这个例子中，异常被重新抛出以便上层可以捕获并处理它（这取决于你的异常处理策略）。如果你不想上层知道这个异常，你可以在catch块中处理完异常后返回null（对于Void返回类型）而不重新抛出异常。但是，这通常不是推荐的做法，因为它可能会隐藏潜在的问题。