ManyToMany EclipseLink插入

debugcn 发表于 Dev

安东尼奥

我认为真正的问题是我无法获取最近保存的实体的ID（我不知道如何）。我正在使用eclipseLink 2.1和mysql 5.1.7，所以我离开了实体类

多对多的联接表是ProductosVentas；对不起，西班牙的名字

请帮我

这是我的剧本

public static void main(String args[]) {
    EntityManager em = EclipseLinkUtil.getEntityManagerFactory();
    em.getTransaction().begin();
    try {
        Query query = em
            .createQuery("from Productos p where p.nombre like 'Lavado de motor' ");
        Productos selledItem = (Productos) query.getSingleResult();
        query = em.createNativeQuery("select curdate() ");
        java.sql.Date sellingDate = (Date) query.getSingleResult();
        Ventas v1 = new Ventas();
        v1.setCondicionventaIdcondicionventa(new Condicionventa(1));
        v1.setFecha(sellingDate);
        List<Productosventas> selledItemTableList = new ArrayList<>();
        v1.setProductosventasCollection(selledItemTableList);
        Productosventas p = new Productosventas();
        p.setVentas(v1);
        p.setCantidad(1);
        p.setProductos(selledItem);
        selledItemTableList.add(p);
        em.persist(v1);
        em.persist(p);
        em.getTransaction().commit();
    } catch (Exception e) {
        e.printStackTrace();
        em.getTransaction().rollback();
    } finally {
        em.close();
    }
}

错误

Internal Exception: com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException:
列'ventas_idventa'不能为空错误代码：1048调用：INSERT INTO productosventas（candidad，ventas_idventa，productos_idProductos，PriceModifiers_idPriceModifier）VALUES（？，？，？，？）bind => [绑定了4个参数]

这些是我的实体

@Entity
@Table(name = "productos")
@XmlRootElement
public class Productos implements Serializable {

    @OneToMany(cascade = CascadeType.ALL, mappedBy = "productos")
    private Collection<Productosventas> productosventasCollection;
    private static final long serialVersionUID = 1L;
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Basic(optional = false)
    @Column(name = "idProductos")
    private Integer idProductos;
    // [properties]
    @JoinColumn(name = "PriceModifiers_idPriceModifier",
            referencedColumnName = "idPriceModifier")
    @ManyToOne(optional = false)
    private Pricemodifiers priceModifiersidPriceModifier;
    @JoinColumn(name = "AreaServicio_idAreaServicio",
            referencedColumnName = "idAreaServicio")
    @ManyToOne(optional = false)
    private Areaservicio areaServicioidAreaServicio;
    @JoinColumn(name = "formaventa_idFormaVenta",
            referencedColumnName = "idFormaVenta")
    @ManyToOne(optional = false)
    private Formaventa formaventaidFormaVenta;

    // geters and setters
    @XmlTransient
    public Collection<Productosventas> getProductosventasCollection() {
        return productosventasCollection;
    }

    public void setProductosventasCollection(
            Collection<Productosventas> productosventasCollection) {
        this.productosventasCollection = productosventasCollection;
    }
}

@Entity
@Table(name = "ventas")
@XmlRootElement
public class Ventas implements Serializable {

    @OneToMany(cascade = CascadeType.ALL, mappedBy = "ventas")
    private Collection<Productosventas> productosventasCollection;
    private static final long serialVersionUID = 1L;
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Basic(optional = false)
    @Column(name = "idventa")
    private Integer idventa;
    @Column(name = "fecha")
    @Temporal(TemporalType.TIMESTAMP)
    private Date fecha;
    @JoinColumn(name = "condicionventa_idcondicionventa",
            referencedColumnName = "idcondicionventa")
    @ManyToOne(optional = false)
    private Condicionventa condicionventaIdcondicionventa;
    @JoinColumn(name = "climas_idclimas", referencedColumnName = "idclimas")
    @ManyToOne(optional = false)
    private Climas climasIdclimas;
    @JoinColumn(name = "cliente_idcliente", referencedColumnName = "idcliente")
    @ManyToOne(optional = false)
    private Cliente clienteIdcliente;
    @JoinColumn(name = "cars_numberplate", referencedColumnName = "numberplate")
    @ManyToOne(optional = false)
    private Cars carsNumberplate;

    // getters and setters
    @XmlTransient
    public Collection<Productosventas> getProductosventasCollection() {
        return productosventasCollection;
    }

    public void setProductosventasCollection(
            Collection<Productosventas> productosventasCollection) {
        this.productosventasCollection = productosventasCollection;
    }
}

@Entity
@Table(name = "productosventas")
@XmlRootElement
public class Productosventas implements Serializable {

    private static final long serialVersionUID = 1L;
    @EmbeddedId
    protected ProductosventasPK productosventasPK;
    @Column(name = "cantidad")
    private Integer cantidad;
    @JoinColumn(name = "PriceModifiers_idPriceModifier",
            referencedColumnName = "idPriceModifier")
    @ManyToOne(optional = false)
    private Pricemodifiers priceModifiersidPriceModifier;
    @JoinColumn(name = "ventas_idventa", referencedColumnName = "idventa",
            insertable = false, updatable = false)
    @ManyToOne(optional = false)
    private Ventas ventas;
    @JoinColumn(name = "productos_idProductos",
            referencedColumnName = "idProductos", insertable = false,
            updatable = false)
    @ManyToOne(optional = false)
    private Productos productos;

    public Productosventas() {}

    public Productosventas(ProductosventasPK productosventasPK) {
        this.productosventasPK = productosventasPK;
    }

    public Productosventas(int ventasIdventa, int productosidProductos) {
        this.productosventasPK = new ProductosventasPK(ventasIdventa,
            productosidProductos);
    }

    public ProductosventasPK getProductosventasPK() {
        return productosventasPK;
    }

    public void setProductosventasPK(ProductosventasPK productosventasPK) {
        this.productosventasPK = productosventasPK;
    }

    // geters and setters
}

@Embeddable
public class ProductosventasPK implements Serializable {

    @Basic(optional = false)
    @Column(name = "ventas_idventa")
    private int ventasIdventa;
    @Basic(optional = false)
    @Column(name = "productos_idProductos")
    private int productosidProductos;

    public ProductosventasPK() {}

    public ProductosventasPK(int ventasIdventa, int productosidProductos) {
        this.ventasIdventa = ventasIdventa;
        this.productosidProductos = productosidProductos;
    }

    // geters and setters

    @Override
    public int hashCode() {
        int hash = 0;
        hash += (int) ventasIdventa;
        hash += (int) productosidProductos;
        return hash;
    }

    @Override
    public boolean equals(Object object) {
        // TODO: Warning - this method won't work in the case the id fields are
        // not set
        if (!(object instanceof ProductosventasPK)) {
            return false;
        }
        ProductosventasPK other = (ProductosventasPK) object;
        if (this.ventasIdventa != other.ventasIdventa) {
            return false;
        }
        if (this.productosidProductos != other.productosidProductos) {
            return false;
        }
        return true;
    }

    @Override
    public String toString() {
        return "tiendita.entities.ProductosventasPK[ ventasIdventa="
            + ventasIdventa + ", productosidProductos=" + productosidProductos
            + " ]";
    }
}

编辑

我先尝试刷新（感谢chris），但是它看起来丑陋而又冗长。...这似乎是一种奇特的方式，但是其休眠状态太糟糕了，我正在使用eclipselink。我希望这段代码可以用相同的方式编写。

session.beginTransaction();

Stock stock = new Stock();
stock.setStockCode("7052");
stock.setStockName("PADINI");

Category category1 = new Category("CONSUMER", "CONSUMER COMPANY");
//new category, need save to get the id first
session.save(category1);

StockCategory stockCategory = new StockCategory();
stockCategory.setStock(stock);
stockCategory.setCategory(category1);
stockCategory.setCreatedDate(new Date()); //extra column
stockCategory.setCreatedBy("system"); //extra column

stock.getStockCategories().add(stockCategory);

session.save(stock);

session.getTransaction().commit();

这似乎很基本

EntityManager em = EclipseLinkUtil.getEntityManagerFactory();

em.getTransaction().begin();
try {

    Query query = em.createQuery("from Productos p where p.nombre like 'Lavado de motor' ");
    Productos selledItem = (Productos) query.getSingleResult();

    query = em.createNativeQuery("select curdate() ");
    java.sql.Date sellingDate = (Date) query.getSingleResult();

    Ventas v1 = new Ventas();
    v1.setCondicionventaIdcondicionventa(new Condicionventa(1));
    v1.setFecha(sellingDate);

    List<Productosventas> selledItemTableList = new ArrayList<>();
    v1.setProductosventasCollection(selledItemTableList);
    em.persist(v1);
    em.flush();

    Productosventas p = new Productosventas();
    p.setProductosventasPK(new ProductosventasPK(v1.getIdventa(), selledItem.getIdProductos()));
    p.setCantidad(1);
    p.setProductos(selledItem);
    selledItemTableList.add(p);

    p = new Productosventas();
    p.setProductosventasPK(new ProductosventasPK(v1.getIdventa(), selledItem.getIdProductos()));
    p.setCantidad(2);
    selledItemTableList.add(p);
    selledItem.setProductosventasCollection(selledItemTableList);

    em.persist(selledItem);
    em.getTransaction().commit();

} catch (Exception e) {
    e.printStackTrace();
    em.getTransaction().rollback();
} finally {
    em.close();
}

我最讨厌的是

    em.persist(v1);
    em.flush();
    Productosventas p = new Productosventas();
    p.setProductosventasPK(new ProductosventasPK(v1.getIdventa(), selledItem.getIdProductos()));
    p.setCantidad(1);
    p.setProductos(selledItem);

第二次编辑

public class ProductosventasPK implements Serializable {

     private int ventas;

    private int productos;

    public ProductosventasPK() {
    }

    public ProductosventasPK(int ventasIdventa, int productosidProductos) {
        this.ventas = ventasIdventa;
        this.productos = productosidProductos;
    }
    // geters and setters

    @Override
    public String toString() {
        return "tiendita.entities.ProductosventasPK[ ventasIdventa=" + ventas
            + ", productosidProductos=" + productos + " ]";
    }

}

@Entity
@IdClass(ProductosventasPK.class)
@Table(name = "productosventas", catalog = "tiendita", schema = "")
public class Productosventas implements Serializable {
@JoinColumn(name = "productos_idProductos", referencedColumnName = "idProductos",
        insertable = true, updatable = true)
    @Id
    @ManyToOne(optional = false, cascade = CascadeType.MERGE)
    private Productos productos;
    @JoinColumn(name = "ventas_idventa", referencedColumnName = "idventa",
        insertable = true, updatable = true)
    @Id
    @ManyToOne(optional = false)
    private Ventas ventas;

    ProductosventasPK productosventasPK;
//important parts

}

其余的完全一样

最终编辑

[EL警告]：2013-09-25 17：14：14.291--ServerSession（1770214826）-异常[EclipseLink-4002]（Eclipse Persistence Services-2.5.0.v20130507-3faac2b）：org.eclipse.persistence.exceptions .DatabaseException内部异常：com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException：'字段列表'中的未知列'PRODUCTOSVENTASPK'错误代码：1054调用：SELECT candidad，PRODUCTOSVENTASPK，PriceModifiers_idPriceModifier，productos_idProductos，ventas_idventaproduct（from tiendita.id =？）绑定=> [绑定1个参数]查询：ReadAllQuery（name =“ productosventasList” referenceClass = Productosventas sql =“ SELECT candidad，PRODUCTOSVENTASPK，PriceModifiers_idPriceModifier，productos_idProductos，ventas_idventa FROM tiendita.productosventas WHERE（productos_idProductos =？）”）建立成功（总时间：3秒）

public class Productosventas implements Serializable {

    private static final long serialVersionUID = 1L;
    @Column(name = "cantidad")
    private Integer cantidad;
    @JoinColumn(name = "PriceModifiers_idPriceModifier", referencedColumnName = "idPriceModifier")
    @ManyToOne
    private Pricemodifiers priceModifiersidPriceModifier;
    @JoinColumn(name = "productos_idProductos", referencedColumnName = "idProductos", insertable = true, updatable = true)
    @Id
    @ManyToOne(optional = false, cascade = CascadeType.MERGE)
    private Productos productos;
    @JoinColumn(name = "ventas_idventa", referencedColumnName = "idventa", insertable = true, updatable = true)
    @Id
    @ManyToOne(optional = false)
    private Ventas ventas;
    @Transient//transistent worked like a charm
    ProductosventasPK productosventasPK;
...rest of the class }

现在我按需要插入

public static void prueba2() {
    EntityManager em = EclipseLinkUtil.getEntityManagerFactory();
    em.getTransaction().begin();
    try {
        Query query = em.createQuery("from Productos p where p.nombre like 'Lavado de motor' ");
        Productos selledItem = (Productos) query.getSingleResult();
        query = em.createQuery("from Productos p where p.nombre like 'Lavado de ventana' ");
        Productos selledItem2 = (Productos) query.getSingleResult();

    // query = em.createNativeQuery("select curdate() ");
    //java.sql.Date sellingDate = (Date) query.getSingleResult();
        java.util.Date sellingDate = new java.util.Date();

        Ventas v1 = new Ventas();
        v1.setCondicionventaIdcondicionventa(new Condicionventa(1));
        v1.setFecha(sellingDate);

        List<Productosventas> selledItemTableList = new ArrayList<>();
        Productosventas pdv = new Productosventas();
        Productosventas pdv2 = new Productosventas();
        em.persist(v1);

        pdv.setCantidad(2);
        pdv.setProductos(selledItem);
        pdv.setVentas(v1);
        pdv2.setCantidad(2);
        pdv2.setProductos(selledItem2);
        pdv2.setVentas(v1);

        selledItem.getProductosventasList().add(pdv);
        selledItem.getProductosventasList().add(pdv2);

        v1.setProductosventasList(selledItemTableList);


        em.getTransaction().commit();

    } catch (Exception e) {
        em.getTransaction().rollback();
    } finally {
        em.close();
    }
}

克里斯

要获取要在Productosventas中使用的ID值，您将需要持久保存引用的实体，然后调用flush以使提供程序为其提供SQL插入。只有使用身份策略时，才可以从数据库中设置ID，而表排序通常允许进行预分配，因此可以在持久调用中使用它们。之后，您可以从实体中获取它们，并在Productosventas的Embeddedid中进行设置。

如果可以使用JPA 2.0功能，则可以使用派生ID。对于Productosventas，您需要做的就是在@ModsId（“ productosidProductos”）上标记priceModifiersidPriceModifier，并且提供程序在分配ID时将使用该关系为您设置Embeddedid字段。对其他关系执行相同的操作，您可以同时保留所有3个实体，并且在刷新或提交所有3个实体后将设置ID值。

http://wiki.eclipse.org/EclipseLink/Examples/JPA/2.0/DerivedIdentifiers http://wiki.eclipse.org/EclipseLink/Development/JPA_2.0/mappedbyid

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。

编辑于2021-06-3

我来说两句

0条评论

登录后参与评论

来自分类Dev

Related 相关文章

文章

ManyToMany EclipseLink插入

ManyToMany EclipseLink插入

以ManyToMany关系插入数据

JPA与EclipseLink ManyToMany关系不起作用

JPA ManyToMany 插入重复值

创建时，JPA ManyToMany不会插入到联接表中

EclipseLink批处理插入非常非常慢

PostgreSQL：无法使用EclipseLink插入路径字段

使用EclipseLink JPA插入Null结构

Hibernate ManyToMany：不会在两个表中插入相同的 ID

EclipseLink确实在错误的租户中插入命令

如何防止EclipseLink / JPA在每次插入之前执行SELECT？

EclipseLink确实在错误的租户中插入命令

如何避免在 Eclipselink JPA 中读取插入的 ID

Symfony 4. ManyToMany 与属性的关联。自定义表单插入属性值，我该怎么做？

Django manytomany限制

原则-与删除的ManyToMany关系

查询多个ManyToMany条件

Spring JPA获取ManyToMany

JPA ManyToMany哪里标注

休眠ManyToMany加入

Django ManyToMany查询或问题

@ManyToMany关系无法保存

JPA ManyToMany where annotation

在ManyToMany关系中查询

在ManyToMany关系中的Save（）

Django ManyToMany查询交集

@ManyToMany额外的列

Django Manytomany动态过滤

JPA ManyToMany单向关系

ManyToMany字段的建模方法