Merge pull request #285 from lgcareer/branch-1.0.2 (cca2877b) · Commits · SUMMER2020 / students / proj-2002251

escheduler-common/src/main/java/cn/escheduler/common/task/sql/SqlParameters.java

+14 −0

Original line number	Diff line number	Diff line
		@@ -73,6 +73,11 @@ public class SqlParameters extends AbstractParameters {
		*/
		private List<String> postStatements;

		/**
		* title
		*/
		private String title;

		/**
		* receivers
		*/
		@@ -139,6 +144,14 @@ public class SqlParameters extends AbstractParameters {
		this.connParams = connParams;
		}

		public String getTitle() {
		return title;
		}

		public void setTitle(String title) {
		this.title = title;
		}

		public String getReceivers() {
		return receivers;
		}
		@@ -190,6 +203,7 @@ public class SqlParameters extends AbstractParameters {
		", udfs='" + udfs + '\'' +
		", showType='" + showType + '\'' +
		", connParams='" + connParams + '\'' +
		", title='" + title + '\'' +
		", receivers='" + receivers + '\'' +
		", receiversCc='" + receiversCc + '\'' +
		", preStatements=" + preStatements +

+5 −1

Original line number	Diff line number	Diff line
		@@ -279,9 +279,13 @@ public class SqlTask extends AbstractTask {
		logger.info("showType is empty,don't need send email");
		} else {
		if (array.size() > 0) {
		if (StringUtils.isNotEmpty(sqlParameters.getTitle())) {
		sendAttachment(sqlParameters.getTitle(), JSONObject.toJSONString(array, SerializerFeature.WriteMapNullValue));
		}else{
		sendAttachment(taskProps.getNodeName() + " query resultsets ", JSONObject.toJSONString(array, SerializerFeature.WriteMapNullValue));
		}
		}
		}

		exitStatusCode = 0;