解析Mybatis Porxy动态代理和sql解析替换问题
JDK常用核心原理
概述
在 Mybatis 中,常用的作用就是讲数据库中的表的字段映射为对象的属性,在进入Mybatis之前,原生的 JDBC 有几个步骤:导入 JDBC 驱动包,通过 DriverManager 注册驱动,创建连接,创建 Statement,增删改查,操作结果集,关闭连接
过程详解
首先进行类的加载,通过 DriverManager 注册驱动
Class.forName("com.mysql.jdbc.Driver"); Connection connection = DriverManager.getConnection("");
为什么在这里可以直接注册进去,com.mysql.jdbc.Driver 被加载到 Driver.class ,在 DriverManager 中,首先有一个静态代码块来进行初始化加载 Driver
static { loadInitialDrivers(); println("JDBC DriverManager initialized"); }
通过 loadInitialDrivers(),来加载 Driver,拿出 jdbc.drivers,通过 ServiceLoader 读取 Driver.class,读取拿出 driver 和 所有迭代器,一直迭代
private static void loadInitialDrivers() { String drivers; // 访问修饰符,在这里把 jdbc.drivers 拿出来 try { drivers = AccessController.doPrivileged(new PrivilegedAction<String>() { public String run() { return System.getProperty("jdbc.drivers"); } }); } catch (Exception ex) { drivers = null; } AccessController.doPrivileged(new PrivilegedAction<Void>() { public Void run() { // 读取拿出 driver 和 所有迭代器 ServiceLoader<Driver> loadedDrivers = ServiceLoader.load(Driver.class); Iterator<Driver> driversIterator = loadedDrivers.iterator(); // 一直进行迭代 try{ while(driversIterator.hasNext()) { driversIterator.next(); } } catch(Throwable t) { // Do nothing } return null; } }); println("DriverManager.initialize: jdbc.drivers = " + drivers); if (drivers == null || drivers.equals("")) { return; } String[] driversList = drivers.split(":"); println("number of Drivers:" + driversList.length); for (String aDriver : driversList) { try { println("DriverManager.Initialize: loading " + aDriver); Class.forName(aDriver, true, ClassLoader.getSystemClassLoader()); } catch (Exception ex) { println("DriverManager.Initialize: load failed: " + ex); } } }
从 Driver 加载完后,就可以得到一个和数据库的连接 connection ,connection 就可以创建一个 Statement,Statement 就可以进行执行 sql 语句,将结果返回一个结果集,获取出来的结果集遍历放进一个 List 集合中
Statement statement = connection.createStatement(); ResultSet resultSet = statement.executeQuery("select * from mybatis.user"); while (resultSet.next()) { int id = resultSet.getInt(1); String username = resultSet.getString(2); list.add(new User(id,username)); }
在原生的 JDBC 直接操作中,繁杂的步骤在业务代码中不会使用,而 Mybatis 可以在更好的便利度上使用
JDK动态代理
sql语句解析替换
在 JDK 动态代理中,利用了 Proxy 这个类来实现,在 Proxy 中,有着 newProxyInstance() 方法,创建一个动态代理实例
interface UserMapper { @Select("select * from mybatis.user where id =#{id}") List<User> selectUserList(); } public static void main(String[] args) { UserMapper userMapper = (UserMapper) Proxy.newProxyInstance( JDKMybatis.class.getClassLoader(), new Class<?>[]{UserMapper.class}, new InvocationHandler() { /** * 在 invoke() 方法中就可以进行查找 method,args * @param proxy 动态代理 * @param method 方法 * @param args 参数 */ @Override public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { // 把注解类获取,可以查出注解的值等多种其他值 Select annotation = method.getAnnotation(Select.class); if (annotation != null) { String[] value = annotation.value(); System.out.println(Arrays.toString(value)); } return null; } }); userMapper.selectUserList(1); }
newProxyInstance() 的创建需要三个参数,查看源码,可以知道需要 ClassLoader 类加载器,interfaces 接口(Mapper 接口),InvocationHandler 处理器,来进行处理
public static Object newProxyInstance(ClassLoader loader, Class<?>[] interfaces, InvocationHandler h)
把 sql 语句中的参数取出来放进 args,这时需要一个 Map 来进行传值
问题
当在通过反射获取方法的参数名,method.getParameters() 获取出来的参数都是 arg0,arg1...无意义参数
在Java8之前,代码编译为class文件后,方法参数的类型是固定的,但参数名称却丢失了,在编译的时候,需要有编译的选项,javac -parameters 默认是关闭的,需要在 idea 中设置开启,开启完成后,重新编译源文件
这种方式只能临时解决当前环境设置,在其他人运行代码时还是要重新设置
另一种解决方式,在pom文件中添加编译参数:
<plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <configuration> <compilerArgument>-parameters</compilerArgument> <source>1.8</source> <target>1.8</target> </configuration> </plugin> </plugins>
编译完成后,重新执行,再次通过method.getParameters()获取参数:
解析原来的 sql ,就要把 #{} 给替换掉,这时候可以使用 StringBuffer 类来实现替换
private static String parseSql(String sql, Map<String, Object> argsNameMap) { // 定义为常量数组 char[] str = {'#', '{'}; StringBuilder stringBuilder = new StringBuilder(); for (int i = 0; i < sql.length(); i++) { char aloneParseSql = sql.charAt(i); if (str[0] == aloneParseSql) { int nextIndex = i + 1; char nextChar = sql.charAt(nextIndex); // # 后应该是 { ,不匹配直接抛出异常 if (str[1] != nextChar) { throw new RuntimeException(String.format( "此处应该是:#{\n sql:%s\n index:%d", stringBuilder.toString(), nextIndex)); } /* 1 已经解析完的下标 2 解析完的 #{} 内的参数名 3 把对应的 argsName 的值 argsValue 取出来 4 追加到原来的 stringBuilder 中的 sql 语句后面 */ StringBuilder partStringBuilder = new StringBuilder(); i = partParseSql(partStringBuilder, sql, nextIndex); String argsName = partStringBuilder.toString(); Object argsValue = argsNameMap.get(argsName); stringBuilder.append(argsValue.toString()); } // 如果没有条件,直接追加 stringBuilder.append(aloneParseSql); } return stringBuilder.toString(); }
在其中需要把需要替换的值,再用 StringBuffer 类来实现
private static int partParseSql(StringBuilder partStringBuilder, String sql, int nextIndex) { // 由于 nextIndex 当前指针指向的是 { 所以要加一位,把后面内容解析 nextIndex++; char[] str = {'}'}; for (; nextIndex < sql.length(); nextIndex++) { char indexSql = sql.charAt(nextIndex); if (str[0] != indexSql) { partStringBuilder.append(indexSql); } if (str[0] == indexSql) { return nextIndex; } } throw new RuntimeException(String.format( "缺少:}\n index:%d", nextIndex)); }
再重新在 invoke 方法中进行调用,完成 sql 语句的动态拼装
@Override public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { // 把注解类获取,可以查出注解的值等多种其他值 Select annotation = method.getAnnotation(Select.class); Map<String, Object> argsNameMap = MapBuildArgsName(method, args); if (annotation != null) { String[] value = annotation.value(); String sql = value[0]; sql = parseSql(sql, argsNameMap); System.out.println(sql); } return null; }
到此这篇关于Mybatis(一)Porxy动态代理和sql解析替换的文章就介绍到这了,更多相关Mybatis(一)Porxy动态代理和sql解析替换内容请搜索猪先飞以前的文章或继续浏览下面的相关文章希望大家以后多多支持猪先飞!
相关文章
- 本文给大家分享C#连接SQL数据库和查询数据功能的操作技巧,本文通过图文并茂的形式给大家介绍的非常详细,需要的朋友参考下吧...2021-05-17
- 这篇文章主要介绍了Mybatis Plus select 实现只查询部分字段的操作,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-09-01
- 这篇文章主要介绍了MySQL性能监控软件Nagios的安装及配置教程,这里以CentOS操作系统为环境进行演示,需要的朋友可以参考下...2015-12-14
- 这篇文章主要介绍了PostgreSQL判断字符串是否包含目标字符串的多种方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-02-23
- 这篇文章主要介绍了解决Mybatis 大数据量的批量insert问题,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-01-09
- 这篇文章主要介绍了mybatis的Configuration详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-11-04
- 这篇文章主要介绍了PostgreSQL TIMESTAMP类型 时间戳操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-12-26
- 新版 Mysql 中加入了对 JSON Document 的支持,可以创建 JSON 类型的字段,并有一套函数支持对JSON的查询、修改等操作,下面就实际体验一下...2016-08-23
mybatis 返回Integer,Double,String等类型的数据操作
这篇文章主要介绍了mybatis 返回Integer,Double,String等类型的数据操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-11-25- 这篇文章主要介绍了postgresql 实现多表关联删除操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-01-02
- 这篇文章主要介绍了Postgresl 如何选择正确的关闭模式,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-01-18
深入研究mysql中的varchar和limit(容易被忽略的知识)
为什么标题要起这个名字呢?commen sence指的是那些大家都应该知道的事情,但往往大家又会会略这些东西,或者对这些东西一知半解,今天我总结下自己在mysql中遇到的一些commen sense类型的问题。 ...2015-03-15- 这篇文章主要介绍了MySQL 字符串拆分操作(含分隔符的字符串截取),具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-02-22
- 这篇文章主要介绍了postgresql数据添加两个字段联合唯一的操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-02-04
- 一、先说一下为什么要分表:当一张的数据达到几百万时,你查询一次所花的时间会变多,如果有联合查询的话,有可能会死在那儿了。分表的目的就在于此,减小数据库的负担,缩短查询时间。根据个人经验,mysql执行一个sql的过程如下:1...2014-05-31
- 这篇文章主要介绍了node.js如何操作MySQL数据库,帮助大家更好的进行web开发,感兴趣的朋友可以了解下...2020-10-29
- 这篇文章主要介绍了PostgreSQL 字符串处理与日期处理操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-02-01
- 我们自己鼓捣mysql时,总免不了会遇到这个问题:插入中文字符出现乱码,虽然这是运维先给配好的环境,但是在自己机子上玩的时候咧,总得知道个一二吧,不然以后如何优雅的吹牛B。...2015-03-15
- 这篇文章主要介绍了Vscode上使用SQL的方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-01-26
- 这几天在centos下装mysql,这里记录一下安装的过程,方便以后查阅Mysql5.5.37安装需要cmake,5.6版本开始都需要cmake来编译,5.5以后的版本应该也要装这个。安装cmake复制代码 代码如下: [root@local ~]# wget http://www.cm...2015-03-15