手撸Mybatis（三）——收敛SQL操作到SqlSession

2024-05-04 18:44
文章标签 sql 收敛 操作 mybatis database sqlsession

本文主要是介绍手撸Mybatis（三）——收敛SQL操作到SqlSession，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

本专栏的源码：https://gitee.com/dhi-chen-xiaoyang/yang-mybatis。

引言

在上一章中，我们实现了读取mapper配置并构造相关的mapper代理对象，读取mapper.xml文件中的sql信息等操作，现在，在上一章的基础上，我们接着开始链接数据库，通过封装JDBC，来实现我们数据库操作。

数据库准备

我们创建一个user表，用于后续进行测试，user表的结构如下图所示：
image.png
user表的内容如下：
image.png

添加User类

我们根据表结构，创建对应的user类，user类的结构如下：

package com.yang.mybatis.test;import java.io.Serializable;
import java.util.Date;public class User implements Serializable {private Integer id;private String userName;private String password;private Integer age;private Date createTime;public Integer getId() {return id;}public void setId(Integer id) {this.id = id;}public String getUserName() {return userName;}public void setUserName(String userName) {this.userName = userName;}public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}public Integer getAge() {return age;}public void setAge(Integer age) {this.age = age;}public Date getCreateTime() {return createTime;}public void setCreateTime(Date createTime) {this.createTime = createTime;}
}
JDBC基础操作

在使用jdbc之前，我们先引入mysql的依赖

<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.27</version></dependency>

jdbc的操作，一般分为下面几个步骤：
1）加载JDBC驱动程序
2）创建数据库链接
3）创建一个preparedStatement
4）执行SQL语句
5）遍历数据集
6）处理异常，关闭JDBC对象资源
示例代码如下：

 public static void main(String[] args) throws SQLException {String url = "jdbc:mysql://localhost:3306/test?useSSL=false";String username = "用户名";String password = "密码";Connection conn = null;try {// 1. 加载驱动Class.forName("com.mysql.cj.jdbc.Driver");// 2. 创建数据库链接conn = DriverManager.getConnection(url, username, password);conn.setAutoCommit(false);// 3. 创建preparedStatementString sql = "select user_name from user where id = ?";PreparedStatement preparedStatement = conn.prepareStatement(sql);preparedStatement.setInt(1, 1);// 4. 执行sqlResultSet resultSet = preparedStatement.executeQuery();// 5. 遍历结果if (resultSet.next()) {System.out.println(resultSet.getString(1));}conn.commit();} catch (SQLException | ClassNotFoundException e) {conn.rollback();e.printStackTrace();} finally {// 6. 释放连接conn.close();}}

执行上述代码，结果如下：
image.png

将sql操作，收敛到SqlSession

在上一章，当我们调用mapper的方法时，最终是通过在MapperProxy中获取对应的MybatisStatement，然后打印出sql信息的，但是如果后续操作数据库是，也在MapperProxy中执行sql的话，不太方便管理。因此，我们添加一个IMybatisSqlSession类，后续对于数据库的操作，收敛到此类进行。
首先，我们添加IMybatisSqlSession：

package com.yang.mybatis.session;public interface IMybatisSqlSession {<T> T execute(String method, Object parameter);<T> T getMapper(Class<T> type);
}

然后添加其默认实现：

package com.yang.mybatis.session;import com.yang.mybatis.proxy.MapperProxyFactory;public class DefaultMybatisSqlSession implements IMybatisSqlSession {private MapperProxyFactory mapperProxyFactory;public DefaultMybatisSqlSession(MapperProxyFactory mapperProxyFactory) {this.mapperProxyFactory = mapperProxyFactory;}@Overridepublic <T> T execute(String method, Object parameter) {return (T)("你被代理了!" + method + ",入参:" + parameter);}@Overridepublic <T> T getMapper(Class<T> type) {return (T) mapperProxyFactory.newInstance(type, this);}
}

添加IMybatisSqlSession的工厂接口

package com.yang.mybatis.session;public interface MybatisSqlSessionFactory {IMybatisSqlSession openSession();
}

添加工厂的默认实现：

package com.yang.mybatis.session;import com.yang.mybatis.proxy.MapperProxyFactory;public class DefaultMybatisSqlSessionFactory implements IMybatisSqlSessionFactory {private MapperProxyFactory mapperProxyFactory;public DefaultMybatisSqlSessionFactory(MapperProxyFactory mapperProxyFactory) {this.mapperProxyFactory = mapperProxyFactory;}@Overridepublic IMybatisSqlSession openSession() {return new DefaultMybatisSqlSession(mapperProxyFactory);}
}

修改MapperProxyFactory，在新建MapperProxy的时候，将imybatisSqlSession传递给MapperProxy。

package com.yang.mybatis.proxy;import com.yang.mybatis.config.MybatisConfiguration;
import com.yang.mybatis.session.IMybatisSqlSession;import java.lang.reflect.Proxy;public class MapperProxyFactory {private MybatisConfiguration mybatisConfiguration;public MapperProxyFactory(MybatisConfiguration mybatisConfiguration) {this.mybatisConfiguration = mybatisConfiguration;}public Object newInstance(Class mapperType, IMybatisSqlSession mybatisSqlSession) {MapperProxy mapperProxy = new MapperProxy(mapperType, mybatisSqlSession);return Proxy.newProxyInstance(mapperType.getClassLoader(),new Class[]{mapperType},mapperProxy);}public MybatisConfiguration getMybatisConfiguration() {return mybatisConfiguration;}public void setMybatisConfiguration(MybatisConfiguration mybatisConfiguration) {this.mybatisConfiguration = mybatisConfiguration;}
}

然后修改MapperProxy，在真正执行的时候，通过iMybatisSqlSession的execute，来执行sql操作，以此实现sql操作由iMybatisSqlSession来统一管理。

package com.yang.mybatis.proxy;import com.yang.mybatis.session.IMybatisSqlSession;import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;public class MapperProxy<T> implements InvocationHandler {private Class<T> mapperInterface;private IMybatisSqlSession sqlSession;public MapperProxy(Class<T> mapperInterface, IMybatisSqlSession mybatisSqlSession) {this.mapperInterface = mapperInterface;this.sqlSession = mybatisSqlSession;}@Overridepublic Object invoke(Object proxy, Method method, Object[] args) throws Throwable {if (Object.class.equals(method.getDeclaringClass())) {return method.invoke(this, args);}String methodName = this.mapperInterface.getName() + "." + method.getName();return sqlSession.execute(methodName, args);}
}

最后，我们添加sqlSession工厂类的创建者，通过创建者模式，来创建SqlSession工厂

package com.yang.mybatis.session;import com.yang.mybatis.config.MybatisConfiguration;
import com.yang.mybatis.config.MybatisSqlStatement;
import com.yang.mybatis.config.parser.IMybatisConfigurationParser;
import com.yang.mybatis.config.parser.IMybatisMapperParser;
import com.yang.mybatis.proxy.MapperProxyFactory;import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;public class MybatisSqlSessionFactoryBuilder {private IMybatisConfigurationParser mybatisConfigurationParser;private IMybatisMapperParser mybatisMapperParser;private String configPath;public IMybatisSqlSessionFactory buildSqlSessionFactory() {if (configPath == null || configPath.isEmpty()) {throw new RuntimeException("配置文件路径不合法==========");}if (this.mybatisMapperParser == null || this.mybatisConfigurationParser == null) {throw new RuntimeException("缺少解析器=======");}MybatisConfiguration mybatisConfiguration = mybatisConfigurationParser.parser(configPath);List<String> mapperPaths = mybatisConfiguration.getMapperPaths();for (String mapperPath : mapperPaths) {List<MybatisSqlStatement> mybatisSqlStatements = this.mybatisMapperParser.parseMapper(mapperPath);Map<String, List<MybatisSqlStatement>> mapperNameGroupMap = mybatisSqlStatements.stream().collect(Collectors.groupingBy(MybatisSqlStatement::getNamespace));for (Map.Entry<String, List<MybatisSqlStatement>> entry : mapperNameGroupMap.entrySet()) {String mapperName = entry.getKey();List<MybatisSqlStatement> sqlSessionList = entry.getValue();mybatisConfiguration.putMybatisSqlStatementList(mapperName, sqlSessionList);}}MapperProxyFactory mapperProxyFactory = new MapperProxyFactory(mybatisConfiguration);return new DefaultMybatisSqlSessionFactory(mapperProxyFactory);}public MybatisSqlSessionFactoryBuilder setConfigPath(String configPath) {this.configPath = configPath;return this;}public MybatisSqlSessionFactoryBuilder setMybatisConfigurationParser(IMybatisConfigurationParser iMybatisConfigurationParser) {this.mybatisConfigurationParser = iMybatisConfigurationParser;return this;}public MybatisSqlSessionFactoryBuilder setMybatisMapperParser(IMybatisMapperParser iMybatisMapperParser) {this.mybatisMapperParser = iMybatisMapperParser;return this;}
}

添加测试代码，进行测试：

package com.yang.mybatis.test;import com.yang.mybatis.config.parser.XmlMybatisConfigurationParser;
import com.yang.mybatis.config.parser.XmlMybatisMapperParser;
import com.yang.mybatis.session.IMybatisSqlSession;
import com.yang.mybatis.session.IMybatisSqlSessionFactory;
import com.yang.mybatis.session.MybatisSqlSessionFactoryBuilder;public class Main {public static void main(String[] args) {String configPath = "mybatis-config.xml";IMybatisSqlSessionFactory mybatisSqlSessionFactory = new MybatisSqlSessionFactoryBuilder().setMybatisMapperParser(new XmlMybatisMapperParser()).setMybatisConfigurationParser(new XmlMybatisConfigurationParser()).setConfigPath(configPath).buildSqlSessionFactory();IMybatisSqlSession mybatisSqlSession = mybatisSqlSessionFactory.openSession();IUserMapper userMapper = mybatisSqlSession.getMapper(IUserMapper.class);System.out.println(userMapper.queryUserName(1));}
}

image.png

SqlSession获取执行方法对应的sql语句

首先，修改MybatisConfiguration，之前是将每一个mapper和他所拥有的MybatisSqlStatement列表关联起来，现在感觉粒度太大，因此，该为每一个mapper的方法和对应的MybatisSqlStatement关联。

package com.yang.mybatis.config;import java.io.Serializable;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;public class MybatisConfiguration implements Serializable {private Map<String, MybatisEnvironment> id2EnvironmentMap = new HashMap<>();private MybatisEnvironment defaultMybatisEnvironment;private List<String> mapperPaths = new ArrayList<>();private Map<String, MybatisSqlStatement> mapperMethod2SqlStatementsMap = new HashMap<>();public void putMapperMethod2MybatisSqlStatement(String mapperMethod, MybatisSqlStatement mybatisSqlStatement) {this.mapperMethod2SqlStatementsMap.put(mapperMethod, mybatisSqlStatement);}public MybatisSqlStatement getMybatisSqlStatement(String mapperMethod) {return this.mapperMethod2SqlStatementsMap.get(mapperMethod);}public Map<String, MybatisSqlStatement> getMapperMethod2SqlStatementsMap() {return this.mapperMethod2SqlStatementsMap;}public void addEnvironment(String id, MybatisEnvironment mybatisEnvironment) {this.id2EnvironmentMap.put(id, mybatisEnvironment);}public MybatisEnvironment getEnvironment(String id) {return id2EnvironmentMap.get(id);}public MybatisEnvironment getDefaultMybatisEnvironment() {return defaultMybatisEnvironment;}public void setDefaultMybatisEnvironment(MybatisEnvironment defaultMybatisEnvironment) {this.defaultMybatisEnvironment = defaultMybatisEnvironment;}public void addMapperPath(String mapperPath) {this.mapperPaths.add(mapperPath);}public List<String> getMapperPaths() {return this.mapperPaths;}public List<MybatisEnvironment> getEnvironments() {return new ArrayList<>(id2EnvironmentMap.values());}}

然后修改MybatisSqlSessionFactoryBuilder:

package com.yang.mybatis.session;import com.yang.mybatis.config.MybatisConfiguration;
import com.yang.mybatis.config.MybatisSqlStatement;
import com.yang.mybatis.config.parser.IMybatisConfigurationParser;
import com.yang.mybatis.config.parser.IMybatisMapperParser;
import com.yang.mybatis.proxy.MapperProxyFactory;import java.util.List;public class MybatisSqlSessionFactoryBuilder {private IMybatisConfigurationParser mybatisConfigurationParser;private IMybatisMapperParser mybatisMapperParser;private String configPath;public IMybatisSqlSessionFactory buildSqlSessionFactory() {if (configPath == null || configPath.isEmpty()) {throw new RuntimeException("配置文件路径不合法==========");}if (this.mybatisMapperParser == null || this.mybatisConfigurationParser == null) {throw new RuntimeException("缺少解析器=======");}MybatisConfiguration mybatisConfiguration = mybatisConfigurationParser.parser(configPath);List<String> mapperPaths = mybatisConfiguration.getMapperPaths();for (String mapperPath : mapperPaths) {List<MybatisSqlStatement> mybatisSqlStatements = this.mybatisMapperParser.parseMapper(mapperPath);for (MybatisSqlStatement mybatisSqlStatement : mybatisSqlStatements) {String methodName = mybatisSqlStatement.getNamespace() + "." + mybatisSqlStatement.getId();mybatisConfiguration.putMapperMethod2MybatisSqlStatement(methodName, mybatisSqlStatement);}}MapperProxyFactory mapperProxyFactory = new MapperProxyFactory(mybatisConfiguration);return new DefaultMybatisSqlSessionFactory(mapperProxyFactory);}public MybatisSqlSessionFactoryBuilder setConfigPath(String configPath) {this.configPath = configPath;return this;}public MybatisSqlSessionFactoryBuilder setMybatisConfigurationParser(IMybatisConfigurationParser iMybatisConfigurationParser) {this.mybatisConfigurationParser = iMybatisConfigurationParser;return this;}public MybatisSqlSessionFactoryBuilder setMybatisMapperParser(IMybatisMapperParser iMybatisMapperParser) {this.mybatisMapperParser = iMybatisMapperParser;return this;}
}

修改DefaultMybatisSqlSession类，获取方法对应的MybatisStatement

package com.yang.mybatis.session;import com.yang.mybatis.config.MybatisSqlStatement;
import com.yang.mybatis.proxy.MapperProxyFactory;public class DefaultMybatisSqlSession implements IMybatisSqlSession {private MapperProxyFactory mapperProxyFactory;public DefaultMybatisSqlSession(MapperProxyFactory mapperProxyFactory) {this.mapperProxyFactory = mapperProxyFactory;}@Overridepublic <T> T execute(String method, Object parameter) {MybatisSqlStatement mybatisSqlStatement = this.mapperProxyFactory.getMybatisConfiguration().getMybatisSqlStatement(method);return (T)("method:" + method + "sql:"+ mybatisSqlStatement.getSql() + ",入参:" + parameter);}@Overridepublic <T> T getMapper(Class<T> type) {return (T) mapperProxyFactory.newInstance(type, this);}
}

添加测试方法进行测试：

 public static void main(String[] args) {String configPath = "mybatis-config.xml";MybatisSqlSessionFactory mybatisSqlSessionFactory = new MybatisSqlSessionFactoryBuilder().setMybatisMapperParser(new XmlMybatisMapperParser()).setMybatisConfigurationParser(new XmlMybatisConfigurationParser()).setConfigPath(configPath).buildSqlSessionFactory();IMybatisSqlSession mybatisSqlSession = mybatisSqlSessionFactory.openSession();IUserMapper userMapper = mybatisSqlSession.getMapper(IUserMapper.class);System.out.println(userMapper.queryUserAge(1));}

测试结果如下：
image.png

参考文章

https://blog.csdn.net/weixin_43520450/article/details/107230205

这篇关于手撸Mybatis（三）——收敛SQL操作到SqlSession的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/959857。

相关文章

python panda库从基础到高级操作分析

python panda库从基础到高级操作分析

《pythonpanda库从基础到高级操作分析》本文介绍了Pandas库的核心功能,包括处理结构化数据的Series和DataFrame数据结构,数据读取、清洗、分组聚合、合并、时间序列分析及大数据... 目录1. Pandas 概述2. 基本操作：数据读取与查看3. 索引操作：精准定位数据4. Group
阅读更多...
破茧 JDBC:MyBatis 在 Spring Boot 中的轻量实践指南

破茧 JDBC:MyBatis 在 Spring Boot 中的轻量实践指南

《破茧JDBC:MyBatis在SpringBoot中的轻量实践指南》MyBatis是持久层框架,简化JDBC开发,通过接口+XML/注解实现数据访问,动态代理生成实现类,支持增删改查及参数... 目录一、什么是 MyBATis二、 MyBatis 入门2.1、创建项目2.2、配置数据库连接字符串2.3、入
阅读更多...
MySQL中EXISTS与IN用法使用与对比分析

MySQL中EXISTS与IN用法使用与对比分析

《MySQL中EXISTS与IN用法使用与对比分析》在MySQL中,EXISTS和IN都用于子查询中根据另一个查询的结果来过滤主查询的记录,本文将基于工作原理、效率和应用场景进行全面对比... 目录一、基本用法详解1. IN 运算符2. EXISTS 运算符二、EXISTS 与 IN 的选择策略三、性能对比
阅读更多...
MySQL常用字符串函数示例和场景介绍

MySQL常用字符串函数示例和场景介绍

《MySQL常用字符串函数示例和场景介绍》MySQL提供了丰富的字符串函数帮助我们高效地对字符串进行处理、转换和分析,本文我将全面且深入地介绍MySQL常用的字符串函数,并结合具体示例和场景,帮你熟练... 目录一、字符串函数概述1.1 字符串函数的作用1.2 字符串函数分类二、字符串长度与统计函数2.1
阅读更多...
SQL Server跟踪自动统计信息更新实战指南

SQL Server跟踪自动统计信息更新实战指南

《SQLServer跟踪自动统计信息更新实战指南》本文详解SQLServer自动统计信息更新的跟踪方法,推荐使用扩展事件实时捕获更新操作及详细信息,同时结合系统视图快速检查统计信息状态,重点强调修... 目录SQL Server 如何跟踪自动统计信息更新：深入解析与实战指南 核心跟踪方法1️⃣ 利用系统目录
阅读更多...
MySQL 内存使用率常用分析语句

MySQL 内存使用率常用分析语句

《MySQL内存使用率常用分析语句》用户整理了MySQL内存占用过高的分析方法,涵盖操作系统层确认及数据库层bufferpool、内存模块差值、线程状态、performance_schema性能数据... 目录一、 OS层二、 DB层1. 全局情况2. 内存占js用详情最近连续遇到mysql内存占用过高导致
阅读更多...
Python操作PDF文档的主流库使用指南

Python操作PDF文档的主流库使用指南

《Python操作PDF文档的主流库使用指南》PDF因其跨平台、格式固定的特性成为文档交换的标准,然而,由于其复杂的内部结构,程序化操作PDF一直是个挑战,本文主要为大家整理了Python操作PD... 目录一、 基础操作1.PyPDF2 (及其继任者 pypdf)2.PyMuPDF / fitz3.Fre
阅读更多...
Mysql中设计数据表的过程解析

Mysql中设计数据表的过程解析

《Mysql中设计数据表的过程解析》数据库约束通过NOTNULL、UNIQUE、DEFAULT、主键和外键等规则保障数据完整性,自动校验数据,减少人工错误,提升数据一致性和业务逻辑严谨性,本文介绍My... 目录1.引言2.NOT NULL——制定某列不可以存储NULL值2.UNIQUE——保证某一列的每一
阅读更多...
解密SQL查询语句执行的过程

解密SQL查询语句执行的过程

《解密SQL查询语句执行的过程》文章讲解了SQL语句的执行流程,涵盖解析、优化、执行三个核心阶段,并介绍执行计划查看方法EXPLAIN,同时提出性能优化技巧如合理使用索引、避免SELECT*、JOIN... 目录1. SQL语句的基本结构2. SQL语句的执行过程3. SQL语句的执行计划4. 常见的性能优
阅读更多...
Python对接支付宝支付之使用AliPay实现的详细操作指南

Python对接支付宝支付之使用AliPay实现的详细操作指南

《Python对接支付宝支付之使用AliPay实现的详细操作指南》支付宝没有提供PythonSDK,但是强大的github就有提供python-alipay-sdk,封装里很多复杂操作,使用这个我们就... 目录一、引言二、准备工作2.1 支付宝开放平台入驻与应用创建2.2 密钥生成与配置2.3 安装ali
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2