//[数据库名字].[表名]
@Table(name = "canal.act_activity")
@Component
public class ActivityCanalListener implements ProcessListener<Activity> {
    private static final Logger logger = LoggerFactory.getLogger(ActivityCanalListener.class);

    @Override
    public boolean update(Activity after, Activity before, List<String> updateFiled) {
        logger.info("-------------------------触发修改-------------------------");
        logger.info("修改一条数据修改前:{}", JSON.toJSON(after));
        logger.info("修改一条数据修改后:{}", JSON.toJSON(before));
        logger.info("修改一条数据修改字段:{}", JSON.toJSON(updateFiled));
        logger.info("-------------------------触发end-------------------------");
        return false;
    }

    @Override
    public boolean insert(Activity activity) {
        logger.info("新增一条数据{}", JSON.toJSON(activity));
        return false;
    }

    @Override
    public boolean delete(Activity activity) {
        logger.info("删除一条数据{}", JSON.toJSON(activity));
        return false;
    }
}