Skip to content

Package: JobStepImpl

JobStepImpl

nameinstructionbranchcomplexitylinemethod
JobStepImpl()
M: 3 C: 0
0%
M: 0 C: 0
100%
M: 1 C: 0
0%
M: 2 C: 0
0%
M: 1 C: 0
0%
JobStepImpl(JobStep)
M: 20 C: 0
0%
M: 0 C: 0
100%
M: 1 C: 0
0%
M: 6 C: 0
0%
M: 1 C: 0
0%
JobStepImpl(KapuaId)
M: 4 C: 0
0%
M: 0 C: 0
100%
M: 1 C: 0
0%
M: 2 C: 0
0%
M: 1 C: 0
0%
getJobId()
M: 3 C: 0
0%
M: 0 C: 0
100%
M: 1 C: 0
0%
M: 1 C: 0
0%
M: 1 C: 0
0%
getJobStepDefinitionId()
M: 3 C: 0
0%
M: 0 C: 0
100%
M: 1 C: 0
0%
M: 1 C: 0
0%
M: 1 C: 0
0%
getStepIndex()
M: 4 C: 0
0%
M: 0 C: 0
100%
M: 1 C: 0
0%
M: 1 C: 0
0%
M: 1 C: 0
0%
getStepProperties()
M: 11 C: 0
0%
M: 2 C: 0
0%
M: 2 C: 0
0%
M: 3 C: 0
0%
M: 1 C: 0
0%
setJobId(KapuaId)
M: 5 C: 0
0%
M: 0 C: 0
100%
M: 1 C: 0
0%
M: 2 C: 0
0%
M: 1 C: 0
0%
setJobStepDefinitionId(KapuaId)
M: 5 C: 0
0%
M: 0 C: 0
100%
M: 1 C: 0
0%
M: 2 C: 0
0%
M: 1 C: 0
0%
setStepIndex(int)
M: 5 C: 0
0%
M: 0 C: 0
100%
M: 1 C: 0
0%
M: 2 C: 0
0%
M: 1 C: 0
0%
setStepProperties(List)
M: 23 C: 0
0%
M: 2 C: 0
0%
M: 2 C: 0
0%
M: 5 C: 0
0%
M: 1 C: 0
0%

Coverage

1: /*******************************************************************************
2: * Copyright (c) 2017, 2022 Eurotech and/or its affiliates and others
3: *
4: * This program and the accompanying materials are made
5: * available under the terms of the Eclipse Public License 2.0
6: * which is available at https://www.eclipse.org/legal/epl-2.0/
7: *
8: * SPDX-License-Identifier: EPL-2.0
9: *
10: * Contributors:
11: * Eurotech - initial API and implementation
12: *******************************************************************************/
13: package org.eclipse.kapua.service.job.step.internal;
14:
15: import org.eclipse.kapua.KapuaException;
16: import org.eclipse.kapua.commons.model.AbstractKapuaNamedEntity;
17: import org.eclipse.kapua.commons.model.id.KapuaEid;
18: import org.eclipse.kapua.model.id.KapuaId;
19: import org.eclipse.kapua.service.job.step.JobStep;
20: import org.eclipse.kapua.service.job.step.definition.JobStepProperty;
21: import org.eclipse.kapua.service.job.step.definition.internal.JobStepPropertyImpl;
22:
23: import javax.persistence.AttributeOverride;
24: import javax.persistence.AttributeOverrides;
25: import javax.persistence.Basic;
26: import javax.persistence.CollectionTable;
27: import javax.persistence.Column;
28: import javax.persistence.ElementCollection;
29: import javax.persistence.Embedded;
30: import javax.persistence.Entity;
31: import javax.persistence.JoinColumn;
32: import javax.persistence.Table;
33: import java.util.ArrayList;
34: import java.util.List;
35:
36: /**
37: * {@link JobStep} implementation.
38: *
39: * @since 1.0.0
40: */
41: @Entity(name = "JobStep")
42: @Table(name = "job_job_step")
43: public class JobStepImpl extends AbstractKapuaNamedEntity implements JobStep {
44:
45: private static final long serialVersionUID = -5686107367635300337L;
46:
47: @Embedded
48: @AttributeOverrides({
49: @AttributeOverride(name = "eid", column = @Column(name = "job_id", nullable = false, updatable = false))
50: })
51: private KapuaEid jobId;
52:
53: @Embedded
54: @AttributeOverrides({
55: @AttributeOverride(name = "eid", column = @Column(name = "job_step_definition_id", nullable = false, updatable = false))
56: })
57: private KapuaEid jobStepDefinitionId;
58:
59: @Basic
60: @Column(name = "step_index", nullable = false, updatable = true)
61: private Integer stepIndex;
62:
63: @ElementCollection
64: @CollectionTable(name = "job_job_step_properties", joinColumns = @JoinColumn(name = "step_id", referencedColumnName = "id"))
65: private List<JobStepPropertyImpl> stepProperties;
66:
67: /**
68: * Constructor.
69: *
70: * @since 1.0.0
71: */
72: public JobStepImpl() {
73: }
74:
75: /**
76: * Constructor.
77: *
78: * @param scopeId The scope {@link KapuaId} to set into the {@link JobStep}
79: * @since 1.0.0
80: */
81: public JobStepImpl(KapuaId scopeId) {
82: super(scopeId);
83: }
84:
85: /**
86: * Clone constructor.
87: *
88: * @param jobStep
89: * @throws KapuaException
90: * @since 1.1.0
91: */
92: public JobStepImpl(JobStep jobStep) throws KapuaException {
93: super(jobStep);
94:
95: setJobId(jobStep.getJobId());
96: setJobStepDefinitionId(jobStep.getJobStepDefinitionId());
97: setStepIndex(jobStep.getStepIndex());
98: setStepProperties(jobStep.getStepProperties());
99: }
100:
101: @Override
102: public KapuaId getJobId() {
103: return jobId;
104: }
105:
106: @Override
107: public void setJobId(KapuaId jobId) {
108: this.jobId = KapuaEid.parseKapuaId(jobId);
109: }
110:
111: @Override
112: public KapuaId getJobStepDefinitionId() {
113: return jobStepDefinitionId;
114: }
115:
116: @Override
117: public void setJobStepDefinitionId(KapuaId jobStepDefinitionId) {
118: this.jobStepDefinitionId = KapuaEid.parseKapuaId(jobStepDefinitionId);
119: }
120:
121: @Override
122: public int getStepIndex() {
123: return stepIndex;
124: }
125:
126: @Override
127: public void setStepIndex(int stepIndex) {
128: this.stepIndex = stepIndex;
129: }
130:
131: @Override
132: public List<JobStepPropertyImpl> getStepProperties() {
133:• if (stepProperties == null) {
134: stepProperties = new ArrayList<>();
135: }
136:
137: return stepProperties;
138: }
139:
140: @Override
141: public void setStepProperties(List<JobStepProperty> jobStepProperties) {
142:
143: this.stepProperties = new ArrayList<>();
144:
145:• for (JobStepProperty sp : jobStepProperties) {
146: this.stepProperties.add(JobStepPropertyImpl.parse(sp));
147: }
148: }
149: }