全面解析@InsertProvider执行原理

目录
  • @InsertProvider执行原理
    • 1.首先要拼接处insert语句
  • 2.ProviderSqlSource实现了sqlSource接口
  • 关于@Insert和@InsertProvider注解用法
    • 1.项目主要结构
    • 2.下面以BlogMapper中的保存Blog实体方法为例

@InsertProvider执行原理

1.首先要拼接处insert语句

其中包含入参,与数据库表字段的映射字段。

在执行Provider类里面的动态插入sql的时候,程序会调用 AbstractSQL这个抽象类,执行里面的两个拼接字符串的方法

    public T INSERT_INTO(String tableName) {
        this.sql().statementType = AbstractSQL.SQLStatement.StatementType.INSERT;
        this.sql().tables.add(tableName);
        return this.getSelf();
    }

    public T VALUES(String columns, String values) {
        this.sql().columns.add(columns);
        this.sql().values.add(values);
        return this.getSelf();
    }

这个抽象class里面有一个私有的静态类SQLStatement和私有静态SalfAppendable类。

SQLStatement类里面有一个共有静态枚举类,里面有它的一个私有构造函数,枚举被设计成是单例模式,即枚举类型会由JVM在加载的时候,实例化枚举对象,你在枚举类中定义了多少个就会实例化多少个,JVM为了保证每一个枚举类元素的唯一实例,是不会允许外部进行new的,所以会把构造函数设计成private,防止用户生成实例,破坏唯一性。

枚举类里面含有增删查改四种。私有的静态类SQLStatement有sql语句的各种关键字list,distinct是boolean类型,例如:

   List<String> sets = new ArrayList();

子类ArrayList实例化List,因为List是一个接口,所以只能依靠其“子类”(在这里是List的实现类)来进行实例化,这里的对象是List的对象。

  private void sqlClause(AbstractSQL.SafeAppendable builder, String keyword, List<String> parts, String open, String close, String conjunction) {
            if(!parts.isEmpty()) {
                if(!builder.isEmpty()) {
                    builder.append("\n");
                }

                builder.append(keyword);
                builder.append(" ");
                builder.append(open);
                String last = "________";
                int i = 0;

                for(int n = parts.size(); i < n; ++i) {
                    String part = (String)parts.get(i);
                    if(i > 0 && !part.equals(") \nAND (") && !part.equals(") \nOR (") && !last.equals(") \nAND (") && !last.equals(") \nOR (")) {
                        builder.append(conjunction);
                    }

                    builder.append(part);
                    last = part;
                }

                builder.append(close);
            }
        }

上面这个函数就是增删查改通用的sql解析函数。

下面是增调用的函数

  private String insertSQL(AbstractSQL.SafeAppendable builder) {
            this.sqlClause(builder, "INSERT INTO", this.tables, "", "", "");
            this.sqlClause(builder, "", this.columns, "(", ")", ", ");
            this.sqlClause(builder, "VALUES", this.values, "(", ")", ", ");
            return builder.toString();
        }

通过下面的函数确定增删查改对应调用的函数

 public String sql(Appendable a) {
            AbstractSQL.SafeAppendable builder = new AbstractSQL.SafeAppendable(a);
            if(this.statementType == null) {
                return null;
            } else {
                String answer;
                switch(null.$SwitchMap$org$apache$ibatis$jdbc$AbstractSQL$SQLStatement$StatementType[this.statementType.ordinal()]) {
                case 1:
                    answer = this.deleteSQL(builder);
                    break;
                case 2:
                    answer = this.insertSQL(builder);
                    break;
                case 3:
                    answer = this.selectSQL(builder);
                    break;
                case 4:
                    answer = this.updateSQL(builder);
                    break;
                default:
                    answer = null;
                }

                return answer;
            }
        }

私有静态SalfAppendable类是进行sql字符串的拼接。

里面有是一个私有不可以改变的Appendable对象。

 private static class SafeAppendable {
        private final Appendable a;
        private boolean empty = true;

        public SafeAppendable(Appendable a) {
            this.a = a;
        }

        public AbstractSQL.SafeAppendable append(CharSequence s) {
            try {
                if(this.empty && s.length() > 0) {
                    this.empty = false;
                }

                this.a.append(s);
                return this;
            } catch (IOException var3) {
                throw new RuntimeException(var3);
            }
        }

        public boolean isEmpty() {
            return this.empty;
        }
    }

然后调用ProviderSqlSource类,接着调用不可变类MappedStatement类,再调用BaseStatementHandler类,--->PreparedStatementHandler等。

2.ProviderSqlSource实现了sqlSource接口

代表从注解中读取相关的映射语句的内容,它创建的sql会被传到数据库。

根据SQL语句的类型不同,mybatis提供了多种SqlSource的具体实现:

1)StaticSqlSource:最终静态SQL语句的封装,其他类型的SqlSource最终都委托给StaticSqlSource。

2)RawSqlSource:原始静态SQL语句的封装,在加载时就已经确定了SQL语句,没有、等动态标签和${} SQL拼接,比动态SQL语句要快,因为不需要运行时解析SQL节点。

3)DynamicSqlSource:动态SQL语句的封装,在运行时需要根据参数处理、等标签或者${} SQL拼接之后才能生成最后要执行的静态SQL语句。

4)ProviderSqlSource:当SQL语句通过指定的类和方法获取时(使用@XXXProvider注解),需要使用本类,它会通过反射调用相应的方法得到SQL语句

关于@Insert和@InsertProvider注解用法

@Insert和@InsertProvider都是用来在实体类的Mapper类里注解保存方法的SQL语句。

不同的是,@Insert是直接配置SQL语句,而@InsertProvider则是通过SQL工厂类及对应的方法生产SQL语句,这种方法的好处在于,我们可以根据不同的需求生产出不同的SQL,适用性更好。

1.项目主要结构

(1)项目中的实体类

(2)每个实体类对应的Mapper方法

(3)SQL工厂

2.下面以BlogMapper中的保存Blog实体方法为例

Blog实体类属性:

为了方便说明,属性不设置过多,假设Blog类的属性有blogId,title,author

(1)@Insert的注解方式

@Insert("insert into blog(blogId,title,author) values(#blogId,#title,#author)")
public boolean saveBlog(Blog blog);

说明:由于我们不能确定哪些属性没有值,那只能把所有属性都写上了。

(2)@InsertProvider的注解方式

@InsertProvider(type = SqlFactory.class,method = "insertBlog")
public boolean saveBlog(@Param("bean")Blog blog);

说明:type指明SQL工厂类,method是工厂类里对应的方法

SqlFactory类代码:

public class SqlFactory {
    public String insertBlog(Map<String,Object> para){
        Blog blog = (Blog)para.get("bean"); //
        SQL sql = new SQL(); //SQL语句对象,所在包:org.apache.ibatis.jdbc.SQL
        sql.INSERT_INTO("blog");
        if(blog.getBlogId() != null){ //判断blogId属性是否有值
            sql.VALUES("blogId", blog.getBlogId());
        }

        if(blog.getTitle() != null){//判断title属性是否有值
            sql.VALUES("title", blog.getTitle());
        }

        if(blog.getAuthor() != null){//判断author属性是否有值
            sql.VALUES("author", blog.getAuthor());
        }
        return sql.toString();
}
}

使用@InsertProvider的方式,可以根据实体中有值的属性,进行动态的生成插入SQL语句如:

  • blogId和title有值:insert into blog(blogId,title) values(v1,v2);
  • author和title有值:insert into blog(author,title) values(v1,v2);

总结:其实也就是说因为mybaits的xml中有<if test=""></if>标签来动态生成sql,但是在程序代码中没有办法这么做。

那么insertprovider就是充当了这样一个角色,来动态的生成sql。

与之类似的还有MyBatis注解的巧妙使用---@InsertProvider,@UpdateProvider,@DeleteProvider和@SelectProvider等等。

以上为个人经验,希望能给大家一个参考,也希望大家多多支持我们。

(0)

相关推荐

  • Mapper批量插入Oracle数据@InsertProvider注解

    Mapper: @Mapper @OracleRepository public interface OracleRadiusMapper{ @InsertProvider(type = OracleRadiusProvider.class , method = "insertRadiusDataBatch") int insertRadiusDataBatch(@Param("list")List<AcctInfo> acctInfoList); }

  • MyBatis注解开发-@Insert和@InsertProvider的使用

    目录 @Insert和@InsertProvider的使用 使用InsertProvider注解报错解决过程 @Insert和@InsertProvider的使用 首先,在mybatis-generator.xml中配置返回主键 UserMapper中的 @SelectKey:返回主键,具体解释见下面说明 @InsertProvider:type指明SQL工厂类,method是工厂类里对应的方法 @SelectKey注解源码 statement是要运行的SQL语句,它的返回值通过resultTy

  • mybatis @InsertProvider报错问题及解决

    目录 使用@Provider注意事项(要点) 直接上错误 代码截图如下 同时看到控制台报错日志(因为项目加载项比较多,前面日志被覆盖掉了) 总结 使用@Provider注意事项(要点) 1.在Mapper接口和@InsertProvider方法类中,不要使用重载,也就是说,不要使用方法名相同参数不同的方法(使用mapper.xml同理). 2.InsertProvider method参数指定的方法,必须是public的,返回值必须为String,可以为static. 3.Mapper接口中@I

  • 全面解析@InsertProvider执行原理

    目录 @InsertProvider执行原理 1.首先要拼接处insert语句 2.ProviderSqlSource实现了sqlSource接口 关于@Insert和@InsertProvider注解用法 1.项目主要结构 2.下面以BlogMapper中的保存Blog实体方法为例 @InsertProvider执行原理 1.首先要拼接处insert语句 其中包含入参,与数据库表字段的映射字段. 在执行Provider类里面的动态插入sql的时候,程序会调用 AbstractSQL这个抽象类,

  • 基于servlet的执行原理与生命周期(全面解析)

    一.先从servlet容器说起:大家最为熟悉的servlet容器就是Tomcat ,Servlet 容器是如何管理 Servlet? 先看一下tomcat的容器模型: 从上图可以看出 Tomcat 的容器分为四个等级,真正管理Servlet 的容器是Context 容器,一个 Context 对应一个 Web 工程 Tomcat 的容器等级中,Context 容器是直接管理 Servlet 在容器中的包装类Wrapper(StandardWrapper)的容器,所以 Context 容器如何运行

  • 输入npm run xxx后执行原理深入解析

    目录 前言 总结 前言 当我们输入npm run XXX会首先去package.json文件里找scripts 里找对应的xxx,然后执行 xxx的命令,例如我下面这个项目输入npm run dev就会执行vue-cli-service serve 这条命令. package.json文件 那么问题来了: 为什么不直接执行vue-cli-service serve而要执行npm run serve 呢? 因为 直接执行vue-cli-service serve,会报错,因为操作系统中没有存在vu

  • mybatis-plugin插件执行原理解析

    mybatis-plugin插件执行原理 今天主要是在看mybatis的主流程源码,其中比较感兴趣的是mybatis的plugin功能,这里主要记录下mybatis-plugin的插件功能原理. plugin集合列表:在构建SqlSessionFactory时,通过解析配置或者plugin-bean的注入,会将所有的mybatis-plugin都收集到Configuration对象的interceptorChain属性中.InterceptorChain类定义如下: public class I

  • react fiber执行原理示例解析

    目录 为什么要使用fiber,要解决什么问题? fiber是什么? 数据结构 执行单元 浏览器工作: Fiber执行原理 workInProgress tree: currentFiber tree: Effects list: render阶段: 遍历节点过程: 收集effect list: commit阶段: 为什么commit必须是同步的操作的? 为什么要使用fiber,要解决什么问题? 在 react16 引入 Fiber 架构之前,react 会采用递归方法对比两颗虚拟DOM树,找出需

  • JS异步的执行原理和回调详解

    一.JS异步的执行原理   我们知道JavaScript是单线程的,而浏览器是多线程的.单线程执行任务需要一个个排队进行,假如一个任务需要很长时间执行(像ajax需要较长时间),会直接导致无响应,后面的任务一直在等待执行.这时候就需要用到异步.   想了解异步,首先我们要知道浏览器有最基本的三个常驻线程: JS引擎线程,事件触发线程,GUI渲染线程.   其中JS引擎线程和事件触发线程共同构成了一种事件循环机制,而GUI渲染线程与JS引擎是互斥的,当JS引擎执行时GUI线程会被挂起,GUI更新保

  • 详解PHP的执行原理和流程

    简介 先看看下面这个过程: • 我们从未手动开启过PHP的相关进程,它是随着Apache的启动而运行的: • PHP通过mod_php5.so模块和Apache相连(具体说来是SAPI,即服务器应用程序编程接口): • PHP总共有三个模块:内核.Zend引擎.以及扩展层: • PHP内核用来处理请求.文件流.错误处理等相关操作: • Zend引擎(ZE)用以将源文件转换成机器语言,然后在虚拟机上运行它: • 扩展层是一组函数.类库和流,PHP使用它们来执行一些特定的操作.比如,我们需要mysq

  • 解析Java8 Stream原理

    目录 一.前言 二.Stream流水线解决方案 2.1.操作如何记录 2.2.操作如何叠加 2.3.叠加之后的操作如何执行 一.前言 首先我们先看一个使用Stream API的示例,具体代码如下: 这是个很简单的一个Stream使用例子,我们过滤掉空字符串后,转成int类型并计算出最大值,这其中包括了三个操作:filter.mapToInt.sum.相信大多数人再刚使用Stream API的时候都会有个疑问,Stream是指怎么实现的,是每一次函数调用就执行一次迭代吗?答案肯定是否,因为如果真的

  • 解析Redis Cluster原理

    目录 一.前言 二.为什么需要Redis Cluster 三.Redis Cluster是什么 四.节点负载均衡 五.什么是一致性哈希 六.虚拟节点机制 七.Redis Cluster采用的什么算法 八.Redis Cluster如何做到高可用 8.1.集群如何进行扩容 8.2.高可用及故障转移 九.简单了解gossip协议 十.gossip协议消息类型 十一.使用gossip的优劣 十二.总结 一.前言 Sentinel集群会对Redis的主从架构中的Redis实例进行监控,一旦发现了mast

  • 解析Tomcat架构原理到架构设计

    目录 一.学习目的 1.1.掌握 Tomcat 架构设计与原理提高内功 1.2.宏观理解一个请求如何与 Spring 联系起来 1.3.提升自己的系统设计能力 二.整体架构设计 2.1.连接器 2.2.封装变与不变 2.3.容器 2.4.请求定位 Servlet 的过程 三.Tomcat 为何打破双亲委派机制 3.1.双亲委派 3.2.Tomcat 热加载 3.3.Tomcat 的类加载器 3.4.Tomcat 类加载器层次 四.整体架构设计解析收获总结 4.1.连接器 4.2.容器 4.3.类

随机推荐