SpringBoot整合JPA

2020-10-04

1. 依赖

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.15</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>

2. 实体类

@Entity：说明这个类是实体类，并且使用默认的ORM规则，即类名对应数据库表中表名，类的字段名即表中的字段名。
@Table：替换默认的ORM规则。表名为t_user。
@Id：主键
@GeneratedValue(strategy = GenerationType.IDENTITY)：主键的自增策略。这里使用了GenerationType.IDENTITY，表明主键由数据库自动生成（主要是自动增长型）。

strategy 有四种：
- TABLE：使用一个特定的数据库表格来保存主键。
- SEQUENCE：根据底层数据库的序列来生成主键，条件是数据库支持序列。
- IDENTITY：主键由数据库自动生成（主要是自动增长型）
- AUTO：主键由程序控制。
@Column：将类的字段名与数据库表中的字段名相对应。

@Entity
@Table(name="t_user")
public class User {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "id")
    private int userId;

    @Column(name = "user_name")
    private String username;

    @Column(name = "password")
    private String password;

    // getter&setter
}

3. 配置文件

server.port = 8089
############ MYSQL配置 ###########
spring.datasource.url=jdbc:mysql://localhost:3306/springboot_jpa?useUnicode=true&characterEncoding=utf-8&serverTimezone=GMT%2B8&useSSL=false
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
############# JPA ##############
spring.jpa.properties.hibernate.enable_lazy_load_no_trans=true
# 打印出 sql 语句
spring.jpa.show-sql=true
spring.jpa.hibernate.ddl-auto=update
spring.jpa.open-in-view=false

4. 运行程序

在控制台上输出了建表语句。

查看数据库，可以看到已经有了t_user表，并且表的字段名和实体类代码中@Column注解所标注的相同。

5. 创建操作数据库的 Repository 接口

1
2
3

@Repository
public interface UserDao extends JpaRepository<User, Integer> {
}

继承了 JpaRepository<Person, Long>接口。查看 JpaRepository<T, ID>的源码，它已经提供好了增删改查、分页查询以及根据条件查询等方法，所以直接继承即可。

6. 使用JPA提供的方法

再需要操作数据库的地方直接使用UserDao即可

@RestController
public class UserController {

    @Autowired
    private UserDao userDao;

    @GetMapping(value = "/findUserById")
    public User findUserById(@RequestParam Integer userId) {
        Optional<User> userOptional = userDao.findById(userId);
        return userOptional.get();
    }

    @PostMapping(value = "/saveUser")
    public User saveUser(@RequestParam String userName, @RequestParam String password) {
        User user = new User();
        user.setUsername(userName);
        user.setPassword(password);
        return userDao.save(user);
    }

    @PostMapping(value = "/deleteByUserId")
    public void deleteByUserId(@RequestParam int userId) {
        userDao.deleteById(userId);
    }
}

7. 自定义方法

自定义的方法需要写到UserDao.java中，

@Repository
public interface UserDao extends JpaRepository<User, Integer> {
    Optional<User> findByUsername(String username);
}

在controller中调用自定义的方法

@GetMapping(value = "/findByUsername")
public User findByUserName(@RequestParam String username) {
    Optional<User> userOptional = userDao.findByUsername(username);
    return userOptional.get();
}

参考：