我正在使用 Spring 框架在 Java 中开发一个小型应用程序。作为其中的一部分，我在这个 Spring 项目中开发了一个命令行工具，它读取 CSV 文件并将其插入 MySQL 数据库。

我想为此目的使用 Soring 自己的事务管理，并且我发现使用 @Transactional 的注释方法很有吸引力。问题是即使产生异常，带有这个注解的函数也不会回滚。

这是我认为与此问题相关的一小部分代码:

public static void main(String[] args) throws Exception {

    //some variables and stuff here

    //getting application context
    ApplicationContext applicationContext = new AnnotationConfigApplicationContext(BeanConfig.class);
    JdbcOperations jdbcOperations = applicationContext.getBean("jdbcOperations", JdbcOperations.class);
    UserDaoImpl userDaoImpl = applicationContext.getBean("userDao", UserDaoImpl.class);
    DBDaoImpl DBDaoImpl = applicationContext.getBean("dbDao", DBDaoImpl.class);

    UserDetailImporterTool importerTool = new UserDetailImporterTool(jdbcOperations, DBDaoImpl, userDaoImpl);

    //this functions calls a DAO 
    importerTool.execute(users, userFollowingMapCSV, batchSize);
}

这是从上面提到的 main() 调用的 execute() 函数:

public int execute(List<User> users, String userFollowingMapCSV, int batchSize) throws Exception{
    // stuff here

    int numSuccessfulInsertions = userDaoImpl.insert(users, jdbcOperations, batchSize);

   // stuff here
}

这是从上述execute() 函数调用的insert() 函数:

@Override
public int insert(@Nonnull List<User> user,
                  @Nonnull JdbcOperations jdbcOperations,
                  int batchSize) throws Exception
{
    //stuff here

        try {
            insertBatch(jdbcOperations,
                    userArgsList,
                    userDetailArgsList,
                    officialDetailArgsList,
                    residentialDetailArgsList
            );
        } catch (Exception e) {
            LOGGER.warning("ERROR");
        }
    }
    // stuff here
}

最后是 DAO 中应用事务管理的 insertBatch() 函数:

@Transactional("dataSourceTransactionManager")
private void insertBatch(JdbcOperations jdbcOperations,
                         List<Object[]> userArgsList,
                         List<Object[]> userDetailArgsList,
                         List<Object[]> officialDetailArgsList,
                         List<Object[]> residentialDetailArgsList
) throws Exception 
{
    try {
        jdbcOperations.batchUpdate(userSql, userArgsList);
        jdbcOperations.batchUpdate(userDetailSql, userDetailArgsList);
        jdbcOperations.batchUpdate(officialDetailSql, officialDetailArgsList);
        jdbcOperations.batchUpdate(residentailDetailSql, residentialDetailArgsList);
    } catch (Exception e) {
        LOGGER.warning(debugMessageIndicator + " Batch failed to insert. Error : " + e.getMessage());
        throw new Exception();
    }


}

最后(我保证，这是最后一个片段 :P)这是我的 bean 配置文件:

@EnableTransactionManagement
@Configuration
@EnableAspectJAutoProxy(proxyTargetClass = true)
@PropertySource("classpath:application.properties")
public class BeanConfig {

private static final String VALIDATION_QUERY = "SELECT 1";

@Autowired
private Environment env;

@Bean
public BasicDataSource dataSource() {
    String driverClassName = env.getProperty("db.driverClassName");
    String jdbcUrl = env.getProperty("db.jdbcUrl");
    String username = env.getProperty("db.username");
    String password = env.getProperty("db.password");

    BasicDataSource basicDataSource = new BasicDataSource();
    basicDataSource.setDriverClassName(driverClassName);
    basicDataSource.setUrl(jdbcUrl);
    basicDataSource.setUsername(username);
    basicDataSource.setPassword(password);

    basicDataSource.setValidationQuery(VALIDATION_QUERY);
    basicDataSource.setValidationQueryTimeout(1);
    basicDataSource.setTestOnBorrow(true);
    basicDataSource.setTestWhileIdle(true);

    return basicDataSource;
}

@Bean
public JdbcOperations jdbcOperations() {
    BasicDataSource dataSource = dataSource();
    return new JdbcTemplate(dataSource);
}

@Bean
public UserDAO userDao() {
    return new UserDaoImpl();
}

@Bean
public DBDao dbDao() {
    return new DBDaoImpl();
}

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

我相信所有这些都是看到完整的控制流所必需的。如您所见，即使我重新抛出异常，回滚也不会执行。有人告诉我，除非我在 Tomcat 上部署项目的 WAR 文件，否则我不能使用注释性事务管理。现在我通过 maven 从命令行运行它。

如果不部署，我真的不能使用 @Transactional 吗？是否有任何错误阻止执行回滚表单？

我尝试在 DataSource bean 中将自动提交设置为 false 但没有成功。任何指示都会有所帮助。

最佳答案

1. 如果我能看到您有一个已检查的异常。但在这种情况下 Spring 默认情况下，事务不会回滚事务。仅未勾选 默认情况下会回滚异常。 Spring 文档说:

   While the EJB default behavior is for the EJB container to automatically roll back the transaction on a system exception (usually a runtime exception), EJB CMT does not roll back the transaction automatically on an application exception (that is, a checked exception other than java.rmi.RemoteException). While the Spring default behavior for declarative transaction management follows EJB convention (roll back is automatic only on unchecked exceptions), it is often useful to customize this.

   你必须在你的类之上定义它:

   @Transactional(rollbackFor=Exception.class) 类 YourClassName {}

   或者您可以指定特定的检查异常。

2. 可以在没有任何 servlet 的情况下使用 Spring Transaction(@Transactional 和其他注释) Tomcat 等容器。这些是完全不同的事情。

更新:您还需要在配置类中定义 transactionManager，如图所示 here :

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

更新 2:您不需要手动加载 main() 方法中的所有 bean。指定 bean 之间关系的更好方法。只应手动加载主要服务。 Spring 容器将为您完成这项工作。交易也将正常进行。如图所示here .

关于java - Spring——在命令行工具中使用注解事务管理，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/31253110/