2 * ============LICENSE_START=======================================================
\r
4 * ================================================================================
\r
5 * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved.
\r
6 * Copyright © 2017-2018 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 package org.onap.aai.sa.searchdbabstraction.elasticsearch.dao;
\r
23 import org.junit.Assert;
\r
24 import org.junit.Test;
\r
26 public class ElasticSearchResultItemTest {
\r
29 public void testAllMethods(){
\r
30 ElasticSearchShardStatus shardStatus = new ElasticSearchShardStatus();
\r
31 shardStatus.setTotal(10);
\r
32 shardStatus.setSuccessful(0);
\r
33 shardStatus.setFailed(1);
\r
34 Assert.assertEquals(shardStatus.getTotal(), 10);
\r
35 Assert.assertEquals(shardStatus.getSuccessful(), 0);
\r
36 Assert.assertEquals(shardStatus.getFailed(), 1);
\r
38 ElasticSearchCause cause = new ElasticSearchCause();
\r
39 cause.setType("type-1");
\r
40 cause.setReason("reason-1");
\r
41 Assert.assertEquals(cause.getType(), "type-1");
\r
42 Assert.assertEquals(cause.getReason(), "reason-1");
\r
44 ElasticSearchError error = new ElasticSearchError();
\r
45 error.setType("type-1");
\r
46 error.setReason("reason-1");
\r
47 error.setCausedBy(cause);
\r
48 Assert.assertEquals(error.getType(), "type-1");
\r
49 Assert.assertEquals(error.getReason(), "reason-1");
\r
50 Assert.assertNotNull(error.getCausedBy());
\r
51 error.setAdditionalProperties("name-1", "value-1");
\r
52 Assert.assertNotNull(error.getAdditionalProperties());
\r
55 ElasticSearchResultItem resultItem1 = new ElasticSearchResultItem();
\r
56 resultItem1.setCreate(getStatus(shardStatus, error));
\r
57 Assert.assertNotNull(resultItem1.getCreate());
\r
58 Assert.assertEquals(resultItem1.operationType(), "create");
\r
59 Assert.assertEquals(resultItem1.operationStatus(), resultItem1.getCreate());
\r
60 Assert.assertTrue(resultItem1.toString().contains("create"));
\r
61 Assert.assertNotNull(resultItem1.toJson());
\r
64 ElasticSearchResultItem resultItem2 = new ElasticSearchResultItem();
\r
65 resultItem2.setIndex(getStatus(shardStatus, error));
\r
66 Assert.assertNotNull(resultItem2.getIndex());
\r
67 Assert.assertEquals(resultItem2.operationType(), "update");
\r
68 Assert.assertEquals(resultItem2.operationStatus(), resultItem2.getIndex());
\r
69 Assert.assertTrue(resultItem2.toString().contains("index"));
\r
70 Assert.assertNotNull(resultItem2.toJson());
\r
73 ElasticSearchResultItem resultItem3 = new ElasticSearchResultItem();
\r
74 resultItem3.setDelete(getStatus(shardStatus, error));
\r
75 Assert.assertNotNull(resultItem3.getDelete());
\r
76 Assert.assertEquals(resultItem3.operationType(), "delete");
\r
77 Assert.assertEquals(resultItem3.operationStatus(), resultItem3.getDelete());
\r
78 Assert.assertTrue(resultItem3.toString().contains("delete"));
\r
79 Assert.assertNotNull(resultItem3.toJson());
\r
82 ElasticSearchResultItem resultItem4 = new ElasticSearchResultItem();
\r
83 Assert.assertEquals(resultItem4.operationType(), "unknown");
\r
84 Assert.assertNull(resultItem4.operationStatus());
\r
86 //ElasticSearchBulkOperationResult
\r
87 ElasticSearchResultItem[] resultItems = {resultItem1, resultItem2, resultItem3};
\r
88 ElasticSearchBulkOperationResult result = new ElasticSearchBulkOperationResult();
\r
89 result.setErrors(true);
\r
90 result.setTook(new Integer(10));
\r
91 result.setItems(resultItems);
\r
92 Assert.assertTrue(result.getErrors());
\r
93 Assert.assertEquals(result.getTook(), new Integer(10));
\r
94 Assert.assertNotNull(result.getItems());
\r
95 Assert.assertNotNull(result.toString());
\r
98 private ElasticSearchOperationStatus getStatus(ElasticSearchShardStatus shardStatus, ElasticSearchError error) {
\r
99 ElasticSearchOperationStatus status = new ElasticSearchOperationStatus();
\r
100 status.setIndex("index-1");
\r
101 status.setType("type-1");
\r
102 status.setId("id-1");
\r
103 status.setVersion("1.0");
\r
104 status.setShards(shardStatus);
\r
105 status.setStatus(new Integer(1));
\r
106 status.setError(error);
\r
107 status.setAdditionalProperties("REQUEST_URL", "http://127.0.0.1");
\r
108 Assert.assertEquals(status.getIndex(), "index-1");
\r
109 Assert.assertEquals(status.getType(), "type-1");
\r
110 Assert.assertEquals(status.getId(), "id-1");
\r
111 Assert.assertEquals(status.getVersion(), "1.0");
\r
112 Assert.assertEquals(status.getStatus(), new Integer(1));
\r
113 Assert.assertNotNull(status.getShards());
\r
114 Assert.assertNotNull(status.getError());
\r
115 Assert.assertNotNull(status.getAdditionalProperties());
\r