JPA: incomplete SQL query

[sachin y deshpande]

I have a table:

JOB (
	JOB_ID NUMBER NOT NULL,
	JOB_TYPE_ID NUMBER NOT NULL,
	STATUS_CD NUMBER NOT NULL,
	SUBMITTED_BY VARCHAR2(30),
	SUBMITTED_TS TIMESTAMP(6) NOT NULL
)

and another table:

SUB_JOB (
	JOB_ID NUMBER NOT NULL,
	DEVICE_STN_ID CHAR(5) NOT NULL,
	DEVICE_EQ_TYPE CHAR(6) NOT NULL,
	DEVICE_UNIT_ID VARCHAR2(10) NOT NULL,
	STATUS_CD NUMBER NOT NULL,
	JOB_TYPE_ID NUMBER,
	STEP_ID NUMBER
)

with the following constraints:

JOB 
	PRIMARY KEY 
	(JOB_ID);

and

SUB_JOB 
	PRIMARY KEY
	(JOB_ID,
	 DEVICE_EQ_TYPE,
	 DEVICE_STN_ID,
	 DEVICE_UNIT_ID);

DEVICE_EQ_TYPE, DEVICE_STN_ID and DEVICE_UNIT_ID are FKs too.


"Generated" entities look like:

public class Job implements Serializable {
	@Id
	@Column(name="JOB_ID")
	private long jobId;

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

	@Column(name="SUBMITTED_TS")
	private Timestamp submittedTs;

	@ManyToOne
	@JoinColumn(name="JOB_TYPE_ID")
	private JobType jobTypeId;

	@ManyToOne
	@JoinColumn(name="STATUS_CD")
	private JobStatusCd statusCd;

	private static final long serialVersionUID = 1L;

	@OneToMany(mappedBy="jobId",fetch=FetchType.EAGER)
	private Set<ParamChangeJob> paramChangeJobCollection;

	@OneToMany(mappedBy="jobId",fetch=FetchType.EAGER)
	private Set<SubJob> subJobCollection;

	@JoinTable(name="FIMRWARE_UPGRADE_JOB",
joinColumns=@JoinColumn(name="JOB_ID"),
inverseJoinColumns=@JoinColumn(name="FIRMWARE_ID"))
	@ManyToMany(fetch=FetchType.EAGER)
	private Set<Firmware> firmwareCollection;

	@ManyToMany(mappedBy="jobCollection",fetch=FetchType.EAGER)
	private Set<Device> deviceCollection;

	public Job() {
		super();
	}

	public long getJobId() {
		return this.jobId;
	}

	public void setJobId(long jobId) {
		this.jobId = jobId;
	}

	public String getSubmittedBy() {
		return this.submittedBy;
	}

	public void setSubmittedBy(String submittedBy) {
		this.submittedBy = submittedBy;
	}

	public Timestamp getSubmittedTs() {
		return this.submittedTs;
	}

	public void setSubmittedTs(Timestamp submittedTs) {
		this.submittedTs = submittedTs;
	}

	public JobType getJobTypeId() {
		return this.jobTypeId;
	}

	public void setJobTypeId(JobType jobTypeId) {
		this.jobTypeId = jobTypeId;
	}

	public JobStatusCd getStatusCd() {
		return this.statusCd;
	}

	public void setStatusCd(JobStatusCd statusCd) {
		this.statusCd = statusCd;
	}

	public Set<SubJob> getSubJobCollection() {
		return this.subJobCollection;
	}

	public void setSubJobCollection(Set<SubJob> subJobCollection) {
		this.subJobCollection = subJobCollection;
	}

	public Set<ParamChangeJob> getParamChangeJobCollection() {
		return this.paramChangeJobCollection;
	}

	public void setParamChangeJobCollection(Set<ParamChangeJob> paramChangeJobCollection) {
		this.paramChangeJobCollection = paramChangeJobCollection;
	}

	public Set<Firmware> getFirmwareCollection() {
		return this.firmwareCollection;
	}

	public void setFirmwareCollection(Set<Firmware> firmwareCollection) {
		this.firmwareCollection = firmwareCollection;
	}

	public Set<Device> getDeviceCollection() {
		return this.deviceCollection;
	}

	public void setDeviceCollection(Set<Device> deviceCollection) {
		this.deviceCollection = deviceCollection;
	}

}

and:

public class SubJob implements Serializable {
	@EmbeddedId
	private SubJobPK pk;

	@Column(name="RETRY_CTR")
	private BigDecimal retryCtr;

	@ManyToOne
	@JoinColumn(name="JOB_ID")
	private Job jobId;

	@ManyToOne
	@JoinColumns({
		@JoinColumn(name="DEVICE_STN_ID", 
referencedColumnName="DEVICE_STN_ID"),
		@JoinColumn(name="DEVICE_EQ_TYPE", 
referencedColumnName="DEVICE_EQ_TYPE"),
		@JoinColumn(name="DEVICE_UNIT_ID", 
referencedColumnName="DEVICE_UNIT_ID")
	})
	private DeviceUnit deviceUnit;

	@ManyToOne
	@JoinColumns({
		@JoinColumn(name="JOB_TYPE_ID", 
referencedColumnName="JOB_TYPE_ID"),
		@JoinColumn(name="STEP_ID", 
referencedColumnName="STEP_ID")
	})
	private JobTypeSteps jobTypeSteps;

	@ManyToOne
	@JoinColumn(name="STATUS_CD")
	private JobStatusCd statusCd;

	private static final long serialVersionUID = 1L;

	@OneToMany(mappedBy="subJob",fetch=FetchType.EAGER)
	private Set<JobFailureDetails> jobFailureDetailsCollection;

	public SubJob() {
		super();
	}

	public SubJobPK getPk() {
		return this.pk;
	}

	public void setPk(SubJobPK pk) {
		this.pk = pk;
	}

	public BigDecimal getRetryCtr() {
		return this.retryCtr;
	}

	public void setRetryCtr(BigDecimal retryCtr) {
		this.retryCtr = retryCtr;
	}

	public Job getJobId() {
		return this.jobId;
	}

	public void setJobId(Job jobId) {
		this.jobId = jobId;
	}

	public DeviceUnit getDeviceUnit() {
		return this.deviceUnit;
	}

	public void setDeviceUnit(DeviceUnit deviceUnit) {
		this.deviceUnit = deviceUnit;
	}

	public JobTypeSteps getJobTypeSteps() {
		return this.jobTypeSteps;
	}

	public void setJobTypeSteps(JobTypeSteps jobTypeSteps) {
		this.jobTypeSteps = jobTypeSteps;
	}

	public JobStatusCd getStatusCd() {
		return this.statusCd;
	}

	public void setStatusCd(JobStatusCd statusCd) {
		this.statusCd = statusCd;
	}

	public Set<JobFailureDetails> getJobFailureDetailsCollection() {
		return this.jobFailureDetailsCollection;
	}

	public void setJobFailureDetailsCollection(Set<JobFailureDetails> jobFailureDetailsCollection) {
		this.jobFailureDetailsCollection = jobFailureDetailsCollection;
	}

}

and:

@Embeddable
public class SubJobPK implements Serializable {
	@Column(name="JOB_ID", insertable=false, updatable=false)
	private long jobId2;

	@Column(name="DEVICE_EQ_TYPE", insertable=false, updatable=false)
	private String deviceEqType;

	@Column(name="DEVICE_STN_ID", insertable=false, updatable=false)
	private String deviceStnId;

	@Column(name="DEVICE_UNIT_ID", insertable=false, updatable=false)
	private String deviceUnitId;

	private static final long serialVersionUID = 1L;

	public SubJobPK() {
		super();
	}

	public long getJobId2() {
		return this.jobId2;
	}

	public void setJobId2(long jobId2) {
		this.jobId2 = jobId2;
	}

	public String getDeviceEqType() {
		return this.deviceEqType;
	}

	public void setDeviceEqType(String deviceEqType) {
		this.deviceEqType = deviceEqType;
	}

	public String getDeviceStnId() {
		return this.deviceStnId;
	}

	public void setDeviceStnId(String deviceStnId) {
		this.deviceStnId = deviceStnId;
	}

	public String getDeviceUnitId() {
		return this.deviceUnitId;
	}

	public void setDeviceUnitId(String deviceUnitId) {
		this.deviceUnitId = deviceUnitId;
	}

	@Override
	public boolean equals(Object o) {
	...
	...
	...
	}

	@Override
	public int hashCode() {
	...
	...
	...
	}

}

and there are some other entities which i guess (and hope) are of not much value in this context.

I need to create a Job and SubJob in the same application managed transaction.
The JPA entity managers/controller are generated.
Note: managers/controller have been modified so that they dont have to manage transactions.

Here is the code that I have written:

...
...
...
Job dbJob = jobMgr.getNewJob();
dbJob.setSubmittedBy(ValidSubmitter);
dbJob.setJobTypeId(validdbJobType);
dbJob.setStatusCd(validbJobStatusCd);

em.beginTransaction();
jobMgr.createJob(dbJob);

SubJobPK dbSubJobPK = new dbSubJobPK();
dbSubJobPK.setDeviceStnId(ValidstationId);
dbSubJobPK.setDeviceEqType(ValideqType);
dbSubJobPK.setDeviceUnitId(ValiddeviceUnitId);
dbSubJobPK.setJobId2(dbJob.getJobId());
dbSubJob.setJobId(dbJob);
dbSubJob.setPk(dbSubJobPK);
dbSubJob.setStatusCd(dbSubJobStatusCd);
subJobMgr.createSubJob(dbSubJob);

em.commit();
...
...
...

The error stack is:
<openjpa-1.2.1-SNAPSHOT-r422266:707222 fatal store error> org.apache.openjpa.persistence.RollbackException: The transaction has been rolled back. See the nested exceptions for details on the errors that occurred.
at org.apache.openjpa.persistence.EntityManagerImpl.commit(EntityManagerImpl.java:523)
...
...
... 38 more
Caused by: <openjpa-1.2.1-SNAPSHOT-r422266:707222 nonfatal user error> org.apache.openjpa.persistence.ArgumentException: Field "entity.SubJob.pk" of "entity.SubJob@577a577a" can not be set to "entity.SubJobPK@84933dcf" value.
at org.apache.openjpa.jdbc.meta.strats.HandlerFieldStrategy.insert(HandlerFieldStrategy.java:131)
...
...
...


The queries printed on the console are:
executing prepstmnt 885994703 INSERT INTO EM.Job (JOB_ID, SUBMITTED_BY, SUBMITTED_TS, JOB_TYPE_ID, STATUS_CD) VALUES (?, ?, ?, ?, ?) [params=(long) 19, (String) shree, (Timestamp) 2009-03-13 19:54:02.125, (long) 1, (long) 1]
[0 ms] spent
executing prepstmnt 1556241602 INSERT INTO EM.SUB_JOB (JOB_ID, JOB_TYPE_ID, STEP_ID) VALUES (?, ?, ?) [params=(long) 19, (null) null, (null) null]
[16 ms] spent


Looks like the insert of SUB_JOB query is generated in correctly/ incompletely!
Can anyone help us in rectifying the problem?

Thanks in advance