BoYiZhang
4 years ago
committed by
GitHub
84 changed files with 1939 additions and 1193 deletions
@ -0,0 +1,122 @@
|
||||
/* |
||||
* Licensed to the Apache Software Foundation (ASF) under one or more |
||||
* contributor license agreements. See the NOTICE file distributed with |
||||
* this work for additional information regarding copyright ownership. |
||||
* The ASF licenses this file to You under the Apache License, Version 2.0 |
||||
* (the "License"); you may not use this file except in compliance with |
||||
* the License. You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
*/ |
||||
package org.apache.dolphinscheduler.common.model; |
||||
|
||||
|
||||
import java.util.Date; |
||||
import java.util.Set; |
||||
|
||||
import com.fasterxml.jackson.annotation.JsonFormat; |
||||
|
||||
/** |
||||
* server |
||||
*/ |
||||
public class WorkerServerModel { |
||||
|
||||
/** |
||||
* id |
||||
*/ |
||||
private int id; |
||||
|
||||
/** |
||||
* host |
||||
*/ |
||||
private String host; |
||||
|
||||
/** |
||||
* port |
||||
*/ |
||||
private int port; |
||||
|
||||
/** |
||||
* worker directories in zookeeper |
||||
*/ |
||||
private Set<String> zkDirectories; |
||||
|
||||
/** |
||||
* resource info about CPU and memory |
||||
*/ |
||||
private String resInfo; |
||||
|
||||
/** |
||||
* create time |
||||
*/ |
||||
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") |
||||
private Date createTime; |
||||
|
||||
/** |
||||
* last heart beat time |
||||
*/ |
||||
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") |
||||
private Date lastHeartbeatTime; |
||||
|
||||
public int getId() { |
||||
return id; |
||||
} |
||||
|
||||
public void setId(int id) { |
||||
this.id = id; |
||||
} |
||||
|
||||
public Date getCreateTime() { |
||||
return createTime; |
||||
} |
||||
|
||||
public void setCreateTime(Date createTime) { |
||||
this.createTime = createTime; |
||||
} |
||||
|
||||
public Set<String> getZkDirectories() { |
||||
return zkDirectories; |
||||
} |
||||
|
||||
public void setZkDirectories(Set<String> zkDirectories) { |
||||
this.zkDirectories = zkDirectories; |
||||
} |
||||
|
||||
public Date getLastHeartbeatTime() { |
||||
return lastHeartbeatTime; |
||||
} |
||||
|
||||
public void setLastHeartbeatTime(Date lastHeartbeatTime) { |
||||
this.lastHeartbeatTime = lastHeartbeatTime; |
||||
} |
||||
|
||||
public String getResInfo() { |
||||
return resInfo; |
||||
} |
||||
|
||||
public void setResInfo(String resInfo) { |
||||
this.resInfo = resInfo; |
||||
} |
||||
|
||||
public String getHost() { |
||||
return host; |
||||
} |
||||
|
||||
public void setHost(String host) { |
||||
this.host = host; |
||||
} |
||||
|
||||
public int getPort() { |
||||
return port; |
||||
} |
||||
|
||||
public void setPort(int port) { |
||||
this.port = port; |
||||
} |
||||
} |
||||
@ -0,0 +1,85 @@
|
||||
/* |
||||
* Licensed to the Apache Software Foundation (ASF) under one or more |
||||
* contributor license agreements. See the NOTICE file distributed with |
||||
* this work for additional information regarding copyright ownership. |
||||
* The ASF licenses this file to You under the Apache License, Version 2.0 |
||||
* (the "License"); you may not use this file except in compliance with |
||||
* the License. You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
*/ |
||||
|
||||
package org.apache.dolphinscheduler.dao.datasource; |
||||
|
||||
import org.junit.Assert; |
||||
import org.junit.Test; |
||||
|
||||
/** |
||||
* test data source of hive |
||||
*/ |
||||
public class HiveDataSourceTest { |
||||
|
||||
@Test |
||||
public void testfilterOther() { |
||||
BaseDataSource hiveDataSource = new HiveDataSource(); |
||||
|
||||
// not contain hive_site_conf
|
||||
String other = hiveDataSource.filterOther("charset=UTF-8"); |
||||
Assert.assertEquals("charset=UTF-8", other); |
||||
|
||||
// not contain
|
||||
other = hiveDataSource.filterOther(""); |
||||
Assert.assertEquals("", other); |
||||
|
||||
// only contain hive_site_conf
|
||||
other = hiveDataSource.filterOther("hive.mapred.mode=strict"); |
||||
Assert.assertEquals("?hive.mapred.mode=strict", other); |
||||
|
||||
// contain hive_site_conf at the first
|
||||
other = hiveDataSource.filterOther("hive.mapred.mode=strict;charset=UTF-8"); |
||||
Assert.assertEquals("charset=UTF-8?hive.mapred.mode=strict", other); |
||||
|
||||
// contain hive_site_conf in the middle
|
||||
other = hiveDataSource.filterOther("charset=UTF-8;hive.mapred.mode=strict;foo=bar"); |
||||
Assert.assertEquals("charset=UTF-8;foo=bar?hive.mapred.mode=strict", other); |
||||
|
||||
// contain hive_site_conf at the end
|
||||
other = hiveDataSource.filterOther("charset=UTF-8;foo=bar;hive.mapred.mode=strict"); |
||||
Assert.assertEquals("charset=UTF-8;foo=bar?hive.mapred.mode=strict", other); |
||||
|
||||
// contain multi hive_site_conf
|
||||
other = hiveDataSource.filterOther("charset=UTF-8;foo=bar;hive.mapred.mode=strict;hive.exec.parallel=true"); |
||||
Assert.assertEquals("charset=UTF-8;foo=bar?hive.mapred.mode=strict;hive.exec.parallel=true", other); |
||||
} |
||||
|
||||
@Test |
||||
public void testGetHiveJdbcUrlOther() { |
||||
|
||||
BaseDataSource hiveDataSource = new HiveDataSource(); |
||||
hiveDataSource.setAddress("jdbc:hive2://127.0.0.1:10000"); |
||||
hiveDataSource.setDatabase("test"); |
||||
hiveDataSource.setPassword("123456"); |
||||
hiveDataSource.setUser("test"); |
||||
Assert.assertEquals("jdbc:hive2://127.0.0.1:10000/test", hiveDataSource.getJdbcUrl()); |
||||
|
||||
hiveDataSource.setOther("charset=UTF-8;hive.mapred.mode=strict;hive.server2.thrift.http.path=hs2"); |
||||
|
||||
Assert.assertEquals( |
||||
"jdbc:hive2://127.0.0.1:10000/test;charset=UTF-8?hive.mapred.mode=strict;hive.server2.thrift.http.path=hs2", |
||||
hiveDataSource.getJdbcUrl()); |
||||
|
||||
hiveDataSource.setOther("hive.mapred.mode=strict;hive.server2.thrift.http.path=hs2"); |
||||
|
||||
Assert.assertEquals( |
||||
"jdbc:hive2://127.0.0.1:10000/test;?hive.mapred.mode=strict;hive.server2.thrift.http.path=hs2", |
||||
hiveDataSource.getJdbcUrl()); |
||||
|
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,202 @@
|
||||
|
||||
Apache License |
||||
Version 2.0, January 2004 |
||||
http://www.apache.org/licenses/ |
||||
|
||||
TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION |
||||
|
||||
1. Definitions. |
||||
|
||||
"License" shall mean the terms and conditions for use, reproduction, |
||||
and distribution as defined by Sections 1 through 9 of this document. |
||||
|
||||
"Licensor" shall mean the copyright owner or entity authorized by |
||||
the copyright owner that is granting the License. |
||||
|
||||
"Legal Entity" shall mean the union of the acting entity and all |
||||
other entities that control, are controlled by, or are under common |
||||
control with that entity. For the purposes of this definition, |
||||
"control" means (i) the power, direct or indirect, to cause the |
||||
direction or management of such entity, whether by contract or |
||||
otherwise, or (ii) ownership of fifty percent (50%) or more of the |
||||
outstanding shares, or (iii) beneficial ownership of such entity. |
||||
|
||||
"You" (or "Your") shall mean an individual or Legal Entity |
||||
exercising permissions granted by this License. |
||||
|
||||
"Source" form shall mean the preferred form for making modifications, |
||||
including but not limited to software source code, documentation |
||||
source, and configuration files. |
||||
|
||||
"Object" form shall mean any form resulting from mechanical |
||||
transformation or translation of a Source form, including but |
||||
not limited to compiled object code, generated documentation, |
||||
and conversions to other media types. |
||||
|
||||
"Work" shall mean the work of authorship, whether in Source or |
||||
Object form, made available under the License, as indicated by a |
||||
copyright notice that is included in or attached to the work |
||||
(an example is provided in the Appendix below). |
||||
|
||||
"Derivative Works" shall mean any work, whether in Source or Object |
||||
form, that is based on (or derived from) the Work and for which the |
||||
editorial revisions, annotations, elaborations, or other modifications |
||||
represent, as a whole, an original work of authorship. For the purposes |
||||
of this License, Derivative Works shall not include works that remain |
||||
separable from, or merely link (or bind by name) to the interfaces of, |
||||
the Work and Derivative Works thereof. |
||||
|
||||
"Contribution" shall mean any work of authorship, including |
||||
the original version of the Work and any modifications or additions |
||||
to that Work or Derivative Works thereof, that is intentionally |
||||
submitted to Licensor for inclusion in the Work by the copyright owner |
||||
or by an individual or Legal Entity authorized to submit on behalf of |
||||
the copyright owner. For the purposes of this definition, "submitted" |
||||
means any form of electronic, verbal, or written communication sent |
||||
to the Licensor or its representatives, including but not limited to |
||||
communication on electronic mailing lists, source code control systems, |
||||
and issue tracking systems that are managed by, or on behalf of, the |
||||
Licensor for the purpose of discussing and improving the Work, but |
||||
excluding communication that is conspicuously marked or otherwise |
||||
designated in writing by the copyright owner as "Not a Contribution." |
||||
|
||||
"Contributor" shall mean Licensor and any individual or Legal Entity |
||||
on behalf of whom a Contribution has been received by Licensor and |
||||
subsequently incorporated within the Work. |
||||
|
||||
2. Grant of Copyright License. Subject to the terms and conditions of |
||||
this License, each Contributor hereby grants to You a perpetual, |
||||
worldwide, non-exclusive, no-charge, royalty-free, irrevocable |
||||
copyright license to reproduce, prepare Derivative Works of, |
||||
publicly display, publicly perform, sublicense, and distribute the |
||||
Work and such Derivative Works in Source or Object form. |
||||
|
||||
3. Grant of Patent License. Subject to the terms and conditions of |
||||
this License, each Contributor hereby grants to You a perpetual, |
||||
worldwide, non-exclusive, no-charge, royalty-free, irrevocable |
||||
(except as stated in this section) patent license to make, have made, |
||||
use, offer to sell, sell, import, and otherwise transfer the Work, |
||||
where such license applies only to those patent claims licensable |
||||
by such Contributor that are necessarily infringed by their |
||||
Contribution(s) alone or by combination of their Contribution(s) |
||||
with the Work to which such Contribution(s) was submitted. If You |
||||
institute patent litigation against any entity (including a |
||||
cross-claim or counterclaim in a lawsuit) alleging that the Work |
||||
or a Contribution incorporated within the Work constitutes direct |
||||
or contributory patent infringement, then any patent licenses |
||||
granted to You under this License for that Work shall terminate |
||||
as of the date such litigation is filed. |
||||
|
||||
4. Redistribution. You may reproduce and distribute copies of the |
||||
Work or Derivative Works thereof in any medium, with or without |
||||
modifications, and in Source or Object form, provided that You |
||||
meet the following conditions: |
||||
|
||||
(a) You must give any other recipients of the Work or |
||||
Derivative Works a copy of this License; and |
||||
|
||||
(b) You must cause any modified files to carry prominent notices |
||||
stating that You changed the files; and |
||||
|
||||
(c) You must retain, in the Source form of any Derivative Works |
||||
that You distribute, all copyright, patent, trademark, and |
||||
attribution notices from the Source form of the Work, |
||||
excluding those notices that do not pertain to any part of |
||||
the Derivative Works; and |
||||
|
||||
(d) If the Work includes a "NOTICE" text file as part of its |
||||
distribution, then any Derivative Works that You distribute must |
||||
include a readable copy of the attribution notices contained |
||||
within such NOTICE file, excluding those notices that do not |
||||
pertain to any part of the Derivative Works, in at least one |
||||
of the following places: within a NOTICE text file distributed |
||||
as part of the Derivative Works; within the Source form or |
||||
documentation, if provided along with the Derivative Works; or, |
||||
within a display generated by the Derivative Works, if and |
||||
wherever such third-party notices normally appear. The contents |
||||
of the NOTICE file are for informational purposes only and |
||||
do not modify the License. You may add Your own attribution |
||||
notices within Derivative Works that You distribute, alongside |
||||
or as an addendum to the NOTICE text from the Work, provided |
||||
that such additional attribution notices cannot be construed |
||||
as modifying the License. |
||||
|
||||
You may add Your own copyright statement to Your modifications and |
||||
may provide additional or different license terms and conditions |
||||
for use, reproduction, or distribution of Your modifications, or |
||||
for any such Derivative Works as a whole, provided Your use, |
||||
reproduction, and distribution of the Work otherwise complies with |
||||
the conditions stated in this License. |
||||
|
||||
5. Submission of Contributions. Unless You explicitly state otherwise, |
||||
any Contribution intentionally submitted for inclusion in the Work |
||||
by You to the Licensor shall be under the terms and conditions of |
||||
this License, without any additional terms or conditions. |
||||
Notwithstanding the above, nothing herein shall supersede or modify |
||||
the terms of any separate license agreement you may have executed |
||||
with Licensor regarding such Contributions. |
||||
|
||||
6. Trademarks. This License does not grant permission to use the trade |
||||
names, trademarks, service marks, or product names of the Licensor, |
||||
except as required for reasonable and customary use in describing the |
||||
origin of the Work and reproducing the content of the NOTICE file. |
||||
|
||||
7. Disclaimer of Warranty. Unless required by applicable law or |
||||
agreed to in writing, Licensor provides the Work (and each |
||||
Contributor provides its Contributions) on an "AS IS" BASIS, |
||||
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or |
||||
implied, including, without limitation, any warranties or conditions |
||||
of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A |
||||
PARTICULAR PURPOSE. You are solely responsible for determining the |
||||
appropriateness of using or redistributing the Work and assume any |
||||
risks associated with Your exercise of permissions under this License. |
||||
|
||||
8. Limitation of Liability. In no event and under no legal theory, |
||||
whether in tort (including negligence), contract, or otherwise, |
||||
unless required by applicable law (such as deliberate and grossly |
||||
negligent acts) or agreed to in writing, shall any Contributor be |
||||
liable to You for damages, including any direct, indirect, special, |
||||
incidental, or consequential damages of any character arising as a |
||||
result of this License or out of the use or inability to use the |
||||
Work (including but not limited to damages for loss of goodwill, |
||||
work stoppage, computer failure or malfunction, or any and all |
||||
other commercial damages or losses), even if such Contributor |
||||
has been advised of the possibility of such damages. |
||||
|
||||
9. Accepting Warranty or Additional Liability. While redistributing |
||||
the Work or Derivative Works thereof, You may choose to offer, |
||||
and charge a fee for, acceptance of support, warranty, indemnity, |
||||
or other liability obligations and/or rights consistent with this |
||||
License. However, in accepting such obligations, You may act only |
||||
on Your own behalf and on Your sole responsibility, not on behalf |
||||
of any other Contributor, and only if You agree to indemnify, |
||||
defend, and hold each Contributor harmless for any liability |
||||
incurred by, or claims asserted against, such Contributor by reason |
||||
of your accepting any such warranty or additional liability. |
||||
|
||||
END OF TERMS AND CONDITIONS |
||||
|
||||
APPENDIX: How to apply the Apache License to your work. |
||||
|
||||
To apply the Apache License to your work, attach the following |
||||
boilerplate notice, with the fields enclosed by brackets "[]" |
||||
replaced with your own identifying information. (Don't include |
||||
the brackets!) The text should be enclosed in the appropriate |
||||
comment syntax for the file format. We also recommend that a |
||||
file or class name and description of purpose be included on the |
||||
same "printed page" as the copyright notice for easier |
||||
identification within third-party archives. |
||||
|
||||
Copyright [yyyy] [name of copyright owner] |
||||
|
||||
Licensed under the Apache License, Version 2.0 (the "License"); |
||||
you may not use this file except in compliance with the License. |
||||
You may obtain a copy of the License at |
||||
|
||||
http://www.apache.org/licenses/LICENSE-2.0 |
||||
|
||||
Unless required by applicable law or agreed to in writing, software |
||||
distributed under the License is distributed on an "AS IS" BASIS, |
||||
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
See the License for the specific language governing permissions and |
||||
limitations under the License. |
||||
@ -0,0 +1,112 @@
|
||||
/* |
||||
* Licensed to the Apache Software Foundation (ASF) under one or more |
||||
* contributor license agreements. See the NOTICE file distributed with |
||||
* this work for additional information regarding copyright ownership. |
||||
* The ASF licenses this file to You under the Apache License, Version 2.0 |
||||
* (the "License"); you may not use this file except in compliance with |
||||
* the License. You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0 |
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
*/ |
||||
<template> |
||||
<div class="container"> |
||||
<div class="title-box"> |
||||
<span class="name">{{$t('zkDirectory')}}</span> |
||||
</div> |
||||
|
||||
<div class="table-box" v-if="zkDirectories.length > 0"> |
||||
<table class="fixed"> |
||||
<caption><!-- placeHolder --></caption> |
||||
<tr> |
||||
<th scope="col" style="min-width: 40px"> |
||||
<span>#</span> |
||||
</th> |
||||
<th scope="col" style="min-width: 40px"> |
||||
<span>{{$t('zkDirectory')}}</span> |
||||
</th> |
||||
</tr> |
||||
<tr v-for="(item, $index) in zkDirectories" :key="item.id"> |
||||
<td> |
||||
<span>{{$index + 1}}</span> |
||||
</td> |
||||
<td> |
||||
<span>{{item.zkDirectory}}</span> |
||||
</td> |
||||
</tr> |
||||
</table> |
||||
</div> |
||||
|
||||
<div v-if="zkDirectories.length === 0"> |
||||
<m-no-data><!----></m-no-data> |
||||
</div> |
||||
|
||||
<div v-if="zkDirectories.length > 0"> |
||||
<div class="bottom-box"> |
||||
</div> |
||||
</div> |
||||
</div> |
||||
</template> |
||||
|
||||
<script> |
||||
import mNoData from '@/module/components/noData/noData' |
||||
|
||||
export default { |
||||
name: 'zookeeperDirectoriesPopup', |
||||
data () { |
||||
return { |
||||
tableHeaders: [ |
||||
{ |
||||
label: $t('zkDirectory'), |
||||
prop: 'zkDirectory' |
||||
} |
||||
] |
||||
} |
||||
}, |
||||
props: { |
||||
zkDirectories: Array |
||||
}, |
||||
components: { mNoData } |
||||
} |
||||
</script> |
||||
|
||||
<style lang="scss" rel="stylesheet/scss"> |
||||
.container { |
||||
width: 500px; |
||||
.title-box { |
||||
height: 61px; |
||||
border-bottom: 1px solid #DCDEDC; |
||||
position: relative; |
||||
.name { |
||||
position: absolute; |
||||
left: 24px; |
||||
top: 18px; |
||||
font-size: 16px; |
||||
} |
||||
} |
||||
.bottom-box { |
||||
position: absolute; |
||||
bottom: 0; |
||||
left: 0; |
||||
width: 100%; |
||||
text-align: right; |
||||
height: 60px; |
||||
line-height: 60px; |
||||
border-top: 1px solid #DCDEDC; |
||||
background: #fff; |
||||
.ans-page { |
||||
display: inline-block; |
||||
} |
||||
} |
||||
.table-box { |
||||
overflow-y: scroll; |
||||
height: calc(100vh - 61px); |
||||
padding-bottom: 60px; |
||||
} |
||||
} |
||||
</style> |
||||
@ -0,0 +1,32 @@
|
||||
/* |
||||
* Licensed to the Apache Software Foundation (ASF) under one or more |
||||
* contributor license agreements. See the NOTICE file distributed with |
||||
* this work for additional information regarding copyright ownership. |
||||
* The ASF licenses this file to You under the Apache License, Version 2.0 |
||||
* (the "License"); you may not use this file except in compliance with |
||||
* the License. You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
*/ |
||||
package org.apache.dolphinscheduler.data.project; |
||||
|
||||
public class RunWorkflowData { |
||||
/** |
||||
* run workflow data |
||||
*/ |
||||
//input shell task name
|
||||
public static final String RECIPIENT = "123456789@qq.com"; |
||||
|
||||
//input shell task description
|
||||
public static final String Cc = "qwe12312sds@qq.com"; |
||||
|
||||
public static final String RUN_WORKFLOW_TITLE = "工作流定义 - DolphinScheduler"; |
||||
|
||||
|
||||
} |
||||
@ -0,0 +1,35 @@
|
||||
/* |
||||
* Licensed to the Apache Software Foundation (ASF) under one or more |
||||
* contributor license agreements. See the NOTICE file distributed with |
||||
* this work for additional information regarding copyright ownership. |
||||
* The ASF licenses this file to You under the Apache License, Version 2.0 |
||||
* (the "License"); you may not use this file except in compliance with |
||||
* the License. You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
*/ |
||||
package org.apache.dolphinscheduler.data.project; |
||||
|
||||
public class TimingData { |
||||
/** |
||||
* timing data |
||||
*/ |
||||
//input shell task name
|
||||
public static final String RECIPIENT = "test123456@qq.com"; |
||||
|
||||
//input shell task description
|
||||
public static final String Cc = "test.123qwe@qq.com"; |
||||
|
||||
public static final String EDIT_RECIPIENT = "test.edit123456@qq.com"; |
||||
|
||||
public static final String EDIT_Cc = "test.edit123qwe@qq.com"; |
||||
|
||||
public static final String WORKFLOW_TITLE = "工作流定义 - DolphinScheduler"; |
||||
public static final String TIMING_TITLE = "定时任务列表 - DolphinScheduler"; |
||||
} |
||||
@ -0,0 +1,48 @@
|
||||
/* |
||||
* Licensed to the Apache Software Foundation (ASF) under one or more |
||||
* contributor license agreements. See the NOTICE file distributed with |
||||
* this work for additional information regarding copyright ownership. |
||||
* The ASF licenses this file to You under the Apache License, Version 2.0 |
||||
* (the "License"); you may not use this file except in compliance with |
||||
* the License. You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
*/ |
||||
package org.apache.dolphinscheduler.locator.project; |
||||
|
||||
import org.openqa.selenium.By; |
||||
|
||||
public class RunWorkflowLocator { |
||||
/** |
||||
* run workflow |
||||
*/ |
||||
// click run workflow button
|
||||
public static final By CLICK_RUN_WORKFLOW_BUTTON = By.xpath("//div[1]/div/table/tr[2]/td[10]/button[2]"); |
||||
|
||||
//set running parameters
|
||||
public static final By SELECT_FAILURE_STRATEGY_END = By.xpath("//div[5]/div/div[2]/div/div[3]/div[2]/div/label[2]/span[1]/input"); |
||||
public static final By SELECT_FAILURE_STRATEGY_CONTINUE = By.xpath("//div[3]/div[2]/div/label[1]/span[1]/input"); |
||||
|
||||
public static final By CLICK_NOTICE_STRATEGY = By.xpath("//div[4]/div[2]/div/div[1]/div/input"); |
||||
public static final By SELECT_NOTICE_STRATEGY = By.xpath("//div/ul/li[4]/span"); |
||||
|
||||
public static final By CLICK_PROCESS_PRIORITY = By.xpath("//div/div/div/div/div/span[2]"); |
||||
public static final By SELECT_PROCESS_PRIORITY_HIGHEST = By.xpath("//li[1]/li/span"); |
||||
|
||||
public static final By CLICK_WORKER_GROUP = By.xpath("//div[6]/div[2]/div/div[1]/div/input"); |
||||
public static final By SELECT_WORKER_GROUP = By.xpath("//div[5]/div/div[2]/div/div[6]/div[2]/div/div[2]/div/div/div/ul/li/span"); |
||||
|
||||
public static final By CLICK_NOTICE_GROUP = By.xpath("//div[7]/div[2]/div/div[1]/div/input"); |
||||
public static final By SELECT_NOTICE_GROUP = By.xpath("//div[5]/div/div[2]/div/div[7]/div[2]/div/div[2]/div/div/div/ul/li/span"); |
||||
|
||||
public static final By INPUT_RECIPIENT = By.xpath("//div[8]/div[2]/div/div/span/span/input"); |
||||
public static final By INPUT_Cc = By.xpath("//div[9]/div[2]/div/div/span/span/input"); |
||||
|
||||
public static final By CLICK_RUNNING_BUTTON = By.xpath("//div[11]/button[2]"); |
||||
} |
||||
@ -0,0 +1,61 @@
|
||||
/* |
||||
* Licensed to the Apache Software Foundation (ASF) under one or more |
||||
* contributor license agreements. See the NOTICE file distributed with |
||||
* this work for additional information regarding copyright ownership. |
||||
* The ASF licenses this file to You under the Apache License, Version 2.0 |
||||
* (the "License"); you may not use this file except in compliance with |
||||
* the License. You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
*/ |
||||
package org.apache.dolphinscheduler.locator.project; |
||||
|
||||
import org.openqa.selenium.By; |
||||
|
||||
public class TimingLocator { |
||||
// create timing button
|
||||
public static final By CLICK_TIMING_BUTTON = By.xpath("//button[3]"); |
||||
|
||||
public static final By CLICK_EXECUTION_TIMING_BUTTON = By.xpath("//div[3]/button/span"); |
||||
|
||||
public static final By SELECT_FAILURE_STRATEGY_END = By.xpath("//label[2]/span/input"); |
||||
public static final By SELECT_FAILURE_STRATEGY_CONTINUE = By.xpath("//div[2]/div/label/span[2]"); |
||||
|
||||
public static final By CLICK_NOTICE_STRATEGY = By.xpath("//div[6]/div[2]/div/div/div/input"); |
||||
public static final By SELECT_NOTICE_STRATEGY = By.xpath("//div[2]/div/div/div/ul/li[4]/span"); |
||||
|
||||
public static final By CLICK_PROCESS_PRIORITY = By.xpath("//div[7]/div[2]/div/div/div/div/div/span[2]"); |
||||
public static final By SELECT_PROCESS_PRIORITY = By.xpath("//li/li/span"); |
||||
|
||||
public static final By CLICK_WORKER_GROUP = By.xpath("//div[8]/div[2]/div/div/div/input"); |
||||
public static final By SELECT_WORKER_GROUP = By.xpath("//div[8]/div[2]/div/div[2]/div/div/div/ul/li/span"); |
||||
|
||||
public static final By CLICK_NOTICE_GROUP = By.xpath("//div[9]/div[2]/div/div/div/input"); |
||||
public static final By SELECT_NOTICE_GROUP = By.xpath("//div[9]/div[2]/div/div[2]/div/div/div/ul/li/span"); |
||||
|
||||
public static final By INPUT_RECIPIENT = By.xpath("//div[10]/div[2]/div/div/span/span/input"); |
||||
public static final By INPUT_Cc = By.xpath("//div[11]/div[2]/div/div/span/span/input"); |
||||
|
||||
public static final By CLICK_CREATE_BUTTON = By.xpath("//div[12]/button[2]/span"); |
||||
|
||||
//edit timing
|
||||
public static final By CLICK_TIMING_MANAGEMENT_BUTTON = By.xpath("//div[2]/div/div[3]/div[1]/div/table/tr[2]/td[10]/button[6]"); |
||||
|
||||
public static final By CLICK_EDIT_TIMING_BUTTON = By.xpath("//div[2]/div[3]/div/div[2]/div[1]/table/tr[2]/td[10]/button[1]"); |
||||
|
||||
//online timing
|
||||
public static final By CLICK_ONLINE_TIMING_BUTTON = By.xpath("//td[10]/button[2]"); |
||||
|
||||
//offline timing
|
||||
public static final By CLICK_OFFLINE_TIMING_BUTTON = By.xpath("//div[2]/div[3]/div/div[2]/div[1]/table/tr[2]/td[10]/button[2]"); |
||||
|
||||
//delete timing
|
||||
public static final By CLICK_DELETE_TIMING_BUTTON = By.xpath("//div[2]/div[3]/div/div[2]/div[1]/table/tr[2]/td[10]/span/button"); |
||||
public static final By CLICK_CONFIRM_DELETE_TIMING_BUTTON = By.xpath("//div[2]/div/button[2]/span"); |
||||
} |
||||
@ -0,0 +1,53 @@
|
||||
/* |
||||
* Licensed to the Apache Software Foundation (ASF) under one or more |
||||
* contributor license agreements. See the NOTICE file distributed with |
||||
* this work for additional information regarding copyright ownership. |
||||
* The ASF licenses this file to You under the Apache License, Version 2.0 |
||||
* (the "License"); you may not use this file except in compliance with |
||||
* the License. You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
*/ |
||||
package org.apache.dolphinscheduler.page.project; |
||||
|
||||
import org.apache.dolphinscheduler.common.PageCommon; |
||||
import org.apache.dolphinscheduler.data.project.RunWorkflowData; |
||||
import org.apache.dolphinscheduler.locator.project.RunWorkflowLocator; |
||||
import org.openqa.selenium.WebDriver; |
||||
|
||||
public class RunWorkflowPage extends PageCommon { |
||||
public RunWorkflowPage(WebDriver driver) { |
||||
super(driver); |
||||
} |
||||
|
||||
public boolean runWorkflow() throws InterruptedException { |
||||
// click run workflow button
|
||||
System.out.println("Click run workflow button"); |
||||
Thread.sleep(1000); |
||||
clickButton(RunWorkflowLocator.CLICK_RUN_WORKFLOW_BUTTON); |
||||
Thread.sleep(1000); |
||||
|
||||
clickElement(RunWorkflowLocator.SELECT_FAILURE_STRATEGY_END); |
||||
clickElement(RunWorkflowLocator.SELECT_FAILURE_STRATEGY_CONTINUE); |
||||
clickElement(RunWorkflowLocator.CLICK_NOTICE_STRATEGY); |
||||
clickElement(RunWorkflowLocator.SELECT_NOTICE_STRATEGY); |
||||
Thread.sleep(500); |
||||
clickElement(RunWorkflowLocator.CLICK_PROCESS_PRIORITY); |
||||
clickElement(RunWorkflowLocator.SELECT_PROCESS_PRIORITY_HIGHEST); |
||||
clickElement(RunWorkflowLocator.CLICK_WORKER_GROUP); |
||||
clickElement(RunWorkflowLocator.SELECT_WORKER_GROUP); |
||||
clickElement(RunWorkflowLocator.CLICK_NOTICE_GROUP); |
||||
clickElement(RunWorkflowLocator.SELECT_NOTICE_GROUP); |
||||
sendInput(RunWorkflowLocator.INPUT_RECIPIENT, RunWorkflowData.RECIPIENT); |
||||
sendInput(RunWorkflowLocator.INPUT_Cc,RunWorkflowData.Cc); |
||||
clickButton(RunWorkflowLocator.CLICK_RUNNING_BUTTON); |
||||
|
||||
return ifTitleContains(RunWorkflowData.RUN_WORKFLOW_TITLE); |
||||
} |
||||
} |
||||
@ -0,0 +1,134 @@
|
||||
/* |
||||
* Licensed to the Apache Software Foundation (ASF) under one or more |
||||
* contributor license agreements. See the NOTICE file distributed with |
||||
* this work for additional information regarding copyright ownership. |
||||
* The ASF licenses this file to You under the Apache License, Version 2.0 |
||||
* (the "License"); you may not use this file except in compliance with |
||||
* the License. You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
*/ |
||||
package org.apache.dolphinscheduler.page.project; |
||||
|
||||
import org.apache.dolphinscheduler.common.PageCommon; |
||||
import org.apache.dolphinscheduler.data.project.TimingData; |
||||
import org.apache.dolphinscheduler.locator.project.RunWorkflowLocator; |
||||
import org.apache.dolphinscheduler.locator.project.TimingLocator; |
||||
import org.openqa.selenium.WebDriver; |
||||
|
||||
public class TimingPage extends PageCommon { |
||||
public TimingPage(WebDriver driver) { |
||||
super(driver); |
||||
} |
||||
|
||||
|
||||
/** |
||||
* create timing |
||||
*/ |
||||
public boolean createTiming() throws InterruptedException { |
||||
// click timing button
|
||||
System.out.println("Click timing button"); |
||||
Thread.sleep(1000); |
||||
clickButton(TimingLocator.CLICK_TIMING_BUTTON); |
||||
System.out.println("Click execution timing button"); |
||||
clickButton(TimingLocator.CLICK_EXECUTION_TIMING_BUTTON); |
||||
Thread.sleep(1000); |
||||
|
||||
clickElement(TimingLocator.SELECT_FAILURE_STRATEGY_END); |
||||
clickElement(TimingLocator.SELECT_FAILURE_STRATEGY_CONTINUE); |
||||
clickElement(TimingLocator.CLICK_NOTICE_STRATEGY); |
||||
clickElement(TimingLocator.SELECT_NOTICE_STRATEGY); |
||||
Thread.sleep(500); |
||||
clickElement(TimingLocator.CLICK_PROCESS_PRIORITY); |
||||
clickElement(TimingLocator.SELECT_PROCESS_PRIORITY); |
||||
clickElement(TimingLocator.CLICK_WORKER_GROUP); |
||||
clickElement(TimingLocator.SELECT_WORKER_GROUP); |
||||
clickElement(TimingLocator.CLICK_NOTICE_GROUP); |
||||
clickElement(TimingLocator.SELECT_NOTICE_GROUP); |
||||
sendInput(TimingLocator.INPUT_RECIPIENT, TimingData.RECIPIENT); |
||||
sendInput(TimingLocator.INPUT_Cc,TimingData.Cc); |
||||
clickButton(TimingLocator.CLICK_CREATE_BUTTON); |
||||
|
||||
return ifTitleContains(TimingData.WORKFLOW_TITLE); |
||||
} |
||||
|
||||
/** |
||||
* edit timing |
||||
*/ |
||||
public boolean editTiming() throws InterruptedException { |
||||
// click timing button
|
||||
System.out.println("Click timing management button"); |
||||
clickButton(TimingLocator.CLICK_TIMING_MANAGEMENT_BUTTON); |
||||
Thread.sleep(500); |
||||
System.out.println("Click edit timing button"); |
||||
clickButton(TimingLocator.CLICK_EDIT_TIMING_BUTTON); |
||||
Thread.sleep(500); |
||||
System.out.println("Click execution timing button"); |
||||
clickButton(TimingLocator.CLICK_EXECUTION_TIMING_BUTTON); |
||||
Thread.sleep(1000); |
||||
|
||||
clickElement(TimingLocator.SELECT_FAILURE_STRATEGY_END); |
||||
clickElement(TimingLocator.SELECT_FAILURE_STRATEGY_CONTINUE); |
||||
clickElement(TimingLocator.CLICK_NOTICE_STRATEGY); |
||||
clickElement(TimingLocator.SELECT_NOTICE_STRATEGY); |
||||
Thread.sleep(500); |
||||
clickElement(TimingLocator.CLICK_PROCESS_PRIORITY); |
||||
clickElement(TimingLocator.SELECT_PROCESS_PRIORITY); |
||||
clickElement(TimingLocator.CLICK_WORKER_GROUP); |
||||
clickElement(TimingLocator.SELECT_WORKER_GROUP); |
||||
clickElement(TimingLocator.CLICK_NOTICE_GROUP); |
||||
clickElement(TimingLocator.SELECT_NOTICE_GROUP); |
||||
sendInput(TimingLocator.INPUT_RECIPIENT, TimingData.EDIT_RECIPIENT); |
||||
sendInput(TimingLocator.INPUT_Cc,TimingData.EDIT_Cc); |
||||
clickButton(TimingLocator.CLICK_CREATE_BUTTON); |
||||
|
||||
return ifTitleContains(TimingData.TIMING_TITLE ); |
||||
} |
||||
|
||||
|
||||
/** |
||||
* online timing |
||||
*/ |
||||
public boolean onlineTiming() throws InterruptedException { |
||||
// click online timing button
|
||||
System.out.println("Click online timing button"); |
||||
Thread.sleep(500); |
||||
clickButton(TimingLocator.CLICK_ONLINE_TIMING_BUTTON); |
||||
|
||||
return ifTitleContains(TimingData.TIMING_TITLE ); |
||||
} |
||||
|
||||
|
||||
/** |
||||
* offline timing |
||||
*/ |
||||
public boolean offlineTiming() throws InterruptedException { |
||||
// click offline timing button
|
||||
System.out.println("Click offline timing button"); |
||||
Thread.sleep(500); |
||||
clickButton(TimingLocator.CLICK_OFFLINE_TIMING_BUTTON); |
||||
|
||||
return ifTitleContains(TimingData.TIMING_TITLE ); |
||||
} |
||||
|
||||
|
||||
|
||||
/** |
||||
* delete timing |
||||
*/ |
||||
public boolean deleteTiming() throws InterruptedException { |
||||
// click offline timing button
|
||||
System.out.println("Click delete timing button"); |
||||
Thread.sleep(500); |
||||
clickButton(TimingLocator.CLICK_DELETE_TIMING_BUTTON); |
||||
clickButton(TimingLocator.CLICK_CONFIRM_DELETE_TIMING_BUTTON); |
||||
|
||||
return ifTitleContains(TimingData.WORKFLOW_TITLE ); |
||||
} |
||||
} |
||||
@ -0,0 +1,41 @@
|
||||
/* |
||||
* Licensed to the Apache Software Foundation (ASF) under one or more |
||||
* contributor license agreements. See the NOTICE file distributed with |
||||
* this work for additional information regarding copyright ownership. |
||||
* The ASF licenses this file to You under the Apache License, Version 2.0 |
||||
* (the "License"); you may not use this file except in compliance with |
||||
* the License. You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
*/ |
||||
package org.apache.dolphinscheduler.testcase.testProject; |
||||
|
||||
import org.apache.dolphinscheduler.base.BaseTest; |
||||
import org.apache.dolphinscheduler.page.project.CreateProjectPage; |
||||
import org.apache.dolphinscheduler.page.project.CreateWorkflowPage; |
||||
import org.apache.dolphinscheduler.page.project.RunWorkflowPage; |
||||
import org.testng.annotations.Test; |
||||
|
||||
public class TestRunWorkflow extends BaseTest { |
||||
private CreateWorkflowPage createWorkflowPage; |
||||
private CreateProjectPage createProjectPage; |
||||
private RunWorkflowPage runWorkflowPage; |
||||
|
||||
|
||||
@Test(groups={"functionTests","runWorkflow"},dependsOnGroups = { "login","workflow" },description = "TestRunWorkflow") |
||||
public void testRunWorkflow() throws InterruptedException { |
||||
runWorkflowPage = new RunWorkflowPage(driver); |
||||
|
||||
createProjectPage = new CreateProjectPage(driver); |
||||
System.out.println("start run workflow"); |
||||
assert runWorkflowPage.runWorkflow(); |
||||
System.out.println("end run workflow"); |
||||
System.out.println("==================================="); |
||||
} |
||||
} |
||||
@ -0,0 +1,75 @@
|
||||
/* |
||||
* Licensed to the Apache Software Foundation (ASF) under one or more |
||||
* contributor license agreements. See the NOTICE file distributed with |
||||
* this work for additional information regarding copyright ownership. |
||||
* The ASF licenses this file to You under the Apache License, Version 2.0 |
||||
* (the "License"); you may not use this file except in compliance with |
||||
* the License. You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
*/ |
||||
package org.apache.dolphinscheduler.testcase.testProject; |
||||
|
||||
import org.apache.dolphinscheduler.base.BaseTest; |
||||
import org.apache.dolphinscheduler.page.project.TimingPage; |
||||
import org.testng.annotations.Test; |
||||
|
||||
public class TestTiming extends BaseTest { |
||||
private TimingPage timingPage; |
||||
|
||||
@Test(groups={"functionTests","createTiming"},dependsOnGroups = { "login","workflow"},description = "TestCreateTiming") |
||||
public void testCreateTiming() throws InterruptedException { |
||||
timingPage = new TimingPage(driver); |
||||
|
||||
System.out.println("start create timing"); |
||||
assert timingPage.createTiming(); |
||||
System.out.println("end create timing"); |
||||
System.out.println("==================================="); |
||||
|
||||
} |
||||
@Test(groups={"functionTests","timing"},dependsOnGroups = { "login","workflow"},description = "TestEditTiming") |
||||
public void testEditTiming() throws InterruptedException { |
||||
timingPage = new TimingPage(driver); |
||||
|
||||
System.out.println("start edit timing"); |
||||
assert timingPage.editTiming(); |
||||
System.out.println("end edit timing"); |
||||
System.out.println("==================================="); |
||||
} |
||||
|
||||
@Test(groups={"functionTests","timing"},dependsOnGroups = { "login","workflow" },description = "TestOnlineTiming") |
||||
public void testOnlineTiming() throws InterruptedException { |
||||
timingPage = new TimingPage(driver); |
||||
|
||||
System.out.println("start online timing"); |
||||
assert timingPage.onlineTiming(); |
||||
System.out.println("end online timing"); |
||||
System.out.println("==================================="); |
||||
} |
||||
|
||||
@Test(groups={"functionTests","timing"},dependsOnGroups = { "login","workflow"},description = "TestOfflineTiming") |
||||
public void testOfflineTiming() throws InterruptedException { |
||||
timingPage = new TimingPage(driver); |
||||
|
||||
System.out.println("start offline timing"); |
||||
assert timingPage.offlineTiming(); |
||||
System.out.println("end offline timing"); |
||||
System.out.println("==================================="); |
||||
} |
||||
|
||||
@Test(groups={"functionTests","timing"},dependsOnGroups = { "login","workflow"},description = "TestDeleteTiming") |
||||
public void testDeleteTiming() throws InterruptedException { |
||||
timingPage = new TimingPage(driver); |
||||
|
||||
System.out.println("start delete timing"); |
||||
assert timingPage.deleteTiming(); |
||||
System.out.println("end delete timing"); |
||||
System.out.println("==================================="); |
||||
} |
||||
} |
||||
Loading…
Reference in new issue