目录
六、使用javassist生成类
6.1Javassist的使用
6.2使用Javassist生成DaoImpl类
七、MyBatis中接口代理机制及使用
7.1在之前的web应用中使用接口代理机制
7.2使用接口代理机制完成之前的CRUD(部分代码)
六、使用javassist生成类
6.1Javassist的使用
引入javassist依赖
<dependency>
<groupId>org.javassist</groupId>
<artifactId>javassist</artifactId>
<version>3.29.1-GA</version>
</dependency>测试
@Test
public void testGenerateFirstClass() throws Exception {
//获取类池，这个类池就是用来生成class的
ClassPool pool = ClassPool.getDefault();
//制造类（需要告诉javassist类名是什么）
CtClass ctClass = pool.makeClass("com.hhb.dao.impl.AccountDaoImpl");
//制造方法
String methodCode = "public void insert(){System.out.println(123);}";
CtMethod ctMethod = CtMethod.make(methodCode, ctClass);
//将方法添加到类中
ctClass.addMethod(ctMethod);
//在内存中生成class
ctClass.toClass();
//类加载到JVM中，返回AccountDaoImpl类的字节码
Class<?> clazz = Class.forName("com.hhb.dao.impl.AccountDaoImpl");
//创建对象
Object obj = clazz.newInstance();
//获取AccountDaoImpl中的insert方法
Method insertMethod = clazz.getDeclaredMethod("insert");
//调用方法insert
insertMethod.invoke(obj);
}6.2使用Javassist生成DaoImpl类
GenerateDaoProxy
package com.hhb.utils;
import org.apache.ibatis.javassist.ClassPool;
import org.apache.ibatis.javassist.CtClass;
import org.apache.ibatis.javassist.CtMethod;
import org.apache.ibatis.mapping.SqlCommandType;
import org.apache.ibatis.session.SqlSession;
import java.lang.reflect.Method;
import java.util.Arrays;
/**
* 工具类：可以动态的生成DAO的实现类。（或者说可以动态生成DAO的代理类）
* 注意注意注意注意注意！！！！！！：
* 凡是使用GenerateDaoProxy的，SQLMapper.xml映射文件中namespace必须是dao接口的全名，id必须是dao接口中的方法名。
*/
public class GenerateDaoProxy { // GenerateDaoProxy是mybatis框架的开发者写的。
/**
* 生成dao接口实现类，并且将实现类的对象创建出来并返回。
* @param daoInterface dao接口
* @return dao接口实现类的实例化对象。
*/
public static Object generate(SqlSession sqlSession, Class daoInterface){
// 类池
ClassPool pool = ClassPool.getDefault();
// 制造类(com.powernode.bank.dao.AccountDao --> com.powernode.bank.dao.AccountDaoProxy)
CtClass ctClass = pool.makeClass(daoInterface.getName() + "Proxy"); // 实际本质上就是在内存中动态生成一个代理类。
// 制造接口
CtClass ctInterface = pool.makeInterface(daoInterface.getName());
// 实现接口
ctClass.addInterface(ctInterface);
// 实现接口中所有的方法
Method[] methods = daoInterface.getDeclaredMethods();
Arrays.stream(methods).forEach(method -> {
// method是接口中的抽象方法
// 将method这个抽象方法进行实现
try {
// Account selectByActno(String actno);
// public Account selectByActno(String actno){ 代码; }
StringBuilder methodCode = new StringBuilder();
methodCode.append("public ");
methodCode.append(method.getReturnType().getName());
methodCode.append(" ");
methodCode.append(method.getName());
methodCode.append("(");
// 需要方法的形式参数列表
Class<?>[] parameterTypes = method.getParameterTypes();
for (int i = 0; i < parameterTypes.length; i++) {
Class<?> parameterType = parameterTypes[i];
methodCode.append(parameterType.getName());
methodCode.append(" ");
methodCode.append("arg" + i);
if(i != parameterTypes.length - 1){
methodCode.append(",");
}
}
methodCode.append(")");
methodCode.append("{");
// 需要方法体当中的代码
methodCode.append("org.apache.ibatis.session.SqlSession sqlSession = com.powernode.bank.utils.SqlSessionUtil.openSession();");
// 需要知道是什么类型的sql语句
// sql语句的id是框架使用者提供的，具有多变性。对于我框架的开发人员来说。我不知道。
// 既然我框架开发者不知道sqlId，怎么办呢？mybatis框架的开发者于是就出台了一个规定：凡是使用GenerateDaoProxy机制的。
// sqlId都不能随便写。namespace必须是dao接口的全限定名称。id必须是dao接口中方法名。
String sqlId = daoInterface.getName() + "." + method.getName();
SqlCommandType sqlCommandType = sqlSession.getConfiguration().getMappedStatement(sqlId).getSqlCommandType();
if (sqlCommandType == SqlCommandType.INSERT) {
}
if (sqlCommandType == SqlCommandType.DELETE) {
}
if (sqlCommandType == SqlCommandType.UPDATE) {
methodCode.append("return sqlSession.update(\""+sqlId+"\", arg0);");
}
if (sqlCommandType == SqlCommandType.SELECT) {
String returnType = method.getReturnType().getName();
methodCode.append("return ("+returnType+")sqlSession.selectOne(\""+sqlId+"\", arg0);");
}
methodCode.append("}");
CtMethod ctMethod = CtMethod.make(methodCode.toString(), ctClass);
ctClass.addMethod(ctMethod);
} catch (Exception e) {
e.printStackTrace();
}
});
// 创建对象
Object obj = null;
try {
Class<?> clazz = ctClass.toClass();
obj = clazz.newInstance();
} catch (Exception e) {
e.printStackTrace();
}
return obj;
}
}修改AccountMapper.xml文件：namespace必须是dao接口的全限定名称，id必须是dao接口中的方法名
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<!--要想使用GenerateDaoProxy，namespace必须是dao的全限定名称-->
<mapper namespace="com.hhb.dao.AccountDao">
<!--要想使用GenerdateDaoProxy，id必须是dao的方法名-->
<select id="selectByActno" resultType="com.hhb.pojo.Account">
select * from t_act where actno = #{actno}
</select>
<update id="updateByActno">
update t_act set balance = #{balance} where actno = #{actno}
</update>
</mapper>修改service类中获取dao对象
七、MyBatis中接口代理机制及使用
7.1在之前的web应用中使用接口代理机制
将service中获取dao对象的代码修改
前提：AccountMapper.xml文件中的namespace必须和dao接口的全限定名称一致，id必须和dao接口中方法名一致。否则报错提示如下：
7.2使用接口代理机制完成之前的CRUD(部分代码)
com.hhb.mapper.CarMapper
CarMapper相当于之前的CarDao。
package com.hhb.mapper;
import com.hhb.pojo.Car;
import java.util.List;
public interface CarMapper {
int insert(Car car);
int deleteById(Long id);
int update(Car car);
Car selectById(Long id);
List<Car> selectAll();
}测试
package com.hhb.test;
import com.hhb.mapper.CarMapper;
import com.hhb.pojo.Car;
import com.hhb.utils.SqlSessionUtil;
import org.apache.ibatis.session.SqlSession;
import org.junit.Test;
import java.util.List;
public class CarMapperTest {
@Test
public void testinsert() {
SqlSession sqlSession = SqlSessionUtil.openSession();
//面向接口获取接口的代理对象
CarMapper mapper = sqlSession.getMapper(CarMapper.class);
Car car = new Car(null, "4444", "奔驰cls300", 65.0, "2023-06-05", "燃油车");
int count = mapper.insert(car);
System.out.println(count);
sqlSession.commit();
}
@Test
public void testDeleteById() {
SqlSession sqlSession = SqlSessionUtil.openSession();
CarMapper mapper = sqlSession.getMapper(CarMapper.class);
int count = mapper.deleteById(10L);
System.out.println(count);
sqlSession.commit();
}
@Test
public void testUpdate() {
SqlSession sqlSession = SqlSessionUtil.openSession();
CarMapper mapper = sqlSession.getMapper(CarMapper.class);
Car car = new Car(28L, "1234", "奔驰cls300", 65.0, "2023-05-05", "燃油车");
int count = mapper.update(car);
System.out.println(count);
sqlSession.commit();
}
@Test
public void testSelectById() {
SqlSession sqlSession = SqlSessionUtil.openSession();
CarMapper mapper = sqlSession.getMapper(CarMapper.class);
Car car = mapper.selectById(1L);
System.out.println(car);
sqlSession.commit();
}
@Test
public void testSelectAll() {
SqlSession sqlSession = SqlSessionUtil.openSession();
CarMapper mapper = sqlSession.getMapper(CarMapper.class);
List<Car> cars = mapper.selectAll();
cars.forEach(car -> {
System.out.println(car);
});
}
}
