Mybatis 动态修改 SQL 的两种方式
创始人
2025-07-12 09:20:46
0

在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,你需要相应地修改配置类中的代码。

相关内容

热门资讯

如何允许远程连接到MySQL数... [[277004]]【51CTO.com快译】默认情况下,MySQL服务器仅侦听来自localhos...
如何利用交换机和端口设置来管理... 在网络管理中,总是有些人让管理员头疼。下面我们就将介绍一下一个网管员利用交换机以及端口设置等来进行D...
施耐德电气数据中心整体解决方案... 近日,全球能效管理专家施耐德电气正式启动大型体验活动“能效中国行——2012卡车巡展”,作为该活动的...
Windows恶意软件20年“... 在Windows的早期年代,病毒游走于系统之间,偶尔删除文件(但被删除的文件几乎都是可恢复的),并弹...
20个非常棒的扁平设计免费资源 Apple设备的平面图标PSD免费平板UI 平板UI套件24平图标Freen平板UI套件PSD径向平...
德国电信门户网站可实时显示全球... 德国电信周三推出一个门户网站,直观地实时提供其安装在全球各地的传感器网络检测到的网络攻击状况。该网站...
着眼MAC地址,解救无法享受D... 在安装了DHCP服务器的局域网环境中,每一台工作站在上网之前,都要先从DHCP服务器那里享受到地址动...
为啥国人偏爱 Mybatis,... 关于 SQL 和 ORM 的争论,永远都不会终止,我也一直在思考这个问题。昨天又跟群里的小伙伴进行...