这里有两个?，而jdbc的预处理语句传入参数的时候要明确的知道第一个参数的类型是什么，如果传过来是对象的话，要知道对应对象的哪个值。这就是为什么接口里的预处理语句传入是
INSERT INTO person(name,age) VALUES (#{name},#{age})因为可以通过匹配#{XX}这样的确定都是哪些参数，因为User对象里有定义参数的类型。所以类型和值都确定了。这个就是MappedStatement对象做的事情。以下是用正则表达式匹配+反射来达到解析sql并和对象值做匹配的实现：
public static void main(String[] args) throws Exception{Matcher m= pattern.matcher("INSERT INTO person(name,age) VALUES (#{name},#{age})");
User user1 = new User();
user1.setId(1);
user1.setName("贾元春");
user1.setAge(27);
int i=1;
while(m.find()) {
System.out.println(m.group());
String group = m.group();
String fieldName = group.replace("#{","").replace("}","");
Field field = User.class.getDeclaredField(fieldName);
field.setAccessible(true);
if("java.lang.Integer".equals(field.getType().getName())) {
System.out.println("stmt.setInt("+i+","+field.get(user1)+")");
} else if("java.lang.String".equals(field.getType().getName())) {
System.out.println(" stmt.setString("+i+","+field.get(user1)+")");
}
i++;
}
}
运行结果是
可以看到实现了效果。下面就是和jdbc连接结合起来。
public class YunaInvocationHandler implements InvocationHandler {public static final String DBDRIVER = "org.xx.mm.mysql.Driver";
public static final String DBURL = "jdbc:mysql://localhost:3306/mydb";
//现在使用的是mysql数据库，是直接连接的，所以此处必须有用户名和密码
public static final String USERNAME = "root";
public static final String PASSWORD = "mysqladmin";
@Override
public Object invoke(Object proxy, Method method, Object[] args) throws Exception{
Object result = null;
Insert insert = method.getAnnotation(Insert.class);
if (insert != null) {
String sql = insert.value()[0];
System.out.println("插入语句为"+s);
YunaSqlDeal yunaSqlDeal = new YunaSqlDeal();
yunaSqlDeal.insert(s, Arrays.toString(args));
//1、加载驱动程序
try {
Class.forName(DBDRIVER);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
//2、连接数据库
//通过连接管理器连接数据库
//数据库连接对象
Connection conn = null;
try {
//在连接的时候直接输入用户名和密码才可以连接
conn = DriverManager.getConnection(DBURL, USERNAME, PASSWORD);
} catch (SQLException e) {
e.printStackTrace();
}
composeStatement(sql, args[0], conn);
}
return 1;
}
private static final String PATTERN = "#\\{[A-Za-z0-9]+\\}";
private static Pattern pattern = Pattern.compile("("+PATTERN+")");
public static void composeStatement(String sql, Object obj, Connection conn) throws Exception{
PreparedStatement stmt = conn.prepareStatement(sql.replaceAll(PATTERN, ""));
Matcher m= pattern.matcher(sql);
int i=1;
while(m.find()) {
System.out.println(m.group());
String group = m.group();
String fieldName = group.replace("#{","").replace("}","");
Field field = User.class.getDeclaredField(fieldName);
field.setAccessible(true);
if("java.lang.Integer".equals(field.getType().getName())) {
System.out.println("stmt.setInt("+i+","+field.get(obj)+")");
stmt.setInt(i, Integer.parseInt(field.get(obj).toString()));
} else if("java.lang.String".equals(field.getType().getName())) {
stmt.setString(i, field.get(obj).toString());
}
i++;
}
stmt.execute();
stmt.close();
conn.close();
}
}
这个实现的是insert的，返回值类型固定，如果是select查询语句，涉及到返回的结果封装成对象。思路也是通过反射，和参数转换步骤差不多，就不贴代码了。
到此，我们实现了一个简化版的mybatis框架。比贴的架构图简化在少用了很多设计模式的东西，和出于性能考虑重用的东西。mybatis的核心就实现完了。
总结
本文从mybatis的设计者角度出发，构造了一个简化的mybatis框架。具体可运行的完整代码放到了我的github上，地址：
https://github.com/xiexiaojing/yuna。
很多原理性的东西看过之后会忘，但是如果真正站在设计者角度实现过一个简化的版本，相信会增强记忆。同时也能和真正的实现做对比，更深层学习技术大牛们的设计精华