Mybatis 动态修改 SQL 的两种方式

在Spring AOP中，你可以使用切面（Aspect）来拦截MyBatis执行期间的方法调用，包括修改BoundSql对象中的SQL语句。以下是一个基本的示例：

1、创建切面类

创建一个切面类，使用@Aspect注解进行标记，并使用@Around注解来拦截目标方法的执行。

@Aspect
@Component
public class BoundSqlAspect {

    @Around("execution(* org.apache.ibatis.executor.BaseExecutor.query(..)) && args(ms, parameterObject, rowBounds, resultHandler)")
    public Object modifyBoundSql(ProceedingJoinPoint joinPoint, MappedStatement ms, Object parameterObject, RowBounds rowBounds, ResultHandler resultHandler) throws Throwable {
        // 获取BoundSql对象
        BoundSql boundSql = ms.getBoundSql(parameterObject);
        
        // 获取原始SQL语句
        String sql = boundSql.getSql();
        
        // 修改SQL语句
        String modifiedSql = modifySql(sql);
        
        // 修改BoundSql对象
        BoundSql modifiedBoundSql = new BoundSql(ms.getConfiguration(), modifiedSql, boundSql.getParameterMappings(), parameterObject);
        
        // 将修改后的BoundSql对象设置回MappedStatement中
        ((MappedStatement) joinPoint.getArgs()[0]).setBoundSql(modifiedBoundSql);
        
        // 执行原始方法
        Object result = joinPoint.proceed();
        
        return result;
    }

    private String modifySql(String sql) {
        // 在这里进行SQL语句的修改，例如添加额外的条件、修改排序方式等
        return sql + " WHERE column = ?";
    }
}

2、 在Spring Boot应用程序中，将切面类注册为一个Bean

@SpringBootApplication
@EnableAspectJAutoProxy
public class YourApplication {

    public static void main(String[] args) {
        SpringApplication.run(YourApplication.class, args);
    }

    @Bean
    public BoundSqlAspect boundSqlAspect() {
        return new BoundSqlAspect();
    }
}

通过以上步骤，你可以使用Spring AOP拦截MyBatis执行期间的方法调用，并在切面中修改BoundSql对象中的SQL语句。在modifyBoundSql方法中，你可以获取原始的BoundSql对象，修改SQL语句并创建一个新的BoundSql对象，然后将其设置回MappedStatement中。最后，你可以继续执行原始方法并返回结果。请注意，修改后的SQL语句和参数绑定需要保持一致，以确保正确执行和获取结果。

请注意，这个示例假设你正在使用org.mybatis.spring.SqlSessionTemplate来执行MyBatis的语句。如果你正在使用其他方式执行语句，你需要相应地修改切面中的切点表达式。

在Spring中，你可以使用BeanPostProcessor接口来拦截和修改MyBatis中的SQL语句。下面是一个示例：

1、创建一个实现BeanPostProcessor接口的类，用于拦截MyBatis相关的Bean：

@Component
public class MyBatisSqlInterceptor implements BeanPostProcessor {

    @Autowired
    private SqlSessionFactory sqlSessionFactory;

    @Override
    public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {
        if (bean instanceof SqlSessionFactoryBean) {
            SqlSessionFactoryBean sessionFactoryBean = (SqlSessionFactoryBean) bean;
            sessionFactoryBean.setPlugins(new Interceptor[]{new MyBatisInterceptor()});
        }
        return bean;
    }

    @Override
    public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
        return bean;
    }

    private class MyBatisInterceptor implements Interceptor {
        @Override
        public Object intercept(Invocation invocation) throws Throwable {
            if (invocation.getTarget() instanceof RoutingStatementHandler) {
                RoutingStatementHandler routingStatementHandler = (RoutingStatementHandler) invocation.getTarget();
                MetaObject metaObject = SystemMetaObject.forObject(routingStatementHandler);
                MappedStatement mappedStatement = (MappedStatement) metaObject.getValue("delegate.mappedStatement");
                BoundSql boundSql = (BoundSql) metaObject.getValue("delegate.boundSql");

                // 修改SQL语句
                String modifiedSql = modifySql(boundSql.getSql());

                // 将修改后的SQL语句设置回BoundSql对象
                metaObject.setValue("delegate.boundSql.sql", modifiedSql);
            }

            return invocation.proceed();
        }

        private String modifySql(String sql) {
            // 在这里进行SQL语句的修改，例如添加额外的条件、修改排序方式等
            return sql + " WHERE column = ?";
        }
    }
}

2、配置MyBatis：

在Spring Boot的配置类中，将上述MyBatisSqlInterceptor类配置为一个Bean，并注入到SqlSessionFactoryBean中。

@Configuration
public class MyBatisConfig {

    @Autowired
    private MyBatisSqlInterceptor myBatisSqlInterceptor;

    @Bean
    public SqlSessionFactoryBean sqlSessionFactory(DataSource dataSource) throws Exception {
        SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();
        sessionFactoryBean.setDataSource(dataSource);
        sessionFactoryBean.setPlugins(new Interceptor[]{myBatisSqlInterceptor});

        return sessionFactoryBean;
    }
}

通过以上步骤，你可以使用BeanPostProcessor接口拦截MyBatis相关的Bean，并在拦截器中修改BoundSql对象中的SQL语句。在MyBatisInterceptor的intercept方法中，你可以获取MappedStatement和BoundSql对象，修改SQL语句并将其设置回BoundSql对象。然后，你可以继续执行原始方法并返回结果。请注意，修改后的SQL语句和参数绑定需要保持一致，以确保正确执行和获取结果。

在上述示例中，假设你使用的是Spring Boot的默认SqlSessionFactoryBean来配置MyBatis的SqlSessionFactory。如果你使用不同的方式来配置SqlSessionFactory，你需要相应地修改配置类中的代码。