package org.onap.holmes.rulemgt.db;\r
\r
import org.easymock.EasyMock;\r
+import org.jdbi.v3.core.Handle;\r
+import org.jdbi.v3.core.Jdbi;\r
+import org.jdbi.v3.core.result.ResultIterable;\r
+import org.jdbi.v3.core.statement.Query;\r
import org.junit.Before;\r
import org.junit.Rule;\r
import org.junit.Test;\r
import org.junit.runner.RunWith;\r
import org.onap.holmes.common.api.entity.CorrelationRule;\r
import org.onap.holmes.common.exception.CorrelationException;\r
-import org.onap.holmes.common.utils.DbDaoUtil;\r
import org.onap.holmes.rulemgt.bean.request.RuleQueryCondition;\r
import org.powermock.api.easymock.PowerMock;\r
import org.powermock.core.classloader.annotations.PrepareForTest;\r
import org.powermock.modules.junit4.PowerMockRunner;\r
import org.powermock.reflect.Whitebox;\r
-import org.skife.jdbi.v2.Handle;\r
-import org.skife.jdbi.v2.Query;\r
\r
import java.util.*;\r
\r
import static org.hamcrest.Matchers.is;\r
\r
@RunWith(PowerMockRunner.class)\r
-@PrepareForTest({DbDaoUtil.class, Handle.class, Query.class})\r
-public class CorrelationRuleQueryDaoTest {\r
+@PrepareForTest({Handle.class, Query.class})\r
+public class CorrelationRuleQueryServiceTest {\r
\r
@Rule\r
public ExpectedException thrown = ExpectedException.none();\r
-\r
- private DbDaoUtil dbDaoUtil;\r
-\r
private Handle handle;\r
-\r
private Query query;\r
-\r
- private CorrelationRuleQueryDao correlationRuleQueryDao;\r
+ private ResultIterable resultIterable;\r
+ private CorrelationRuleQueryService correlationRuleQueryDao;\r
private RuleQueryCondition ruleQueryCondition;\r
+ private Jdbi jdbi;\r
\r
@Before\r
public void setUp() throws Exception {\r
- correlationRuleQueryDao = new CorrelationRuleQueryDao();\r
+ correlationRuleQueryDao = new CorrelationRuleQueryService();\r
\r
- dbDaoUtil = PowerMock.createMock(DbDaoUtil.class);\r
+ jdbi = PowerMock.createMock(Jdbi.class);\r
handle = PowerMock.createMock(Handle.class);\r
query = PowerMock.createMock(Query.class);\r
+ resultIterable = PowerMock.createMock(ResultIterable.class);\r
\r
- Whitebox.setInternalState(correlationRuleQueryDao, "dbDaoUtil", dbDaoUtil);\r
+ Whitebox.setInternalState(correlationRuleQueryDao, "jdbi", jdbi);\r
\r
ruleQueryCondition = createRuleQueryCondition();\r
}\r
thrown.expect(CorrelationException.class);\r
thrown.expectMessage("Failed to query the rule.");\r
\r
- EasyMock.expect(dbDaoUtil.getHandle()).andReturn(handle);\r
+ EasyMock.expect(jdbi.open()).andReturn(handle);\r
EasyMock.expect(handle.createQuery(EasyMock.anyObject(String.class))).andReturn(query);\r
- EasyMock.expect(query.list()).andThrow(new RuntimeException()).anyTimes();\r
- dbDaoUtil.close(handle);\r
+ EasyMock.expect(query.mapToMap()).andThrow(new RuntimeException()).anyTimes();\r
+ handle.close();\r
EasyMock.expectLastCall();\r
\r
PowerMock.replayAll();\r
\r
@Test\r
public void getCorrelationRulesByCondition_normal() throws Exception {\r
- EasyMock.expect(dbDaoUtil.getHandle()).andReturn(handle);\r
+ EasyMock.expect(jdbi.open()).andReturn(handle);\r
EasyMock.expect(handle.createQuery(EasyMock.anyObject(String.class))).andReturn(query);\r
- EasyMock.expect(query.list()).andReturn(createQueryResult()).anyTimes();\r
- dbDaoUtil.close(handle);\r
+ EasyMock.expect(query.mapToMap()).andReturn(resultIterable);\r
+ EasyMock.expect(resultIterable.list()).andReturn(createQueryResult());\r
+ handle.close();\r
EasyMock.expectLastCall();\r
\r
PowerMock.replayAll();\r
thrown.expect(CorrelationException.class);\r
thrown.expectMessage("An error occurred while building the query SQL.");\r
\r
- EasyMock.expect(dbDaoUtil.getHandle()).andReturn(handle);\r
+ EasyMock.expect(jdbi.open()).andReturn(handle);\r
EasyMock.expect(handle.createQuery(EasyMock.anyObject(String.class))).andReturn(query);\r
- EasyMock.expect(query.list()).andReturn(createQueryResult()).anyTimes();\r
- dbDaoUtil.close(handle);\r
+ EasyMock.expect(query.mapToMap()).andReturn(resultIterable);\r
+ EasyMock.expect(resultIterable.list()).andReturn(createQueryResult());\r
+ handle.close();\r
EasyMock.expectLastCall();\r
\r
PowerMock.replayAll();\r
value.put("rid", "rule_" + System.currentTimeMillis());\r
value.put("description", "desc");\r
value.put("enable", 0);\r
- value.put("templateID", 1L);\r
- value.put("engineId", "engine-001");\r
- value.put("engineType", "engineType-001");\r
+ value.put("templateid", 1L);\r
+ value.put("engineid", "engine-001");\r
+ value.put("enginetype", "engineType-001");\r
value.put("creator", "admin");\r
- value.put("createTime", new Date());\r
+ value.put("createtime", new Date());\r
value.put("updator", "admin");\r
- value.put("updateTime", new Date());\r
+ value.put("updatetime", new Date());\r
value.put("params", new Properties());\r
value.put("domain", "Domain");\r
- value.put("isManual", 0);\r
+ value.put("ismanual", 0);\r
value.put("vendor", "Vendor");\r
value.put("content", "Contents");\r
value.put("package", "package");\r