前言
如果涉及到同一台机器上不同库不同表的关联查询,可以通过 数据库名.表名 的形式来进行跨库查询,若不用插件,这时可以通过存储过程来完成查询。
编写存储过程
以学生信息查询为例,例如有两个库。
学生库student(学生信息表 stu_info)
CREATE TABLE `stu_info` (
`id` varchar(64) NOT NULL,
`name` varchar(64) NOT NULL COMMENT '学生姓名',
`teacher_id` varchar(64) DEFAULT NULL COMMENT '教师id',
PRIMARY KEY (`id`),
) ENGINE=InnoDB DEFAULT CHARSET=utf8 ROW_FORMAT=COMPACT;
教师库teacher(教师信息表 teacher_info)
CREATE TABLE `teacher_info` (
`id` varchar(64) NOT NULL,
`name` varchar(64) NOT NULL COMMENT '教师姓名',
PRIMARY KEY (`id`),
) ENGINE=InnoDB DEFAULT CHARSET=utf8 ROW_FORMAT=COMPACT;
其中每个学生有一个指导老师,每个指导老师可以指导多个学生。
先要查询出所有学生的名字及其指导教师。由于分页参数是调用方传入,因此分页参数通过占位符(?,?)来替代,并使用MySql Prepared SQL Statement[1]。最终存储过程如下。
CREATE PROCEDURE test_proc_paging(
IN pageNum int,
IN pageSize int
)
BEGIN
SET @pageSize = pageSize;
SET @pageNum = pageNum;
PREPARE s1 FROM "
select s.name as stu,t.name as teacher from student.stu_info s left join teacher.teacher_info t on s.teacher_id = t.id
limit ?,?"
EXECUTE s1 USING @pageNum,@pageSize;
DEALLOCATE PREPARE s1;
SELECT FOUND_ROWS() as recordCounts;
END
- PREPARE s1 … 定义prepared statement s1
- EXECUTE s1 … 执行s1,并用参数替换占位符
- DEALLOCATE PREPARE s1… 释放prepared statement
- SELECT FOUND_ROWS() as recordCounts; 返回总记录数
最终调用存储过程会返回两个结果,一个是分页查询的结果,一个是总的结果数。
MyBatis调用存储过程
StuInfoDao定义为,其中StuInfoForm 包含了查询参数,即两个分页参数。注意由于调用的存储过程返回多个结果集,因此DAO中的查询语句返回结果为List<Object>
public interface StuInfoDao {
public List<Object> queryStuByProc(StuInfoForm form);
}
Mybatis mapper.xml 定义,由于返回结果包含两个结果集,因此定义了两个ResultMap,并在select查询中指定了两个ResultMap[2]。
<resultMap type="java.lang.Integer" id="recordCounts">
<result column="recordCounts" jdbcType="INTEGER" />
</resultMap>
<resultMap id="dtoResultMap" type="com.fengdai.report.model.Certification">
<result column="stu" jdbcType="VARCHAR" property="stu" />
<result column="teacher" jdbcType="VARCHAR" property="teacher" />
</resultMap>
<select id="queryStuByProc" resultMap="dtoResultMap,recordCounts" statementType="CALLABLE" >
{
CALL test_proc_paging(#{pageNum,jdbcType=INTEGER},
#{pageSize,jdbcType=INTEGER})
}
</select>
查询与返回结果的处理
返回结果,那么通过如下的代码获取结果,及总记录数,然后填入返回对象的成员中,最后返回给前端即可。
form.setPageNum((form.getPageNum()-1)*form.getPageSize());
List<Object> result = certificationDao.queryStuByProc(form);
// 结果
List<Object> result = list.get(0);
// 总记录数
Integer size = ((ArrayList<Integer>)list.get(1)).get(1);
form中的pageNum定义了页号,pageSize定义的单页大小,因此在查询前需要将pageNum,pageSize转换为相应的分页查询参数。
例如 查第5页,每页10条,那么sql中的limit偏移就是 limit (5-1)*10,10
参考
[1]Prepared SQL Statement Syntax,
https://dev.mysql.com/doc/refman/5.6/en/sql-syntax-prepared-statements.html
[2]Mybatis references Multiple ResultSets for Association,
http://www.mybatis.org/mybatis-3/sqlmap-xml.html