自定义持久层框架

源码地址

前言:其实之前学习mybatis或者其他框架时候，只是单纯的以为会使用就可以，而通过这次课程也打破了我之前的对学习方式的看法.第一节就是之前想都不敢想的手写一个自定义的持久层框架.这样平时眼高手低的我感觉很难,不过还是在导师催促自己的坚持下完成了这么一个简单的框架 倍感兴奋.

   首先我们分析一下原生JDBC问题：

1、 数据库连接创建、释放频繁造成系统资源浪费，从而影响系统性能。

2、 Sql语句在代码中硬编码，造成代码不易维护，实际应用中sql变化的可能较大，sql变动需要改变

java代码。

3、 使用preparedStatement向占有位符号传参数存在硬编码，因为sql语句的where条件不一定，可能

多也可能少，修改sql还要修改代码，系统不易维护。

4、 对结果集解析存在硬编码(查询列名)，sql变化导致解析代码变化，系统不易维护，如果能将数据 库

记录封装成pojo对象解析比较方便

 问题解决思路

①使用数据库连接池初始化连接资源

②将sql语句抽取到xml配置文件中

③使用反射、内省等底层技术，自动将实体与表进行属性与字段的自动映射

 自定义框架设计

使用端：

提供核心配置文件：

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

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

框架端：

1.读取配置文件

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

以创建javaBean来存储

（1）Configuration : 存放数据库基本信息、Map<唯一标识，Mapper> 唯一标识：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完成对数据库表的查询操作

涉及到的设计模式：

Builder构建者设计模式、工厂模式、代理模式

大致流程图如下

自定义框架流程图

代码实现思路如下:

1.框架端主要类介绍:

自定义框架整体结构

代码流程:

1) 客户端配置

sqlMapConfig.xml

<configuration>

<property name="driverClass" value="com.mysql.jdbc.Driver">

        <property name="jdbcUrl" value="jdbc:mysql:///testdb">

        <property name="username" value="root">

        <property name="password" value="1234">

      <!--存放mapper.xml的全路径-->

     <mapper resource="UserMapper.xml">

</configuration>      

Mapper.xml

<mapper namespace="com.lagou.Dao.UserDao">

    <!--sql的唯一标识：namespace.id来组成 ：statementId-->

    <select id="findAll" resultType="com.lagou.pojo.User" >

        select * from user

    <select id="findByCondition" resultType="com.lagou.pojo.User" paramterType="com.lagou.pojo.User">

        select * from user where id = #{id} and username = #{username}

</mapper>

测试类:

@Test

public void test()throws Exception {

InputStream resourcesAsStream = Resources.getResourcesAsStream("sqlMapConfig.xml");

    SqlSessionFactory build =new SqlSessionFactoryBuilder().build(resourcesAsStream);

    SqlSession sqlSession = build.openSession();

    User user=new User();

    user.setId(1);

    user.setUsername("lucy");

    UserDao mapper = sqlSession.getMapper(UserDao.class);

    List all = mapper.findAll();

    System.out.println(mapper.findByCondition(user));

    System.out.println(all);

2) 框架实现查询功能

SqlSessionFactoryBuilder 生成SqlSessionFactory

public SqlSessionFactorybuild(InputStream inputStream)throws PropertyVetoException, DocumentException {

//1.使用dom4j解析xml

    XMLConfigBuilder xmlConfigBuilder =new XMLConfigBuilder();

    Configuration configuration= xmlConfigBuilder.parseConfig(inputStream);

    DefaultSqlSessionFactory defaultSqlSessionFactory =new DefaultSqlSessionFactory(configuration);

    return defaultSqlSessionFactory;

}

DefaultSqlSessionFactory工厂模式生成sqlsession对象

@Override

public SqlSessionopenSession() {

return new DefaultSqlSession(configuration);

}

SqlSession中getMapper方法通过反射实现对入参和结果集的返回

@Override

public T getMapper(Class mapperClass) {

Object proxyInstance = Proxy.newProxyInstance(DefaultSqlSession.class.getClassLoader(), new Class[]{mapperClass}, new InvocationHandler() {

@Override

        public Objectinvoke(Object proxy, Method method, Object[] args)throws Throwable {

// 底层都还是去执行JDBC代码 //根据不同情况，来调用selctList或者selectOne

            // 准备参数 1：statmentid :sql语句的唯一标识：namespace.id= 接口全限定名.方法名

            // 方法名：findAll

            String methodName = method.getName();

            String className = method.getDeclaringClass().getName();

            String statementId = className+"."+methodName;

            // 准备参数2：params:args

            // 获取被调用方法的返回值类型

            Type genericReturnType = method.getGenericReturnType();

            // 判断是否进行了 泛型类型参数化

            if(genericReturnTypeinstanceof ParameterizedType){

List objects = selectList(statementId, args);

                return objects;

            }

return selectOne(statementId,args);

        }

});

    return (T) proxyInstance;

}

selectList,selectOne 调用Executor进行后续查询

@Override

public ListselectList(String statementId, Object... param)throws Exception {

//通过Executor进行后续查询

    DefaultExecutor executor=new DefaultExecutor();

    List query = executor.query(configuration, configuration.getMappedStatementMap().get(statementId), param);

    return (List) query;

}

@Override

public T selectOne(String statementId, Object... param)throws Exception {

List objects = selectList(statementId, param);

    if (objects.size()==1){

return (T) objects.get(0);

    }else {

throw new RuntimeException("结果集为null 或大于1");

    }

}

Executor..真正做数据库交互的类 主要包括 获取连接信息,sql信息 通过反射将param中的值取出,并且拼接sql

@Override

public Listquery(Configuration configuration, MappedStatement mappedStatement, Object... param)throws Exception {

//获取连接池  解析sql

    DataSource dataSource = configuration.getDataSource();

    Connection connection = dataSource.getConnection();

    String sql = mappedStatement.getSql();

    Boundsql bandSql=  getBoundsql(sql);

    PreparedStatement preparedStatement = connection.prepareStatement(bandSql.getParse());

    //通过反射获取到param中的值

    String paramType = mappedStatement.getParamType();

    Class classType =getClassType(paramType);

    List parameterMappings = bandSql.getParameterMappings();

    for (int i =0; i < parameterMappings.size(); i++) {

ParameterMapping parameterMapping = parameterMappings.get(i);

        String content = parameterMapping.getContent();

        Field declaredField = classType.getDeclaredField(content);

        declaredField.setAccessible(true);

        Object o = declaredField.get(param[0]);

        preparedStatement.setObject(i+1,o);

    }

//将返回结果集 处理成对应的返回对象list

    ResultSet resultSet = preparedStatement.executeQuery();

    Class resultType = getClassType(mappedStatement.getResultType());

    Object o = resultType.newInstance();

    List objectList=new ArrayList<>();

    while (resultSet.next()){

ResultSetMetaData metaData = resultSet.getMetaData();

        for (int i =1; i <=metaData.getColumnCount(); i++) {

//字段名

            String columnName = metaData.getColumnName(i);

            //字段值

            Object object = resultSet.getObject(columnName);

            //内省方式映射成对象

            PropertyDescriptor descriptor=new PropertyDescriptor(columnName,resultType);

            Method writeMethod = descriptor.getWriteMethod();

            writeMethod.invoke(o,object);

        }

objectList.add(o);

    }

return (List) objectList;

}

private ClassgetClassType(String paramType)throws ClassNotFoundException {

if (paramType!=null){

return Class.forName(paramType);

    }

return null;

}

/**

* 完成占位符的替换  #{} --->? 以及将占位符里面的参数名取出来

* @param sql

* @return

*/

private BoundsqlgetBoundsql(String sql) {

//标记处理类

    ParameterMappingTokenHandler parameterMappingTokenHandler =new ParameterMappingTokenHandler();

    GenericTokenParser genericTokenParser=new GenericTokenParser("#{","}",parameterMappingTokenHandler);

    String parse = genericTokenParser.parse(sql);

    List parameterMappings = parameterMappingTokenHandler.getParameterMappings();

    Boundsql boundsql=new Boundsql(parse,parameterMappings);

    //设置参数 通过 反射

    return boundsql;

}

.