natas_hw
/
dolphinscheduler
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add queue error，checkQueueExist and checkQueueNameExist update (#997) 

* add ConnectionFactoryTest and ConnectionFactory read datasource from appliction.yml

* .escheduler_env.sh to dolphinscheduler_env.sh

* dao yml assembly to conf directory

* table name modify

* entity title table  name modify

* logback log name modify

* running through the big process

* running through the big process error modify

* logback log name modify

* data_source.properties rename

* logback log name modify

* install.sh optimization

* install.sh optimization

* command count modify

* command state update

* countCommandState sql update

* countCommandState sql update

* remove application.yml file

* master.properties modify

* install.sh modify

* install.sh modify

* api server startup modify

* the current user quits and the session is completely emptied. bug fix

* remove pom package resources

* checkQueueNameExist method update

* checkQueueExist
This commit is contained in:
qiaozhanwei 2019-10-12 14:28:49 +08:00 committed by lgcareer
parent 91229993c7
commit 8f86582609
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/QueueService.java
View File

@ -238,22 +238,23 @@ public class QueueService extends BaseService {
/**
* check queue exist
*
* if exists return true，not exists return false
* check queue exist
* @param queue
* @return
*/
private boolean checkQueueExist(String queue) {
return queueMapper.queryAllQueueList(queue, null).size()>0 ? false : true;
return queueMapper.queryAllQueueList(queue, null).size()>0 ? true : false;
}
/**
* check queue name exist
*
* if exists return true，not exists return false
* @param queueName
* @return
*/
private boolean checkQueueNameExist(String queueName) {
return queueMapper.queryAllQueueList(null ,queueName).size()>0 ? false : true;
return queueMapper.queryAllQueueList(null ,queueName).size() > 0 ? true : false;
}
}