blob: 0bbe2b6e03a49071aff66c25c1f572b58b67ee25 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
package org.openecomp.sdc.be.dao.cassandra;
import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.Row;
import com.datastax.driver.core.Session;
import com.datastax.driver.mapping.MappingManager;
import fj.data.Either;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.junit.Before;
import org.junit.Test;
import org.mockito.InjectMocks;
import org.mockito.Mock;
import org.mockito.Mockito;
import org.mockito.MockitoAnnotations;
import org.openecomp.sdc.be.resources.data.ESArtifactData;
public class ArtifactCassandraDaoTest {
@InjectMocks
ArtifactCassandraDao testSubject;
@Mock
CassandraClient client;
@Mock
ArtifactAccessor artifactAccessor;
@Before
public void setUp() throws Exception {
MockitoAnnotations.initMocks(this);
}
@Test(expected = RuntimeException.class)
public void testInit() throws Exception {
Mockito.when(client.isConnected()).thenReturn(true);
Either<ImmutablePair<Session, MappingManager>, CassandraOperationStatus> value = Either.right(CassandraOperationStatus.CLUSTER_NOT_CONNECTED);
Mockito.when(client.connect(Mockito.anyString())).thenReturn(value);
testSubject.init();
}
@Test
public void testInitError() throws Exception {
testSubject.init();
}
@Test
public void testSaveArtifact() throws Exception {
ESArtifactData artifact = null;
CassandraOperationStatus result;
// default test
result = testSubject.saveArtifact(artifact);
}
@Test
public void testGetArtifact() throws Exception {
String artifactId = "";
Either<ESArtifactData, CassandraOperationStatus> result;
// default test
result = testSubject.getArtifact(artifactId);
}
@Test
public void testDeleteArtifact() throws Exception {
String artifactId = "";
CassandraOperationStatus result;
// default test
result = testSubject.deleteArtifact(artifactId);
}
@Test
public void testDeleteAllArtifacts() throws Exception {
CassandraOperationStatus result;
// default test
result = testSubject.deleteAllArtifacts();
}
@Test
public void testIsTableEmpty() throws Exception {
String tableName = "";
Either<Boolean, CassandraOperationStatus> result;
// default test
result = testSubject.isTableEmpty(tableName);
}
@Test
public void testGetCountOfArtifactById() throws Exception {
String uniqeId = "mock";
Either<Long, CassandraOperationStatus> result;
ResultSet value = Mockito.mock(ResultSet.class);
Row value2 = Mockito.mock(Row.class);
Mockito.when(value2.getLong(0)).thenReturn(0L);
Mockito.when(value.one()).thenReturn(value2);
Mockito.when(artifactAccessor.getNumOfArtifactsById(uniqeId)).thenReturn(value);
// default test
result = testSubject.getCountOfArtifactById(uniqeId);
}
@Test
public void testGetCountOfArtifactById1() throws Exception {
String uniqeId = "mock";
Either<Long, CassandraOperationStatus> result;
ResultSet value = Mockito.mock(ResultSet.class);
Mockito.when(artifactAccessor.getNumOfArtifactsById(uniqeId)).thenReturn(null);
// default test
result = testSubject.getCountOfArtifactById(uniqeId);
}
}
|
