test/DolphinScheduler
1
0
Fork 0
mirror of https://gitee.com/dolphinscheduler/DolphinScheduler.git synced 2024-12-03 20:58:11 +08:00
Code Issues Actions 10 Packages Projects Releases Wiki Activity

add queryByQueueName

Browse Source
This commit is contained in:
ligang 2019-04-11 18:39:54 +08:00
parent 30a63a05aa
commit 4214d60ffa
2 changed files with 21 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
escheduler-dao/src/main/java/cn/escheduler/dao/mapper/QueueMapper.java
View File

@ -112,5 +112,8 @@ public interface QueueMapper {
@SelectProvider(type = QueueMapperProvider.class, method = "queryByQueue")
Queue queryByQueue(@Param("queue") String queue);
@SelectProvider(type = QueueMapperProvider.class, method = "queryByQueueName")
Queue queryByQueueName(@Param("queueName") String queueName);
}

18
escheduler-dao/src/main/java/cn/escheduler/dao/mapper/QueueMapperProvider.java
View File

@ -170,4 +170,22 @@ public class QueueMapperProvider {
}.toString();
}
/**
* query by queue name
*
* @param parameter
* @return
*/
public String queryByQueueName(Map<String, Object> parameter) {
return new SQL() {
{
SELECT("*");
FROM(TABLE_NAME);
WHERE("`queue_name` = #{queueName}");
}
}.toString();
}
}