Spring-data-jpa实现DDL(创建表、删除表)

传说中的架构师

0.077 2020-08-18 11:09 IP属地: 山西

Spring-data-jpa：

Spring提供的操作数据库一系列的接口（基于hibernate上进行操作）。

遇到的问题：

需求描述：在系统中出现一个需求，需要定期去删除过期的数据，删除之前肯定是需要对表进行备份，且也不能无休止的进行备份。例如：1天清理一次过期数据，则会产生1个当日的备份表，假定只需要最近7天的备份表，其余则删除。所以需要进行数据库表的创建以及删除。

系统中使用的orm框架是JPA，使用EntityManager的方式进行操作，如果使用 @Query 自定义sql执行，则拼接表名称无法识别（自动拼接上 单引号 ‘your_table_name’，导致sql报错，因为表名需要的是符号 your_table_name ）。

关于@Modifying、 @Transactional注解

使用jpa进行增删改、DDL操作为什么都需要使用注解

在官网上又这样一句描述
By default, CRUD methods on repository instances are transactional. For read operations, the transaction configuration readOnly flag is set to true. All others are configured with a plain @Transactional so that default transaction configuration applies. For details, see JavaDoc of SimpleJpaRepository.
说人话就是：默认情况下，存储库实例上的CRUD方法是事务性的。对于读取操作，事务配置readOnly标志设置为true。所有其他的都配置了一个普通的@Transactional，以便应用默认的事务配置。有关详细信息，请参见SimpleJpaRepository的JavaDoc。

@Modifying去声明了这个操作是一个修改操作。

@Transactional去覆盖了默认的readOnly = true，其中指定rollbackFor = Exception.class（如果不指定，则遇到 运行时异常 会回滚事务）代表了只要遇到 任何异常 都会进行回滚。

代码如下：
* @author xxx * @date 2020/5/8 10:59 @Repository public class Repository { @PersistenceContext private EntityManager entityManager; private Logger logger = LoggerFactory.getLogger(Repository.class); @Autowired private AppConfig config; @Transactional(rollbackFor = Exception.class) @Modifying public Integer backupTableForBookMarriage () { // 备份表名称 String tableName = "table_" + LocalDateTime.now().format(DateTimeFormatter.ISO_DATE) + "_24_00"; int nativeQuery = 0; logger.info("开始备份表：{}",tableName); String sql = "CREATE TABLE " + '`' + tableName + '`' + " (SELECT * FROM `book_marriage`)"; try { nativeQuery = entityManager.createNativeQuery(sql).executeUpdate(); } catch (Exception e) { logger.error("备份失败：{}", tableName); logger.error("备份发生异常：{}", e.getMessage()); if (nativeQuery > 0) { logger.info("备份成功，备份表名称：{}", tableName); return nativeQuery; * 删除指定天数以外的备份的数据库 * @return @Transactional(rollbackFor = Exception.class) @Modifying public void deleteWeekAgoTableForBookMarriage() { String tableName = "table_" + this.getLastWeekTime(Integer.parseInt(config.getDeleteDayNumber())) + "_24_00"; int nativeQuery = 0; logger.info("开始删除一周前的备份表：{}",tableName); String sql = "DROP TABLE " + '`' + tableName + '`'; logger.info("==========SQL：{}",sql); try { nativeQuery = entityManager.createNativeQuery(sql).executeUpdate(); } catch (Exception e) { logger.error("删除备份表失败：{}", e.getMessage()); if (nativeQuery > 0) { logger.info("删除备份表成功，备份表名称：{}", tableName); * 获取指定日期 * @return private String getLastWeekTime (int deleteDayNumber) { SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd"); Calendar calendar = Calendar.getInstance(); Date date = new Date(); calendar.setTime(date); calendar.add(Calendar.DATE, - deleteDayNumber); date = calendar.getTime(); return df.format(date);