mybatis-kb88凯时官网登录

目录

• 起源
• 实现拦截器接口innerinterceptor
• 修改sql常用的工具类

起源

最近公司要做多租户，mybatis-plus的多租户插件很好用，但是有一个场景是：字典表或者某些数据表，一些数据需要在各个租户之间共享，而数据表本身又同时要实现多租户数据隔离，比如字典表：性别等“男”/“女”基础数据。

sql拦截器是一种用于拦截和修改mybatis执行的sql语句的工具。通过使用sql拦截器，开发人员可以在执行sql语句之前或之后对其进行修改或记录，从而更好地控制和优化数据库操作。例如mybatis-plus的基础分页插件、多租户插件就是sql拦截器，那么，我们是否可以实现自己的sql拦截器呢？

答案当然是肯定的。

实现拦截器接口innerinterceptor

innerinterceptor 这个接口是mybaitsplus的拦截器接口类，实现它之后，并且通过mybatisplusinterceptor配置后，就可以实现sql执行拦截。

mybatisplusinterceptor interceptor = new mybatisplusinterceptor();
// 多租户拦截器
interceptor.addinnerinterceptor(new tenantlineinnerinterceptor(new tenantdatabaseinterceptor(tenantproperties)));
// 多租户部分表数据共享拦截器
interceptor.addinnerinterceptor(new tenantdatabaseshareinterceptor(new tenantsharehandlerimpl(tenantproperties)));

那么如何实现该接口以及修改sql呢？

下面是一个样例：

import com.baomidou.mybatisplus.core.interceptor.innerinterceptor;
import com.baomidou.mybatisplus.core.metadata.ipage;
import com.baomidou.mybatisplus.core.parser.sqlparserhelper;
import com.baomidou.mybatisplus.extension.plugins.inner.innerinterceptorchain;
import net.sf.jsqlparser.parser.ccjsqlparserutil;
import net.sf.jsqlparser.statement.statement;
import net.sf.jsqlparser.statement.select.select;
public class myinterceptor implements innerinterceptor {
    @override
    ```
    @override
    public void beforequery(executor executor, mappedstatement ms, object parameter, rowbounds rowbounds, resulthandler resulthandler, boundsql boundsql) throws sqlexception {
        if (interceptorignorehelper.willignoretenantline(ms.getid())) return;
        pluginutils.mpboundsql mpbs = pluginutils.mpboundsql(boundsql);
        mpbs.sql(parsersingle(mpbs.sql(), null));
    }
}

通过修改beforequery函数中的代码，即可修改执行的sql。

修改sql常用的工具类

jsqlparsersupport该类用于解析与修改sql，并且mybatisplus的多租户插件更是直接继承了该类。 ccjsqlparserutil是jsqlparser中用于解析sql语句的工具类。它提供了一些静态方法，可以将sql语句解析为statement对象、select对象、update对象、insert对象、delete对象等。

常用的类还有expression, statement等类。

例如，使用expression实现一个in语句：

import net.sf.jsqlparser.expression.expression;
import net.sf.jsqlparser.expression.longvalue;
import net.sf.jsqlparser.expression.stringvalue;
import net.sf.jsqlparser.expression.operators.relational.inexpression;
import net.sf.jsqlparser.expression.operators.relational.itemslist;
import net.sf.jsqlparser.expression.operators.relational.multiexpressionlist;
import net.sf.jsqlparser.expression.operators.relational.namedparameter;
import net.sf.jsqlparser.expression.operators.relational.subselect;
import net.sf.jsqlparser.parser.ccjsqlparserutil;
public class jsqlparserexample {
    public static void main(string[] args) throws exception {
        // in语句
        inexpression inexpr = new inexpression();
        inexpr.setleftexpression(ccjsqlparserutil.parseexpression("age"));
        itemslist valuelist = new multiexpressionlist();
        ((multiexpressionlist) valuelist).addexpressions(new longvalue(18), new longvalue(21), new longvalue(30));
        inexpr.setitemslist(valuelist);
        system.out.println(inexpr.tostring());
        // 子查询
        inexpression subqueryinexpr = new inexpression();
        subqueryinexpr.setleftexpression(ccjsqlparserutil.parseexpression("age"));
        subselect subquery = new subselect();
        subquery.setselectbody(ccjsqlparserutil.parse("select age from users where country = 'us'"));
        subqueryinexpr.setrightexpression(subquery);
        system.out.println(subqueryinexpr.tostring());
    }
}