java - 使用 JPA 一对一映射以及 mysql 复合主键插入数据

Question

我想使用 JPA 一对一映射以及 mysql 中的复合主键插入数据。在这个论坛中已经有很多关于同一主题的问题，但这对我没有帮助。

但我遇到了异常，例如“非法参数异常不是已知实体类型 jpa”和“表‘callredirect.callredirect_callredirectgroup’不存在” 我的 mysql 表:

CREATE TABLE IF NOT EXISTS `CallRedirect` (
  `redirect_id` varchar(20) NOT NULL,
  `ric` varchar(20) NOT NULL,
  `tgrp` varchar (20) NOT NULL,
  `loop_ind` varchar(4) NOT NULL,
  PRIMARY KEY (`redirect_id`));


CREATE TABLE IF NOT EXISTS `CallRedirectGroup` (
  `msisdn` varchar(20) NOT NULL,
  `redirect_id` varchar(20) NOT NULL ,
PRIMARY KEY (`msisdn`,`redirect_id`),
FOREIGN KEY (redirect_id) REFERENCES CallRedirect(redirect_id));    

调用重定向.java:

package com.sample.rest.dao.entity;
import java.io.Serializable;
import java.util.List;

import javax.persistence.CascadeType;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.FetchType;
import javax.persistence.Id;
import javax.persistence.IdClass;
import javax.persistence.NamedQueries;
import javax.persistence.NamedQuery;
import javax.persistence.OneToMany;
import javax.persistence.OneToOne;
import javax.persistence.QueryHint;
import javax.persistence.Table;

import org.codehaus.jackson.annotate.JsonProperty;
import org.eclipse.persistence.annotations.PrivateOwned;


@Entity
@NamedQueries({
        @NamedQuery(name = "getCallRedirectById", query = "SELECT a FROM CallRedirect a WHERE a.redirect_id=:redirect_id", hints = @QueryHint(name = "eclipselink.refresh", value = "true")),
        @NamedQuery(name = "getAllCallRedirect", query = "SELECT a FROM CallRedirect a order by a.redirect_id", hints = @QueryHint(name = "eclipselink.refresh", value = "true"))
       //@NamedQuery(name = "deleteCallRedirectById", query = "DELETE a FROM CallRedirect a WHERE a.redirect_id=:redirect_id", hints = @QueryHint(name = "eclipselink.refresh", value = "true"))
})


@Table(name = "callRedirect")
public class CallRedirect implements Serializable{

@Id
@JsonProperty("redirect_id")
@Column(name = "redirect_id")
private String redirect_id;

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

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

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



@OneToOne(mappedBy = "callRedirect", cascade = CascadeType.ALL, fetch = FetchType.EAGER)
@PrivateOwned
private List<CallRedirectGroup> callRedirectGroupEntity;


public CallRedirect() {
    super();
    } 

/**
 * @return the redirect_id
 */
public String getRedirectId()
{
    return redirect_id;
}

/**
 * @param redirect_id
 *            the redirect_id to set
 */
public void setRedirectId(String redirect_id)
{
    this.redirect_id = redirect_id;
}

/**
 * @return the ric
 */
public String getRic()
{
    return ric;
}

/**
 * @param ric
 *            the ric to set
 */
public void setRic(String ric)
{
    this.ric = ric;
}

/**
 * @return the tgrp
 */
public String getTgrp()
{
    return tgrp;
}

/**
 * @param tgrp
 *            the tgrp to set
 */
public void setTgrp(String tgrp)
{
    this.tgrp = tgrp;
}

/**
 * @return the loop_ind
 */
public String getLoopInd()
{
    return loop_ind;
}

/**
 * @param loop_ind
 *            the loop_ind to set
 */
public void setLoopInd(String loop_ind)
{
    this.loop_ind = loop_ind;
}

/**
 * @return the callRedirectGroupEntity
 */
 public List<CallRedirectGroup> getCallRedirectGroupEntity()
{
    return callRedirectGroupEntity;
} 

/**
 * @param callRedirectGroupEntity
 *            the callRedirectGroupEntity to set
 */
public void setCallRedirectGroupEntity(List<CallRedirectGroup> callRedirectGroupEntity)
{
    this.callRedirectGroupEntity = callRedirectGroupEntity;
}

@Override
public String toString()
{
    return "CallRedirect :: redirect_id: " + redirect_id + ", Ric : " + ric + ", Tgrp : " + tgrp + ", loop_ind : "
            + loop_ind;
}

}

调用重定向组.java:

package com.sample.rest.dao.entity;
import java.io.Serializable;
import java.util.*;

import javax.persistence.CascadeType;
import javax.persistence.Column;
import javax.persistence.Embeddable;
import javax.persistence.Entity;
import javax.persistence.FetchType;
import javax.persistence.Id;
import javax.persistence.IdClass;
import javax.persistence.JoinColumn;
import javax.persistence.ManyToOne;
import javax.persistence.NamedNativeQueries;
import javax.persistence.NamedNativeQuery;
import javax.persistence.NamedQueries;
import javax.persistence.NamedQuery;
import javax.persistence.OneToOne;
import javax.persistence.QueryHint;
import javax.persistence.Table;

import org.codehaus.jackson.annotate.JsonProperty;
import org.eclipse.persistence.annotations.PrivateOwned;


@Entity
@NamedQueries({
    @NamedQuery(name = "getRedirectIdByMSISDN", query = "SELECT a FROM CallRedirectGroup a WHERE a.msisdn=:msisdn", hints = @QueryHint(name = "eclipselink.refresh", value = "true"))
    //@NamedQuery(name = "getAllCallRedirect", query = "SELECT a FROM CallRedirectGroup a order by a.redirect_id", hints = @QueryHint(name = "eclipselink.refresh", value = "true")),
    })
@NamedNativeQueries({
    @NamedNativeQuery(
            name    =   "createNewCallRedirectGroup",
            query   =   "INSERT INTO CallRedirect(redirect_id,ric,tgrp,loop_ind) VALUES (?,?,?,?)"
            ,resultSetMapping = "updateResult"
    )
})

@Table(name = "CallRedirectGroup")
public class CallRedirectGroup implements Serializable{

@Id
@Column(name = "msisdn")
@JsonProperty("msisdn")
private String msisdn;


@OneToOne
@JoinColumn(name = "redirect_id")
private CallRedirect callRedirect;

public CallRedirectGroup() {
    super();
    } 
public String getMsisdn()
{
    return msisdn;
}

public void setMsisdn(String msisdn)
{
    this.msisdn = msisdn;
}

public CallRedirect getCallRedirect()
{
    return callRedirect;
}

public void setCallRedirect(CallRedirect callRedirect)
{
    this.callRedirect = callRedirect;
    /*List<CallRedirectGroup> list = new ArrayList<CallRedirectGroup>();
    list.add(this);
    this.callRedirect.setCallRedirectGroupEntity(list);*/
}
@Override
public String toString()
{
    return "CallRedirectGroup - " + callRedirect + ", Msisdn : " + msisdn;
}
}

调用RedirectDAO.java:

    public class CallRedirectDaoImpl implements CallRedirectDao{
@PersistenceContext(unitName = "CALLREDIRECT_PERSISTENCE_READ")
private EntityManagerFactory entityManagerFactoryRead = Persistence.createEntityManagerFactory("CALLREDIRECT_PERSISTENCE_READ");
EntityManager entityManager = entityManagerFactoryRead.createEntityManager();
public boolean createNewRedirectGroup(CallRedirectGroup callredirectgroup) {
    boolean result = false;
     try
        {


        List<CallRedirectGroup> list = new ArrayList<CallRedirectGroup>();
            list.add(callredirectgroup);
         CallRedirect callredirect = callredirectgroup.getCallRedirect();

         callredirect.setCallRedirectGroupEntity(list);
         entityManager.getTransaction().begin();


         entityManager.persist(callredirect);
         entityManager.persist(callredirectgroup);
         entityManager.getTransaction().commit();
         entityManager.flush();
         result = true;
    }
     catch (PersistenceException persistenceException)
        {
         result = false;
            if(entityManager.getTransaction().isActive())
                entityManager.getTransaction().rollback();
            LOGGER.log(Level.SEVERE, "Unexpected error while creating new callRedirectGroup: " +callredirectgroup);
        }
        catch (Exception e)
        {
            result = false;
            if(entityManager.getTransaction().isActive())
                entityManager.getTransaction().rollback();
            LOGGER.log(Level.SEVERE, " while creating new callRedirectGroup, Exception = ", e);
        }
        finally
        {
            entityManager.clear();
        }
        return result;

}

持久性.xml:

    <?xml version="1.0" encoding="UTF-8"?>
<persistence xmlns="http://java.sun.com/xml/ns/persistence" version="1.0">
    <persistence-unit name="CALLREDIRECT_PERSISTENCE_READ"  transaction-type="JTA">
        <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
        <jta-data-source>jdbc/callRedirectRead</jta-data-source>
        <class>com.sample.rest.dao.entity.CallRedirect</class>
        <class>com.sample.rest.dao.entity.CallRedirectGroup</class>
        <exclude-unlisted-classes>false</exclude-unlisted-classes>      
        <properties>
            <property name="eclipselink.jpa.uppercase-column-names" value="false"/>
        </properties>   
    </persistence-unit>
</persistence>

输入为 JSON:

{
"callRedirect": {
"redirect_id": "RED002",
"ric": "ric1",
"tgrp": "tgrp1",
"loop_ind": "TES" 
},
    "msisdn": "887055"

异常(exception):

1.javax.persistence.RollbackException:异常 [EclipseLink-4002](Eclipse 持久性服务 - 2.0.2.v20100323-r6872):org.eclipse.persistence.exceptions.DatabaseException 内部异常:com.mysql.jdbc.exceptions.MySQLSyntaxErrorException:表'callredirect.callredirect_callredirectgroup'不存在 错误代码:1146 调用:插入 callRedirect_CallRedirectGroup(callRedirectGroupEntity_msisdn，CallRedirect_redirect_id)VALUES(？，？) 绑定(bind) => [887055, RED002] 查询:DataModifyQuery(sql="INSERT INTO callRedirect_CallRedirectGroup (callRedirectGroupEntity_msisdn, CallRedirect_redirect_id) VALUES (?, ?)")

2.java.lang.IllegalArgumentException: Object: CallRedirect::redirect_id: RED003, Ric : ric1, Tgrp : tgrp1, loop_ind : TES 不是已知的实体类型。

Answer 1

你正在为列表使用 OneToOne，你应该使用 OneToMany 和 ManyToOne

@OneToMany(mappedBy = "callRedirect", cascade = CascadeType.ALL, fetch = FetchType.EAGER)
@PrivateOwned
private List<CallRedirectGroup> callRedirectGroupEntity;



@ManyToOne
@JoinColumn(name = "redirect_id")
private CallRedirect callRedirect;