SpringBoot 整合 JPA

ops/2025/2/23 10:06:46/

JPA简介

JPA（Java Persistence API）是 Java 平台的一个持久化标准，用于将 Java 对象映射到关系型数据库中的表。它是 Java EE（现 Jakarta EE）的一部分，旨在简化数据库操作，使开发者能够通过操作对象来访问和操作数据库，而无需编写复杂的 SQL 语句。

1、ORM（对象关系映射）：

  • JPA 是一种 ORM 框架，它将 Java 对象（实体类）与数据库表进行映射。

  • 开发者通过操作 Java 对象来实现对数据库的增删改查操作。

2、实体类（Entity）：

  • 使用 @Entity 注解标记的 Java 类，表示数据库中的一张表。

  • 每个实体类的实例对应数据库中的一行记录。

3、持久化上下文（Persistence Context）：

  • 持久化上下文是 JPA 管理的实体对象的集合。

  • 它负责跟踪实体对象的状态变化，并在事务提交时将变化同步到数据库。

4、实体管理器（EntityManager）：

  • 实体管理器是 JPA 的核心接口，用于管理实体对象的生命周期。

  • 通过实体管理器，开发者可以执行 CRUD 操作。

5、JPQL（Java Persistence Query Language）：

  • JPQL 是一种面向对象的查询语言，类似于 SQL，但操作的是实体对象而非数据库表。

核心注解

1、@Entity：

  • 用于标记一个类为实体类，表示该类与数据库中的一张表映射。

2、@Table：

  • 指定实体类对应的数据库表名。如果表名与类名相同，可以省略。

3、@Id：

  • 用于标记实体类的主键字段。

4、@GeneratedValue：

  • 指定主键的生成策略（如自增、UUID 等）。

5、@Column：

  • 指定字段与数据库列的映射关系。如果字段名与列名相同，可以省略。

6、@OneToMany / @ManyToOne / @ManyToMany / @OneToOne：

  • 用于定义实体类之间的关系（如一对多、多对一等）。

7、@Query：

  • 用于定义自定义查询（JPQL 或原生 SQL）。

核心组件

1、EntityManager：

  • 用于管理实体对象的生命周期，包括持久化、更新、删除和查询操作。

2、Persistence Unit：

  • 在 persistence.xml 中定义的持久化单元，包含数据源、实体类、事务类型等配置。

3、JPQL：

  • 一种面向对象的查询语言，支持动态查询和复杂查询。

4、事务管理：

  • JPA 支持容器管理的事务（CMT）和用户管理的事务（BMT）。

SpringBoot 整合 JPA

maven依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><artifactId>spring-boot-demo-orm-jpa</artifactId><version>1.0.0-SNAPSHOT</version><packaging>jar</packaging><name>spring-boot-demo-orm-jpa</name><description>Demo project for Spring Boot</description><parent><groupId>com.xiaoma</groupId><artifactId>spring-boot-demo</artifactId><version>1.0.0-SNAPSHOT</version></parent><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-jpa</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>cn.hutool</groupId><artifactId>hutool-all</artifactId></dependency><dependency><groupId>com.google.guava</groupId><artifactId>guava</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency></dependencies><build><finalName>spring-boot-demo-orm-jpa</finalName><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

JpaConfig.java

@Configuration
@EnableTransactionManagement
@EnableJpaAuditing
@EnableJpaRepositories(basePackages = "com.xiaoma.orm.jpa.repository", transactionManagerRef = "jpaTransactionManager")
public class JpaConfig {@Bean@ConfigurationProperties(prefix = "spring.datasource")public DataSource dataSource() {return DataSourceBuilder.create().build();}@Beanpublic LocalContainerEntityManagerFactoryBean entityManagerFactory() {HibernateJpaVendorAdapter japVendor = new HibernateJpaVendorAdapter();japVendor.setGenerateDdl(false);LocalContainerEntityManagerFactoryBean entityManagerFactory = new LocalContainerEntityManagerFactoryBean();entityManagerFactory.setDataSource(dataSource());entityManagerFactory.setJpaVendorAdapter(japVendor);entityManagerFactory.setPackagesToScan("com.xiaoma.orm.jpa.entity");return entityManagerFactory;}@Beanpublic PlatformTransactionManager jpaTransactionManager(EntityManagerFactory entityManagerFactory) {JpaTransactionManager transactionManager = new JpaTransactionManager();transactionManager.setEntityManagerFactory(entityManagerFactory);return transactionManager;}
}

User.java

@EqualsAndHashCode(callSuper = true)
@NoArgsConstructor
@AllArgsConstructor
@Data
@Builder
@Entity
@Table(name = "orm_user")
@ToString(callSuper = true)
public class User extends AbstractAuditModel {/*** 用户名*/private String name;/*** 加密后的密码*/private String password;/*** 加密使用的盐*/private String salt;/*** 邮箱*/private String email;/*** 手机号码*/@Column(name = "phone_number")private String phoneNumber;/*** 状态，-1：逻辑删除，0：禁用，1：启用*/private Integer status;/*** 上次登录时间*/@Column(name = "last_login_time")private Date lastLoginTime;/*** 关联部门表* 1、关系维护端，负责多对多关系的绑定和解除* 2、@JoinTable注解的name属性指定关联表的名字，joinColumns指定外键的名字，关联到关系维护端(User)* 3、inverseJoinColumns指定外键的名字，要关联的关系被维护端(Department)* 4、其实可以不使用@JoinTable注解，默认生成的关联表名称为主表表名+下划线+从表表名，* 即表名为user_department* 关联到主表的外键名：主表名+下划线+主表中的主键列名,即user_id,这里使用referencedColumnName指定* 关联到从表的外键名：主表中用于关联的属性名+下划线+从表的主键列名,department_id* 主表就是关系维护端对应的表，从表就是关系被维护端对应的表*/@ManyToMany(cascade = CascadeType.ALL, fetch = FetchType.EAGER)@JoinTable(name = "orm_user_dept", joinColumns = @JoinColumn(name = "user_id", referencedColumnName = "id"), inverseJoinColumns = @JoinColumn(name = "dept_id", referencedColumnName = "id"))private Collection<Department> departmentList;}

Department.java

@EqualsAndHashCode(callSuper = true)
@Data
@NoArgsConstructor
@AllArgsConstructor
@Builder
@Entity
@Table(name = "orm_department")
@ToString(callSuper = true)
public class Department extends AbstractAuditModel {/*** 部门名*/@Column(name = "name", columnDefinition = "varchar(255) not null")private String name;/*** 上级部门id*/@ManyToOne(cascade = {CascadeType.REFRESH}, optional = true)@JoinColumn(name = "superior", referencedColumnName = "id")private Department superior;/*** 所属层级*/@Column(name = "levels", columnDefinition = "int not null default 0")private Integer levels;/*** 排序*/@Column(name = "order_no", columnDefinition = "int not null default 0")private Integer orderNo;/*** 子部门集合*/@OneToMany(cascade = {CascadeType.REFRESH, CascadeType.REMOVE}, fetch = FetchType.EAGER, mappedBy = "superior")private Collection<Department> children;/*** 部门下用户集合*/@ManyToMany(mappedBy = "departmentList")private Collection<User> userList;}

AbstractAuditModel.java

@MappedSuperclass
@EntityListeners(AuditingEntityListener.class)
@Data
public abstract class AbstractAuditModel implements Serializable {/*** 主键*/@Id@GeneratedValue(strategy = GenerationType.IDENTITY)private Long id;/*** 创建时间*/@Temporal(TemporalType.TIMESTAMP)@Column(name = "create_time", nullable = false, updatable = false)@CreatedDateprivate Date createTime;/*** 上次更新时间*/@Temporal(TemporalType.TIMESTAMP)@Column(name = "last_update_time", nullable = false)@LastModifiedDateprivate Date lastUpdateTime;
}

UserDao.java

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

DepartmentDao.java

@Repository
public interface DepartmentDao extends JpaRepository<Department, Long> {/*** 根据层级查询部门** @param level 层级* @return 部门列表*/List<Department> findDepartmentsByLevels(Integer level);
}

application.yml

server:port: 8080servlet:context-path: /demo
spring:datasource:jdbc-url: jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&failOverReadOnly=false&serverTimezone=GMT%2B8username: rootpassword: rootdriver-class-name: com.mysql.cj.jdbc.Drivertype: com.zaxxer.hikari.HikariDataSourceinitialization-mode: alwayscontinue-on-error: trueschema:- "classpath:db/schema.sql"data:- "classpath:db/data.sql"hikari:minimum-idle: 5connection-test-query: SELECT 1 FROM DUALmaximum-pool-size: 20auto-commit: trueidle-timeout: 30000pool-name: SpringBootDemoHikariCPmax-lifetime: 60000connection-timeout: 30000jpa:show-sql: truehibernate:ddl-auto: validateproperties:hibernate:dialect: org.hibernate.dialect.MySQL57InnoDBDialectopen-in-view: true
logging:level:com.xiaoma: debugorg.hibernate.SQL: debugorg.hibernate.type: trace

UserDaoTest.java

@Slf4j
public class UserDaoTest extends SpringBootDemoOrmJpaApplicationTests {@Autowiredprivate UserDao userDao;/*** 测试保存*/@Testpublic void testSave() {String salt = IdUtil.fastSimpleUUID();User testSave3 = User.builder().name("testSave3").password(SecureUtil.md5("123456" + salt)).salt(salt).email("testSave3@xiaoma.com").phoneNumber("17300000003").status(1).lastLoginTime(new DateTime()).build();userDao.save(testSave3);Assert.assertNotNull(testSave3.getId());Optional<User> byId = userDao.findById(testSave3.getId());Assert.assertTrue(byId.isPresent());log.debug("【byId】= {}", byId.get());}/*** 测试删除*/@Testpublic void testDelete() {long count = userDao.count();userDao.deleteById(1L);long left = userDao.count();Assert.assertEquals(count - 1, left);}/*** 测试修改*/@Testpublic void testUpdate() {userDao.findById(1L).ifPresent(user -> {user.setName("JPA修改名字");userDao.save(user);});Assert.assertEquals("JPA修改名字", userDao.findById(1L).get().getName());}/*** 测试查询单个*/@Testpublic void testQueryOne() {Optional<User> byId = userDao.findById(1L);Assert.assertTrue(byId.isPresent());log.debug("【byId】= {}", byId.get());}/*** 测试查询所有*/@Testpublic void testQueryAll() {List<User> users = userDao.findAll();Assert.assertNotEquals(0, users.size());log.debug("【users】= {}", users);}/*** 测试分页排序查询*/@Testpublic void testQueryPage() {// 初始化数据initData();// JPA分页的时候起始页是页码减1Integer currentPage = 0;Integer pageSize = 5;Sort sort = Sort.by(Sort.Direction.DESC, "id");PageRequest pageRequest = PageRequest.of(currentPage, pageSize, sort);Page<User> userPage = userDao.findAll(pageRequest);Assert.assertEquals(5, userPage.getSize());Assert.assertEquals(userDao.count(), userPage.getTotalElements());log.debug("【id】= {}", userPage.getContent().stream().map(User::getId).collect(Collectors.toList()));}/*** 初始化10条数据*/private void initData() {List<User> userList = Lists.newArrayList();for (int i = 0; i < 10; i++) {String salt = IdUtil.fastSimpleUUID();int index = 3 + i;User user = User.builder().name("testSave" + index).password(SecureUtil.md5("123456" + salt)).salt(salt).email("testSave" + index + "@xiaoma.com").phoneNumber("1730000000" + index).status(1).lastLoginTime(new DateTime()).build();userList.add(user);}userDao.saveAll(userList);}}

DepartmentDaoTest.java

@Slf4j
public class DepartmentDaoTest extends SpringBootDemoOrmJpaApplicationTests {@Autowiredprivate DepartmentDao departmentDao;@Autowiredprivate UserDao userDao;/*** 测试保存 ,根节点*/@Test@Transactionalpublic void testSave() {Collection<Department> departmentList = departmentDao.findDepartmentsByLevels(0);if (departmentList.size() == 0) {Department testSave1 = Department.builder().name("testSave1").orderNo(0).levels(0).superior(null).build();Department testSave1_1 = Department.builder().name("testSave1_1").orderNo(0).levels(1).superior(testSave1).build();Department testSave1_2 = Department.builder().name("testSave1_2").orderNo(0).levels(1).superior(testSave1).build();Department testSave1_1_1 = Department.builder().name("testSave1_1_1").orderNo(0).levels(2).superior(testSave1_1).build();departmentList.add(testSave1);departmentList.add(testSave1_1);departmentList.add(testSave1_2);departmentList.add(testSave1_1_1);departmentDao.saveAll(departmentList);Collection<Department> deptall = departmentDao.findAll();log.debug("【部门】= {}", JSONArray.toJSONString((List) deptall));}userDao.findById(1L).ifPresent(user -> {user.setName("添加部门");Department dept = departmentDao.findById(2L).get();user.setDepartmentList(departmentList);userDao.save(user);});log.debug("用户部门={}", JSONUtil.toJsonStr(userDao.findById(1L).get().getDepartmentList()));departmentDao.findById(2L).ifPresent(dept -> {Collection<User> userlist = dept.getUserList();//关联关系由user维护中间表，department userlist不会发生变化，可以增加查询方法来处理  重写getUserList方法log.debug("部门下用户={}", JSONUtil.toJsonStr(userlist));});userDao.findById(1L).ifPresent(user -> {user.setName("清空部门");user.setDepartmentList(null);userDao.save(user);});log.debug("用户部门={}", userDao.findById(1L).get().getDepartmentList());}
}

sql

DROP TABLE IF EXISTS `orm_user`;
CREATE TABLE `orm_user` (`id` INT(11) NOT NULL AUTO_INCREMENT PRIMARY KEY COMMENT '主键',`name` VARCHAR(32) NOT NULL UNIQUE COMMENT '用户名',`password` VARCHAR(32) NOT NULL COMMENT '加密后的密码',`salt` VARCHAR(32) NOT NULL COMMENT '加密使用的盐',`email` VARCHAR(32) NOT NULL UNIQUE COMMENT '邮箱',`phone_number` VARCHAR(15) NOT NULL UNIQUE COMMENT '手机号码',`status` INT(2) NOT NULL DEFAULT 1 COMMENT '状态，-1：逻辑删除，0：禁用，1：启用',`create_time` DATETIME NOT NULL DEFAULT NOW() COMMENT '创建时间',`last_login_time` DATETIME DEFAULT NULL COMMENT '上次登录时间',`last_update_time` DATETIME NOT NULL DEFAULT NOW() COMMENT '上次更新时间'
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='Spring Boot Demo Orm 系列示例表';DROP TABLE IF EXISTS `orm_department`;
CREATE TABLE `orm_department` (`id` INT(11) NOT NULL AUTO_INCREMENT PRIMARY KEY COMMENT '主键',`name` VARCHAR(32) NOT NULL COMMENT '部门名称',`superior` INT(11)  COMMENT '上级id',`levels` INT(11) NOT NULL COMMENT '层级',`order_no` INT(11) NOT NULL DEFAULT 0 COMMENT '排序',`create_time` DATETIME NOT NULL DEFAULT NOW() COMMENT '创建时间',`last_update_time` DATETIME NOT NULL DEFAULT NOW() COMMENT '上次更新时间'
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='Spring Boot Demo Orm 系列示例表';DROP TABLE IF EXISTS `orm_user_dept`;
CREATE TABLE `orm_user_dept` (`id` INT(11) NOT NULL AUTO_INCREMENT PRIMARY KEY COMMENT '主键',`user_id` INT(11) NOT NULL COMMENT '用户id',`dept_id` INT(11) NOT NULL COMMENT '部门id',`create_time` DATETIME NOT NULL DEFAULT NOW() COMMENT '创建时间',`last_update_time` DATETIME NOT NULL DEFAULT NOW() COMMENT '上次更新时间'
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='Spring Boot Demo Orm 系列示例表';

http://www.ppmy.cn/ops/160739.html

相关文章

体育数据网站推荐系统开发：赛事数据、前瞻分析与智能推荐

体育数据网站推荐系统开发：赛事数据、前瞻分析与智能推荐

体育数据网站作为集赛事数据、前瞻分析、专家解读于一体的综合平台&#xff0c;其推荐系统的开发需要充分考虑多维度数据的整合与应用。本文将深入探讨如何构建一个智能化的体育数据推荐系统。 一、系统架构设计 数据采集层&#xff1a; 实时赛事数据API接入 专家分析内容抓…
阅读更多...
ctf网络安全题库 ctf网络安全大赛答案

ctf网络安全题库 ctf网络安全大赛答案

此题解仅为部分题解&#xff0c;包括&#xff1a; 【RE】&#xff1a;①Reverse_Checkin ②SimplePE ③EzGame 【Web】①f12 ②ezrunner 【Crypto】①MD5 ②password ③看我回旋踢 ④摩丝 【Misc】①爆爆爆爆 ②凯撒大帝的三个秘密 ③你才是职业选手 一、 Re ① Reverse Chec…
阅读更多...
武汉火影数字|VR沉浸式空间制作 VR大空间打造

武汉火影数字|VR沉浸式空间制作 VR大空间打造

VR沉浸式空间制作是指通过虚拟现实技术创建一个逼真的三维环境&#xff0c;让用户能够沉浸在这个环境中&#xff0c;彷佛置身于一个全新的世界。 也许你会好奇&#xff0c;VR 沉浸式空间究竟是如何将我们带入那奇妙的虚拟世界的呢&#xff1f;这背后&#xff0c;离不开一系列关…
阅读更多...
Docker的学习笔记

Docker的学习笔记

Docker的学习笔记 DockerB站视频链接-docker快速入门docker的启动dockerfile 文件的编写实现镜像的创建采用docker build创建镜像有了镜像就可以启动容器 B站文档资料创建镜像修改镜像名称删除镜像Docker 中 save 和 export 命令的区别 容器container常规命令进入容器停止容器重…
阅读更多...
粘贴到Word里的图片显示不全

粘贴到Word里的图片显示不全

粘贴到Word里的图片显示不全&#xff0c;可从Word设置、图片本身、软件与系统等方面着手解决&#xff0c;具体方法如下&#xff1a; Word软件设置 经实践发现&#xff0c;图片在word行距的行距出现问题&#xff0c;可以按照如下调整行距进行处理 修改段落行距&#xff1a; 选…
阅读更多...
【Android】类加载器热修复-随记

【Android】类加载器热修复-随记

1. 背景 在「Android插件化开发指南——类加载器」一文中曾提到&#xff0c;在Android中的类加载示意图为&#xff1a; 图中可知&#xff0c;加载外部jar、dex、apk都需要构建一个DexClassLoader的实例&#xff0c;并将对应的jar、dex、apk文件塞入其中&#xff0c;以构建出一…
阅读更多...
【多模态处理篇六】【DeepSeek3D点云处理：PointNet++工业检测】

【多模态处理篇六】【DeepSeek3D点云处理：PointNet++工业检测】

嘿，各位技术爱好者们！今天咱要来好好唠唠《DeepSeek3D点云处理：PointNet++工业检测》这个超厉害的技术。在工业领域，检测可是个至关重要的环节，而点云处理技术就像是给工业检测装上了一双超级眼睛，能让我们更精准地发现产品里的各种问题。那DeepSeek3D和PointNet++到底是…
阅读更多...
契约思维驱动开发：OpenAPI的最佳实践

契约思维驱动开发：OpenAPI的最佳实践

文章目录 引言软件设计中的规范命名规范异常处理规范服务提供者的异常处理服务调用者的异常处理 架构规范 软件设计中的标准Java规范API设计标准 依赖契约的扩展机制基于接口的扩展1. Spring ApplicationListener 扩展示例接口定义 (框架提供)用户自定义实现 (扩展点)框架调用逻…
阅读更多...
最新文章

Copyright @ 2022~2023