手动实现mysql简单功能

mysql 手写

分使用端与架构端

创建配置文件，数据库连接配置、sqlmapper配置文件

sql语句信息mapper

sqlMapConfig.xml : 存放数据源信息，引入mapper.xml （存放）

Mapper.xml : sql语句的配置文件信息

1.读取配置文件

读取完成以后以流的形式存在，我们不能将读取到的配置信息以流的形式存放在内存中，不好操作，可 以创建javaBean来存储

(1)Configuration : 存放数据库基本信息、Map 唯一标识:namespace + "." + id

(2)MappedStatement:sql语句、statement类型、输入参数java类型、输出 参数java类型

2.解析配置文件

创建sqlSessionFactoryBuilder类: 方法:sqlSessionFactory build(): 第一:使用dom4j解析配置文件，将解析出来的内容封装到Configuration和MappedStatement中 第二:创建SqlSessionFactory的实现类DefaultSqlSession

3.创建SqlSessionFactory: 方法:openSession() : 获取sqlSession接口的实现类实例对象

4.创建sqlSession接口及实现类:主要封装crud方法 方法:selectList(String statementId,Object param):查询所有 selectOne(String statementId,Object param):查询单个 具体实现:封装JDBC完成对数据库表的查询操作

代码步骤

框架层

加载配置文件：根据配置文件路径，加载字节流到内存

创建两个javaBean（容器对象） 存放的是对配置文件解析出来的内容

Configuration：核心配置类，放sqlMapConfig.xml的内容

MappedStatement 映射配置类 放mapper.xml内容

解析配置文件：dom4j

创建SqlSessionFactoryBuilder。方法：build(InputStream in)

一 使用dom4j解析配置文件，装载到容器对象

二 创建SqlSessionFactory对象；生成sqlSession （工厂模式）

DefaultSqlSessionFactory实现SqlSessionFactory

生产sqlSession

创建SqlSession接口及实现类 DefaultSession

定义对数据库的curd操作：selectList() selectOne() update() delete()

创建Executor接口及实现类SimpleExecutor实现类

通用的query(Configuration ，MappedStatement，Object… param) 执行的就是JDBC操作代码

代码执行流程

先加载配置文件

SqlSessionFactoryBuilder通过配置文件流构建SqlSessionFactory对象 得到工厂对象

由工厂对象创建SqlSession

最后由SqlSession提供增删查改方法语句

还提供getMapper方法(代理的dao层实现)

sqlSession底层使用SimpleExecutor提供的query方法，其底层使用jdbc操作数据库代码结构图

核心加载类结构图

代码实现sqlSessionFactoryBuilder.java主要用于创建SqlSessionFactory工厂mysql作用，其中做了两件事：

一 使用dom4j解析配置文件输入流并得到Configuration对象，

二 通过配置对象创建默认工厂类实例DefautSqlSessionFactory用于生产SqlSession的

```java

public class SqlSessionFactoryBuilder {

public SqlSessionFactory build(InputStream in ) throws PropertyVetoException, DocumentException {
       // 第一：使用dom4j解析配置文件，将解析出来的内容封装到Configuration中
       XMLConfigBuilder xmlConfigBuilder = new XMLConfigBuilder();
       Configuration configuration = xmlConfigBuilder.parseConfig(in);
       // 第二：创建sqlSessionFactory对象：工厂类：生产sqlSession:会话对象
       SqlSessionFactory sqlSessionFactory = new DefautSqlSessionFactory(configuration);
       return sqlSessionFactory;
   }

} ```

Configuration.java 中主要存储xml解析出来的配置信息，包含数据库链接信息和sql语句信息

```java public class Configuration {

// 数据库连接池
   DataSource dataSource;
   Map mappedStatementMap = new HashMap();
   public DataSource getDataSource() {
       return dataSource;
   }
   public void setDataSource(DataSource dataSource) {
       this.dataSource = dataSource;
   }
   public Map getMappedStatementMap() {
       return mappedStatementMap;
   }
   public void setMappedStatementMap(Map mappedStatementMap) {
       this.mappedStatementMap = mappedStatementMap;
   }

} ```

默认工厂类DefautSqlSessionFactory.java 提供一个openSession()方法，该方法用于获取SqlSession对象

```java public class DefautSqlSessionFactory implements SqlSessionFactory {private Configuration configuration ;

public DefautSqlSessionFactory(Configuration configuration) {

       this.configuration = configuration;
   }
   @Override
   public SqlSession openSession() {
       SqlSession sqlSession = new DefaultSqlSession(configuration);
       return sqlSession;
   }

} ```

持久化核心实现类：DefaultSqlSession.java以上准备工作完成后，由session路由到指定sql语句并执行

```java public class DefaultSqlSession implements SqlSession {

private Configuration configuration;
   public DefaultSqlSession(Configuration configuration) {
       this.configuration = configuration;
   }
   public  List selectList(String statementid, Object... params) throws Exception {
       Executor executor = new SimpleExecutor();
       MappedStatement mappedStatement = configuration.getMappedStatementMap().get(statementid);
       List