diff --git a/CHANGELOG b/CHANGELOG index 596266705..18f989dd4 100644 --- a/CHANGELOG +++ b/CHANGELOG @@ -1,3 +1,6 @@ +2021-08-13 Version: 1.36.852 +- Supported etlOperatorColumnReference for ModifyDtsJob. + 2021-08-13 Version: 1.36.851 - Support sts. diff --git a/VERSION b/VERSION index 5dd88c5d4..e6b688697 100644 --- a/VERSION +++ b/VERSION @@ -1 +1 @@ -1.36.851 \ No newline at end of file +1.36.852 \ No newline at end of file diff --git a/dts/CMakeLists.txt b/dts/CMakeLists.txt index 6cf6533e4..30ccf5cb0 100644 --- a/dts/CMakeLists.txt +++ b/dts/CMakeLists.txt @@ -113,6 +113,8 @@ set(dts_public_header_model include/alibabacloud/dts/model/DescribeSynchronizationJobsResult.h include/alibabacloud/dts/model/DescribeSynchronizationObjectModifyStatusRequest.h include/alibabacloud/dts/model/DescribeSynchronizationObjectModifyStatusResult.h + include/alibabacloud/dts/model/IgnoreJobDetailRequest.h + include/alibabacloud/dts/model/IgnoreJobDetailResult.h include/alibabacloud/dts/model/ListTagResourcesRequest.h include/alibabacloud/dts/model/ListTagResourcesResult.h include/alibabacloud/dts/model/ModifyConsumerChannelRequest.h @@ -155,6 +157,8 @@ set(dts_public_header_model include/alibabacloud/dts/model/StopDtsJobResult.h include/alibabacloud/dts/model/StopMigrationJobRequest.h include/alibabacloud/dts/model/StopMigrationJobResult.h + include/alibabacloud/dts/model/SummaryJobDetailRequest.h + include/alibabacloud/dts/model/SummaryJobDetailResult.h include/alibabacloud/dts/model/SuspendDtsJobRequest.h include/alibabacloud/dts/model/SuspendDtsJobResult.h include/alibabacloud/dts/model/SuspendMigrationJobRequest.h @@ -270,6 +274,8 @@ set(dts_src src/model/DescribeSynchronizationJobsResult.cc src/model/DescribeSynchronizationObjectModifyStatusRequest.cc src/model/DescribeSynchronizationObjectModifyStatusResult.cc + src/model/IgnoreJobDetailRequest.cc + src/model/IgnoreJobDetailResult.cc src/model/ListTagResourcesRequest.cc src/model/ListTagResourcesResult.cc src/model/ModifyConsumerChannelRequest.cc @@ -312,6 +318,8 @@ set(dts_src src/model/StopDtsJobResult.cc src/model/StopMigrationJobRequest.cc src/model/StopMigrationJobResult.cc + src/model/SummaryJobDetailRequest.cc + src/model/SummaryJobDetailResult.cc src/model/SuspendDtsJobRequest.cc src/model/SuspendDtsJobResult.cc src/model/SuspendMigrationJobRequest.cc diff --git a/dts/include/alibabacloud/dts/DtsClient.h b/dts/include/alibabacloud/dts/DtsClient.h index c01fe435b..057a9c23e 100644 --- a/dts/include/alibabacloud/dts/DtsClient.h +++ b/dts/include/alibabacloud/dts/DtsClient.h @@ -114,6 +114,8 @@ #include "model/DescribeSynchronizationJobsResult.h" #include "model/DescribeSynchronizationObjectModifyStatusRequest.h" #include "model/DescribeSynchronizationObjectModifyStatusResult.h" +#include "model/IgnoreJobDetailRequest.h" +#include "model/IgnoreJobDetailResult.h" #include "model/ListTagResourcesRequest.h" #include "model/ListTagResourcesResult.h" #include "model/ModifyConsumerChannelRequest.h" @@ -156,6 +158,8 @@ #include "model/StopDtsJobResult.h" #include "model/StopMigrationJobRequest.h" #include "model/StopMigrationJobResult.h" +#include "model/SummaryJobDetailRequest.h" +#include "model/SummaryJobDetailResult.h" #include "model/SuspendDtsJobRequest.h" #include "model/SuspendDtsJobResult.h" #include "model/SuspendMigrationJobRequest.h" @@ -323,6 +327,9 @@ namespace AlibabaCloud typedef Outcome DescribeSynchronizationObjectModifyStatusOutcome; typedef std::future DescribeSynchronizationObjectModifyStatusOutcomeCallable; typedef std::function&)> DescribeSynchronizationObjectModifyStatusAsyncHandler; + typedef Outcome IgnoreJobDetailOutcome; + typedef std::future IgnoreJobDetailOutcomeCallable; + typedef std::function&)> IgnoreJobDetailAsyncHandler; typedef Outcome ListTagResourcesOutcome; typedef std::future ListTagResourcesOutcomeCallable; typedef std::function&)> ListTagResourcesAsyncHandler; @@ -386,6 +393,9 @@ namespace AlibabaCloud typedef Outcome StopMigrationJobOutcome; typedef std::future StopMigrationJobOutcomeCallable; typedef std::function&)> StopMigrationJobAsyncHandler; + typedef Outcome SummaryJobDetailOutcome; + typedef std::future SummaryJobDetailOutcomeCallable; + typedef std::function&)> SummaryJobDetailAsyncHandler; typedef Outcome SuspendDtsJobOutcome; typedef std::future SuspendDtsJobOutcomeCallable; typedef std::function&)> SuspendDtsJobAsyncHandler; @@ -559,6 +569,9 @@ namespace AlibabaCloud DescribeSynchronizationObjectModifyStatusOutcome describeSynchronizationObjectModifyStatus(const Model::DescribeSynchronizationObjectModifyStatusRequest &request)const; void describeSynchronizationObjectModifyStatusAsync(const Model::DescribeSynchronizationObjectModifyStatusRequest& request, const DescribeSynchronizationObjectModifyStatusAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; DescribeSynchronizationObjectModifyStatusOutcomeCallable describeSynchronizationObjectModifyStatusCallable(const Model::DescribeSynchronizationObjectModifyStatusRequest& request) const; + IgnoreJobDetailOutcome ignoreJobDetail(const Model::IgnoreJobDetailRequest &request)const; + void ignoreJobDetailAsync(const Model::IgnoreJobDetailRequest& request, const IgnoreJobDetailAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + IgnoreJobDetailOutcomeCallable ignoreJobDetailCallable(const Model::IgnoreJobDetailRequest& request) const; ListTagResourcesOutcome listTagResources(const Model::ListTagResourcesRequest &request)const; void listTagResourcesAsync(const Model::ListTagResourcesRequest& request, const ListTagResourcesAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ListTagResourcesOutcomeCallable listTagResourcesCallable(const Model::ListTagResourcesRequest& request) const; @@ -622,6 +635,9 @@ namespace AlibabaCloud StopMigrationJobOutcome stopMigrationJob(const Model::StopMigrationJobRequest &request)const; void stopMigrationJobAsync(const Model::StopMigrationJobRequest& request, const StopMigrationJobAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; StopMigrationJobOutcomeCallable stopMigrationJobCallable(const Model::StopMigrationJobRequest& request) const; + SummaryJobDetailOutcome summaryJobDetail(const Model::SummaryJobDetailRequest &request)const; + void summaryJobDetailAsync(const Model::SummaryJobDetailRequest& request, const SummaryJobDetailAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + SummaryJobDetailOutcomeCallable summaryJobDetailCallable(const Model::SummaryJobDetailRequest& request) const; SuspendDtsJobOutcome suspendDtsJob(const Model::SuspendDtsJobRequest &request)const; void suspendDtsJobAsync(const Model::SuspendDtsJobRequest& request, const SuspendDtsJobAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; SuspendDtsJobOutcomeCallable suspendDtsJobCallable(const Model::SuspendDtsJobRequest& request) const; diff --git a/dts/include/alibabacloud/dts/model/DescribePreCheckStatusRequest.h b/dts/include/alibabacloud/dts/model/DescribePreCheckStatusRequest.h index beab4b805..43a270799 100644 --- a/dts/include/alibabacloud/dts/model/DescribePreCheckStatusRequest.h +++ b/dts/include/alibabacloud/dts/model/DescribePreCheckStatusRequest.h @@ -45,6 +45,8 @@ namespace AlibabaCloud void setPageSize(const std::string& pageSize); std::string getJobCode()const; void setJobCode(const std::string& jobCode); + std::string getName()const; + void setName(const std::string& name); std::string getDtsJobId()const; void setDtsJobId(const std::string& dtsJobId); std::string getStructPhase()const; @@ -56,6 +58,7 @@ namespace AlibabaCloud std::string pageNo_; std::string pageSize_; std::string jobCode_; + std::string name_; std::string dtsJobId_; std::string structPhase_; diff --git a/dts/include/alibabacloud/dts/model/DescribePreCheckStatusResult.h b/dts/include/alibabacloud/dts/model/DescribePreCheckStatusResult.h index f5d6ac135..c6486231d 100644 --- a/dts/include/alibabacloud/dts/model/DescribePreCheckStatusResult.h +++ b/dts/include/alibabacloud/dts/model/DescribePreCheckStatusResult.h @@ -62,6 +62,7 @@ namespace AlibabaCloud int total; bool skip; std::string errDetail; + std::string id; std::string jobId; std::string ddlSql; }; @@ -97,6 +98,7 @@ namespace AlibabaCloud int total; bool skip; std::string errDetail; + std::string id; std::string jobId; std::string ddlSql; }; diff --git a/dts/include/alibabacloud/dts/model/IgnoreJobDetailRequest.h b/dts/include/alibabacloud/dts/model/IgnoreJobDetailRequest.h new file mode 100644 index 000000000..c5387524c --- /dev/null +++ b/dts/include/alibabacloud/dts/model/IgnoreJobDetailRequest.h @@ -0,0 +1,63 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * 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. + */ + +#ifndef ALIBABACLOUD_DTS_MODEL_IGNOREJOBDETAILREQUEST_H_ +#define ALIBABACLOUD_DTS_MODEL_IGNOREJOBDETAILREQUEST_H_ + +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dts + { + namespace Model + { + class ALIBABACLOUD_DTS_EXPORT IgnoreJobDetailRequest : public RpcServiceRequest + { + + public: + IgnoreJobDetailRequest(); + ~IgnoreJobDetailRequest(); + + std::string getRegionId()const; + void setRegionId(const std::string& regionId); + std::string getJobCode()const; + void setJobCode(const std::string& jobCode); + std::string getDtsJobId()const; + void setDtsJobId(const std::string& dtsJobId); + std::string getId()const; + void setId(const std::string& id); + std::string getDtsInstanceId()const; + void setDtsInstanceId(const std::string& dtsInstanceId); + std::string getSynchronizationDirection()const; + void setSynchronizationDirection(const std::string& synchronizationDirection); + + private: + std::string regionId_; + std::string jobCode_; + std::string dtsJobId_; + std::string id_; + std::string dtsInstanceId_; + std::string synchronizationDirection_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DTS_MODEL_IGNOREJOBDETAILREQUEST_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/IgnoreJobDetailResult.h b/dts/include/alibabacloud/dts/model/IgnoreJobDetailResult.h new file mode 100644 index 000000000..ee0b6cc1f --- /dev/null +++ b/dts/include/alibabacloud/dts/model/IgnoreJobDetailResult.h @@ -0,0 +1,55 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * 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. + */ + +#ifndef ALIBABACLOUD_DTS_MODEL_IGNOREJOBDETAILRESULT_H_ +#define ALIBABACLOUD_DTS_MODEL_IGNOREJOBDETAILRESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dts + { + namespace Model + { + class ALIBABACLOUD_DTS_EXPORT IgnoreJobDetailResult : public ServiceResult + { + public: + + + IgnoreJobDetailResult(); + explicit IgnoreJobDetailResult(const std::string &payload); + ~IgnoreJobDetailResult(); + int getHttpStatusCode()const; + std::string getCode()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + int httpStatusCode_; + std::string code_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DTS_MODEL_IGNOREJOBDETAILRESULT_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/ModifyDtsJobRequest.h b/dts/include/alibabacloud/dts/model/ModifyDtsJobRequest.h index df9b66dcb..73cc6f84c 100644 --- a/dts/include/alibabacloud/dts/model/ModifyDtsJobRequest.h +++ b/dts/include/alibabacloud/dts/model/ModifyDtsJobRequest.h @@ -45,8 +45,8 @@ namespace AlibabaCloud void setAccessKeyId(const std::string& accessKeyId); std::string getRegionId()const; void setRegionId(const std::string& regionId); - std::string getReserve()const; - void setReserve(const std::string& reserve); + std::string getEtlOperatorColumnReference()const; + void setEtlOperatorColumnReference(const std::string& etlOperatorColumnReference); std::string getDtsInstanceId()const; void setDtsInstanceId(const std::string& dtsInstanceId); std::string getSynchronizationDirection()const; @@ -58,7 +58,7 @@ namespace AlibabaCloud std::string ownerId_; std::string accessKeyId_; std::string regionId_; - std::string reserve_; + std::string etlOperatorColumnReference_; std::string dtsInstanceId_; std::string synchronizationDirection_; diff --git a/dts/include/alibabacloud/dts/model/SummaryJobDetailRequest.h b/dts/include/alibabacloud/dts/model/SummaryJobDetailRequest.h new file mode 100644 index 000000000..be2ffc711 --- /dev/null +++ b/dts/include/alibabacloud/dts/model/SummaryJobDetailRequest.h @@ -0,0 +1,60 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * 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. + */ + +#ifndef ALIBABACLOUD_DTS_MODEL_SUMMARYJOBDETAILREQUEST_H_ +#define ALIBABACLOUD_DTS_MODEL_SUMMARYJOBDETAILREQUEST_H_ + +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dts + { + namespace Model + { + class ALIBABACLOUD_DTS_EXPORT SummaryJobDetailRequest : public RpcServiceRequest + { + + public: + SummaryJobDetailRequest(); + ~SummaryJobDetailRequest(); + + std::string getRegionId()const; + void setRegionId(const std::string& regionId); + std::string getJobCode()const; + void setJobCode(const std::string& jobCode); + std::string getDtsJobId()const; + void setDtsJobId(const std::string& dtsJobId); + std::string getDtsInstanceId()const; + void setDtsInstanceId(const std::string& dtsInstanceId); + std::string getSynchronizationDirection()const; + void setSynchronizationDirection(const std::string& synchronizationDirection); + + private: + std::string regionId_; + std::string jobCode_; + std::string dtsJobId_; + std::string dtsInstanceId_; + std::string synchronizationDirection_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DTS_MODEL_SUMMARYJOBDETAILREQUEST_H_ \ No newline at end of file diff --git a/dts/include/alibabacloud/dts/model/SummaryJobDetailResult.h b/dts/include/alibabacloud/dts/model/SummaryJobDetailResult.h new file mode 100644 index 000000000..9cfa40d8c --- /dev/null +++ b/dts/include/alibabacloud/dts/model/SummaryJobDetailResult.h @@ -0,0 +1,65 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * 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. + */ + +#ifndef ALIBABACLOUD_DTS_MODEL_SUMMARYJOBDETAILRESULT_H_ +#define ALIBABACLOUD_DTS_MODEL_SUMMARYJOBDETAILRESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dts + { + namespace Model + { + class ALIBABACLOUD_DTS_EXPORT SummaryJobDetailResult : public ServiceResult + { + public: + struct ProgressSummaryDetail + { + long totalCount; + int state; + std::string key; + }; + + + SummaryJobDetailResult(); + explicit SummaryJobDetailResult(const std::string &payload); + ~SummaryJobDetailResult(); + std::vector getProgressSummaryDetails()const; + int getHttpStatusCode()const; + std::string getCode()const; + std::string getJobId()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + std::vector progressSummaryDetails_; + int httpStatusCode_; + std::string code_; + std::string jobId_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DTS_MODEL_SUMMARYJOBDETAILRESULT_H_ \ No newline at end of file diff --git a/dts/src/DtsClient.cc b/dts/src/DtsClient.cc index 53cb25552..51624b3ab 100644 --- a/dts/src/DtsClient.cc +++ b/dts/src/DtsClient.cc @@ -1707,6 +1707,42 @@ DtsClient::DescribeSynchronizationObjectModifyStatusOutcomeCallable DtsClient::d return task->get_future(); } +DtsClient::IgnoreJobDetailOutcome DtsClient::ignoreJobDetail(const IgnoreJobDetailRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return IgnoreJobDetailOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return IgnoreJobDetailOutcome(IgnoreJobDetailResult(outcome.result())); + else + return IgnoreJobDetailOutcome(outcome.error()); +} + +void DtsClient::ignoreJobDetailAsync(const IgnoreJobDetailRequest& request, const IgnoreJobDetailAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, ignoreJobDetail(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +DtsClient::IgnoreJobDetailOutcomeCallable DtsClient::ignoreJobDetailCallable(const IgnoreJobDetailRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->ignoreJobDetail(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + DtsClient::ListTagResourcesOutcome DtsClient::listTagResources(const ListTagResourcesRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -2463,6 +2499,42 @@ DtsClient::StopMigrationJobOutcomeCallable DtsClient::stopMigrationJobCallable(c return task->get_future(); } +DtsClient::SummaryJobDetailOutcome DtsClient::summaryJobDetail(const SummaryJobDetailRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return SummaryJobDetailOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return SummaryJobDetailOutcome(SummaryJobDetailResult(outcome.result())); + else + return SummaryJobDetailOutcome(outcome.error()); +} + +void DtsClient::summaryJobDetailAsync(const SummaryJobDetailRequest& request, const SummaryJobDetailAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, summaryJobDetail(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +DtsClient::SummaryJobDetailOutcomeCallable DtsClient::summaryJobDetailCallable(const SummaryJobDetailRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->summaryJobDetail(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + DtsClient::SuspendDtsJobOutcome DtsClient::suspendDtsJob(const SuspendDtsJobRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); diff --git a/dts/src/model/DescribePreCheckStatusRequest.cc b/dts/src/model/DescribePreCheckStatusRequest.cc index 78b315349..9b0c04fd9 100644 --- a/dts/src/model/DescribePreCheckStatusRequest.cc +++ b/dts/src/model/DescribePreCheckStatusRequest.cc @@ -82,6 +82,17 @@ void DescribePreCheckStatusRequest::setJobCode(const std::string& jobCode) setParameter("JobCode", jobCode); } +std::string DescribePreCheckStatusRequest::getName()const +{ + return name_; +} + +void DescribePreCheckStatusRequest::setName(const std::string& name) +{ + name_ = name; + setParameter("Name", name); +} + std::string DescribePreCheckStatusRequest::getDtsJobId()const { return dtsJobId_; diff --git a/dts/src/model/DescribePreCheckStatusResult.cc b/dts/src/model/DescribePreCheckStatusResult.cc index 6f25dea37..0e9731fe2 100644 --- a/dts/src/model/DescribePreCheckStatusResult.cc +++ b/dts/src/model/DescribePreCheckStatusResult.cc @@ -87,6 +87,8 @@ void DescribePreCheckStatusResult::parse(const std::string &payload) jobProgressObject.errDetail = valueJobProgressProgressInfo["ErrDetail"].asString(); if(!valueJobProgressProgressInfo["DdlSql"].isNull()) jobProgressObject.ddlSql = valueJobProgressProgressInfo["DdlSql"].asString(); + if(!valueJobProgressProgressInfo["Id"].isNull()) + jobProgressObject.id = valueJobProgressProgressInfo["Id"].asString(); auto allLogsNode = valueJobProgressProgressInfo["Logs"]["JobLog"]; for (auto valueJobProgressProgressInfoLogsJobLog : allLogsNode) { @@ -167,6 +169,8 @@ void DescribePreCheckStatusResult::parse(const std::string &payload) jobProgress1Object.errDetail = valueSubDistributedJobStatusSubDistributedJobStatusItemJobProgressProgressInfo["ErrDetail"].asString(); if(!valueSubDistributedJobStatusSubDistributedJobStatusItemJobProgressProgressInfo["DdlSql"].isNull()) jobProgress1Object.ddlSql = valueSubDistributedJobStatusSubDistributedJobStatusItemJobProgressProgressInfo["DdlSql"].asString(); + if(!valueSubDistributedJobStatusSubDistributedJobStatusItemJobProgressProgressInfo["Id"].isNull()) + jobProgress1Object.id = valueSubDistributedJobStatusSubDistributedJobStatusItemJobProgressProgressInfo["Id"].asString(); auto allLogs3Node = valueSubDistributedJobStatusSubDistributedJobStatusItemJobProgressProgressInfo["Logs"]["JobLog"]; for (auto valueSubDistributedJobStatusSubDistributedJobStatusItemJobProgressProgressInfoLogsJobLog : allLogs3Node) { diff --git a/dts/src/model/IgnoreJobDetailRequest.cc b/dts/src/model/IgnoreJobDetailRequest.cc new file mode 100644 index 000000000..bbc9ae72d --- /dev/null +++ b/dts/src/model/IgnoreJobDetailRequest.cc @@ -0,0 +1,95 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * 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. + */ + +#include + +using AlibabaCloud::Dts::Model::IgnoreJobDetailRequest; + +IgnoreJobDetailRequest::IgnoreJobDetailRequest() : + RpcServiceRequest("dts", "2020-01-01", "IgnoreJobDetail") +{ + setMethod(HttpRequest::Method::Post); +} + +IgnoreJobDetailRequest::~IgnoreJobDetailRequest() +{} + +std::string IgnoreJobDetailRequest::getRegionId()const +{ + return regionId_; +} + +void IgnoreJobDetailRequest::setRegionId(const std::string& regionId) +{ + regionId_ = regionId; + setParameter("RegionId", regionId); +} + +std::string IgnoreJobDetailRequest::getJobCode()const +{ + return jobCode_; +} + +void IgnoreJobDetailRequest::setJobCode(const std::string& jobCode) +{ + jobCode_ = jobCode; + setParameter("JobCode", jobCode); +} + +std::string IgnoreJobDetailRequest::getDtsJobId()const +{ + return dtsJobId_; +} + +void IgnoreJobDetailRequest::setDtsJobId(const std::string& dtsJobId) +{ + dtsJobId_ = dtsJobId; + setParameter("DtsJobId", dtsJobId); +} + +std::string IgnoreJobDetailRequest::getId()const +{ + return id_; +} + +void IgnoreJobDetailRequest::setId(const std::string& id) +{ + id_ = id; + setParameter("Id", id); +} + +std::string IgnoreJobDetailRequest::getDtsInstanceId()const +{ + return dtsInstanceId_; +} + +void IgnoreJobDetailRequest::setDtsInstanceId(const std::string& dtsInstanceId) +{ + dtsInstanceId_ = dtsInstanceId; + setParameter("DtsInstanceId", dtsInstanceId); +} + +std::string IgnoreJobDetailRequest::getSynchronizationDirection()const +{ + return synchronizationDirection_; +} + +void IgnoreJobDetailRequest::setSynchronizationDirection(const std::string& synchronizationDirection) +{ + synchronizationDirection_ = synchronizationDirection; + setParameter("SynchronizationDirection", synchronizationDirection); +} + diff --git a/dts/src/model/IgnoreJobDetailResult.cc b/dts/src/model/IgnoreJobDetailResult.cc new file mode 100644 index 000000000..3d5b2d81e --- /dev/null +++ b/dts/src/model/IgnoreJobDetailResult.cc @@ -0,0 +1,65 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * 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. + */ + +#include +#include + +using namespace AlibabaCloud::Dts; +using namespace AlibabaCloud::Dts::Model; + +IgnoreJobDetailResult::IgnoreJobDetailResult() : + ServiceResult() +{} + +IgnoreJobDetailResult::IgnoreJobDetailResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +IgnoreJobDetailResult::~IgnoreJobDetailResult() +{} + +void IgnoreJobDetailResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + if(!value["Code"].isNull()) + code_ = value["Code"].asString(); + if(!value["HttpStatusCode"].isNull()) + httpStatusCode_ = std::stoi(value["HttpStatusCode"].asString()); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + +} + +int IgnoreJobDetailResult::getHttpStatusCode()const +{ + return httpStatusCode_; +} + +std::string IgnoreJobDetailResult::getCode()const +{ + return code_; +} + +bool IgnoreJobDetailResult::getSuccess()const +{ + return success_; +} + diff --git a/dts/src/model/ModifyDtsJobRequest.cc b/dts/src/model/ModifyDtsJobRequest.cc index 243e08b6c..00dc92bed 100644 --- a/dts/src/model/ModifyDtsJobRequest.cc +++ b/dts/src/model/ModifyDtsJobRequest.cc @@ -82,15 +82,15 @@ void ModifyDtsJobRequest::setRegionId(const std::string& regionId) setParameter("RegionId", regionId); } -std::string ModifyDtsJobRequest::getReserve()const +std::string ModifyDtsJobRequest::getEtlOperatorColumnReference()const { - return reserve_; + return etlOperatorColumnReference_; } -void ModifyDtsJobRequest::setReserve(const std::string& reserve) +void ModifyDtsJobRequest::setEtlOperatorColumnReference(const std::string& etlOperatorColumnReference) { - reserve_ = reserve; - setBodyParameter("Reserve", reserve); + etlOperatorColumnReference_ = etlOperatorColumnReference; + setBodyParameter("EtlOperatorColumnReference", etlOperatorColumnReference); } std::string ModifyDtsJobRequest::getDtsInstanceId()const diff --git a/dts/src/model/SummaryJobDetailRequest.cc b/dts/src/model/SummaryJobDetailRequest.cc new file mode 100644 index 000000000..e25864b1f --- /dev/null +++ b/dts/src/model/SummaryJobDetailRequest.cc @@ -0,0 +1,84 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * 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. + */ + +#include + +using AlibabaCloud::Dts::Model::SummaryJobDetailRequest; + +SummaryJobDetailRequest::SummaryJobDetailRequest() : + RpcServiceRequest("dts", "2020-01-01", "SummaryJobDetail") +{ + setMethod(HttpRequest::Method::Post); +} + +SummaryJobDetailRequest::~SummaryJobDetailRequest() +{} + +std::string SummaryJobDetailRequest::getRegionId()const +{ + return regionId_; +} + +void SummaryJobDetailRequest::setRegionId(const std::string& regionId) +{ + regionId_ = regionId; + setParameter("RegionId", regionId); +} + +std::string SummaryJobDetailRequest::getJobCode()const +{ + return jobCode_; +} + +void SummaryJobDetailRequest::setJobCode(const std::string& jobCode) +{ + jobCode_ = jobCode; + setParameter("JobCode", jobCode); +} + +std::string SummaryJobDetailRequest::getDtsJobId()const +{ + return dtsJobId_; +} + +void SummaryJobDetailRequest::setDtsJobId(const std::string& dtsJobId) +{ + dtsJobId_ = dtsJobId; + setParameter("DtsJobId", dtsJobId); +} + +std::string SummaryJobDetailRequest::getDtsInstanceId()const +{ + return dtsInstanceId_; +} + +void SummaryJobDetailRequest::setDtsInstanceId(const std::string& dtsInstanceId) +{ + dtsInstanceId_ = dtsInstanceId; + setParameter("DtsInstanceId", dtsInstanceId); +} + +std::string SummaryJobDetailRequest::getSynchronizationDirection()const +{ + return synchronizationDirection_; +} + +void SummaryJobDetailRequest::setSynchronizationDirection(const std::string& synchronizationDirection) +{ + synchronizationDirection_ = synchronizationDirection; + setParameter("SynchronizationDirection", synchronizationDirection); +} + diff --git a/dts/src/model/SummaryJobDetailResult.cc b/dts/src/model/SummaryJobDetailResult.cc new file mode 100644 index 000000000..4fd914ee7 --- /dev/null +++ b/dts/src/model/SummaryJobDetailResult.cc @@ -0,0 +1,89 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * 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. + */ + +#include +#include + +using namespace AlibabaCloud::Dts; +using namespace AlibabaCloud::Dts::Model; + +SummaryJobDetailResult::SummaryJobDetailResult() : + ServiceResult() +{} + +SummaryJobDetailResult::SummaryJobDetailResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +SummaryJobDetailResult::~SummaryJobDetailResult() +{} + +void SummaryJobDetailResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + auto allProgressSummaryDetailsNode = value["ProgressSummaryDetails"]["ProgressSummaryDetail"]; + for (auto valueProgressSummaryDetailsProgressSummaryDetail : allProgressSummaryDetailsNode) + { + ProgressSummaryDetail progressSummaryDetailsObject; + if(!valueProgressSummaryDetailsProgressSummaryDetail["Key"].isNull()) + progressSummaryDetailsObject.key = valueProgressSummaryDetailsProgressSummaryDetail["Key"].asString(); + if(!valueProgressSummaryDetailsProgressSummaryDetail["TotalCount"].isNull()) + progressSummaryDetailsObject.totalCount = std::stol(valueProgressSummaryDetailsProgressSummaryDetail["TotalCount"].asString()); + if(!valueProgressSummaryDetailsProgressSummaryDetail["State"].isNull()) + progressSummaryDetailsObject.state = std::stoi(valueProgressSummaryDetailsProgressSummaryDetail["State"].asString()); + progressSummaryDetails_.push_back(progressSummaryDetailsObject); + } + if(!value["Code"].isNull()) + code_ = value["Code"].asString(); + if(!value["HttpStatusCode"].isNull()) + httpStatusCode_ = std::stoi(value["HttpStatusCode"].asString()); + if(!value["JobId"].isNull()) + jobId_ = value["JobId"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + +} + +std::vector SummaryJobDetailResult::getProgressSummaryDetails()const +{ + return progressSummaryDetails_; +} + +int SummaryJobDetailResult::getHttpStatusCode()const +{ + return httpStatusCode_; +} + +std::string SummaryJobDetailResult::getCode()const +{ + return code_; +} + +std::string SummaryJobDetailResult::getJobId()const +{ + return jobId_; +} + +bool SummaryJobDetailResult::getSuccess()const +{ + return success_; +} +