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 类:
静态方法 | 描述 |
startPage(int pageNum,int pageSize) | 设置本次查询的分页数据。( 在本次查询之前设置 ) 参数:
|
- PageInfo 对象:
方法 | 描述 |
getPageNum() | 获取当前是第几页 |
getTotal() | 获取总记录数 |
getPages() | 获取总页数 |
getPageSize() | 获取一页显示多少条数据 |
getList() | 获取当前页的所有数据 |
- 代码实现
- 测试类
/** * 分页查询 */ @Test public void run2(){ User DAO dao = MyBatis Utils.getMapper(UserDao. class ); //1、设置分页数据 PageHelper.startPage(1, 3); //2、正常查询所有(查询时已经进行分页) //注意,此时返回的ulist,不是ArrayList,而是继承了ArrayList的Page 类对象, //page类重写了toString,所以建议使用遍历来展示数据 | ||
|
| List<User> ulist = dao .selectAll(); |
|
| //3、封装分页数据(建议使用 pageInfo 对象封装转换,可以操作功能) |
|
| PageInfo<User> pageInfo = new PageInfo<User>( ulist ); |
|
| System. out .println( “当前页:” + pageInfo .getPageNum()); |
|
| System. out .println( “总记录数:” + pageInfo .getTotal()); |
|
| System. out .println( “总页数:” + pageInfo .getPages()); |
|
| System. out .println( “一页显示记录数:” + pageInfo .getPageSize()); |
|
| //当前页的数据 |
|
| for (User u : pageInfo .getList()){ |
|
| System. out .println( u ); |
|
| } |
|
| MyBatisUtils.close(); |
| } |
|
- UserDao
@Select ( “select * from user” )
List<User> selectAll();
- 通用 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 Thread Local<SqlSession> local = new ThreadLocal<>();
/**
- 获得新会话
- @return
*/
private static Sql Session openSession(){ SqlSession sql Session = 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,分别为 Sequence Name,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 = ui d;
}
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(){
/**
|
| for (User u : list ){ System. out .println( u ); |
|
| } |
|
| //3、关闭资源 |
|
| MyBatisUtils.close(); |
| } |
|
- 分页查询
- 测试类:
//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(){
|
| //1、获取Dao实现类对象 UserDao dao = MyBatisUtils.getMapper(UserDao. class ); //2、调用通过Mapper中继承而来的方法 |
|
| int i = dao . deleteByPrimaryKey (9); |
|
| System. out .println( “成功删除” + i + “行数据” ); |
|
| //3、关闭资源 |
|
| MyBatisUtils.commitAndClose(); |
| } |
|
- 多条件查询(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(附录)
- 查询方法
方法名 | 描述 |
T selectOne(T t) | 根据实体中的属性进行查询,只能有一个返回值,有多个 结果是抛出异常,查询条件使用等号 |
List<T> select(T t) | 根据实体中的属性值进行查询,查询条件使用等号 |
List<T> selectAll() | 查询全部结果 |
int selectCount(T t) | 根据实体中的属性查询总数,查询条件,使用等号 |
T selectByPrimaryKey(Object key) | 根据主键字段进行查询 |
boolean existsWhithPrimaryKey(Object key) | 根据主键字段查询记录是否存在 |
List<T> selectByExample (Object example) | 根据 Example 条件进行查询 |
T selectOneByExample(Object example) | 根据Example 条件进行查询,只能有一个返回值 |
int selectCountByExample(Object example) | 根据 Example 条件进行查询记录数 |
- 插入方法
方法名 | 描述 |
int insert (T t) | 保存一个实体,设置为 null 的属性会作为 null 保存, 不使用该字段默认值 |
int intsertSelective (T t) | 保存一个实体,设置为 null 的属性不会直接保存 null,而是 先尝试使用数 据库默认值保存 |
- 更新方法
方法名 | 描述 |
int updateByPrimaryKey (T t) | 根据主键更新实体全部字段, 若属性设置为 null,则该字段 的值更新为 null |
int updateByPrimaryKeySelective (T t) | 根据主键更新实体, 若属性设置为 null,则忽略该属性 |
- 删除方法
方法名 | 描述 |
int delete(T t) | 根据实体属性作为条件进行删除,查询条件使用等号 |
int deletePrimaryKey (Object key) | 根据主键字段进行删除 |
int deleteByExample (Object example) | 根据 Example 条件删除数据 |