mybatis插件

Configuration组成

在这里插入图片描述

Mapper映射器

3个部分组成：

MappedStatement
保存一个节点(select | insert | update | delete) ，包括我们配置的sql，，sql的id，，缓存信息，，resultMap,parameterType,resultType,languageDriver 等
SqlSource ：提供BoundSql对象的地方，是MappedStatement的一个属性
BoundSql ：建立sql和参数的地方

三个常用属性：
- sql ： sql语句
- parameterObject ：参数本身
- parameterMappings ：是一个List，，由ParameterMapping组成，，这个对象会描述我们的参数，，比如：属性，名称，表达式，javaType,jdbcType,typeHandler等重要信息，，一个参数对应一个ParameterMapping

SqlSession下的四大对象

Executor执行器

调度StatementHandler,ParameterHandler,ResultSetHandler等来执行sql

mybatis存在三种执行器：

simple : 简易执行器，，默认的
reuse ：重用预处理语句
batch ：重用语句和批量更新

在配置文件中设置setting元素defaultExecutorType

StatementHandler 数据库会话器

使用数据库的Statement(PreparedStatement)执行操作
三种StatementHandler：

SimpleStatementHandler
PreparedStatementHandler
CallableStatementHandler

创建一个RoutingStatementHandler对象，，RoutingStatementHandler不是我们真实的服务对象，，他是通过适配模式找到对应的StatementHandler来执行的，，初始化RoutingStatementHandler对象的时候，他会根据上下文环境决定创建哪个StatementHandler对象

方法：

prepare() : 进行预编译sql语句，，同时设置一些基本运行的参数
parameterize() : 启用ParameterHandler设置参数，完成预编译
query() : 执行查询

ParameterHandler 参数处理器

对sql参数的处理，，对预编译语句进行参数设置

方法：

getParameterObject() : 返回参数对象
setParameters() ：设置预编译sql语句的参数

DefaultParameterHandler
从parameterObject对象中取出参数，使用typeHandler进行参数处理

ResultSetHandler 结果处理器

最后数据集ResultSet的处理
方法：

handleOutputParameters() : 处理存储过程输出参数
handlerResultSets() : 包装结果集

SqlSession运行总结

在这里插入图片描述

SqlSession执行过程：
SqlSession是通过 Executor 创建StatementHandler 来运行的，而StatementHandler要经过下面三个步骤：

prepared ：预编译sql
parameterize ：设置参数
query/update : 执行sql

其中parameterize 是调用 ParameterHandler的方法去设置的，而且参数是根据类型处理器typeHandler处理。
query/update是通过resultHandler进行处理结果的封装，如果是update就返回整数，否则就通过typeHandler处理，，最后用 ObjectFactory 提供的规则组装对象，返回给调用者

插件

插件接口Interceptor:

intercept() : 直接覆盖你所拦截对象原有的方法，，
plugin() ：给被拦截的对象生成一个代理对象 Plugin.wrap()
setProperties() : 配置所需要的参数

Plugin.wrap() : 生成这个对象的动态代理对象

调用方法的时候，会从最后一个代理对象的invoke方法运行到第一个代理对象的invoke方法,直至四大对象的真实方法

MetaObject 工具类使用

MetaObject这个工具类可以通过其他的技术手段读取或者修改这些重要对象的属性

方法：

SystemMetaObject.forObject() ：获取MetaObject
getValue() : 获取对象属性值
setValue() : 设置值

  public void test01(){
        User user = new User();
        MetaObject metaObject = SystemMetaObject.forObject(user);

        // 设置属性
        metaObject.setValue("userName","sb");
        metaObject.setValue("id",100L);

        // 设置list
        Role role = new Role();
        List<Role> roleList = Arrays.asList(role);
        metaObject.setValue("roleList",roleList);
        metaObject.setValue("roleList[0].roleName","test");

        System.out.println("user = " + user);
    }

引用：https://blog.csdn.net/Linging_24/article/details/126355031

插件开发

@Intercepts : 说明他是一个拦截器
@Signature : 注册拦截器签名的地方。。。。type是四大对象中的一个，method代表要拦截四大对象中的某一种接口的方法，，args表示参数

导包：

    <dependency>
        <groupId>org.mybatis</groupId>
        <artifactId>mybatis</artifactId>
        <version>3.5.11</version>
    </dependency>
    <dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
        <version>4.13.2</version>
    </dependency>
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.31</version>
    </dependency>
    <dependency>
        <groupId>log4j</groupId>
        <artifactId>log4j</artifactId>
        <version>1.2.15</version>
    </dependency>

插件类：

@Intercepts(@Signature(type = StatementHandler.class,method = "prepare",args = {Connection.class,Integer.class}))
public class QueryLimitPlugin implements Interceptor {
    // 最大查询条数
    private int limit;
    // 数据库类型
    private String dbType;

    // 限制表中间别名，，避免表重名
    private static final String LMT_TABLE_NAME="limit_table_name_xxx";

//    private static final limit_
    @Override
    public Object intercept(Invocation invocation) throws Throwable {
        // 拦截对象
        StatementHandler statementHandler = (StatementHandler) invocation.getTarget();


        MetaObject statementMetaObject = SystemMetaObject.forObject(statementHandler);

        // StatementHandler下面有一个 BoundSql对象 ，，
        // 获取原来的sql
        String sql = (String) statementMetaObject.getValue("boundSql.sql");

        String limitSql;
        // 数据库是mysql，并且这个sql没有被修改过
        if ("mysql".equals(dbType) && sql.indexOf(LMT_TABLE_NAME)==-1){
            limitSql = "select * from (  "+sql+" ) "+LMT_TABLE_NAME+" limit  "+limit;
            // 设置sql
            statementMetaObject.setValue("boundSql.sql",limitSql);
        }

        // 调度真实的StatementHandler的prepare()方法来完成sql预编译
        return invocation.proceed();
    }

    @Override
    public Object plugin(Object target) {
        // 返回代理对象
        return Plugin.wrap(target,this);
    }

    @Override
    public void setProperties(Properties properties) {
        this.dbType = properties.getProperty("dbType","mysql");
        this.limit = Integer.parseInt(properties.getProperty("limit","1"));
    }
}

配置文件：

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
<!--    数据库-->
    <properties resource="jdbc.properties"/>

<!--    <settings>-->
<!--        <setting name="mapUnderscoreToCamelCase" value="true"/>-->
<!--    </settings>-->

    <settings>
<!--        autoMappingBehavior-->
        <setting name="mapUnderscoreToCamelCase" value="true"/>
<!--        <setting name="lazyLoadingEnabled" value="true"/>-->
        <setting name="aggressiveLazyLoading" value="false"/>
    </settings>

    <!--    定义别名 -->
    <typeAliases>
        <package name="com.cj.model"/>
    </typeAliases>

    <plugins>
        <plugin interceptor="com.cj.plugin.QueryLimitPlugin">
            <property name="dbtype" value="mysql"/>
            <property name="limit" value="1"/>
        </plugin>
<!--        <plugin interceptor="com.cj.plugin.MyPlugin">-->
<!--            <property name="dbType" value="mysql"/>-->
<!--        </plugin>-->
    </plugins>

    <!--    定义数据库信息，默认使用 development 数据库构建环境-->
    <environments default="development">
        <environment id="development">
            <!--            jdbc事务管理-->
            <transactionManager type="JDBC">
                <property name="autoCommit" value="true"/>
            </transactionManager>
            <!--            数据库信息-->
            <dataSource type="POOLED">
                <property name="driver" value="${driver}"/>
                <property name="url" value="${url}"/>
                <property name="username" value="${username}"/>
                <property name="password" value="${password}"/>
            </dataSource>
        </environment>
    </environments>

    <databaseIdProvider type="DB_VENDOR">
        <property name="MySQL" value="mysql"/>
        <property name="SQL Server" value="sqlserver"/>
    </databaseIdProvider>

    <!--    定义映射器-->
    <mappers>
        <!--        sql和pojo 的映射规则定义，，mybatis解析这个xml，生成映射器 -->
<!--        <mapper resource="mapper/UserMapper.xml"/>-->

        <package name="com.cj.mapper"/>
    </mappers>
</configuration>

log4j.properties

log4j.rootLogger=DEBUG,stdout
log4j.logger.org.mybatis=DEBUG
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%5p %d %C: %m%n

jdbc.properties

driver=com.mysql.cj.jdbc.Driver
url=jdbc:mysql:///mybatisplus?serverTimezone=UTC
username=root
password=root

测试：

public interface UserMapper {
    @Select("select * from t_user")
    List<User> getAllUser();
}


    @Test
    public void test01() throws IOException {
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(Resources.getResourceAsStream("mybatis02.xml"));
        SqlSession sqlSession = factory.openSession();
        UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
        List<User> allUser = userMapper.getAllUser();
        System.out.println("allUser = " + allUser);
    }

引入插件：

<plugin interceptor="com.cj.plugin.QueryLimitPlugin">
    <property name="dbtype" value="mysql"/>
    <property name="limit" value="1"/>
</plugin>

总结

尽量不要用插件，插件生成的是层层代理对象的责任链模式，通过反射方法运行，性能不高
插件的代码要考虑全面，特别是多个插件层层代理的时候，要保证逻辑的正确性

mybatis插件

Configuration组成

Mapper映射器

SqlSession下的四大对象

Executor执行器

StatementHandler 数据库会话器

ParameterHandler 参数处理器

ResultSetHandler 结果处理器

SqlSession运行总结

插件

MetaObject 工具类使用

插件开发

总结

相关文章

Redis高并发锁（三）分布式锁

Arduino code for RS-365PW 16120

学生抢课接口(高并发入门)

【python游戏】新的一年快来变身兔兔战士打败獾守护兔兔吧~

C++中STL的vector扩容机制

Redis集群系列十 —— 集群伸缩之收缩

字符串大小写转化，有序数组二分查找个人心得等若干内容

在wsl下开发T113的主线linux（1）-准备wsl开发环境

MySQL隐式转换

2022年年终总结---新方向，新期待

力扣(LeetCode)2351. 第一个出现两次的字母(C++)

第二证券|72家公司接待机构过千，迈瑞医疗热度“断层领先”

记录NCNN Yolov5部署华为鸿蒙系统踩过的坑

使用 Bitnami Helm 安装 Kafka

LinuxShell注意事项

【Mongoose笔记】Websocket 服务器

Chromium Embedded Framework(CEF)源码编译基于windows

第三十二讲：神州交换机和路由器上分别实现QoS

深入浅出闭包

基于OpenSSL的安全Web Server实现