博客

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);
    }
}