-/**\r
- * ============LICENSE_START=======================================================\r
- * org.onap.aai\r
- * ================================================================================\r
- * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved.\r
- * Copyright © 2017-2018 Amdocs\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.onap.aai.sa.searchdbabstraction.elasticsearch.dao;\r
-\r
-import org.junit.Assert;\r
-import org.junit.Test;\r
-\r
-public class ElasticSearchResultItemTest {\r
-\r
- @Test\r
- public void testAllMethods() {\r
- ElasticSearchShardStatus shardStatus = new ElasticSearchShardStatus();\r
- shardStatus.setTotal(10);\r
- shardStatus.setSuccessful(0);\r
- shardStatus.setFailed(1);\r
- Assert.assertEquals(shardStatus.getTotal(), 10);\r
- Assert.assertEquals(shardStatus.getSuccessful(), 0);\r
- Assert.assertEquals(shardStatus.getFailed(), 1);\r
-\r
- ElasticSearchCause cause = new ElasticSearchCause();\r
- cause.setType("type-1");\r
- cause.setReason("reason-1");\r
- Assert.assertEquals(cause.getType(), "type-1");\r
- Assert.assertEquals(cause.getReason(), "reason-1");\r
-\r
- ElasticSearchError error = new ElasticSearchError();\r
- error.setType("type-1");\r
- error.setReason("reason-1");\r
- error.setCausedBy(cause);\r
- Assert.assertEquals(error.getType(), "type-1");\r
- Assert.assertEquals(error.getReason(), "reason-1");\r
- Assert.assertNotNull(error.getCausedBy());\r
- error.setAdditionalProperties("name-1", "value-1");\r
- Assert.assertNotNull(error.getAdditionalProperties());\r
-\r
- // Create Status\r
- ElasticSearchResultItem resultItem1 = new ElasticSearchResultItem();\r
- resultItem1.setCreate(getStatus(shardStatus, error));\r
- Assert.assertNotNull(resultItem1.getCreate());\r
- Assert.assertEquals(resultItem1.operationType(), "create");\r
- Assert.assertEquals(resultItem1.operationStatus(), resultItem1.getCreate());\r
- Assert.assertTrue(resultItem1.toString().contains("create"));\r
- Assert.assertNotNull(resultItem1.toJson());\r
-\r
- // Index Status\r
- ElasticSearchResultItem resultItem2 = new ElasticSearchResultItem();\r
- resultItem2.setIndex(getStatus(shardStatus, error));\r
- Assert.assertNotNull(resultItem2.getIndex());\r
- Assert.assertEquals(resultItem2.operationType(), "update");\r
- Assert.assertEquals(resultItem2.operationStatus(), resultItem2.getIndex());\r
- Assert.assertTrue(resultItem2.toString().contains("index"));\r
- Assert.assertNotNull(resultItem2.toJson());\r
-\r
- // Delete Status\r
- ElasticSearchResultItem resultItem3 = new ElasticSearchResultItem();\r
- resultItem3.setDelete(getStatus(shardStatus, error));\r
- Assert.assertNotNull(resultItem3.getDelete());\r
- Assert.assertEquals(resultItem3.operationType(), "delete");\r
- Assert.assertEquals(resultItem3.operationStatus(), resultItem3.getDelete());\r
- Assert.assertTrue(resultItem3.toString().contains("delete"));\r
- Assert.assertNotNull(resultItem3.toJson());\r
-\r
- // Unknown Status\r
- ElasticSearchResultItem resultItem4 = new ElasticSearchResultItem();\r
- Assert.assertEquals(resultItem4.operationType(), "unknown");\r
- Assert.assertNull(resultItem4.operationStatus());\r
-\r
- // ElasticSearchBulkOperationResult\r
- ElasticSearchResultItem[] resultItems = {resultItem1, resultItem2, resultItem3};\r
- ElasticSearchBulkOperationResult result = new ElasticSearchBulkOperationResult();\r
- result.setErrors(true);\r
- result.setTook(new Integer(10));\r
- result.setItems(resultItems);\r
- Assert.assertTrue(result.getErrors());\r
- Assert.assertEquals(result.getTook(), new Integer(10));\r
- Assert.assertNotNull(result.getItems());\r
- Assert.assertNotNull(result.toString());\r
- }\r
-\r
- private ElasticSearchOperationStatus getStatus(ElasticSearchShardStatus shardStatus, ElasticSearchError error) {\r
- ElasticSearchOperationStatus status = new ElasticSearchOperationStatus();\r
- status.setIndex("index-1");\r
- status.setType("type-1");\r
- status.setId("id-1");\r
- status.setVersion("1.0");\r
- status.setShards(shardStatus);\r
- status.setStatus(new Integer(1));\r
- status.setError(error);\r
- status.setAdditionalProperties("REQUEST_URL", "http://127.0.0.1");\r
- Assert.assertEquals(status.getIndex(), "index-1");\r
- Assert.assertEquals(status.getType(), "type-1");\r
- Assert.assertEquals(status.getId(), "id-1");\r
- Assert.assertEquals(status.getVersion(), "1.0");\r
- Assert.assertEquals(status.getStatus(), new Integer(1));\r
- Assert.assertNotNull(status.getShards());\r
- Assert.assertNotNull(status.getError());\r
- Assert.assertNotNull(status.getAdditionalProperties());\r
- return status;\r
- }\r
-\r
-}\r
+/**
+ * ============LICENSE_START=======================================================
+ * org.onap.aai
+ * ================================================================================
+ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright © 2017-2018 Amdocs
+ * ================================================================================
+ * 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.onap.aai.sa.searchdbabstraction.elasticsearch.dao;
+
+import org.junit.Assert;
+import org.junit.Test;
+
+public class ElasticSearchResultItemTest {
+
+ @Test
+ public void testAllMethods() {
+ ElasticSearchShardStatus shardStatus = new ElasticSearchShardStatus();
+ shardStatus.setTotal(10);
+ shardStatus.setSuccessful(0);
+ shardStatus.setFailed(1);
+ Assert.assertEquals(shardStatus.getTotal(), 10);
+ Assert.assertEquals(shardStatus.getSuccessful(), 0);
+ Assert.assertEquals(shardStatus.getFailed(), 1);
+
+ ElasticSearchCause cause = new ElasticSearchCause();
+ cause.setType("type-1");
+ cause.setReason("reason-1");
+ Assert.assertEquals(cause.getType(), "type-1");
+ Assert.assertEquals(cause.getReason(), "reason-1");
+
+ ElasticSearchError error = new ElasticSearchError();
+ error.setType("type-1");
+ error.setReason("reason-1");
+ error.setCausedBy(cause);
+ Assert.assertEquals(error.getType(), "type-1");
+ Assert.assertEquals(error.getReason(), "reason-1");
+ Assert.assertNotNull(error.getCausedBy());
+ error.setAdditionalProperties("name-1", "value-1");
+ Assert.assertNotNull(error.getAdditionalProperties());
+
+ // Create Status
+ ElasticSearchResultItem resultItem1 = new ElasticSearchResultItem();
+ resultItem1.setCreate(getStatus(shardStatus, error));
+ Assert.assertNotNull(resultItem1.getCreate());
+ Assert.assertEquals(resultItem1.operationType(), "create");
+ Assert.assertEquals(resultItem1.operationStatus(), resultItem1.getCreate());
+ Assert.assertTrue(resultItem1.toString().contains("create"));
+ Assert.assertNotNull(resultItem1.toJson());
+
+ // Index Status
+ ElasticSearchResultItem resultItem2 = new ElasticSearchResultItem();
+ resultItem2.setIndex(getStatus(shardStatus, error));
+ Assert.assertNotNull(resultItem2.getIndex());
+ Assert.assertEquals(resultItem2.operationType(), "update");
+ Assert.assertEquals(resultItem2.operationStatus(), resultItem2.getIndex());
+ Assert.assertTrue(resultItem2.toString().contains("index"));
+ Assert.assertNotNull(resultItem2.toJson());
+
+ // Delete Status
+ ElasticSearchResultItem resultItem3 = new ElasticSearchResultItem();
+ resultItem3.setDelete(getStatus(shardStatus, error));
+ Assert.assertNotNull(resultItem3.getDelete());
+ Assert.assertEquals(resultItem3.operationType(), "delete");
+ Assert.assertEquals(resultItem3.operationStatus(), resultItem3.getDelete());
+ Assert.assertTrue(resultItem3.toString().contains("delete"));
+ Assert.assertNotNull(resultItem3.toJson());
+
+ // Unknown Status
+ ElasticSearchResultItem resultItem4 = new ElasticSearchResultItem();
+ Assert.assertEquals(resultItem4.operationType(), "unknown");
+ Assert.assertNull(resultItem4.operationStatus());
+
+ // ElasticSearchBulkOperationResult
+ ElasticSearchResultItem[] resultItems = {resultItem1, resultItem2, resultItem3};
+ ElasticSearchBulkOperationResult result = new ElasticSearchBulkOperationResult();
+ result.setErrors(true);
+ result.setTook(new Integer(10));
+ result.setItems(resultItems);
+ Assert.assertTrue(result.getErrors());
+ Assert.assertEquals(result.getTook(), new Integer(10));
+ Assert.assertNotNull(result.getItems());
+ Assert.assertNotNull(result.toString());
+ }
+
+ private ElasticSearchOperationStatus getStatus(ElasticSearchShardStatus shardStatus, ElasticSearchError error) {
+ ElasticSearchOperationStatus status = new ElasticSearchOperationStatus();
+ status.setIndex("index-1");
+ status.setType("type-1");
+ status.setId("id-1");
+ status.setVersion("1.0");
+ status.setShards(shardStatus);
+ status.setStatus(new Integer(1));
+ status.setError(error);
+ status.setAdditionalProperties("REQUEST_URL", "http://127.0.0.1");
+ Assert.assertEquals(status.getIndex(), "index-1");
+ Assert.assertEquals(status.getType(), "type-1");
+ Assert.assertEquals(status.getId(), "id-1");
+ Assert.assertEquals(status.getVersion(), "1.0");
+ Assert.assertEquals(status.getStatus(), new Integer(1));
+ Assert.assertNotNull(status.getShards());
+ Assert.assertNotNull(status.getError());
+ Assert.assertNotNull(status.getAdditionalProperties());
+ return status;
+ }
+
+}
Code Review / aai / search-data-service.git / blobdiff