Отношение многие ко многим - получить двойные строки в MySQL

Question

Ну, как следует из названия, в моем проекте много-много отношений, когда у клиента может быть много купонов, и наоборот.Для этого я создал еще одну таблицу в MySQL, которая включает идентификатор купона и идентификатор клиента (каждая строка), но каким-то образом каждый раз, когда я добавляю купон клиенту, он удваивает свои строки в таблице coupon_customer.например:

купон-> идентификатор 1

customer-> идентификатор 4

первое добавление

теперь я добавляю еще один купон(id 2) тому же клиенту, и вот результат:

второе добавление

мой код:

Клиент:

@Entity
@Table(name = "customer")
public class Customer {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "id")
    private int id;

    @Column(name = "name")
    private String name;

    @Column(name = "password")
    private String password;

    @ManyToMany(fetch = FetchType.EAGER, cascade = { CascadeType.PERSIST, CascadeType.MERGE, CascadeType.DETACH,
            CascadeType.REFRESH })
    @JoinTable(name = "coupon_customer", joinColumns = @JoinColumn(name = "customer_id"), inverseJoinColumns = @JoinColumn(name = "coupon_id"))
    private List<Coupon> coupons;

    public Customer() {
    }

    public Customer(String name, String password) {

        this.name = name;
        this.password = password;
        this.coupons = new ArrayList<Coupon>();
    }

    public int getId() {
        return id;
    }

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

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    @JsonIgnore
    public List<Coupon> getCoupons() {

        return coupons;
    }

    public void setCoupons(ArrayList<Coupon> coupons) {
        this.coupons = coupons;
    }

    @Override
    public String toString() {
        return "Customer [id=" + id + ", name=" + name + ", password=" + password + "]";
    }

}

Купон:

@Entity
@Table(name = "coupon")
public class Coupon {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "id")
    private int id;

    @Column(name = "title")
    private String title;

    @Column(name = "start_date")
    private Date startDate;

    @Column(name = "end_date")
    private Date endDate;

    @Column(name = "amount")
    private int amount;

    @Enumerated(EnumType.STRING)
    @Column(name = "type")
    private CouponType type;

    @Column(name = "message")
    private String message;

    @Column(name = "price")
    private double price;

    @ManyToOne(fetch = FetchType.LAZY)
    @JoinColumn(name = "company_id")
    private Company company;

    @ManyToMany(fetch = FetchType.LAZY, cascade = { CascadeType.PERSIST, CascadeType.MERGE, CascadeType.DETACH,
            CascadeType.REFRESH })
    @JoinTable(name = "coupon_customer", joinColumns = @JoinColumn(name = "coupon_id"), inverseJoinColumns = @JoinColumn(name = "customer_id"))
    private List<Customer> customers;

    public Coupon() {
    }

    public Coupon(String title, Date startDate, Date endDate, int amount, CouponType type, String message,
            double price) {

        this.title = title;
        this.startDate = startDate;
        this.endDate = endDate;
        this.amount = amount;
        this.type = type;
        this.message = message;
        this.price = price;

    }

    public int getId() {
        return id;
    }

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

    public String getTitle() {
        return title;
    }

    public void setTitle(String title) {
        this.title = title;
    }

    public Date getStartDate() {
        return startDate;
    }

    public void setStartDate(Date startDate) {
        this.startDate = startDate;
    }

    public Date getEndDate() {
        return endDate;
    }

    public void setEndDate(Date endDate) {
        this.endDate = endDate;
    }

    public int getAmount() {
        return amount;
    }

    public void setAmount(int amount) {
        this.amount = amount;
    }

    public CouponType getType() {
        return type;
    }

    public void setType(CouponType type) {
        this.type = type;
    }

    public String getMessage() {
        return message;
    }

    public void setMessage(String message) {
        this.message = message;
    }

    public double getPrice() {
        return price;
    }

    public void setPrice(double price) {
        this.price = price;
    }

    @JsonIgnore
    public Company getCompany() {
        return company;
    }

    public void setCompany(Company company) {
        this.company = company;
    }

    @JsonIgnore
    public List<Customer> getCustomers() {
        return customers;
    }

    public void setCustomers(List<Customer> customers) {
        this.customers = customers;
    }

    @Override
    public String toString() {
        return "Coupon [id=" + id + ", title=" + title + ", startDate=" + startDate + ", endDate=" + endDate
                + ", amount=" + amount + ", type=" + type + ", message=" + message + ", price=" + price + "]";
    }

CustomerController:

@RequestMapping(value = "/purchaseCoupon")
    public ResponseEntity<CouponSystemResponse> purchaseCoupon(@RequestParam(value = "id") int id) {
        try {

            Coupon coupon = couponService.getCoupon(id);
            getEntity().getCoupons().add(coupon); --> getEntity() gets the customer 
            coupon.setAmount(coupon.getAmount() - 1);
            customerService.updateCustomer(getEntity()); --> updates customer after purchase coupon
            couponService.updateCoupon(coupon); --> update coupon after been purchased(amount -1)

.....

и, если это помогает, сценарий MySQL:

DROP SCHEMA IF EXISTS `couponsystem`;

CREATE SCHEMA `couponsystem`;

use `couponsystem`;



DROP TABLE IF EXISTS `company`;

CREATE TABLE `company` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(20) NOT NULL UNIQUE,
  `password` varchar(20) NOT NULL,
  `email` varchar(20) DEFAULT NULL,
  PRIMARY KEY (`id`)
);


DROP TABLE IF EXISTS `coupon`;

CREATE TABLE `coupon` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `title` varchar(20) NOT NULL UNIQUE,
  `start_date` datetime DEFAULT NULL,
  `end_date` datetime DEFAULT NULL,
  `amount` int DEFAULT NULL,
  `type` varchar(15) DEFAULT NULL,
  `message` varchar(50) DEFAULT NULL,
  `price` float DEFAULT NULL,
  `company_id` int(11),
  PRIMARY KEY (`id`),
  KEY `FK_company_id` (`company_id`),
  CONSTRAINT `FK_company_id` FOREIGN KEY (`company_id`) REFERENCES `company` (`id`) ON DELETE CASCADE ON UPDATE CASCADE
);

DROP TABLE IF EXISTS `customer`;

CREATE TABLE `customer` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(20) NOT NULL UNIQUE,
  `password` varchar(20) NOT NULL,
  PRIMARY KEY (`id`)
);


CREATE TABLE `coupon_customer`(
`coupon_id` int(11) NOT NULL,
`customer_id` int(11) NOT NULL,
/*
PRIMARY KEY (`coupon_id`,`customer_id`), --> that's in comment only cause I got exception every time row doubles itself and tried looking for solutions
*/
CONSTRAINT `FK_coupon_id` FOREIGN KEY (`coupon_id`) REFERENCES `coupon` (`id`) ON DELETE CASCADE ON UPDATE CASCADE,
CONSTRAINT `FK_customer_id` FOREIGN KEY (`customer_id`) REFERENCES `customer` (`id`) ON DELETE CASCADE ON UPDATE CASCADE

);

CustomerService:

@Service
public class CustomerService {

    @Autowired
    CustomerRepository customerRepo;


    .....

    public void updateCustomer(Customer customer) {
        customerRepo.save(customer);
    }

   .....

CouponService:

@Service
public class CouponService {

    @Autowired
    CouponRepository couponRepo;

    ......
    public void updateCoupon(Coupon coupon) {
        couponRepo.save(coupon);
    }
    ......

Странный материал. Как и все последние строки, добавьте их, а затем добавьте еще ряды.Я думал, что-то с каскадом, но не мог сделать эту работу .... благодарю за любую помощь.

Answer 1

Ваш Coupon_Customer первичный ключ должен состоять из двух полей (customer_id и coupon_id).

Глядя на ваш код, у вас нет первичного ключа в этой таблице.Это главная проблема.

Чтобы создать составной первичный ключ в Spring Data JPA, вам нужен @Embeddable аннотированный класс, который будет представлять ваш coupon_customer_id.

Что-то вродеследующее:

CouponCustomerId.java

import java.io.Serializable;

import javax.persistence.Column;
import javax.persistence.Embeddable;

@Embeddable
public class CouponCustomerId implements Serializable {

    @Column(name = "coupon_id")
    private Long couponId;

    @Column(name = "customer_id")
    private Long customerId;

    public CouponCustomerId(Long couponId, Long customerId) {
        this.couponId = couponId;
        this.customerId = customerId;
    }

    // getters and setters..
}

Теперь вам нужно создать сущность CouponCustomer с @EmbeddedId, который будет представлять ваш составной первичныйkey.

CouponCustomer.java

import java.util.ArrayList;
import java.util.List;

import javax.persistence.Column;
import javax.persistence.EmbeddedId;
import javax.persistence.Entity;
import javax.persistence.FetchType;
import javax.persistence.ManyToOne;
import javax.persistence.MapsId;
import javax.persistence.OneToMany;

@Entity
public class CouponCustomer {

    @EmbeddedId
    private CouponCustomerId id;
    @ManyToOne(fetch = FetchType.LAZY) // add your own ManyToOne configurations
    @MapsId("couponId")
    private Coupon coupon;
    @ManyToOne(fetch = FetchType.LAZY) // add your own ManyToOne configurations
    @MapsId("customerId")
    private Customer customer;

    // getters and setters..
}

Теперь, в вашей сущности Customer, вам придется изменить List<Coupon> на List<CouponCustomer> иизмените отношение на @OneToMany.

Customer.java

....
@OneToMany(mappedBy = "customer", fetch = FetchType.LAZY, cascade = {
    CascadeType.PERSIST,
    CascadeType.MERGE,
    CascadeType.DETACH,
    CascadeType.REFRESH
})
private List<CouponCustomer> coupons;
....

То же самое для сущности Coupon.

Coupon.java

....
@OneToMany(mappedBy = "coupon" fetch = FetchType.LAZY, cascade = {
    CascadeType.PERSIST,
    CascadeType.MERGE,
    CascadeType.DETACH,
    CascadeType.REFRESH
})
private List<CouponCustomer> customers;
....

Теперь, каждый раз, когда вы добавляете купон покупателю, вам просто нужно связать его идентификаторы.

Что-то вроде следующего:

@RequestMapping(value = "/purchaseCoupon")
public ResponseEntity < CouponSystemResponse > purchaseCoupon(@RequestParam(value = "id") int id) {
    try {

        Coupon coupon = couponService.getCoupon(id);
        coupon.setAmount(coupon.getAmount() - 1);
        couponService.updateCoupon(coupon); -->update coupon after been purchased(amount - 1)

        CouponCustomer cc = new CouponCustomer();
        // assuming that getEntity() gets your Customer
        cc.setCoupon(coupon);
        cc.setCustomer(getEntity();
        cc.setId(new CouponCustomerId(coupon.getId(), getEntity().getId()));
        couponCustomerService.save(cc);
        .....

Имейте в виду, что для обновления Coupon и создания записи в Coupon_customer вам не нужно для вызова customerService.updateCustomer.

В

cc.setId(new CouponCustomerId(coupon.getId(), getEntity().getId()));
couponCustomerService.save(cc);

Вы создаете запись для таблицы coupon_customer с составным первичным ключом (coupon_id, customer_id).

Надеюсь, это поможет.

Answer 2

Во-первых, я бы добавил еще одно ограничение к таблице coupon_customer, уникальную комбинацию, снабженную константой INSERT IGNORE, которая пропустит ошибки вставки, обеспечит базовую защиту таких ошибок от дБ

ALTER TABLE coupon_customer ADD  UNIQUE KEY coupon_customer (coupon_id, customer_id);

и INSERT должен быть:

INSERT IGNORE INTO...

Кроме того, функция, генерирующая запрос, должна получать ровно один параметр для каждого ключа и генерировать самый простой запрос.Если вставка js, созданная с помощью select, или функция работает с функцией с массивами, они могут генерировать ошибки, как вы описали

public function add coupon($customer_id, $coupon_id) {
... 

$sql =  "INSERT IGNORE INTO coupon_customer VALUES (". $customer_id . ",". $coupon_id . ");" ;
... 
}