mybatis springboot多数据源，根据使用的数据库不同，执行不同的sql语句

import org.apache.ibatis.cache.CacheKey;
import org.apache.ibatis.executor.Executor;
import org.apache.ibatis.mapping.BoundSql;
import org.apache.ibatis.mapping.MappedStatement;
import org.apache.ibatis.plugin.Interceptor;
import org.apache.ibatis.plugin.Intercepts;
import org.apache.ibatis.plugin.Invocation;
import org.apache.ibatis.plugin.Signature;
import org.apache.ibatis.session.Configuration;
import org.apache.ibatis.session.ResultHandler;
import org.apache.ibatis.session.RowBounds;
import org.springframework.stereotype.Component;
import uz.sinow.datasource.dynamic.DynamicDataSourceConfiguration;
import uz.sinow.datasource.dynamic.ShardingContextHolder;

/**
 *
 * 多数据源sql方言切换拦截器，
 * 通过拦截方式替换执行sql来实现sql的切换，databaseId未查到正确的注入方式，这个通过mybatis的MappedStatement对象的
 * 替换来实现
 * 替换规则，原MappedStatement的id加上‘_’+数据源切库标识
 */
@Component("DynmicDatabaseSql")
@Intercepts({
        @Signature(type= Executor.class, method="query", args={MappedStatement.class,Object.class, RowBounds.class, ResultHandler.class, CacheKey.class, BoundSql.class}),
        @Signature(type= Executor.class, method="query", args={MappedStatement.class,Object.class,RowBounds.class, ResultHandler.class})
})
public class DynamicMappedStatementChooseInterceptor implements Interceptor {

    private String base;

    public DynamicMappedStatementChooseInterceptor(DynamicDataSourceConfiguration dynamicDataSourceConfiguration) {
        this.base = dynamicDataSourceConfiguration.getBase();
    }

    @Override
    public Object intercept(Invocation invocation) throws Throwable {
        //取出当前数据源的DSName
        String ds = ShardingContextHolder.getDS();
        //如果是基本数据源（未指定表示用的是基本数据源）执行默认的方法对应的sql
        if (ds == null || ds.trim().length() == 0 || ds.equals(base))
            return invocation.proceed();
        //取出当前要执行的sql
        Object[] args = invocation.getArgs();
        MappedStatement mappedStatement = (MappedStatement) args[0];
        //查看是否有要替换的方言，有就替换，没有就还用默认的
        Configuration configuration = mappedStatement.getConfiguration();
        MappedStatement mappedStatement1 = configuration.getMappedStatement(mappedStatement.getId() + "_" + ds);
        if(mappedStatement1!=null)
            args[0] = mappedStatement1;
        return invocation.proceed();
    }
}