您的位置 首页 java

分页查询+通用mapper(Java数据库编程)

MyBatis

分页查询

分页简述

分页查询+通用mapper(Java数据库编程)

  • 搭建环境

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

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

  • 导入jar 包:
  • 添加插件
分页查询+通用mapper(Java数据库编程)

<!– 插件(放在 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)

设置本次查询的分页数据。( 在本次查询之前设置 ) 参数:

  • pageNum:当前展示数据的第几页
  • 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();

  1. 通用 Mapper
  • 概述

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

分页查询+通用mapper(Java数据库编程)

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

public interface UserDao extends Mapper<User> {

}

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

  • 搭建环境
  • 导入jar 包
分页查询+通用mapper(Java数据库编程)

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

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
分页查询+通用mapper(Java数据库编程)

*/

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());

分页查询+通用mapper(Java数据库编程)

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 +

分页查询+通用mapper(Java数据库编程)

“, 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> {

}

  • 编写测试类

通过主键查询

  • 确定主键,否则所有字段都是主键
分页查询+通用mapper(Java数据库编程)

  • 测试类

//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”

分页查询+通用mapper(Java数据库编程)

    • 多条件查询(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(){

/**

分页查询+通用mapper(Java数据库编程)

总结:

分页查询+通用mapper(Java数据库编程)

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

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

分页查询+通用mapper(Java数据库编程)

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 条件删除数据

文章来源:智云一二三科技

文章标题:分页查询+通用mapper(Java数据库编程)

文章地址:https://www.zhihuclub.com/193497.shtml

关于作者: 智云科技

热门文章

网站地图