0

0

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

DDD

DDD

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

|

505人浏览过

|

来源于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实体对象。

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实体之间是一对多关系(一个产品可以出现在多条发票详情中)。

小艺
小艺

华为公司推出的AI智能助手

下载
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 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 getInvoiceInfos() { return invoiceInfos; }
    public void setInvoiceInfos(Set 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 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 getInvoiceInfos() { return invoiceInfos; }
    public void setInvoiceInfos(Set 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 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 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

相关专题

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

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

326

2023.06.29

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

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

2066

2023.08.14

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

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

346

2023.08.31

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

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

250

2023.09.05

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

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

316

2023.10.09

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

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

401

2023.10.16

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

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

366

2023.10.16

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

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

216

2023.10.19

虚拟号码教程汇总
虚拟号码教程汇总

本专题整合了虚拟号码接收验证码相关教程,阅读下面的文章了解更多详细操作。

25

2025.12.25

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Kotlin 教程
Kotlin 教程

共23课时 | 2万人学习

C# 教程
C# 教程

共94课时 | 5.3万人学习

Java 教程
Java 教程

共578课时 | 37.8万人学习

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

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号