Supported etlOperatorColumnReference for ModifyDtsJob.

This commit is contained in:
sdk-team
2021-08-13 03:55:50 +00:00
parent c40875737f
commit 80e8534b12
19 changed files with 704 additions and 9 deletions

View File

@@ -1,3 +1,6 @@
2021-08-13 Version: 1.36.852
- Supported etlOperatorColumnReference for ModifyDtsJob.
2021-08-13 Version: 1.36.851
- Support sts.

View File

@@ -1 +1 @@
1.36.851
1.36.852

View File

@@ -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

View File

@@ -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<Error, Model::DescribeSynchronizationObjectModifyStatusResult> DescribeSynchronizationObjectModifyStatusOutcome;
typedef std::future<DescribeSynchronizationObjectModifyStatusOutcome> DescribeSynchronizationObjectModifyStatusOutcomeCallable;
typedef std::function<void(const DtsClient*, const Model::DescribeSynchronizationObjectModifyStatusRequest&, const DescribeSynchronizationObjectModifyStatusOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> DescribeSynchronizationObjectModifyStatusAsyncHandler;
typedef Outcome<Error, Model::IgnoreJobDetailResult> IgnoreJobDetailOutcome;
typedef std::future<IgnoreJobDetailOutcome> IgnoreJobDetailOutcomeCallable;
typedef std::function<void(const DtsClient*, const Model::IgnoreJobDetailRequest&, const IgnoreJobDetailOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> IgnoreJobDetailAsyncHandler;
typedef Outcome<Error, Model::ListTagResourcesResult> ListTagResourcesOutcome;
typedef std::future<ListTagResourcesOutcome> ListTagResourcesOutcomeCallable;
typedef std::function<void(const DtsClient*, const Model::ListTagResourcesRequest&, const ListTagResourcesOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ListTagResourcesAsyncHandler;
@@ -386,6 +393,9 @@ namespace AlibabaCloud
typedef Outcome<Error, Model::StopMigrationJobResult> StopMigrationJobOutcome;
typedef std::future<StopMigrationJobOutcome> StopMigrationJobOutcomeCallable;
typedef std::function<void(const DtsClient*, const Model::StopMigrationJobRequest&, const StopMigrationJobOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> StopMigrationJobAsyncHandler;
typedef Outcome<Error, Model::SummaryJobDetailResult> SummaryJobDetailOutcome;
typedef std::future<SummaryJobDetailOutcome> SummaryJobDetailOutcomeCallable;
typedef std::function<void(const DtsClient*, const Model::SummaryJobDetailRequest&, const SummaryJobDetailOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> SummaryJobDetailAsyncHandler;
typedef Outcome<Error, Model::SuspendDtsJobResult> SuspendDtsJobOutcome;
typedef std::future<SuspendDtsJobOutcome> SuspendDtsJobOutcomeCallable;
typedef std::function<void(const DtsClient*, const Model::SuspendDtsJobRequest&, const SuspendDtsJobOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& 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<const AsyncCallerContext>& context = nullptr) const;
SuspendDtsJobOutcomeCallable suspendDtsJobCallable(const Model::SuspendDtsJobRequest& request) const;

View File

@@ -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_;

View File

@@ -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;
};

View File

@@ -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 <string>
#include <vector>
#include <alibabacloud/core/RpcServiceRequest.h>
#include <alibabacloud/dts/DtsExport.h>
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_

View File

@@ -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 <string>
#include <vector>
#include <utility>
#include <alibabacloud/core/ServiceResult.h>
#include <alibabacloud/dts/DtsExport.h>
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_

View File

@@ -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_;

View File

@@ -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 <string>
#include <vector>
#include <alibabacloud/core/RpcServiceRequest.h>
#include <alibabacloud/dts/DtsExport.h>
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_

View File

@@ -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 <string>
#include <vector>
#include <utility>
#include <alibabacloud/core/ServiceResult.h>
#include <alibabacloud/dts/DtsExport.h>
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<ProgressSummaryDetail> 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<ProgressSummaryDetail> progressSummaryDetails_;
int httpStatusCode_;
std::string code_;
std::string jobId_;
bool success_;
};
}
}
}
#endif // !ALIBABACLOUD_DTS_MODEL_SUMMARYJOBDETAILRESULT_H_

View File

@@ -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<const AsyncCallerContext>& 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<std::packaged_task<IgnoreJobDetailOutcome()>>(
[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<const AsyncCallerContext>& 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<std::packaged_task<SummaryJobDetailOutcome()>>(
[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();

View File

@@ -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_;

View File

@@ -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)
{

View File

@@ -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 <alibabacloud/dts/model/IgnoreJobDetailRequest.h>
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);
}

View File

@@ -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 <alibabacloud/dts/model/IgnoreJobDetailResult.h>
#include <json/json.h>
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_;
}

View File

@@ -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

View File

@@ -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 <alibabacloud/dts/model/SummaryJobDetailRequest.h>
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);
}

View File

@@ -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 <alibabacloud/dts/model/SummaryJobDetailResult.h>
#include <json/json.h>
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::ProgressSummaryDetail> 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_;
}