spring boot 中使用 jpa(详细操作)

            org.springframework.boot
            spring-boot-starter-test
            test
        
        
        
            org.springframework.boot
            spring-boot-starter-data-jpa
        
        
        
            com.alibaba
            druid-spring-boot-starter
            1.1.23
        
        
        
            org.projectlombok
            lombok
            true
        
        
        
            mysql
            mysql-connector-java
            5.1.47
        

在application.yml文件中添加如下配置

spring:
  server:
    port: 9000  //启动端口
  datasource:  //链接数据库
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://localhost:3306/库名?useUnicode=true&characterEncoding=utf-8&useSSL=false
    username: root
    password: root
    type: com.alibaba.druid.pool.DruidDataSource
  jpa:
    hibernate:
      ddl-auto: update //自动更新
    show-sql: true  //日志中显示sql语句

首先来看一下实体类User.java

package com.jpa.entity;

import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import org.springframework.data.annotation.CreatedDate;
import javax.persistence.*;
import java.util.Date;

@Entity
@Table(name = "user")
@Data
public class User {
    @Id
    @GeneratedValue(strategy=GenerationType.IDENTITY)//主键生成策略
    @Column(name="id")//数据库字段名
    private Integer id;

    @Column(name="name")//数据库字段名
    private String name;

    @Column(name="password")//数据库字段名
    private String password;

    @Column(name="head_portrait")//数据库字段名
    private String headPortrait;

    @Column(name="member")//数据库字段名
    private boolean member;

    @CreatedDate
    @Column(name = "register_date",updatable = false,nullable = false)
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date registerDate;

    @Column(name="vip_data")//数据库字段名
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date vipData;

    @Column(name="phone")//数据库字段名
    private String phone;

    @Column(name="admin")//数据库字段名
    private int admin;

    @Column(name="jurisdiction")//数据库字段名
    private String jurisdiction;
}

3.1JPA拥有哪些注解呢？

注解	解释
@Entity	声明类为实体或表。
@Table	声明表名。
@Basic	指定非约束明确的各个字段。
@Embedded	指定类或它的值是一个可嵌入的类的实例的实体的属性。
@Id	指定的类的属性，用于识别（一个表中的主键）。
@GeneratedValue	指定如何标识属性可以被初始化，例如自动、手动、或从序列表中获得的值。
@Transient	指定的属性，它是不持久的，即：该值永远不会存储在数据库中。
@Column	指定持久属性栏属性。
@SequenceGenerator	指定在@GeneratedValue注解中指定的属性的值。它创建了一个序列。
@TableGenerator	指定在@GeneratedValue批注指定属性的值发生器。它创造了的值生成的表。
@AccessType	这种类型的注释用于设置访问类型。如果设置@AccessType（FIELD），则可以直接访问变量并且不需要getter和setter，但必须为public。如果设置@AccessType（PROPERTY），通过getter和setter方法访问Entity的变量。
@JoinColumn	指定一个实体组织或实体的集合。这是用在多对一和一对多关联。
@UniqueConstraint	指定的字段和用于主要或辅助表的唯一约束。
@ColumnResult	参考使用select子句的SQL查询中的列名。
@ManyToMany	定义了连接表之间的多对多一对多的关系。
@ManyToOne	定义了连接表之间的多对一的关系。
@oneToMany	定义了连接表之间存在一个一对多的关系。
@oneToOne	定义了连接表之间有一个一对一的关系。
@NamedQueries	指定命名查询的列表。
@NamedQuery	指定使用静态名称的查询。

接着是UserRepository.java，改接口只需要继承JpaRepository接口即可。

package com.jpa.repository;

import com.jpa.entity.User;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;


public interface UserRepository extends JpaRepository {
    
    @Modifying
    @Query(value = "update `user` set admin= :admin where id= :id",nativeQuery = true)
    int updateAdminById(@Param("admin")Integer admin,@Param("id")Integer id);
}

然后接着写一个service。

package com.jpa.service;

import com.jpa.entity.User;

import java.util.List;


public interface UserService {

    
    void deleteUser(Integer id);

    
    User updateUser(User user);

    
    List findAllUser();

    
    User findUserById(Integer id);

    int updateAdminById(Integer admin,Integer id);
}

然后实现service。

package com.jpa.service.impl;

import com.jpa.entity.User;
import com.jpa.repository.UserRepository;
import com.jpa.service.UserService;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.List;

@Service
public class UserServiceImpl implements UserService {
    @Resource
    private UserRepository userRepository;

    @Override
    public void deleteUser(Integer id) {
        userRepository.deleteById(id);
    }

    @Override
    public User updateUser(User user) {
        return userRepository.save(user);
    }

    @Override
    public List findAllUser() {
        return userRepository.findAll();
    }

    @Override
    public User findUserById(Integer id) {
        return userRepository.findById(id).orElse(null);
    }

    @Override
    @Transactional
    public int updateAdminById(Integer admin, Integer id) {
        return userRepository.updateAdminById(admin, id);
    }
}

启动类

package com.jpa;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.data.jpa.repository.config.EnableJpaAuditing;


@EnableJpaAuditing
@SpringBootApplication
public class DemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }

}

最后写一个测试类

package com.jpa;

import com.jpa.entity.User;
import com.jpa.service.impl.UserServiceImpl;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.web.bind.annotation.ResponseBody;

import javax.annotation.Resource;
import java.util.List;

@SpringBootTest
class DemoApplicationTests {
    @Resource
    private UserServiceImpl userService;
    @Test
    void test1() {
        //查询所有用户
        List allUser = userService.findAllUser();
        for (User user : allUser) {
            System.out.println(user);
        }
    }
    @Test
    void test2(){
        //通过ID查询用户
        User userById = userService.findUserById(1);
        System.out.println("----------"+userById);
        //修改用户信息
        userById.setName("one");
        userById.setAdmin(1);
        User usr = userService.updateUser(userById);
        System.out.println(usr);
    }
    @Test
    void test3(){
        //修改用户Admin字段
        int i = userService.updateAdminById(0, 1);
        System.out.println(i);
        userService.deleteUser(1);
    }

}