JPA接入
本节内容需要了解JPA封装内容,请参见笔者 上篇博文。
准备工作
为了演示JPA接入,需要先准备如下:
- MySQL数据库 (客户端可以使用 navicat for mysql)
- 新建测试数据库 fleajpatest
-
新建测试表 student
建表语句如下:DROP TABLE IF EXISTS `student`; CREATE TABLE `student` ( `stu_id` int(10) NOT NULL AUTO_INCREMENT COMMENT '学生编号', `stu_name` varchar(255) NOT NULL COMMENT '学生姓名', `stu_age` tinyint(2) NOT NULL COMMENT '学生年龄', `stu_sex` tinyint(1) NOT NULL COMMENT '学生性别(1:男 2:女)', `stu_state` tinyint(2) NOT NULL COMMENT '学生状态(0:删除 1:在用)', PRIMARY KEY (`stu_id`) ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;
接入讲解
1. 实体类
新建如下实体类Student,对应测试表student
/**
* <p> 学生表对应的实体类 </p>
*
* @author huazie
* @version 1.0.0
* @since 1.0.0
*/
@Entity
@Table(name = "student")
public class Student implements FleaEntity {
private static final long serialVersionUID = 1267943552214677159L;
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY, generator = "STUDENT_SEQ")
@SequenceGenerator(name = "STUDENT_SEQ")
@Column(name = "stu_id", unique = true, nullable = false)
private Long stuId; // 学生编号
@Column(name = "stu_name", nullable = false)
private String stuName; // 学生姓名
@Column(name = "stu_age", nullable = false)
private Integer stuAge; // 学生年龄
@Column(name = "stu_sex", nullable = false)
private Integer stuSex; // 学生性别(1:男 2:女)
@Column(name = "stu_state", nullable = false)
private Integer stuState; // 学生状态(0:删除 1:在用)
// ... 省略get和set方法
}
2. 持久化单元DAO层实现
上篇博文说到,增加一个持久化单元配置,便需要增加一个持久化单元DAO层实现。针对本次演示新增持久化单元 fleajpa,持久化配置文件 fleajpa-persistence.xml, Spring配置中新增数据库事务管理者配置,相关内容可参考上一篇博文。下面贴出本次演示的持久化单元DAO层实现代码:
/**
* <p> FleaJpa数据源DAO层父类 </p>
*
* @author huazie
* @version 1.0.0
* @since 1.0.0
*/
public class FleaJpaDAOImpl<T> extends AbstractFleaJPADAOImpl<T> {
// 持久化单元,持久化配置文件中定义,spring配置中持久化接口工厂初始化参数
@PersistenceContext(unitName="fleajpa")
protected EntityManager entityManager;
@Override
// 持久化事务管理者, spring配置文件中定义
@Transactional("fleaJpaTransactionManager")
public boolean remove(long entityId) throws Exception {
return super.remove(entityId);
}
// ...其他实现省略
@Override
protected EntityManager getEntityManager() {
return entityManager;
}
}
3. 配置介绍
详细配置信息,可以参考笔者上篇博文,这里不再赘述。
涉及文件 fleajpa-persistence.xml 和 applicationContext.xml
4. 学生DAO层接口
IStudentDAO 继承了抽象Flea JPA DAO层接口,并定义了两个方法,分别获取学生信息列表(分页)和学生总数。
/**
* <p> 学生DAO层接口 </p>
*
* @author huazie
* @version 1.0.0
* @since 1.0.0
*/
public interface IStudentDAO extends IAbstractFleaJPADAO<Student> {
/**
* <p> 学生信息列表 (分页) </p>
*
* @param name 学生姓名,可以模糊查询
* @param sex 性别
* @param minAge 最小年龄
* @param maxAge 最大年龄
* @param pageNum 查询页
* @param pageCount 每页总数
* @return 学生信息列表
* @throws DaoException 数据操作层异常
* @since 1.0.0
*/
List<Student> getStudentList(String name, Integer sex, Integer minAge, Integer maxAge, int pageNum, int pageCount) throws DaoException;
/**
* <p> 学生总数 </p>
*
* @param name 学生姓名,可以模糊查询
* @param sex 性别
* @param minAge 最小年龄
* @param maxAge 最大年龄
* @return 学生总数
* @throws DaoException 数据操作层异常
* @since 1.0.0
*/
int getStudentCount(String name, Integer sex, Integer minAge, Integer maxAge) throws DaoException;
}
5. 学生DAO层实现
StudentDAOImpl 是学生信息的数据操作层实现,继承持久化单元DAO层实现类,并实现了上述学生DAO层接口自定义的两个方法。 具体如何使用 FleaJPAQuery 可以参见下面代码 :
/**
* <p> 学生DAO层实现类 </p>
*
* @author huazie
* @version 1.0.0
* @since 1.0.0
*/
@Repository("studentDAO")
public class StudentDAOImpl extends FleaJpaDAOImpl<Student> implements IStudentDAO {
@Override
@SuppressWarnings(value = "unchecked")
public List<Student> getStudentList(String name, Integer sex, Integer minAge, Integer maxAge, int pageNum, int pageCount) throws DaoException {
FleaJPAQuery query = initQuery(name, sex, minAge, maxAge, null);
List<Student> studentList;
if (pageNum > 0 && pageCount > 0) {
// 分页查询
studentList = query.getResultList((pageNum - 1) * pageCount, pageCount);
} else {
// 全量查询
studentList = query.getResultList();
}
return studentList;
}
@Override
@SuppressWarnings(value = "unchecked")
public long getStudentCount(String name, Integer sex, Integer minAge, Integer maxAge) throws DaoException {
FleaJPAQuery query = initQuery(name, sex, minAge, maxAge, Long.class);
// 统计数目
query.countDistinct();
Object result = query.getSingleResult();
return Long.parseLong(StringUtils.valueOf(result));
}
private FleaJPAQuery initQuery(String name, Integer sex, Integer minAge, Integer maxAge, Class<?> result) throws DaoException{
FleaJPAQuery query = getQuery(result);
// 拼接 查询条件
// 根据姓名 模糊查询, attrName 为 实体类 成员变量名,并非表字段名
if (StringUtils.isNotEmpty(name)) {
query.like("stuName", name);
}
// 查询性别
if (ObjectUtils.isNotEmpty(sex)) {
query.equal("stuSex", sex);
}
// 查询年龄范围
if (ObjectUtils.isNotEmpty(minAge)) {
// 大于等于
query.ge("stuAge", minAge);
}
if (ObjectUtils.isNotEmpty(maxAge)) {
// 小于等于
query.le("stuAge", maxAge);
}
return query;
}
}
6. 学生SV层接口
IStudentSV 继承抽象Flea JPA SV层接口,并定义两个方法,分别获取学生信息列表(分页)和学生总数。
/**
* <p> 学生SV层接口定义 </p>
*
* @author huazie
* @version 1.0.0
* @since 1.0.0
*/
public interface IStudentSV extends IAbstractFleaJPASV<Student> {
/**
* <p> 学生信息列表 (分页) </p>
*
* @param name 学生姓名,可以模糊查询
* @param sex 性别
* @param minAge 最小年龄
* @param maxAge 最大年龄
* @param pageNum 查询页
* @param pageCount 每页总数
* @return 学生信息列表
* @throws DaoException 数据操作层异常
* @since 1.0.0
*/
List<Student> getStudentList(String name, Integer sex, Integer minAge, Integer maxAge, int pageNum, int pageCount) throws DaoException;
/**
* <p> 学生总数 </p>
*
* @param name 学生姓名,可以模糊查询
* @param sex 性别
* @param minAge 最小年龄
* @param maxAge 最大年龄
* @return 学生总数
* @throws DaoException 数据操作层异常
* @since 1.0.0
*/
long getStudentCount(String name, Integer sex, Integer minAge, Integer maxAge) throws DaoException;
}
7. 学生SV层实现
StudentSVImpl 继承抽象Flea JPA SV层实现类,并实现了上述学生SV层接口的两个自定义方法。具体实现参见如下代码:
/**
* <p> 学生SV层实现类 </p>
* * @author huazie
* @version 1.0.0
* @since 1.0.0
*/
@Service("studentSV")
public class StudentSVImpl extends AbstractFleaJPASVImpl<Student> implements IStudentSV {
// 注入学生DAO层实现类
@Autowired
@Qualifier("studentDAO")
private IStudentDAO studentDao;
@Override
public List<Student> getStudentList(String name, Integer sex, Integer minAge, Integer maxAge, int pageNum, int pageCount) throws DaoException {
return studentDao.getStudentList(name, sex, minAge, maxAge, pageNum, pageCount);
}
@Override
public long getStudentCount(String name, Integer sex, Integer minAge, Integer maxAge) throws DaoException {
return studentDao.getStudentCount(name, sex, minAge, maxAge);
}
// 可参见AbstractFleaJPASVImpl里的实现
@Override
protected IAbstractFleaJPADAO<Student> getDAO() {
return studentDao;
}
}
8. JPA接入自测
-
新增学生信息
private ApplicationContext applicationContext; @Before public void init() { applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml"); LOGGER.debug("ApplicationContext={}", applicationContext); } @Test public void testInsertStudent() { try { IStudentSV studentSV = (IStudentSV) applicationContext.getBean("studentSV"); Student student = new Student(); student.setStuName("张三"); student.setStuAge(18); student.setStuSex(1); student.setStuState(1); studentSV.save(student); student = new Student(); student.setStuName("李四"); student.setStuAge(19); student.setStuSex(1); student.setStuState(1); studentSV.save(student); student = new Student(); student.setStuName("王二麻子"); student.setStuAge(20); student.setStuSex(1); student.setStuState(1); studentSV.save(student); } catch (Exception e) { LOGGER.error("Exception : ", e); } }
执行结果:
- 更新学生信息
@Test
public void testStudentUpdate() {
try {
IStudentSV studentSV = (IStudentSV) applicationContext.getBean("studentSV");
// 根据主键查询学生信息
Student student = studentSV.query(3L);
LOGGER.debug("Before : {}", student);
student.setStuName("王三麻子");
student.setStuAge(19);
// 更新学生信息
studentSV.update(student);
// 最后再根据主键查询学生信息
student = studentSV.query(3L);
LOGGER.debug("After : {}", student);
} catch (Exception e) {
LOGGER.error("Exception : ", e);
}
}
运行结果:
- 删除学生信息
@Test
public void testStudentDelete() {
try {
IStudentSV studentSV = (IStudentSV) applicationContext.getBean("studentSV");
// 根据主键查询学生信息
Student student = studentSV.query(3L);
LOGGER.debug("Before : {}", student);
// 删除学生信息(里面会先去将学生实体信息查出来,然后再删除)
studentSV.remove(3L);
// 最后再根据主键查询学生信息
student = studentSV.query(3L);
LOGGER.debug("After : {}", student);
} catch (Exception e) {
LOGGER.error("Exception : ", e);
}
}
运行结果:
-
查询学生信息(按条件分页查询)
表里自行再插入些数据,用于测试查询,查询结果因各自表数据而异;
目前我表中数据如下:@Test public void testStudentQueryPage() { try { IStudentSV studentSV = (IStudentSV) applicationContext.getBean("studentSV"); List<Student> studentList = studentSV.getStudentList("张三", 1, 18, 20, 1, 5); LOGGER.debug("Student List = {}", studentList); } catch (Exception e) { LOGGER.error("Exception : ", e); } }
运行结果:
- 查询学生总数(按条件查询)
@Test
public void testStudentQueryCount() {
try {
IStudentSV studentSV = (IStudentSV) applicationContext.getBean("studentSV");
long count = studentSV.getStudentCount("张三", 1, 18, 20);
LOGGER.debug("Student Count = {}", count);
} catch (Exception e) {
LOGGER.error("Exception : ", e);
}
}
运行结果:
看到这里,我们的JPA接入工作已经成功完成,本demo工程可以移步到GitHub查看 flea-jpa-test。
在JPA封装介绍博文中,针对Flea JPA查询对象还存在的一个并发问题,将在后续的博文中介绍。