插入數據使用JPA一對一的映射連同mysql複合主鍵

我想插入數據使用JPA一對一映射連同複合主鍵在mysql中。已經有很多問題要求在這個論壇中的同一主題，但這對我沒有幫助。插入數據使用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));

CallRedirect.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; 
} 

}

CallRedirectGroup.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; 
} 
}

CallRedirectDAO.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; 

}

的persistence.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"

}

例外：

1. javax.persistence.RollbackException: Exception [EclipseLink-4002] (Eclipse Persistence Services - 2.0.2.v20100323-r6872): org.eclipse.persistence.exceptions.DatabaseException Internal Exception: com.mysql.jdbc.exceptions.MySQLSyntaxErrorException: Table 'callredirect.callredirect_callredirectgroup' doesn't exist Error Code: 1146 Call: INSERT INTO callRedirect_CallRedirectGroup (callRedirectGroupEntity_msisdn, CallRedirect_redirect_id) VALUES (?, ?) bind => [887055, RED002] Query: 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 is not a known entity type.

來源

2017-09-25 Karthick A.S

這將永遠是一個對象和列表之間的OneToOne關係。要麼你映射它錯誤或不明白的要求。 –

[https://en.wikibooks.org/wiki/Java_Persistence/OneToMany#Example_of_a_OneToMany_relationship_database]看一看這個示例，爲您說清楚。 –

您使用OneToOne的列表中，你應該使用一對多和多對一

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



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

來源

2017-09-25 12:32:32

謝謝@Amer and Jorge ....現在它的工作正常....你讓我的一天 –

@ KarthickA.S很高興我能幫忙，隨時接受答案 –

插入數據使用JPA一對一的映射連同mysql複合主鍵

回答

相關問題