@Transactional在春季关机正常关机Hsqldb

Question

这个问题的核心是：是否有可能从Spring关机挂钩触发的方法执行交易？

目前我在这个问题发现，实现SmartLifeCycle一个HyperSqlDbServer类： In a spring bean is it possible to have a shutdown method which can use transactions?

我有一个标记事务那类被调用作为停止方法的一部分的方法：

@Transactional 
public void executeShutdown() { 
    hsqlDBShutdownService.executeShutdownQuery(); 
    hsqlDBShutdownService.closeEntityManager(); 
} 

在该方法中使用的服务是一个黑客一点，我不得不这样做，因为我不能在EntityManager的自动装配这个类：

@Service 
public class HsqlDBShutdownService { 

    @PersistenceContext 
    private EntityManager entityManager; 

    @Autowired 
    private HyperSqlDbServer hyperSqlDbServer; 

    @Transactional 
    public void executeShutdownQuery() { 
     entityManager.createNativeQuery("SHUTDOWN").executeUpdate(); 
    } 

    @Transactional 
    public void closeEntityManager() { 
     entityManager.close(); 
    } 

    @PostConstruct 
    public void setHsqlDBShutdownService() { 
     hyperSqlDbServer.setShutdownService(this); 
    } 
} 

您可能会注意到，我真正想要完成的是在停止服务器之前调用查询“SHUTDOWN”。如果没有这个，hsqldb锁定文件会在服务器重新启动时出现，并且服务器会引发异常。

上面的代码会产生以下异常：

javax.persistence.TransactionRequiredException: Executing an update/delete query 
    at org.hibernate.ejb.AbstractQueryImpl.executeUpdate(AbstractQueryImpl.java:96) 
     ... 

所以我原来的问题表示，但如果有人对我怎么能执行这个查询另一种方式一个想法，我会尝试为好。

仅供参考，我也试过@PreDestroy注释，但得到相同的TransactionRequiredException。

编辑：为了完整起见，我使用的是JpaTransactionManager接口和整个我的项目@Transactional注释工作，除了在关机...

编辑2：数据源和事务管理器配置：

@Configuration 
@EnableTransactionManagement 
@PropertySource("classpath:persistence.properties") 
public class PersistenceConfig implements TransactionManagementConfigurer { 

    private static final String PASSWORD_PROPERTY = "dataSource.password"; 
    private static final String USERNAME_PROPERTY = "dataSource.username"; 
    private static final String URL_PROPERTY = "dataSource.url"; 
    private static final String DRIVER_CLASS_NAME_PROPERTY = "dataSource.driverClassName"; 

    @Autowired 
    private Environment env; 

    @Bean 
    @DependsOn("hsqlDb") 
    public DataSource configureDataSource() { 
     DriverManagerDataSource dataSource = new DriverManagerDataSource(); 
     dataSource.setDriverClassName(env.getProperty(DRIVER_CLASS_NAME_PROPERTY)); 
     dataSource.setUrl(env.getProperty(URL_PROPERTY)); 
     dataSource.setUsername(env.getProperty(USERNAME_PROPERTY)); 
     dataSource.setPassword(env.getProperty(PASSWORD_PROPERTY)); 
     return dataSource; 
    } 

    @Bean 
    @DependsOn("hsqlDb") 
    public LocalContainerEntityManagerFactoryBean configureEntityManagerFactory() { 
     LocalContainerEntityManagerFactoryBean entityManagerFactoryBean = new LocalContainerEntityManagerFactoryBean(); 
     entityManagerFactoryBean.setDataSource(configureDataSource()); 
     entityManagerFactoryBean.setPackagesToScan("com.mycompany.model.db"); 
     entityManagerFactoryBean.setJpaVendorAdapter(new HibernateJpaVendorAdapter()); 

     Properties jpaProperties = new Properties(); 
     jpaProperties.put(org.hibernate.cfg.Environment.DIALECT, env.getProperty(org.hibernate.cfg.Environment.DIALECT)); 
     jpaProperties.put(org.hibernate.cfg.Environment.HBM2DDL_AUTO, env.getProperty(org.hibernate.cfg.Environment.HBM2DDL_AUTO)); 
     jpaProperties.put(org.hibernate.cfg.Environment.SHOW_SQL, env.getProperty(org.hibernate.cfg.Environment.SHOW_SQL)); 
     jpaProperties.put(org.hibernate.cfg.Environment.HBM2DDL_IMPORT_FILES_SQL_EXTRACTOR, env.getProperty(org.hibernate.cfg.Environment.HBM2DDL_IMPORT_FILES_SQL_EXTRACTOR)); 
     jpaProperties.put(org.hibernate.cfg.Environment.HBM2DDL_IMPORT_FILES, env.getProperty(org.hibernate.cfg.Environment.HBM2DDL_IMPORT_FILES)); 
     entityManagerFactoryBean.setJpaProperties(jpaProperties); 

     return entityManagerFactoryBean; 
    } 

    @Override 
    @Bean() 
    @DependsOn("hsqlDb") 
    public PlatformTransactionManager annotationDrivenTransactionManager() { 
     return new JpaTransactionManager(); 
    } 

} 

Answer 1

我发现了一个关闭HsqlDB数据库的解决方法，但它涉及避免使用Spring的EntityManager和@Transactional，因为它们在服务器关闭期间显然不工作。下面是我修改的HsqlDBShutdownService。关键在于不是使用EntityManager来调用查询，而是手动创建一个新的jdbc连接，并以这种方式调用查询。这就避免了对需求@Transactional：

@Service 
public class HsqlDBShutdownService { 

    @Autowired 
    private ApplicationContext applicationContext; 

    @PersistenceContext 
    private EntityManager entityManager; 

    @Autowired 
    private HyperSqlDbServer hyperSqlDbServer; 

    public void executeShutdownQuery() { 

     Connection conn = null; 
     try { 
      JdbcTemplate jdbcTemplate = new JdbcTemplate(this.applicationContext.getBean(DataSource.class)); 
      conn = DataSourceUtils.getConnection(jdbcTemplate.getDataSource()); 
      conn.setAutoCommit(true); 
      jdbcTemplate.execute("SHUTDOWN"); 
     } catch(Exception ex) { 
      ex.printStackTrace(); 
     } finally { 
      try { 
       if(conn != null) 
        conn.close(); 
      } catch(Exception ex) { 
       ex.printStackTrace(); 
      } 
     } 
    } 

    @Transactional 
    public void closeEntityManager() { 
     entityManager.close(); 
    } 

    @PostConstruct 
    public void setHsqlDBShutdownService() { 
     hyperSqlDbServer.setShutdownService(this); 
    } 

} 

服务器现在可以成功地重新启动而没有围绕HSQLDB留下锁定文件。