MyBatis

分页查询

分页简述

• 搭建环境

提供的资料包含了当天通用 mapper 的内容，一并导入jar 包和工具类即可。JavaBean 的定义和之前一样，不再提供

Mybatis 开发中我们采用 pagehelper 插件。

• 导入jar 包：
• 添加插件

<!-- 插件（放在 environments 标签上方即可） -->

<plugins>

<plugin interceptor="com.github.pagehelper.PageHelper">

<property name="dialect" value="mysql"/>

<property name="rowBoundsWithCount" value="true"/>

</plugin>

</plugins>

• 案例 1：分页查询用户信息需求说明

要求：每次查询仅展示 3 条数据

• API 讲解
• PageHelper 类：

• PageInfo 对象：

• 代码实现
• 测试类

• UserDao

@Select("select * from user")

List<User> selectAll();

1. 通用 Mapper

• 概述

MyBatis 通用 Mapper 是用来简化 MyBatis 开发，它提供了一个名为 Mapper<T>的接口。这个 Mapper 接口中提供了常见的 DAO 方法，例如添加、修改、删除、查询等。我们在编写 DAO 接口时继承这个通用 Mapper 接口就可以得到 N 多常用方法。

如果通用 Mapper 中的方法还不能满足产你的需求，那么你只需在 DAO 中添加额外的方法即可。

public interface UserDao extends Mapper<User> {

}

//UserDao 可以使用从 Mapper 继承过来的所有方法

• 搭建环境
• 导入jar 包

• 修改工具类【直接复制使用即可】

factory = new SqlSessionFactoryBuilder().build(is);

=

is

// 会话工厂

private static SqlSessionFactory factory; static{

try {

// 1.1 加载核心配置文件

InputStream Resources.getResourceAsStream("SqlMapConfig.xml");

// 1.2 获得工厂

public class MyBatisUtils {

} catch (Exception e) {

throw new RuntimeException(e);

}

}

private static ThreadLocal<SqlSession> local = new ThreadLocal<>();

/**

• 获得新会话
• @return

*/

private static SqlSession openSession(){ SqlSession sqlSession = local.get(); if(sqlSession == null){

sqlSession = factory.openSession();

//创建一个 MapperHelper

MapperHelper mapperHelper = new MapperHelper();

//特殊配置

Config config = new Config();

// 设置 UUID 生成策略

// 配置 UUID 生成策略需要使用 OGNL 表达式

// 默 认 值 32 位 长度:@java.util.UUID@randomUUID().toString().replace("-", "")

//config.setUUID("");

// 主键自增回写方法,默认值 MYSQL,详细说明请看文档

// config.setIDENTITY("HSQLDB");

// 支持方法上的注解

// 3.3.1 版本增加config.setEnableMethodAnnotation(true); config.setNotEmpty(true);

// 序列的获取规则,使用{num}格式化参数，默认值为{0}.nextval，针对 Oracle

// 可选参数一共 3 个，对应 0,1,2,分别为 SequenceName，ColumnName,

PropertyName

//config.setSeqFormat("NEXT VALUE FOR {0}");

// 设置全局的 catalog, 默认为空， 如果设置了值， 操作表时的 sql 会是

catalog.tablename

//config.setCatalog("");

// 设置全局的 schema, 默认为空， 如果设置了值， 操作表时的 sql 会是

schema.tablename

// 如果同时设置了 catalog,优先使用 catalog.tablename

//config.setSchema("");

// 主键自增回写方法执行顺序,默认 AFTER,可选值为(BEFORE|AFTER)

//config.setOrder("AFTER");

//设置配置mapperHelper.setConfig(config);

// 注册通用 Mapper 接口 - 可以自动注册继承的接口mapperHelper.registerMapper(Mapper.class); mapperHelper.registerMapper(MySqlMapper.class);

// mapperHelper.registerMapper(SqlServerMapper.class);

// mapperHelper.registerMapper(IdsMapper.class);

//配置完成后，执行下面的操作

mapperHelper.processConfiguration(sqlSession.getConfiguration());

local.set(sqlSession);

}

return sqlSession;

}

/**

• 获得 mapper
• @param clazz
• @return

*/

public static <T> T getMapper(Class<T> clazz){ return openSession().getMapper(clazz);

}

/**

• 释放资源

*/

public static void close() {

SqlSession sqlSession = openSession(); if(sqlSession != null){

sqlSession.close();

}

}

/**

• 提交并释放资源
• @param sqlSession

*/

public static void commitAndclose() { SqlSession sqlSession = openSession(); if(sqlSession != null){

sqlSession.commit(); close();

}

}

/**

• 回滚并释放资源
• @param sqlSession

*/

public static void rollbackAndclose() { SqlSession sqlSession = openSession(); if(sqlSession != null){

sqlSession.rollback(); close();

}

}

}

JavaBean 编写@Table 和@Id

@Table(name=”表名”) ： 表示当前 JavaBean 对应哪张 MySQL 表，默认对应 JavaBean

名称的表格

@Id :通用 mapper 必须设置，用于标识当前主键字段

@Table(name="t_user")

public class User implements Serializable {

/**

• uid INT(11) NOT NULL AUTO_INCREMENT PRIMARY KEY,
• username VARCHAR(32) NOT NULL COMMENT '用户名称',
• birthday DATE DEFAULT NULL COMMENT '生日',
• sex CHAR(1) DEFAULT NULL COMMENT '性别',
• address VARCHAR(256) DEFAULT NULL COMMENT '地址'

*/

@Id

private Integer uid; private String username; private Date birthday; private String sex; private String address;

public User(Integer uid, String username, Date birthday, String sex, String address) {

this.uid = uid;

this.username = username;

this.birthday = birthday; this.sex = sex; this.address = address;

}

@Override

public String toString() { return "User{" +

"uid=" + uid +

", username='" + username + '\'' + ", birthday=" + birthday +

", sex='" + sex + '\'' +

", address='" + address + '\'' + '}';

}

public User() {

}

public Integer getUid() { return uid;

}

public void setUid(Integer uid) { this.uid = uid;

}

public String getUsername() { return username;

}

public void setUsername(String username) { this.username = username;

}

public Date getBirthday() { return birthday;

}

public void setBirthday(Date birthday) { this.birthday = birthday;

}

public String getSex() {

return sex;

}

public void setSex(String sex) { this.sex = sex;

}

public String getAddress() { return address;

}

public void setAddress(String address) { this.address = address;

}

}

Dao 接口继承通用 Mapper

import tk.mybatis.mapper.common.Mapper;

public interface UserDao extends Mapper<User> {

}

• 编写测试类

通过主键查询

• 确定主键，否则所有字段都是主键

• 测试类

//1、获取Dao实现类对象

UserDao dao = MyBatisUtils.getMapper(UserDao.class);

//2、调用通过Mapper中继承而来的方法 User user = dao.selectByPrimaryKey(8); System.out.println(user);

//3、关闭资源

MyBatisUtils.close();

}

* 通过主键UID查询

*/ @Test

public void run1(){

/**

• 查询所有
• 测试类

//1、获取Dao实现类对象

UserDao dao = MyBatisUtils.getMapper(UserDao.class);

//2、调用通过Mapper中继承而来的方法

List<User> list = dao.selectAll();

* 查询所有数据

*/ @Test

public void run2(){

/**

• 分页查询
• 测试类：

//1、获取Dao实现类对象

UserDao dao = MyBatisUtils.getMapper(UserDao.class);

//2、设置分页PageHelper.startPage(1, 3);

//3、调用通过Mapper中继承而来的方法List<User> list = dao.selectAll();

//4、封装分页数据

PageInfo<User> pageInfo = new PageInfo<User>(list); for(User u:pageInfo.getList()){

System.out.println(u);

}

//5、关闭资源

MyBatisUtils.close();

}

* 分页查询

*/ @Test

public void run3(){

/**

• 添加
• 测试类：

/**

* 添加： 测试 1，当前日期，男，沭阳

*/

@Test

public void run4_1(){

//1、获取Dao

UserDao dao = MyBatisUtils.getMapper(UserDao.class);

//2、调用Dao 方法

//添加数据，遇到null，添加null

int row = dao.insert(new User(null, "测试 1", new Date(), "男", "沭阳"));

//添加数据，遇到null，先尝试用数据库该字段默认值，该字段没有默认值，继续用null

//int row = dao.insertSelective(new User(null, "测试 1", new Date(), "男", "

沭阳"));

System.out.println("添加成功了"+row+"条数据");

//3、提交事务并关闭会话

MyBatisUtils.commitAndClose();

}

• 根据 ID 修改
• 测试类：

//1、获取Dao实现类对象

UserDao dao = MyBatisUtils.getMapper(UserDao.class);

//2、调用通过Mapper中继承而来的方法

User user = new User(9, "小王2",new Date(), "女", "测试区域2"); int i = dao.updateByPrimaryKey(user);

System.out.println("成功修改"+i+"行数据");

//3、关闭资源

MyBatisUtils.commitAndClose();

}

* 修 改

*/ @Test

public void run5(){

/**

• 根据 ID 删除
• 测试类：

/**

* 删 除

*/

@Test

public void run6(){

• 多条件查询(and 模糊+and 等于+and 区间)

需求：用户名包含“小” 并且 性别为“男” 并且 出生日期在“2018-01-01”~“2018- 04-01”

• 测试类：

//1、获取Dao实现类对象

UserDao dao = MyBatisUtils.getMapper(UserDao.class);

//2、多条件查询

/**创建条件*/

Example example = new Example(User.class);

Criteria c = example.createCriteria();

//username模糊查询c.andLike("username", "%小%");

//sex等号查询c.andEqualTo("sex", "男");

//birthday区间查询

c.andBetween("birthday", "2018-01-01", "2018-04-01");

/**进行查询*/

List<User> ulist = dao.selectByExample(example); for(User u:ulist){

System.out.println(u);

}

//3、关闭资源

MyBatisUtils. close();

}

*/

@Test

public void run7(){

/**

* 多条件查询

* 用户名包含“小” 并且 性别为“男” 并且 出生日期在“2018-01-01”~

“2018-04-01”

• 多条件查询(andIn+and 非空)

需求：查询用户 ID 为 1 或 3 或 5 的数据，并且要求地址不能为空

• 测试类：

//1、获取Dao实现类对象

UserDao dao = MyBatisUtils.getMapper(UserDao.class);

//2、多条件查询

/**创建条件*/

Example example = new Example(User.class); Criteria c = example.createCriteria();

//uid 的in查询

List<Integer> uidList = new ArrayList<Integer>(); uidList.add(1);

uidList.add(3); uidList.add(5);

c.andIn("uid", uidList);

//address 的不为空查询c.andIsNotNull("address");

/**进行查询*/

List<User> ulist = dao.selectByExample(example); for(User u:ulist){

System.out.println(u);

}

//3、关闭资源

MyBatisUtils. close();

}

* 多条件查询

* 查询用户ID为1或3或5的数据，并且要求地址不能为空

*/ @Test

public void run8(){

/**

• 多条件查询(or 查询)

需求：查询用户名为“管理员” 或者 性别为“女”的所有数据

• 测试类：

//1、获取Dao实现类对象

UserDao dao = MyBatisUtils.getMapper(UserDao.class);

//2、多条件查询

/**创建条件*/

Example example = new Example(User.class);

Criteria c = example.createCriteria();

//username 的等于查询c.andEqualTo("username", "管理员");

//sex 的等于查询c.orEqualTo("sex", "女");

/**进行查询*/

List<User> ulist = dao.selectByExample(example); for(User u:ulist){

System.out.println(u);

}

//3、关闭资源

MyBatisUtils.close();

}

* 多条件查询

* 查询用户名为“管理员” 或者 性别为“女”的所有数据

*/ @Test

public void run9(){

/**

• 批量删除（andIn）

需求：根据 ID 删除信息，将 1,3,5 三条信息删除

//1、获取Dao实现类对象

UserDao dao = MyBatisUtils.getMapper(UserDao.class);

//2、调用通过Mapper中继承而来的方法

//创建条件

Example example = new Example(User.class); Criteria c = example.createCriteria();

//uid in

List<Integer> list = new ArrayList<Integer>(); list.add(1);

list.add(3);

list.add(5); c.andIn("uid", list);

//执行按条件删除

int row = dao.deleteByExample(example); System.out.println("成功删除了"+row+"条数据");

//3、关闭资源

MyBatisUtils.commitAndClose();

}

* 按条件删除

*/ @Test

public void run10(){

/**

总结：

1、条件查询一定要先创建查询条件：

2、遇到并且条件，就用 andXxx 遇到或者条件，就用 orXxx

3、最后调用方法查询即可：

• 通用 Mapper-API（附录）
• 查询方法

• 插入方法

• 更新方法

• 删除方法