JPA中向实体集合添加新元素并保留现有数据

import javax.persistence.*;
import java.util.Set;
import java.util.HashSet; // 通常使用HashSet以保证唯一性

@Entity
@Table(name = "listOfProducts")
public class ProductsList {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Integer id;

    // ManyToMany 关系，拥有方通常在此定义
    @ManyToMany(fetch = FetchType.LAZY) // 延迟加载通常是更好的选择
    @JoinTable(
            name = "products_id", // 关联表的名称
            joinColumns = @JoinColumn(name = "id_list"), // ProductsList 在关联表中的外键
            inverseJoinColumns = @JoinColumn(name = "id_product") // Product 在关联表中的外键
    )
    private Set<Product> products = new HashSet<>(); // 初始化集合以避免NullPointerException

    // Getters and Setters
    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public Set<Product> getProducts() {
        return products;
    }

    public void setProducts(Set<Product> products) {
        this.products = products;
    }
}

import com.fasterxml.jackson.annotation.JsonIgnore; // 避免循环引用
import javax.persistence.*;
import java.util.List;
import java.util.ArrayList; // 初始化集合

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

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Integer id;

    // ManyToMany 关系，作为非拥有方
    @ManyToMany(fetch = FetchType.LAZY)
    @JoinTable(
            name = "products_id", // 关联表的名称与ProductsList中保持一致
            joinColumns = @JoinColumn(name = "id_product"), // Product 在关联表中的外键
            inverseJoinColumns = @JoinColumn(name = "id_list") // ProductsList 在关联表中的外键
    )
    @JsonIgnore // 在JSON序列化时忽略此字段，防止无限循环
    private List<ProductsList> productsLists = new ArrayList<>();

    // Getters and Setters
    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public List<ProductsList> getProductsLists() {
        return productsLists;
    }

    public void setProductsLists(List<ProductsList> productsLists) {
        this.productsLists = productsLists;
    }
}

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; // 导入事务注解
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

// 假设您有以下Repository接口
// public interface ProductsListRepository extends JpaRepository<ProductsList, Integer> {}
// public interface ProductRepository extends JpaRepository<Product, Integer> {}

@Service
public class ProductsListService {

    private static final Logger LOGGER = LoggerFactory.getLogger(ProductsListService.class);

    private final ProductsListRepository listRepository;
    private final ProductRepository productRepository;

    // 构造器注入
    public ProductsListService(ProductsListRepository listRepository, ProductRepository productRepository) {
        this.listRepository = listRepository;
        this.productRepository = productRepository;
    }

    /**
     * 向指定的产品列表中添加一个产品，并保留所有现有产品。
     *
     * @param idList    要更新的产品列表的ID。
     * @param idProduct 要添加的产品的ID。
     * @return 更新后的产品列表实体。
     * @throws ResourceNotFoundException 如果产品列表或产品不存在。
     */
    @Transactional // 确保操作在事务中进行
    public ProductsList addProductToList(Integer idList, Integer idProduct) throws ResourceNotFoundException {
        // 1. 从数据库加载原始的产品列表实体
        // 使用orElseThrow确保如果找不到列表，则抛出自定义异常
        ProductsList listOriginal = listRepository.findById(idList)
                .orElseThrow(() -> new ResourceNotFoundException("The list of products could not be found with id: " + idList));

        // 2. 从数据库加载要添加的产品实体
        // 同样，如果找不到产品，则抛出自定义异常
        Product productToAdd = productRepository.findById(idProduct) // 假设Repository有findById方法
                .orElseThrow(() -> new ResourceNotFoundException("Product not found with id: " + idProduct));

        // 3. 将新产品添加到原始列表的products集合中
        // JPA会跟踪对这个由它管理的集合的修改
        listOriginal.getProducts().add(productToAdd);

        // 4. 保存更新后的产品列表实体
        // JPA会检测到集合的变化，并相应地更新联结表（products_id）
        ProductsList updatedList = listRepository.save(listOriginal);

        LOGGER.info(String.format("Product %s was added to the list with id %s ", idProduct, idList));

        return updatedList;
    }
}