目录

• 一、JDBC操作数据库_问题分析
• 二、自定义持久层框架_思路分析
• 三、自定义框架_编码
• • 1、加载配置文件
  • 2、创建两个配置类对象
  • 3、解析配置文件，填充配置类对象
  • 4、创建SqlSessionFactory工厂接口及DefaultSqlSessionFactory实现类
  • 5、创建SqlSession会话接口及DefaultSqlSession实现类
  • 6、创建Executor执行器接口及SimpleExecutor实现类
  • 7、项目使用端利用自定义框架测试
• 四、自定义框架_优化
• • 1、优化思路
  • 2、优化代码
  • 3、优化后测试
• 五、Spring整合优化
• 六、gitee代码

一、JDBC操作数据库_问题分析

JDBC使用流程

1. 加载数据库驱动
2. 创建数据库连接
3. 创建编译对象
4. 设置入参执行SQL
5. 返回结果集

代码示例

public class JDBCTest {public static void main(String[] args) throws Exception {Connection connection = null;PreparedStatement preparedStatement = null;ResultSet resultSet = null;try {// 加载数据库驱动Class.forName("com.mysql.jdbc.Driver");// 通过驱动管理类获取数据库链接connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/mybatis","root","123456789");// 定义sql语句？表示占位符String sql = "select * from user where name = ?";// 获取预处理statementpreparedStatement = connection.prepareStatement(sql);// 设置参数，第一个参数为sql语句中参数的序号(从1开始)，第二个参数为设置的参数值preparedStatement.setString(1, "zhangsan");// 向数据库发出sql执行查询，查询出结果集resultSet = preparedStatement.executeQuery();// 遍历查询结果集while (resultSet.next()) {int id = resultSet.getInt("id");String username = resultSet.getString("name");// 封装UserUser user = new User();user.setId(id);user.setName(username);System.out.println(user);}} catch (Exception e) {e.printStackTrace();} finally {// 释放资源if (resultSet != null) {try {resultSet.close();} catch (SQLException e) {e.printStackTrace();}}if (preparedStatement != null) {try {preparedStatement.close();} catch (SQLException e) {e.printStackTrace();}}if (connection != null) {try {connection.close();} catch (SQLException e) {e.printStackTrace();}}}}
}

问题分析

二、自定义持久层框架_思路分析

主要分两部分，项目使用端：平常写代码所说的后台服务；持久层框架：即项目使用端引入的jar包

核心接口/类重点说明：

项目使用端：

1. 引入自定义持久层框架的jar包
2. sqlMapConfig.xml：数据库配置信息，以及mapper.xml的全路径
3. mapper.xml：SQL配置信息，存放SQL语句、参数类型、返回值类型相关信息

注意： sqlMapConfig.xml中引入mapper.xml是为了只读取一次配置文件，否则每个实体类会有一个mapper.xml，则需要读取很多次

自定义框架本身：

1. 加载配置文件：根据配置文件的路径，加载配置文件成字节输入流，存储在内存中

2. 创建两个javaBean(容器对象)：存放配置文件解析出来的内容

3. 解析配置文件(使用dom4j)，并创建SqlSession会话对象

4. 创建SqlSessionFactory接口以及实现类DefaultSqlSessionFactory

5. 创建SqlSession接口以及实现类DefaultSqlSession

SqlSession接口定义以上方法，DefaultSqlSession来决定什么操作调用对应的sql执行器

6. 创建Executor执行器接口以及实现类SimpleExecutor简单执行器

三、自定义框架_编码

项目使用端

创建sqlMapConfig核心配置文件：

创建映射配置文件：

获取某个sql语句的唯一标示statementId：namespace.id 如：user.selectList

select * from userselect * from user where id = #{id} and name = #{name}

User实体：

@Data
public class User {private Integer id;private String name;
}

pom.xml引入自定义框架

 com.xcown-mybatis1.0-SNAPSHOT

自定义框架本身

1、加载配置文件

• 根据配置文件的路径，加载配置文件成字节输入流，存到内存中

public class Resources {public static InputStream getResourceAsStream(String path){return Resources.class.getClassLoader().getResourceAsStream(path);}
}

2、创建两个配置类对象

• 映射配置类：mapper.xml解析出来内容
• 每个pojo实体都会对应一个mapper.xml文件即一个MapperStatement对象
• sqlCommandType：第四节 自定义框架_优化才会用到

@Data
public class MapperStatement {//唯一标识 statementId：namespace.idprivate String statementId;//返回值类型private String resultType;//参数类型private String parameterType;//sql语句private String sql;// 判断当前是什么操作的一个属性-增删改查private String sqlCommandType;
}

• 核心配置类：数据库配置信息以及映射配置类的map集合
• 将多个MapperStatement对象存入Map集合，statementId(namespace.id)作为key
• 将所有的配置文件都聚合到Configuration中，方便一次读取以及统一管理

@Data
public class Configuration {//数据源对象private DataSource dataSource;//map.xml对象集合 key：statementIdprivate Map mapperStatementMap = new HashMap<>();
}

3、解析配置文件，填充配置类对象

• XMLConfigBuilder类的parse方法：解析核心配置类，返回Configuration对象
• 创建SqlSession工厂对象，以便之后创建SqlSession会话

public class SqlSessionFactoryBuilder {public SqlSessionFactory build(InputStream inputStream) throws Exception {//1.解析配置文件，封装容器对象：专门解析核心配置文件的解析类XMLConfigBuilder xmlConfigBuilder = new XMLConfigBuilder();Configuration configuration = xmlConfigBuilder.parse(inputStream);//2.创建SqlSessionFactory工厂对象return new DefaultSqlSessionFactory(configuration);}}

• XMLConfigBuilder核心配置解析类里面嵌套着XMLMapperBuilder映射配置文件解析类
• 输入流转化为Document对象，一是根据property标签获取数据库配置信息并创建数据源添加到configuration
• 二是根据mapper标签通过XMLMapperBuilder解析类遍历解析配置文件同样添加到configuration的map集合类

public class XMLConfigBuilder {private Configuration configuration;public XMLConfigBuilder() {this.configuration = new Configuration();}// 使用dom4j+xpath解析public Configuration parse(InputStream inputStream) throws Exception {//将xml转化为Document对象Document document = new SAXReader().read(inputStream);//获取跟节点，对于sqlMapConfig.xml来说就是标签Element rootElement = document.getRootElement();// -------------解析数据库配置文件----------------// "//"表示从匹配选择的当前节点，而不考虑它们的位置// 即这里获取数据源url用户密码信息// 例：List propertyList = rootElement.selectNodes("//property");Properties properties = new Properties();for (Element element : propertyList) {// 获取标签中，name和value属性的值String name = element.attributeValue("name");String value = element.attributeValue("value");properties.setProperty(name,value);}// 创建数据源对象DruidDataSource dataSource = new DruidDataSource();dataSource.setDriverClassName(properties.getProperty("driverClassName"));dataSource.setUrl(properties.getProperty("url"));dataSource.setUsername(properties.getProperty("username"));dataSource.setPassword(properties.getProperty("password"));// 将创建好的数据源添加到Configuration对象中configuration.setDataSource(dataSource);// -------------解析映射配置文件----------------/*1.获取映射配置文件路径2.根据路径进行映射文件的加载解析3.封装到MapperStatement，存入configuration的map集合中*/// 例：List mapperList = rootElement.selectNodes("//mapper");for (Element element : mapperList) {String resource = element.attributeValue("resource");InputStream resourceAsStream = Resources.getResourceAsStream(resource);// XMLMapperBuilder 专门解析映射配置文件的对象-最后会存入configuration的map集合对象中XMLMapperBuilder xmlMapperBuilder = new XMLMapperBuilder(configuration);xmlMapperBuilder.parse(resourceAsStream);}return configuration;}
}

• 与XMLConfigBuilder解析类原理一样
• 传入configuration，并将解析好的MapperStatement对象添加到mapperStatementMap

public class XMLMapperBuilder {private Configuration configuration;public XMLMapperBuilder(Configuration configuration) {this.configuration = configuration;}public void parse(InputStream resourceAsStream) throws Exception {// 将输入流转化为Document对象，并获取跟节点Document document = new SAXReader().read(resourceAsStream);Element rootElement = document.getRootElement();// 例：String namespace = rootElement.attributeValue("namespace");/* 例：select * from user where id = #{id} and name = #{name}*/List selectList = rootElement.selectNodes("//select");for (Element element : selectList) {String id = element.attributeValue("id");String resultType = element.attributeValue("resultType");String parameterType = element.attributeValue("parameterType");String sql = element.getTextTrim();// 封装MapperStatement对象MapperStatement mapperStatement = new MapperStatement();String statementId = namespace + "." + id;mapperStatement.setStatementId(statementId);mapperStatement.setParameterType(parameterType);mapperStatement.setResultType(resultType);mapperStatement.setSql(sql);//第四节 自定义框架_优化才会用到mapperStatement.setSqlCommandType("select");// 添加到configurations的map集合中configuration.getMapperStatementMap().put(statementId,mapperStatement);}}
}

4、创建SqlSessionFactory工厂接口及DefaultSqlSessionFactory实现类

• 为了创建SqlSession会话，调用增删改查方法

public interface SqlSessionFactory {// 创建SqlSession对象SqlSession openSession();}

• 创建简单执行器，与核心配置类共同创建SqlSession会话实现类
• configuration提供数据配置和sql以及参数和结果集封装
• simpleExecutor提供JDBC执行sql底层原理

public class DefaultSqlSessionFactory implements SqlSessionFactory {private Configuration configuration;public DefaultSqlSessionFactory(Configuration configuration) {this.configuration = configuration;}@Overridepublic SqlSession openSession() {// 1.创建执行器对象-具体的包装jdbc的sql操作，关闭连接等Executor simpleExecutor = new SimpleExecutor();// 2.创建sqlSession对象-判断执行增删改查哪些操作等return new DefaultSqlSession(configuration,simpleExecutor);}
}

5、创建SqlSession会话接口及DefaultSqlSession实现类

• statementId(“namespace.id”)：定位具体Mapper.xml的sql语句以及入参和返回
• param：替换sql语句中的占位符？，可能字符串、对象、Map、集合

public interface SqlSession {// 查询多个结果 List selectList(String statementId, Object param) throws Exception;// 查询单个结果 T selectOne(String statementId, Object param) throws Exception;// 清理资源void close();}

• 利用聚合进来的configuration对象获取MapperStatement映射配置对象向下传给执行器
• 另外一个聚合进来的executor简单执行器来执行底层JDBC操作
• DefaultSqlSession的作用则是聚合配置类分发到不同执行器的不同方法
• 执行器种类：简单执行器、可重用执行器、批量执行器（这里只模拟第一种）

public class DefaultSqlSession implements SqlSession {private Configuration configuration;private Executor executor;public DefaultSqlSession(Configuration configuration, Executor executor) {this.configuration = configuration;this.executor = executor;}@Overridepublic  List selectList(String statementId, Object param) throws Exception {// 根据StatementId获取映射配置对象MapperStatementMapperStatement mapperStatement = configuration.getMapperStatementMap().get(statementId);// 然后将具体的查询操作委派给SimpleExecutor执行器// 执行底层jdbc需要：1.数据库配置，2.sql配置信息return executor.query(configuration,mapperStatement,param);}@Overridepublic  T selectOne(String statementId, Object param) throws Exception {// 调用selectList()List