Java中SpringDataJPA的使用

　简介：

创新互联网络公司拥有10多年的成都网站开发建设经验，上千家客户的共同信赖。提供成都网站制作、网站设计、网站开发、网站定制、卖友情链接、建网站、网站搭建、成都响应式网站建设、网页设计师打造企业风格，提供周到的售前咨询和贴心的售后服务

　Spring Data JPA 的目标是通过让一些必须的工作变得更简单，来显著提高数据访问层的实现。作为一个开发者，你写你的仓库界面，包括自定义查询方法，而 Spring 给你提供自动实现。

　特性：

　对建立基于Spring 和 JPA 的库的支持

　支持 Querydsl predicates 和安全类型的 JPA 查询

　Transparent auditing of domain class

　Pagination 支持, 动态查询执行, 可以集成自定义数据访问代码

　在 @Query 注明查询引导时验证

　支持基于 XML 的实体映射

　引入 @EnableJpaRepositories.，实现基于JavaConfig based 仓库配置

1. Spring Data JPA

通常，在Java语言中，我们为项目提供数据支持时，常常用到的ORM(Object Relation Mapping)框架有:MyBatis(iBatis)或Hibernate。通常在使用时，我们需要写大量配置文件，比如mapper文件，hibernate cfg文件等。

Spring Data Jpa集成在SpringBoot中，因为SpringBoot是一款习惯大于配置的微服务框架。所以Spring Data Jpa减少了传统ORM框架中的大量配置，转而使用让数据访问类(DAO)实现接口的方式定义数据查询方式，当然，我们也可以利用Spring Data Jpa提供的@Query注解实现SQL自定义，但是因为Spring Data Jpa结合了Hibernate中的特性，所以自定义SQL语句时，必须使用HQL(Hibernate Query Language)语句。

2. 配置数据源

#application.yml

spring:

datasource:

driver-class-name: com.MySQL.cj.jdbc.Driver

url: jdbc:mysql://localhost:3306/db_88ys

username: huangwei

password: 123456789

3. 定义实体

在定义实体时，我们需要使用到大量Spring Data Jpa提供的注解，这些注解都来源于(javax.presistence.*)。

package com.demo.analysis.entity;

import lombok.Data;

import javax.persistence.*;

@Data //lombok注解，提供相应属性的getter,setter

@Entity //表明该类是实体类

@Table(name = "tb_user") //说明该实体所对应的数据表表名称，不添加则说明数据表和类名相同

public class User {

@Id //表明该属性对应数据库中的id主键

@GeneratedValue(strategy = GenerationType.IDENTITY) //指定主键生成策略:自增

private Integer id;

@Column(name = "username") //指定该属性所对应数据库中的字段名称

private String username;

@Column(name = "password")

private String password;

public User(Integer id) {

this.id = id;

}

public User(Integer id, String username, String password) {

this.id = id;

this.username = username;

this.password = password;

}

}

4. 定义数据访问接口

package com.demo.analysis.dao;

import com.demo.analysis.entity.User;

import org.springframework.data.jpa.repository.JpaRepository;

import org.springframework.data.jpa.repository.Query;

import org.springframework.stereotype.Repository;

// 在继承JpaRepository时，我们需要传入两个泛型，第一个是所对应的实体类，第二个是实体类中主键的类型

@Repository

public interface IUserDao extends JpaRepository {

// 这里我们自定义查询语句，必须使用HQL，即(Hibernate Query Language)

@Query(value = "select new User(u.id, u.username, u.password) from User u where u.username=:username")

User findUserByUserName(String username);

}

5. 数据访问接口调用郑州人流医院哪家好 http://m.zzzy120.com/

在接口调用过程中，我们会常常出现Iterable类型的参数，这是我们需要将参数转换为集合类，如List或Set。

package com.demo.analysis.controller;

import com.alibaba.fastjson.JSONArray;

import com.alibaba.fastjson.JSONObject;

import com.demo.analysis.dao.IUserDao;

import com.demo.analysis.entity.User;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RestController;

import java.util.ArrayList;

import java.util.List;

@RestController

public class UserController {

@Autowired

private IUserDao userDao;

// 查找全部

@RequestMapping(value = "/users", method = RequestMethod.GET)

public List getAllUsers() {

return userDao.findAll();

}

// 按id批量查找

@RequestMapping(value = "/users/{ids}", method = RequestMethod.GET)

public List getUsersByIds(@PathVariable("ids") String ids) {

return userDao.findAllById(this.getIdListFromString(ids));

}

// 自定义SQL，按用户名查询

@RequestMapping(value = "/user/{username}", method = RequestMethod.GET)

public User getUserByUserName(@PathVariable("username") String username) {

return userDao.findUserByUserName(username);

}

// 保存单个用户

@RequestMapping(value = "/user", method = RequestMethod.POST)

public User saveUser(User user) {

return userDao.save(user);

}

// 保存多个用户，这里传入的Json数据需要转换Json数组，并最终转换成相应实体类

@RequestMapping(value = "/users", method = RequestMethod.POST)

public List saveUsers(String users) {

JSONArray jsonArray = JSONObject.parseArray(users);

List userList = new ArrayList<>();

for (int i = 0; i < jsonArray.size(); i++) {

userList.add(jsonArray.getObject(i, User.class));

}

return userDao.saveAll(userList);

}

// 删除单个用户

@RequestMapping(value = "/user", method = RequestMethod.DELETE)

public void deleteUser(Integer id) {

userDao.deleteById(id);

}

// 按id删除多个用户

@RequestMapping(value = "/users", method = RequestMethod.DELETE)

public void deleteUsersByIds(String ids) {

List users = new ArrayList<>();

this.getIdListFromString(ids).forEach(id -> {users.add(new User(id));});

userDao.deleteInBatch(users);

}

// 将以,隔开的id转换为List

private List getIdListFromString(String ids) {

List integers = new ArrayList<>();

for (String s : ids.split(",")) {

integers.add(Integer.valueOf(s));

}

return integers;

}

}