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，你需要相應地修改配置類中的代碼。
