From ba5606e264b03d7752fbd6920e4925ba0b4a9b63 Mon Sep 17 00:00:00 2001 From: sdk-team Date: Fri, 26 May 2023 08:09:03 +0000 Subject: [PATCH] Modify ListTaskFlowsByPage API. Add output parameters: CronBeginDate, CronEndDate. Modified input parameter CronParam as ScheduleParam. --- aliyun-java-sdk-dms-enterprise/ChangeLog.txt | 3 + aliyun-java-sdk-dms-enterprise/pom.xml | 2 +- .../v20181101/AnalyzeSQLLineageRequest.java | 80 ++ .../v20181101/AnalyzeSQLLineageResponse.java | 242 ++++ .../model/v20181101/BackFillRequest.java | 14 + .../model/v20181101/BackFillResponse.java | 10 + .../GetDataArchiveOrderDetailRequest.java | 67 + .../GetDataArchiveOrderDetailResponse.java | 1184 +++++++++++++++++ .../model/v20181101/GetDatabaseResponse.java | 10 + .../GetPhysicalDatabaseResponse.java | 10 + .../ListTaskFlowInstanceRequest.java | 28 +- .../ListTaskFlowInstanceResponse.java | 10 + .../v20181101/ListTaskFlowsByPageRequest.java | 32 +- .../ListTaskFlowsByPageResponse.java | 90 ++ ...AnalyzeSQLLineageResponseUnmarshaller.java | 80 ++ .../BackFillResponseUnmarshaller.java | 1 + ...rchiveOrderDetailResponseUnmarshaller.java | 215 +++ .../GetDatabaseResponseUnmarshaller.java | 1 + ...tPhysicalDatabaseResponseUnmarshaller.java | 1 + ...tTaskFlowInstanceResponseUnmarshaller.java | 1 + ...stTaskFlowsByPageResponseUnmarshaller.java | 9 + 21 files changed, 2087 insertions(+), 3 deletions(-) create mode 100644 aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/AnalyzeSQLLineageRequest.java create mode 100644 aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/AnalyzeSQLLineageResponse.java create mode 100644 aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/GetDataArchiveOrderDetailRequest.java create mode 100644 aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/GetDataArchiveOrderDetailResponse.java create mode 100644 aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/AnalyzeSQLLineageResponseUnmarshaller.java create mode 100644 aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/GetDataArchiveOrderDetailResponseUnmarshaller.java diff --git a/aliyun-java-sdk-dms-enterprise/ChangeLog.txt b/aliyun-java-sdk-dms-enterprise/ChangeLog.txt index f99ba24095..1de02fda1c 100644 --- a/aliyun-java-sdk-dms-enterprise/ChangeLog.txt +++ b/aliyun-java-sdk-dms-enterprise/ChangeLog.txt @@ -1,3 +1,6 @@ +2023-05-26 Version: 1.49.0 +- Modify ListTaskFlowsByPage API. Add output parameters: CronBeginDate, CronEndDate. Modified input parameter CronParam as ScheduleParam. + 2023-05-15 Version: 1.48.0 - Support SkipDataCorrectRowCheck API. diff --git a/aliyun-java-sdk-dms-enterprise/pom.xml b/aliyun-java-sdk-dms-enterprise/pom.xml index d37683545c..9234ca4559 100644 --- a/aliyun-java-sdk-dms-enterprise/pom.xml +++ b/aliyun-java-sdk-dms-enterprise/pom.xml @@ -4,7 +4,7 @@ com.aliyun aliyun-java-sdk-dms-enterprise jar - 1.48.0 + 1.49.0 aliyun-java-sdk-dms-enterprise http://www.aliyun.com Aliyun Open API SDK for Java diff --git a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/AnalyzeSQLLineageRequest.java b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/AnalyzeSQLLineageRequest.java new file mode 100644 index 0000000000..e84ace83ca --- /dev/null +++ b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/AnalyzeSQLLineageRequest.java @@ -0,0 +1,80 @@ +/* + * 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. + */ + +package com.aliyuncs.dms_enterprise.model.v20181101; + +import com.aliyuncs.RpcAcsRequest; +import com.aliyuncs.http.MethodType; +import com.aliyuncs.dms_enterprise.Endpoint; + +/** + * @author auto create + * @version + */ +public class AnalyzeSQLLineageRequest extends RpcAcsRequest { + + + private String sqlContent; + + private Long tid; + + private Long dbId; + public AnalyzeSQLLineageRequest() { + super("dms-enterprise", "2018-11-01", "AnalyzeSQLLineage", "dms-enterprise"); + setMethod(MethodType.POST); + try { + com.aliyuncs.AcsRequest.class.getDeclaredField("productEndpointMap").set(this, Endpoint.endpointMap); + com.aliyuncs.AcsRequest.class.getDeclaredField("productEndpointRegional").set(this, Endpoint.endpointRegionalType); + } catch (Exception e) {} + } + + public String getSqlContent() { + return this.sqlContent; + } + + public void setSqlContent(String sqlContent) { + this.sqlContent = sqlContent; + if(sqlContent != null){ + putQueryParameter("SqlContent", sqlContent); + } + } + + public Long getTid() { + return this.tid; + } + + public void setTid(Long tid) { + this.tid = tid; + if(tid != null){ + putQueryParameter("Tid", tid.toString()); + } + } + + public Long getDbId() { + return this.dbId; + } + + public void setDbId(Long dbId) { + this.dbId = dbId; + if(dbId != null){ + putQueryParameter("DbId", dbId.toString()); + } + } + + @Override + public Class getResponseClass() { + return AnalyzeSQLLineageResponse.class; + } + +} diff --git a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/AnalyzeSQLLineageResponse.java b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/AnalyzeSQLLineageResponse.java new file mode 100644 index 0000000000..1c4d18a1c3 --- /dev/null +++ b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/AnalyzeSQLLineageResponse.java @@ -0,0 +1,242 @@ +/* + * 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. + */ + +package com.aliyuncs.dms_enterprise.model.v20181101; + +import java.util.List; +import com.aliyuncs.AcsResponse; +import com.aliyuncs.dms_enterprise.transform.v20181101.AnalyzeSQLLineageResponseUnmarshaller; +import com.aliyuncs.transform.UnmarshallerContext; + +/** + * @author auto create + * @version + */ +public class AnalyzeSQLLineageResponse extends AcsResponse { + + private String requestId; + + private Boolean success; + + private String errorMessage; + + private String errorCode; + + private LineageResult lineageResult; + + public String getRequestId() { + return this.requestId; + } + + public void setRequestId(String requestId) { + this.requestId = requestId; + } + + public Boolean getSuccess() { + return this.success; + } + + public void setSuccess(Boolean success) { + this.success = success; + } + + public String getErrorMessage() { + return this.errorMessage; + } + + public void setErrorMessage(String errorMessage) { + this.errorMessage = errorMessage; + } + + public String getErrorCode() { + return this.errorCode; + } + + public void setErrorCode(String errorCode) { + this.errorCode = errorCode; + } + + public LineageResult getLineageResult() { + return this.lineageResult; + } + + public void setLineageResult(LineageResult lineageResult) { + this.lineageResult = lineageResult; + } + + public static class LineageResult { + + private List lineages; + + private List objectMetadata; + + public List getLineages() { + return this.lineages; + } + + public void setLineages(List lineages) { + this.lineages = lineages; + } + + public List getObjectMetadata() { + return this.objectMetadata; + } + + public void setObjectMetadata(List objectMetadata) { + this.objectMetadata = objectMetadata; + } + + public static class LineageItem { + + private String lineageType; + + private String src; + + private String dst; + + private String operType; + + private ProcessDetail processDetail; + + public String getLineageType() { + return this.lineageType; + } + + public void setLineageType(String lineageType) { + this.lineageType = lineageType; + } + + public String getSrc() { + return this.src; + } + + public void setSrc(String src) { + this.src = src; + } + + public String getDst() { + return this.dst; + } + + public void setDst(String dst) { + this.dst = dst; + } + + public String getOperType() { + return this.operType; + } + + public void setOperType(String operType) { + this.operType = operType; + } + + public ProcessDetail getProcessDetail() { + return this.processDetail; + } + + public void setProcessDetail(ProcessDetail processDetail) { + this.processDetail = processDetail; + } + + public static class ProcessDetail { + + private String code; + + private String calWay; + + public String getCode() { + return this.code; + } + + public void setCode(String code) { + this.code = code; + } + + public String getCalWay() { + return this.calWay; + } + + public void setCalWay(String calWay) { + this.calWay = calWay; + } + } + } + + public static class ObjectMetadataItem { + + private String name; + + private String type; + + private String source; + + private List fields; + + public String getName() { + return this.name; + } + + public void setName(String name) { + this.name = name; + } + + public String getType() { + return this.type; + } + + public void setType(String type) { + this.type = type; + } + + public String getSource() { + return this.source; + } + + public void setSource(String source) { + this.source = source; + } + + public List getFields() { + return this.fields; + } + + public void setFields(List fields) { + this.fields = fields; + } + + public static class Field { + + private String name; + + public String getName() { + return this.name; + } + + public void setName(String name) { + this.name = name; + } + } + } + } + + @Override + public AnalyzeSQLLineageResponse getInstance(UnmarshallerContext context) { + return AnalyzeSQLLineageResponseUnmarshaller.unmarshall(this, context); + } + + @Override + public boolean checkShowJsonItemName() { + return false; + } +} diff --git a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/BackFillRequest.java b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/BackFillRequest.java index b554a397ed..cd38ad600b 100644 --- a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/BackFillRequest.java +++ b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/BackFillRequest.java @@ -41,6 +41,9 @@ public class BackFillRequest extends RpcAcsRequest { @SerializedName("startNodeIds") private List startNodeIds; + @SerializedName("filterNodeIds") + private List filterNodeIds; + private String backFillDateBegin; private String backFillDate; @@ -123,6 +126,17 @@ public void setStartNodeIds(List startNodeIds) { } } + public List getFilterNodeIds() { + return this.filterNodeIds; + } + + public void setFilterNodeIds(List filterNodeIds) { + this.filterNodeIds = filterNodeIds; + if (filterNodeIds != null) { + putQueryParameter("FilterNodeIds" , new Gson().toJson(filterNodeIds)); + } + } + public String getBackFillDateBegin() { return this.backFillDateBegin; } diff --git a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/BackFillResponse.java b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/BackFillResponse.java index 734eb7cad0..267bd6f342 100644 --- a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/BackFillResponse.java +++ b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/BackFillResponse.java @@ -32,6 +32,8 @@ public class BackFillResponse extends AcsResponse { private Boolean success; + private Long dagInstanceId; + private Long nodeId; public String getRequestId() { @@ -66,6 +68,14 @@ public void setSuccess(Boolean success) { this.success = success; } + public Long getDagInstanceId() { + return this.dagInstanceId; + } + + public void setDagInstanceId(Long dagInstanceId) { + this.dagInstanceId = dagInstanceId; + } + public Long getNodeId() { return this.nodeId; } diff --git a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/GetDataArchiveOrderDetailRequest.java b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/GetDataArchiveOrderDetailRequest.java new file mode 100644 index 0000000000..028797f1e1 --- /dev/null +++ b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/GetDataArchiveOrderDetailRequest.java @@ -0,0 +1,67 @@ +/* + * 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. + */ + +package com.aliyuncs.dms_enterprise.model.v20181101; + +import com.aliyuncs.RpcAcsRequest; +import com.aliyuncs.http.MethodType; +import com.aliyuncs.dms_enterprise.Endpoint; + +/** + * @author auto create + * @version + */ +public class GetDataArchiveOrderDetailRequest extends RpcAcsRequest { + + + private Long tid; + + private Long orderId; + public GetDataArchiveOrderDetailRequest() { + super("dms-enterprise", "2018-11-01", "GetDataArchiveOrderDetail", "dms-enterprise"); + setMethod(MethodType.POST); + try { + com.aliyuncs.AcsRequest.class.getDeclaredField("productEndpointMap").set(this, Endpoint.endpointMap); + com.aliyuncs.AcsRequest.class.getDeclaredField("productEndpointRegional").set(this, Endpoint.endpointRegionalType); + } catch (Exception e) {} + } + + public Long getTid() { + return this.tid; + } + + public void setTid(Long tid) { + this.tid = tid; + if(tid != null){ + putQueryParameter("Tid", tid.toString()); + } + } + + public Long getOrderId() { + return this.orderId; + } + + public void setOrderId(Long orderId) { + this.orderId = orderId; + if(orderId != null){ + putQueryParameter("OrderId", orderId.toString()); + } + } + + @Override + public Class getResponseClass() { + return GetDataArchiveOrderDetailResponse.class; + } + +} diff --git a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/GetDataArchiveOrderDetailResponse.java b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/GetDataArchiveOrderDetailResponse.java new file mode 100644 index 0000000000..f998202a81 --- /dev/null +++ b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/GetDataArchiveOrderDetailResponse.java @@ -0,0 +1,1184 @@ +/* + * 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. + */ + +package com.aliyuncs.dms_enterprise.model.v20181101; + +import java.util.List; +import com.aliyuncs.AcsResponse; +import com.aliyuncs.dms_enterprise.transform.v20181101.GetDataArchiveOrderDetailResponseUnmarshaller; +import com.aliyuncs.transform.UnmarshallerContext; + +/** + * @author auto create + * @version + */ +public class GetDataArchiveOrderDetailResponse extends AcsResponse { + + private String traceId; + + private Boolean success; + + private String errorMessage; + + private String errorCode; + + private String requestId; + + private DataArchiveOrderDetail dataArchiveOrderDetail; + + public String getTraceId() { + return this.traceId; + } + + public void setTraceId(String traceId) { + this.traceId = traceId; + } + + public Boolean getSuccess() { + return this.success; + } + + public void setSuccess(Boolean success) { + this.success = success; + } + + public String getErrorMessage() { + return this.errorMessage; + } + + public void setErrorMessage(String errorMessage) { + this.errorMessage = errorMessage; + } + + public String getErrorCode() { + return this.errorCode; + } + + public void setErrorCode(String errorCode) { + this.errorCode = errorCode; + } + + public String getRequestId() { + return this.requestId; + } + + public void setRequestId(String requestId) { + this.requestId = requestId; + } + + public DataArchiveOrderDetail getDataArchiveOrderDetail() { + return this.dataArchiveOrderDetail; + } + + public void setDataArchiveOrderDetail(DataArchiveOrderDetail dataArchiveOrderDetail) { + this.dataArchiveOrderDetail = dataArchiveOrderDetail; + } + + public static class DataArchiveOrderDetail { + + private String comment; + + private String committer; + + private Long committerId; + + private String gmtCreate; + + private String gmtModified; + + private Long id; + + private String pluginType; + + private String statusCode; + + private String statusDesc; + + private Long workflowInstanceId; + + private String workflowStatusDesc; + + private List relatedUserList; + + private List relatedUserNickList; + + private PluginExtraData pluginExtraData; + + private PluginParam pluginParam; + + public String getComment() { + return this.comment; + } + + public void setComment(String comment) { + this.comment = comment; + } + + public String getCommitter() { + return this.committer; + } + + public void setCommitter(String committer) { + this.committer = committer; + } + + public Long getCommitterId() { + return this.committerId; + } + + public void setCommitterId(Long committerId) { + this.committerId = committerId; + } + + public String getGmtCreate() { + return this.gmtCreate; + } + + public void setGmtCreate(String gmtCreate) { + this.gmtCreate = gmtCreate; + } + + public String getGmtModified() { + return this.gmtModified; + } + + public void setGmtModified(String gmtModified) { + this.gmtModified = gmtModified; + } + + public Long getId() { + return this.id; + } + + public void setId(Long id) { + this.id = id; + } + + public String getPluginType() { + return this.pluginType; + } + + public void setPluginType(String pluginType) { + this.pluginType = pluginType; + } + + public String getStatusCode() { + return this.statusCode; + } + + public void setStatusCode(String statusCode) { + this.statusCode = statusCode; + } + + public String getStatusDesc() { + return this.statusDesc; + } + + public void setStatusDesc(String statusDesc) { + this.statusDesc = statusDesc; + } + + public Long getWorkflowInstanceId() { + return this.workflowInstanceId; + } + + public void setWorkflowInstanceId(Long workflowInstanceId) { + this.workflowInstanceId = workflowInstanceId; + } + + public String getWorkflowStatusDesc() { + return this.workflowStatusDesc; + } + + public void setWorkflowStatusDesc(String workflowStatusDesc) { + this.workflowStatusDesc = workflowStatusDesc; + } + + public List getRelatedUserList() { + return this.relatedUserList; + } + + public void setRelatedUserList(List relatedUserList) { + this.relatedUserList = relatedUserList; + } + + public List getRelatedUserNickList() { + return this.relatedUserNickList; + } + + public void setRelatedUserNickList(List relatedUserNickList) { + this.relatedUserNickList = relatedUserNickList; + } + + public PluginExtraData getPluginExtraData() { + return this.pluginExtraData; + } + + public void setPluginExtraData(PluginExtraData pluginExtraData) { + this.pluginExtraData = pluginExtraData; + } + + public PluginParam getPluginParam() { + return this.pluginParam; + } + + public void setPluginParam(PluginParam pluginParam) { + this.pluginParam = pluginParam; + } + + public static class PluginExtraData { + + private Long instanceTotal; + + private Long pageIndex; + + private Long pageSize; + + private List instances; + + private DagInfo dagInfo; + + private DbBaseInfo dbBaseInfo; + + private NextFireTimeResult nextFireTimeResult; + + public Long getInstanceTotal() { + return this.instanceTotal; + } + + public void setInstanceTotal(Long instanceTotal) { + this.instanceTotal = instanceTotal; + } + + public Long getPageIndex() { + return this.pageIndex; + } + + public void setPageIndex(Long pageIndex) { + this.pageIndex = pageIndex; + } + + public Long getPageSize() { + return this.pageSize; + } + + public void setPageSize(Long pageSize) { + this.pageSize = pageSize; + } + + public List getInstances() { + return this.instances; + } + + public void setInstances(List instances) { + this.instances = instances; + } + + public DagInfo getDagInfo() { + return this.dagInfo; + } + + public void setDagInfo(DagInfo dagInfo) { + this.dagInfo = dagInfo; + } + + public DbBaseInfo getDbBaseInfo() { + return this.dbBaseInfo; + } + + public void setDbBaseInfo(DbBaseInfo dbBaseInfo) { + this.dbBaseInfo = dbBaseInfo; + } + + public NextFireTimeResult getNextFireTimeResult() { + return this.nextFireTimeResult; + } + + public void setNextFireTimeResult(NextFireTimeResult nextFireTimeResult) { + this.nextFireTimeResult = nextFireTimeResult; + } + + public static class InstancesItem { + + private String businessTime; + + private Long dagId; + + private String endTime; + + private String gmtCreate; + + private String gmtModified; + + private Long historyDagId; + + private Long id; + + private String lastRunningContext; + + private String msg; + + private Long status; + + private String tenantId; + + private Long triggerType; + + private String version; + + public String getBusinessTime() { + return this.businessTime; + } + + public void setBusinessTime(String businessTime) { + this.businessTime = businessTime; + } + + public Long getDagId() { + return this.dagId; + } + + public void setDagId(Long dagId) { + this.dagId = dagId; + } + + public String getEndTime() { + return this.endTime; + } + + public void setEndTime(String endTime) { + this.endTime = endTime; + } + + public String getGmtCreate() { + return this.gmtCreate; + } + + public void setGmtCreate(String gmtCreate) { + this.gmtCreate = gmtCreate; + } + + public String getGmtModified() { + return this.gmtModified; + } + + public void setGmtModified(String gmtModified) { + this.gmtModified = gmtModified; + } + + public Long getHistoryDagId() { + return this.historyDagId; + } + + public void setHistoryDagId(Long historyDagId) { + this.historyDagId = historyDagId; + } + + public Long getId() { + return this.id; + } + + public void setId(Long id) { + this.id = id; + } + + public String getLastRunningContext() { + return this.lastRunningContext; + } + + public void setLastRunningContext(String lastRunningContext) { + this.lastRunningContext = lastRunningContext; + } + + public String getMsg() { + return this.msg; + } + + public void setMsg(String msg) { + this.msg = msg; + } + + public Long getStatus() { + return this.status; + } + + public void setStatus(Long status) { + this.status = status; + } + + public String getTenantId() { + return this.tenantId; + } + + public void setTenantId(String tenantId) { + this.tenantId = tenantId; + } + + public Long getTriggerType() { + return this.triggerType; + } + + public void setTriggerType(Long triggerType) { + this.triggerType = triggerType; + } + + public String getVersion() { + return this.version; + } + + public void setVersion(String version) { + this.version = version; + } + } + + public static class DagInfo { + + private String creatorId; + + private String cronBeginDate; + + private String cronEndDate; + + private Boolean cronTrigger; + + private Boolean dWDevelop; + + private String dagName; + + private String dagOwnerId; + + private Long deployId; + + private String description; + + private Long editDagId; + + private String gmtCreate; + + private String gmtModified; + + private Long id; + + private Long isPublic; + + private Boolean legacy; + + private Boolean system; + + private String tenantId; + + private Boolean triggerOnce; + + public String getCreatorId() { + return this.creatorId; + } + + public void setCreatorId(String creatorId) { + this.creatorId = creatorId; + } + + public String getCronBeginDate() { + return this.cronBeginDate; + } + + public void setCronBeginDate(String cronBeginDate) { + this.cronBeginDate = cronBeginDate; + } + + public String getCronEndDate() { + return this.cronEndDate; + } + + public void setCronEndDate(String cronEndDate) { + this.cronEndDate = cronEndDate; + } + + public Boolean getCronTrigger() { + return this.cronTrigger; + } + + public void setCronTrigger(Boolean cronTrigger) { + this.cronTrigger = cronTrigger; + } + + public Boolean getDWDevelop() { + return this.dWDevelop; + } + + public void setDWDevelop(Boolean dWDevelop) { + this.dWDevelop = dWDevelop; + } + + public String getDagName() { + return this.dagName; + } + + public void setDagName(String dagName) { + this.dagName = dagName; + } + + public String getDagOwnerId() { + return this.dagOwnerId; + } + + public void setDagOwnerId(String dagOwnerId) { + this.dagOwnerId = dagOwnerId; + } + + public Long getDeployId() { + return this.deployId; + } + + public void setDeployId(Long deployId) { + this.deployId = deployId; + } + + public String getDescription() { + return this.description; + } + + public void setDescription(String description) { + this.description = description; + } + + public Long getEditDagId() { + return this.editDagId; + } + + public void setEditDagId(Long editDagId) { + this.editDagId = editDagId; + } + + public String getGmtCreate() { + return this.gmtCreate; + } + + public void setGmtCreate(String gmtCreate) { + this.gmtCreate = gmtCreate; + } + + public String getGmtModified() { + return this.gmtModified; + } + + public void setGmtModified(String gmtModified) { + this.gmtModified = gmtModified; + } + + public Long getId() { + return this.id; + } + + public void setId(Long id) { + this.id = id; + } + + public Long getIsPublic() { + return this.isPublic; + } + + public void setIsPublic(Long isPublic) { + this.isPublic = isPublic; + } + + public Boolean getLegacy() { + return this.legacy; + } + + public void setLegacy(Boolean legacy) { + this.legacy = legacy; + } + + public Boolean getSystem() { + return this.system; + } + + public void setSystem(Boolean system) { + this.system = system; + } + + public String getTenantId() { + return this.tenantId; + } + + public void setTenantId(String tenantId) { + this.tenantId = tenantId; + } + + public Boolean getTriggerOnce() { + return this.triggerOnce; + } + + public void setTriggerOnce(Boolean triggerOnce) { + this.triggerOnce = triggerOnce; + } + } + + public static class DbBaseInfo { + + private String alias; + + private Long alterTimeout; + + private Boolean assetControl; + + private String catalogName; + + private String clusterNode; + + private Long dbId; + + private String dbType; + + private Long dbaId; + + private String dbaName; + + private String description; + + private String encoding; + + private String envType; + + private Boolean follow; + + private String host; + + private String idc; + + private String idcTitle; + + private Long instanceId; + + private String instanceSource; + + private String lastSyncTime; + + private String level; + + private Boolean logic; + + private Long port; + + private String schemaName; + + private String searchName; + + private String state; + + private Long tableCount; + + private String tnsName; + + private String unitType; + + private List ownerIds; + + private List ownerNames; + + private StandardGroup standardGroup; + + public String getAlias() { + return this.alias; + } + + public void setAlias(String alias) { + this.alias = alias; + } + + public Long getAlterTimeout() { + return this.alterTimeout; + } + + public void setAlterTimeout(Long alterTimeout) { + this.alterTimeout = alterTimeout; + } + + public Boolean getAssetControl() { + return this.assetControl; + } + + public void setAssetControl(Boolean assetControl) { + this.assetControl = assetControl; + } + + public String getCatalogName() { + return this.catalogName; + } + + public void setCatalogName(String catalogName) { + this.catalogName = catalogName; + } + + public String getClusterNode() { + return this.clusterNode; + } + + public void setClusterNode(String clusterNode) { + this.clusterNode = clusterNode; + } + + public Long getDbId() { + return this.dbId; + } + + public void setDbId(Long dbId) { + this.dbId = dbId; + } + + public String getDbType() { + return this.dbType; + } + + public void setDbType(String dbType) { + this.dbType = dbType; + } + + public Long getDbaId() { + return this.dbaId; + } + + public void setDbaId(Long dbaId) { + this.dbaId = dbaId; + } + + public String getDbaName() { + return this.dbaName; + } + + public void setDbaName(String dbaName) { + this.dbaName = dbaName; + } + + public String getDescription() { + return this.description; + } + + public void setDescription(String description) { + this.description = description; + } + + public String getEncoding() { + return this.encoding; + } + + public void setEncoding(String encoding) { + this.encoding = encoding; + } + + public String getEnvType() { + return this.envType; + } + + public void setEnvType(String envType) { + this.envType = envType; + } + + public Boolean getFollow() { + return this.follow; + } + + public void setFollow(Boolean follow) { + this.follow = follow; + } + + public String getHost() { + return this.host; + } + + public void setHost(String host) { + this.host = host; + } + + public String getIdc() { + return this.idc; + } + + public void setIdc(String idc) { + this.idc = idc; + } + + public String getIdcTitle() { + return this.idcTitle; + } + + public void setIdcTitle(String idcTitle) { + this.idcTitle = idcTitle; + } + + public Long getInstanceId() { + return this.instanceId; + } + + public void setInstanceId(Long instanceId) { + this.instanceId = instanceId; + } + + public String getInstanceSource() { + return this.instanceSource; + } + + public void setInstanceSource(String instanceSource) { + this.instanceSource = instanceSource; + } + + public String getLastSyncTime() { + return this.lastSyncTime; + } + + public void setLastSyncTime(String lastSyncTime) { + this.lastSyncTime = lastSyncTime; + } + + public String getLevel() { + return this.level; + } + + public void setLevel(String level) { + this.level = level; + } + + public Boolean getLogic() { + return this.logic; + } + + public void setLogic(Boolean logic) { + this.logic = logic; + } + + public Long getPort() { + return this.port; + } + + public void setPort(Long port) { + this.port = port; + } + + public String getSchemaName() { + return this.schemaName; + } + + public void setSchemaName(String schemaName) { + this.schemaName = schemaName; + } + + public String getSearchName() { + return this.searchName; + } + + public void setSearchName(String searchName) { + this.searchName = searchName; + } + + public String getState() { + return this.state; + } + + public void setState(String state) { + this.state = state; + } + + public Long getTableCount() { + return this.tableCount; + } + + public void setTableCount(Long tableCount) { + this.tableCount = tableCount; + } + + public String getTnsName() { + return this.tnsName; + } + + public void setTnsName(String tnsName) { + this.tnsName = tnsName; + } + + public String getUnitType() { + return this.unitType; + } + + public void setUnitType(String unitType) { + this.unitType = unitType; + } + + public List getOwnerIds() { + return this.ownerIds; + } + + public void setOwnerIds(List ownerIds) { + this.ownerIds = ownerIds; + } + + public List getOwnerNames() { + return this.ownerNames; + } + + public void setOwnerNames(List ownerNames) { + this.ownerNames = ownerNames; + } + + public StandardGroup getStandardGroup() { + return this.standardGroup; + } + + public void setStandardGroup(StandardGroup standardGroup) { + this.standardGroup = standardGroup; + } + + public static class StandardGroup { + + private String dbType; + + private String description; + + private Boolean freeOrStable; + + private String gmtCreate; + + private String gmtModified; + + private String groupMode; + + private String groupName; + + private Long id; + + private Long lastMenderId; + + public String getDbType() { + return this.dbType; + } + + public void setDbType(String dbType) { + this.dbType = dbType; + } + + public String getDescription() { + return this.description; + } + + public void setDescription(String description) { + this.description = description; + } + + public Boolean getFreeOrStable() { + return this.freeOrStable; + } + + public void setFreeOrStable(Boolean freeOrStable) { + this.freeOrStable = freeOrStable; + } + + public String getGmtCreate() { + return this.gmtCreate; + } + + public void setGmtCreate(String gmtCreate) { + this.gmtCreate = gmtCreate; + } + + public String getGmtModified() { + return this.gmtModified; + } + + public void setGmtModified(String gmtModified) { + this.gmtModified = gmtModified; + } + + public String getGroupMode() { + return this.groupMode; + } + + public void setGroupMode(String groupMode) { + this.groupMode = groupMode; + } + + public String getGroupName() { + return this.groupName; + } + + public void setGroupName(String groupName) { + this.groupName = groupName; + } + + public Long getId() { + return this.id; + } + + public void setId(Long id) { + this.id = id; + } + + public Long getLastMenderId() { + return this.lastMenderId; + } + + public void setLastMenderId(Long lastMenderId) { + this.lastMenderId = lastMenderId; + } + } + } + + public static class NextFireTimeResult { + + private String cronFireType; + + public String getCronFireType() { + return this.cronFireType; + } + + public void setCronFireType(String cronFireType) { + this.cronFireType = cronFireType; + } + } + } + + public static class PluginParam { + + private String archiveMethod; + + private String dbSchema; + + private Boolean logic; + + private String runMethod; + + private Long sourceDatabaseId; + + private String targetInstanceId; + + private List tableIncludes; + + private List orderAfter; + + private List tableMapping; + + private List variables; + + public String getArchiveMethod() { + return this.archiveMethod; + } + + public void setArchiveMethod(String archiveMethod) { + this.archiveMethod = archiveMethod; + } + + public String getDbSchema() { + return this.dbSchema; + } + + public void setDbSchema(String dbSchema) { + this.dbSchema = dbSchema; + } + + public Boolean getLogic() { + return this.logic; + } + + public void setLogic(Boolean logic) { + this.logic = logic; + } + + public String getRunMethod() { + return this.runMethod; + } + + public void setRunMethod(String runMethod) { + this.runMethod = runMethod; + } + + public Long getSourceDatabaseId() { + return this.sourceDatabaseId; + } + + public void setSourceDatabaseId(Long sourceDatabaseId) { + this.sourceDatabaseId = sourceDatabaseId; + } + + public String getTargetInstanceId() { + return this.targetInstanceId; + } + + public void setTargetInstanceId(String targetInstanceId) { + this.targetInstanceId = targetInstanceId; + } + + public List getTableIncludes() { + return this.tableIncludes; + } + + public void setTableIncludes(List tableIncludes) { + this.tableIncludes = tableIncludes; + } + + public List getOrderAfter() { + return this.orderAfter; + } + + public void setOrderAfter(List orderAfter) { + this.orderAfter = orderAfter; + } + + public List getTableMapping() { + return this.tableMapping; + } + + public void setTableMapping(List tableMapping) { + this.tableMapping = tableMapping; + } + + public List getVariables() { + return this.variables; + } + + public void setVariables(List variables) { + this.variables = variables; + } + + public static class IncludeTables { + + private String tableName; + + private String tableWhere; + + public String getTableName() { + return this.tableName; + } + + public void setTableName(String tableName) { + this.tableName = tableName; + } + + public String getTableWhere() { + return this.tableWhere; + } + + public void setTableWhere(String tableWhere) { + this.tableWhere = tableWhere; + } + } + } + } + + @Override + public GetDataArchiveOrderDetailResponse getInstance(UnmarshallerContext context) { + return GetDataArchiveOrderDetailResponseUnmarshaller.unmarshall(this, context); + } + + @Override + public boolean checkShowJsonItemName() { + return false; + } +} diff --git a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/GetDatabaseResponse.java b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/GetDatabaseResponse.java index 8880bcdedc..cbd8e52e5c 100644 --- a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/GetDatabaseResponse.java +++ b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/GetDatabaseResponse.java @@ -105,6 +105,8 @@ public static class Database { private String searchName; + private String instanceAlias; + private List ownerIdList; private List ownerNameList; @@ -221,6 +223,14 @@ public void setSearchName(String searchName) { this.searchName = searchName; } + public String getInstanceAlias() { + return this.instanceAlias; + } + + public void setInstanceAlias(String instanceAlias) { + this.instanceAlias = instanceAlias; + } + public List getOwnerIdList() { return this.ownerIdList; } diff --git a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/GetPhysicalDatabaseResponse.java b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/GetPhysicalDatabaseResponse.java index a089b890f0..3bdda2b0f4 100644 --- a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/GetPhysicalDatabaseResponse.java +++ b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/GetPhysicalDatabaseResponse.java @@ -105,6 +105,8 @@ public static class Database { private String searchName; + private String instanceAlias; + private List ownerIdList; private List ownerNameList; @@ -221,6 +223,14 @@ public void setSearchName(String searchName) { this.searchName = searchName; } + public String getInstanceAlias() { + return this.instanceAlias; + } + + public void setInstanceAlias(String instanceAlias) { + this.instanceAlias = instanceAlias; + } + public List getOwnerIdList() { return this.ownerIdList; } diff --git a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/ListTaskFlowInstanceRequest.java b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/ListTaskFlowInstanceRequest.java index f74764ffd3..d7842b4df8 100644 --- a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/ListTaskFlowInstanceRequest.java +++ b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/ListTaskFlowInstanceRequest.java @@ -25,6 +25,8 @@ public class ListTaskFlowInstanceRequest extends RpcAcsRequest { + private Boolean useBizDate; + private Integer triggerType; private Long dagId; @@ -37,7 +39,9 @@ public class ListTaskFlowInstanceRequest extends RpcAcsRequest dagIdList; + private Long tid; private Integer pageSize; - private Integer pageIndex; + private Integer pageIndex; + + private Long scenarioId; public ListTaskFlowsByPageRequest() { super("dms-enterprise", "2018-11-01", "ListTaskFlowsByPage", "dms-enterprise"); setMethod(MethodType.POST); @@ -52,6 +60,17 @@ public void setSearchKey(String searchKey) { } } + public List getDagIdList() { + return this.dagIdList; + } + + public void setDagIdList(List dagIdList) { + this.dagIdList = dagIdList; + if (dagIdList != null) { + putQueryParameter("DagIdList" , new Gson().toJson(dagIdList)); + } + } + public Long getTid() { return this.tid; } @@ -83,6 +102,17 @@ public void setPageIndex(Integer pageIndex) { if(pageIndex != null){ putQueryParameter("PageIndex", pageIndex.toString()); } + } + + public Long getScenarioId() { + return this.scenarioId; + } + + public void setScenarioId(Long scenarioId) { + this.scenarioId = scenarioId; + if(scenarioId != null){ + putQueryParameter("ScenarioId", scenarioId.toString()); + } } @Override diff --git a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/ListTaskFlowsByPageResponse.java b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/ListTaskFlowsByPageResponse.java index 857b51b303..16cc1ef2d7 100644 --- a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/ListTaskFlowsByPageResponse.java +++ b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/model/v20181101/ListTaskFlowsByPageResponse.java @@ -107,6 +107,24 @@ public static class TaskFlow { private String latestInstanceTime; + private String scenarioId; + + private Boolean cronSwitch; + + private String cronStr; + + private String scheduleParam; + + private Integer triggerType; + + private Integer cronType; + + private String cronBeginDate; + + private String cronEndDate; + + private String timeZoneId; + public Long getId() { return this.id; } @@ -186,6 +204,78 @@ public String getLatestInstanceTime() { public void setLatestInstanceTime(String latestInstanceTime) { this.latestInstanceTime = latestInstanceTime; } + + public String getScenarioId() { + return this.scenarioId; + } + + public void setScenarioId(String scenarioId) { + this.scenarioId = scenarioId; + } + + public Boolean getCronSwitch() { + return this.cronSwitch; + } + + public void setCronSwitch(Boolean cronSwitch) { + this.cronSwitch = cronSwitch; + } + + public String getCronStr() { + return this.cronStr; + } + + public void setCronStr(String cronStr) { + this.cronStr = cronStr; + } + + public String getScheduleParam() { + return this.scheduleParam; + } + + public void setScheduleParam(String scheduleParam) { + this.scheduleParam = scheduleParam; + } + + public Integer getTriggerType() { + return this.triggerType; + } + + public void setTriggerType(Integer triggerType) { + this.triggerType = triggerType; + } + + public Integer getCronType() { + return this.cronType; + } + + public void setCronType(Integer cronType) { + this.cronType = cronType; + } + + public String getCronBeginDate() { + return this.cronBeginDate; + } + + public void setCronBeginDate(String cronBeginDate) { + this.cronBeginDate = cronBeginDate; + } + + public String getCronEndDate() { + return this.cronEndDate; + } + + public void setCronEndDate(String cronEndDate) { + this.cronEndDate = cronEndDate; + } + + public String getTimeZoneId() { + return this.timeZoneId; + } + + public void setTimeZoneId(String timeZoneId) { + this.timeZoneId = timeZoneId; + } } @Override diff --git a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/AnalyzeSQLLineageResponseUnmarshaller.java b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/AnalyzeSQLLineageResponseUnmarshaller.java new file mode 100644 index 0000000000..ce78e914ac --- /dev/null +++ b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/AnalyzeSQLLineageResponseUnmarshaller.java @@ -0,0 +1,80 @@ +/* + * 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. + */ + +package com.aliyuncs.dms_enterprise.transform.v20181101; + +import java.util.ArrayList; +import java.util.List; + +import com.aliyuncs.dms_enterprise.model.v20181101.AnalyzeSQLLineageResponse; +import com.aliyuncs.dms_enterprise.model.v20181101.AnalyzeSQLLineageResponse.LineageResult; +import com.aliyuncs.dms_enterprise.model.v20181101.AnalyzeSQLLineageResponse.LineageResult.LineageItem; +import com.aliyuncs.dms_enterprise.model.v20181101.AnalyzeSQLLineageResponse.LineageResult.LineageItem.ProcessDetail; +import com.aliyuncs.dms_enterprise.model.v20181101.AnalyzeSQLLineageResponse.LineageResult.ObjectMetadataItem; +import com.aliyuncs.dms_enterprise.model.v20181101.AnalyzeSQLLineageResponse.LineageResult.ObjectMetadataItem.Field; +import com.aliyuncs.transform.UnmarshallerContext; + + +public class AnalyzeSQLLineageResponseUnmarshaller { + + public static AnalyzeSQLLineageResponse unmarshall(AnalyzeSQLLineageResponse analyzeSQLLineageResponse, UnmarshallerContext _ctx) { + + analyzeSQLLineageResponse.setRequestId(_ctx.stringValue("AnalyzeSQLLineageResponse.RequestId")); + analyzeSQLLineageResponse.setSuccess(_ctx.booleanValue("AnalyzeSQLLineageResponse.Success")); + analyzeSQLLineageResponse.setErrorMessage(_ctx.stringValue("AnalyzeSQLLineageResponse.ErrorMessage")); + analyzeSQLLineageResponse.setErrorCode(_ctx.stringValue("AnalyzeSQLLineageResponse.ErrorCode")); + + LineageResult lineageResult = new LineageResult(); + + List lineages = new ArrayList(); + for (int i = 0; i < _ctx.lengthValue("AnalyzeSQLLineageResponse.LineageResult.Lineages.Length"); i++) { + LineageItem lineageItem = new LineageItem(); + lineageItem.setLineageType(_ctx.stringValue("AnalyzeSQLLineageResponse.LineageResult.Lineages["+ i +"].LineageType")); + lineageItem.setSrc(_ctx.stringValue("AnalyzeSQLLineageResponse.LineageResult.Lineages["+ i +"].Src")); + lineageItem.setDst(_ctx.stringValue("AnalyzeSQLLineageResponse.LineageResult.Lineages["+ i +"].Dst")); + lineageItem.setOperType(_ctx.stringValue("AnalyzeSQLLineageResponse.LineageResult.Lineages["+ i +"].OperType")); + + ProcessDetail processDetail = new ProcessDetail(); + processDetail.setCode(_ctx.stringValue("AnalyzeSQLLineageResponse.LineageResult.Lineages["+ i +"].ProcessDetail.Code")); + processDetail.setCalWay(_ctx.stringValue("AnalyzeSQLLineageResponse.LineageResult.Lineages["+ i +"].ProcessDetail.CalWay")); + lineageItem.setProcessDetail(processDetail); + + lineages.add(lineageItem); + } + lineageResult.setLineages(lineages); + + List objectMetadata = new ArrayList(); + for (int i = 0; i < _ctx.lengthValue("AnalyzeSQLLineageResponse.LineageResult.ObjectMetadata.Length"); i++) { + ObjectMetadataItem objectMetadataItem = new ObjectMetadataItem(); + objectMetadataItem.setName(_ctx.stringValue("AnalyzeSQLLineageResponse.LineageResult.ObjectMetadata["+ i +"].Name")); + objectMetadataItem.setType(_ctx.stringValue("AnalyzeSQLLineageResponse.LineageResult.ObjectMetadata["+ i +"].Type")); + objectMetadataItem.setSource(_ctx.stringValue("AnalyzeSQLLineageResponse.LineageResult.ObjectMetadata["+ i +"].Source")); + + List fields = new ArrayList(); + for (int j = 0; j < _ctx.lengthValue("AnalyzeSQLLineageResponse.LineageResult.ObjectMetadata["+ i +"].Fields.Length"); j++) { + Field field = new Field(); + field.setName(_ctx.stringValue("AnalyzeSQLLineageResponse.LineageResult.ObjectMetadata["+ i +"].Fields["+ j +"].Name")); + + fields.add(field); + } + objectMetadataItem.setFields(fields); + + objectMetadata.add(objectMetadataItem); + } + lineageResult.setObjectMetadata(objectMetadata); + analyzeSQLLineageResponse.setLineageResult(lineageResult); + + return analyzeSQLLineageResponse; + } +} \ No newline at end of file diff --git a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/BackFillResponseUnmarshaller.java b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/BackFillResponseUnmarshaller.java index 54b436fd66..494f60dd60 100644 --- a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/BackFillResponseUnmarshaller.java +++ b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/BackFillResponseUnmarshaller.java @@ -26,6 +26,7 @@ public static BackFillResponse unmarshall(BackFillResponse backFillResponse, Unm backFillResponse.setErrorCode(_ctx.stringValue("BackFillResponse.ErrorCode")); backFillResponse.setErrorMessage(_ctx.stringValue("BackFillResponse.ErrorMessage")); backFillResponse.setSuccess(_ctx.booleanValue("BackFillResponse.Success")); + backFillResponse.setDagInstanceId(_ctx.longValue("BackFillResponse.DagInstanceId")); backFillResponse.setNodeId(_ctx.longValue("BackFillResponse.NodeId")); return backFillResponse; diff --git a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/GetDataArchiveOrderDetailResponseUnmarshaller.java b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/GetDataArchiveOrderDetailResponseUnmarshaller.java new file mode 100644 index 0000000000..d84864df2c --- /dev/null +++ b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/GetDataArchiveOrderDetailResponseUnmarshaller.java @@ -0,0 +1,215 @@ +/* + * 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. + */ + +package com.aliyuncs.dms_enterprise.transform.v20181101; + +import java.util.ArrayList; +import java.util.List; + +import com.aliyuncs.dms_enterprise.model.v20181101.GetDataArchiveOrderDetailResponse; +import com.aliyuncs.dms_enterprise.model.v20181101.GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail; +import com.aliyuncs.dms_enterprise.model.v20181101.GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData; +import com.aliyuncs.dms_enterprise.model.v20181101.GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo; +import com.aliyuncs.dms_enterprise.model.v20181101.GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo; +import com.aliyuncs.dms_enterprise.model.v20181101.GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.StandardGroup; +import com.aliyuncs.dms_enterprise.model.v20181101.GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.InstancesItem; +import com.aliyuncs.dms_enterprise.model.v20181101.GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.NextFireTimeResult; +import com.aliyuncs.dms_enterprise.model.v20181101.GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginParam; +import com.aliyuncs.dms_enterprise.model.v20181101.GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginParam.IncludeTables; +import com.aliyuncs.transform.UnmarshallerContext; + + +public class GetDataArchiveOrderDetailResponseUnmarshaller { + + public static GetDataArchiveOrderDetailResponse unmarshall(GetDataArchiveOrderDetailResponse getDataArchiveOrderDetailResponse, UnmarshallerContext _ctx) { + + getDataArchiveOrderDetailResponse.setRequestId(_ctx.stringValue("GetDataArchiveOrderDetailResponse.RequestId")); + getDataArchiveOrderDetailResponse.setTraceId(_ctx.stringValue("GetDataArchiveOrderDetailResponse.TraceId")); + getDataArchiveOrderDetailResponse.setSuccess(_ctx.booleanValue("GetDataArchiveOrderDetailResponse.Success")); + getDataArchiveOrderDetailResponse.setErrorMessage(_ctx.stringValue("GetDataArchiveOrderDetailResponse.ErrorMessage")); + getDataArchiveOrderDetailResponse.setErrorCode(_ctx.stringValue("GetDataArchiveOrderDetailResponse.ErrorCode")); + + DataArchiveOrderDetail dataArchiveOrderDetail = new DataArchiveOrderDetail(); + dataArchiveOrderDetail.setComment(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.Comment")); + dataArchiveOrderDetail.setCommitter(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.Committer")); + dataArchiveOrderDetail.setCommitterId(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.CommitterId")); + dataArchiveOrderDetail.setGmtCreate(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.GmtCreate")); + dataArchiveOrderDetail.setGmtModified(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.GmtModified")); + dataArchiveOrderDetail.setId(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.Id")); + dataArchiveOrderDetail.setPluginType(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginType")); + dataArchiveOrderDetail.setStatusCode(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.StatusCode")); + dataArchiveOrderDetail.setStatusDesc(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.StatusDesc")); + dataArchiveOrderDetail.setWorkflowInstanceId(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.WorkflowInstanceId")); + dataArchiveOrderDetail.setWorkflowStatusDesc(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.WorkflowStatusDesc")); + + List relatedUserList = new ArrayList(); + for (int i = 0; i < _ctx.lengthValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.RelatedUserList.Length"); i++) { + relatedUserList.add(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.RelatedUserList["+ i +"]")); + } + dataArchiveOrderDetail.setRelatedUserList(relatedUserList); + + List relatedUserNickList = new ArrayList(); + for (int i = 0; i < _ctx.lengthValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.RelatedUserNickList.Length"); i++) { + relatedUserNickList.add(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.RelatedUserNickList["+ i +"]")); + } + dataArchiveOrderDetail.setRelatedUserNickList(relatedUserNickList); + + PluginExtraData pluginExtraData = new PluginExtraData(); + pluginExtraData.setInstanceTotal(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.InstanceTotal")); + pluginExtraData.setPageIndex(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.PageIndex")); + pluginExtraData.setPageSize(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.PageSize")); + + DagInfo dagInfo = new DagInfo(); + dagInfo.setCreatorId(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.CreatorId")); + dagInfo.setCronBeginDate(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.CronBeginDate")); + dagInfo.setCronEndDate(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.CronEndDate")); + dagInfo.setCronTrigger(_ctx.booleanValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.CronTrigger")); + dagInfo.setDWDevelop(_ctx.booleanValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.DWDevelop")); + dagInfo.setDagName(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.DagName")); + dagInfo.setDagOwnerId(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.DagOwnerId")); + dagInfo.setDeployId(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.DeployId")); + dagInfo.setDescription(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.Description")); + dagInfo.setEditDagId(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.EditDagId")); + dagInfo.setGmtCreate(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.GmtCreate")); + dagInfo.setGmtModified(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.GmtModified")); + dagInfo.setId(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.Id")); + dagInfo.setIsPublic(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.IsPublic")); + dagInfo.setLegacy(_ctx.booleanValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.Legacy")); + dagInfo.setSystem(_ctx.booleanValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.System")); + dagInfo.setTenantId(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.TenantId")); + dagInfo.setTriggerOnce(_ctx.booleanValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DagInfo.TriggerOnce")); + pluginExtraData.setDagInfo(dagInfo); + + DbBaseInfo dbBaseInfo = new DbBaseInfo(); + dbBaseInfo.setAlias(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.Alias")); + dbBaseInfo.setAlterTimeout(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.AlterTimeout")); + dbBaseInfo.setAssetControl(_ctx.booleanValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.AssetControl")); + dbBaseInfo.setCatalogName(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.CatalogName")); + dbBaseInfo.setClusterNode(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.ClusterNode")); + dbBaseInfo.setDbId(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.DbId")); + dbBaseInfo.setDbType(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.DbType")); + dbBaseInfo.setDbaId(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.DbaId")); + dbBaseInfo.setDbaName(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.DbaName")); + dbBaseInfo.setDescription(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.Description")); + dbBaseInfo.setEncoding(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.Encoding")); + dbBaseInfo.setEnvType(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.EnvType")); + dbBaseInfo.setFollow(_ctx.booleanValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.Follow")); + dbBaseInfo.setHost(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.Host")); + dbBaseInfo.setIdc(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.Idc")); + dbBaseInfo.setIdcTitle(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.IdcTitle")); + dbBaseInfo.setInstanceId(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.InstanceId")); + dbBaseInfo.setInstanceSource(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.InstanceSource")); + dbBaseInfo.setLastSyncTime(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.LastSyncTime")); + dbBaseInfo.setLevel(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.Level")); + dbBaseInfo.setLogic(_ctx.booleanValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.Logic")); + dbBaseInfo.setPort(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.Port")); + dbBaseInfo.setSchemaName(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.SchemaName")); + dbBaseInfo.setSearchName(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.SearchName")); + dbBaseInfo.setState(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.State")); + dbBaseInfo.setTableCount(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.TableCount")); + dbBaseInfo.setTnsName(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.TnsName")); + dbBaseInfo.setUnitType(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.UnitType")); + + List ownerIds = new ArrayList(); + for (int i = 0; i < _ctx.lengthValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.OwnerIds.Length"); i++) { + ownerIds.add(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.OwnerIds["+ i +"]")); + } + dbBaseInfo.setOwnerIds(ownerIds); + + List ownerNames = new ArrayList(); + for (int i = 0; i < _ctx.lengthValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.OwnerNames.Length"); i++) { + ownerNames.add(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.OwnerNames["+ i +"]")); + } + dbBaseInfo.setOwnerNames(ownerNames); + + StandardGroup standardGroup = new StandardGroup(); + standardGroup.setDbType(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.StandardGroup.DbType")); + standardGroup.setDescription(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.StandardGroup.Description")); + standardGroup.setFreeOrStable(_ctx.booleanValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.StandardGroup.FreeOrStable")); + standardGroup.setGmtCreate(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.StandardGroup.GmtCreate")); + standardGroup.setGmtModified(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.StandardGroup.GmtModified")); + standardGroup.setGroupMode(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.StandardGroup.GroupMode")); + standardGroup.setGroupName(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.StandardGroup.GroupName")); + standardGroup.setId(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.StandardGroup.Id")); + standardGroup.setLastMenderId(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.DbBaseInfo.StandardGroup.LastMenderId")); + dbBaseInfo.setStandardGroup(standardGroup); + pluginExtraData.setDbBaseInfo(dbBaseInfo); + + NextFireTimeResult nextFireTimeResult = new NextFireTimeResult(); + nextFireTimeResult.setCronFireType(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.NextFireTimeResult.CronFireType")); + pluginExtraData.setNextFireTimeResult(nextFireTimeResult); + + List instances = new ArrayList(); + for (int i = 0; i < _ctx.lengthValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.Instances.Length"); i++) { + InstancesItem instancesItem = new InstancesItem(); + instancesItem.setBusinessTime(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.Instances["+ i +"].BusinessTime")); + instancesItem.setDagId(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.Instances["+ i +"].DagId")); + instancesItem.setEndTime(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.Instances["+ i +"].EndTime")); + instancesItem.setGmtCreate(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.Instances["+ i +"].GmtCreate")); + instancesItem.setGmtModified(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.Instances["+ i +"].GmtModified")); + instancesItem.setHistoryDagId(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.Instances["+ i +"].HistoryDagId")); + instancesItem.setId(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.Instances["+ i +"].Id")); + instancesItem.setLastRunningContext(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.Instances["+ i +"].LastRunningContext")); + instancesItem.setMsg(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.Instances["+ i +"].Msg")); + instancesItem.setStatus(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.Instances["+ i +"].Status")); + instancesItem.setTenantId(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.Instances["+ i +"].TenantId")); + instancesItem.setTriggerType(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.Instances["+ i +"].TriggerType")); + instancesItem.setVersion(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginExtraData.Instances["+ i +"].Version")); + + instances.add(instancesItem); + } + pluginExtraData.setInstances(instances); + dataArchiveOrderDetail.setPluginExtraData(pluginExtraData); + + PluginParam pluginParam = new PluginParam(); + pluginParam.setArchiveMethod(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginParam.ArchiveMethod")); + pluginParam.setDbSchema(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginParam.DbSchema")); + pluginParam.setLogic(_ctx.booleanValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginParam.Logic")); + pluginParam.setRunMethod(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginParam.RunMethod")); + pluginParam.setSourceDatabaseId(_ctx.longValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginParam.SourceDatabaseId")); + pluginParam.setTargetInstanceId(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginParam.TargetInstanceId")); + + List orderAfter = new ArrayList(); + for (int i = 0; i < _ctx.lengthValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginParam.OrderAfter.Length"); i++) { + orderAfter.add(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginParam.OrderAfter["+ i +"]")); + } + pluginParam.setOrderAfter(orderAfter); + + List tableMapping = new ArrayList(); + for (int i = 0; i < _ctx.lengthValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginParam.TableMapping.Length"); i++) { + tableMapping.add(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginParam.TableMapping["+ i +"]")); + } + pluginParam.setTableMapping(tableMapping); + + List variables = new ArrayList(); + for (int i = 0; i < _ctx.lengthValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginParam.Variables.Length"); i++) { + variables.add(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginParam.Variables["+ i +"]")); + } + pluginParam.setVariables(variables); + + List tableIncludes = new ArrayList(); + for (int i = 0; i < _ctx.lengthValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginParam.TableIncludes.Length"); i++) { + IncludeTables includeTables = new IncludeTables(); + includeTables.setTableName(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginParam.TableIncludes["+ i +"].TableName")); + includeTables.setTableWhere(_ctx.stringValue("GetDataArchiveOrderDetailResponse.DataArchiveOrderDetail.PluginParam.TableIncludes["+ i +"].TableWhere")); + + tableIncludes.add(includeTables); + } + pluginParam.setTableIncludes(tableIncludes); + dataArchiveOrderDetail.setPluginParam(pluginParam); + getDataArchiveOrderDetailResponse.setDataArchiveOrderDetail(dataArchiveOrderDetail); + + return getDataArchiveOrderDetailResponse; + } +} \ No newline at end of file diff --git a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/GetDatabaseResponseUnmarshaller.java b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/GetDatabaseResponseUnmarshaller.java index 55fb6b663d..434cd0b356 100644 --- a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/GetDatabaseResponseUnmarshaller.java +++ b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/GetDatabaseResponseUnmarshaller.java @@ -46,6 +46,7 @@ public static GetDatabaseResponse unmarshall(GetDatabaseResponse getDatabaseResp database.setEncoding(_ctx.stringValue("GetDatabaseResponse.Database.Encoding")); database.setDbType(_ctx.stringValue("GetDatabaseResponse.Database.DbType")); database.setSearchName(_ctx.stringValue("GetDatabaseResponse.Database.SearchName")); + database.setInstanceAlias(_ctx.stringValue("GetDatabaseResponse.Database.InstanceAlias")); List ownerIdList = new ArrayList(); for (int i = 0; i < _ctx.lengthValue("GetDatabaseResponse.Database.OwnerIdList.Length"); i++) { diff --git a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/GetPhysicalDatabaseResponseUnmarshaller.java b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/GetPhysicalDatabaseResponseUnmarshaller.java index 100bd213d6..9128deea17 100644 --- a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/GetPhysicalDatabaseResponseUnmarshaller.java +++ b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/GetPhysicalDatabaseResponseUnmarshaller.java @@ -46,6 +46,7 @@ public static GetPhysicalDatabaseResponse unmarshall(GetPhysicalDatabaseResponse database.setEncoding(_ctx.stringValue("GetPhysicalDatabaseResponse.Database.Encoding")); database.setDbType(_ctx.stringValue("GetPhysicalDatabaseResponse.Database.DbType")); database.setSearchName(_ctx.stringValue("GetPhysicalDatabaseResponse.Database.SearchName")); + database.setInstanceAlias(_ctx.stringValue("GetPhysicalDatabaseResponse.Database.InstanceAlias")); List ownerIdList = new ArrayList(); for (int i = 0; i < _ctx.lengthValue("GetPhysicalDatabaseResponse.Database.OwnerIdList.Length"); i++) { diff --git a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/ListTaskFlowInstanceResponseUnmarshaller.java b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/ListTaskFlowInstanceResponseUnmarshaller.java index befdbc9580..30bf86f54b 100644 --- a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/ListTaskFlowInstanceResponseUnmarshaller.java +++ b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/ListTaskFlowInstanceResponseUnmarshaller.java @@ -37,6 +37,7 @@ public static ListTaskFlowInstanceResponse unmarshall(ListTaskFlowInstanceRespon DAGInstance dAGInstance = new DAGInstance(); dAGInstance.setId(_ctx.longValue("ListTaskFlowInstanceResponse.DAGInstanceList["+ i +"].Id")); dAGInstance.setBusinessTime(_ctx.stringValue("ListTaskFlowInstanceResponse.DAGInstanceList["+ i +"].BusinessTime")); + dAGInstance.setStartTime(_ctx.stringValue("ListTaskFlowInstanceResponse.DAGInstanceList["+ i +"].startTime")); dAGInstance.setEndTime(_ctx.stringValue("ListTaskFlowInstanceResponse.DAGInstanceList["+ i +"].EndTime")); dAGInstance.setDagId(_ctx.stringValue("ListTaskFlowInstanceResponse.DAGInstanceList["+ i +"].DagId")); dAGInstance.setTriggerType(_ctx.integerValue("ListTaskFlowInstanceResponse.DAGInstanceList["+ i +"].TriggerType")); diff --git a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/ListTaskFlowsByPageResponseUnmarshaller.java b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/ListTaskFlowsByPageResponseUnmarshaller.java index 5db9457cc0..094f2380a5 100644 --- a/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/ListTaskFlowsByPageResponseUnmarshaller.java +++ b/aliyun-java-sdk-dms-enterprise/src/main/java/com/aliyuncs/dms_enterprise/transform/v20181101/ListTaskFlowsByPageResponseUnmarshaller.java @@ -45,6 +45,15 @@ public static ListTaskFlowsByPageResponse unmarshall(ListTaskFlowsByPageResponse taskFlow.setStatus(_ctx.integerValue("ListTaskFlowsByPageResponse.TaskFlowList["+ i +"].Status")); taskFlow.setLatestInstanceStatus(_ctx.integerValue("ListTaskFlowsByPageResponse.TaskFlowList["+ i +"].LatestInstanceStatus")); taskFlow.setLatestInstanceTime(_ctx.stringValue("ListTaskFlowsByPageResponse.TaskFlowList["+ i +"].LatestInstanceTime")); + taskFlow.setScenarioId(_ctx.stringValue("ListTaskFlowsByPageResponse.TaskFlowList["+ i +"].ScenarioId")); + taskFlow.setCronSwitch(_ctx.booleanValue("ListTaskFlowsByPageResponse.TaskFlowList["+ i +"].CronSwitch")); + taskFlow.setCronStr(_ctx.stringValue("ListTaskFlowsByPageResponse.TaskFlowList["+ i +"].CronStr")); + taskFlow.setScheduleParam(_ctx.stringValue("ListTaskFlowsByPageResponse.TaskFlowList["+ i +"].ScheduleParam")); + taskFlow.setTriggerType(_ctx.integerValue("ListTaskFlowsByPageResponse.TaskFlowList["+ i +"].TriggerType")); + taskFlow.setCronType(_ctx.integerValue("ListTaskFlowsByPageResponse.TaskFlowList["+ i +"].CronType")); + taskFlow.setCronBeginDate(_ctx.stringValue("ListTaskFlowsByPageResponse.TaskFlowList["+ i +"].CronBeginDate")); + taskFlow.setCronEndDate(_ctx.stringValue("ListTaskFlowsByPageResponse.TaskFlowList["+ i +"].CronEndDate")); + taskFlow.setTimeZoneId(_ctx.stringValue("ListTaskFlowsByPageResponse.TaskFlowList["+ i +"].TimeZoneId")); taskFlowList.add(taskFlow); }