*/
private static final long serialVersionUID = -661307666798018192L;
- private String requestId;
- private String clientRequestId;
- private String action;
- private String requestStatus;
- private String statusMessage;
+ private String requestId = null;
+ private String clientRequestId = null;
+ private String action = null;
+ private String requestStatus = null;
+ private String statusMessage = null;
private Long progress;
- private Timestamp startTime;
- private Timestamp endTime;
- private String source;
- private String vnfId;
- private String vnfName;
- private String vnfType;
- private String serviceType;
- private String aicNodeClli;
- private String tenantId;
- private String provStatus;
- private String vnfParams;
- private String vnfOutputs;
- private String requestBody;
- private String responseBody;
- private String lastModifiedBy;
- private Timestamp modifyTime;
- private String requestType;
- private String volumeGroupId;
- private String volumeGroupName;
- private String vfModuleId;
- private String vfModuleName;
- private String vfModuleModelName;
- private String aaiServiceId;
- private String aicCloudRegion;
- private String callBackUrl;
- private String correlator;
- private String serviceInstanceId;
- private String serviceInstanceName;
- private String requestScope;
- private String requestAction;
- private String networkId;
- private String networkName;
- private String networkType;
- private String requestorId;
- private String configurationId;
- private String configurationName;
- private String operationalEnvId;
- private String operationalEnvName;
+ private Timestamp startTime = null;
+ private Timestamp endTime = null;
+ private String source = null;
+ private String vnfId = null;
+ private String vnfName = null;
+ private String vnfType = null;
+ private String serviceType = null;
+ private String aicNodeClli = null;
+ private String tenantId = null;
+ private String provStatus = null;
+ private String vnfParams = null;
+ private String vnfOutputs = null;
+ private String requestBody = null;
+ private String responseBody = null;
+ private String lastModifiedBy = null;
+ private Timestamp modifyTime = null;
+ private String requestType = null;
+ private String volumeGroupId = null;
+ private String volumeGroupName = null;
+ private String vfModuleId = null;
+ private String vfModuleName = null;
+ private String vfModuleModelName = null;
+ private String aaiServiceId = null;
+ private String aicCloudRegion = null;
+ private String callBackUrl = null;
+ private String correlator = null;
+ private String serviceInstanceId = null;
+ private String serviceInstanceName = null;
+ private String requestScope = null;
+ private String requestAction = null;
+ private String networkId = null;
+ private String networkName = null;
+ private String networkType = null;
+ private String requestorId = null;
+ private String configurationId = null;
+ private String configurationName = null;
+ private String operationalEnvId = null;
+ private String operationalEnvName = null;
public InfraRequests() {
}
-/*-\r
- * ============LICENSE_START=======================================================\r
- * ONAP - SO\r
- * ================================================================================\r
- * Copyright (C) 2017 Huawei Technologies Co., Ltd. All rights reserved.\r
- * ================================================================================\r
- * Licensed under the Apache License, Version 2.0 (the "License");\r
- * you may not use this file except in compliance with the License.\r
- * You may obtain a copy of the License at\r
- * \r
- * http://www.apache.org/licenses/LICENSE-2.0\r
- * \r
- * Unless required by applicable law or agreed to in writing, software\r
- * distributed under the License is distributed on an "AS IS" BASIS,\r
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
- * See the License for the specific language governing permissions and\r
- * limitations under the License.\r
- * ============LICENSE_END=========================================================\r
- */\r
-package org.openecomp.mso.requestsdb;\r
-\r
-import java.io.Serializable;\r
-import java.sql.Timestamp;\r
-\r
-/**\r
- * The service operation status \r
- * <br>\r
- * <p>\r
- * </p>\r
- * \r
- * @author\r
- * @version ONAP Amsterdam Release 2017-08-28\r
- */\r
-public class OperationStatus implements Serializable{\r
- \r
- /**\r
- * \r
- */\r
- private static final long serialVersionUID = 1L;\r
-\r
- private String serviceId;\r
- \r
- private String operationId;\r
- \r
- private String serviceName;\r
- \r
- private String operation;\r
- \r
- private String userId;\r
- \r
- private String result;\r
- \r
- private String operationContent;\r
- \r
- private String progress = "0";\r
- \r
- private String reason;\r
-\r
- private Timestamp operateAt;\r
- \r
- private Timestamp finishedAt;\r
-\r
- \r
- public String getServiceId() {\r
- return serviceId;\r
- }\r
-\r
- \r
- public void setServiceId(String serviceId) {\r
- this.serviceId = serviceId;\r
- }\r
-\r
- \r
- public String getOperationId() {\r
- return operationId;\r
- }\r
-\r
- \r
- public void setOperationId(String operationId) {\r
- this.operationId = operationId;\r
- }\r
-\r
- \r
- public String getOperation() {\r
- return operation;\r
- }\r
-\r
- \r
- public void setOperation(String operation) {\r
- this.operation = operation;\r
- }\r
-\r
- \r
- public String getUserId() {\r
- return userId;\r
- }\r
-\r
- \r
- public void setUserId(String userId) {\r
- this.userId = userId;\r
- }\r
-\r
- \r
- public String getResult() {\r
- return result;\r
- }\r
-\r
- \r
- public void setResult(String result) {\r
- this.result = result;\r
- }\r
-\r
- \r
- public String getOperationContent() {\r
- return operationContent;\r
- }\r
-\r
- \r
- public void setOperationContent(String operationContent) {\r
- this.operationContent = operationContent;\r
- }\r
-\r
- \r
- public String getProgress() {\r
- return progress;\r
- }\r
-\r
- \r
- public void setProgress(String progress) {\r
- this.progress = progress;\r
- }\r
-\r
- \r
- public String getReason() {\r
- return reason;\r
- }\r
-\r
- \r
- public void setReason(String reason) {\r
- this.reason = reason;\r
- }\r
-\r
- \r
- public Timestamp getOperateAt() {\r
- return operateAt;\r
- }\r
-\r
- \r
- public void setOperateAt(Timestamp operateAt) {\r
- this.operateAt = operateAt;\r
- }\r
-\r
- \r
- public Timestamp getFinishedAt() {\r
- return finishedAt;\r
- }\r
-\r
- \r
- public void setFinishedAt(Timestamp finishedAt) {\r
- this.finishedAt = finishedAt;\r
- }\r
-\r
-\r
- \r
- /**\r
- * @return Returns the serviceName.\r
- */\r
- public String getServiceName() {\r
- return serviceName;\r
- }\r
-\r
-\r
- \r
- /**\r
- * @param serviceName The serviceName to set.\r
- */\r
- public void setServiceName(String serviceName) {\r
- this.serviceName = serviceName;\r
- }\r
-\r
-\r
- /**\r
- * <br>\r
- * \r
- * @return\r
- * @since ONAP Amsterdam Release \r
- */\r
- @Override\r
- public int hashCode() {\r
- final int prime = 31;\r
- int result = 1;\r
- result = prime * result + ((operationId == null) ? 0 : operationId.hashCode());\r
- result = prime * result + ((serviceId == null) ? 0 : serviceId.hashCode());\r
- return result;\r
- }\r
-\r
-\r
- /**\r
- * <br>\r
- * \r
- * @param obj\r
- * @return\r
- * @since ONAP Amsterdam Release \r
- */\r
- @Override\r
- public boolean equals(Object obj) {\r
- if(this == obj)\r
- return true;\r
- if(obj == null)\r
- return false;\r
- if(getClass() != obj.getClass())\r
- return false;\r
- OperationStatus other = (OperationStatus)obj;\r
- if(operationId == null) {\r
- if(other.operationId != null)\r
- return false;\r
- } else if(!operationId.equals(other.operationId))\r
- return false;\r
- if(serviceId == null) {\r
- if(other.serviceId != null)\r
- return false;\r
- } else if(!serviceId.equals(other.serviceId))\r
- return false;\r
- return true;\r
- }\r
-\r
-\r
-}\r
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ * Copyright (C) 2017 Huawei Technologies Co., Ltd. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+package org.openecomp.mso.requestsdb;
+
+import java.io.Serializable;
+import java.sql.Timestamp;
+
+/**
+ * The service operation status
+ * <br>
+ * <p>
+ * </p>
+ *
+ * @author
+ * @version ONAP Amsterdam Release 2017-08-28
+ */
+public class OperationStatus implements Serializable{
+
+ /**
+ *
+ */
+ private static final long serialVersionUID = 1L;
+
+ private String serviceId = null;
+
+ private String operationId = null;
+
+ private String serviceName = null;
+
+ private String operation = null;
+
+ private String userId = null;
+
+ private String result = null;
+
+ private String operationContent = null;
+
+ private String progress = "0";
+
+ private String reason = null;
+
+ private Timestamp operateAt = null;
+
+ private Timestamp finishedAt = null;
+
+
+ public String getServiceId() {
+ return serviceId;
+ }
+
+
+ public void setServiceId(String serviceId) {
+ this.serviceId = serviceId;
+ }
+
+
+ public String getOperationId() {
+ return operationId;
+ }
+
+
+ public void setOperationId(String operationId) {
+ this.operationId = operationId;
+ }
+
+
+ public String getOperation() {
+ return operation;
+ }
+
+
+ public void setOperation(String operation) {
+ this.operation = operation;
+ }
+
+
+ public String getUserId() {
+ return userId;
+ }
+
+
+ public void setUserId(String userId) {
+ this.userId = userId;
+ }
+
+
+ public String getResult() {
+ return result;
+ }
+
+
+ public void setResult(String result) {
+ this.result = result;
+ }
+
+
+ public String getOperationContent() {
+ return operationContent;
+ }
+
+
+ public void setOperationContent(String operationContent) {
+ this.operationContent = operationContent;
+ }
+
+
+ public String getProgress() {
+ return progress;
+ }
+
+
+ public void setProgress(String progress) {
+ this.progress = progress;
+ }
+
+
+ public String getReason() {
+ return reason;
+ }
+
+
+ public void setReason(String reason) {
+ this.reason = reason;
+ }
+
+
+ public Timestamp getOperateAt() {
+ return operateAt;
+ }
+
+
+ public void setOperateAt(Timestamp operateAt) {
+ this.operateAt = operateAt;
+ }
+
+
+ public Timestamp getFinishedAt() {
+ return finishedAt;
+ }
+
+
+ public void setFinishedAt(Timestamp finishedAt) {
+ this.finishedAt = finishedAt;
+ }
+
+
+
+ /**
+ * @return Returns the serviceName.
+ */
+ public String getServiceName() {
+ return serviceName;
+ }
+
+
+
+ /**
+ * @param serviceName The serviceName to set.
+ */
+ public void setServiceName(String serviceName) {
+ this.serviceName = serviceName;
+ }
+
+
+ /**
+ * <br>
+ *
+ * @return
+ * @since ONAP Amsterdam Release
+ */
+ @Override
+ public int hashCode() {
+ final int prime = 31;
+ int result = 1;
+ result = prime * result + ((operationId == null) ? 0 : operationId.hashCode());
+ result = prime * result + ((serviceId == null) ? 0 : serviceId.hashCode());
+ return result;
+ }
+
+
+ /**
+ * <br>
+ *
+ * @param obj
+ * @return
+ * @since ONAP Amsterdam Release
+ */
+ @Override
+ public boolean equals(Object obj) {
+ if(this == obj)
+ return true;
+ if(obj == null)
+ return false;
+ if(getClass() != obj.getClass())
+ return false;
+ OperationStatus other = (OperationStatus)obj;
+ if(operationId == null) {
+ if(other.operationId != null)
+ return false;
+ } else if(!operationId.equals(other.operationId))
+ return false;
+ if(serviceId == null) {
+ if(other.serviceId != null)
+ return false;
+ } else if(!serviceId.equals(other.serviceId))
+ return false;
+ return true;
+ }
+
+
+}
*/
private static final long serialVersionUID = 7398393659281364650L;
- private String distributionId;
- private String operationalEnvId;
- private String serviceModelVersionId;
- private String requestId;
- private String distributionIdStatus;
- private String distributionIdErrorReason;
- private Timestamp createTime;
- private Timestamp modifyTime;
+ private String distributionId = null;
+ private String operationalEnvId = null;
+ private String serviceModelVersionId = null;
+ private String requestId = null;
+ private String distributionIdStatus = null;
+ private String distributionIdErrorReason = null;
+ private Timestamp createTime = null;
+ private Timestamp modifyTime = null;
public String getDistributionId() {
return distributionId;
*/
private static final long serialVersionUID = 8197084996598869656L;
- private String requestId;
- private String operationalEnvId;
- private String serviceModelVersionId;
- private String serviceModelVersionDistrStatus;
- private String recoveryAction;
+ private String requestId = null;
+ private String operationalEnvId = null;
+ private String serviceModelVersionId = null;
+ private String serviceModelVersionDistrStatus = null;
+ private String recoveryAction = null;
private int retryCount;
- private String workloadContext;
- private Timestamp createTime;
- private Timestamp modifyTime;
+ private String workloadContext = null;
+ private Timestamp createTime = null;
+ private Timestamp modifyTime = null;
public String getRequestId() {
return requestId;
-/*-\r
- * ============LICENSE_START=======================================================\r
- * ONAP - SO\r
- * ================================================================================\r
- * Copyright (C) 2017 Huawei Technologies Co., Ltd. All rights reserved.\r
- * ================================================================================\r
- * Licensed under the Apache License, Version 2.0 (the "License");\r
- * you may not use this file except in compliance with the License.\r
- * You may obtain a copy of the License at\r
- * \r
- * http://www.apache.org/licenses/LICENSE-2.0\r
- * \r
- * Unless required by applicable law or agreed to in writing, software\r
- * distributed under the License is distributed on an "AS IS" BASIS,\r
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
- * See the License for the specific language governing permissions and\r
- * limitations under the License.\r
- * ============LICENSE_END=========================================================\r
- */\r
-package org.openecomp.mso.requestsdb;\r
-\r
-import java.io.Serializable;\r
-\r
-/**\r
- * The Resource operation status\r
- * <br>\r
- * <p>\r
- * </p>\r
- * \r
- * @author\r
- * @version ONAP Amsterdam Release 2017-08-28\r
- */\r
-public class ResourceOperationStatus implements Serializable{\r
-\r
- /**\r
- * \r
- */\r
- private static final long serialVersionUID = 1L;\r
-\r
- private String serviceId;\r
- \r
- private String operationId;\r
- \r
- private String resourceTemplateUUID;\r
- \r
- private String operType;\r
- \r
- private String resourceInstanceID;\r
- \r
- private String jobId;\r
- \r
- private String status;\r
- \r
- private String progress = "0";\r
- \r
- private String errorCode;\r
- \r
- private String statusDescription;\r
-\r
- public ResourceOperationStatus(){\r
- \r
- }\r
- \r
- public ResourceOperationStatus(String serviceId, String operationId, String resourceTemplateUUID)\r
- {\r
- this.serviceId = serviceId;\r
- this.operationId = operationId;\r
- this.resourceTemplateUUID = resourceTemplateUUID;\r
- }\r
- \r
- public String getServiceId() {\r
- return serviceId;\r
- }\r
-\r
- \r
- public void setServiceId(String serviceId) {\r
- this.serviceId = serviceId;\r
- }\r
-\r
- \r
- public String getOperationId() {\r
- return operationId;\r
- }\r
-\r
- \r
- public void setOperationId(String operationId) {\r
- this.operationId = operationId;\r
- }\r
-\r
- \r
- public String getResourceTemplateUUID() {\r
- return resourceTemplateUUID;\r
- }\r
-\r
- \r
- public void setResourceTemplateUUID(String resourceTemplateUUId) {\r
- this.resourceTemplateUUID = resourceTemplateUUId;\r
- }\r
-\r
- \r
- public String getJobId() {\r
- return jobId;\r
- }\r
-\r
- \r
- public void setJobId(String jobId) {\r
- this.jobId = jobId;\r
- }\r
-\r
- \r
- public String getStatus() {\r
- return status;\r
- }\r
-\r
- \r
- public void setStatus(String status) {\r
- this.status = status;\r
- }\r
-\r
- \r
- public String getProgress() {\r
- return progress;\r
- }\r
-\r
- \r
- public void setProgress(String progress) {\r
- this.progress = progress;\r
- }\r
-\r
- \r
- public String getErrorCode() {\r
- return errorCode;\r
- }\r
-\r
- \r
- public void setErrorCode(String errorCode) {\r
- this.errorCode = errorCode;\r
- }\r
-\r
- \r
- public String getStatusDescription() {\r
- return statusDescription;\r
- }\r
-\r
- \r
- public void setStatusDescription(String statusDescription) {\r
- this.statusDescription = statusDescription;\r
- }\r
-\r
-\r
- \r
- public String getResourceInstanceID() {\r
- return resourceInstanceID;\r
- }\r
-\r
-\r
- \r
- public void setResourceInstanceID(String resourceInstanceID) {\r
- this.resourceInstanceID = resourceInstanceID;\r
- }\r
-\r
- \r
- public String getOperType() {\r
- return operType;\r
- }\r
-\r
- \r
- public void setOperType(String operType) {\r
- this.operType = operType;\r
- }\r
-\r
- /**\r
- * <br>\r
- * \r
- * @return\r
- * @since ONAP Amsterdam Release \r
- */\r
- @Override\r
- public int hashCode() {\r
- final int prime = 31;\r
- int result = 1;\r
- result = prime * result + ((operationId == null) ? 0 : operationId.hashCode());\r
- result = prime * result + ((resourceTemplateUUID == null) ? 0 : resourceTemplateUUID.hashCode());\r
- result = prime * result + ((serviceId == null) ? 0 : serviceId.hashCode());\r
- return result;\r
- }\r
-\r
- /**\r
- * <br>\r
- * \r
- * @param obj\r
- * @return\r
- * @since ONAP Amsterdam Release \r
- */\r
- @Override\r
- public boolean equals(Object obj) {\r
- if(this == obj)\r
- return true;\r
- if(obj == null)\r
- return false;\r
- if(getClass() != obj.getClass())\r
- return false;\r
- ResourceOperationStatus other = (ResourceOperationStatus)obj;\r
- if(operationId == null) {\r
- if(other.operationId != null)\r
- return false;\r
- } else if(!operationId.equals(other.operationId))\r
- return false;\r
- if(resourceTemplateUUID == null) {\r
- if(other.resourceTemplateUUID != null)\r
- return false;\r
- } else if(!resourceTemplateUUID.equals(other.resourceTemplateUUID))\r
- return false;\r
- if(serviceId == null) {\r
- if(other.serviceId != null)\r
- return false;\r
- } else if(!serviceId.equals(other.serviceId))\r
- return false;\r
- return true;\r
- } \r
- \r
-}\r
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ * Copyright (C) 2017 Huawei Technologies Co., Ltd. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+package org.openecomp.mso.requestsdb;
+
+import java.io.Serializable;
+
+/**
+ * The Resource operation status
+ * <br>
+ * <p>
+ * </p>
+ *
+ * @author
+ * @version ONAP Amsterdam Release 2017-08-28
+ */
+public class ResourceOperationStatus implements Serializable{
+
+ /**
+ *
+ */
+ private static final long serialVersionUID = 1L;
+
+ private String serviceId = null;
+
+ private String operationId = null;
+
+ private String resourceTemplateUUID = null;
+
+ private String operType = null;
+
+ private String resourceInstanceID = null;
+
+ private String jobId = null;
+
+ private String status = null;
+
+ private String progress = "0";
+
+ private String errorCode = null;
+
+ private String statusDescription = null;
+
+ public ResourceOperationStatus(){
+
+ }
+
+ public ResourceOperationStatus(String serviceId, String operationId, String resourceTemplateUUID)
+ {
+ this.serviceId = serviceId;
+ this.operationId = operationId;
+ this.resourceTemplateUUID = resourceTemplateUUID;
+ }
+
+ public String getServiceId() {
+ return serviceId;
+ }
+
+
+ public void setServiceId(String serviceId) {
+ this.serviceId = serviceId;
+ }
+
+
+ public String getOperationId() {
+ return operationId;
+ }
+
+
+ public void setOperationId(String operationId) {
+ this.operationId = operationId;
+ }
+
+
+ public String getResourceTemplateUUID() {
+ return resourceTemplateUUID;
+ }
+
+
+ public void setResourceTemplateUUID(String resourceTemplateUUId) {
+ this.resourceTemplateUUID = resourceTemplateUUId;
+ }
+
+
+ public String getJobId() {
+ return jobId;
+ }
+
+
+ public void setJobId(String jobId) {
+ this.jobId = jobId;
+ }
+
+
+ public String getStatus() {
+ return status;
+ }
+
+
+ public void setStatus(String status) {
+ this.status = status;
+ }
+
+
+ public String getProgress() {
+ return progress;
+ }
+
+
+ public void setProgress(String progress) {
+ this.progress = progress;
+ }
+
+
+ public String getErrorCode() {
+ return errorCode;
+ }
+
+
+ public void setErrorCode(String errorCode) {
+ this.errorCode = errorCode;
+ }
+
+
+ public String getStatusDescription() {
+ return statusDescription;
+ }
+
+
+ public void setStatusDescription(String statusDescription) {
+ this.statusDescription = statusDescription;
+ }
+
+
+
+ public String getResourceInstanceID() {
+ return resourceInstanceID;
+ }
+
+
+
+ public void setResourceInstanceID(String resourceInstanceID) {
+ this.resourceInstanceID = resourceInstanceID;
+ }
+
+
+ public String getOperType() {
+ return operType;
+ }
+
+
+ public void setOperType(String operType) {
+ this.operType = operType;
+ }
+
+ /**
+ * <br>
+ *
+ * @return
+ * @since ONAP Amsterdam Release
+ */
+ @Override
+ public int hashCode() {
+ final int prime = 31;
+ int result = 1;
+ result = prime * result + ((operationId == null) ? 0 : operationId.hashCode());
+ result = prime * result + ((resourceTemplateUUID == null) ? 0 : resourceTemplateUUID.hashCode());
+ result = prime * result + ((serviceId == null) ? 0 : serviceId.hashCode());
+ return result;
+ }
+
+ /**
+ * <br>
+ *
+ * @param obj
+ * @return
+ * @since ONAP Amsterdam Release
+ */
+ @Override
+ public boolean equals(Object obj) {
+ if(this == obj)
+ return true;
+ if(obj == null)
+ return false;
+ if(getClass() != obj.getClass())
+ return false;
+ ResourceOperationStatus other = (ResourceOperationStatus)obj;
+ if(operationId == null) {
+ if(other.operationId != null)
+ return false;
+ } else if(!operationId.equals(other.operationId))
+ return false;
+ if(resourceTemplateUUID == null) {
+ if(other.resourceTemplateUUID != null)
+ return false;
+ } else if(!resourceTemplateUUID.equals(other.resourceTemplateUUID))
+ return false;
+ if(serviceId == null) {
+ if(other.serviceId != null)
+ return false;
+ } else if(!serviceId.equals(other.serviceId))
+ return false;
+ return true;
+ }
+
+}
private static final MsoLogger LOGGER = MsoLogger.getMsoLogger(MsoLogger.Catalog.GENERAL);
private boolean status;
- private String siteName;
- private Timestamp created;
+ private String siteName = null;
+ private Timestamp created = null;
public SiteStatus() {
}
*/
private static final long serialVersionUID = -4344508954204488669L;
- private String distributionId;
- private String componentName;
- private String componentDistributionStatus;
- private Timestamp createTime;
- private Timestamp modifyTime;
+ private String distributionId = null;
+ private String componentName = null;
+ private String componentDistributionStatus = null;
+ private Timestamp createTime = null;
+ private Timestamp modifyTime = null;
public String getDistributionId() {
private static final long serialVersionUID = -4449711060885719079L;
- private String distributionId;
- private String distributionIdStatus;
- private Timestamp createTime;
- private Timestamp modifyTime;
+ private String distributionId = null;
+ private String distributionIdStatus = null;
+ private Timestamp createTime = null;
+ private Timestamp modifyTime = null;
public String getDistributionId() {
*/
private static final long serialVersionUID = 7783869906430250355L;
- private String distributionId;
- private String serviceModelVersionId;
- private Timestamp createTime;
+ private String distributionId = null;
+ private String serviceModelVersionId = null;
+ private Timestamp createTime = null;
public String getDistributionId() {
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+import java.util.Arrays;
+
+import org.hibernate.Query;
+import org.hibernate.Session;
+import org.hibernate.SessionFactory;
+import org.junit.Before;
+import org.junit.Rule;
import org.junit.Test;
+import org.junit.rules.ExpectedException;
+import org.mockito.Mock;
import org.mockito.Mockito;
+import org.mockito.MockitoAnnotations;
+import org.openecomp.mso.db.AbstractSessionFactoryManager;
public class OperationalEnvDistributionStatusDbTest {
+ @Mock
+ private AbstractSessionFactoryManager sessionFactoryRequest;
+ @Mock
+ private SessionFactory sessionFactory;
+ @Mock
+ private Session session;
+
+ @Rule
+ public ExpectedException thrown = ExpectedException.none();
+
+ @Before
+ public void setUp() {
+ MockitoAnnotations.initMocks(this);
+ when(sessionFactory.openSession()).thenReturn(session);
+ when(sessionFactoryRequest.getSessionFactory()).thenReturn(sessionFactory);
+
+ }
-
- private static final String distributionId = "ff3514e3-5a33-55df-13ab-12abad84e7ff";
- private static final String operationalEnvId = "12abad84e7ff";
- private static final String serviceModelVersionId = "ff305d54-75b4-431b-adb2-eb6b9e5ff001";
- private static final String requestId = "431b-adb2-eb6b9e5ff001";
- private static final String status = "SENT";
- private OperationalEnvDistributionStatus operEnvDistStatus;
-
-
@Test
- public void testGetOperationalEnvDistributionStatus() {
-
- OperationalEnvDistributionStatusDb oeds = Mockito.mock(OperationalEnvDistributionStatusDb.class);
- Mockito.when(oeds.getOperationalEnvDistributionStatus("ff3514e3-5a33-55df-13ab-12abad84e7ff")).thenReturn(operEnvDistStatus);
- OperationalEnvDistributionStatus actual = oeds.getOperationalEnvDistributionStatus(distributionId);
- assertEquals(actual, operEnvDistStatus);
- verify(oeds, times(1)).getOperationalEnvDistributionStatus(any(String.class));
+ public void insertFailure() {
+ OperationalEnvDistributionStatusDb omsDB = new OperationalEnvDistributionStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.uniqueResult()).thenReturn(null);
+ when(session.isOpen()).thenReturn(true);
+ when(session.getTransaction()).thenThrow(Exception.class);
+ thrown.expect(Exception.class);
+
+ omsDB.insertOperationalEnvDistributionStatus("myDistId", "myEnvId", "myModelVerId", "myDistIdStatus", "myReqId");
}
@Test
- public void testGetOperationalEnvDistributionStatusPerReqId() {
-
- OperationalEnvDistributionStatusDb oeds = Mockito.mock(OperationalEnvDistributionStatusDb.class);
- Mockito.when(oeds.getOperationalEnvDistributionStatusPerReqId("ff3514e3-5a33-55df-13ab-12abad84e7ff", "431b-adb2-eb6b9e5ff001")).thenReturn(operEnvDistStatus);
- OperationalEnvDistributionStatus actual = oeds.getOperationalEnvDistributionStatusPerReqId(distributionId, requestId);
- assertEquals(actual, operEnvDistStatus);
- verify(oeds, times(1)).getOperationalEnvDistributionStatusPerReqId(any(String.class), any(String.class));
+ public void updateFailureRetryCount() {
+ OperationalEnvDistributionStatusDb omsDB = new OperationalEnvDistributionStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(session.isOpen()).thenReturn(true);
+ when(session.getTransaction()).thenThrow(Exception.class);
+ thrown.expect(Exception.class);
+
+ omsDB.updateOperationalEnvDistributionStatus("asdcStatus", "myDistId", "myEnvId", "myVerId");
}
-
+
@Test
- public void testUpdateOperationalEnvDistributionStatus() {
-
- int val = 1;
- OperationalEnvDistributionStatusDb oeds = Mockito.mock(OperationalEnvDistributionStatusDb.class);
- Mockito.when(oeds.updateOperationalEnvDistributionStatus("OK", "ff3514e3-5a33", "ff3514e3-5a33", "ff3514e3-5a33-55df-13ab-12abad84e7ff")).thenReturn(val);
- int actual = oeds.updateOperationalEnvDistributionStatus("OK", "ff3514e3-5a33", "ff3514e3-5a33", "ff3514e3-5a33-55df-13ab-12abad84e7ff");
- assertEquals(actual, val);
- verify(oeds, times(1)).updateOperationalEnvDistributionStatus(any(String.class), any(String.class), any(String.class), any(String.class));
+ public void getOperationalEnvIdStatusTest() {
+ OperationalEnvDistributionStatusDb omsDB = new OperationalEnvDistributionStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ OperationalEnvDistributionStatus status = new OperationalEnvDistributionStatus();
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.uniqueResult()).thenReturn(status);
+ when(session.isOpen()).thenReturn(true);
+ assertEquals(status, omsDB.getOperationalEnvDistributionStatusPerReqId("myDistId", "myReqId"));
}
@Test
- public void testInsertOperationalEnvDistributionStatus() {
-
- OperationalEnvDistributionStatusDb oeds = mock(OperationalEnvDistributionStatusDb.class);
-
- oeds.insertOperationalEnvDistributionStatus(distributionId, operationalEnvId, serviceModelVersionId, status, requestId);
- doNothing().when(oeds).insertOperationalEnvDistributionStatus(any(String.class), any(String.class), any(String.class), any(String.class), any(String.class));
- verify(oeds, times(1)).insertOperationalEnvDistributionStatus(any(String.class), any(String.class), any(String.class), any(String.class), any(String.class));
-
+ public void getOperationalEnvServiceModelStatusTest() {
+ OperationalEnvDistributionStatusDb omsDB = new OperationalEnvDistributionStatusDb(this.sessionFactoryRequest);
+ OperationalEnvDistributionStatus status = new OperationalEnvDistributionStatus();
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.uniqueResult()).thenReturn(status);
+ when(session.isOpen()).thenReturn(true);
+ assertEquals(status, omsDB.getOperationalEnvDistributionStatus("myDistId"));
}
-
}
\ No newline at end of file
import static org.junit.Assert.assertEquals;
import static org.mockito.Matchers.any;
-import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.times;
-import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
-import java.util.ArrayList;
-import java.util.List;
+import java.util.Arrays;
+import org.hibernate.Query;
+import org.hibernate.Session;
+import org.hibernate.SessionFactory;
+import org.junit.Before;
+import org.junit.Rule;
import org.junit.Test;
-import org.mockito.Mockito;
+import org.junit.rules.ExpectedException;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
+import org.openecomp.mso.db.AbstractSessionFactoryManager;
public class OperationalEnvServiceModelStatusDbTest {
-
- private static final String operationalEnvId = "12abad84e7ff";
- private static final String serviceModelVersionId = "ff305d54-75b4-431b-adb2-eb6b9e5ff001";
- private static final String requestId = "431b-adb2-eb6b9e5ff001";
- private static final String status = "SENT";
- private static final int retryCount = 1;
- private static final String recoveryAction = "Retry";
- private static final String workloadContext = "VNF_D2D";
-
- private OperationalEnvServiceModelStatus operEnvDistStatus;
+ @Mock
+ private AbstractSessionFactoryManager sessionFactoryRequest;
+ @Mock
+ private SessionFactory sessionFactory;
+ @Mock
+ private Session session;
-
- @Test
- public void testGetOperationalEnvDistributionStatus() {
-
- OperationalEnvServiceModelStatusDb oesms = Mockito.mock(OperationalEnvServiceModelStatusDb.class);
- Mockito.when(oesms.getOperationalEnvServiceModelStatus("12abad84e7ff", "ff305d54-75b4-431b-adb2-eb6b9e5ff001")).thenReturn(operEnvDistStatus);
- OperationalEnvServiceModelStatus actual = oesms.getOperationalEnvServiceModelStatus(operationalEnvId, serviceModelVersionId);
- assertEquals(actual, operEnvDistStatus);
- verify(oesms, times(1)).getOperationalEnvServiceModelStatus(any(String.class), any(String.class));
- }
-
- @Test
- public void testGetOperationalEnvIdStatus() {
-
- List<OperationalEnvServiceModelStatus> operEnvSvcModelStatus = new ArrayList<>();
- OperationalEnvServiceModelStatusDb oesms = Mockito.mock(OperationalEnvServiceModelStatusDb.class);
- Mockito.when(oesms.getOperationalEnvIdStatus("12abad84e7ff", "ff305d54-75b4-431b-adb2-eb6b9e5ff001")).thenReturn(operEnvSvcModelStatus);
- List<OperationalEnvServiceModelStatus> actual = oesms.getOperationalEnvIdStatus(operationalEnvId, requestId);
- assertEquals(actual, operEnvSvcModelStatus);
- verify(oesms, times(1)).getOperationalEnvIdStatus(any(String.class), any(String.class));
-
- }
-
- @Test
- public void testUpdateOperationalEnvRetryCountStatus() {
-
- int val = 1;
- OperationalEnvServiceModelStatusDb oesms = Mockito.mock(OperationalEnvServiceModelStatusDb.class);
- Mockito.when(oesms.updateOperationalEnvRetryCountStatus("12abad84e7ff", "ff305d54-75b4-431b-adb2-eb6b9e5ff001", "SENT", 1)).thenReturn(val);
- int actual = oesms.updateOperationalEnvRetryCountStatus(operationalEnvId, serviceModelVersionId, status, retryCount);
- assertEquals(actual, val);
- verify(oesms, times(1)).updateOperationalEnvRetryCountStatus(any(String.class), any(String.class), any(String.class), any(int.class));
- }
+ @Rule
+ public ExpectedException thrown = ExpectedException.none();
- @Test
- public void testUpdateOperationalEnvRetryCountStatusPerReqId() {
-
- int val = 1;
- OperationalEnvServiceModelStatusDb oesms = Mockito.mock(OperationalEnvServiceModelStatusDb.class);
- Mockito.when(oesms.updateOperationalEnvRetryCountStatusPerReqId("12abad84e7ff", "ff305d54-75b4-431b-adb2-eb6b9e5ff001", "SENT", 1, "431b-adb2-eb6b9e5ff001")).thenReturn(val);
- int actual = oesms.updateOperationalEnvRetryCountStatusPerReqId(operationalEnvId, serviceModelVersionId, status, retryCount, requestId);
- assertEquals(actual, val);
- verify(oesms, times(1)).updateOperationalEnvRetryCountStatusPerReqId(any(String.class), any(String.class), any(String.class),
- any(int.class), any(String.class));
- }
-
+ @Before
+ public void setUp() {
+ MockitoAnnotations.initMocks(this);
+ when(sessionFactory.openSession()).thenReturn(session);
+ when(sessionFactoryRequest.getSessionFactory()).thenReturn(sessionFactory);
- @Test
- public void testInsertOperationalEnvServiceModelStatus() {
-
- OperationalEnvServiceModelStatusDb oesms = mock(OperationalEnvServiceModelStatusDb.class);
-
- oesms.insertOperationalEnvServiceModelStatus(requestId, operationalEnvId, serviceModelVersionId, status, recoveryAction, retryCount, workloadContext);
- doNothing().when(oesms).insertOperationalEnvServiceModelStatus(any(String.class), any(String.class), any(String.class),
- any(String.class), any(String.class), any(int.class), any(String.class));
- verify(oesms, times(1)).insertOperationalEnvServiceModelStatus(any(String.class), any(String.class), any(String.class),
- any(String.class), any(String.class), any(int.class), any(String.class));
+ }
+
+ @Test
+ public void insertFailure() {
+ OperationalEnvServiceModelStatusDb omsDB = new OperationalEnvServiceModelStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.uniqueResult()).thenReturn(null);
+ when(session.isOpen()).thenReturn(true);
+ when(session.getTransaction()).thenThrow(Exception.class);
+ thrown.expect(Exception.class);
+
+ omsDB.insertOperationalEnvServiceModelStatus("myRequestId", "myOperationalEnvId", "myServiceModelVersionId", "myVal", "myRecoveryAction", 1, "myWorkloadContext");
+ }
+
+ @Test
+ public void updateFailureRetryCount() {
+ OperationalEnvServiceModelStatusDb omsDB = new OperationalEnvServiceModelStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(session.isOpen()).thenReturn(true);
+ when(session.getTransaction()).thenThrow(Exception.class);
+ thrown.expect(Exception.class);
- }
+ omsDB.updateOperationalEnvRetryCountStatus("myOperationalEnvId", "myServiceModelVersionId", "status", 1);
+ }
+
+ @Test
+ public void updateFailureRetryCountPerReqId() {
+ OperationalEnvServiceModelStatusDb omsDB = new OperationalEnvServiceModelStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(session.isOpen()).thenReturn(true);
+ when(session.getTransaction()).thenThrow(Exception.class);
+ thrown.expect(Exception.class);
+ omsDB.updateOperationalEnvRetryCountStatusPerReqId("myOperationalEnvId", "myServiceModelVersionId", "status", 1, "myReqId");
+ }
+
+
+ @Test
+ public void getOperationalEnvIdStatusTest() {
+ OperationalEnvServiceModelStatusDb omsDB = new OperationalEnvServiceModelStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ OperationalEnvServiceModelStatus status = new OperationalEnvServiceModelStatus();
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.list()).thenReturn(Arrays.asList(status));
+ when(session.isOpen()).thenReturn(true);
+ assertEquals(status, omsDB.getOperationalEnvIdStatus("myEnvId", "myReqId").get(0));
+ }
+
+ @Test
+ public void getOperationalEnvServiceModelStatusTest() {
+ OperationalEnvServiceModelStatusDb omsDB = new OperationalEnvServiceModelStatusDb(this.sessionFactoryRequest);
+ OperationalEnvServiceModelStatus status = new OperationalEnvServiceModelStatus();
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.uniqueResult()).thenReturn(status);
+ when(session.isOpen()).thenReturn(true);
+ assertEquals(status, omsDB.getOperationalEnvServiceModelStatus("myEnvId", "myModelId"));
+ }
}
package org.openecomp.mso.requestsdb;
-import org.junit.Test;
-import org.mockito.Mockito;
-
import static org.junit.Assert.assertEquals;
import static org.mockito.Matchers.any;
-import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.times;
-import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
-import java.util.ArrayList;
-import java.util.List;
+import java.util.Arrays;
+
+import org.hibernate.Query;
+import org.hibernate.Session;
+import org.hibernate.SessionFactory;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.rules.ExpectedException;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
+import org.openecomp.mso.db.AbstractSessionFactoryManager;
public class WatchdogComponentDistributionStatusDbTest {
- private static final String distributionId = "ff3514e3-5a33-55df-13ab-12abad84e7ff";
- private static final String componentName = "MSO";
- private static final String componentDistributionStatus = "SENT";
-
-
+ @Mock
+ private AbstractSessionFactoryManager sessionFactoryRequest;
+ @Mock
+ private SessionFactory sessionFactory;
+ @Mock
+ private Session session;
+
+ @Rule
+ public ExpectedException thrown = ExpectedException.none();
+
+ @Before
+ public void setUp() {
+ MockitoAnnotations.initMocks(this);
+ when(sessionFactory.openSession()).thenReturn(session);
+ when(sessionFactoryRequest.getSessionFactory()).thenReturn(sessionFactory);
+
+ }
+
@Test
- public void testGetWatchdogComponentDistributionStatus() {
- List<WatchdogComponentDistributionStatus> watchDogCompDistStatus = new ArrayList<>();
- WatchdogComponentDistributionStatusDb wdcds = Mockito.mock(WatchdogComponentDistributionStatusDb.class);
- Mockito.when(wdcds.getWatchdogComponentDistributionStatus("ff3514e3-5a33-55df-13ab-12abad84e7ff")).thenReturn(watchDogCompDistStatus);
- List<WatchdogComponentDistributionStatus> actual = wdcds.getWatchdogComponentDistributionStatus(distributionId);
-
- assertEquals(actual, watchDogCompDistStatus);
- verify(wdcds, times(1)).getWatchdogComponentDistributionStatus(any(String.class));
+ public void insertFailure() {
+ WatchdogComponentDistributionStatusDb wds = new WatchdogComponentDistributionStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.uniqueResult()).thenReturn(null);
+ when(session.isOpen()).thenReturn(true);
+ when(session.getTransaction()).thenThrow(Exception.class);
+ thrown.expect(Exception.class);
+
+ wds.insertWatchdogComponentDistributionStatus("myId", "myComponentName", "myStatus");
}
-
-
+
+
@Test
- public void testInsertWatchdogComponentDistributionStatus() {
-
- WatchdogComponentDistributionStatusDb wdcds = mock(WatchdogComponentDistributionStatusDb.class);
-
- wdcds.insertWatchdogComponentDistributionStatus(distributionId, componentName, componentDistributionStatus);
- doNothing().when(wdcds).insertWatchdogComponentDistributionStatus(any(String.class), any(String.class), any(String.class));
- verify(wdcds, times(1)).insertWatchdogComponentDistributionStatus(any(String.class), any(String.class), any(String.class));
-
+ public void getWatchdogComponentNamesTest() {
+ WatchdogComponentDistributionStatusDb wds = new WatchdogComponentDistributionStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.list()).thenReturn(Arrays.asList("myValue"));
+ when(session.isOpen()).thenReturn(true);
+ assertEquals("myValue", wds.getWatchdogComponentNames("myId").get(0));
+ }
+
+ @Test
+ public void getWatchdogComponentDistributionStatusTest() {
+ WatchdogComponentDistributionStatusDb wds = new WatchdogComponentDistributionStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.list()).thenReturn(Arrays.asList("myValue"));
+ when(session.isOpen()).thenReturn(true);
+ assertEquals("myValue", wds.getWatchdogComponentDistributionStatus("myStatus").get(0));
+ assertEquals("myValue", wds.getWatchdogComponentDistributionStatus("myId", "myName").get(0));
}
+ @Test
+ public void testGetWatchdogDistributionIdNotFound() {
+ WatchdogDistributionStatusDb wds = new WatchdogDistributionStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.uniqueResult()).thenReturn(null);
+ when(session.isOpen()).thenReturn(true);
+ assertEquals(null, wds.getWatchdogDistributionId("test"));
+ }
+
+ @Test
+ public void testGetWatchdogDistributionIdStatus() {
+ WatchdogDistributionStatusDb wds = new WatchdogDistributionStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.uniqueResult()).thenReturn("myValue");
+ when(session.isOpen()).thenReturn(true);
+ assertEquals("myValue", wds.getWatchdogDistributionIdStatus("test"));
+ }
+
+ @Test
+ public void testGetWatchdogDistributionIdStatusNotFound() {
+ WatchdogDistributionStatusDb wds = new WatchdogDistributionStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.uniqueResult()).thenReturn(null);
+ when(session.isOpen()).thenReturn(true);
+ assertEquals(null, wds.getWatchdogDistributionIdStatus("test"));
+ }
+
}
package org.openecomp.mso.requestsdb;
-import org.junit.Test;
-import org.mockito.Mockito;
-
import static org.junit.Assert.assertEquals;
import static org.mockito.Matchers.any;
-import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.times;
-import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import org.hibernate.Query;
+import org.hibernate.Session;
+import org.hibernate.SessionFactory;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.rules.ExpectedException;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
+import org.openecomp.mso.db.AbstractSessionFactoryManager;
public class WatchdogDistributionStatusDbTest {
- private static final String distributionId = "ff3514e3-5a33-55df-13ab-12abad84e7ff";
-
+ @Mock
+ private AbstractSessionFactoryManager sessionFactoryRequest;
+ @Mock
+ private SessionFactory sessionFactory;
+ @Mock
+ private Session session;
+
+ @Rule
+ public ExpectedException thrown = ExpectedException.none();
+
+ @Before
+ public void setUp() {
+ MockitoAnnotations.initMocks(this);
+ when(sessionFactory.openSession()).thenReturn(session);
+ when(sessionFactoryRequest.getSessionFactory()).thenReturn(sessionFactory);
+
+ }
+
@Test
- public void testUpdateWatchdogDistributionIdStatus() {
- WatchdogDistributionStatusDb wdds = Mockito.mock(WatchdogDistributionStatusDb.class);
+ public void insertFailure() {
+ WatchdogDistributionStatusDb wds = new WatchdogDistributionStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.uniqueResult()).thenReturn(null);
+ when(session.isOpen()).thenReturn(true);
+ when(session.getTransaction()).thenThrow(Exception.class);
+ thrown.expect(Exception.class);
- doNothing().when(wdds).updateWatchdogDistributionIdStatus("ff3514e3-5a33-55df-13ab-12abad84e7ff", "SENT");
- wdds.updateWatchdogDistributionIdStatus(any(String.class), any(String.class));
- verify(wdds, times(1)).updateWatchdogDistributionIdStatus(any(String.class), any(String.class));
- }
+ wds.insertWatchdogDistributionId("myId");
+ }
@Test
- public void testInsertWatchdogDistributionId() {
-
- WatchdogDistributionStatusDb wdds = mock(WatchdogDistributionStatusDb.class);
+ public void updateFailure() {
+ WatchdogDistributionStatusDb wds = new WatchdogDistributionStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(session.isOpen()).thenReturn(true);
+ when(session.getTransaction()).thenThrow(Exception.class);
+ thrown.expect(Exception.class);
- wdds.insertWatchdogDistributionId(distributionId);
- doNothing().when(wdds).insertWatchdogDistributionId(any(String.class));
- verify(wdds, times(1)).insertWatchdogDistributionId(any(String.class));
+ wds.updateWatchdogDistributionIdStatus("myId", "myStatus");
+ }
+ @Test
+ public void testGetWatchdogDistributionId() {
+ WatchdogDistributionStatusDb wds = new WatchdogDistributionStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.uniqueResult()).thenReturn("myValue");
+ when(session.isOpen()).thenReturn(true);
+ assertEquals("myValue", wds.getWatchdogDistributionId("test"));
}
-
+
+ @Test
+ public void testGetWatchdogDistributionIdNotFound() {
+ WatchdogDistributionStatusDb wds = new WatchdogDistributionStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.uniqueResult()).thenReturn(null);
+ when(session.isOpen()).thenReturn(true);
+ assertEquals(null, wds.getWatchdogDistributionId("test"));
+ }
+
@Test
public void testGetWatchdogDistributionIdStatus() {
-
- WatchdogDistributionStatusDb wdds = Mockito.mock(WatchdogDistributionStatusDb.class);
- Mockito.when(wdds.getWatchdogDistributionIdStatus("ff305d54-75b4-431b-adb2-eb6b9e5ff001")).thenReturn("ff3514e3-5a33-55df-13ab-12abad84e7ff");
- String actual = wdds.getWatchdogDistributionIdStatus("ff305d54-75b4-431b-adb2-eb6b9e5ff001");
- assertEquals(actual, distributionId);
- verify(wdds, times(1)).getWatchdogDistributionIdStatus(any(String.class));
+ WatchdogDistributionStatusDb wds = new WatchdogDistributionStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.uniqueResult()).thenReturn("myValue");
+ when(session.isOpen()).thenReturn(true);
+ assertEquals("myValue", wds.getWatchdogDistributionIdStatus("test"));
+ }
+
+ @Test
+ public void testGetWatchdogDistributionIdStatusNotFound() {
+ WatchdogDistributionStatusDb wds = new WatchdogDistributionStatusDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.uniqueResult()).thenReturn(null);
+ when(session.isOpen()).thenReturn(true);
+ assertEquals(null, wds.getWatchdogDistributionIdStatus("test"));
}
}
*/
package org.openecomp.mso.requestsdb;
-import org.junit.Test;
-import org.mockito.Mockito;
-
import static org.junit.Assert.assertEquals;
import static org.mockito.Matchers.any;
-import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.times;
-import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import org.hibernate.Query;
+import org.hibernate.Session;
+import org.hibernate.SessionFactory;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.rules.ExpectedException;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
+import org.openecomp.mso.db.AbstractSessionFactoryManager;
public class WatchdogServiceModVerIdLookupDbTest {
+ @Mock
+ private AbstractSessionFactoryManager sessionFactoryRequest;
+ @Mock
+ private SessionFactory sessionFactory;
+ @Mock
+ private Session session;
+
+ @Rule
+ public ExpectedException thrown = ExpectedException.none();
+
+ @Before
+ public void setUp() {
+ MockitoAnnotations.initMocks(this);
+ when(sessionFactory.openSession()).thenReturn(session);
+ when(sessionFactoryRequest.getSessionFactory()).thenReturn(sessionFactory);
- private static final String distributionId = "ff3514e3-5a33-55df-13ab-12abad84e7ff";
- private static final String serviceModelVersionId = "SENT";
+ }
@Test
- public void testInsertWatchdogServiceModVerIdLookup() {
-
- WatchdogServiceModVerIdLookupDb wdsm = mock(WatchdogServiceModVerIdLookupDb.class);
-
- wdsm.insertWatchdogServiceModVerIdLookup(distributionId, serviceModelVersionId);
- doNothing().when(wdsm).insertWatchdogServiceModVerIdLookup(any(String.class), any(String.class));
- verify(wdsm, times(1)).insertWatchdogServiceModVerIdLookup(any(String.class), any(String.class));
-
+ public void getWatchdogServiceModVerIdTest() {
+ WatchdogServiceModVerIdLookupDb wds = new WatchdogServiceModVerIdLookupDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.uniqueResult()).thenReturn(null);
+ when(session.isOpen()).thenReturn(true);
+ assertEquals(null, wds.getWatchdogServiceModVerId("test"));
}
@Test
- public void testGetWatchdogServiceModVerId() {
-
- WatchdogServiceModVerIdLookupDb wdsm = Mockito.mock(WatchdogServiceModVerIdLookupDb.class);
- Mockito.when(wdsm.getWatchdogServiceModVerId("ff305d54-75b4-431b-adb2-eb6b9e5ff001")).thenReturn("ff3514e3-5a33-55df-13ab-12abad84e7ff");
- String actual = wdsm.getWatchdogServiceModVerId("ff305d54-75b4-431b-adb2-eb6b9e5ff001");
- assertEquals(actual, "ff3514e3-5a33-55df-13ab-12abad84e7ff");
- verify(wdsm, times(1)).getWatchdogServiceModVerId(any(String.class));
+ public void insertWatchdogServiceModVerIdLookupTest() {
+ WatchdogServiceModVerIdLookupDb wds = new WatchdogServiceModVerIdLookupDb(this.sessionFactoryRequest);
+ Query mockQuery = mock(Query.class);
+ when(session.createQuery(any(String.class))).thenReturn(mockQuery);
+ when(mockQuery.uniqueResult()).thenReturn(null);
+ when(session.isOpen()).thenReturn(true);
+ when(session.getTransaction()).thenThrow(Exception.class);
+ thrown.expect(Exception.class);
+
+ wds.insertWatchdogServiceModVerIdLookup("myId", "myModelVersion");
}
+
}
Code Review / so.git / commitdiff