手写开源ORM框架介绍
简介
前段时间利用空闲时间，参照mybatis的基本思路手写了一个ORM框架。一直没有时间去补充相应的文档，现在正好抽时间去整理下。通过思路历程和代码注释，一方面重温下知识，另一方面准备后期去完善这个框架。
传统JDBC连接
参照传统的JDBC连接数据库过程如下，框架所做的事情就是把这些步骤进行封装。
// 1. 注册 JDBC 驱动
Class.forName(JDBC_DRIVER);
// 2. 打开链接
conn = DriverManager.getConnection(DB_URL,USER,PASS);
// 3. 实例化statement
stmt = conn.prepareStatement(sql);
// 4. 填充数据
stmt.setString(1,id);
// 5. 执行Sql连接
ResultSet rs = stmt.executeQuery();
// 6. 结果查询
while(rs.next()){
// 7. 通过字段检索
int id = rs.getInt("id");
String name = rs.getString("name");
String url = rs.getString("url");
}
思路历程
上述是执行Java连接数据库通用语句，ORM框架就是对象关系映射框架。我们需要做的重点是步骤4和7，将对象字段填充至数据库，将数据库的内容取出作为对象返回。了解了基本的方法后，开始动手写一个框架了。
数据库驱动
开始，需要构建一个驱动注册类，这个类主要用来对数据库驱动进行构造。详见代码块1
代码块1
数据库驱动类（com.simple.ibatis.dirver）
/**
* @Author xiabing
* @Desc 驱动注册中心，对数据库驱动进行注册的地方
**/
public class DriverRegister { /*
* mysql的driver类
* */
private static final String MYSQLDRIVER = "com.mysql.jdbc.Driver"; /*
* 构建driver缓存，存储已经注册了的driver的类型
* */
private static final Map<String,Driver> registerDrivers = new ConcurrentHashMap<>(); /*
* 初始化，此处是将DriverManager中已经注册了驱动放入自己缓存中。当然，你也可以在这个方法内注册
常见的数据库驱动，这样后续就可以直接使用，不用自己手动注册了。
* */
static {
Enumeration<Driver> driverEnumeration = DriverManager.getDrivers();
while (driverEnumeration.hasMoreElements()){
Driver driver = driverEnumeration.nextElement();
registerDrivers.put(driver.getClass().getName(),driver);
}
} /*
* 加载mysql驱动，此个方法可以写在静态代码块内，代表项目启动时即注册mysql驱动
* */
public void loadMySql(){
if(! registerDrivers.containsKey(MYSQLDRIVER)){
loadDriver(MYSQLDRIVER);
}
} /*
* 加载数据库驱动通用方法，并注册到registerDrivers缓存中，此处是注册数据库驱动的方法
* */
public void loadDriver(String driverName){ Class<?> driverType;
try {
// 注册驱动，返回驱动类
driverType = Class.forName(driverName);
// 将驱动实例放入驱动缓存中
registerDrivers.put(driverType.getName(),(Driver)driverType.newInstance());
}catch (ClassNotFoundException e){
throw new RuntimeException(e);
}catch (Exception e){
throw new RuntimeException(e);
}
}
}
驱动注册后，需要建立数据库连接。但是框架如果一个请求建一个连接，那木势必耗费大量的资源。所以该框架引入池化的概念，对连接进行池化管理。详情见代码2
代码块2
数据源类（com.simple.ibatis.datasource）
PoolConnection
/**
* @Author xiabing
* @Desc 连接代理类，是对Connection的一个封装。除了提供基本的连接外，还想记录
这个连接的连接时间，因为有的连接如果一直连接不释放，那木我可以通过查看
这个连接已连接的时间，如果超时了，我可以主动释放。
**/
public class PoolConnection { // 真实的数据库连接
public Connection connection; // 数据开始连接时间
private Long CheckOutTime; // 连接的hashCode
private int hashCode = 0; public PoolConnection(Connection connection) {
this.connection = connection;
this.hashCode = connection.hashCode();
} public Long getCheckOutTime() {
return CheckOutTime;
} public void setCheckOutTime(Long checkOutTime) {
CheckOutTime = checkOutTime;
} // 判断两个PoolConnection对象是否相等，其实是判断其中真实连接的hashCode是否相等
@Override
public boolean equals(Object obj) {
if(obj instanceof PoolConnection){
return connection.hashCode() ==
((PoolConnection) obj).connection.hashCode();
}else if(obj instanceof Connection){
return obj.hashCode() == hashCode;
}else {
return false;
}
} @Override
public int hashCode() {
return hashCode;
}
}
NormalDataSource
/**
* @Author xiabing
* @Desc 普通数据源,这个数据源是用来产生数据库连接的。来一个请求就会建立一个数据库连接，没有池化的概念
**/
public class NormalDataSource implements DataSource{ // 驱动名称
private String driverClassName; // 数据库连接URL
private String url; // 数据库用户名
private String userName; // 数据库密码
private String passWord; // 驱动注册中心
private DriverRegister driverRegister = new DriverRegister(); public NormalDataSource(String driverClassName, String url, String userName, String passWord) {
// 初始化时将驱动进行注册
this.driverRegister.loadDriver(driverClassName);
this.driverClassName = driverClassName;
this.url = url;
this.userName = userName;
this.passWord = passWord;
} // 获取数据库连接
@Override
public Connection getConnection() throws SQLException {
return DriverManager.getConnection(url,userName,passWord); } // 移除数据库连接，此方法没有真正移除，只是将连接中未提交的事务进行回滚操作。
public void removeConnection(Connection connection) throws SQLException{
if(!connection.getAutoCommit()){
connection.rollback();
}
} // 获取数据库连接
@Override
public Connection getConnection(String username, String password) throws SQLException {
return DriverManager.getConnection(url,username,password);
} // 后续方法因为没有用到，所有没有进行重写了
@Override
public <T> T unwrap(Class<T> iface) throws SQLException {
return null;
} @Override
public boolean isWrapperFor(Class<?> iface) throws SQLException {
return false;
} @Override
public PrintWriter getLogWriter() throws SQLException {
return null;
} @Override
public void setLogWriter(PrintWriter out) throws SQLException { } @Override
public void setLoginTimeout(int seconds) throws SQLException { } @Override
public int getLoginTimeout() throws SQLException {
return 0;
} @Override
public Logger getParentLogger() throws SQLFeatureNotSupportedException {
return null;
} }
PoolDataSource
/**
* @Author xiabing
* @Desc 池化线程池,对连接进行管理
**/
public class PoolDataSource implements DataSource{ private Integer maxActiveConnectCount = 10; // 最大活跃线程数，此处可根据实际情况自行设置 private Integer maxIdleConnectCount = 10; // 最大空闲线程数，此处可根据实际情况自行设置 private Long maxConnectTime = 30*1000L; // 连接最长使用时间，在自定义连接中配置了连接开始时间，在这里来判断该连接是否超时 private Integer waitTime = 2000; // 线程wait等待时间 private NormalDataSource normalDataSource; // 使用normalDataSource来产生连接 private Queue<PoolConnection> activeConList = new LinkedList<>(); // 存放活跃连接的队列 private Queue<PoolConnection> idleConList = new LinkedList<>(); // 存放空闲连接的队列 public PoolDataSource(String driverClassName, String url, String userName, String passWord) { this(driverClassName,url,userName,passWord,10,10); } public PoolDataSource(String driverClassName, String url, String userName, String passWord,Integer maxActiveConnectCount,Integer maxIdleConnectCount) {
// 初始化normalDataSource，因为normalDataSource已经封装了新建连接的方法
this.normalDataSource = new NormalDataSource(driverClassName,url,userName,passWord);
this.maxActiveConnectCount = maxActiveConnectCount;
this.maxIdleConnectCount = maxIdleConnectCount; }
/**
* @Desc 获取连接时先从空闲连接列表中获取。若没有，则判断现在活跃连接是否已超过设置的最大活跃连接数，没超过，new一个
* 若超过，则判断第一个连接是否已超时，若超时，则移除掉在新建。若未超时，则wait(）等待。
**/
@Override
public Connection getConnection(){
Connection connection = null;
try {
connection = doGetPoolConnection().connection;
}catch (SQLException e){
throw new RuntimeException(e);
}
return connection;
} public void removeConnection(Connection connection){
PoolConnection poolConnection = new PoolConnection(connection);
doRemovePoolConnection(poolConnection);
} private PoolConnection doGetPoolConnection() throws SQLException{
PoolConnection connection = null;
while (connection == null){
// 加锁
synchronized (this){
// 判断是否有空闲连接
if(idleConList.size() < 1){
// 判断活跃连接数是否已经超过预设的最大活跃连接数
if(activeConList.size() < maxActiveConnectCount){
// 如果还可以新建连接，就新建一个连接
connection = new PoolConnection(normalDataSource.getConnection());
}else {
// 走到这一步，说明没有空闲连接，并且活跃连接已经满了，则只能看哪些连接超时，判断第一个连接是否超时
PoolConnection poolConnection = activeConList.peek();
// 这就是我为啥要给数据库连接加连接时间了
if(System.currentTimeMillis() - poolConnection.getCheckOutTime() > maxConnectTime){
// 若第一个连接已经超时了，移除第一个活跃连接
PoolConnection timeOutConnect = activeConList.poll();
if(!timeOutConnect.connection.getAutoCommit()){
// 如果该连接设的是非自动提交，则对事物进行回滚操作
timeOutConnect.connection.rollback();
}
// 置为空，让垃圾收集器去收集
timeOutConnect.connection.close();
timeOutConnect = null;
// 新建一个连接
connection = new PoolConnection(normalDataSource.getConnection());
}else {
// 走到这一步，代表所有连接都没有超时，只能等了
try{
// 于是等一会
this.wait(waitTime);
}catch (InterruptedException e){
// ignore错误，并退出
break;
}
}
}
}else {
// 这一步代表空闲连接队列里面有连接，则直接取出
connection = idleConList.poll();
}
if(connection != null){
// 设置这个连接的连接时间
connection.setCheckOutTime(System.currentTimeMillis());
// 然后放入活跃连接队列中
activeConList.add(connection);
}
}
} return connection;
} // 移除连接
private void doRemovePoolConnection(PoolConnection connection){
// 加锁
synchronized (this){
// 移除连接，这里需要重写PoolConnection的equal方法，因为只要真实连接相同，就可以代表这个封装的连接相等了
activeConList.remove(connection);
if(idleConList.size() < maxIdleConnectCount){
// 加入空闲连接队列中
idleConList.add(connection);
}
// 通知其他等待线程，让他们继续获取连接
this.notifyAll();
}
} @Override
public Connection getConnection(String username, String password) throws SQLException {
return getConnection();
} // 后面的方法没有用到就没有重写了
@Override
public <T> T unwrap(Class<T> iface) throws SQLException {
return null;
} @Override
public boolean isWrapperFor(Class<?> iface) throws SQLException {
return false;
} @Override
public PrintWriter getLogWriter() throws SQLException {
return null;
} @Override
public void setLogWriter(PrintWriter out) throws SQLException { } @Override
public void setLoginTimeout(int seconds) throws SQLException { } @Override
public int getLoginTimeout() throws SQLException {
return 0;
} @Override
public Logger getParentLogger() throws SQLFeatureNotSupportedException {
return null;
}
}
使用数据库连接池获取连接后，接下来就是关键了，生成SQL预处理语句，并进行数据填充。这让我想到了mybatis使用方法。
@Select("select * from users")
List<User> getUsers();
上面是mybatis基于注解的配置方式。除了注解，还支持xml。于是框架准备先使用基于注解的方式进行代码配置。首先，需要知道这些接口类的类名。于是提供一个配置，根据指定包名获取包下所有类的类名详情见代码3
代码块3
方法类（com.simple.ibatis.util）
PackageUtil
/**
* @Author xiabing
* @Desc 获取指定包下所有类的名称
**/
public class PackageUtil { private static final String CLASS_SUFFIX = ".class";
private static final String CLASS_FILE_PREFIX = "classes" + File.separator;
private static final String PACKAGE_SEPARATOR = "."; /**
* 查找包下的所有类的名字
* @param packageName
* @param showChildPackageFlag 是否需要显示子包内容
* @return List集合，内容为类的全名
*/
public static List<String> getClazzName(String packageName, boolean showChildPackageFlag){
List<String> classNames = new ArrayList<>();
String suffixPath = packageName.replaceAll("\\.", "/");
// 获取类加载器
ClassLoader loader = Thread.currentThread().getContextClassLoader();
try{
Enumeration<URL> urls = loader.getResources(suffixPath);
while(urls.hasMoreElements()) {
URL url = urls.nextElement();
if(url != null){
if ("file".equals(url.getProtocol())) {
String path = url.getPath();
classNames.addAll(getAllClassName(new File(path),showChildPackageFlag));
}
}
}
}catch (IOException e){
throw new RuntimeException("load resource is error , resource is "+packageName);
}
return classNames;
} // 获取所有类的名称
private static List<String> getAllClassName(File file,boolean flag){ List<String> classNames = new ArrayList<>(); if(!file.exists()){
return classNames;
}
if(file.isFile()){
String path = file.getPath();
if(path.endsWith(CLASS_SUFFIX)){
path = path.replace(CLASS_SUFFIX,"");
String clazzName = path.substring(path.indexOf(CLASS_FILE_PREFIX) + CLASS_FILE_PREFIX.length()).replace(File.separator, PACKAGE_SEPARATOR);
classNames.add(clazzName);
}
}else {
File[] listFiles = file.listFiles();
if(listFiles != null && listFiles.length > 0){
for (File f : listFiles){
if(flag) {
classNames.addAll(getAllClassName(f, flag));
}else {
if(f.isFile()){
String path = f.getPath();
if(path.endsWith(CLASS_SUFFIX)) {
path = path.replace(CLASS_SUFFIX, "");
String clazzName = path.substring(path.indexOf(CLASS_FILE_PREFIX) + CLASS_FILE_PREFIX.length()).replace(File.separator,PACKAGE_SEPARATOR);
classNames.add(clazzName);
}
}
}
}
}
}
return classNames;
}
}
在知道接口类存放在哪些类后，我需要解析这些类中的各个方法，包括每个方法的注解，入参，和返回值。同时，我需要使用一个全局配置类，用于存放我解析后生成的对象，并且一些数据源配置信息也可以放在这个全局类中。详情见代码4
代码块4
核心类（com.simple.ibatis.core）
Config
/**
* @Author xiabing
* @Desc 框架的核心配置类
**/
public class Config { // 数据源
private PoolDataSource dataSource; // mapper包地址（即待解析的包名），后续改为List<String>，能同时加载多个mapper包 todo
private String daoSource; // mapper核心文件（存放类解析后的对象）
private MapperCore mapperCore; // 是否启用事务
private boolean openTransaction; // 是否开启缓存
private boolean openCache; public Config(String mapperSource,PoolDataSource dataSource){
this.dataSource = dataSource;
this.daoSource = mapperSource;
this.mapperCore = new MapperCore(this);
} // 生成SQL语句执行器
public SimpleExecutor getExecutor(){
return new SimpleExecutor(this,this.getDataSource(),openTransaction,openCache);
} // 后文都是基本的get,set方法
public PoolDataSource getDataSource() {
return dataSource;
} public void setDataSource(PoolDataSource dataSource) {
this.dataSource = dataSource;
} public String getDaoSource() {
return daoSource;
} public void setDaoSource(String daoSource) {
this.daoSource = daoSource;
} public MapperCore getMapperCore() {
return mapperCore;
} public void setMapperCore(MapperCore mapperCore) {
this.mapperCore = mapperCore;
} public boolean isOpenTransaction() {
return openTransaction;
} public void setOpenTransaction(boolean openTransaction) {
this.openTransaction = openTransaction;
} public boolean isOpenCache() {
return openCache;
} public void setOpenCache(boolean openCache) {
this.openCache = openCache;
} }
SqlSource
/**
* @Author xiabing5
* @Desc 将sql语句拆分为sql部分和参数部分,因为我们需要使用java对象对数据库预处理对象进行注入。具体看下面例子 * @example select * from users where id = {user.id} and name = {user.name}
* -> sql = select * from users where id = ? and name = ?
* -> paramResult = {user.id,user.name}
**/
public class SqlSource {
/**sql语句，待输入字段替换成?*/
private String sql;
/**待输入字段*/
private List<String> param;
/**select update insert delete*/
private Integer executeType; public SqlSource(String sql){
this.param = new ArrayList<>();
this.sql = sqlInject(this.param,sql);
} /**sql注入，对要注入的属性，必须使用{} 包裹，并替换为？ 见例子 */
private String sqlInject(List<String> paramResult, String sql){ String labelPrefix = "{"; String labelSuffix = "}";
// 将语句的所有的{}全部都解析成？,并将{xxx}中的xxx提取出来。
while (sql.indexOf(labelPrefix) > 0 && sql.indexOf(labelSuffix) > 0){
String sqlParamName = sql.substring(sql.indexOf(labelPrefix),sql.indexOf(labelSuffix)+1);
sql = sql.replace(sqlParamName,"?");
paramResult.add(sqlParamName.replace("{","").replace("}",""));
}
return sql;
} public String getSql() {
return sql;
} public void setSql(String sql) {
this.sql = sql;
} public List<String> getParam() {
return param;
} public void setParam(List<String> param) {
this.param = param;
} public Integer getExecuteType() {
return executeType;
} public void setExecuteType(Integer executeType) {
this.executeType = executeType;
}
}
MapperCore
/**
* @Author xiabing5
* @Desc mapper方法解析核心类,此处是将接口中的方法进行解析的关键类
**/
public class MapperCore { // select方法
private static final Integer SELECT_TYPE = 1;
// update方法
private static final Integer UPDATE_TYPE = 2;
// delete方法
private static final Integer DELETE_TYPE = 3;
// insert方法
private static final Integer INSERT_TYPE = 4; /**mapper文件解析类缓存，解析后都放在里面，避免重复对一个mapper文件进行解析*/
private static Map<String,MethodDetails> cacheMethodDetails = new ConcurrentHashMap<>(); /**
* 全局配置
* */
private Config config; public MapperCore(Config config){
this.config = config;
load(config.getDaoSource());
} /*
* 加载，解析指定包名下的类
* */
private void load(String source){
/**加载mapper包下的文件*/
List<String> clazzNames = PackageUtil.getClazzName(source,true);
try{
for(String clazz: clazzNames){
Class<?> nowClazz = java.lang.Class.forName(clazz);
// 不是接口跳过，只能解析接口
if(!nowClazz.isInterface()){
continue;
} /**接口上没有@Dao跳过。我们对接口类上加了@Dao后，就代表要解析*/
boolean skip = false;
Annotation[] annotations = nowClazz.getDeclaredAnnotations();
for(Annotation annotation:annotations){
// 该接口中的注释中是否有带@Dao
if(annotation instanceof Dao) {
skip = true;
break;
}
}
if(!skip){
continue;
}
// 调用反射接口，获取所有接口中的方法
Method[] methods = nowClazz.getDeclaredMethods();
for( Method method : methods){
// 解析方法详情
MethodDetails methodDetails = handleParameter(method);
// 解析@SELECT()等注解中的SQL内容
methodDetails.setSqlSource(handleAnnotation(method));
// 解析完成后放入缓存
cacheMethodDetails.put(generateStatementId(method),methodDetails);
}
}
}catch (ClassNotFoundException e){
throw new RuntimeException(" class load error,class is not exist");
}
} /**
* 获得方法详情，从方法缓存池中获取，因为每个方法事先已经完成解析
* */
public MethodDetails getMethodDetails(Method method){
String statementId = generateStatementId(method);
if(cacheMethodDetails.containsKey(statementId)){
return cacheMethodDetails.get(statementId);
}
return new MethodDetails();
} /**
* 获得方法对应的sql语句
* */
public SqlSource getStatement(Method method){
String statementId = generateStatementId(method);
if(cacheMethodDetails.containsKey(statementId)){
return cacheMethodDetails.get(statementId).getSqlSource();
}
throw new RuntimeException(method + " is not sql");
} /**
* 获得方法对应的参数名
* */
public List<String> getParameterName(Method method){
String statementId = generateStatementId(method);
if(cacheMethodDetails.containsKey(statementId)){
return cacheMethodDetails.get(statementId).getParameterNames();
}
return new ArrayList<>();
} /**
* 获取方法返回类型
* */
public Class getReturnType(Method method){
String statementId = generateStatementId(method);
if(cacheMethodDetails.containsKey(statementId)){
return cacheMethodDetails.get(statementId).getReturnType();
}
return null;
} /**
* 获得方法对应的参数类型
* */
public Class<?>[] getParameterType(Method method) {
String statementId = generateStatementId(method);
if(cacheMethodDetails.containsKey(statementId)){
return cacheMethodDetails.get(statementId).getParameterTypes();
}
return new Class<?>[]{};
} /**
* 获得方法是SELECT UPDATE DELETE INSERT
* */
public Integer getMethodType(Method method){
String statementId = generateStatementId(method);
if(cacheMethodDetails.containsKey(statementId)){
return cacheMethodDetails.get(statementId).getSqlSource().getExecuteType();
}
return null;
} /**
* 获得方法是否返回集合类型list
* */
public boolean getHasSet(Method method){
String statementId = generateStatementId(method);
if(cacheMethodDetails.containsKey(statementId)){
return cacheMethodDetails.get(statementId).isHasSet();
}
return false;
} /**
* 解析方法内的注解
* */
private MethodDetails handleParameter(Method method){ MethodDetails methodDetails = new MethodDetails(); // 获取方法输入参数数量
int parameterCount = method.getParameterCount(); // 获取方法输入各参数类型
Class<?>[] parameterTypes = method.getParameterTypes(); // 获取方法输入各参数名称
List<String> parameterNames = new ArrayList<>(); Parameter[] params = method.getParameters();
for(Parameter parameter:params){
parameterNames.add(parameter.getName());
} /*
* 获得方法参数的注解值替代默认值，如果使用了@Param注解，则默认使用注解中的值作为参数名
* */
for(int i = 0; i < parameterCount; i++){
parameterNames.set(i,getParamNameFromAnnotation(method,i,parameterNames.get(i)));
} methodDetails.setParameterTypes(parameterTypes);
methodDetails.setParameterNames(parameterNames); /** 获取方法返回类型*/
Type methodReturnType = method.getGenericReturnType();
Class<?> methodReturnClass = method.getReturnType();
if(methodReturnType instanceof ParameterizedType){
/** 返回是集合类 目前仅支持List todo*/
if(!List.class.equals(methodReturnClass)){
throw new RuntimeException("now ibatis only support list");
}
Type type = ((ParameterizedType) methodReturnType).getActualTypeArguments()[0];
/** 设置 返回集合中的对象类型 */
methodDetails.setReturnType((Class<?>) type);
/** 标注该方法返回类型是集合类型 */
methodDetails.setHasSet(true);
}else {
/** 不是集合类型，就直接设置返回类型 */
methodDetails.setReturnType(methodReturnClass);
/** 标注该方法返回类型不是集合类型 */
methodDetails.setHasSet(false);
} return methodDetails;
} /**
* 解析@select，@update等注解，获取SQL语句，并封装成对象
* */
private SqlSource handleAnnotation(Method method){
SqlSource sqlSource = null;
String sql = null;
/** 获取方法上所有注解 */
Annotation[] annotations = method.getDeclaredAnnotations();
for(Annotation annotation : annotations){
/** 如果有@select注解 */
if(Select.class.isInstance(annotation)){
Select selectAnnotation = (Select)annotation;
sql = selectAnnotation.value();
/** 语句封装成sqlSource对象 */
sqlSource = new SqlSource(sql);
/** 设置执行语句类型 */
sqlSource.setExecuteType(SELECT_TYPE);
break;
}else if(Update.class.isInstance(annotation)){
Update updateAnnotation = (Update)annotation;
sql = updateAnnotation.value();
sqlSource = new SqlSource(sql);
sqlSource.setExecuteType(UPDATE_TYPE);
break;
}else if(Delete.class.isInstance(annotation)){
Delete deleteAnnotation = (Delete) annotation;
sql = deleteAnnotation.value();
sqlSource = new SqlSource(sql);
sqlSource.setExecuteType(DELETE_TYPE);
break;
}else if(Insert.class.isInstance(annotation)){
Insert insertAnnotation = (Insert) annotation;
sql = insertAnnotation.value();
sqlSource = new SqlSource(sql);
sqlSource.setExecuteType(INSERT_TYPE);
break;
}
}
if(sqlSource == null){
throw new RuntimeException("method annotation not null");
}
return sqlSource;
} /**
* 获取@Param注解内容
* */
private String getParamNameFromAnnotation(Method method, int i, String paramName) {
final Object[] paramAnnos = method.getParameterAnnotations()[i];
for (Object paramAnno : paramAnnos) {
if (paramAnno instanceof Param) {
paramName = ((Param) paramAnno).value();
}
}
return paramName;
} /**
* 生成唯一的statementId
* */
private static String generateStatementId(Method method){
return method.getDeclaringClass().getName() + "." + method.getName();
} /**
* 每个mapper方法的封装类
* */
public static class MethodDetails{
/**方法返回类型,若是集合，则代表集合的对象类，目前集合类仅支持返回List */
private Class<?> returnType; /**方法返回类型是否是集合*/
private boolean HasSet; /**执行类型，SELECT,UPDATE,DELETE,INSERT*/
private Integer executeType; /**方法输入参数类型集合*/
private Class<?>[] parameterTypes; /**方法输入参数名集合*/
private List<String> parameterNames; /**sql语句集合*/
private SqlSource sqlSource; public Class<?> getReturnType() {
return returnType;
} public void setReturnType(Class<?> returnType) {
this.returnType = returnType;
} public boolean isHasSet() {
return HasSet;
} public void setHasSet(boolean hasSet) {
HasSet = hasSet;
} public Integer getExecuteType() {
return executeType;
} public void setExecuteType(Integer executeType) {
this.executeType = executeType;
} public Class<?>[] getParameterTypes() {
return parameterTypes;
} public void setParameterTypes(Class<?>[] parameterTypes) {
this.parameterTypes = parameterTypes;
} public List<String> getParameterNames() {
return parameterNames;
} public void setParameterNames(List<String> parameterNames) {
this.parameterNames = parameterNames;
} public SqlSource getSqlSource() {
return sqlSource;
} public void setSqlSource(SqlSource sqlSource) {
this.sqlSource = sqlSource;
}
}
}
SQL语句已经解析完毕，后面开始执行SQL语句。在之前，我想给执行SQL语句时加点功能，如提供select缓存，事务功能，详情见代码块5，代码块6
代码块5
缓存类（com.simple.ibatis.cache）
Cache
/**
* @author xiabing
* @description: 自定义缓存接口,主要提供增删改查功能
*/
public interface Cache { /**放入缓存*/
void putCache(String key,Object val); /**获取缓存*/
Object getCache(String key); /**清空缓存*/
void cleanCache(); /**获取缓存健数量*/
int getSize(); /**移除key的缓存*/
void removeCache(String key);
}
SimpleCache
/**
* @author xiabing
* @description: 缓存的简单实现
*/
public class SimpleCache implements Cache{ /**用HashMap来实现缓存的增删改查*/
private static Map<String,Object> map = new HashMap<>(); @Override
public void putCache(String key, Object val) {
map.put(key,val);
} @Override
public Object getCache(String key) {
return map.get(key);
} @Override
public void cleanCache() {
map.clear();
} @Override
public int getSize() {
return map.size();
} @Override
public void removeCache(String key) {
map.remove(key);
}
}
LruCache
/**
* @author xiabing
* @description: 缓存包装类没，使缓存具有LRU功能
*/
public class LruCache implements Cache{ /**缓存大小*/
private static Integer cacheSize = 2000; /**HashMap负载因子，可以自己指定*/
private static Float loadFactory = 0.75F; /**真实缓存*/
private Cache trueCache; /**使用LinkedHashMap来实现Lru功能*/
private Map<String,Object> linkedCache; /**待移除的元素*/
private static Map.Entry removeEntry; public LruCache(Cache trueCache){
this(cacheSize,loadFactory,trueCache);
} public LruCache(Integer cacheSize, Float loadFactory, Cache trueCache) {
this.trueCache = trueCache;
/**初始化LinkedHashMap,并重写removeEldestEntry() 方法,不了解的可以看我之前的博客*/
this.linkedCache = new LinkedHashMap<String, Object>(cacheSize,loadFactory,true){
@Override
protected boolean removeEldestEntry(Map.Entry eldest) {
// 当缓存容量超过设置的容量时，返回true,并记录待删除的对象
if(getSize() > cacheSize){
removeEntry = eldest;
return true;
}
return false;
}
};
} // 放入缓存，当待删除的元素不为空时，就在真实缓存中删除该元素
@Override
public void putCache(String key, Object val) {
// 真实缓存中放入
this.trueCache.putCache(key,val);
// linkedHashMap中放入,此处放入会调用重写的removeEldestEntry()方法
this.linkedCache.put(key,val);
// 当removeEldestEntry()执行后，如果有待删除元素，就开始执行删除操作
if(removeEntry != null){
removeCache((String)removeEntry.getKey());
removeEntry = null;
}
} @Override
public Object getCache(String key) {
// 因为调用linkedHashMap中的get()方法会对链表进行再一次排序。见之前关于缓存的博客
linkedCache.get(key);
return trueCache.getCache(key);
} @Override
public void cleanCache() {
trueCache.cleanCache();
linkedCache.clear();
} @Override
public int getSize() {
return trueCache.getSize();
} @Override
public void removeCache(String key) {
trueCache.removeCache(key);
}
}
代码块6
事务类（com.simple.ibatis.transaction）
Transaction
/**
* @Author xiabing
* @Desc 封装事务功能
**/
public interface Transaction { /**获取数据库连接*/
Connection getConnection() throws SQLException; /**事务提交*/
void commit() throws SQLException; /**事务回滚*/
void rollback() throws SQLException; /**关闭连接*/
void close() throws SQLException;
}
SimpleTransaction
/**
* @Author xiabing
* @Desc 事务的简单实现，封装了数据库的事务功能
**/
public class SimpleTransaction implements Transaction{ private Connection connection; // 数据库连接
private PoolDataSource dataSource; // 数据源
private Integer level = Connection.TRANSACTION_REPEATABLE_READ; // 事务隔离级别
private Boolean autoCommmit = true; // 是否自动提交 public SimpleTransaction(PoolDataSource dataSource){
this(dataSource,null,null);
} public SimpleTransaction(PoolDataSource dataSource, Integer level, Boolean autoCommmit) {
this.dataSource = dataSource;
if(level != null){
this.level = level;
}
if(autoCommmit != null){
this.autoCommmit = autoCommmit;
}
} /**获取数据库连接，并设置该连接的事务隔离级别，是否自动提交*/
@Override
public Connection getConnection() throws SQLException{
if(connection != null){
return connection;
}
this.connection = dataSource.getConnection(); this.connection.setAutoCommit(autoCommmit); this.connection.setTransactionIsolation(level); return this.connection;
} @Override
public void commit() throws SQLException{
if(this.connection != null){
this.connection.commit();
}
} @Override
public void rollback() throws SQLException{
if(this.connection != null){
this.connection.rollback();
}
} /**关闭连接*/
@Override
public void close() throws SQLException{
/**如果该连接设置自动连接为false,则在关闭前进行事务回滚一下*/
if(autoCommmit != null && !autoCommmit){
connection.rollback();
} if(connection != null){
dataSource.removeConnection(connection);
} this.connection = null;
}
}
TransactionFactory
/**
* @Author xiabing
* @Desc 事务工厂，封装获取事务的功能
**/
public class TransactionFactory { public static SimpleTransaction newTransaction(PoolDataSource poolDataSource, Integer level, Boolean autoCommmit){
return new SimpleTransaction(poolDataSource,level,autoCommmit);
} }
代码真正执行SQL的地方，见代码块7
代码块7
语句执行类（com.simple.ibatis.execute）
Executor
/**
* @Author xiabing
* @Desc 执行接口类，后续执行器需要实现此接口
**/
public interface Executor { /**获取Mapper接口代理类，使用了动态代理技术，见实现类分析*/
<T> T getMapper(Class<T> type); void commit() throws SQLException; void rollback() throws SQLException; void close() throws SQLException;
}
SimpleExecutor
/**
* @Author xiabing
* @Desc 简单执行器类，对于Sql的执行和处理都依赖此类
**/
public class SimpleExecutor implements Executor{ /**全局配置类*/
public Config config; /**mapper核心类，解析mapper接口类*/
public MapperCore mapperCore; /**数据库源*/
public PoolDataSource poolDataSource; /**事务*/
public Transaction transaction; /**缓存*/
public Cache cache; public SimpleExecutor(Config config,PoolDataSource poolDataSource){
this(config,poolDataSource,false,false);
} public SimpleExecutor(Config config,PoolDataSource poolDataSource,boolean openTransaction,boolean openCache){
this.config = config;
this.mapperCore = config.getMapperCore();
this.poolDataSource = poolDataSource;
if(openCache){
// 设置缓存策略为LRU
this.cache = new LruCache(new SimpleCache());
}
if(openTransaction){
// 关闭自动提交
this.transaction = TransactionFactory.newTransaction(poolDataSource,Connection.TRANSACTION_REPEATABLE_READ,false);
}else {
// 开启自动提交
this.transaction = TransactionFactory.newTransaction(poolDataSource,null,null);
}
} /**
* @Desc 获取mapper接口的代理类
为什么要使用代理类，因为我们写mapper接口类只写了接口，却没有提供它的实现。于是
使用动态代理机制对这些接口进行代理，在代理类中实现sql执行的方法。此处是参照
mybatis的设计。
**/
@Override
public <T> T getMapper(Class<T> type){
/**MapperProxy代理类分析见详情8.1*/
MapperProxy mapperProxy = new MapperProxy(type,this);
return (T)mapperProxy.initialization();
} /*select 语句执行流程分析**/
public <E> List<E> select(Method method,Object[] args) throws Exception{ /**PreparedStatementHandle 生成器见9.1 */
PreparedStatementHandle preparedStatementHandle = new PreparedStatementHandle(mapperCore,transaction,method,args);
PreparedStatement preparedStatement = preparedStatementHandle.generateStatement(); /**执行查询接口，此处是真实调用sql语句的地方 */
preparedStatement.executeQuery();
ResultSet resultSet = preparedStatement.getResultSet(); /**查询方法的返回参数值，若是void类型，就不用返回任务东西 */
Class returnClass = mapperCore.getReturnType(method);
if(returnClass == null || void.class.equals(returnClass)){
return null;
}else {
/**ResultSetHandle 结果处理器见9.2 */
ResultSetHandle resultSetHandle = new ResultSetHandle(returnClass,resultSet);
return resultSetHandle.handle();
}
} /*update 语句执行流程分析,update，delete,insert都是调用的这个方法**/
public int update(Method method,Object[] args)throws SQLException{
PreparedStatementHandle preparedStatementHandle = null;
PreparedStatement preparedStatement = null;
Integer count = null;
try{
/**PreparedStatementHandle 生成器见9.1 */
preparedStatementHandle = new PreparedStatementHandle(mapperCore,transaction,method,args);
preparedStatement = preparedStatementHandle.generateStatement(); /**返回受影响的行数 */
count = preparedStatement.executeUpdate();
}finally {
if(preparedStatement != null){
preparedStatement.close();
}
}
return count;
} /**后续方法直接调用transaction相关方法*/
@Override
public void commit() throws SQLException{
transaction.commit();
} @Override
public void rollback() throws SQLException{
transaction.rollback();
} @Override
public void close() throws SQLException{
transaction.close();
}
}
因为我们mapper接口类只有接口，没有实现。但为什么可以调用这些接口方法？此处参照mybatis源码，自己通过动态代理技术实现接口的动态代理，在代理方法里写我们自己执行Sql的逻辑。代理类见代码块8
代码块8
mapper接口代理类（com.simple.ibatis.execute）
MapperProxy
/**
* @Author xiabing
* @Desc mapper接口代理类
**/
public class MapperProxy<T> implements InvocationHandler{ /**要代理的mapper接口类*/
private Class<T> interfaces; /**具体的执行器，执行mapper中的一个方法相当于执行一条sql语句*/
private SimpleExecutor executor; public MapperProxy(Class<T> interfaces,SimpleExecutor executor) {
this.interfaces = interfaces;
this.executor = executor;
} /**反射方法，该方法自定义需要代理的逻辑。不了解可以去看下JAVA动态代理技术*/
@Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
Object result = null;
/**object方法直接代理*/
if(Object.class.equals(method.getDeclaringClass())){
result = method.invoke(this,args);
}else {
// 获取方法是select还是非select方法
Integer methodType = executor.mapperCore.getMethodType(method); if(methodType == null){
throw new RuntimeException("method is normal sql method");
}
if(methodType == 1){
/**调用执行器的select方法，返回集合类*/
List<Object> list = executor.select(method,args);
result = list;
/**查看接口的返回是List，还是单个对象*/
if(!executor.mapperCore.getHasSet(method)){
if(list.size() == 0){
result = null;
}else {
/**单个对象就直接取第一个*/
result = list.get(0);
}
} }else{
/**返回受影响的行数*/
Integer count = executor.update(method,args);
result = count;
}
}
return result;
} /**构建代理类*/
public T initialization(){
return (T)Proxy.newProxyInstance(interfaces.getClassLoader(),new Class[] { interfaces },this);
}
}
代码块7中执行SQL其实包含3个过程，生成SQL预处理语句，执行SQL，将SQL结果转为JAVA对象。详情见代码块9
代码块9
各生成器类（com.simple.ibatis.statement）
PreparedStatementHandle
/**
* @Author xiabing
* @Desc PreparedStatement生成器
**/
public class PreparedStatementHandle {
/**
* 全局核心mapper解析类
*/
private MapperCore mapperCore; /**
* 待执行的方法
*/
private Method method; private Transaction transaction; private Connection connection; /**
* 方法输入参数
*/
private Object[] args; public PreparedStatementHandle(MapperCore mapperCore, Transaction transaction,Method method, Object[] args)throws SQLException {
this.mapperCore = mapperCore;
this.method = method;
this.transaction = transaction;
this.args = args;
connection = transaction.getConnection();
} /**
* @Author xiabing5
* @Desc 参数处理核心方法 todo
**/
public PreparedStatement generateStatement() throws SQLException{
// 获取已经解析方法的sqlSource类，已经将待注入字段变为？，后续直接填充就好
SqlSource sqlSource = mapperCore.getStatement(method);
// 调用connection方法生成预处理语句
PreparedStatement preparedStatement = connection.prepareStatement(sqlSource.getSql()); // 获取方法输入参数的类型
Class<?>[] clazzes = mapperCore.getParameterType(method);
List<String> paramNames = mapperCore.getParameterName(method);
List<String> params = sqlSource.getParam();
// 详见typeInject方法，注入SQL参数
preparedStatement = typeInject(preparedStatement,clazzes,paramNames,params,args);
return preparedStatement;
} /**
* @Author xiabing
* @Desc preparedStatement构建，将参数注入到SQL语句中
* @Param preparedStatement 待构建的preparedStatement
* @Param clazzes 该方法中参数类型数组
* @Param paramNames 该方法中参数名称列表,若有@Param注解，则为此注解的值，默认为类名首字母小写
* @Param params 待注入的参数名，如user.name或普通类型如name
* @Param args 真实参数值
**/
private PreparedStatement typeInject(PreparedStatement preparedStatement,Class<?>[] clazzes,List<String> paramNames,List<String> params,Object[] args)throws SQLException{ for(int i = 0; i < paramNames.size(); i++){
// 第i个参数名称
String paramName = paramNames.get(i);
// 第i个参数类型
Class type = clazzes[i];
if(String.class.equals(type)){
// 原始SQL中需要注入的参数名中是否有此参数名称
// example: select * from users where id = {id} and name = {name} 则{id}中的id和name就是如下的params里面内容
int injectIndex = params.indexOf(paramName);
/**此处是判断sql中是否有待注入的名称({name})和方法内输入对象名(name)相同，若相同，则直接注入*/
if(injectIndex >= 0){
preparedStatement.setString(injectIndex+1,(String)args[i]);
}
}else if(Integer.class.equals(type) || int.class.equals(type)){
int injectIndex = params.indexOf(paramName);
if(injectIndex >= 0){
preparedStatement.setInt(injectIndex+1,(Integer)args[i]);
}
}else if(Float.class.equals(type) || float.class.equals(type)){
int injectIndex = params.indexOf(paramName);
if(injectIndex >= 0){
preparedStatement.setFloat(injectIndex+1,(Float)args[i]);
}
}else {
/** 若待注入的是对象。example:
@SELECT(select * from users where id = {user.id} and name = {user.name})
List<User> getUser(User user)
*/
// 对象工厂，获取对象包装实例，见代码块10
ObjectWrapper objectWrapper = ObjectWrapperFactory.getInstance(args[i]);
for(int j = 0; j < params.size(); j++){
/**此处是判断对象的属性 如user.name，需要先获取user对象，在调用getName方法获取值*/
if((params.get(j).indexOf(paramName)) >= 0 ){
try{
String paramProperties = params.get(j).substring(params.get(j).indexOf(".")+1);
Object object = objectWrapper.getVal(paramProperties);
Class childClazz = object.getClass();
if(String.class.equals(childClazz)){
preparedStatement.setString(j+1,(String)object);
}else if(Integer.class.equals(childClazz) || int.class.equals(childClazz)){
preparedStatement.setInt(j+1,(Integer)object);
}else if(Float.class.equals(childClazz) || float.class.equals(childClazz)){
preparedStatement.setFloat(j+1,(Float)object);
}else {
/**目前不支持对象中包含对象，如dept.user.name todo*/
throw new RuntimeException("now not support object contain object");
}
}catch (Exception e){
throw new RuntimeException(e.getMessage());
}
}
}
}
}
return preparedStatement;
} public void closeConnection() throws SQLException{
transaction.close();
}
}
ResultSetHandle
/**
* @Author xiabing
* @Desc ResultSet结果处理器，执行之后返回的json对象，转为java对象的过程
**/
public class ResultSetHandle { /**转换的目标类型*/
Class<?> typeReturn; /**待转换的ResultSet*/
ResultSet resultSet; Boolean hasSet; public ResultSetHandle(Class<?> typeReturn,ResultSet resultSet){
this.resultSet = resultSet;
this.typeReturn = typeReturn;
} /**
* ResultSet处理方法，目前仅支持String,int,Float,不支持属性是集合类 todo
* */
public <T> List<T> handle() throws Exception{ List<T> res = new ArrayList<>(resultSet.getRow());
Object object = null;
ObjectWrapper objectWrapper = null;
Set<ClazzWrapper.FiledExpand> filedExpands = null;
// 返回类型若不是基本数据类型
if(!TypeUtil.isBaseType(typeReturn)){
// 生成对象
object = generateObj(typeReturn);
// 将对象封装成包装类
objectWrapper = ObjectWrapperFactory.getInstance(object); /** 获取对象属性 */
filedExpands = objectWrapper.getMapperFiledExpands();
} while (resultSet.next()){
/** 若返回是基础数据类型，则直接将结果放入List中并返回 */
if(String.class.equals(typeReturn)){
String val = resultSet.getString(1);
if(val != null){
res.add((T)val);
}
}else if(Integer.class.equals(typeReturn) || int.class.equals(typeReturn)){
Integer val = resultSet.getInt(1);
if(val != null){
res.add((T)val);
}
}else if(Float.class.equals(typeReturn) || float.class.equals(typeReturn)){
Float val = resultSet.getFloat(1);
if(val != null){
res.add((T)val);
}
}else { // 若返回的是对象（如User这种）
// 查找对象属性，一个个注入
for(ClazzWrapper.FiledExpand filedExpand:filedExpands){
// 如果对象属性是String类型，例如User.name是String类型
if(String.class.equals(filedExpand.getType())){
// resultSet中获取该属性
String val = resultSet.getString(filedExpand.getPropertiesName());
if(val != null){
// 填充到对象包装类中
objectWrapper.setVal(filedExpand.getPropertiesName(),val);
}
}else if(Integer.class.equals(filedExpand.getType()) || int.class.equals(filedExpand.getType())){
Integer val = resultSet.getInt(filedExpand.getPropertiesName());
if(val != null){
objectWrapper.setVal(filedExpand.getPropertiesName(),val);
}
}else if(Float.class.equals(filedExpand.getType()) || float.class.equals(filedExpand.getType())){
Float val = resultSet.getFloat(filedExpand.getPropertiesName());
if(val != null){
objectWrapper.setVal(filedExpand.getPropertiesName(),val);
}
}else {
continue;
}
}
// 后续将对象包装类转为真实对象，放入List中并返回。对象包装类见代码10
res.add((T)objectWrapper.getRealObject());
}
}
return res;
} // 根据类型，根据反射，实例化对象
private Object generateObj(Class<?> clazz) throws Exception{
Constructor[] constructors = clazz.getConstructors();
Constructor usedConstructor = null;
// 获取无参构造器，若对象没有无参构造方法，则失败
for(Constructor constructor:constructors){
if(constructor.getParameterCount() == 0){
usedConstructor = constructor;
break;
}
}
if(constructors == null) {
throw new RuntimeException(typeReturn + " is not empty constructor");
}
// 利用反射生成实例
return usedConstructor.newInstance();
}
}
代码块9中大量用到了对象增强，类增强。使用这些原因是 在编写框架代码时，因为并不知道每个属性名，不可能把每个get或者set方法写死，只能通过将对象封装成包装类。然后利用反射，要填充某个对象，就调用setVal(属性名)，获取对象类似。详情见代码块10
代码块10
类增强（com.simple.ibatis.reflect）
ClazzWrapper
/**
* @Author xiabing
* @Desc clazz解析类
**/
public class ClazzWrapper {
/**
* 待解析类
* */
private Class<?> clazz;
/**
* 该类存储的属性名
* */
private Set<String> propertiesSet = new HashSet<>(); /**
* 该类存储的属性名及属性类
* */
private Set<FiledExpand> filedExpandSet = new HashSet<>(); /**
* 该类存储的get方法。key为属性名，value为getxxx方法
* */
private Map<String,Method> getterMethodMap = new HashMap<>();
/**
* 该类存储的set方法。key为属性名，value为setxxx方法
* */
private Map<String,Method> setterMethodMap = new HashMap<>();
/**
* 缓存，避免对同一个类多次解析
* */
private static Map<String,ClazzWrapper> clazzWrapperMap = new ConcurrentHashMap<>(); public ClazzWrapper(Class clazz){
this.clazz = clazz;
// 对类进行解析，如果已经解析了，则不用二次解析
if(!clazzWrapperMap.containsKey(clazz.getName())){
// 获取该类的所有属性
Field[] fields = clazz.getDeclaredFields();
for(Field field : fields){
// 获取属性的名称，属性类型
FiledExpand filedExpand = new FiledExpand(field.getName(),field.getType());
filedExpandSet.add(filedExpand);
propertiesSet.add(field.getName());
}
// 获取该类的方法
Method[] methods = clazz.getMethods();
for(Method method:methods){
String name = method.getName();
// 如果是get方法
if(name.startsWith("get")){
name = name.substring(3);
if (name.length() == 1 || (name.length() > 1 && !Character.isUpperCase(name.charAt(1)))) {
name = name.substring(0, 1).toLowerCase(Locale.ENGLISH) + name.substring(1);
}
// 放入get方法缓存中
if(propertiesSet.contains(name)){
getterMethodMap.put(name,method);
}
}else if(name.startsWith("set")){
name = name.substring(3);
if (name.length() == 1 || (name.length() > 1 && !Character.isUpperCase(name.charAt(1)))) {
name = name.substring(0, 1).toLowerCase(Locale.ENGLISH) + name.substring(1);
}
if(propertiesSet.contains(name)){
setterMethodMap.put(name,method);
}
}
else {
continue;
}
}
// 放入缓存，代表该类已经完成解析
clazzWrapperMap.put(clazz.getName(),this);
}
} // 查找该类是否包含指定属性的get方法
public boolean hasGetter(String properties){
ClazzWrapper clazzWrapper = clazzWrapperMap.get(clazz.getName()); return clazzWrapper.getterMethodMap.containsKey(properties);
} // 查找该类是否包含指定属性的set方法
public boolean hasSetter(String properties){
ClazzWrapper clazzWrapper = clazzWrapperMap.get(clazz.getName()); return clazzWrapper.setterMethodMap.containsKey(properties);
} // 获取该类指定属性的set方法
public Method getSetterMethod(String properties){
if(!hasSetter(properties)){
throw new RuntimeException("properties " + properties + " is not set method") ;
}
ClazzWrapper clazzWrapper = clazzWrapperMap.get(clazz.getName());
return clazzWrapper.setterMethodMap.get(properties);
} // 获取该类指定属性的get方法
public Method getGetterMethod(String properties){
if(!hasGetter(properties)){
throw new RuntimeException("properties " + properties + " is not get method") ;
}
ClazzWrapper clazzWrapper = clazzWrapperMap.get(clazz.getName());
return clazzWrapper.getterMethodMap.get(properties);
} // 获取该类所有属性
public Set<String> getProperties(){ ClazzWrapper clazzWrapper = clazzWrapperMap.get(clazz.getName()); return clazzWrapper.propertiesSet;
} // 获取该类所有属性增强
public Set<FiledExpand> getFiledExpandSet(){
ClazzWrapper clazzWrapper = clazzWrapperMap.get(clazz.getName()); return clazzWrapper.filedExpandSet;
} /**
* 属性增强类
* */
public static class FiledExpand{ // 属性名称
String propertiesName; // 属性类型
Class type; public FiledExpand() {
} public FiledExpand(String propertiesName, Class type) {
this.propertiesName = propertiesName;
this.type = type;
} public String getPropertiesName() {
return propertiesName;
} public void setPropertiesName(String propertiesName) {
this.propertiesName = propertiesName;
} public Class getType() {
return type;
} public void setType(Class type) {
this.type = type;
} @Override
public int hashCode() {
return propertiesName.hashCode();
} @Override
public boolean equals(Object obj) {
if(obj instanceof FiledExpand){
return ((FiledExpand) obj).propertiesName.equals(propertiesName);
}
return false;
}
}
}
ObjectWrapper
/**
* @Author xiabing
* @Desc 对象增强,封装了get,set方法
**/
public class ObjectWrapper {
// 真实对象
private Object realObject;
// 该对象的类的增强
private ClazzWrapper clazzWrapper; public ObjectWrapper(Object realObject){
this.realObject = realObject;
this.clazzWrapper = new ClazzWrapper(realObject.getClass());
} // 调用对象指定属性的get方法
public Object getVal(String property) throws Exception{ return clazzWrapper.getGetterMethod(property).invoke(realObject,null);
} // 调用对象指定属性的set方法
public void setVal(String property,Object value) throws Exception{ clazzWrapper.getSetterMethod(property).invoke(realObject,value);
} public Set<String> getProperties(){ return clazzWrapper.getProperties();
} public Set<ClazzWrapper.FiledExpand> getMapperFiledExpands(){ return clazzWrapper.getFiledExpandSet();
} public Object getRealObject(){ return realObject; }
}
ObjectWrapperFactory
/**
* @Author xiabing5
* @Desc 对象增强类。使用对象增强是因为我们不知道每个对象的getXXX方法，只能利用反射获取对象的属性和方法，然后
统一提供getVal或者setVal来获取或者设置指定属性，这就是对象的增强的重要性
**/
public class ObjectWrapperFactory { public static ObjectWrapper getInstance(Object o){
return new ObjectWrapper(o);
} }
总结感悟
上述是我在写这个框架时的一些思路历程，代码演示请见我github。通过自己手写源码,对mybatis也有了个深刻的见解。当然有很多问题，后面也会进一步去完善，如果你对这个开源项目感兴趣，不妨star一下呀！