在上一篇文章《Spring整合Hibernate实现JPA持久化》中，我们已经介绍了怎样在Spring容器中合理地集成Hibernate来实现JPA的ORM机制。但是，细心的读者会发现，上一篇文章中使用了EntityManager来直接与数据库交互，存在这一定的耦合度，更重要的是每当新增或修改新的实体Entity的管理时，都需要重复的实现EntityManager在Dao层的逻辑，有些过于模版化，重复劳动的问题存在，所以这篇文章就来介绍下解决这个问题所采用的Spring Data来自动化JPA的实现，听着很牛是吧！
l 基本储备技术介绍
l Spring Data如何实现JPA
l Spring Data JPA重构实例
一、基础储备技术介绍
在介绍如何实现之前，很有必要先介绍些储备内容。
首先，我们需要在Maven中引入spring-data-jpa软件包，参看如下内容：
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-jpa</artifactId>
<version>1.10.1.RELEASE</version>
</dependency>
这里使用了1.10.1.RELEASE版本，注意不同版本与Spring和Hibernate版本的兼容，读者只需要按照上篇文章及这里的介绍实现即可。在这个软件包里，提供了JpaRepository接口（继承自Repository），它的作用就是留给开发者自定义Dao层接口时进行拓展继承的，其用来绑定@Entity模型以及模型对应的ID类型的，这样绑定声明后，在程序或容器启动时进行初始化时，Spring Data根据@Entity注解找到该实体，并通过反射和注解技术来获取实体类的类名字、属性以及方法等参数，然后通过其默认提供的18个方法API（这里不做介绍，读者可执行查阅资料了解），来实现对实体的管理及持久化的封装。
其次，Spring Data默认生成的实体持久化方法遵循着一种模式，有助于生成针对数据库的查询，比如：
findUserByFirstnameAndLastnameOrderByLastname()
针对这个方法，SpringData是这样的规定的：find/get/read是查询动词，不论使用哪个，功能都是一样的；User代表主题，指的是被定义为@Entity实体的类名；By仅仅是一个连接符而已，其主要是用来连接查询条件（断言），以及断言内查询条件的连接，比如：OrderByLastname；FirstnameAndLastnameOrderByLastname则比较明显，是查询SQL的条件断言，这里指的根据User的Firstname和Lastname查询记录，并根据Lastname生序排列结果,另外，还可以忽略断言条件的大小写，以及判断过滤等，具体里面的内容较多，建议读者查阅相关资料熟悉了解。
最后，我们来简单介绍下DSL（领域驱动语言）：其思想主要是“求专不求全”，不像其它通用语言那样涵盖一切范围的问题，而是专门针对某一特定问题的计算机语言。在本质上，Spring Data中已经定义了一组小规模的领域驱动语言，并且持久化的细节支持，都是通过Repository方法的签名来描述的。但是，DSL也有其局限性，在其所提供的实体查询方法无法满足需求时，我们就得借助于@Query等来实现更为复杂的需求，具体会在下面实现部分介绍。
二、Spring Data如何实现JPA
1、定义查询方法，JpaRepository提供的CURD方法
UserRepository.java:
public interface UserRepository extends JpaRepository<User,String> {
// 这里不需要任何方法
}
使用JpaRepository绑定User实体（@Entity标注的实体类），并指定主键（ID）类型为String类型。此接口体内，不需要声明任何方法，直接使用由Spring Data默认提供的18个方法。
2、定义查询方法，JpaRepository规则支持的方法
UserRepository.java:
public interface UserRepository extends JpaRepository<User,String> {
// 定义查询方法，供JpaRepository默认18个方法无法满足时
User findByUsername(String userName);
// 定对查询方法，根据email或mobile查询多条记录
List<User> findByEmailOrMobile(String email,String mobile);
}
这里的两个方法，虽然是开发者自行定义的，但是它们满足Spring Data的规则，所以开发者不需要具体实现这些方法，所有的工作都交给SpringData自动完成。
3、声明自定义查询方法，采用@Query封装SQL操作
UserRepository.java:
public interface UserRepository extends JpaRepository<User,String> {
// 声明自定义查询，根据email模糊查询多条记录
@Query("select u from User u where u.email like '123456@%'")
List<User> findAllEmailUsers();
}
需要特殊说明的是，在SpringData默认的DSL不能满足需求时，那么就需要结合其支持的拓展注解@Query来灵活自定义更为复杂的SQL操作，当然这里只是为了演示用法，仅仅是实现了模糊匹配的查询。另外，findAllEmailUsers方法是用户自定义的，此时可以不需要符合Spring Data的规则，可随意命名。
4、混合自定义操作方法，与降级EntityManager结合
UserRepository.java:
public interface UserRepository extends JpaRepository<User,String> , UserExtRepository {
// 这里不需要任何方法
}
这里主要是在SpringData默认方法，以及@Query都不能满足需求时（虽然很少），就需要降级使用老版的EntityManager来实现了，当然，虽然结合使用了EntityManager，也就需要实现对应的接口，这里新建立了一个UserExtRepository接口，具体内容如下：
public interface UserExtRepository {
// 单一的Spring Data JPA无法完成的操作，
// 需要降低版本，结合EntityManager协同完成
public int batchUpdate(String email);
}
那么，接下来就得提供一个它的实现类：UserRepositoryImpl了，内容如下：
@Repository("UserRepositoryImpl")
public class UserRepositoryImpl implements UserExtRepository {
@PersistenceContext
private EntityManager em;
@Override
public intbatchUpdate(String email) {
String update = "update User u set u.status=1 where u.email='"+email+"'";
return em.createQuery(update).executeUpdate();
}
}
需要注意的是，SpringData在结合EntityManager实现JPA时，需要嵌入了EntityManager的实现类，如：UserRepositoryImpl,需要满足Spring Data的命名规则，其默认必须是采用xxxImpl的形式才能被识别，如果需要定义为别的格式命名，只需要在@EnableJpaRepositories开支持时（在Spring上下文配置中声明，这里使用的是JavaConfig方式），指定命名格式即可，具体如下实现：
@EnableJpaRepositories(basePackages="com.cwteam.orm.dao",repositoryImplementationPostfix="Helper")
同时，还有个需要注意的是，既然你想在Spring Data中混合使用EntityManager的功能，那么你的实现类的命名需要有一定规则，如：UserRepositoryImpl，其与我们继承JpaRepository的自定义类UserRepository相对应吧！另外，这里的basePackages的作用比较显示，用来指定扫描初始化Entity的位置。
三、Spring Data JPA重构实例
在完成了上面所有工作之后，接下来具体介绍下针对上一篇文章的例子重构，实际上改动量较小，主要修改Dao相关，以及控制器调用相关，具体各个新增或修改的内容已经在上面第二部分有介绍，这里直接罗列代码！
1、Dao层相关
新增UserRepository.java:
public interface UserRepository extends JpaRepository<User,String>,UserExtRepository {
// 定义查询方法，供JpaRepository默认18个方法无法满足时
User findByUsername(String userName);
// 定对查询方法，根据email或mobile查询多条记录
List<User> findByEmailOrMobile(String email,String mobile);
// 声明自定义查询，根据email模糊查询多条记录
@Query("select u from User u where u.email like '123456@%'")
List<User> findAllEmailUsers();
}
新增UserExtRepository.java:
public interface UserExtRepository {
// 单一的Spring Data JPA无法完成的操作，
// 需要降低版本，结合EntityManager协同完成
public int batchUpdate(String email);
}
新增UserRepositoryImpl.java:
@Repository("UserRepositoryImpl")
public class UserRepositoryImpl implements UserExtRepository {
@PersistenceContext
private EntityManager em;
@Override
public int batchUpdate(String email) {
String update = "update User u set u.status=1 where u.email='"+email+"'";
return em.createQuery(update).executeUpdate();
}
}
2、Service层
新增UserRepositoryService.java:
@Service("UserRepositoryService")
public class UserRepositoryService {
@Autowired
private UserRepository userRepository;
// 新增记录
@Transactional
public void saveUser(User user) {
userRepository.save(user);
}
// 更新记录
@Transactional
public void updateUser(User user) {
User result = findUserByID(user);
result.setUsername(user.getUsername());
result.setPassword(user.getPassword());
result.setEmail(user.getEmail());
result.setMobile(user.getMobile());
}
// 根据ID查询记录
public User findUserByID(User user) {
return userRepository.findOne(user.getId());
}
// 根据用户名查询
public User findByUsername(String username) {
return userRepository.findByUsername(username);
}
// 根据邮箱或手机查询
public List<User> findByEmailOrMobile(String email,String mobile) {
return userRepository.findByEmailOrMobile(email, mobile);
}
// 根据email模糊匹配
public List<User> findAllEmailUsers() {
return userRepository.findAllEmailUsers();
}
// 查询所有记录
public List<User> findUsersNoPage() {
return userRepository.findAll();
}
// 根据用户名删除记录
@Transactional
public void delete(User user) {
userRepository.delete(user);
}
// 批量修改status状态
@Transactional
public int batchUpdate(String email) {
return userRepository.batchUpdate(email);
}
}
3、Controller层
UserController.java:
@Controller
@RequestMapping("/user")
public class UserController {
@Autowired
UserRepositoryService userRepositoryService;
// 操作页面
@RequestMapping(value="/show",method=RequestMethod.GET)
public ModelAndView show() throws Exception {
// 业务逻辑处理
List<User> result = userRepositoryService.findUsersNoPage();
// 页面数据渲染
ModelAndView mav = new ModelAndView("test/user_operation");
mav.addObject("result", result);
return mav;
}
// 新增记录
@RequestMapping(value="/save",method=RequestMethod.POST)
public ModelAndView save(HttpServletRequest request) throws Exception {
User user = new User();
user.setUsername(request.getParameter("username"));
user.setPassword(request.getParameter("password"));
user.setMobile(request.getParameter("mobile"));
user.setEmail(request.getParameter("email"));
// 业务逻辑处理
userRepositoryService.saveUser(user);
// 页面数据渲染
ModelAndView mav = new ModelAndView("test/user_operation");
mav.addObject("result", userRepositoryService.findUsersNoPage());
return mav;
}
// 更新记录
@RequestMapping(value="/update",method=RequestMethod.POST)
public ModelAndView update(HttpServletRequest request) throws Exception {
User user = new User();
user.setId(request.getParameter("id"));
user.setUsername(request.getParameter("username"));
user.setPassword(request.getParameter("password"));
user.setMobile(request.getParameter("mobile"));
user.setEmail(request.getParameter("email"));
// 业务逻辑处理
userRepositoryService.updateUser(user);
// 页面数据渲染
ModelAndView mav = new ModelAndView("test/user_operation");
mav.addObject("result", userRepositoryService.findUsersNoPage());
return mav;
}
// 根据ID查询
@RequestMapping(value="/find",method=RequestMethod.GET)
public ModelAndView find(HttpServletRequest request) throws Exception {
User user = new User();
user.setId(request.getParameter("id"));
// 业务逻辑处理
User user2 = userRepositoryService.findUserByID(user);
List<User> result = new ArrayList<User>();
result.add(user2);
// 页面数据渲染
ModelAndView mav = new ModelAndView("test/user_operation");
mav.addObject("result", result);
return mav;
}
// 根据用户名查询
@RequestMapping(value="/findbyusername",method=RequestMethod.GET)
public ModelAndView findByUsername(HttpServletRequest request) throws Exception {
User user = new User();
user.setUsername(request.getParameter("username"));
// 业务逻辑处理
User userTmp = userRepositoryService.findByUsername(user.getUsername());
List<User> result = new ArrayList<User>();
result.add(userTmp);
// 页面数据渲染
ModelAndView mav = new ModelAndView("test/user_operation");
mav.addObject("result", result);
return mav;
}
// 根据email或mobile查询
@RequestMapping(value="/findbyemailormobile",method=RequestMethod.GET)
public ModelAndView findByEmailOrMobile(HttpServletRequest request) throws Exception {
User user = new User();
user.setEmail(request.getParameter("email"));
user.setMobile(request.getParameter("mobile"));
// 业务逻辑处理
List<User> result = userRepositoryService.findByEmailOrMobile(user.getEmail(), user.getMobile());
// 页面数据渲染
ModelAndView mav = new ModelAndView("test/user_operation");
mav.addObject("result", result);
return mav;
}
// 根据email模糊匹配查询
@RequestMapping(value="/findallemailusers",method=RequestMethod.GET)
public ModelAndView findAllEmailUsers(HttpServletRequest request) throws Exception {
// 业务逻辑处理
List<User> result = userRepositoryService.findAllEmailUsers();
// 页面数据渲染
ModelAndView mav = new ModelAndView("test/user_operation");
mav.addObject("result", result);
return mav;
}
// 根据ID删除记录
@RequestMapping(value="/delete",method=RequestMethod.GET)
public ModelAndView delete(HttpServletRequest request) throws Exception {
User user = new User();
user.setId(request.getParameter("id"));
// 业务逻辑处理
userRepositoryService.delete(user);
// 页面数据渲染
ModelAndView mav = new ModelAndView("test/user_operation");
mav.addObject("result", userRepositoryService.findUsersNoPage());
return mav;
}
// 根据email匹配批量修改
@RequestMapping(value="/batchupdate",method=RequestMethod.POST)
public ModelAndView extUpdate(HttpServletRequest request) throws Exception {
String email = request.getParameter("email");
// 业务逻辑处理
userRepositoryService.batchUpdate(email);
// 页面数据渲染
ModelAndView mav = new ModelAndView("test/user_operation");
mav.addObject("result", userRepositoryService.findUsersNoPage());
return mav;
}
}
4、View页面
具体的页面部分，请读者结合上一篇的jsp页面进行修改实现，具体实现的效果会在下面逻辑，读者也可以自行设计布局。
整体效果如下：
A、新增一条记录
新增cwteam7记录
B、修改一条记录
修改cwteam7的mobile值
C、根据ID查询
根据ID查询cwteam7记录
D、删除一条记录
删除cwteam7这条记录
E、根据用户名查询
根据用户名查询cwteam5记录
F、根据email或mobile查询
G、根据email模糊查询
查询条件，请查看UserRepository代码部分。
H、匹配email批量修改
修改的细节，请查看UserRepositoryImpl代码部分。
