8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2025-12-24 11:52:08 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

实现core包下TopicReportService接口单元测试 & TopicReportDao.xml中字段和关键字错误修改

Browse Source
This commit is contained in:
xuguang
2021-12-08 15:50:53 +08:00
parent 8086ef355b
commit 4538593236
2 changed files with 49 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
kafka-manager-core/src/test/java/com/xiaojukeji/kafka/manager/service/service/gateway/TopicReportServiceTest.java Normal file
View File

@@ -0,0 +1,47 @@
package com.xiaojukeji.kafka.manager.service.service.gateway;
import com.xiaojukeji.kafka.manager.common.entity.pojo.gateway.TopicReportDO;
import com.xiaojukeji.kafka.manager.dao.gateway.TopicReportDao;
import com.xiaojukeji.kafka.manager.service.config.BaseTest;
import org.springframework.beans.factory.annotation.Autowired;
import org.testng.Assert;
import org.testng.annotations.DataProvider;
import org.testng.annotations.Test;
import java.util.Date;
import java.util.List;
/**
* @author xuguang
* @Date 2021/12/7
*/
public class TopicReportServiceTest extends BaseTest {
@Autowired
private TopicReportService topicReportService;
@Autowired
private TopicReportDao topicReportDao;
@DataProvider(name = "provideTopicReportDO")
public static Object[][] provideTopicReportDO() {
TopicReportDO topicReportDO = new TopicReportDO();
topicReportDO.setId(1L);
topicReportDO.setClusterId(1L);
topicReportDO.setTopicName("xgTest");
topicReportDO.setStartTime(new Date(1638786493173L));
topicReportDO.setEndTime(new Date(1638786493173L));
topicReportDO.setModifyTime(new Date(1638786493173L));
topicReportDO.setCreateTime(new Date(1638786493173L));
return new Object[][] {{topicReportDO}};
}
@Test(dataProvider = "provideTopicReportDO")
public void getNeedReportTopicTest(TopicReportDO topicReportDO) {
// 数据库中插入数据
int replace = topicReportDao.replace(topicReportDO);
List<TopicReportDO> result = topicReportService.getNeedReportTopic(1L);
Assert.assertEquals(result.size(), 1);
Assert.assertEquals(result.get(0).toString(), topicReportDO.toString());
}
}

4
kafka-manager-dao/src/main/resources/mapper/TopicReportDao.xml
View File

@@ -27,13 +27,13 @@
]]>
</delete>
<select id="getNeedReportTopics" parameterType="java.util.Map" resultMap="TopicReportMap">
<select id="getNeedReportTopic" parameterType="java.util.Map" resultMap="TopicReportMap">
<![CDATA[
SELECT *
FROM topic_report
WHERE (cluster_id = #{clusterId}
AND start_time <= #{now}
And end_time >= #{now})
AND end_time >= #{now})
]]>
</select>