自定义持久层框架
前言:其实之前学习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;
}
.
