本节内容需要了解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;
新建如下实体类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方法
@Override
public String toString() {
return ToStringBuilder.reflectionToString(this);
}
}
上篇博文说到，增加一个持久化单元配置，便需要增加一个持久化单元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;
}
}
详细配置信息，可以参考笔者上篇博文，这里不再赘述。
涉及文件 fleajpa-persistence.xml 和 applicationContext.xml
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;
}
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;
}
}
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;
}
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;
}
}
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查询对象还存在的一个并发问题，将在后续的博文《flea-db使用之基于对象池的FleaJPAQuery》中介绍。