讲师中心 微信公众号
AI工具推荐 视频效率加速

JPA多对多关联映射与中介表处理:以发票信息为例

梦宇君_9159

梦宇君_9159

发布时间:2025-11-15 16:15:12

|

525人浏览过

|

来源于php中文网

原创

JPA多对多关联映射与中介表处理:以发票信息为例

本文旨在深入探讨jpa中如何高效处理一个表作为中介,关联另外两个核心表的场景,尤其关注多对多关系的实现。我们将通过一个具体的发票与产品关联的示例,详细阐述如何利用jpa的`@onetomany`和`@manytoone`注解来建立实体间的双向关系,并演示如何通过级联操作(`cascadetype.all`)实现关联数据的同步持久化,确保数据操作的完整性与一致性。

1. 理解多对多关系与中介表

在关系型数据库设计中,当两个实体之间存在多对多关系时(例如,一张发票可以包含多个产品,一个产品也可以出现在多张发票中),通常会引入一个第三张表作为“中介表”或“连接表”来存储这种关系。这张中介表通常包含两个外键,分别指向两个关联实体的主键,并且可以包含额外的属性来描述这段关系(例如,产品在发票中的数量、折扣等)。

在本示例中,Invoice(发票)和Product(产品)之间就是多对多关系,而InvoiceInfo(发发票详情)表则充当了中介。InvoiceInfo表通过invoice_id关联Invoice,通过product_id关联Product。

2. JPA实体映射的优化

为了在JPA中正确地表示这种关系并实现数据持久化,我们需要对现有的实体类进行改造,使其能够反映出这种双向关联。

2.1 优化 InvoiceInfo 实体

InvoiceInfo是中介表,它不再直接存储product_id和invoice_id,而是通过@ManyToOne注解直接引用Product和Invoice实体对象。

前端开发
前端开发

ys-agent 前端(frontend/)功能迭代的工程规范守门 skill。当任何 agent 接到 ys-agent 前端相关任务时——新增页面、新增组件、加 API、加 Pinia store、改路由、写 mock、调整布局、修改样式、对接后端接口、迁移 demo 代码、做主题、加权限、写公共组件、做数据可视化、做表单、做弹窗、做表格、做搜索过滤、调 Element Plus 用法、做响应式、做性能优化,或仅仅是在 frontend/ 目录下编辑任何 .vue / .ts / .scss / .c

下载
import javax.persistence.*;

@Entity
@Table(name = "invoice_info")
public class InvoiceInfo {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "item_id")
    private Long id; // 统一使用Long类型ID

    // Many-to-one relationship with Product
    @ManyToOne(fetch = FetchType.LAZY) // 懒加载,提高性能
    @JoinColumn(name = "product_id", nullable = false) // 对应数据库中的外键列名
    private Product product;

    // Many-to-one relationship with Invoice
    @ManyToOne(fetch = FetchType.LAZY) // 懒加载
    @JoinColumn(name = "invoice_id", nullable = false) // 对应数据库中的外键列名
    private Invoice invoice;

    // 可以添加额外的属性,例如产品在发票中的数量
    @Column(name = "quantity")
    private int quantity;

    // 构造函数
    public InvoiceInfo() {}

    public InvoiceInfo(Product product, Invoice invoice, int quantity) {
        this.product = product;
        this.invoice = invoice;
        this.quantity = quantity;
    }

    // Getters and Setters
    public Long getId() { return id; }
    public void setId(Long id) { this.id = id; }
    public Product getProduct() { return product; }
    public void setProduct(Product product) { this.product = product; }
    public Invoice getInvoice() { return invoice; }
    public void setInvoice(Invoice invoice) { this.invoice = invoice; }
    public int getQuantity() { return quantity; }
    public void setQuantity(int quantity) { this.quantity = quantity; }

    // 建议重写equals和hashCode方法,特别是在Set中使用时
    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
        InvoiceInfo that = (InvoiceInfo) o;
        return id != null && id.equals(that.id);
    }

    @Override
    public int hashCode() {
        return 31; // 对于使用数据库生成ID的实体,可以简化hashCode,但需谨慎
    }
}

2.2 优化 Product 实体

Product实体与InvoiceInfo实体之间是一对多关系(一个产品可以出现在多条发票详情中)。

import javax.persistence.*;
import java.util.HashSet;
import java.util.Set;

@Entity
@Table(name = "product")
public class Product {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "id")
    private Long id;
    @Column(name = "family_id")
    private long familyId;
    @Column(name = "product_name")
    private String productName;
    @Column(name = "product_category")
    private String productCategory;
    @Column(name = "product_quantity") // 这是库存数量,不是发票中的数量
    private int productQuantity;

    // One-to-many relationship with InvoiceInfo
    // mappedBy指向InvoiceInfo中关联Product的字段名
    // cascade = CascadeType.ALL表示对Product的操作会级联到InvoiceInfo
    // orphanRemoval = true表示当InvoiceInfo从集合中移除时,对应的实体也会被删除
    @OneToMany(mappedBy = "product", cascade = CascadeType.ALL, orphanRemoval = true)
    private Set<InvoiceInfo> invoiceInfos = new HashSet<>();

    // Getters and Setters
    public Long getId() { return id; }
    public void setId(Long id) { this.id = id; }
    public long getFamilyId() { return familyId; }
    public void setFamilyId(long familyId) { this.familyId = familyId; }
    public String getProductName() { return productName; }
    public void setProductName(String productName) { this.productName = productName; }
    public String getProductCategory() { return productCategory; }
    public void setProductCategory(String productCategory) { this.productCategory = productCategory; }
    public int getProductQuantity() { return productQuantity; }
    public void setProductQuantity(int productQuantity) { this.productQuantity = productQuantity; }
    public Set<InvoiceInfo> getInvoiceInfos() { return invoiceInfos; }
    public void setInvoiceInfos(Set<InvoiceInfo> invoiceInfos) { this.invoiceInfos = invoiceInfos; }

    // 辅助方法,用于维护双向关系
    public void addInvoiceInfo(InvoiceInfo invoiceInfo) {
        this.invoiceInfos.add(invoiceInfo);
        invoiceInfo.setProduct(this);
    }

    public void removeInvoiceInfo(InvoiceInfo invoiceInfo) {
        this.invoiceInfos.remove(invoiceInfo);
        invoiceInfo.setProduct(null);
    }
}

2.3 优化 Invoice 实体

Invoice实体与InvoiceInfo实体之间也是一对多关系(一张发票可以包含多条发票详情)。

import javax.persistence.*;
import java.util.Date;
import java.util.HashSet;
import java.util.Set;

@Entity
@Table(name = "invoice")
public class Invoice {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "invoice_id")
    private Long id;
    @Column(name = "provider_id")
    private Long providerId;
    @Column(name = "total")
    private int invoiceTotal;
    @Column(name = "date")
    private Date invoiceDate;

    // One-to-many relationship with InvoiceInfo
    // mappedBy指向InvoiceInfo中关联Invoice的字段名
    // cascade = CascadeType.ALL表示对Invoice的操作会级联到InvoiceInfo
    // orphanRemoval = true表示当InvoiceInfo从集合中移除时,对应的实体也会被删除
    @OneToMany(mappedBy = "invoice", cascade = CascadeType.ALL, orphanRemoval = true)
    private Set<InvoiceInfo> invoiceInfos = new HashSet<>();

    // Getters and Setters
    public Long getId() { return id; }
    public void setId(Long id) { this.id = id; }
    public Long getProviderId() { return providerId; }
    public void setProviderId(Long providerId) { this.providerId = providerId; }
    public int getInvoiceTotal() { return invoiceTotal; }
    public void setInvoiceTotal(int invoiceTotal) { this.invoiceTotal = invoiceTotal; }
    public Date getInvoiceDate() { return invoiceDate; }
    public void setInvoiceDate(Date invoiceDate) { this.invoiceDate = invoiceDate; }
    public Set<InvoiceInfo> getInvoiceInfos() { return invoiceInfos; }
    public void setInvoiceInfos(Set<InvoiceInfo> invoiceInfos) { this.invoiceInfos = invoiceInfos; }

    // 辅助方法,用于维护双向关系
    public void addInvoiceInfo(InvoiceInfo invoiceInfo) {
        this.invoiceInfos.add(invoiceInfo);
        invoiceInfo.setInvoice(this);
    }

    public void removeInvoiceInfo(InvoiceInfo invoiceInfo) {
        this.invoiceInfos.remove(invoiceInfo);
        invoiceInfo.setInvoice(null);
    }
}

3. 持久化新发票及关联产品

在完成实体映射后,插入新的发票及关联产品变得相对简单。我们只需要创建Invoice对象、Product对象(或从数据库加载现有产品),然后创建InvoiceInfo对象来连接它们,并最终保存Invoice对象。由于设置了CascadeType.ALL,InvoiceInfo实体将随之自动持久化。

3.1 示例服务层代码

假设我们有InvoiceRepository和ProductRepository。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Date;
import java.util.List;
import java.util.Optional;

@Service
public class InvoiceService {

    @Autowired
    private InvoiceRepository invoiceRepository;
    @Autowired
    private ProductRepository productRepository; // 假设存在Product的Repository

    @Transactional // 确保整个操作在一个事务中
    public Invoice createNewInvoiceWithProducts(Long providerId, List<ProductDetails> productDetailsList) {
        // 1. 创建新的发票实体
        Invoice invoice = new Invoice();
        invoice.setProviderId(providerId);
        invoice.setInvoiceDate(new Date());
        invoice.setInvoiceTotal(0); // 初始总金额,可后续计算或更新

        // 2. 遍历产品详情列表,创建InvoiceInfo并建立关系
        int totalAmount = 0; // 用于计算发票总金额,如果Product有价格字段
        for (ProductDetails details : productDetailsList) {
            // 从数据库中查找产品,确保产品存在
            Optional<Product> productOptional = productRepository.findById(details.getProductId());
            if (!productOptional.isPresent()) {
                throw new IllegalArgumentException("Product with ID " + details.getProductId() + " not found.");
            }
            Product product = productOptional.get();

            // 创建InvoiceInfo实体,链接发票和产品
            InvoiceInfo invoiceInfo = new InvoiceInfo(product, invoice, details.getQuantity());

            // 建立双向关系:将invoiceInfo添加到invoice的集合中
            // 此操作会通过invoice.addInvoiceInfo()方法同时设置invoiceInfo.setInvoice(invoice)
            invoice.addInvoiceInfo(invoiceInfo);

            // 如果Product实体有价格字段,可以在这里计算总金额
            // totalAmount += product.getPrice() * details.getQuantity();
        }

        // 3. 更新发票总金额(如果适用)
        invoice.setInvoiceTotal(totalAmount);

        // 4. 保存发票实体。由于设置了CascadeType.ALL,所有关联的InvoiceInfo实体也会被自动保存。
        return invoiceRepository.save(invoice);
    }

    // 辅助类,用于接收前端传入的产品详情
    public static class ProductDetails {
        private Long productId;
        private int quantity;

        public Long getProductId() { return productId; }
        public void setProductId(Long productId) { this.productId = productId; }
        public

热门AI工具

更多
音述AI
音述AI Hot

一款AI音频处理工具,主要用于音述AI是一个以“用声音述说故事”为核心的 AI 音乐创作与声音分享社区,适合需要提升相关任务效率的用户。

小橡皮AI

一款AI工具,主要用于小橡皮一键去AI味,将机器味重的内容改得更有活人感,防止因为 AI 内容被平台打上 AI 标签,以及限流,适合需要提升相关任务效率的用户。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

火山引擎

火山引擎是一款面向企业的云计算与AI服务平台。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

超级麦吉

一款通过数字员工协作完成调研、数据分析与文档制作的AI办公平台。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

讯飞智作

讯飞智作是一款AI视频创作工具,AI文本配音工具,数字人课程、营销视频制作。

UP简历
UP简历 Hot

一款AI办公效率工具,主要用于基于AI技术的免费在线简历制作工具,适合需要提升相关任务效率的用户。

相关专题

更多
数据库三范式
数据库三范式

数据库三范式是一种设计规范,用于规范化关系型数据库中的数据结构,它通过消除冗余数据、提高数据库性能和数据一致性,提供了一种有效的数据库设计方法。本专题提供数据库三范式相关的文章、下载和课程。

2885

2023.06.29

如何删除数据库
如何删除数据库

删除数据库是指在MySQL中完全移除一个数据库及其所包含的所有数据和结构,作用包括:1、释放存储空间;2、确保数据的安全性;3、提高数据库的整体性能,加速查询和操作的执行速度。尽管删除数据库具有一些好处,但在执行任何删除操作之前,务必谨慎操作,并备份重要的数据。删除数据库将永久性地删除所有相关数据和结构,无法回滚。

4041

2023.08.14

vb怎么连接数据库
vb怎么连接数据库

在VB中,连接数据库通常使用ADO(ActiveX 数据对象)或 DAO(Data Access Objects)这两个技术来实现:1、引入ADO库;2、创建ADO连接对象;3、配置连接字符串;4、打开连接;5、执行SQL语句;6、处理查询结果;7、关闭连接即可。

3211

2023.08.31

MySQL恢复数据库
MySQL恢复数据库

MySQL恢复数据库的方法有使用物理备份恢复、使用逻辑备份恢复、使用二进制日志恢复和使用数据库复制进行恢复等。本专题为大家提供MySQL数据库相关的文章、下载、课程内容,供大家免费下载体验。

1007

2023.09.05

vb中怎么连接access数据库
vb中怎么连接access数据库

vb中连接access数据库的步骤包括引用必要的命名空间、创建连接字符串、创建连接对象、打开连接、执行SQL语句和关闭连接。本专题为大家提供连接access数据库相关的文章、下载、课程内容,供大家免费下载体验。

2807

2023.10.09

数据库对象名无效怎么解决
数据库对象名无效怎么解决

数据库对象名无效解决办法:1、检查使用的对象名是否正确,确保没有拼写错误;2、检查数据库中是否已存在具有相同名称的对象,如果是,请更改对象名为一个不同的名称,然后重新创建;3、确保在连接数据库时使用了正确的用户名、密码和数据库名称;4、尝试重启数据库服务,然后再次尝试创建或使用对象;5、尝试更新驱动程序,然后再次尝试创建或使用对象。

2807

2023.10.16

vb连接access数据库的方法
vb连接access数据库的方法

vb连接access数据库方法:1、使用ADO连接,首先导入System.Data.OleDb模块,然后定义一个连接字符串,接着创建一个OleDbConnection对象并使用Open() 方法打开连接;2、使用DAO连接,首先导入 Microsoft.Jet.OLEDB模块,然后定义一个连接字符串,接着创建一个JetConnection对象并使用Open()方法打开连接即可。

2933

2023.10.16

vb连接数据库的方法
vb连接数据库的方法

vb连接数据库的方法有使用ADO对象库、使用OLEDB数据提供程序、使用ODBC数据源等。详细介绍:1、使用ADO对象库方法,ADO是一种用于访问数据库的COM组件,可以通过ADO连接数据库并执行SQL语句。可以使用ADODB.Connection对象来建立与数据库的连接,然后使用ADODB.Recordset对象来执行查询和操作数据;2、使用OLEDB数据提供程序方法等等。

2621

2023.10.19

Vite 项目如何打包和部署
Vite 项目如何打包和部署

Vite项目打包部署专题汇集生产构建、产物预览、输出目录、资源路径、Nginx与GitHub Pages部署及常见白屏和路由404问题的已审核文章,帮助读者完成上线流程。

20

2026.10.28

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
dev.java 官方:Learn Java
dev.java 官方:Learn Java

共0课时 | 0人学习

Java JDBC数据库连接官方教程
Java JDBC数据库连接官方教程

共0课时 | 0人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn