模拟MyBatis自定义 的实现

xml与 注解 的 实现 :

总结 : 实现 curd 增删改查 与 使用 增删改查
引导的是如何实现的 主配置 文件的配置 :
分析的是 :
===== MyBatis 原理的 分析流程 的是 =======- :

有了 主配置文件 的 连接数据库的 4个基本 与 mappers 的 里第二个映射xml 里
有了 就是xml配置的sql 语句 封装实体 全限定类名
于是 这改为框架就 开始 创建 JDBC 的事务了 Connection 对象

于是实体类 与。数据的 用的还是:***** 反射 ***** 
-----证明 反射是 框架的灵魂

 解析配置文件用的是的xml 解析  用得到的  dom4j的技术

在 API有的 为所欲为 的 SqlSession 会创建的是 Dao 的 代理对象
代理模式 3个参数 :----- 基于JDK 的接口实现的 方式 :
代理对象 与被 代理对象 使用的是 同一个 接口字节码数组

如何代理 :与增强的方法 就是SqlSession对象的的 好多的方法 :

还从认识API的4个里获取:
2个接口 2个类 :

Class Resources
Class SqlSessionFactoryBuild:
interface SqlSessionFactory: ======= 用的 是 反射 : 基于 (验证)
interface SqlSession ===== 用到的是 动态代理 JDK的 基于接口来实现的
===== 下图是 对于 Mybatisde 流程的分析

==== 主 配置文件 ======== :
数据库连接池的 : Environment
事务管理 : transactionManager 的type 是JDBC 的 就是 连库的 :
数据资源 类型:
------ dataSource 的type 是 POOLED 数据库连接池的
4个要素 : 的 property : 1:driver 2: url 3:username 4: password

mappers 里 好多的 : 也是说 可以有好多 的 映射文件
======= 而Resources 的文件是 === 如下

Resources 的配置文件
在UNity里可以通过Rwsources.Load来获取

这样我们就能不通过拖拽,直接写程序的方式来生成对象,是不是很高大尚呢?

Mapper 的映射文件 就是 MyBatis 里要写的sql 语句 : 这是程序员 动手 的时刻 :

====== 增删改查 的crud 过于sql语句的 DML 的 操作 :

持久层接口 : 只有与接口的实现的 是 如何实现 ?

是基于 动态代理 与反射来 实现的

主 配置文件 ======== :
数据库连接池的 : 到========

经过的 设计模式 :

简介一下 : 构建者模式 :与 工厂 模式 :

构建者模式  SqlSessionFactoryBuilder :  类
工厂 模式 : SQLSessionFactory:接口
代理模式 proxy   : SQLSession的  接口 JDK的方式
经过3个模式的加持 :====== 最终  为所欲为 了 :
============  分享 摘抄 ““编码之路就在脚下 ”” 的文章  : 如下

在Mybatis环境的初始化过程中,SqlSessionFactoryBuilder会调用XMLConfigBuilder读取所有的MybatisMapConfig.xml和所有的*Mapper.xml文件,构建Mybatis运行的核心对象Configuration对象,然后将该Configuration对象作为参数构建一个SqlSessionFactory对象。

其中XMLConfigBuilder在构建Configuration对象时,也会调用XMLMapperBuilder用于读取*Mapper文件,而XMLMapperBuilder会使用XMLStatementBuilder来读取和build所有的SQL语句。

在这个过程中,有一个相似的特点,就是这些Builder会读取文件或者配置,然后做大量的XpathParser解析、配置或语法的解析、反射生成对象、存入结果缓存等步骤,这么多的工作都不是一个构造函数所能包括的,因此大量采用了Builder模式来解决。

对于builder的具体类,方法都大都用build*开头,比如SqlSessionFactoryBuilder为例,它包含以下方法:

*工厂 模式 :=========

可以看到,该Factory的openSession方法重载了很多个,分别支持autoCommit、Executor、Transaction等参数的输入,来构建核心的SqlSession对象。
在DefaultSqlSessionFactory的默认工厂实现里,有一个方法可以看出工厂怎么产出一个产品

==========MyBatis至少有9大 设计模式 ===== ;

Mybatis至少遇到了以下的设计模式的使用:

Builder模式,例如SqlSessionFactoryBuilder、XMLConfigBuilder、XMLMapperBuilder、XMLStatementBuilder、CacheBuilder;
工厂模式,例如SqlSessionFactory、ObjectFactory、MapperProxyFactory;
单例模式,例如ErrorContext和LogFactory;
代理模式,Mybatis实现的核心,比如MapperProxy、ConnectionLogger,用的jdk的动态代理;还有executor.loader包使用了cglib或者javassist达到延迟加载的效果;
组合模式,例如SqlNode和各个子类ChooseSqlNode等;
模板方法模式,例如BaseExecutor和SimpleExecutor,还有BaseTypeHandler和所有的子类例如IntegerTypeHandler;
适配器模式,例如Log的Mybatis接口和它对jdbc、log4j等各种日志框架的适配实现;
装饰者模式,例如Cache包中的cache.decorators子包中等各个装饰者的实现;
迭代器模式,例如迭代器模式PropertyTokenizer;

开始自定义的是 :

xml 的 实现 :

-!!!! maven构建项目的时候 ,不用 骨架

  • !!! pom 文件里 不用myBaties 的依赖

还从认识API的4个里获取:
2个接口 2个类 :

Class Resources
Class SqlSessionFactoryBuild:
interface SqlSessionFactory: ======= 用的 是 反射 : 基于 (验证)
interface SqlSession ===== 用到的是 动态代理 JDK的 基于接口来实现的

用的反射 : 创建 使用类加载器 读取时的

不用MyBatis 的坐标依赖

这就是自定义的 特色 :

    <dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.6</version></dependency><dependency><groupId>log4j</groupId><artifactId>log4j</artifactId><version>1.2.12</version></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.10</version></dependency><dependency><groupId>dom4j</groupId><artifactId>dom4j</artifactId><version>1.6.1</version></dependency><dependency><groupId>jaxen</groupId><artifactId>jaxen</artifactId><version>1.1.6</version></dependency><dependency><groupId>org.mybatis</groupId><artifactId>mybatis</artifactId><version>3.4.5</version></dependency>
</dependencies>

======== 准备 建构 ======== mysql数据库 的资源 :

DROP TABLE IF EXISTS `user`;CREATE TABLE `user` (`id` INT(11) NOT NULL AUTO_INCREMENT,`username` VARCHAR(32) NOT NULL COMMENT '用户名称',`birthday` DATETIME DEFAULT NULL COMMENT '生日',`sex` CHAR(1) DEFAULT NULL COMMENT '性别',`address` VARCHAR(256) DEFAULT NULL COMMENT '地址',PRIMARY KEY  (`id`)
) ENGINE=INNODB DEFAULT CHARSET=utf8;

dao 接口
pojo 实体类
Resources 里的 配置文件 :
主配置文件 :
Mapper 映射 文件:

主配置文件

   <environments default="mysql"><!-- 默认指定 的--><!-- 配置mysql的环境--><environment id="mysql"><!-- 可以自定义--><!-- 配置事务的类型--><transactionManager type="JDBC"></transactionManager><!-- 配置数据源(连接池) 里再 配置 连接数据库的 的4个信息  用:单闭合标签--><dataSource type="POOLED"><!-- 我们就在下面 的value 使用 ${} 来 引用的 properties配置文件的 value值  可以在其他 的类里来使用--><property name="driver" value="com.mysql.jdbc.Driver"></property><!--本机默认的端口号 就可以省略不写jdbc:mysql:///testMybatise001--><property name="url" value="jdbc:mysql://localhost:3306/mybaties001"></property><property name="username" value="root"></property><property name="password" value="root"></property></dataSource></environment></environments><!-- 指定映射配置文件的位置,映射配置文件指的是每个dao独立的配置文件 --><mappers><mapper resource="com/fhw/dao/IUserDao.xml"></mapper><!-- 自定义  注解  --><!--    <mapper class="com.fhw.dao.IUserDao"/>-->
</mappers>
</configuration >

mapper 映射文件 :

<?xml version="1.0" encoding="UTF-8"?>
<mapper namespace="com.fhw.dao.IUserDao"><!--配置查询所有--><select id="findAll" resultType="com.fhw.domain.User">select * from user</select>
</mapper>

pojo 类 :

public class User implements Serializable{private Integer id;private String username;private Date birthday;private String sex;private String address;

log4j

 Set root category priority to INFO and its only appender to CONSOLE.
#log4j.rootCategory=INFO, CONSOLE            debug   info   warn error fatal
log4j.rootCategory=debug, CONSOLE, LOGFILESet the enterprise logger category to FATAL and its only appender to CONSOLE.
log4j.logger.org.apache.axis.enterprise=FATAL, CONSOLECONSOLE is set to be a ConsoleAppender using a PatternLayout.
log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
log4j.appender.CONSOLE.layout.ConversionPattern=%d{ISO8601} %-6r [%15.15t] %-5p %30.30c %x - %m\nLOGFILE is set to be a File appender using a PatternLayout.
log4j.appender.LOGFILE=org.apache.log4j.FileAppender
log4j.appender.LOGFILE.File=d:\axis.log
log4j.appender.LOGFILE.Append=true
log4j.appender.LOGFILE.layout=org.apache.log4j.PatternLayout
log4j.appender.LOGFILE.layout.ConversionPattern=%d{ISO8601} %-6r [%15.15t] %-5p %30.30c %x - %m\n

dao接口 ======------

 * 用户的持久层接口*/
public interface IUserDao {/*** 查询所有操作* @return*//*  @Select("select * from user")*/List<User> findAll();
}

只留下测试类 的这些 API 的 就会报错 :开始你的 自定义构建 :
找到解决完这些 报错的 的就会 成功了 !!!

依次 是反射 构建者 proxyJDK代理

class Resources 使用类加载器读取配置文件的类

package com.fhw.mybatis.io;import java.io.InputStream;/*** 使用类加载器读取配置文件的类*/
public class Resources {/*** 根据传入的参数,获取一个字节输入流* @param filePath* @return*/public static InputStream getResourceAsStream(String filePath){return Resources.class.getClassLoader().getResourceAsStream(filePath);}
}

用于创建一个SqlSessionFactory对象

package com.fhw.mybatis.sqlsession;import com.fhw.mybatis.cfg.Configuration;
import com.fhw.mybatis.sqlsession.defaults.DefaultSqlSessionFactory;
import com.fhw.mybatis.utils.XMLConfigBuilder;import java.io.InputStream;/***  用于创建一个SqlSessionFactory对象*/
public class SqlSessionFactoryBuilder {/*** 根据参数的字节输入流来构建一个SqlSessionFactory工厂* @param config* @return*/public DefaultSqlSessionFactory build(InputStream config){Configuration cfg = XMLConfigBuilder.loadConfiguration(config);return  new DefaultSqlSessionFactory(cfg);}
}

用于打开一个新的SqlSession对象

package com.fhw.mybatis.sqlsession;public interface SqlSessionFactory {/*** 用于打开一个新的SqlSession对象* @return*/SqlSession openSession();
}

自定义Mybatis中和数据库交互的核心类

  • 它里面可以创建dao接口的代理对象
  • 就是 可以 为所欲为 SqlSession
package com.fhw.mybatis.sqlsession;/*** 自定义Mybatis中和数据库交互的核心类*  它里面可以创建dao接口的代理对象*/
public interface SqlSession {/*** 根据参数创建一个代理对象* @param daoInterfaceClass dao的接口字节码* @param <T>* @return*/// 泛型 要先声明  再 使用  声明在  返回值之前<T> T getMapper(Class<T> daoInterfaceClass);/*** 释放资源*/void close();
}

准备工具类 : utils :

用于解析配置文件 以 支持 xml 与注解
使用 dom4j 与 xpath 解析xml 的

package com.fhw.mybatis.utils;
/*import com.fhw.mybatis.annotations.Select;*/
import com.fhw.mybatis.cfg.Configuration;
import com.fhw.mybatis.cfg.Mapper;
import org.apache.ibatis.io.Resources;
import org.dom4j.Attribute;
import org.dom4j.Document;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;import java.io.IOException;
import java.io.InputStream;
import java.lang.reflect.Method;
import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.util.HashMap;
import java.util.List;
import java.util.Map;/***  用于解析配置文件*/
public class XMLConfigBuilder {/*** 解析主配置文件,把里面的内容填充到DefaultSqlSession所需要的地方* 使用的技术:*      dom4j+xpath*/public static Configuration loadConfiguration(InputStream config){try{//定义封装连接信息的配置对象(mybatis的配置对象)Configuration cfg = new Configuration();//1.获取SAXReader对象SAXReader reader = new SAXReader();//2.根据字节输入流获取Document对象Document document = reader.read(config);//3.获取根节点Element root = document.getRootElement();//4.使用xpath中选择指定节点的方式,获取所有property节点List<Element> propertyElements = root.selectNodes("//property");//5.遍历节点for(Element propertyElement : propertyElements){//判断节点是连接数据库的哪部分信息//取出name属性的值String name = propertyElement.attributeValue("name");if("driver".equals(name)){//表示驱动//获取property标签value属性的值String driver = propertyElement.attributeValue("value");cfg.setDriver(driver);}if("url".equals(name)){//表示连接字符串//获取property标签value属性的值String url = propertyElement.attributeValue("value");cfg.setUrl(url);}if("username".equals(name)){//表示用户名//获取property标签value属性的值String username = propertyElement.attributeValue("value");cfg.setUsername(username);}if("password".equals(name)){//表示密码//获取property标签value属性的值String password = propertyElement.attributeValue("value");cfg.setPassword(password);}}//取出mappers中的所有mapper标签,判断他们使用了resource还是class属性List<Element> mapperElements = root.selectNodes("//mappers/mapper");//遍历集合for(Element mapperElement : mapperElements){//判断mapperElement使用的是哪个属性Attribute attribute = mapperElement.attribute("resource");if(attribute != null){System.out.println("使用的是XML");//表示有resource属性,用的是XML//取出属性的值String mapperPath = attribute.getValue();//获取属性的值"com/itheima/dao/IUserDao.xml"//把映射配置文件的内容获取出来,封装成一个mapMap<String,Mapper> mappers = loadMapperConfiguration(mapperPath);//给configuration中的mappers赋值cfg.setMappers(mappers);}/*else{*//* System.out.println("使用的是注解");//表示没有resource属性,用的是注解//获取class属性的值String daoClassPath = mapperElement.attributeValue("class");//根据daoClassPath获取封装的必要信息Map<String,Mapper> mappers = loadMapperAnnotation(daoClassPath);//给configuration中的mappers赋值cfg.setMappers(mappers);*//*}*/}//返回Configurationreturn cfg;}catch(Exception e){throw new RuntimeException(e);}finally{try {config.close();}catch(Exception e){e.printStackTrace();}}}/*** 根据传入的参数,解析XML,并且封装到Map中* @param mapperPath    映射配置文件的位置* @return  map中包含了获取的唯一标识(key是由dao的全限定类名和方法名组成)*          以及执行所需的必要信息(value是一个Mapper对象,里面存放的是执行的SQL语句和要封装的实体类全限定类名)*/private static Map<String,Mapper> loadMapperConfiguration(String mapperPath)throws IOException {InputStream in = null;try{//定义返回值对象Map<String,Mapper> mappers = new HashMap<String,Mapper>();//1.根据路径获取字节输入流in = Resources.getResourceAsStream(mapperPath);//2.根据字节输入流获取Document对象SAXReader reader = new SAXReader();Document document = reader.read(in);//3.获取根节点Element root = document.getRootElement();//4.获取根节点的namespace属性取值String namespace = root.attributeValue("namespace");//是组成map中key的部分//5.获取所有的select节点List<Element> selectElements = root.selectNodes("//select");//6.遍历select节点集合for(Element selectElement : selectElements){//取出id属性的值      组成map中key的部分String id = selectElement.attributeValue("id");//取出resultType属性的值  组成map中value的部分String resultType = selectElement.attributeValue("resultType");//取出文本内容            组成map中value的部分String queryString = selectElement.getText();//创建KeyString key = namespace+"."+id;//创建ValueMapper mapper = new Mapper();mapper.setQueryString(queryString);mapper.setResultType(resultType);//把key和value存入mappers中mappers.put(key,mapper);}return mappers;}catch(Exception e){throw new RuntimeException(e);}finally{in.close();}}/*** 根据传入的参数,得到dao中所有被select注解标注的方法。* 根据方法名称和类名,以及方法上注解value属性的值,组成Mapper的必要信息* @param daoClassPath* @return*/
/*private static Map<String,Mapper> loadMapperAnnotation(String daoClassPath)throws Exception{//定义返回值对象Map<String,Mapper> mappers = new HashMap<String, Mapper>();//1.得到dao接口的字节码对象Class daoClass = Class.forName(daoClassPath);//2.得到dao接口中的方法数组Method[] methods = daoClass.getMethods();//3.遍历Method数组for(Method method : methods){//取出每一个方法,判断是否有select注解boolean isAnnotated = method.isAnnotationPresent(Select.class);if(isAnnotated){//创建Mapper对象Mapper mapper = new Mapper();//取出注解的value属性值Select selectAnno = method.getAnnotation(Select.class);String queryString = selectAnno.value();mapper.setQueryString(queryString);//获取当前方法的返回值,还要求必须带有泛型信息Type type = method.getGenericReturnType();//List<User>//判断type是不是参数化的类型if(type instanceof ParameterizedType){//强转ParameterizedType ptype = (ParameterizedType)type;//得到参数化类型中的实际类型参数Type[] types = ptype.getActualTypeArguments();//取出第一个Class domainClass = (Class)types[0];//获取domainClass的类名String resultType = domainClass.getName();//给Mapper赋值mapper.setResultType(resultType);}//组装key的信息//获取方法的名称String methodName = method.getName();String className = method.getDeclaringClass().getName();String key = className+"."+methodName;//给map赋值mappers.put(key,mapper);}}return mappers;}*/}

测试类:

 public static void main(String[] args)throws Exception {//1.读取配置文件InputStream in = Resources.getResourceAsStream("SqlMapConfig01.xml");//2.创建SqlSessionFactory工厂SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();SqlSessionFactory factory = builder.build(in);//3.使用工厂生产SqlSession对象SqlSession session = factory.openSession();//4.使用SqlSession创建Dao接口的代理对象IUserDao userDao = session.getMapper(IUserDao.class);//5.使用代理对象执行方法List<User> users = userDao.findAll();for(User user : users){System.out.println(user);}//6.释放资源
//        session.close();in.close();}

自定义mybatis的配置类 连库 mysql :

package com.fhw.mybatis.cfg.Configuration

package com.fhw.mybatis.cfg; import java.util.HashMap;
import java.util.Map;/*** 自定义mybatis的配置类*/
public class Configuration {private String driver;private String url;private String username;private String password;private Map<String,Mapper> mappers = new HashMap<String,Mapper>();public Map<String, Mapper> getMappers() {return mappers;}public void setMappers(Map<String, Mapper> mappers) {this.mappers.putAll(mappers);//此处需要使用追加的方式}public String getDriver() {return driver;}public void setDriver(String driver) {this.driver = driver;}public String getUrl() {return url;}public void setUrl(String url) {this.url = url;}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;}
}

mapper类 :

package com.fhw.mybatis.cfg;/*** 用于封装执行的SQL语句和结果类型的全限定类名*/
public class Mapper {private String queryString;//SQLprivate String resultType;//实体类的全限定类名public String getQueryString() {return queryString;}public void setQueryString(String queryString) {this.queryString = queryString;}public String getResultType() {return resultType;}public void setResultType(String resultType) {this.resultType = resultType;}
}

`解析主配置文件的原理


解析 的 这样 配置文件

SqlSessionFactory接口的实现类

package com.fhw.mybatis.sqlsession.defaults;import com.fhw.mybatis.cfg.Configuration;
import com.fhw.mybatis.sqlsession.SqlSession;
import com.fhw.mybatis.sqlsession.SqlSessionFactory;/*** SqlSessionFactory接口的实现类*/
public class DefaultSqlSessionFactory implements SqlSessionFactory {private Configuration cfg;public DefaultSqlSessionFactory(Configuration cfg){this.cfg = cfg;}/*** 用于创建一个新的操作数据库对象* @return*/public SqlSession openSession() {return new DefaultSqlSession(cfg);}
}

:SqlSession接口的实现类

package com.fhw.mybatis.sqlsession.defaults;import com.fhw.mybatis.cfg.Configuration;
import com.fhw.mybatis.sqlsession.SqlSession;
import com.fhw.mybatis.sqlsession.proxy.MapperProxy;
import com.fhw.mybatis.utils.DataSourceUtil;import java.lang.reflect.Proxy;
import java.sql.Connection;/*** SqlSession接口的实现类*/
public class DefaultSqlSession implements SqlSession{private Configuration cfg;private Connection connection;public DefaultSqlSession(Configuration cfg){this.cfg = cfg;connection = DataSourceUtil.getConnection(cfg);}/*** 用于创建代理对象* @param daoInterfaceClass dao的接口字节码* @param <T>* @return*/
// 类加载器   :该类自身  就有能  获取 类加载器
//代理谁 就要和谁有相同的接口 ,
// 如何代理 ; 用自己的类的 于是就要创建下面 的 自定义类 public <T> T getMapper(Class<T> daoInterfaceClass) {return (T) Proxy.newProxyInstance(daoInterfaceClass.getClassLoader(),new Class[]{daoInterfaceClass},new MapperProxy(cfg.getMappers(),connection));}/*** 用于释放资源*/public void close() {if(connection != null) {try {connection.close();} catch (Exception e) {e.printStackTrace();}}}
}

截止现在 : 解析配置文件 就跟工厂 的有连接 了 构建者 给构建工厂 ----- 工厂 生产了SqlSession ------ 在 SqlSession的实现里还有很多 : 比如 :实现查询所的功能 ,类与接口的是修关系 :读 配置文件用到了io 流的Resources 类 ,就是文件信息 , 要交给 构建者 SqlSessionFactoryBuilder ,---- 使用工厂对象 SqlSessionFactory 的openSession 提供了方法 ------- 在Session对象里面 去实现 代理对象与 增强的 查询方法 ,

代理 对象累的实现 : MapperProxy

我们的增强其实就是调用selectList方法

package com.fhw.mybatis.sqlsession.proxy;import com.fhw.mybatis.cfg.Mapper;
import com.fhw.mybatis.utils.Executor;import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.sql.Connection;
import java.util.Map;/***/
public class MapperProxy implements InvocationHandler {//map的key是全限定类名+方法名private Map<String,Mapper> mappers;private Connection conn;
//用构造方法 赋值 public MapperProxy(Map<String,Mapper> mappers,Connection conn){this.mappers = mappers;this.conn = conn;}/*** 用于对方法进行增强的,我们的增强其实就是调用selectList方法* @param proxy* @param method* @param args* @return* @throws Throwable*/public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {//1.获取方法名String methodName = method.getName();//2.获取方法所在类的名称String className = method.getDeclaringClass().getName();//3.组合keyString key = className+"."+methodName;//4.获取mappers中的Mapper对象Mapper mapper = mappers.get(key);//5.判断是否有mapperif(mapper == null){throw new IllegalArgumentException("传入的参数有误");}//6.调用工具类执行查询所有return new Executor().selectList(mapper,conn);}
}

执行 赋值的selectList的方法的工具类 utils

负责执行SQL语句,并且封装结果集

package com.fhw.mybatis.utils;import com.fhw.mybatis.cfg.Mapper;import java.beans.PropertyDescriptor;
import java.lang.reflect.Method;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.util.ArrayList;
import java.util.List;/**=* 负责执行SQL语句,并且封装结果集*/
public class Executor {public <E> List<E> selectList(Mapper mapper, Connection conn) {PreparedStatement pstm = null;ResultSet rs = null;try {//1.取出mapper中的数据String queryString = mapper.getQueryString();//select * from userString resultType = mapper.getResultType();//com.itheima.domain.UserClass domainClass = Class.forName(resultType);//2.获取PreparedStatement对象pstm = conn.prepareStatement(queryString);//3.执行SQL语句,获取结果集rs = pstm.executeQuery();//4.封装结果集List<E> list = new ArrayList<E>();//定义返回值while(rs.next()) {//实例化要封装的实体类对象E obj = (E)domainClass.newInstance();//取出结果集的元信息:ResultSetMetaDataResultSetMetaData rsmd = rs.getMetaData();//取出总列数int columnCount = rsmd.getColumnCount();//遍历总列数for (int i = 1; i <= columnCount; i++) {//获取每列的名称,列名的序号是从1开始的String columnName = rsmd.getColumnName(i);//根据得到列名,获取每列的值Object columnValue = rs.getObject(columnName);//给obj赋值:使用Java内省机制(借助PropertyDescriptor实现属性的封装)PropertyDescriptor pd = new PropertyDescriptor(columnName,domainClass);//要求:实体类的属性和数据库表的列名保持一种//获取它的写入方法Method writeMethod = pd.getWriteMethod();//把获取的列的值,给对象赋值writeMethod.invoke(obj,columnValue);}//把赋好值的对象加入到集合中list.add(obj);}return list;} catch (Exception e) {throw new RuntimeException(e);} finally {release(pstm,rs);}}private void release(PreparedStatement pstm,ResultSet rs){if(rs != null){try {rs.close();}catch(Exception e){e.printStackTrace();}}if(pstm != null){try {pstm.close();}catch(Exception e){e.printStackTrace();}}}
}

此刻 需要一个连接对象 一获取资源 与Mapper 语句

package com.fhw.mybatis.utils;import com.fhw.mybatis.cfg.Configuration;
import java.sql.Connection;
import java.sql.DriverManager;/*** 用于创建数据源的工具类*/
public class DataSourceUtil {/*** 用于获取一个连接* @param cfg* @return*/public static Connection getConnection(Configuration cfg){try {Class.forName(cfg.getDriver());return DriverManager.getConnection(cfg.getUrl(), cfg.getUsername(), cfg.getPassword());}catch(Exception e){throw new RuntimeException(e);}}
}

做 成功 呈现的 结果 :

注解 的 实现 :

主配置文件 的改制 :
主配置文件的里mappers里 使用的是Class属性url到该接口


注解 要注意的的一点 mappers(映射器)========------
用于注解开发 ;
注意:此种方法要求 mapper 接口名称和 mapper 映射文件名称相同,且放在同一个目录中。

接着在该 接口里实现 自定义注解的 sql 语句 :

package com.fhw.dao;import com.fhw.domain.User;
/*import com.fhw.mybatis.annotations.Select;*/
import java.util.List;/** 用户的持久层接口*/
public interface IUserDao {/*** 查询所有操作* @return*/@Select("select * from user")List<User> findAll();
}

自定义注解

注解 的生命周期 与 与注解的位置 :

package com.fhw.mybatis.annotations;import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;/*** * 查询的注解*/
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface Select {/*** * sql 语句 查询的注解* @return*/String value();
}

使用注解的就是基于反射 的方式

我们要把 XMLConfigBuilder 代码里的 注解的 给 放行了

该 代码片段是 :有2段

else{System.out.println("使用的是注解");//表示没有resource属性,用的是注解//获取class属性的值String daoClassPath = mapperElement.attributeValue("class");//根据daoClassPath获取封装的必要信息Map<String,Mapper> mappers = loadMapperAnnotation(daoClassPath);//给configuration中的mappers赋值cfg.setMappers(mappers);}
  /*** 根据传入的参数,得到dao中所有被select注解标注的方法。* 根据方法名称和类名,以及方法上注解value属性的值,组成Mapper的必要信息* @param daoClassPath* @return*/private static Map<String,Mapper> loadMapperAnnotation(String daoClassPath)throws Exception{//定义返回值对象Map<String,Mapper> mappers = new HashMap<String, Mapper>();//1.得到dao接口的字节码对象Class daoClass = Class.forName(daoClassPath);//2.得到dao接口中的方法数组Method[] methods = daoClass.getMethods();//3.遍历Method数组for(Method method : methods){//取出每一个方法,判断是否有select注解boolean isAnnotated = method.isAnnotationPresent(Select.class);if(isAnnotated){//创建Mapper对象Mapper mapper = new Mapper();//取出注解的value属性值Select selectAnno = method.getAnnotation(Select.class);String queryString = selectAnno.value();mapper.setQueryString(queryString);//获取当前方法的返回值,还要求必须带有泛型信息Type type = method.getGenericReturnType();//List<User>//判断type是不是参数化的类型if(type instanceof ParameterizedType){//强转ParameterizedType ptype = (ParameterizedType)type;//得到参数化类型中的实际类型参数Type[] types = ptype.getActualTypeArguments();//取出第一个Class domainClass = (Class)types[0];//获取domainClass的类名String resultType = domainClass.getName();//给Mapper赋值mapper.setResultType(resultType);}//组装key的信息//获取方法的名称String methodName = method.getName();String className = method.getDeclaringClass().getName();String key = className+"."+methodName;//给map赋值mappers.put(key,mapper);}}return mappers;}

得到接口的所有方法
遍历 接口的哪一个方法
方法上有 注解 的
注解的value属性:
就是那条sql 语句

mapper 的结果类型 resultType
也很巧妙 :
//获取当前方法的返回值,还要求必须带有泛型信息
Type type = method.getGenericReturnType();//List
Generic在java里是 泛型的意思 :

/得到参数化类型中的实际类型参数
Type[] types = ptype.getActualTypeArguments()
得到实际类型参数 就是pojo 的
//组装key的信息
//获取方法的名称
mappers 就起来 了 ;

===== 基于注解的 自定义Mybatis 效果

MyBatis 简单手写的 实现相关推荐

  1. python简单代码演示效果-10分钟教你用python 30行代码搞定简单手写识别!

    欲直接下载代码文件,关注我们的公众号哦!查看历史消息即可! 手写笔记还是电子笔记好呢? 毕业季刚结束,眼瞅着2018级小萌新马上就要来了,老腊肉小编为了咱学弟学妹们的学习,绞尽脑汁准备编一套大学秘籍, ...

  2. 手写java_JAVA实现简单手写识别

    作为一个机器学习的初学者,首先肯定是要有点自己的对机器学习的看法的. 我认为的机器学习(在我目前接触到的知识来说.!!(大佬勿喷)),机器学习专门研究计算机怎样模拟或实现人类的学习行为,以获取新的知识 ...

  3. JAVA简单手写数字识别

    作为一个机器学习的初学者,首先肯定是要有点自己的对机器学习的看法的.我认为的机器学习(在我目前接触到的知识来说.!!(大佬勿喷)),机器学习专门研究计算机怎样模拟或实现人类的学习行为,以获取新的知识或 ...

  4. opencl 加速 c语言程序_在AlveoU200加速卡上实现简单手写数字识别

    最近实验室租了块xilinx家的AlveoU200加速卡,过去几天被这块板吸引了注意力.刚开始了解,做点什么来试试水呢?一想,可以把曾经学 @蔡宇杰 大佬在pynq-z2上做的那个手写数字识别工程在这 ...

  5. 手写MyBatis分页插件

    目录 前言 MyBatis插件 手写分页插件 总结 前言 在开发查询类的接口时,有一个让开发者比较头疼的问题:分页. 如果每次都要开发者自己去写limit,计算起始行和偏移量就太烦了,于是市面上诞生了 ...

  6. 手写一个简单的IOC容器

    手写一个简单的IOC容器 原文 http://localhost:4000/2020/02/25/SSM/spring/%E6%89%8B%E5%86%99%E4%B8%80%E4%B8%AA%E5% ...

  7. 用了MybatisPlus后,我很久没有手写sql了

    (一)前言 最早写JDBC的时候,要手动配连接信息,要一条条手写sql语句.后来Mybatis出现了,不需要再手动配置连接信息,sql语句也和代码隔离开来,但是还免不了写Sql.接着出现了Mybati ...

  8. Java之手写实现ORM框架

    借鉴Mybatis框架手写一个ORM框架.mybatis整体架构中的整体思路是,首先解析一下配置文件,一个是框架的全局配置文件,一个是mapper配置文件,定义格式如下 <configurati ...

  9. 报告论文:手写数字识别

                                                手写数字识别 简单手写数字识别系统 :我们对VC比较熟悉,采用VC开发.   数字的类别只有十种,笔划又简单,其 ...

  10. 如何手写一个支持H.265的高清播放器

    概述 音视频编解码技术在当前的互联网行业中十分热门,特别是高清视频播放器的开发,其中包括4K.8K等超高清分辨率的播放器,具有极高的市场需求和广泛的应用场景.H265编码技术更是实现高清视频压缩的重要 ...

最新文章

  1. JSON学习笔记-3
  2. git中的gitgnore是什么? 码云gitee
  3. python之socket
  4. 【131天】尚学堂高淇Java300集视频精华笔记(65-66)
  5. homelede软路由设置方法_斐讯无线路由器怎么设置 斐讯无线路由器设置方法【详解】...
  6. Redis学习笔记01---配置文件
  7. 将流数据输出到Mysql中
  8. 用于最优控制的简单软件
  9. 博客迁移至: http://www.cleocn.com
  10. INFO:AdminStudio Debug
  11. C语言中的神兽strdup
  12. mysql命令行闪退解决办法。
  13. 试验设计与方差分析的基本原理——以单因素试验为例
  14. 《区块链底层设计Java实战》之第一章区块链简介
  15. 顶级在线图片处理工具Photopea
  16. 38家公司上榜2020大中华区最佳职场;中国新生代企业家调研白皮书正式发布 | 美通企业日报...
  17. 华为西欧副总裁:华为很快就能推出自研操作系统
  18. 服务器中搭建OA系统,云服务器搭建oa系统
  19. 泪目!上海00后小伙AI「复活」奶奶,100%还原音容笑貌,却引发巨大争议
  20. 数据结构: 算法的时间复杂度和空间复杂度

热门文章

  1. 使用NGUI实现拖拽功能(拼图小游戏)
  2. 被头条开除了....
  3. nstrFetchProhibited,stack overflow,Task watchdog got triggered解决办法
  4. java球球的表面积和体积代码_【编程1小时】球体表面积和体积计算
  5. 在MS Word 中添加 Mathtype 插件(vbe6ext.olb不能被加载问题 已解决)
  6. Tips_linux
  7. uva 1589 - Xiangqi(象棋)
  8. 看看什么叫穿越失败,我承认我确实笑了
  9. docker wordpress 提示:Error establishing a database connection
  10. GoLang之什么是workstealing(5)