在前面分别讲解了通过mybatis执行简单的增删改,多表联合查询,那么自然不能缺少存储过程调用,而且还带分页功能。
注意:表结构参见上篇讲解联合查询的表。
一、查询某班级以及该班级下面所有学生的记录
上面这个查询可以用sql语句表示为:
select c.class_id,c.class_name,s.s_id,s.s_name from Class c left join ClassStudent cs on c.class_id = cs.class_id left join Student s on cs.student_id = s.s_id where c.class_id = 1
查询出来的结果是:
那么如果这个班级里面学生超级多,要通过分页查询,并且用存储过程该怎么通过mybatis调用了???
二、在sql2008r2里面新建一个分页查询的存储过程,如下
create proc [dbo].[SP_PAGE_GetClassStudent] ( @ClassID int, --班级编码 @PageSize int, --每页显示多少条 @PageIndex int , --查询第多少页 @PageCount int output, --总页数输出 @RecordCount int output --总记录数输出 ) as begin declare @startIndex int declare @endIndex int declare @sqlString varchar(4000) declare @QueryPageSql nvarchar(4000) declare @QueryCountString nvarchar(4000) --1、拼接sql语句 SET @sqlString ='(select *,ROW_NUMBER() over (order by t.s_id) as rowId from ( select c.class_id,c.class_name,s.s_id,s.s_name from Class c left join ClassStudent cs on c.class_id = cs.class_id left join Student s on cs.student_id = s.s_id where c.class_id = '+str(@ClassID)+' )t) temp' --2、计算总页数,总记录数 SET @QueryCountString = 'select @RecordCount=count(1),@PageCount=CEILING((COUNT(1)+0.0)/' + CAST(@PageSize AS NVARCHAR)+') from ' +@SqlString ; --PRINT(@QueryCountString) EXEC SP_EXECUTESQL @QueryCountString,N'@RecordCount int output,@PageCount int output', @RecordCount output, @PageCount output --3、判断输入的当前页数大于实际总页数,则把实际总页数赋值给当前页数 IF @PageIndex > CEILING((@RecordCount+0.0)/@PageSize) BEGIN SET @PageIndex = CEILING((@RecordCount+0.0)/@PageSize) END SET @startIndex=(@PageIndex-1)*@PageSize+1 SET @endIndex=@PageIndex*@PageSize --4、执行分页查询 SET @QueryPageSql ='select * from ' + @SqlString + ' where rowId between ' + str(@startIndex) + ' and ' + str(@endIndex); --PRINT(@QueryPageSql) EXEC (@QueryPageSql) end
不难看出,这个存储过程一共有5个参数,3个输入参数,2个输出参数,我们通过sql2008r2自带的工具执行这个存储过程,如下:
点击“确定”会在sql查询窗体中出现如下sql语句块:
USE [mybatisDB] GO DECLARE @return_value int, @PageCount int, @RecordCount int EXEC @return_value = [dbo].[SP_PAGE_GetClassStudent] @ClassID = 1, @PageSize = 2, @PageIndex = 5, @PageCount = @PageCount OUTPUT, @RecordCount = @RecordCount OUTPUT SELECT @PageCount as N'@PageCount', @RecordCount as N'@RecordCount' SELECT 'Return Value' = @return_value GO
仔细一看,怎么多出了一个输出参数“@return_value”了,可是在设计存储过程的时候只有2个输出参数,此处先埋下伏笔。
三、在原先项目下新建com.mybatis.proc这个包,在包里面建一个procMapper.xml的映射文件,之后需要在该项目的mybatis的配置文件conf.xml下面对这个procMapper.xml文件进行注册,具体是:
<!-- 注册映射文件 --> <mappers> <!-- 通过xml方式映射 --> <mapper resource="com/mybatis/proc/procMapper.xml"/> </mappers>
四、填充procMapper.xml,编写测试代码
<?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"> <mapper namespace="com.mybatis.proc.procMapper"> <!-- 1、测试错误,待解决 --> <!-- ### Error querying database. Cause: com.microsoft.sqlserver.jdbc.SQLServerException: '@P0' 附近有语法错误。 ### The error may exist in com/mybatis/proc/procMapper.xml ### The error may involve com.mybatis.proc.procMapper.getCSPMap ### The error occurred while setting parameters ### SQL: CALL SP_PAGE_GetClassStudent(?,?,?,?,?) --> <!-- <select id="getClassStudentsProc" statementType="CALLABLE" parameterMap="getCSPMap" resultType="com.mybatis.bean.StudentClassView"> CALL SP_PAGE_GetClassStudent(?,?,?,?,?) </select> <parameterMap type="java.util.Map" id="getCSPMap"> <parameter property="ClassID" mode="IN" jdbcType="INTEGER" /> <parameter property="PageSize" mode="IN" jdbcType="INTEGER" /> <parameter property="PageIndex" mode="IN" jdbcType="INTEGER" /> <parameter property="PageCount" mode="OUT" jdbcType="INTEGER" /> <parameter property="RecordCount" mode="OUT" jdbcType="INTEGER" /> </parameterMap> --> <!--2、测试通过,返回数据有冗余 --> <!-- <select id="getClassStudentsProc" statementType="CALLABLE" resultType="com.mybatis.bean.StudentClassView"> <![CDATA[ {#{rval,mode=OUT,jdbcType=INTEGER} = CALL SP_PAGE_GetClassStudent( #{ClassID,mode=IN,jdbcType=INTEGER}, #{PageSize,mode=IN,jdbcType=INTEGER}, #{PageIndex,mode=IN,jdbcType=INTEGER}, #{PageCount,mode=OUT,jdbcType=INTEGER}, #{RecordCount,mode=OUT,jdbcType=INTEGER} )} ]]> </select> --> <!-- 3、测试通过,一对多格式 --> <select id="getClassStudentsProc" statementType="CALLABLE" resultMap="cvs2Map"> <![CDATA[ {#{rval,mode=OUT,jdbcType=INTEGER} = CALL SP_PAGE_GetClassStudent( #{ClassID,mode=IN,jdbcType=INTEGER}, #{PageSize,mode=IN,jdbcType=INTEGER}, #{PageIndex,mode=IN,jdbcType=INTEGER}, #{PageCount,mode=OUT,jdbcType=INTEGER}, #{RecordCount,mode=OUT,jdbcType=INTEGER} )} ]]> </select> <resultMap type="com.mybatis.bean.StudentClassView2" id="cvs2Map"> <id property="class_id" column="class_id" /> <result property="class_name" column="class_name" /> <result property="rowId" column="rowId" /> <collection property="students" ofType="com.mybatis.bean.Student"> <id property="studentid" column="s_id"/> <result property="studentname" column="s_name"/> </collection> </resultMap> </mapper>
我最开始的写法是按照注释里面的那种方式,也就是第1种,可是在执行的时候却报错“ '@P0' 附近有语法错误。 ”,查了n久,不知道是那里问题,如是将sql追踪器打开,检测到该存储过程在数据库中的执行代码如下:
怎么这里第一个参数就是输出参数,与之前在sql编辑器里面一样的现象,看来这种写法是不行的,可是我找不到解决方案,如果谁发现了希望能告诉我,在这里谢谢。
如是按照另一种方式,执行却ok了。测试代码如下:
先定义一个实体类接收存储过程返回的结果
package com.mybatis.bean; public class StudentClassView { private int s_id; private String s_name; private int class_id; private String class_name; private int rowId;
//private List<Student> students; 如果启用这个属性,则将s_id,s_name注释掉,将类名称修改为StudentClassView2
public int getRowId() { return rowId; } public void setRowId(int rowId) { this.rowId = rowId; } public int getS_id() { return s_id; } public void setS_id(int s_id) { this.s_id = s_id; } public String getS_name() { return s_name; } public void setS_name(String s_name) { this.s_name = s_name; } public int getClass_id() { return class_id; } public void setClass_id(int class_id) { this.class_id = class_id; } public String getClass_name() { return class_name; } public void setClass_name(String class_name) { this.class_name = class_name; } @Override public String toString() { return "studentclass2 [s_id=" + s_id + ", s_name=" + s_name + ", class_id=" + class_id + ", class_name=" + class_name + ", rowId=" + rowId + "]"; } }
具体测试代码
package com.mybatis.proc; import java.util.*; import org.apache.ibatis.session.SqlSession; import org.apache.ibatis.session.SqlSessionFactory; import com.mybatis.bean.Student; import com.mybatis.bean.StudentClassView; import com.mybatis.bean.StudentClassView2; import com.mybatis.util.MybatisUtils; public class testproc { public static void main(String[] args) { SqlSessionFactory factory = MybatisUtils.getFactory(); SqlSession session = null; try { session = factory.openSession(true); Map<String, Integer> paramMap = new HashMap<>(); paramMap.put("ClassID", 1); paramMap.put("PageSize", 2); paramMap.put("PageIndex", 5); String statement = "com.mybatis.proc.procMapper.getClassStudentsProc"; //1、数据冗余 // List<StudentClassView> scv = session.selectList(statement, paramMap); // for(int i = 0;i<scv.size();i++){ // System.out.println(scv.get(i)); // } //2、一对多展现 StudentClassView2 scv2 = session.selectOne(statement, paramMap); List<Student> students = scv2.getStudents(); System.out.println("排序字段:"+scv2.getRowId() +";班级编号:"+scv2.getClass_id()+";班级名称:"+scv2.getClass_name()); for(int i = 0;i<students.size();i++){ System.out.println(students.get(i)); } Integer pageCount = paramMap.get("PageCount"); Integer recordCount = paramMap.get("RecordCount"); System.out.println("总页数:"+pageCount); System.out.println("总记录数:"+recordCount); } catch (Exception e) { e.printStackTrace(); }finally{ session.close(); } } }
在控制台中输出的结果如下:
到此测试成功。
五、需要注意的问题
1、存储过程的output参数,只能通过传入的map获取
2、存储过程的return结果需要使用 参数x=call procName(?,?...)的第一个参数接收,需要指定对应的mode为OUT类型
3、<select id="getClassStudentsProc" statementType="CALLABLE" resultType="com.mybatis.bean.StudentClassView">
resultType是映射数据查询出来的记录,存储过程必须标明类型为CALLABLE
4、<![CDATA[ sql语句 ]]> 作用是避免不必要的麻烦(如<,>,&,'," 会被xml转义成<,>,&,',")。
5、resultType="com.mybatis.bean.StudentClassView"会决定测试代码中session.selectList(statement, paramMap)的返回类型,是一一对应的关系。
6、<select id="getClassStudentsProc" statementType="CALLABLE" resultMap="cvs2Map">
如果这里使用resultMap,那么返回的结果可以自定义,同样与session.selectOne(statement, paramMap)返回类型一致。