当前位置： 首页 > article >正文

SpringBoot Data JPA基本使用

article 2024/10/19 21:16:25

一、项目起步

1.1 pom配置

<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>

<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
</dependency>

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.33</version>
</dependency>

1.2 yml配置

server:
  port: 8037
spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/db_jpa?useSSL=false&useUnicode=true&characterEncoding=utf-8
    username: root
    password: root
  jpa:
    # 在建表的时候，将默认的存储引擎切换为InnoDB
    database-platform: org.hibernate.dialect.MySQL5InnoDBDialect
    # 控制台显示sql
    show-sql: true
    # 默认为false，意味着在视图渲染完成后，session会自动关闭
    open-in-view: false
    hibernate:
      # 自动生成数据库表
      ddl-auto: update
      # 字段命名策略（默认）【驼峰转换下划线】
      naming:
        physical-strategy: org.hibernate.boot.model.naming.CamelCaseToUnderscoresNamingStrategy

1.3 实体类

1.3.1 用户

package com.qiangesoft.jpa.entity;

import java.io.Serializable;
import java.util.Date;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import javax.persistence.*;

/**
 * 用户实体
 *
 * @author qiangesoft
 * @date 2024-10-12
 */
@Data
@AllArgsConstructor
@NoArgsConstructor
@Entity
@Table(name = "sys_user")
public class SysUser implements Serializable {

    private static final long serialVersionUID = 1L;

    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    private Long id;

    private Long createBy;

    private Date createTime;

    private Long updateBy;

    private Date updateTime;

    @Column(nullable = false, length = 50)
    private String userName;

    @Column(length = 255)
    private String password;

    @ManyToOne
    @JoinColumn(name = "dept_id", nullable = false)
    private SysDept dept;

    @Column(nullable = false, length = 50)
    private String nickName;

    private Integer sex;

    @Column(length = 50)
    private String phoneNumber;

    @Column(length = 50)
    private String email;

    @Column(length = 255)
    private String avatar;

    @Column(length = 500)
    private String remark;

    private Integer status;

    @Column(name = "is_deleted", nullable = false)
    private Boolean deleted;

    /**
     * 旧密码
     * <p>非表字段</p>
     */
    @Transient
    private String oldPassword;

}

1.3.2 部门

package com.qiangesoft.jpa.entity;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import javax.persistence.*;
import java.io.Serializable;
import java.util.Date;

/**
 * 部门实体
 *
 * @author qiangesoft
 * @date 2024-10-12
 */
@Data
@AllArgsConstructor
@NoArgsConstructor
@Entity
@Table(name = "sys_dept")
public class SysDept implements Serializable {

    private static final long serialVersionUID = 1L;

    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    private Long id;

    private Long createBy;

    private Date createTime;

    private Long updateBy;

    private Date updateTime;

    @Column(nullable = false, length = 50)
    private String deptName;

    @ManyToOne
    @JoinColumn(name = "parent_id")
    private SysDept parent;

    @Column(length = 500)
    private String remark;

    private Integer status;

    @Column(name = "is_deleted", nullable = false)
    private Boolean deleted;

}

1.4持久层

1.4.1 用户

package com.qiangesoft.jpa.dao;

import com.qiangesoft.jpa.entity.SysUser;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;

/**
 * 用户持久层
 *
 * @author qiangesoft
 * @date 2024-10-12
 */
@Repository
public interface SysUserDao extends JpaRepository<SysUser, Long> {

}

1.4.2 部门

package com.qiangesoft.jpa.dao;

import com.qiangesoft.jpa.entity.SysDept;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;

/**
 * 部门持久层
 *
 * @author qiangesoft
 * @date 2024-10-12
 */
@Repository
public interface SysDeptDao extends JpaRepository<SysDept, Long> {

}

1.5 启动

在这里插入图片描述
在这里插入图片描述

二、CRUD

2.1 业务层

package com.qiangesoft.jpa.service;

import com.qiangesoft.jpa.entity.SysUser;

import java.util.List;

/**
 * 用户服务层
 *
 * @author qiangesoft
 * @date 2024-10-11
 */
public interface SysUserService {

    void save(SysUser sysUser);

    void deleteById(Long id);

    List<SysUser> finaAll();

    SysUser findById(Long id);

}


package com.qiangesoft.jpa.service.impl;

import com.qiangesoft.jpa.dao.SysUserDao;
import com.qiangesoft.jpa.entity.SysUser;
import com.qiangesoft.jpa.service.SysUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * 用户服务层实现
 *
 * @author qiangesoft
 * @date 2024-10-11
 */
@Service
public class SysUserServiceImpl implements SysUserService {

    @Autowired
    private SysUserDao sysUserDao;


    @Override
    public void save(SysUser sysUser) {
        sysUserDao.save(sysUser);
    }

    @Override
    public void deleteById(Long id) {
    	boolean exists = sysUserDao.existsById(id);
        if (exists) {
            sysUserDao.deleteById(id);
        }
    }

    @Override
    public List<SysUser> finaAll() {
        return sysUserDao.findAll();
    }

    @Override
    public SysUser findById(Long id) {
        return sysUserDao.findById(id).orElse(null);
    }
}

2.2 控制层

package com.qiangesoft.jpa.controller;

import com.qiangesoft.jpa.entity.SysUser;
import com.qiangesoft.jpa.service.SysUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.List;

@RequestMapping("/sys-user")
@RestController
public class SysUserController {

    @Autowired
    private SysUserService sysUserService;

    /**
     * 新增或者修改
     * @param sysUser
     */
    @PostMapping
    public void save(@RequestBody SysUser sysUser) {
        sysUserService.save(sysUser);
    }

    /**
     * 删除
     * @param id
     */
    @DeleteMapping("/{id}")
    public void deleteById(@PathVariable("id") Long id) {
        sysUserService.deleteById(id);
    }

    /**
     * 单个查询
     * @param id
     * @return
     */
    @GetMapping("/{id}")
    public SysUser findById(@PathVariable("id") Long id) {
        return sysUserService.findById(id);
    }

    /**
     * 查询列表
     * @return
     */
    @GetMapping
    public List<SysUser> findAll() {
        return sysUserService.finaAll();
    }

}

2.3 测试

新增
在这里插入图片描述
单个查询
在这里插入图片描述
查询列表
在这里插入图片描述
删除
在这里插入图片描述

三、进阶

3.1 持久层

package com.qiangesoft.jpa.dao;

import com.qiangesoft.jpa.entity.SysUser;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Transactional;

/**
 * 用户持久层
 *
 * @author qiangesoft
 * @date 2024-10-12
 */
@Repository
public interface SysUserDao extends JpaRepository<SysUser, Long>, JpaSpecificationExecutor<SysUser> {

    /**
     * nativeQuery为true表示使用原生sql
     * @param userName
     * @return
     */
    @Query(value = "select * from sys_user where user_name =:userName", nativeQuery = true)
    SysUser findByUserName(@Param("userName") String userName);

    @Query(value = "select u from SysUser u where u.nickName =:nickName")
    Page<SysUser> pageByNickName(@Param("nickName") String nickName, Pageable pageable);

    @Modifying
    @Transactional
    @Query("update SysUser u set u.nickName =:nickName where u.id =:id")
    Integer updateById(@Param("nickName") String nickName, @Param("id") Long id);

}

3.2 业务层

package com.qiangesoft.jpa.service;

import com.qiangesoft.jpa.entity.SysUser;
import org.springframework.data.domain.Page;

import java.util.List;

/**
 * 用户服务层
 *
 * @author qiangesoft
 * @date 2024-10-11
 */
public interface SysUserService {

    void save(SysUser sysUser);

    void deleteById(Long id);

    List<SysUser> finaAll();

    Page<SysUser> page(Integer pageNum, Integer pageSize, String nickName);

    SysUser findById(Long id);

}


package com.qiangesoft.jpa.service.impl;

import com.qiangesoft.jpa.dao.SysUserDao;
import com.qiangesoft.jpa.entity.SysUser;
import com.qiangesoft.jpa.service.SysUserService;
import lombok.SneakyThrows;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Sort;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Service;

import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import java.util.ArrayList;
import java.util.List;

/**
 * 用户服务层实现
 *
 * @author qiangesoft
 * @date 2024-10-11
 */
@Service
public class SysUserServiceImpl implements SysUserService {

    @Autowired
    private SysUserDao sysUserDao;


    @Override
    public void save(SysUser sysUser) {
        sysUserDao.save(sysUser);
    }

    @Override
    public void deleteById(Long id) {
        boolean exists = sysUserDao.existsById(id);
        if (exists) {
            sysUserDao.deleteById(id);
        }
    }

    @Override
    public List<SysUser> finaAll() {
        return sysUserDao.findAll();
    }

    @Override
    public Page<SysUser> page(Integer pageNum, Integer pageSize, String nickName) {
        // 排序
        List<Sort.Order> orders = new ArrayList<>();
        orders.add(new Sort.Order(Sort.Direction.DESC, "id"));
        Sort sort = Sort.by(orders);

        // 分页
        PageRequest pageRequest = PageRequest.of(pageNum - 1, pageSize, sort);

        if (nickName != null && !"".equals(nickName)) {
            // 查询条件
            Specification<SysUser> specification = (root, criteriaQuery, criteriaBuilder) -> {
                List<Predicate> predicateList = new ArrayList<>();
                predicateList.add(criteriaBuilder.equal(root.get("nickName"), nickName));
                Predicate[] pre = predicateList.toArray(new Predicate[0]);
                return criteriaQuery.where(pre).getRestriction();
            };
            return sysUserDao.findAll(specification, pageRequest);
//            return sysUserDao.pageByNickName(nickName, pageRequest);
        } else {
            return sysUserDao.findAll(pageRequest);
        }
    }

    @Override
    public SysUser findById(Long id) {
        sysUserDao.updateById("王五", 2L);
//        SysUser admin = sysUserDao.findByUserName("admin");
        return sysUserDao.findById(id).orElse(null);
    }
}

3.3 控制层

package com.qiangesoft.jpa.controller;

import com.qiangesoft.jpa.entity.SysUser;
import com.qiangesoft.jpa.service.SysUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.web.bind.annotation.*;

import java.util.List;

@RequestMapping("/sys-user")
@RestController
public class SysUserController {

    @Autowired
    private SysUserService sysUserService;

    /**
     * 新增或者修改
     * @param sysUser
     */
    @PostMapping
    public void save(@RequestBody SysUser sysUser) {
        sysUserService.save(sysUser);
    }

    /**
     * 删除
     * @param id
     */
    @DeleteMapping("/{id}")
    public void deleteById(@PathVariable("id") Long id) {
        sysUserService.deleteById(id);
    }

    /**
     * 单个查询
     * @param id
     * @return
     */
    @GetMapping("/{id}")
    public SysUser findById(@PathVariable("id") Long id) {
        return sysUserService.findById(id);
    }

    /**
     * 查询列表
     * @return
     */
    @GetMapping
    public List<SysUser> findAll() {
        return sysUserService.finaAll();
    }

    /**
     * 分页查询
     * @return
     */
    @GetMapping("/page")
    public Page<SysUser> page(@RequestParam Integer pageNum,
                              @RequestParam Integer pageSize,
                              @RequestParam String nickName) {
        return sysUserService.page(pageNum, pageSize, nickName);
    }

}

3.4 测试

在这里插入图片描述

四、代码仓库

https://gitee.com/qiangesoft/boot-business/tree/master/boot-business-jpa


http://www.kler.cn/news/356370.html

相关文章：

  • 《CS:GO》的标志性实验地图在 RTX GPU 神经网络中运行
  • Linux_进程概念详解(续)_命令行参数_环境变量_进程地址空间
  • SpringBoot中大量数据导出方案：使用EasyExcel并行导出多个excel文件并压缩zip后下载
  • MYSQL基础快速入门
  • 单片机探秘：从理论到应用
  • MYSQL-查看数据库中的存储过程语法（六）
  • 【Cadence27】HDL拷贝工程➕Allegro导出DXF和3D文件STP
  • Windows 与 Java 环境下的 Redis 利用分析
  • 生活中的感悟
  • 大数据linux操作系统
  • vim编辑器交换文件的产生与处理方法
  • 在 Python 语言中，元组（tuple）、字符串（str）、列表（list）和集合（set）是常见的数据结构，它们有以下区别：
  • Vscode的远程开发之VScode优势（一）
  • SpringBoot中的Component和ComponentScan注解工作原理
  • 各种语言的序列化与反序列化(C/C++ c# Python Javascript Java)
  • 【C++】string类（接口使用详解 下）
  • c++中，经常需要用来获取用户输入的写法，或者暂停【防止终端退出】
  • MySQL中8.0为啥引入索引跳跃扫描（Index Skip Scan）
  • 基于DE1-SOC的My_first_fpga
  • 14.归一化——关键的数据预处理方法