如何批量测试Mybatis项目中的Sql是否正确详解

网友投稿 277 2023-07-16

如何批量测试Mybatis项目中的Sql是否正确详解

去Oracle行动

最近公司要发展海外项目,所以要将现有的系统全部平移过去,另外数据库也要从原来的Oracle变为mysql。公司的数据库交互层面使用的是Mybatis,而Oracle与Mysql也有一些语法上的不同。所以在项目中的Sql要改动,但是多个项目中涉及到的Sql非常多,如果仅凭人工一条一条辨别的话,工作量有点大。所以就萌发出了直接将数据源变为Mysql,利用反射批量执行Mapper中的方法,然后如果有参数的话,就设置为默认的初始值,然后记录下来成功的数据和失败的数据,这样就可以根据失败原因进行修改。

能够节省很大的时间。

执行效果

代码介绍

总体思路就三步

通过反射获得要执行的Mapper类的所有方法

获得方法中的参数,并赋值

执行

AutoTestMapper autoTestMapper = new AutoTestMapper("存放Mapper全路径名");

autoTestMapper.openSqlSession(sqlSessionFactory);

在构造函数中传入全路径名后,进行解析,解析出包名和所有的文件名并存储起来

public AutoTestMapper(String path) throws IOException, ClassNotFoundException {

String mapperContent = getFileContent(path);

String pathPattern = "import [a-z,A-Z,/.]+;";

String[] pathArr = matchMethod(pathPattern, mapperContent).split(";");

for (int i = 0; i < pathArr.length; i++) {

pathArr[i] = pathArr[i].replaceAll("import ", "");

Class cls = Class.forName(pathArr[i]);

if (!cls.isInterface()) {

TYPE_ARRAY.add(cls);

}

}

//获得全路径名的前缀

String packPattern = "package [a-z,A-Z,/.]+;";

String[] packPathArr = matchMethod(packPattern, mapperContent).split(";");

String packPath = packPathArr[0].replaceAll("package ", "").replaceAll(";", "");

this.PACK_PATH = packPath;

}

然后调用openSqlSession的方法,传入SqlSessionFactory参数

List> list = new ArrayList<>();

List invokeSuccess = new ArrayList<>();

List invokeFail = new ArrayList<>();

for (String fileName : FILE_NAME) {

Class cls = Class.forName(PACK_PATH + "." + fileName);

//添加Mapper

if (!sqlSessionFactory.getConfiguration().hasMapper(cls)){

sqlSessionFactory.getConfiguration().addMapper(cls);

}

//获得Mapper

Object mapper = sqlSessionFactory.openSession().getMapper(cls);

//反射执行Mapper的方法

Map> resultMap = autoTestInvoke(cls, mapper);

invokeSuccess.addAll(resultMap.get(SUCCESS_FLG));

invokeFail.addAll(resultMap.get(FAIL_FLG));

}

然后通过Mybatyis提供的方法getMapper()传入类名获得所要Mapper类。核心方法就是autoTestInvoke()方法了

private Map> autoTestInvoke(Class c, Object o)

{

Method[] declaredMethods = c.getDeclaredMethods();

String fileName = c.getName().substring(c.getName().lastIndexOf("."));

List invokeSuccess = new ArrayList<>();

List invokeFail = new ArrayList<>();

Map> resultMap = new HashMap<&ghttp://t;();

//给参数赋初始值

for (Method method : declaredMethods) {

List list = new ArrayList<>();

for (Class cls : method.getParameterTypes()) {

Object par = new Object();

if (TYPE_ARRAY.contains(cls)) {

if (cls.equals(String.class)) {

par = "1";

} else {

try {

par = cls.newInstance();

assignment(cls, par);

} catch (InstantiationException e) {

if (cls.isPrimitive()) {

cls = primitiveClazz.get(cls.getName());

}

try {

par = cls.getDeclaredConstructor(String.class).newInstance("1");

}catch (NoSuchMethodException e1){

System.out.println(cls.getName()+e);

}

}

}

}else if ("java.util.Map".equals(cls.getName())){

par = getMapData(c.getName()+"."+method.getName());

}

list.add(par);

}

try {

method.invoke(o, list.toArray());

invokeSuccess.add("Success: " + fileName + "." + method.getName());

} catch (Exception e) {

invokeFail.add("Error:" + method.getName() + " Error Info:" + e);

}

}

resultMap.put(SUCCESS_FLG, invokeSuccess);

resultMap.put(FAIL_FLG, invokeFail);

return resultMap;

}

这里面完成为参数赋初始值,和执行的逻辑。

使用说明

导入Jar包

Maven

com.github.modouxiansheng

convenientUtil

1.3-release

Gradle

compile 'com.github.modouxiansheng:convenientUtil:1.1-release'

创建mybatis-config.xml文件

在项目的resource文件夹下创建mybatis-config.xml文件,里面内容如下,里面value值为想要测的数据库的连接信息

PUBLIC "-//mybatis.org//DTD Config 3.0//EN"

"http://mybatis.org/dtd/mybatis-3-config.dtd">

&lthttp://;configuration>

在测试类中编写代码

在测试类中编写如下代码

Reader resourceAsReader = Resources.getResourceAsReader("mybatis-config.xml");

SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(resourceAsReader);

resourceAsReader.close();

AutoTestMapper autoTestMapper = new AutoTestMapper("想要测试的Mapper文件夹全路径名");

autoTestMapper.openSqlSession(sqlSessionFactory);

查看输出的信息

然后会打印出执行成功的Sql,执行失败的Sql。如果失败的话会有原因。

Success: TSesSetManualMapper.updateFlgdelAutoInTimePay

Success: TSesSetManualMapper.getAutoSetManualOrdListCount

Success: TSesSetManualMapper.updateAutoSetManualOrd

Success: TSesSetManualMapper.queryAutoSetManualOrdDetail

Success: TSesSetManualMapper.querySetManualOrdListCount

Success: ShortMessageMapper.queryPayInsSmInfo

-------------------

|Error: |TSesSetManualMapper.queryAutoSetManualOrdList| Every derived table must have its own alias|

|Error: |TSesSetManualMapper.querySetManualOrdList| Every derived table must have its own alias|

这样就能够根据错误信息进行更改了。

github地址:https://github.com/modouxiansheng/convenientUtil (本地下载)

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对我们的支持。

版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:Springboot整合Shiro之加盐MD5加密的方法
下一篇:web中拖拽排序和java后台交互实现方法示例
相关文章

 发表评论

暂时没有评论,来抢沙发吧~