拦截sql修改表名

package com.xf.config;

import com.alibaba.druid.sql.ast.statement.SQLExprTableSource;
import com.alibaba.druid.sql.dialect.mysql.visitor.MySqlASTVisitorAdapter;


public class MySqlExportTableAliasVisitor extends MySqlASTVisitorAdapter {
    @Override
    public boolean visit(SQLExprTableSource x) {
        x.setExpr("saas_base."+x.getTableName());
        return true;
    }
}

protected String changeTable(String sql) {
        DbType dbType = JdbcConstants.MYSQL;
        List<SQLStatement> stmtList = SQLUtils.parseStatements(sql, dbType);
        for (SQLStatement sqlStatement : stmtList) {
            MySqlASTVisitorAdapter visitor = new MySqlExportTableAliasVisitor();
            sqlStatement.accept(visitor);
        }
        return SQLUtils.toSQLString(stmtList, JdbcConstants.MYSQL);
    }