大家好,欢迎来到IT知识分享网。
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(){ UserDao dao = MyBatisUtils.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 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(){
/**
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 条件删除数据 |
免责声明:本站所有文章内容,图片,视频等均是来源于用户投稿和互联网及文摘转载整编而成,不代表本站观点,不承担相关法律责任。其著作权各归其原作者或其出版社所有。如发现本站有涉嫌抄袭侵权/违法违规的内容,侵犯到您的权益,请在线联系站长,一经查实,本站将立刻删除。 本文来自网络,若有侵权,请联系删除,如若转载,请注明出处:https://yundeesoft.com/41816.html