2 * ============LICENSE_START=======================================================
\r
4 * ================================================================================
\r
5 * Copyright © 2017 AT&T Intellectual Property. All rights reserved.
\r
6 * Copyright © 2017 Amdocs
\r
7 * ================================================================================
\r
8 * Licensed under the Apache License, Version 2.0 (the "License");
\r
9 * you may not use this file except in compliance with the License.
\r
10 * You may obtain a copy of the License at
\r
12 * http://www.apache.org/licenses/LICENSE-2.0
\r
14 * Unless required by applicable law or agreed to in writing, software
\r
15 * distributed under the License is distributed on an "AS IS" BASIS,
\r
16 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
\r
17 * See the License for the specific language governing permissions and
\r
18 * limitations under the License.
\r
19 * ============LICENSE_END=========================================================
\r
21 * ECOMP is a trademark and service mark of AT&T Intellectual Property.
\r
23 package org.onap.aai.sa.searchdbabstraction.elasticsearch.dao;
\r
25 import org.junit.Assert;
\r
26 import org.junit.Test;
\r
28 public class ElasticSearchResultItemTest {
\r
31 public void testAllMethods(){
\r
32 ElasticSearchShardStatus shardStatus = new ElasticSearchShardStatus();
\r
33 shardStatus.setTotal(10);
\r
34 shardStatus.setSuccessful(0);
\r
35 shardStatus.setFailed(1);
\r
36 Assert.assertEquals(shardStatus.getTotal(), 10);
\r
37 Assert.assertEquals(shardStatus.getSuccessful(), 0);
\r
38 Assert.assertEquals(shardStatus.getFailed(), 1);
\r
40 ElasticSearchCause cause = new ElasticSearchCause();
\r
41 cause.setType("type-1");
\r
42 cause.setReason("reason-1");
\r
43 Assert.assertEquals(cause.getType(), "type-1");
\r
44 Assert.assertEquals(cause.getReason(), "reason-1");
\r
46 ElasticSearchError error = new ElasticSearchError();
\r
47 error.setType("type-1");
\r
48 error.setReason("reason-1");
\r
49 error.setCausedBy(cause);
\r
50 Assert.assertEquals(error.getType(), "type-1");
\r
51 Assert.assertEquals(error.getReason(), "reason-1");
\r
52 Assert.assertNotNull(error.getCausedBy());
\r
53 error.setAdditionalProperties("name-1", "value-1");
\r
54 Assert.assertNotNull(error.getAdditionalProperties());
\r
57 ElasticSearchResultItem resultItem1 = new ElasticSearchResultItem();
\r
58 resultItem1.setCreate(getStatus(shardStatus, error));
\r
59 Assert.assertNotNull(resultItem1.getCreate());
\r
60 Assert.assertEquals(resultItem1.operationType(), "create");
\r
61 Assert.assertEquals(resultItem1.operationStatus(), resultItem1.getCreate());
\r
62 Assert.assertTrue(resultItem1.toString().contains("create"));
\r
63 Assert.assertNotNull(resultItem1.toJson());
\r
66 ElasticSearchResultItem resultItem2 = new ElasticSearchResultItem();
\r
67 resultItem2.setIndex(getStatus(shardStatus, error));
\r
68 Assert.assertNotNull(resultItem2.getIndex());
\r
69 Assert.assertEquals(resultItem2.operationType(), "update");
\r
70 Assert.assertEquals(resultItem2.operationStatus(), resultItem2.getIndex());
\r
71 Assert.assertTrue(resultItem2.toString().contains("index"));
\r
72 Assert.assertNotNull(resultItem2.toJson());
\r
75 ElasticSearchResultItem resultItem3 = new ElasticSearchResultItem();
\r
76 resultItem3.setDelete(getStatus(shardStatus, error));
\r
77 Assert.assertNotNull(resultItem3.getDelete());
\r
78 Assert.assertEquals(resultItem3.operationType(), "delete");
\r
79 Assert.assertEquals(resultItem3.operationStatus(), resultItem3.getDelete());
\r
80 Assert.assertTrue(resultItem3.toString().contains("delete"));
\r
81 Assert.assertNotNull(resultItem3.toJson());
\r
84 ElasticSearchResultItem resultItem4 = new ElasticSearchResultItem();
\r
85 Assert.assertEquals(resultItem4.operationType(), "unknown");
\r
86 Assert.assertNull(resultItem4.operationStatus());
\r
88 //ElasticSearchBulkOperationResult
\r
89 ElasticSearchResultItem[] resultItems = {resultItem1, resultItem2, resultItem3};
\r
90 ElasticSearchBulkOperationResult result = new ElasticSearchBulkOperationResult();
\r
91 result.setErrors(true);
\r
92 result.setTook(new Integer(10));
\r
93 result.setItems(resultItems);
\r
94 Assert.assertTrue(result.getErrors());
\r
95 Assert.assertEquals(result.getTook(), new Integer(10));
\r
96 Assert.assertNotNull(result.getItems());
\r
97 Assert.assertNotNull(result.toString());
\r
100 private ElasticSearchOperationStatus getStatus(ElasticSearchShardStatus shardStatus, ElasticSearchError error) {
\r
101 ElasticSearchOperationStatus status = new ElasticSearchOperationStatus();
\r
102 status.setIndex("index-1");
\r
103 status.setType("type-1");
\r
104 status.setId("id-1");
\r
105 status.setVersion("1.0");
\r
106 status.setShards(shardStatus);
\r
107 status.setStatus(new Integer(1));
\r
108 status.setError(error);
\r
109 status.setAdditionalProperties("REQUEST_URL", "http://127.0.0.1");
\r
110 Assert.assertEquals(status.getIndex(), "index-1");
\r
111 Assert.assertEquals(status.getType(), "type-1");
\r
112 Assert.assertEquals(status.getId(), "id-1");
\r
113 Assert.assertEquals(status.getVersion(), "1.0");
\r
114 Assert.assertEquals(status.getStatus(), new Integer(1));
\r
115 Assert.assertNotNull(status.getShards());
\r
116 Assert.assertNotNull(status.getError());
\r
117 Assert.assertNotNull(status.getAdditionalProperties());
\r