Generated 2019-09-01 for OceanBasePro.
This commit is contained in:
sdk-team
@@ -339,6 +339,42 @@ OceanBaseProClient::CreateMySqlDataSourceOutcomeCallable OceanBaseProClient::cre
|
||||
return task->get_future();
|
||||
}
|
||||
|
||||
OceanBaseProClient::CreateOasOutlineTaskOutcome OceanBaseProClient::createOasOutlineTask(const CreateOasOutlineTaskRequest &request) const
|
||||
{
|
||||
auto endpointOutcome = endpointProvider_->getEndpoint();
|
||||
if (!endpointOutcome.isSuccess())
|
||||
return CreateOasOutlineTaskOutcome(endpointOutcome.error());
|
||||
|
||||
auto outcome = makeRequest(endpointOutcome.result(), request);
|
||||
|
||||
if (outcome.isSuccess())
|
||||
return CreateOasOutlineTaskOutcome(CreateOasOutlineTaskResult(outcome.result()));
|
||||
else
|
||||
return CreateOasOutlineTaskOutcome(outcome.error());
|
||||
}
|
||||
|
||||
void OceanBaseProClient::createOasOutlineTaskAsync(const CreateOasOutlineTaskRequest& request, const CreateOasOutlineTaskAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
||||
{
|
||||
auto fn = [this, request, handler, context]()
|
||||
{
|
||||
handler(this, request, createOasOutlineTask(request), context);
|
||||
};
|
||||
|
||||
asyncExecute(new Runnable(fn));
|
||||
}
|
||||
|
||||
OceanBaseProClient::CreateOasOutlineTaskOutcomeCallable OceanBaseProClient::createOasOutlineTaskCallable(const CreateOasOutlineTaskRequest &request) const
|
||||
{
|
||||
auto task = std::make_shared<std::packaged_task<CreateOasOutlineTaskOutcome()>>(
|
||||
[this, request]()
|
||||
{
|
||||
return this->createOasOutlineTask(request);
|
||||
});
|
||||
|
||||
asyncExecute(new Runnable([task]() { (*task)(); }));
|
||||
return task->get_future();
|
||||
}
|
||||
|
||||
OceanBaseProClient::CreateOceanBaseDataSourceOutcome OceanBaseProClient::createOceanBaseDataSource(const CreateOceanBaseDataSourceRequest &request) const
|
||||
{
|
||||
auto endpointOutcome = endpointProvider_->getEndpoint();
|
||||
@@ -1527,6 +1563,42 @@ OceanBaseProClient::DescribeInstanceOutcomeCallable OceanBaseProClient::describe
|
||||
return task->get_future();
|
||||
}
|
||||
|
||||
OceanBaseProClient::DescribeInstanceAvailableZonesOutcome OceanBaseProClient::describeInstanceAvailableZones(const DescribeInstanceAvailableZonesRequest &request) const
|
||||
{
|
||||
auto endpointOutcome = endpointProvider_->getEndpoint();
|
||||
if (!endpointOutcome.isSuccess())
|
||||
return DescribeInstanceAvailableZonesOutcome(endpointOutcome.error());
|
||||
|
||||
auto outcome = makeRequest(endpointOutcome.result(), request);
|
||||
|
||||
if (outcome.isSuccess())
|
||||
return DescribeInstanceAvailableZonesOutcome(DescribeInstanceAvailableZonesResult(outcome.result()));
|
||||
else
|
||||
return DescribeInstanceAvailableZonesOutcome(outcome.error());
|
||||
}
|
||||
|
||||
void OceanBaseProClient::describeInstanceAvailableZonesAsync(const DescribeInstanceAvailableZonesRequest& request, const DescribeInstanceAvailableZonesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
||||
{
|
||||
auto fn = [this, request, handler, context]()
|
||||
{
|
||||
handler(this, request, describeInstanceAvailableZones(request), context);
|
||||
};
|
||||
|
||||
asyncExecute(new Runnable(fn));
|
||||
}
|
||||
|
||||
OceanBaseProClient::DescribeInstanceAvailableZonesOutcomeCallable OceanBaseProClient::describeInstanceAvailableZonesCallable(const DescribeInstanceAvailableZonesRequest &request) const
|
||||
{
|
||||
auto task = std::make_shared<std::packaged_task<DescribeInstanceAvailableZonesOutcome()>>(
|
||||
[this, request]()
|
||||
{
|
||||
return this->describeInstanceAvailableZones(request);
|
||||
});
|
||||
|
||||
asyncExecute(new Runnable([task]() { (*task)(); }));
|
||||
return task->get_future();
|
||||
}
|
||||
|
||||
OceanBaseProClient::DescribeInstanceCreatableZoneOutcome OceanBaseProClient::describeInstanceCreatableZone(const DescribeInstanceCreatableZoneRequest &request) const
|
||||
{
|
||||
auto endpointOutcome = endpointProvider_->getEndpoint();
|
||||
@@ -2427,6 +2499,42 @@ OceanBaseProClient::DescribeProjectStepsOutcomeCallable OceanBaseProClient::desc
|
||||
return task->get_future();
|
||||
}
|
||||
|
||||
OceanBaseProClient::DescribeProxyServiceOutcome OceanBaseProClient::describeProxyService(const DescribeProxyServiceRequest &request) const
|
||||
{
|
||||
auto endpointOutcome = endpointProvider_->getEndpoint();
|
||||
if (!endpointOutcome.isSuccess())
|
||||
return DescribeProxyServiceOutcome(endpointOutcome.error());
|
||||
|
||||
auto outcome = makeRequest(endpointOutcome.result(), request);
|
||||
|
||||
if (outcome.isSuccess())
|
||||
return DescribeProxyServiceOutcome(DescribeProxyServiceResult(outcome.result()));
|
||||
else
|
||||
return DescribeProxyServiceOutcome(outcome.error());
|
||||
}
|
||||
|
||||
void OceanBaseProClient::describeProxyServiceAsync(const DescribeProxyServiceRequest& request, const DescribeProxyServiceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
||||
{
|
||||
auto fn = [this, request, handler, context]()
|
||||
{
|
||||
handler(this, request, describeProxyService(request), context);
|
||||
};
|
||||
|
||||
asyncExecute(new Runnable(fn));
|
||||
}
|
||||
|
||||
OceanBaseProClient::DescribeProxyServiceOutcomeCallable OceanBaseProClient::describeProxyServiceCallable(const DescribeProxyServiceRequest &request) const
|
||||
{
|
||||
auto task = std::make_shared<std::packaged_task<DescribeProxyServiceOutcome()>>(
|
||||
[this, request]()
|
||||
{
|
||||
return this->describeProxyService(request);
|
||||
});
|
||||
|
||||
asyncExecute(new Runnable([task]() { (*task)(); }));
|
||||
return task->get_future();
|
||||
}
|
||||
|
||||
OceanBaseProClient::DescribeRecommendIndexOutcome OceanBaseProClient::describeRecommendIndex(const DescribeRecommendIndexRequest &request) const
|
||||
{
|
||||
auto endpointOutcome = endpointProvider_->getEndpoint();
|
||||
@@ -2859,6 +2967,42 @@ OceanBaseProClient::DescribeSlowSQLListOutcomeCallable OceanBaseProClient::descr
|
||||
return task->get_future();
|
||||
}
|
||||
|
||||
OceanBaseProClient::DescribeSqlAuditStatOutcome OceanBaseProClient::describeSqlAuditStat(const DescribeSqlAuditStatRequest &request) const
|
||||
{
|
||||
auto endpointOutcome = endpointProvider_->getEndpoint();
|
||||
if (!endpointOutcome.isSuccess())
|
||||
return DescribeSqlAuditStatOutcome(endpointOutcome.error());
|
||||
|
||||
auto outcome = makeRequest(endpointOutcome.result(), request);
|
||||
|
||||
if (outcome.isSuccess())
|
||||
return DescribeSqlAuditStatOutcome(DescribeSqlAuditStatResult(outcome.result()));
|
||||
else
|
||||
return DescribeSqlAuditStatOutcome(outcome.error());
|
||||
}
|
||||
|
||||
void OceanBaseProClient::describeSqlAuditStatAsync(const DescribeSqlAuditStatRequest& request, const DescribeSqlAuditStatAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
||||
{
|
||||
auto fn = [this, request, handler, context]()
|
||||
{
|
||||
handler(this, request, describeSqlAuditStat(request), context);
|
||||
};
|
||||
|
||||
asyncExecute(new Runnable(fn));
|
||||
}
|
||||
|
||||
OceanBaseProClient::DescribeSqlAuditStatOutcomeCallable OceanBaseProClient::describeSqlAuditStatCallable(const DescribeSqlAuditStatRequest &request) const
|
||||
{
|
||||
auto task = std::make_shared<std::packaged_task<DescribeSqlAuditStatOutcome()>>(
|
||||
[this, request]()
|
||||
{
|
||||
return this->describeSqlAuditStat(request);
|
||||
});
|
||||
|
||||
asyncExecute(new Runnable([task]() { (*task)(); }));
|
||||
return task->get_future();
|
||||
}
|
||||
|
||||
OceanBaseProClient::DescribeStandbyCreateModeOutcome OceanBaseProClient::describeStandbyCreateMode(const DescribeStandbyCreateModeRequest &request) const
|
||||
{
|
||||
auto endpointOutcome = endpointProvider_->getEndpoint();
|
||||
@@ -4551,6 +4695,42 @@ OceanBaseProClient::ReleaseWorkerInstanceOutcomeCallable OceanBaseProClient::rel
|
||||
return task->get_future();
|
||||
}
|
||||
|
||||
OceanBaseProClient::RemoveStandbyInstanceOutcome OceanBaseProClient::removeStandbyInstance(const RemoveStandbyInstanceRequest &request) const
|
||||
{
|
||||
auto endpointOutcome = endpointProvider_->getEndpoint();
|
||||
if (!endpointOutcome.isSuccess())
|
||||
return RemoveStandbyInstanceOutcome(endpointOutcome.error());
|
||||
|
||||
auto outcome = makeRequest(endpointOutcome.result(), request);
|
||||
|
||||
if (outcome.isSuccess())
|
||||
return RemoveStandbyInstanceOutcome(RemoveStandbyInstanceResult(outcome.result()));
|
||||
else
|
||||
return RemoveStandbyInstanceOutcome(outcome.error());
|
||||
}
|
||||
|
||||
void OceanBaseProClient::removeStandbyInstanceAsync(const RemoveStandbyInstanceRequest& request, const RemoveStandbyInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
||||
{
|
||||
auto fn = [this, request, handler, context]()
|
||||
{
|
||||
handler(this, request, removeStandbyInstance(request), context);
|
||||
};
|
||||
|
||||
asyncExecute(new Runnable(fn));
|
||||
}
|
||||
|
||||
OceanBaseProClient::RemoveStandbyInstanceOutcomeCallable OceanBaseProClient::removeStandbyInstanceCallable(const RemoveStandbyInstanceRequest &request) const
|
||||
{
|
||||
auto task = std::make_shared<std::packaged_task<RemoveStandbyInstanceOutcome()>>(
|
||||
[this, request]()
|
||||
{
|
||||
return this->removeStandbyInstance(request);
|
||||
});
|
||||
|
||||
asyncExecute(new Runnable([task]() { (*task)(); }));
|
||||
return task->get_future();
|
||||
}
|
||||
|
||||
OceanBaseProClient::ResumeProjectOutcome OceanBaseProClient::resumeProject(const ResumeProjectRequest &request) const
|
||||
{
|
||||
auto endpointOutcome = endpointProvider_->getEndpoint();
|
||||
|
||||
@@ -34,6 +34,15 @@ void BatchKillProcessListRequest::setSessionList(const std::string &sessionList)
|
||||
setBodyParameter(std::string("SessionList"), sessionList);
|
||||
}
|
||||
|
||||
bool BatchKillProcessListRequest::getByObSessionId() const {
|
||||
return byObSessionId_;
|
||||
}
|
||||
|
||||
void BatchKillProcessListRequest::setByObSessionId(bool byObSessionId) {
|
||||
byObSessionId_ = byObSessionId;
|
||||
setBodyParameter(std::string("ByObSessionId"), byObSessionId ? "true" : "false");
|
||||
}
|
||||
|
||||
std::string BatchKillProcessListRequest::getInstanceId() const {
|
||||
return instanceId_;
|
||||
}
|
||||
|
||||
171
oceanbasepro/src/model/CreateOasOutlineTaskRequest.cc
Normal file
171
oceanbasepro/src/model/CreateOasOutlineTaskRequest.cc
Normal file
@@ -0,0 +1,171 @@
|
||||
/*
|
||||
* 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/oceanbasepro/model/CreateOasOutlineTaskRequest.h>
|
||||
|
||||
using AlibabaCloud::OceanBasePro::Model::CreateOasOutlineTaskRequest;
|
||||
|
||||
CreateOasOutlineTaskRequest::CreateOasOutlineTaskRequest()
|
||||
: RpcServiceRequest("oceanbasepro", "2019-09-01", "CreateOasOutlineTask") {
|
||||
setMethod(HttpRequest::Method::Post);
|
||||
}
|
||||
|
||||
CreateOasOutlineTaskRequest::~CreateOasOutlineTaskRequest() {}
|
||||
|
||||
std::string CreateOasOutlineTaskRequest::getStartTime() const {
|
||||
return startTime_;
|
||||
}
|
||||
|
||||
void CreateOasOutlineTaskRequest::setStartTime(const std::string &startTime) {
|
||||
startTime_ = startTime;
|
||||
setBodyParameter(std::string("StartTime"), startTime);
|
||||
}
|
||||
|
||||
std::string CreateOasOutlineTaskRequest::getUId() const {
|
||||
return uId_;
|
||||
}
|
||||
|
||||
void CreateOasOutlineTaskRequest::setUId(const std::string &uId) {
|
||||
uId_ = uId;
|
||||
setBodyParameter(std::string("UId"), uId);
|
||||
}
|
||||
|
||||
bool CreateOasOutlineTaskRequest::getDynamicSql() const {
|
||||
return dynamicSql_;
|
||||
}
|
||||
|
||||
void CreateOasOutlineTaskRequest::setDynamicSql(bool dynamicSql) {
|
||||
dynamicSql_ = dynamicSql;
|
||||
setBodyParameter(std::string("DynamicSql"), dynamicSql ? "true" : "false");
|
||||
}
|
||||
|
||||
std::string CreateOasOutlineTaskRequest::getSqlText() const {
|
||||
return sqlText_;
|
||||
}
|
||||
|
||||
void CreateOasOutlineTaskRequest::setSqlText(const std::string &sqlText) {
|
||||
sqlText_ = sqlText;
|
||||
setBodyParameter(std::string("SqlText"), sqlText);
|
||||
}
|
||||
|
||||
bool CreateOasOutlineTaskRequest::getBySqlId() const {
|
||||
return bySqlId_;
|
||||
}
|
||||
|
||||
void CreateOasOutlineTaskRequest::setBySqlId(bool bySqlId) {
|
||||
bySqlId_ = bySqlId;
|
||||
setBodyParameter(std::string("BySqlId"), bySqlId ? "true" : "false");
|
||||
}
|
||||
|
||||
int CreateOasOutlineTaskRequest::getMaxConcurrent() const {
|
||||
return maxConcurrent_;
|
||||
}
|
||||
|
||||
void CreateOasOutlineTaskRequest::setMaxConcurrent(int maxConcurrent) {
|
||||
maxConcurrent_ = maxConcurrent;
|
||||
setBodyParameter(std::string("MaxConcurrent"), std::to_string(maxConcurrent));
|
||||
}
|
||||
|
||||
std::string CreateOasOutlineTaskRequest::getTenantId() const {
|
||||
return tenantId_;
|
||||
}
|
||||
|
||||
void CreateOasOutlineTaskRequest::setTenantId(const std::string &tenantId) {
|
||||
tenantId_ = tenantId;
|
||||
setBodyParameter(std::string("TenantId"), tenantId);
|
||||
}
|
||||
|
||||
std::string CreateOasOutlineTaskRequest::getStatementId() const {
|
||||
return statementId_;
|
||||
}
|
||||
|
||||
void CreateOasOutlineTaskRequest::setStatementId(const std::string &statementId) {
|
||||
statementId_ = statementId;
|
||||
setBodyParameter(std::string("StatementId"), statementId);
|
||||
}
|
||||
|
||||
std::string CreateOasOutlineTaskRequest::getTableName() const {
|
||||
return tableName_;
|
||||
}
|
||||
|
||||
void CreateOasOutlineTaskRequest::setTableName(const std::string &tableName) {
|
||||
tableName_ = tableName;
|
||||
setBodyParameter(std::string("TableName"), tableName);
|
||||
}
|
||||
|
||||
std::string CreateOasOutlineTaskRequest::getSqlId() const {
|
||||
return sqlId_;
|
||||
}
|
||||
|
||||
void CreateOasOutlineTaskRequest::setSqlId(const std::string &sqlId) {
|
||||
sqlId_ = sqlId;
|
||||
setBodyParameter(std::string("SqlId"), sqlId);
|
||||
}
|
||||
|
||||
std::string CreateOasOutlineTaskRequest::getEndTime() const {
|
||||
return endTime_;
|
||||
}
|
||||
|
||||
void CreateOasOutlineTaskRequest::setEndTime(const std::string &endTime) {
|
||||
endTime_ = endTime;
|
||||
setBodyParameter(std::string("EndTime"), endTime);
|
||||
}
|
||||
|
||||
std::string CreateOasOutlineTaskRequest::getInstanceId() const {
|
||||
return instanceId_;
|
||||
}
|
||||
|
||||
void CreateOasOutlineTaskRequest::setInstanceId(const std::string &instanceId) {
|
||||
instanceId_ = instanceId;
|
||||
setBodyParameter(std::string("InstanceId"), instanceId);
|
||||
}
|
||||
|
||||
std::string CreateOasOutlineTaskRequest::getPlanData() const {
|
||||
return planData_;
|
||||
}
|
||||
|
||||
void CreateOasOutlineTaskRequest::setPlanData(const std::string &planData) {
|
||||
planData_ = planData;
|
||||
setBodyParameter(std::string("PlanData"), planData);
|
||||
}
|
||||
|
||||
std::string CreateOasOutlineTaskRequest::getIndexName() const {
|
||||
return indexName_;
|
||||
}
|
||||
|
||||
void CreateOasOutlineTaskRequest::setIndexName(const std::string &indexName) {
|
||||
indexName_ = indexName;
|
||||
setBodyParameter(std::string("IndexName"), indexName);
|
||||
}
|
||||
|
||||
std::string CreateOasOutlineTaskRequest::getDatabaseName() const {
|
||||
return databaseName_;
|
||||
}
|
||||
|
||||
void CreateOasOutlineTaskRequest::setDatabaseName(const std::string &databaseName) {
|
||||
databaseName_ = databaseName;
|
||||
setBodyParameter(std::string("DatabaseName"), databaseName);
|
||||
}
|
||||
|
||||
bool CreateOasOutlineTaskRequest::getIsConcurrentLimit() const {
|
||||
return isConcurrentLimit_;
|
||||
}
|
||||
|
||||
void CreateOasOutlineTaskRequest::setIsConcurrentLimit(bool isConcurrentLimit) {
|
||||
isConcurrentLimit_ = isConcurrentLimit;
|
||||
setBodyParameter(std::string("IsConcurrentLimit"), isConcurrentLimit ? "true" : "false");
|
||||
}
|
||||
|
||||
58
oceanbasepro/src/model/CreateOasOutlineTaskResult.cc
Normal file
58
oceanbasepro/src/model/CreateOasOutlineTaskResult.cc
Normal file
@@ -0,0 +1,58 @@
|
||||
/*
|
||||
* 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/oceanbasepro/model/CreateOasOutlineTaskResult.h>
|
||||
#include <json/json.h>
|
||||
|
||||
using namespace AlibabaCloud::OceanBasePro;
|
||||
using namespace AlibabaCloud::OceanBasePro::Model;
|
||||
|
||||
CreateOasOutlineTaskResult::CreateOasOutlineTaskResult() :
|
||||
ServiceResult()
|
||||
{}
|
||||
|
||||
CreateOasOutlineTaskResult::CreateOasOutlineTaskResult(const std::string &payload) :
|
||||
ServiceResult()
|
||||
{
|
||||
parse(payload);
|
||||
}
|
||||
|
||||
CreateOasOutlineTaskResult::~CreateOasOutlineTaskResult()
|
||||
{}
|
||||
|
||||
void CreateOasOutlineTaskResult::parse(const std::string &payload)
|
||||
{
|
||||
Json::Reader reader;
|
||||
Json::Value value;
|
||||
reader.parse(payload, value);
|
||||
setRequestId(value["RequestId"].asString());
|
||||
if(!value["Success"].isNull())
|
||||
success_ = value["Success"].asString() == "true";
|
||||
if(!value["Message"].isNull())
|
||||
message_ = value["Message"].asString();
|
||||
|
||||
}
|
||||
|
||||
std::string CreateOasOutlineTaskResult::getMessage()const
|
||||
{
|
||||
return message_;
|
||||
}
|
||||
|
||||
bool CreateOasOutlineTaskResult::getSuccess()const
|
||||
{
|
||||
return success_;
|
||||
}
|
||||
|
||||
@@ -58,6 +58,9 @@ void CreateProjectModifyRecordsRequest::setDatabases(const std::vector<CreatePro
|
||||
for(int dep3 = 0; dep3 != databases[dep1].tables[dep2].filterColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("Databases") + "." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".FilterColumns." + std::to_string(dep3 + 1), databases[dep1].tables[dep2].filterColumns[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("Databases") + "." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".ObkvPartitionConfig.VirtualColumn", databases[dep1].tables[dep2].obkvPartitionConfig.virtualColumn);
|
||||
setBodyParameter(std::string("Databases") + "." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".ObkvPartitionConfig.PartitionType", databases[dep1].tables[dep2].obkvPartitionConfig.partitionType);
|
||||
setBodyParameter(std::string("Databases") + "." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".ObkvPartitionConfig.PartitionSize", std::to_string(databases[dep1].tables[dep2].obkvPartitionConfig.partitionSize));
|
||||
for(int dep3 = 0; dep3 != databases[dep1].tables[dep2].adbTableSchema.primaryKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("Databases") + "." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PrimaryKeys." + std::to_string(dep3 + 1), databases[dep1].tables[dep2].adbTableSchema.primaryKeys[dep3]);
|
||||
}
|
||||
@@ -118,6 +121,312 @@ void CreateProjectModifyRecordsRequest::setDatabases(const std::vector<CreatePro
|
||||
}
|
||||
}
|
||||
|
||||
CreateProjectModifyRecordsRequest::TransferMapping CreateProjectModifyRecordsRequest::getTransferMapping() const {
|
||||
return transferMapping_;
|
||||
}
|
||||
|
||||
void CreateProjectModifyRecordsRequest::setTransferMapping(const CreateProjectModifyRecordsRequest::TransferMapping &transferMapping) {
|
||||
transferMapping_ = transferMapping;
|
||||
setBodyParameter(std::string("TransferMapping") + ".Mode", transferMapping.mode);
|
||||
for(int dep1 = 0; dep1 != transferMapping.databases.size(); dep1++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".MappedName", transferMapping.databases[dep1].mappedName);
|
||||
for(int dep2 = 0; dep2 != transferMapping.databases[dep1].specificViews.size(); dep2++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".MappedName", transferMapping.databases[dep1].specificViews[dep2].mappedName);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].specificViews[dep2].filterColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".FilterColumns." + std::to_string(dep3 + 1), transferMapping.databases[dep1].specificViews[dep2].filterColumns[dep3]);
|
||||
}
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].specificViews[dep2].adbTableSchema.primaryKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".AdbTableSchema.PrimaryKeys." + std::to_string(dep3 + 1), transferMapping.databases[dep1].specificViews[dep2].adbTableSchema.primaryKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionStatement", transferMapping.databases[dep1].specificViews[dep2].adbTableSchema.partitionStatement);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionLifeCycle", transferMapping.databases[dep1].specificViews[dep2].adbTableSchema.partitionLifeCycle);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].specificViews[dep2].adbTableSchema.distributedKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".AdbTableSchema.DistributedKeys." + std::to_string(dep3 + 1), transferMapping.databases[dep1].specificViews[dep2].adbTableSchema.distributedKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".Name", transferMapping.databases[dep1].specificViews[dep2].name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".WhereClause", transferMapping.databases[dep1].specificViews[dep2].whereClause);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".Id", transferMapping.databases[dep1].specificViews[dep2].id);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].specificViews[dep2].shardColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".ShardColumns." + std::to_string(dep3 + 1), transferMapping.databases[dep1].specificViews[dep2].shardColumns[dep3]);
|
||||
}
|
||||
}
|
||||
for(int dep2 = 0; dep2 != transferMapping.databases[dep1].tables.size(); dep2++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".MappedName", transferMapping.databases[dep1].tables[dep2].mappedName);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].tables[dep2].filterColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".FilterColumns." + std::to_string(dep3 + 1), transferMapping.databases[dep1].tables[dep2].filterColumns[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".ObkvPartitionConfig.VirtualColumn", transferMapping.databases[dep1].tables[dep2].obkvPartitionConfig.virtualColumn);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".ObkvPartitionConfig.PartitionType", transferMapping.databases[dep1].tables[dep2].obkvPartitionConfig.partitionType);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".ObkvPartitionConfig.PartitionSize", std::to_string(transferMapping.databases[dep1].tables[dep2].obkvPartitionConfig.partitionSize));
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].tables[dep2].adbTableSchema.primaryKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PrimaryKeys." + std::to_string(dep3 + 1), transferMapping.databases[dep1].tables[dep2].adbTableSchema.primaryKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionStatement", transferMapping.databases[dep1].tables[dep2].adbTableSchema.partitionStatement);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionLifeCycle", transferMapping.databases[dep1].tables[dep2].adbTableSchema.partitionLifeCycle);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].tables[dep2].adbTableSchema.distributedKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".AdbTableSchema.DistributedKeys." + std::to_string(dep3 + 1), transferMapping.databases[dep1].tables[dep2].adbTableSchema.distributedKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".Name", transferMapping.databases[dep1].tables[dep2].name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".WhereClause", transferMapping.databases[dep1].tables[dep2].whereClause);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".Id", transferMapping.databases[dep1].tables[dep2].id);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].tables[dep2].shardColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".ShardColumns." + std::to_string(dep3 + 1), transferMapping.databases[dep1].tables[dep2].shardColumns[dep3]);
|
||||
}
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".ClusterName", transferMapping.databases[dep1].clusterName);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Name", transferMapping.databases[dep1].name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".TenantName", transferMapping.databases[dep1].tenantName);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Id", transferMapping.databases[dep1].id);
|
||||
for(int dep2 = 0; dep2 != transferMapping.databases[dep1].specificTables.size(); dep2++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".MappedName", transferMapping.databases[dep1].specificTables[dep2].mappedName);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].specificTables[dep2].filterColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".FilterColumns." + std::to_string(dep3 + 1), transferMapping.databases[dep1].specificTables[dep2].filterColumns[dep3]);
|
||||
}
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].specificTables[dep2].adbTableSchema.primaryKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PrimaryKeys." + std::to_string(dep3 + 1), transferMapping.databases[dep1].specificTables[dep2].adbTableSchema.primaryKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionStatement", transferMapping.databases[dep1].specificTables[dep2].adbTableSchema.partitionStatement);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionLifeCycle", transferMapping.databases[dep1].specificTables[dep2].adbTableSchema.partitionLifeCycle);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].specificTables[dep2].adbTableSchema.distributedKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".AdbTableSchema.DistributedKeys." + std::to_string(dep3 + 1), transferMapping.databases[dep1].specificTables[dep2].adbTableSchema.distributedKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".Name", transferMapping.databases[dep1].specificTables[dep2].name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".WhereClause", transferMapping.databases[dep1].specificTables[dep2].whereClause);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".Id", transferMapping.databases[dep1].specificTables[dep2].id);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].specificTables[dep2].shardColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".ShardColumns." + std::to_string(dep3 + 1), transferMapping.databases[dep1].specificTables[dep2].shardColumns[dep3]);
|
||||
}
|
||||
}
|
||||
for(int dep2 = 0; dep2 != transferMapping.databases[dep1].views.size(); dep2++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".MappedName", transferMapping.databases[dep1].views[dep2].mappedName);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].views[dep2].filterColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".FilterColumns." + std::to_string(dep3 + 1), transferMapping.databases[dep1].views[dep2].filterColumns[dep3]);
|
||||
}
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].views[dep2].adbTableSchema.primaryKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".AdbTableSchema.PrimaryKeys." + std::to_string(dep3 + 1), transferMapping.databases[dep1].views[dep2].adbTableSchema.primaryKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionStatement", transferMapping.databases[dep1].views[dep2].adbTableSchema.partitionStatement);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionLifeCycle", transferMapping.databases[dep1].views[dep2].adbTableSchema.partitionLifeCycle);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].views[dep2].adbTableSchema.distributedKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".AdbTableSchema.DistributedKeys." + std::to_string(dep3 + 1), transferMapping.databases[dep1].views[dep2].adbTableSchema.distributedKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".Name", transferMapping.databases[dep1].views[dep2].name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".WhereClause", transferMapping.databases[dep1].views[dep2].whereClause);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".Id", transferMapping.databases[dep1].views[dep2].id);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].views[dep2].shardColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".ShardColumns." + std::to_string(dep3 + 1), transferMapping.databases[dep1].views[dep2].shardColumns[dep3]);
|
||||
}
|
||||
}
|
||||
}
|
||||
for(int dep1 = 0; dep1 != transferMapping.tableAndViewBlackList.size(); dep1++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".TableAndViewBlackList." + std::to_string(dep1 + 1), transferMapping.tableAndViewBlackList[dep1]);
|
||||
}
|
||||
for(int dep1 = 0; dep1 != transferMapping.blackTableRules.size(); dep1++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".BlackTableRules." + std::to_string(dep1 + 1) + ".ObjectMapping.MappedName", transferMapping.blackTableRules[dep1].objectMapping.mappedName);
|
||||
setBodyParameter(std::string("TransferMapping") + ".BlackTableRules." + std::to_string(dep1 + 1) + ".ObjectMapping.Name", transferMapping.blackTableRules[dep1].objectMapping.name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".BlackTableRules." + std::to_string(dep1 + 1) + ".SchemaMapping.MappedName", transferMapping.blackTableRules[dep1].schemaMapping.mappedName);
|
||||
setBodyParameter(std::string("TransferMapping") + ".BlackTableRules." + std::to_string(dep1 + 1) + ".SchemaMapping.Name", transferMapping.blackTableRules[dep1].schemaMapping.name);
|
||||
}
|
||||
for(int dep1 = 0; dep1 != transferMapping.schemas.size(); dep1++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".MappedName", transferMapping.schemas[dep1].mappedName);
|
||||
for(int dep2 = 0; dep2 != transferMapping.schemas[dep1].specificViews.size(); dep2++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".MappedName", transferMapping.schemas[dep1].specificViews[dep2].mappedName);
|
||||
for(int dep3 = 0; dep3 != transferMapping.schemas[dep1].specificViews[dep2].filterColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".FilterColumns." + std::to_string(dep3 + 1), transferMapping.schemas[dep1].specificViews[dep2].filterColumns[dep3]);
|
||||
}
|
||||
for(int dep3 = 0; dep3 != transferMapping.schemas[dep1].specificViews[dep2].adbTableSchema.primaryKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".AdbTableSchema.PrimaryKeys." + std::to_string(dep3 + 1), transferMapping.schemas[dep1].specificViews[dep2].adbTableSchema.primaryKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionStatement", transferMapping.schemas[dep1].specificViews[dep2].adbTableSchema.partitionStatement);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionLifeCycle", transferMapping.schemas[dep1].specificViews[dep2].adbTableSchema.partitionLifeCycle);
|
||||
for(int dep3 = 0; dep3 != transferMapping.schemas[dep1].specificViews[dep2].adbTableSchema.distributedKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".AdbTableSchema.DistributedKeys." + std::to_string(dep3 + 1), transferMapping.schemas[dep1].specificViews[dep2].adbTableSchema.distributedKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".Name", transferMapping.schemas[dep1].specificViews[dep2].name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".WhereClause", transferMapping.schemas[dep1].specificViews[dep2].whereClause);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".Id", transferMapping.schemas[dep1].specificViews[dep2].id);
|
||||
for(int dep3 = 0; dep3 != transferMapping.schemas[dep1].specificViews[dep2].shardColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".ShardColumns." + std::to_string(dep3 + 1), transferMapping.schemas[dep1].specificViews[dep2].shardColumns[dep3]);
|
||||
}
|
||||
}
|
||||
for(int dep2 = 0; dep2 != transferMapping.schemas[dep1].tables.size(); dep2++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".MappedName", transferMapping.schemas[dep1].tables[dep2].mappedName);
|
||||
for(int dep3 = 0; dep3 != transferMapping.schemas[dep1].tables[dep2].filterColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".FilterColumns." + std::to_string(dep3 + 1), transferMapping.schemas[dep1].tables[dep2].filterColumns[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".ObkvPartitionConfig.VirtualColumn", transferMapping.schemas[dep1].tables[dep2].obkvPartitionConfig.virtualColumn);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".ObkvPartitionConfig.PartitionType", transferMapping.schemas[dep1].tables[dep2].obkvPartitionConfig.partitionType);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".ObkvPartitionConfig.PartitionSize", std::to_string(transferMapping.schemas[dep1].tables[dep2].obkvPartitionConfig.partitionSize));
|
||||
for(int dep3 = 0; dep3 != transferMapping.schemas[dep1].tables[dep2].adbTableSchema.primaryKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PrimaryKeys." + std::to_string(dep3 + 1), transferMapping.schemas[dep1].tables[dep2].adbTableSchema.primaryKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionStatement", transferMapping.schemas[dep1].tables[dep2].adbTableSchema.partitionStatement);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionLifeCycle", transferMapping.schemas[dep1].tables[dep2].adbTableSchema.partitionLifeCycle);
|
||||
for(int dep3 = 0; dep3 != transferMapping.schemas[dep1].tables[dep2].adbTableSchema.distributedKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".AdbTableSchema.DistributedKeys." + std::to_string(dep3 + 1), transferMapping.schemas[dep1].tables[dep2].adbTableSchema.distributedKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".Name", transferMapping.schemas[dep1].tables[dep2].name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".WhereClause", transferMapping.schemas[dep1].tables[dep2].whereClause);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".Id", transferMapping.schemas[dep1].tables[dep2].id);
|
||||
for(int dep3 = 0; dep3 != transferMapping.schemas[dep1].tables[dep2].shardColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".ShardColumns." + std::to_string(dep3 + 1), transferMapping.schemas[dep1].tables[dep2].shardColumns[dep3]);
|
||||
}
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".ClusterName", transferMapping.schemas[dep1].clusterName);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Name", transferMapping.schemas[dep1].name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".TenantName", transferMapping.schemas[dep1].tenantName);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Id", transferMapping.schemas[dep1].id);
|
||||
for(int dep2 = 0; dep2 != transferMapping.schemas[dep1].specificTables.size(); dep2++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".MappedName", transferMapping.schemas[dep1].specificTables[dep2].mappedName);
|
||||
for(int dep3 = 0; dep3 != transferMapping.schemas[dep1].specificTables[dep2].filterColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".FilterColumns." + std::to_string(dep3 + 1), transferMapping.schemas[dep1].specificTables[dep2].filterColumns[dep3]);
|
||||
}
|
||||
for(int dep3 = 0; dep3 != transferMapping.schemas[dep1].specificTables[dep2].adbTableSchema.primaryKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PrimaryKeys." + std::to_string(dep3 + 1), transferMapping.schemas[dep1].specificTables[dep2].adbTableSchema.primaryKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionStatement", transferMapping.schemas[dep1].specificTables[dep2].adbTableSchema.partitionStatement);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionLifeCycle", transferMapping.schemas[dep1].specificTables[dep2].adbTableSchema.partitionLifeCycle);
|
||||
for(int dep3 = 0; dep3 != transferMapping.schemas[dep1].specificTables[dep2].adbTableSchema.distributedKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".AdbTableSchema.DistributedKeys." + std::to_string(dep3 + 1), transferMapping.schemas[dep1].specificTables[dep2].adbTableSchema.distributedKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".Name", transferMapping.schemas[dep1].specificTables[dep2].name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".WhereClause", transferMapping.schemas[dep1].specificTables[dep2].whereClause);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".Id", transferMapping.schemas[dep1].specificTables[dep2].id);
|
||||
for(int dep3 = 0; dep3 != transferMapping.schemas[dep1].specificTables[dep2].shardColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".ShardColumns." + std::to_string(dep3 + 1), transferMapping.schemas[dep1].specificTables[dep2].shardColumns[dep3]);
|
||||
}
|
||||
}
|
||||
for(int dep2 = 0; dep2 != transferMapping.schemas[dep1].views.size(); dep2++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".MappedName", transferMapping.schemas[dep1].views[dep2].mappedName);
|
||||
for(int dep3 = 0; dep3 != transferMapping.schemas[dep1].views[dep2].filterColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".FilterColumns." + std::to_string(dep3 + 1), transferMapping.schemas[dep1].views[dep2].filterColumns[dep3]);
|
||||
}
|
||||
for(int dep3 = 0; dep3 != transferMapping.schemas[dep1].views[dep2].adbTableSchema.primaryKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".AdbTableSchema.PrimaryKeys." + std::to_string(dep3 + 1), transferMapping.schemas[dep1].views[dep2].adbTableSchema.primaryKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionStatement", transferMapping.schemas[dep1].views[dep2].adbTableSchema.partitionStatement);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionLifeCycle", transferMapping.schemas[dep1].views[dep2].adbTableSchema.partitionLifeCycle);
|
||||
for(int dep3 = 0; dep3 != transferMapping.schemas[dep1].views[dep2].adbTableSchema.distributedKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".AdbTableSchema.DistributedKeys." + std::to_string(dep3 + 1), transferMapping.schemas[dep1].views[dep2].adbTableSchema.distributedKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".Name", transferMapping.schemas[dep1].views[dep2].name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".WhereClause", transferMapping.schemas[dep1].views[dep2].whereClause);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".Id", transferMapping.schemas[dep1].views[dep2].id);
|
||||
for(int dep3 = 0; dep3 != transferMapping.schemas[dep1].views[dep2].shardColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Schemas." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".ShardColumns." + std::to_string(dep3 + 1), transferMapping.schemas[dep1].views[dep2].shardColumns[dep3]);
|
||||
}
|
||||
}
|
||||
}
|
||||
for(int dep1 = 0; dep1 != transferMapping.blackViewRules.size(); dep1++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".BlackViewRules." + std::to_string(dep1 + 1) + ".ObjectMapping.MappedName", transferMapping.blackViewRules[dep1].objectMapping.mappedName);
|
||||
setBodyParameter(std::string("TransferMapping") + ".BlackViewRules." + std::to_string(dep1 + 1) + ".ObjectMapping.Name", transferMapping.blackViewRules[dep1].objectMapping.name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".BlackViewRules." + std::to_string(dep1 + 1) + ".SchemaMapping.MappedName", transferMapping.blackViewRules[dep1].schemaMapping.mappedName);
|
||||
setBodyParameter(std::string("TransferMapping") + ".BlackViewRules." + std::to_string(dep1 + 1) + ".SchemaMapping.Name", transferMapping.blackViewRules[dep1].schemaMapping.name);
|
||||
}
|
||||
for(int dep1 = 0; dep1 != transferMapping.databasesBlack.size(); dep1++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".MappedName", transferMapping.databasesBlack[dep1].mappedName);
|
||||
for(int dep2 = 0; dep2 != transferMapping.databasesBlack[dep1].specificViews.size(); dep2++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".MappedName", transferMapping.databasesBlack[dep1].specificViews[dep2].mappedName);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databasesBlack[dep1].specificViews[dep2].filterColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".FilterColumns." + std::to_string(dep3 + 1), transferMapping.databasesBlack[dep1].specificViews[dep2].filterColumns[dep3]);
|
||||
}
|
||||
for(int dep3 = 0; dep3 != transferMapping.databasesBlack[dep1].specificViews[dep2].adbTableSchema.primaryKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".AdbTableSchema.PrimaryKeys." + std::to_string(dep3 + 1), transferMapping.databasesBlack[dep1].specificViews[dep2].adbTableSchema.primaryKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionStatement", transferMapping.databasesBlack[dep1].specificViews[dep2].adbTableSchema.partitionStatement);
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionLifeCycle", transferMapping.databasesBlack[dep1].specificViews[dep2].adbTableSchema.partitionLifeCycle);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databasesBlack[dep1].specificViews[dep2].adbTableSchema.distributedKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".AdbTableSchema.DistributedKeys." + std::to_string(dep3 + 1), transferMapping.databasesBlack[dep1].specificViews[dep2].adbTableSchema.distributedKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".Name", transferMapping.databasesBlack[dep1].specificViews[dep2].name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".WhereClause", transferMapping.databasesBlack[dep1].specificViews[dep2].whereClause);
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".Id", transferMapping.databasesBlack[dep1].specificViews[dep2].id);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databasesBlack[dep1].specificViews[dep2].shardColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificViews." + std::to_string(dep2 + 1) + ".ShardColumns." + std::to_string(dep3 + 1), transferMapping.databasesBlack[dep1].specificViews[dep2].shardColumns[dep3]);
|
||||
}
|
||||
}
|
||||
for(int dep2 = 0; dep2 != transferMapping.databasesBlack[dep1].tables.size(); dep2++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".MappedName", transferMapping.databasesBlack[dep1].tables[dep2].mappedName);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databasesBlack[dep1].tables[dep2].filterColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".FilterColumns." + std::to_string(dep3 + 1), transferMapping.databasesBlack[dep1].tables[dep2].filterColumns[dep3]);
|
||||
}
|
||||
for(int dep3 = 0; dep3 != transferMapping.databasesBlack[dep1].tables[dep2].adbTableSchema.primaryKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PrimaryKeys." + std::to_string(dep3 + 1), transferMapping.databasesBlack[dep1].tables[dep2].adbTableSchema.primaryKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionStatement", transferMapping.databasesBlack[dep1].tables[dep2].adbTableSchema.partitionStatement);
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionLifeCycle", transferMapping.databasesBlack[dep1].tables[dep2].adbTableSchema.partitionLifeCycle);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databasesBlack[dep1].tables[dep2].adbTableSchema.distributedKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".AdbTableSchema.DistributedKeys." + std::to_string(dep3 + 1), transferMapping.databasesBlack[dep1].tables[dep2].adbTableSchema.distributedKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".Name", transferMapping.databasesBlack[dep1].tables[dep2].name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".WhereClause", transferMapping.databasesBlack[dep1].tables[dep2].whereClause);
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".Id", transferMapping.databasesBlack[dep1].tables[dep2].id);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databasesBlack[dep1].tables[dep2].shardColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".ShardColumns." + std::to_string(dep3 + 1), transferMapping.databasesBlack[dep1].tables[dep2].shardColumns[dep3]);
|
||||
}
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".ClusterName", transferMapping.databasesBlack[dep1].clusterName);
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Name", transferMapping.databasesBlack[dep1].name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".TenantName", transferMapping.databasesBlack[dep1].tenantName);
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Id", transferMapping.databasesBlack[dep1].id);
|
||||
for(int dep2 = 0; dep2 != transferMapping.databasesBlack[dep1].specificTables.size(); dep2++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".MappedName", transferMapping.databasesBlack[dep1].specificTables[dep2].mappedName);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databasesBlack[dep1].specificTables[dep2].filterColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".FilterColumns." + std::to_string(dep3 + 1), transferMapping.databasesBlack[dep1].specificTables[dep2].filterColumns[dep3]);
|
||||
}
|
||||
for(int dep3 = 0; dep3 != transferMapping.databasesBlack[dep1].specificTables[dep2].adbTableSchema.primaryKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PrimaryKeys." + std::to_string(dep3 + 1), transferMapping.databasesBlack[dep1].specificTables[dep2].adbTableSchema.primaryKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionStatement", transferMapping.databasesBlack[dep1].specificTables[dep2].adbTableSchema.partitionStatement);
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionLifeCycle", transferMapping.databasesBlack[dep1].specificTables[dep2].adbTableSchema.partitionLifeCycle);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databasesBlack[dep1].specificTables[dep2].adbTableSchema.distributedKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".AdbTableSchema.DistributedKeys." + std::to_string(dep3 + 1), transferMapping.databasesBlack[dep1].specificTables[dep2].adbTableSchema.distributedKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".Name", transferMapping.databasesBlack[dep1].specificTables[dep2].name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".WhereClause", transferMapping.databasesBlack[dep1].specificTables[dep2].whereClause);
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".Id", transferMapping.databasesBlack[dep1].specificTables[dep2].id);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databasesBlack[dep1].specificTables[dep2].shardColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".SpecificTables." + std::to_string(dep2 + 1) + ".ShardColumns." + std::to_string(dep3 + 1), transferMapping.databasesBlack[dep1].specificTables[dep2].shardColumns[dep3]);
|
||||
}
|
||||
}
|
||||
for(int dep2 = 0; dep2 != transferMapping.databasesBlack[dep1].views.size(); dep2++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".MappedName", transferMapping.databasesBlack[dep1].views[dep2].mappedName);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databasesBlack[dep1].views[dep2].filterColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".FilterColumns." + std::to_string(dep3 + 1), transferMapping.databasesBlack[dep1].views[dep2].filterColumns[dep3]);
|
||||
}
|
||||
for(int dep3 = 0; dep3 != transferMapping.databasesBlack[dep1].views[dep2].adbTableSchema.primaryKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".AdbTableSchema.PrimaryKeys." + std::to_string(dep3 + 1), transferMapping.databasesBlack[dep1].views[dep2].adbTableSchema.primaryKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionStatement", transferMapping.databasesBlack[dep1].views[dep2].adbTableSchema.partitionStatement);
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".AdbTableSchema.PartitionLifeCycle", transferMapping.databasesBlack[dep1].views[dep2].adbTableSchema.partitionLifeCycle);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databasesBlack[dep1].views[dep2].adbTableSchema.distributedKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".AdbTableSchema.DistributedKeys." + std::to_string(dep3 + 1), transferMapping.databasesBlack[dep1].views[dep2].adbTableSchema.distributedKeys[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".Name", transferMapping.databasesBlack[dep1].views[dep2].name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".WhereClause", transferMapping.databasesBlack[dep1].views[dep2].whereClause);
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".Id", transferMapping.databasesBlack[dep1].views[dep2].id);
|
||||
for(int dep3 = 0; dep3 != transferMapping.databasesBlack[dep1].views[dep2].shardColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".DatabasesBlack." + std::to_string(dep1 + 1) + ".Views." + std::to_string(dep2 + 1) + ".ShardColumns." + std::to_string(dep3 + 1), transferMapping.databasesBlack[dep1].views[dep2].shardColumns[dep3]);
|
||||
}
|
||||
}
|
||||
}
|
||||
for(int dep1 = 0; dep1 != transferMapping.whiteTableRules.size(); dep1++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".WhiteTableRules." + std::to_string(dep1 + 1) + ".ObjectMapping.MappedName", transferMapping.whiteTableRules[dep1].objectMapping.mappedName);
|
||||
setBodyParameter(std::string("TransferMapping") + ".WhiteTableRules." + std::to_string(dep1 + 1) + ".ObjectMapping.Name", transferMapping.whiteTableRules[dep1].objectMapping.name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".WhiteTableRules." + std::to_string(dep1 + 1) + ".SchemaMapping.MappedName", transferMapping.whiteTableRules[dep1].schemaMapping.mappedName);
|
||||
setBodyParameter(std::string("TransferMapping") + ".WhiteTableRules." + std::to_string(dep1 + 1) + ".SchemaMapping.Name", transferMapping.whiteTableRules[dep1].schemaMapping.name);
|
||||
}
|
||||
for(int dep1 = 0; dep1 != transferMapping.whiteViewRules.size(); dep1++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".WhiteViewRules." + std::to_string(dep1 + 1) + ".ObjectMapping.MappedName", transferMapping.whiteViewRules[dep1].objectMapping.mappedName);
|
||||
setBodyParameter(std::string("TransferMapping") + ".WhiteViewRules." + std::to_string(dep1 + 1) + ".ObjectMapping.Name", transferMapping.whiteViewRules[dep1].objectMapping.name);
|
||||
setBodyParameter(std::string("TransferMapping") + ".WhiteViewRules." + std::to_string(dep1 + 1) + ".SchemaMapping.MappedName", transferMapping.whiteViewRules[dep1].schemaMapping.mappedName);
|
||||
setBodyParameter(std::string("TransferMapping") + ".WhiteViewRules." + std::to_string(dep1 + 1) + ".SchemaMapping.Name", transferMapping.whiteViewRules[dep1].schemaMapping.name);
|
||||
}
|
||||
for(int dep1 = 0; dep1 != transferMapping.tableAndViewWhiteList.size(); dep1++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".TableAndViewWhiteList." + std::to_string(dep1 + 1), transferMapping.tableAndViewWhiteList[dep1]);
|
||||
}
|
||||
}
|
||||
|
||||
std::string CreateProjectModifyRecordsRequest::getId() const {
|
||||
return id_;
|
||||
}
|
||||
|
||||
@@ -76,10 +76,14 @@ CreateProjectRequest::FullTransferConfig CreateProjectRequest::getFullTransferCo
|
||||
|
||||
void CreateProjectRequest::setFullTransferConfig(const CreateProjectRequest::FullTransferConfig &fullTransferConfig) {
|
||||
fullTransferConfig_ = fullTransferConfig;
|
||||
setBodyParameter(std::string("FullTransferConfig") + ".IndexDDLConcurrencyLimit", std::to_string(fullTransferConfig.indexDDLConcurrencyLimit));
|
||||
setBodyParameter(std::string("FullTransferConfig") + ".HbaseObjMigMode", fullTransferConfig.hbaseObjMigMode);
|
||||
setBodyParameter(std::string("FullTransferConfig") + ".NonePkUkTruncateDstTable", fullTransferConfig.nonePkUkTruncateDstTable ? "true" : "false");
|
||||
setBodyParameter(std::string("FullTransferConfig") + ".ThrottleRps", std::to_string(fullTransferConfig.throttleRps));
|
||||
setBodyParameter(std::string("FullTransferConfig") + ".FullVerifySpeedMode", fullTransferConfig.fullVerifySpeedMode);
|
||||
setBodyParameter(std::string("FullTransferConfig") + ".WriteWorkerNum", std::to_string(fullTransferConfig.writeWorkerNum));
|
||||
setBodyParameter(std::string("FullTransferConfig") + ".HbaseObjCheckMode", fullTransferConfig.hbaseObjCheckMode);
|
||||
setBodyParameter(std::string("FullTransferConfig") + ".MaxConcurrentIndexDDLs", std::to_string(fullTransferConfig.maxConcurrentIndexDDLs));
|
||||
setBodyParameter(std::string("FullTransferConfig") + ".ReadWorkerNum", std::to_string(fullTransferConfig.readWorkerNum));
|
||||
setBodyParameter(std::string("FullTransferConfig") + ".FullTransferSpeedMode", fullTransferConfig.fullTransferSpeedMode);
|
||||
setBodyParameter(std::string("FullTransferConfig") + ".AllowDestTableNotEmpty", fullTransferConfig.allowDestTableNotEmpty ? "true" : "false");
|
||||
@@ -129,6 +133,9 @@ void CreateProjectRequest::setTransferMapping(const CreateProjectRequest::Transf
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].tables[dep2].filterColumns.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".FilterColumns." + std::to_string(dep3 + 1), transferMapping.databases[dep1].tables[dep2].filterColumns[dep3]);
|
||||
}
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".ObkvPartitionConfig.VirtualColumn", transferMapping.databases[dep1].tables[dep2].obkvPartitionConfig.virtualColumn);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".ObkvPartitionConfig.PartitionType", transferMapping.databases[dep1].tables[dep2].obkvPartitionConfig.partitionType);
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".ObkvPartitionConfig.PartitionSize", std::to_string(transferMapping.databases[dep1].tables[dep2].obkvPartitionConfig.partitionSize));
|
||||
for(int dep3 = 0; dep3 != transferMapping.databases[dep1].tables[dep2].adbTableSchema.primaryKeys.size(); dep3++) {
|
||||
setBodyParameter(std::string("TransferMapping") + ".Databases." + std::to_string(dep1 + 1) + ".Tables." + std::to_string(dep2 + 1) + ".AdbTableSchema.PrimaryKeys." + std::to_string(dep3 + 1), transferMapping.databases[dep1].tables[dep2].adbTableSchema.primaryKeys[dep3]);
|
||||
}
|
||||
|
||||
@@ -52,6 +52,15 @@ void CreateTenantUserRequest::setUserPassword(const std::string &userPassword) {
|
||||
setBodyParameter(std::string("UserPassword"), userPassword);
|
||||
}
|
||||
|
||||
std::string CreateTenantUserRequest::getGlobalPermissions() const {
|
||||
return globalPermissions_;
|
||||
}
|
||||
|
||||
void CreateTenantUserRequest::setGlobalPermissions(const std::string &globalPermissions) {
|
||||
globalPermissions_ = globalPermissions;
|
||||
setBodyParameter(std::string("GlobalPermissions"), globalPermissions);
|
||||
}
|
||||
|
||||
std::string CreateTenantUserRequest::getTenantId() const {
|
||||
return tenantId_;
|
||||
}
|
||||
|
||||
@@ -46,6 +46,8 @@ void CreateTenantUserResult::parse(const std::string &payload)
|
||||
tenantUser_.userStatus = tenantUserNode["UserStatus"].asString();
|
||||
if(!tenantUserNode["UserName"].isNull())
|
||||
tenantUser_.userName = tenantUserNode["UserName"].asString();
|
||||
if(!tenantUserNode["GlobalPermissions"].isNull())
|
||||
tenantUser_.globalPermissions = tenantUserNode["GlobalPermissions"].asString();
|
||||
auto allRolesNode = tenantUserNode["Roles"]["RolesItem"];
|
||||
for (auto tenantUserNodeRolesRolesItem : allRolesNode)
|
||||
{
|
||||
|
||||
@@ -56,7 +56,7 @@ void DescribeDataBackupSetResult::parse(const std::string &payload)
|
||||
if(!valueDataDataItem["Policy"].isNull())
|
||||
dataObject.policy = valueDataDataItem["Policy"].asString();
|
||||
if(!valueDataDataItem["SetId"].isNull())
|
||||
dataObject.setId = std::stoi(valueDataDataItem["SetId"].asString());
|
||||
dataObject.setId = valueDataDataItem["SetId"].asString();
|
||||
if(!valueDataDataItem["Method"].isNull())
|
||||
dataObject.method = valueDataDataItem["Method"].asString();
|
||||
if(!valueDataDataItem["Checkpoint"].isNull())
|
||||
|
||||
@@ -0,0 +1,36 @@
|
||||
/*
|
||||
* 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/oceanbasepro/model/DescribeInstanceAvailableZonesRequest.h>
|
||||
|
||||
using AlibabaCloud::OceanBasePro::Model::DescribeInstanceAvailableZonesRequest;
|
||||
|
||||
DescribeInstanceAvailableZonesRequest::DescribeInstanceAvailableZonesRequest()
|
||||
: RpcServiceRequest("oceanbasepro", "2019-09-01", "DescribeInstanceAvailableZones") {
|
||||
setMethod(HttpRequest::Method::Post);
|
||||
}
|
||||
|
||||
DescribeInstanceAvailableZonesRequest::~DescribeInstanceAvailableZonesRequest() {}
|
||||
|
||||
std::string DescribeInstanceAvailableZonesRequest::getInstanceId() const {
|
||||
return instanceId_;
|
||||
}
|
||||
|
||||
void DescribeInstanceAvailableZonesRequest::setInstanceId(const std::string &instanceId) {
|
||||
instanceId_ = instanceId;
|
||||
setBodyParameter(std::string("InstanceId"), instanceId);
|
||||
}
|
||||
|
||||
@@ -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.
|
||||
*/
|
||||
|
||||
#include <alibabacloud/oceanbasepro/model/DescribeInstanceAvailableZonesResult.h>
|
||||
#include <json/json.h>
|
||||
|
||||
using namespace AlibabaCloud::OceanBasePro;
|
||||
using namespace AlibabaCloud::OceanBasePro::Model;
|
||||
|
||||
DescribeInstanceAvailableZonesResult::DescribeInstanceAvailableZonesResult() :
|
||||
ServiceResult()
|
||||
{}
|
||||
|
||||
DescribeInstanceAvailableZonesResult::DescribeInstanceAvailableZonesResult(const std::string &payload) :
|
||||
ServiceResult()
|
||||
{
|
||||
parse(payload);
|
||||
}
|
||||
|
||||
DescribeInstanceAvailableZonesResult::~DescribeInstanceAvailableZonesResult()
|
||||
{}
|
||||
|
||||
void DescribeInstanceAvailableZonesResult::parse(const std::string &payload)
|
||||
{
|
||||
Json::Reader reader;
|
||||
Json::Value value;
|
||||
reader.parse(payload, value);
|
||||
setRequestId(value["RequestId"].asString());
|
||||
auto allZoneListNode = value["ZoneList"]["ZoneListItem"];
|
||||
for (auto valueZoneListZoneListItem : allZoneListNode)
|
||||
{
|
||||
ZoneListItem zoneListObject;
|
||||
if(!valueZoneListZoneListItem["Zone"].isNull())
|
||||
zoneListObject.zone = valueZoneListZoneListItem["Zone"].asString();
|
||||
if(!valueZoneListZoneListItem["IsInCluster"].isNull())
|
||||
zoneListObject.isInCluster = valueZoneListZoneListItem["IsInCluster"].asString() == "true";
|
||||
if(!valueZoneListZoneListItem["ReplicateZoneIndex"].isNull())
|
||||
zoneListObject.replicateZoneIndex = valueZoneListZoneListItem["ReplicateZoneIndex"].asString();
|
||||
if(!valueZoneListZoneListItem["LogicalZoneName"].isNull())
|
||||
zoneListObject.logicalZoneName = valueZoneListZoneListItem["LogicalZoneName"].asString();
|
||||
zoneList_.push_back(zoneListObject);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
std::vector<DescribeInstanceAvailableZonesResult::ZoneListItem> DescribeInstanceAvailableZonesResult::getZoneList()const
|
||||
{
|
||||
return zoneList_;
|
||||
}
|
||||
|
||||
@@ -47,6 +47,12 @@ void DescribeInstanceCreatableZoneResult::parse(const std::string &payload)
|
||||
zoneListObject.isInCluster = valueZoneListZoneListItem["IsInCluster"].asString() == "true";
|
||||
if(!valueZoneListZoneListItem["Zone"].isNull())
|
||||
zoneListObject.zone = valueZoneListZoneListItem["Zone"].asString();
|
||||
if(!valueZoneListZoneListItem["FullCopyId"].isNull())
|
||||
zoneListObject.fullCopyId = valueZoneListZoneListItem["FullCopyId"].asString();
|
||||
if(!valueZoneListZoneListItem["LogicalZoneName"].isNull())
|
||||
zoneListObject.logicalZoneName = valueZoneListZoneListItem["LogicalZoneName"].asString();
|
||||
if(!valueZoneListZoneListItem["ReplicateZoneIndex"].isNull())
|
||||
zoneListObject.replicateZoneIndex = std::stol(valueZoneListZoneListItem["ReplicateZoneIndex"].asString());
|
||||
zoneList_.push_back(zoneListObject);
|
||||
}
|
||||
|
||||
|
||||
@@ -34,15 +34,6 @@ void DescribeInstanceRequest::setPageNumber(int pageNumber) {
|
||||
setBodyParameter(std::string("PageNumber"), std::to_string(pageNumber));
|
||||
}
|
||||
|
||||
std::string DescribeInstanceRequest::getMaxConnectionLimit() const {
|
||||
return maxConnectionLimit_;
|
||||
}
|
||||
|
||||
void DescribeInstanceRequest::setMaxConnectionLimit(const std::string &maxConnectionLimit) {
|
||||
maxConnectionLimit_ = maxConnectionLimit;
|
||||
setBodyParameter(std::string("MaxConnectionLimit"), maxConnectionLimit);
|
||||
}
|
||||
|
||||
std::string DescribeInstanceRequest::getInstanceId() const {
|
||||
return instanceId_;
|
||||
}
|
||||
|
||||
@@ -34,3 +34,12 @@ void DescribeInstanceSSLRequest::setInstanceId(const std::string &instanceId) {
|
||||
setBodyParameter(std::string("InstanceId"), instanceId);
|
||||
}
|
||||
|
||||
std::string DescribeInstanceSSLRequest::getTenantId() const {
|
||||
return tenantId_;
|
||||
}
|
||||
|
||||
void DescribeInstanceSSLRequest::setTenantId(const std::string &tenantId) {
|
||||
tenantId_ = tenantId;
|
||||
setBodyParameter(std::string("TenantId"), tenantId);
|
||||
}
|
||||
|
||||
|
||||
@@ -54,6 +54,10 @@ void DescribeInstanceSSLResult::parse(const std::string &payload)
|
||||
instanceSSL_.forceSSLSupport = instanceSSLNode["ForceSSLSupport"].asString() == "true";
|
||||
if(!instanceSSLNode["ForceSSL"].isNull())
|
||||
instanceSSL_.forceSSL = instanceSSLNode["ForceSSL"].asString();
|
||||
if(!instanceSSLNode["AutoUpdate"].isNull())
|
||||
instanceSSL_.autoUpdate = instanceSSLNode["AutoUpdate"].asString();
|
||||
if(!instanceSSLNode["TenantId"].isNull())
|
||||
instanceSSL_.tenantId = instanceSSLNode["TenantId"].asString();
|
||||
|
||||
}
|
||||
|
||||
|
||||
@@ -69,15 +69,15 @@ void DescribeInstanceSummaryResult::parse(const std::string &payload)
|
||||
if(!instanceSummaryNodeRegionalInstanceSummaryListRegionalInstanceSummaryLis["Region"].isNull())
|
||||
regionalInstanceSummaryLisObject.region = instanceSummaryNodeRegionalInstanceSummaryListRegionalInstanceSummaryLis["Region"].asString();
|
||||
if(!instanceSummaryNodeRegionalInstanceSummaryListRegionalInstanceSummaryLis["TotalInstancesCount"].isNull())
|
||||
regionalInstanceSummaryLisObject.totalInstancesCount = instanceSummaryNodeRegionalInstanceSummaryListRegionalInstanceSummaryLis["TotalInstancesCount"].asString();
|
||||
regionalInstanceSummaryLisObject.totalInstancesCount = std::stol(instanceSummaryNodeRegionalInstanceSummaryListRegionalInstanceSummaryLis["TotalInstancesCount"].asString());
|
||||
if(!instanceSummaryNodeRegionalInstanceSummaryListRegionalInstanceSummaryLis["ImmediatelyExpiredInstancesCount"].isNull())
|
||||
regionalInstanceSummaryLisObject.immediatelyExpiredInstancesCount = instanceSummaryNodeRegionalInstanceSummaryListRegionalInstanceSummaryLis["ImmediatelyExpiredInstancesCount"].asString();
|
||||
regionalInstanceSummaryLisObject.immediatelyExpiredInstancesCount = std::stol(instanceSummaryNodeRegionalInstanceSummaryListRegionalInstanceSummaryLis["ImmediatelyExpiredInstancesCount"].asString());
|
||||
if(!instanceSummaryNodeRegionalInstanceSummaryListRegionalInstanceSummaryLis["RunningInstancesCount"].isNull())
|
||||
regionalInstanceSummaryLisObject.runningInstancesCount = instanceSummaryNodeRegionalInstanceSummaryListRegionalInstanceSummaryLis["RunningInstancesCount"].asString();
|
||||
regionalInstanceSummaryLisObject.runningInstancesCount = std::stol(instanceSummaryNodeRegionalInstanceSummaryListRegionalInstanceSummaryLis["RunningInstancesCount"].asString());
|
||||
if(!instanceSummaryNodeRegionalInstanceSummaryListRegionalInstanceSummaryLis["ExpiredInstancesCount"].isNull())
|
||||
regionalInstanceSummaryLisObject.expiredInstancesCount = instanceSummaryNodeRegionalInstanceSummaryListRegionalInstanceSummaryLis["ExpiredInstancesCount"].asString();
|
||||
regionalInstanceSummaryLisObject.expiredInstancesCount = std::stol(instanceSummaryNodeRegionalInstanceSummaryListRegionalInstanceSummaryLis["ExpiredInstancesCount"].asString());
|
||||
if(!instanceSummaryNodeRegionalInstanceSummaryListRegionalInstanceSummaryLis["RecentCreatedInstancesCount"].isNull())
|
||||
regionalInstanceSummaryLisObject.recentCreatedInstancesCount = instanceSummaryNodeRegionalInstanceSummaryListRegionalInstanceSummaryLis["RecentCreatedInstancesCount"].asString();
|
||||
regionalInstanceSummaryLisObject.recentCreatedInstancesCount = std::stol(instanceSummaryNodeRegionalInstanceSummaryListRegionalInstanceSummaryLis["RecentCreatedInstancesCount"].asString());
|
||||
instanceSummary_.regionalInstanceSummaryList.push_back(regionalInstanceSummaryLisObject);
|
||||
}
|
||||
|
||||
|
||||
@@ -82,6 +82,8 @@ void DescribeInstanceTopologyResult::parse(const std::string &payload)
|
||||
tenantZonesObject.logicalZone = instanceTopologyNodeTenantsTenantsItemTenantZonesTenantZonesItem["LogicalZone"].asString();
|
||||
if(!instanceTopologyNodeTenantsTenantsItemTenantZonesTenantZonesItem["ReplicaType"].isNull())
|
||||
tenantZonesObject.replicaType = instanceTopologyNodeTenantsTenantsItemTenantZonesTenantZonesItem["ReplicaType"].asString();
|
||||
if(!instanceTopologyNodeTenantsTenantsItemTenantZonesTenantZonesItem["ReadOnlyReplicaType"].isNull())
|
||||
tenantZonesObject.readOnlyReplicaType = instanceTopologyNodeTenantsTenantsItemTenantZonesTenantZonesItem["ReadOnlyReplicaType"].asString();
|
||||
auto allUnitsNode = instanceTopologyNodeTenantsTenantsItemTenantZonesTenantZonesItem["Units"]["UnitsItem"];
|
||||
for (auto instanceTopologyNodeTenantsTenantsItemTenantZonesTenantZonesItemUnitsUnitsItem : allUnitsNode)
|
||||
{
|
||||
@@ -140,6 +142,8 @@ void DescribeInstanceTopologyResult::parse(const std::string &payload)
|
||||
nodesObject.readOnlyCopyId = std::stol(instanceTopologyNodeZonesZonesItemNodesNodesItem["ReadOnlyCopyId"].asString());
|
||||
if(!instanceTopologyNodeZonesZonesItemNodesNodesItem["LogicalZone"].isNull())
|
||||
nodesObject.logicalZone = instanceTopologyNodeZonesZonesItemNodesNodesItem["LogicalZone"].asString();
|
||||
if(!instanceTopologyNodeZonesZonesItemNodesNodesItem["ReadOnlyReplicaType"].isNull())
|
||||
nodesObject.readOnlyReplicaType = instanceTopologyNodeZonesZonesItemNodesNodesItem["ReadOnlyReplicaType"].asString();
|
||||
auto nodeResourceNode = value["NodeResource"];
|
||||
auto cpuNode = nodeResourceNode["Cpu"];
|
||||
if(!cpuNode["UsedCpu"].isNull())
|
||||
@@ -185,6 +189,10 @@ void DescribeInstanceTopologyResult::parse(const std::string &payload)
|
||||
replicasItemObject.replicaType = instanceTopologyNodeReplicasReplicasItem["ReplicaType"].asString();
|
||||
if(!instanceTopologyNodeReplicasReplicasItem["Status"].isNull())
|
||||
replicasItemObject.status = instanceTopologyNodeReplicasReplicasItem["Status"].asString();
|
||||
if(!instanceTopologyNodeReplicasReplicasItem["ReadOnlyReplicaType"].isNull())
|
||||
replicasItemObject.readOnlyReplicaType = instanceTopologyNodeReplicasReplicasItem["ReadOnlyReplicaType"].asString();
|
||||
if(!instanceTopologyNodeReplicasReplicasItem["OnlineNodeNum"].isNull())
|
||||
replicasItemObject.onlineNodeNum = std::stol(instanceTopologyNodeReplicasReplicasItem["OnlineNodeNum"].asString());
|
||||
auto replicaResourceNode = value["ReplicaResource"];
|
||||
auto memory2Node = replicaResourceNode["Memory"];
|
||||
if(!memory2Node["UsedMemory"].isNull())
|
||||
|
||||
@@ -52,6 +52,15 @@ void DescribeInstancesRequest::setResourceGroupId(const std::string &resourceGro
|
||||
setBodyParameter(std::string("ResourceGroupId"), resourceGroupId);
|
||||
}
|
||||
|
||||
int DescribeInstancesRequest::getPageSize() const {
|
||||
return pageSize_;
|
||||
}
|
||||
|
||||
void DescribeInstancesRequest::setPageSize(int pageSize) {
|
||||
pageSize_ = pageSize;
|
||||
setBodyParameter(std::string("PageSize"), std::to_string(pageSize));
|
||||
}
|
||||
|
||||
std::string DescribeInstancesRequest::getInstanceId() const {
|
||||
return instanceId_;
|
||||
}
|
||||
@@ -70,12 +79,12 @@ void DescribeInstancesRequest::setInstanceName(const std::string &instanceName)
|
||||
setBodyParameter(std::string("InstanceName"), instanceName);
|
||||
}
|
||||
|
||||
int DescribeInstancesRequest::getPageSize() const {
|
||||
return pageSize_;
|
||||
bool DescribeInstancesRequest::getWithOBCloudInstances() const {
|
||||
return withOBCloudInstances_;
|
||||
}
|
||||
|
||||
void DescribeInstancesRequest::setPageSize(int pageSize) {
|
||||
pageSize_ = pageSize;
|
||||
setBodyParameter(std::string("PageSize"), std::to_string(pageSize));
|
||||
void DescribeInstancesRequest::setWithOBCloudInstances(bool withOBCloudInstances) {
|
||||
withOBCloudInstances_ = withOBCloudInstances;
|
||||
setBodyParameter(std::string("WithOBCloudInstances"), withOBCloudInstances ? "true" : "false");
|
||||
}
|
||||
|
||||
|
||||
@@ -66,7 +66,7 @@ void DescribeInstancesResult::parse(const std::string &payload)
|
||||
if(!valueInstancesData["PayType"].isNull())
|
||||
instancesObject.payType = valueInstancesData["PayType"].asString();
|
||||
if(!valueInstancesData["DiskSize"].isNull())
|
||||
instancesObject.diskSize = valueInstancesData["DiskSize"].asString();
|
||||
instancesObject.diskSize = std::stol(valueInstancesData["DiskSize"].asString());
|
||||
if(!valueInstancesData["DiskType"].isNull())
|
||||
instancesObject.diskType = valueInstancesData["DiskType"].asString();
|
||||
if(!valueInstancesData["InstanceId"].isNull())
|
||||
@@ -101,6 +101,10 @@ void DescribeInstancesResult::parse(const std::string &payload)
|
||||
instancesObject.specType = valueInstancesData["SpecType"].asString();
|
||||
if(!valueInstancesData["ObRpmVersion"].isNull())
|
||||
instancesObject.obRpmVersion = valueInstancesData["ObRpmVersion"].asString();
|
||||
if(!valueInstancesData["ReplicaMode"].isNull())
|
||||
instancesObject.replicaMode = valueInstancesData["ReplicaMode"].asString();
|
||||
if(!valueInstancesData["Migratable"].isNull())
|
||||
instancesObject.migratable = valueInstancesData["Migratable"].asString() == "true";
|
||||
auto resourceNode = value["Resource"];
|
||||
if(!resourceNode["UnitCount"].isNull())
|
||||
instancesObject.resource.unitCount = std::stol(resourceNode["UnitCount"].asString());
|
||||
@@ -155,6 +159,24 @@ void DescribeInstancesResult::parse(const std::string &payload)
|
||||
instancesObject.dataDiskAutoScaleConfig.scaleStepInMerge = dataDiskAutoScaleConfigNode["ScaleStepInMerge"].asString();
|
||||
if(!dataDiskAutoScaleConfigNode["UpperScaleStrategy"].isNull())
|
||||
instancesObject.dataDiskAutoScaleConfig.upperScaleStrategy = dataDiskAutoScaleConfigNode["UpperScaleStrategy"].asString();
|
||||
auto migrationInfoNode = value["MigrationInfo"];
|
||||
if(!migrationInfoNode["Migratable"].isNull())
|
||||
instancesObject.migrationInfo.migratable = migrationInfoNode["Migratable"].asString() == "true";
|
||||
auto checkResultNode = migrationInfoNode["CheckResult"];
|
||||
if(!checkResultNode["Level"].isNull())
|
||||
instancesObject.migrationInfo.checkResult.level = checkResultNode["Level"].asString();
|
||||
if(!checkResultNode["Code"].isNull())
|
||||
instancesObject.migrationInfo.checkResult.code = checkResultNode["Code"].asString();
|
||||
if(!checkResultNode["CodeName"].isNull())
|
||||
instancesObject.migrationInfo.checkResult.codeName = checkResultNode["CodeName"].asString();
|
||||
if(!checkResultNode["Module"].isNull())
|
||||
instancesObject.migrationInfo.checkResult.module = checkResultNode["Module"].asString();
|
||||
if(!checkResultNode["ModuleName"].isNull())
|
||||
instancesObject.migrationInfo.checkResult.moduleName = checkResultNode["ModuleName"].asString();
|
||||
if(!checkResultNode["SubModule"].isNull())
|
||||
instancesObject.migrationInfo.checkResult.subModule = checkResultNode["SubModule"].asString();
|
||||
if(!checkResultNode["SubModuleName"].isNull())
|
||||
instancesObject.migrationInfo.checkResult.subModuleName = checkResultNode["SubModuleName"].asString();
|
||||
auto allAvailableZones = value["AvailableZones"]["AvailableZones"];
|
||||
for (auto value : allAvailableZones)
|
||||
instancesObject.availableZones.push_back(value.asString());
|
||||
|
||||
@@ -181,6 +181,8 @@ void DescribeOasSQLHistoryListResult::parse(const std::string &payload)
|
||||
dataObject.avgDbTime = valueDataDataItem["AvgDbTime"].asString();
|
||||
if(!valueDataDataItem["SumDbTime"].isNull())
|
||||
dataObject.sumDbTime = valueDataDataItem["SumDbTime"].asString();
|
||||
if(!valueDataDataItem["WaitEvent"].isNull())
|
||||
dataObject.waitEvent = valueDataDataItem["WaitEvent"].asString();
|
||||
data_.push_back(dataObject);
|
||||
}
|
||||
|
||||
|
||||
@@ -145,6 +145,8 @@ void DescribeOasSQLPlansResult::parse(const std::string &payload)
|
||||
plansObject.planUnionHash = valueDataDataItemPlansPlansItem["PlanUnionHash"].asString();
|
||||
if(!valueDataDataItemPlansPlansItem["SqlId"].isNull())
|
||||
plansObject.sqlId = valueDataDataItemPlansPlansItem["SqlId"].asString();
|
||||
if(!valueDataDataItemPlansPlansItem["SqlText"].isNull())
|
||||
plansObject.sqlText = valueDataDataItemPlansPlansItem["SqlText"].asString();
|
||||
dataObject.plans.push_back(plansObject);
|
||||
}
|
||||
auto planExplainNode = value["PlanExplain"];
|
||||
|
||||
@@ -34,6 +34,15 @@ void DescribeOasTopSQLListRequest::setStartTime(const std::string &startTime) {
|
||||
setBodyParameter(std::string("StartTime"), startTime);
|
||||
}
|
||||
|
||||
std::string DescribeOasTopSQLListRequest::getCustomColumns() const {
|
||||
return customColumns_;
|
||||
}
|
||||
|
||||
void DescribeOasTopSQLListRequest::setCustomColumns(const std::string &customColumns) {
|
||||
customColumns_ = customColumns;
|
||||
setBodyParameter(std::string("CustomColumns"), customColumns);
|
||||
}
|
||||
|
||||
std::string DescribeOasTopSQLListRequest::getSearchRule() const {
|
||||
return searchRule_;
|
||||
}
|
||||
|
||||
@@ -203,6 +203,8 @@ void DescribeOasTopSQLListResult::parse(const std::string &payload)
|
||||
dataObject.avgDbTime = valueDataDataItem["AvgDbTime"].asString();
|
||||
if(!valueDataDataItem["SumDbTime"].isNull())
|
||||
dataObject.sumDbTime = valueDataDataItem["SumDbTime"].asString();
|
||||
if(!valueDataDataItem["ObDbId"].isNull())
|
||||
dataObject.obDbId = valueDataDataItem["ObDbId"].asString();
|
||||
auto allSqlListNode = valueDataDataItem["SqlList"]["SqlListItem"];
|
||||
for (auto valueDataDataItemSqlListSqlListItem : allSqlListNode)
|
||||
{
|
||||
@@ -365,6 +367,11 @@ void DescribeOasTopSQLListResult::parse(const std::string &payload)
|
||||
sqlListObject.sumDbTime = valueDataDataItemSqlListSqlListItem["SumDbTime"].asString();
|
||||
dataObject.sqlList.push_back(sqlListObject);
|
||||
}
|
||||
auto customColumnsNode = value["CustomColumns"];
|
||||
if(!customColumnsNode["Expression"].isNull())
|
||||
dataObject.customColumns.expression = customColumnsNode["Expression"].asString();
|
||||
if(!customColumnsNode["Value"].isNull())
|
||||
dataObject.customColumns.value = customColumnsNode["Value"].asString();
|
||||
data_.push_back(dataObject);
|
||||
}
|
||||
|
||||
|
||||
@@ -50,6 +50,10 @@ void DescribeOutlineBindingResult::parse(const std::string &payload)
|
||||
outlineBinding_.maxConcurrent = std::stoi(outlineBindingNode["MaxConcurrent"].asString());
|
||||
if(!outlineBindingNode["TableName"].isNull())
|
||||
outlineBinding_.tableName = outlineBindingNode["TableName"].asString();
|
||||
if(!outlineBindingNode["SqlText"].isNull())
|
||||
outlineBinding_.sqlText = outlineBindingNode["SqlText"].asString();
|
||||
if(!outlineBindingNode["SqlTextConcurrentNum"].isNull())
|
||||
outlineBinding_.sqlTextConcurrentNum = std::stol(outlineBindingNode["SqlTextConcurrentNum"].asString());
|
||||
|
||||
}
|
||||
|
||||
|
||||
@@ -39,40 +39,35 @@ void DescribeParametersHistoryResult::parse(const std::string &payload)
|
||||
Json::Value value;
|
||||
reader.parse(payload, value);
|
||||
setRequestId(value["RequestId"].asString());
|
||||
auto allRespondNode = value["Respond"]["Data"];
|
||||
for (auto valueRespondData : allRespondNode)
|
||||
auto respondNode = value["Respond"];
|
||||
if(!respondNode["TotalCount"].isNull())
|
||||
respond_.totalCount = std::stoi(respondNode["TotalCount"].asString());
|
||||
if(!respondNode["PageNumber"].isNull())
|
||||
respond_.pageNumber = std::stoi(respondNode["PageNumber"].asString());
|
||||
auto allParametersNode = respondNode["Parameters"]["ParametersItem"];
|
||||
for (auto respondNodeParametersParametersItem : allParametersNode)
|
||||
{
|
||||
Data respondObject;
|
||||
if(!valueRespondData["TotalCount"].isNull())
|
||||
respondObject.totalCount = std::stoi(valueRespondData["TotalCount"].asString());
|
||||
if(!valueRespondData["PageNumber"].isNull())
|
||||
respondObject.pageNumber = std::stoi(valueRespondData["PageNumber"].asString());
|
||||
auto allParametersNode = valueRespondData["Parameters"]["ParametersItem"];
|
||||
for (auto valueRespondDataParametersParametersItem : allParametersNode)
|
||||
{
|
||||
Data::ParametersItem parametersObject;
|
||||
if(!valueRespondDataParametersParametersItem["Status"].isNull())
|
||||
parametersObject.status = valueRespondDataParametersParametersItem["Status"].asString();
|
||||
if(!valueRespondDataParametersParametersItem["OldValue"].isNull())
|
||||
parametersObject.oldValue = valueRespondDataParametersParametersItem["OldValue"].asString();
|
||||
if(!valueRespondDataParametersParametersItem["UpdateTime"].isNull())
|
||||
parametersObject.updateTime = valueRespondDataParametersParametersItem["UpdateTime"].asString();
|
||||
if(!valueRespondDataParametersParametersItem["CreateTime"].isNull())
|
||||
parametersObject.createTime = valueRespondDataParametersParametersItem["CreateTime"].asString();
|
||||
if(!valueRespondDataParametersParametersItem["DimensionValue"].isNull())
|
||||
parametersObject.dimensionValue = valueRespondDataParametersParametersItem["DimensionValue"].asString();
|
||||
if(!valueRespondDataParametersParametersItem["Name"].isNull())
|
||||
parametersObject.name = valueRespondDataParametersParametersItem["Name"].asString();
|
||||
if(!valueRespondDataParametersParametersItem["NewValue"].isNull())
|
||||
parametersObject.newValue = valueRespondDataParametersParametersItem["NewValue"].asString();
|
||||
respondObject.parameters.push_back(parametersObject);
|
||||
}
|
||||
respond_.push_back(respondObject);
|
||||
Respond::ParametersItem parametersItemObject;
|
||||
if(!respondNodeParametersParametersItem["Status"].isNull())
|
||||
parametersItemObject.status = respondNodeParametersParametersItem["Status"].asString();
|
||||
if(!respondNodeParametersParametersItem["OldValue"].isNull())
|
||||
parametersItemObject.oldValue = respondNodeParametersParametersItem["OldValue"].asString();
|
||||
if(!respondNodeParametersParametersItem["UpdateTime"].isNull())
|
||||
parametersItemObject.updateTime = respondNodeParametersParametersItem["UpdateTime"].asString();
|
||||
if(!respondNodeParametersParametersItem["CreateTime"].isNull())
|
||||
parametersItemObject.createTime = respondNodeParametersParametersItem["CreateTime"].asString();
|
||||
if(!respondNodeParametersParametersItem["DimensionValue"].isNull())
|
||||
parametersItemObject.dimensionValue = respondNodeParametersParametersItem["DimensionValue"].asString();
|
||||
if(!respondNodeParametersParametersItem["Name"].isNull())
|
||||
parametersItemObject.name = respondNodeParametersParametersItem["Name"].asString();
|
||||
if(!respondNodeParametersParametersItem["NewValue"].isNull())
|
||||
parametersItemObject.newValue = respondNodeParametersParametersItem["NewValue"].asString();
|
||||
respond_.parameters.push_back(parametersItemObject);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
std::vector<DescribeParametersHistoryResult::Data> DescribeParametersHistoryResult::getRespond()const
|
||||
DescribeParametersHistoryResult::Respond DescribeParametersHistoryResult::getRespond()const
|
||||
{
|
||||
return respond_;
|
||||
}
|
||||
|
||||
@@ -34,6 +34,15 @@ void DescribeProcessStatsCompositionRequest::setUId(const std::string &uId) {
|
||||
setBodyParameter(std::string("UId"), uId);
|
||||
}
|
||||
|
||||
bool DescribeProcessStatsCompositionRequest::getMergeDynamicSql() const {
|
||||
return mergeDynamicSql_;
|
||||
}
|
||||
|
||||
void DescribeProcessStatsCompositionRequest::setMergeDynamicSql(bool mergeDynamicSql) {
|
||||
mergeDynamicSql_ = mergeDynamicSql;
|
||||
setBodyParameter(std::string("MergeDynamicSql"), mergeDynamicSql ? "true" : "false");
|
||||
}
|
||||
|
||||
std::string DescribeProcessStatsCompositionRequest::getSqlText() const {
|
||||
return sqlText_;
|
||||
}
|
||||
|
||||
@@ -82,6 +82,86 @@ void DescribeProcessStatsCompositionResult::parse(const std::string &payload)
|
||||
allProcessListItemObject.traceId = dataNodeAllProcessListAllProcessListItem["TraceId"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItem["PlanId"].isNull())
|
||||
allProcessListItemObject.planId = dataNodeAllProcessListAllProcessListItem["PlanId"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItem["DynamicSql"].isNull())
|
||||
allProcessListItemObject.dynamicSql = dataNodeAllProcessListAllProcessListItem["DynamicSql"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItem["ServerSn"].isNull())
|
||||
allProcessListItemObject.serverSn = dataNodeAllProcessListAllProcessListItem["ServerSn"].asString();
|
||||
auto allProcessSqlListsNode = dataNodeAllProcessListAllProcessListItem["ProcessSqlLists"]["ProcessSqlListsItem"];
|
||||
for (auto dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem : allProcessSqlListsNode)
|
||||
{
|
||||
Data::AllProcessListItem::ProcessSqlListsItem processSqlListsObject;
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["SqlText"].isNull())
|
||||
processSqlListsObject.sqlText = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["SqlText"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["TenantId"].isNull())
|
||||
processSqlListsObject.tenantId = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["TenantId"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["Database"].isNull())
|
||||
processSqlListsObject.database = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["Database"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["User"].isNull())
|
||||
processSqlListsObject.user = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["User"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["ExecuteTime"].isNull())
|
||||
processSqlListsObject.executeTime = std::stol(dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["ExecuteTime"].asString());
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["CpuTime"].isNull())
|
||||
processSqlListsObject.cpuTime = std::stol(dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["CpuTime"].asString());
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["ServerIp"].isNull())
|
||||
processSqlListsObject.serverIp = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["ServerIp"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["ClientIp"].isNull())
|
||||
processSqlListsObject.clientIp = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["ClientIp"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["SessionId"].isNull())
|
||||
processSqlListsObject.sessionId = std::stol(dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["SessionId"].asString());
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["ProxySessId"].isNull())
|
||||
processSqlListsObject.proxySessId = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["ProxySessId"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["Command"].isNull())
|
||||
processSqlListsObject.command = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["Command"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["Status"].isNull())
|
||||
processSqlListsObject.status = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["Status"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["SqlId"].isNull())
|
||||
processSqlListsObject.sqlId = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["SqlId"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["TraceId"].isNull())
|
||||
processSqlListsObject.traceId = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["TraceId"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["PlanId"].isNull())
|
||||
processSqlListsObject.planId = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["PlanId"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["DynamicSql"].isNull())
|
||||
processSqlListsObject.dynamicSql = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["DynamicSql"].asString();
|
||||
auto allProcessSqlListNode = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItem["ProcessSqlList"]["ProcessSqlListItem"];
|
||||
for (auto dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem : allProcessSqlListNode)
|
||||
{
|
||||
Data::AllProcessListItem::ProcessSqlListsItem::ProcessSqlListItem processSqlListObject;
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["SqlText"].isNull())
|
||||
processSqlListObject.sqlText = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["SqlText"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["TenantId"].isNull())
|
||||
processSqlListObject.tenantId = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["TenantId"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["Database"].isNull())
|
||||
processSqlListObject.database = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["Database"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["User"].isNull())
|
||||
processSqlListObject.user = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["User"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["ExecuteTime"].isNull())
|
||||
processSqlListObject.executeTime = std::stol(dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["ExecuteTime"].asString());
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["CpuTime"].isNull())
|
||||
processSqlListObject.cpuTime = std::stol(dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["CpuTime"].asString());
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["ServerIp"].isNull())
|
||||
processSqlListObject.serverIp = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["ServerIp"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["ClientIp"].isNull())
|
||||
processSqlListObject.clientIp = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["ClientIp"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["SessionId"].isNull())
|
||||
processSqlListObject.sessionId = std::stol(dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["SessionId"].asString());
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["ProxySessId"].isNull())
|
||||
processSqlListObject.proxySessId = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["ProxySessId"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["Command"].isNull())
|
||||
processSqlListObject.command = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["Command"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["Status"].isNull())
|
||||
processSqlListObject.status = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["Status"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["SqlId"].isNull())
|
||||
processSqlListObject.sqlId = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["SqlId"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["TraceId"].isNull())
|
||||
processSqlListObject.traceId = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["TraceId"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["PlanId"].isNull())
|
||||
processSqlListObject.planId = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["PlanId"].asString();
|
||||
if(!dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["DynamicSql"].isNull())
|
||||
processSqlListObject.dynamicSql = dataNodeAllProcessListAllProcessListItemProcessSqlListsProcessSqlListsItemProcessSqlListProcessSqlListItem["DynamicSql"].asString();
|
||||
processSqlListsObject.processSqlList.push_back(processSqlListObject);
|
||||
}
|
||||
allProcessListItemObject.processSqlLists.push_back(processSqlListsObject);
|
||||
}
|
||||
data_.allProcessList.push_back(allProcessListItemObject);
|
||||
}
|
||||
auto sessionStatisticsNode = dataNode["SessionStatistics"];
|
||||
|
||||
36
oceanbasepro/src/model/DescribeProxyServiceRequest.cc
Normal file
36
oceanbasepro/src/model/DescribeProxyServiceRequest.cc
Normal file
@@ -0,0 +1,36 @@
|
||||
/*
|
||||
* 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/oceanbasepro/model/DescribeProxyServiceRequest.h>
|
||||
|
||||
using AlibabaCloud::OceanBasePro::Model::DescribeProxyServiceRequest;
|
||||
|
||||
DescribeProxyServiceRequest::DescribeProxyServiceRequest()
|
||||
: RpcServiceRequest("oceanbasepro", "2019-09-01", "DescribeProxyService") {
|
||||
setMethod(HttpRequest::Method::Post);
|
||||
}
|
||||
|
||||
DescribeProxyServiceRequest::~DescribeProxyServiceRequest() {}
|
||||
|
||||
std::string DescribeProxyServiceRequest::getInstanceId() const {
|
||||
return instanceId_;
|
||||
}
|
||||
|
||||
void DescribeProxyServiceRequest::setInstanceId(const std::string &instanceId) {
|
||||
instanceId_ = instanceId;
|
||||
setBodyParameter(std::string("InstanceId"), instanceId);
|
||||
}
|
||||
|
||||
76
oceanbasepro/src/model/DescribeProxyServiceResult.cc
Normal file
76
oceanbasepro/src/model/DescribeProxyServiceResult.cc
Normal file
@@ -0,0 +1,76 @@
|
||||
/*
|
||||
* 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/oceanbasepro/model/DescribeProxyServiceResult.h>
|
||||
#include <json/json.h>
|
||||
|
||||
using namespace AlibabaCloud::OceanBasePro;
|
||||
using namespace AlibabaCloud::OceanBasePro::Model;
|
||||
|
||||
DescribeProxyServiceResult::DescribeProxyServiceResult() :
|
||||
ServiceResult()
|
||||
{}
|
||||
|
||||
DescribeProxyServiceResult::DescribeProxyServiceResult(const std::string &payload) :
|
||||
ServiceResult()
|
||||
{
|
||||
parse(payload);
|
||||
}
|
||||
|
||||
DescribeProxyServiceResult::~DescribeProxyServiceResult()
|
||||
{}
|
||||
|
||||
void DescribeProxyServiceResult::parse(const std::string &payload)
|
||||
{
|
||||
Json::Reader reader;
|
||||
Json::Value value;
|
||||
reader.parse(payload, value);
|
||||
setRequestId(value["RequestId"].asString());
|
||||
auto dataNode = value["Data"];
|
||||
if(!dataNode["ProxyClusterId"].isNull())
|
||||
data_.proxyClusterId = dataNode["ProxyClusterId"].asString();
|
||||
if(!dataNode["ProxyMode"].isNull())
|
||||
data_.proxyMode = dataNode["ProxyMode"].asString();
|
||||
if(!dataNode["Zone"].isNull())
|
||||
data_.zone = dataNode["Zone"].asString();
|
||||
if(!dataNode["UnitSpec"].isNull())
|
||||
data_.unitSpec = dataNode["UnitSpec"].asString();
|
||||
if(!dataNode["UnitNum"].isNull())
|
||||
data_.unitNum = std::stol(dataNode["UnitNum"].asString());
|
||||
if(!dataNode["CurrentEndpointNum"].isNull())
|
||||
data_.currentEndpointNum = std::stol(dataNode["CurrentEndpointNum"].asString());
|
||||
if(!dataNode["EndpointNumQuota"].isNull())
|
||||
data_.endpointNumQuota = std::stol(dataNode["EndpointNumQuota"].asString());
|
||||
if(!dataNode["CreateTime"].isNull())
|
||||
data_.createTime = dataNode["CreateTime"].asString();
|
||||
if(!dataNode["Status"].isNull())
|
||||
data_.status = dataNode["Status"].asString();
|
||||
if(!dataNode["ProxyServiceVersion"].isNull())
|
||||
data_.proxyServiceVersion = dataNode["ProxyServiceVersion"].asString();
|
||||
if(!dataNode["ExpireTime"].isNull())
|
||||
data_.expireTime = dataNode["ExpireTime"].asString();
|
||||
if(!dataNode["UnitNumLimit"].isNull())
|
||||
data_.unitNumLimit = std::stol(dataNode["UnitNumLimit"].asString());
|
||||
if(!dataNode["ProxyVersion"].isNull())
|
||||
data_.proxyVersion = dataNode["ProxyVersion"].asString();
|
||||
|
||||
}
|
||||
|
||||
DescribeProxyServiceResult::Data DescribeProxyServiceResult::getData()const
|
||||
{
|
||||
return data_;
|
||||
}
|
||||
|
||||
@@ -43,6 +43,15 @@ void DescribeSampleSqlRawTextsRequest::setStartTime(const std::string &startTime
|
||||
setBodyParameter(std::string("StartTime"), startTime);
|
||||
}
|
||||
|
||||
bool DescribeSampleSqlRawTextsRequest::getDynamicSql() const {
|
||||
return dynamicSql_;
|
||||
}
|
||||
|
||||
void DescribeSampleSqlRawTextsRequest::setDynamicSql(bool dynamicSql) {
|
||||
dynamicSql_ = dynamicSql;
|
||||
setBodyParameter(std::string("DynamicSql"), dynamicSql ? "true" : "false");
|
||||
}
|
||||
|
||||
std::string DescribeSampleSqlRawTextsRequest::getTenantId() const {
|
||||
return tenantId_;
|
||||
}
|
||||
|
||||
81
oceanbasepro/src/model/DescribeSqlAuditStatRequest.cc
Normal file
81
oceanbasepro/src/model/DescribeSqlAuditStatRequest.cc
Normal file
@@ -0,0 +1,81 @@
|
||||
/*
|
||||
* 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/oceanbasepro/model/DescribeSqlAuditStatRequest.h>
|
||||
|
||||
using AlibabaCloud::OceanBasePro::Model::DescribeSqlAuditStatRequest;
|
||||
|
||||
DescribeSqlAuditStatRequest::DescribeSqlAuditStatRequest()
|
||||
: RpcServiceRequest("oceanbasepro", "2019-09-01", "DescribeSqlAuditStat") {
|
||||
setMethod(HttpRequest::Method::Post);
|
||||
}
|
||||
|
||||
DescribeSqlAuditStatRequest::~DescribeSqlAuditStatRequest() {}
|
||||
|
||||
std::string DescribeSqlAuditStatRequest::getStartTime() const {
|
||||
return startTime_;
|
||||
}
|
||||
|
||||
void DescribeSqlAuditStatRequest::setStartTime(const std::string &startTime) {
|
||||
startTime_ = startTime;
|
||||
setBodyParameter(std::string("StartTime"), startTime);
|
||||
}
|
||||
|
||||
int DescribeSqlAuditStatRequest::getPageNumber() const {
|
||||
return pageNumber_;
|
||||
}
|
||||
|
||||
void DescribeSqlAuditStatRequest::setPageNumber(int pageNumber) {
|
||||
pageNumber_ = pageNumber;
|
||||
setBodyParameter(std::string("PageNumber"), std::to_string(pageNumber));
|
||||
}
|
||||
|
||||
std::string DescribeSqlAuditStatRequest::getTenantId() const {
|
||||
return tenantId_;
|
||||
}
|
||||
|
||||
void DescribeSqlAuditStatRequest::setTenantId(const std::string &tenantId) {
|
||||
tenantId_ = tenantId;
|
||||
setBodyParameter(std::string("TenantId"), tenantId);
|
||||
}
|
||||
|
||||
int DescribeSqlAuditStatRequest::getPageSize() const {
|
||||
return pageSize_;
|
||||
}
|
||||
|
||||
void DescribeSqlAuditStatRequest::setPageSize(int pageSize) {
|
||||
pageSize_ = pageSize;
|
||||
setBodyParameter(std::string("PageSize"), std::to_string(pageSize));
|
||||
}
|
||||
|
||||
std::string DescribeSqlAuditStatRequest::getEndTime() const {
|
||||
return endTime_;
|
||||
}
|
||||
|
||||
void DescribeSqlAuditStatRequest::setEndTime(const std::string &endTime) {
|
||||
endTime_ = endTime;
|
||||
setBodyParameter(std::string("EndTime"), endTime);
|
||||
}
|
||||
|
||||
std::string DescribeSqlAuditStatRequest::getInstanceId() const {
|
||||
return instanceId_;
|
||||
}
|
||||
|
||||
void DescribeSqlAuditStatRequest::setInstanceId(const std::string &instanceId) {
|
||||
instanceId_ = instanceId;
|
||||
setBodyParameter(std::string("InstanceId"), instanceId);
|
||||
}
|
||||
|
||||
89
oceanbasepro/src/model/DescribeSqlAuditStatResult.cc
Normal file
89
oceanbasepro/src/model/DescribeSqlAuditStatResult.cc
Normal 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/oceanbasepro/model/DescribeSqlAuditStatResult.h>
|
||||
#include <json/json.h>
|
||||
|
||||
using namespace AlibabaCloud::OceanBasePro;
|
||||
using namespace AlibabaCloud::OceanBasePro::Model;
|
||||
|
||||
DescribeSqlAuditStatResult::DescribeSqlAuditStatResult() :
|
||||
ServiceResult()
|
||||
{}
|
||||
|
||||
DescribeSqlAuditStatResult::DescribeSqlAuditStatResult(const std::string &payload) :
|
||||
ServiceResult()
|
||||
{
|
||||
parse(payload);
|
||||
}
|
||||
|
||||
DescribeSqlAuditStatResult::~DescribeSqlAuditStatResult()
|
||||
{}
|
||||
|
||||
void DescribeSqlAuditStatResult::parse(const std::string &payload)
|
||||
{
|
||||
Json::Reader reader;
|
||||
Json::Value value;
|
||||
reader.parse(payload, value);
|
||||
setRequestId(value["RequestId"].asString());
|
||||
auto allDataNode = value["Data"]["DataItem"];
|
||||
for (auto valueDataDataItem : allDataNode)
|
||||
{
|
||||
DataItem dataObject;
|
||||
if(!valueDataDataItem["InstanceId"].isNull())
|
||||
dataObject.instanceId = valueDataDataItem["InstanceId"].asString();
|
||||
if(!valueDataDataItem["TenantId"].isNull())
|
||||
dataObject.tenantId = valueDataDataItem["TenantId"].asString();
|
||||
if(!valueDataDataItem["UserClientIp"].isNull())
|
||||
dataObject.userClientIp = valueDataDataItem["UserClientIp"].asString();
|
||||
if(!valueDataDataItem["UserName"].isNull())
|
||||
dataObject.userName = valueDataDataItem["UserName"].asString();
|
||||
if(!valueDataDataItem["DatabaseName"].isNull())
|
||||
dataObject.databaseName = valueDataDataItem["DatabaseName"].asString();
|
||||
if(!valueDataDataItem["SqlId"].isNull())
|
||||
dataObject.sqlId = valueDataDataItem["SqlId"].asString();
|
||||
if(!valueDataDataItem["TotalSucceed"].isNull())
|
||||
dataObject.totalSucceed = std::stol(valueDataDataItem["TotalSucceed"].asString());
|
||||
if(!valueDataDataItem["TotalFailed"].isNull())
|
||||
dataObject.totalFailed = std::stol(valueDataDataItem["TotalFailed"].asString());
|
||||
if(!valueDataDataItem["TotalAffectRows"].isNull())
|
||||
dataObject.totalAffectRows = std::stol(valueDataDataItem["TotalAffectRows"].asString());
|
||||
if(!valueDataDataItem["TotalScanRows"].isNull())
|
||||
dataObject.totalScanRows = std::stol(valueDataDataItem["TotalScanRows"].asString());
|
||||
if(!valueDataDataItem["TotalReturnRows"].isNull())
|
||||
dataObject.totalReturnRows = std::stol(valueDataDataItem["TotalReturnRows"].asString());
|
||||
if(!valueDataDataItem["AffectRows"].isNull())
|
||||
dataObject.affectRows = valueDataDataItem["AffectRows"].asString();
|
||||
if(!valueDataDataItem["ScanRows"].isNull())
|
||||
dataObject.scanRows = valueDataDataItem["ScanRows"].asString();
|
||||
if(!valueDataDataItem["ReturnRows"].isNull())
|
||||
dataObject.returnRows = valueDataDataItem["ReturnRows"].asString();
|
||||
if(!valueDataDataItem["ExecuteTime"].isNull())
|
||||
dataObject.executeTime = valueDataDataItem["ExecuteTime"].asString();
|
||||
if(!valueDataDataItem["SqlStatement"].isNull())
|
||||
dataObject.sqlStatement = valueDataDataItem["SqlStatement"].asString();
|
||||
if(!valueDataDataItem["OperatorType"].isNull())
|
||||
dataObject.operatorType = valueDataDataItem["OperatorType"].asString();
|
||||
data_.push_back(dataObject);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
std::vector<DescribeSqlAuditStatResult::DataItem> DescribeSqlAuditStatResult::getData()const
|
||||
{
|
||||
return data_;
|
||||
}
|
||||
|
||||
@@ -104,6 +104,10 @@ void DescribeTenantResult::parse(const std::string &payload)
|
||||
tenant_.version = tenantNode["Version"].asString();
|
||||
if(!tenantNode["OdpVersion"].isNull())
|
||||
tenant_.odpVersion = tenantNode["OdpVersion"].asString();
|
||||
if(!tenantNode["TenantMaxConnections"].isNull())
|
||||
tenant_.tenantMaxConnections = tenantNode["TenantMaxConnections"].asString();
|
||||
if(!tenantNode["ParameterTemplate"].isNull())
|
||||
tenant_.parameterTemplate = tenantNode["ParameterTemplate"].asString();
|
||||
auto allTenantConnectionsNode = tenantNode["TenantConnections"]["TenantConnectionsItem"];
|
||||
for (auto tenantNodeTenantConnectionsTenantConnectionsItem : allTenantConnectionsNode)
|
||||
{
|
||||
@@ -158,6 +162,8 @@ void DescribeTenantResult::parse(const std::string &payload)
|
||||
tenantConnectionsItemObject.intranetSqlPort = std::stoi(tenantNodeTenantConnectionsTenantConnectionsItem["IntranetSqlPort"].asString());
|
||||
if(!tenantNodeTenantConnectionsTenantConnectionsItem["OdpVersion"].isNull())
|
||||
tenantConnectionsItemObject.odpVersion = tenantNodeTenantConnectionsTenantConnectionsItem["OdpVersion"].asString();
|
||||
if(!tenantNodeTenantConnectionsTenantConnectionsItem["InternetSqlPort"].isNull())
|
||||
tenantConnectionsItemObject.internetSqlPort = std::stoi(tenantNodeTenantConnectionsTenantConnectionsItem["InternetSqlPort"].asString());
|
||||
auto allConnectionZones = value["ConnectionZones"]["ConnectionZones"];
|
||||
for (auto value : allConnectionZones)
|
||||
tenantConnectionsItemObject.connectionZones.push_back(value.asString());
|
||||
@@ -183,7 +189,7 @@ void DescribeTenantResult::parse(const std::string &payload)
|
||||
if(!tenantNodeTenantZonesTenantZonesItemTenantZoneReplicasTenantZoneReplicasItem["ZoneReplicaType"].isNull())
|
||||
tenantZoneReplicasObject.zoneReplicaType = tenantNodeTenantZonesTenantZonesItemTenantZoneReplicasTenantZoneReplicasItem["ZoneReplicaType"].asString();
|
||||
if(!tenantNodeTenantZonesTenantZonesItemTenantZoneReplicasTenantZoneReplicasItem["ZoneNodes"].isNull())
|
||||
tenantZoneReplicasObject.zoneNodes = tenantNodeTenantZonesTenantZonesItemTenantZoneReplicasTenantZoneReplicasItem["ZoneNodes"].asString();
|
||||
tenantZoneReplicasObject.zoneNodes = std::stol(tenantNodeTenantZonesTenantZonesItemTenantZoneReplicasTenantZoneReplicasItem["ZoneNodes"].asString());
|
||||
if(!tenantNodeTenantZonesTenantZonesItemTenantZoneReplicasTenantZoneReplicasItem["LogicZoneName"].isNull())
|
||||
tenantZoneReplicasObject.logicZoneName = tenantNodeTenantZonesTenantZonesItemTenantZoneReplicasTenantZoneReplicasItem["LogicZoneName"].asString();
|
||||
if(!tenantNodeTenantZonesTenantZonesItemTenantZoneReplicasTenantZoneReplicasItem["ZoneCopyId"].isNull())
|
||||
@@ -192,6 +198,8 @@ void DescribeTenantResult::parse(const std::string &payload)
|
||||
tenantZoneReplicasObject.fullCopyId = std::stoi(tenantNodeTenantZonesTenantZonesItemTenantZoneReplicasTenantZoneReplicasItem["FullCopyId"].asString());
|
||||
if(!tenantNodeTenantZonesTenantZonesItemTenantZoneReplicasTenantZoneReplicasItem["ReadOnlyCopyId"].isNull())
|
||||
tenantZoneReplicasObject.readOnlyCopyId = tenantNodeTenantZonesTenantZonesItemTenantZoneReplicasTenantZoneReplicasItem["ReadOnlyCopyId"].asString();
|
||||
if(!tenantNodeTenantZonesTenantZonesItemTenantZoneReplicasTenantZoneReplicasItem["ReadOnlyReplicaType"].isNull())
|
||||
tenantZoneReplicasObject.readOnlyReplicaType = tenantNodeTenantZonesTenantZonesItemTenantZoneReplicasTenantZoneReplicasItem["ReadOnlyReplicaType"].asString();
|
||||
tenantZonesItemObject.tenantZoneReplicas.push_back(tenantZoneReplicasObject);
|
||||
}
|
||||
tenant_.tenantZones.push_back(tenantZonesItemObject);
|
||||
|
||||
@@ -25,6 +25,15 @@ DescribeTenantUserRolesRequest::DescribeTenantUserRolesRequest()
|
||||
|
||||
DescribeTenantUserRolesRequest::~DescribeTenantUserRolesRequest() {}
|
||||
|
||||
std::string DescribeTenantUserRolesRequest::getInstanceId() const {
|
||||
return instanceId_;
|
||||
}
|
||||
|
||||
void DescribeTenantUserRolesRequest::setInstanceId(const std::string &instanceId) {
|
||||
instanceId_ = instanceId;
|
||||
setBodyParameter(std::string("InstanceId"), instanceId);
|
||||
}
|
||||
|
||||
std::string DescribeTenantUserRolesRequest::getTenantId() const {
|
||||
return tenantId_;
|
||||
}
|
||||
|
||||
@@ -55,6 +55,8 @@ void DescribeTenantUsersResult::parse(const std::string &payload)
|
||||
tenantUsersObject.tenantId = valueTenantUsersTenantUsersItem["TenantId"].asString();
|
||||
if(!valueTenantUsersTenantUsersItem["InstanceId"].isNull())
|
||||
tenantUsersObject.instanceId = valueTenantUsersTenantUsersItem["InstanceId"].asString();
|
||||
if(!valueTenantUsersTenantUsersItem["GlobalPermissions"].isNull())
|
||||
tenantUsersObject.globalPermissions = valueTenantUsersTenantUsersItem["GlobalPermissions"].asString();
|
||||
auto allDatabasesNode = valueTenantUsersTenantUsersItem["Databases"]["DatabasesItem"];
|
||||
for (auto valueTenantUsersTenantUsersItemDatabasesDatabasesItem : allDatabasesNode)
|
||||
{
|
||||
|
||||
@@ -81,6 +81,8 @@ void DescribeTenantsResult::parse(const std::string &payload)
|
||||
tenantsObject.collation = valueTenantsData["Collation"].asString();
|
||||
if(!valueTenantsData["EnableReadOnlyReplica"].isNull())
|
||||
tenantsObject.enableReadOnlyReplica = valueTenantsData["EnableReadOnlyReplica"].asString() == "true";
|
||||
if(!valueTenantsData["ParameterTemplate"].isNull())
|
||||
tenantsObject.parameterTemplate = valueTenantsData["ParameterTemplate"].asString();
|
||||
tenants_.push_back(tenantsObject);
|
||||
}
|
||||
if(!value["TotalCount"].isNull())
|
||||
|
||||
@@ -43,3 +43,12 @@ void ModifyInstanceSSLRequest::setEnableSSL(const std::string &enableSSL) {
|
||||
setBodyParameter(std::string("EnableSSL"), enableSSL);
|
||||
}
|
||||
|
||||
std::string ModifyInstanceSSLRequest::getTenantId() const {
|
||||
return tenantId_;
|
||||
}
|
||||
|
||||
void ModifyInstanceSSLRequest::setTenantId(const std::string &tenantId) {
|
||||
tenantId_ = tenantId;
|
||||
setBodyParameter(std::string("TenantId"), tenantId);
|
||||
}
|
||||
|
||||
|
||||
@@ -44,6 +44,8 @@ void ModifyInstanceSSLResult::parse(const std::string &payload)
|
||||
instanceSSL_.instanceId = instanceSSLNode["InstanceId"].asString();
|
||||
if(!instanceSSLNode["EnableSSL"].isNull())
|
||||
instanceSSL_.enableSSL = instanceSSLNode["EnableSSL"].asString();
|
||||
if(!instanceSSLNode["TenantId"].isNull())
|
||||
instanceSSL_.tenantId = instanceSSLNode["TenantId"].asString();
|
||||
|
||||
}
|
||||
|
||||
|
||||
@@ -25,6 +25,15 @@ ModifyTenantUserRolesRequest::ModifyTenantUserRolesRequest()
|
||||
|
||||
ModifyTenantUserRolesRequest::~ModifyTenantUserRolesRequest() {}
|
||||
|
||||
std::string ModifyTenantUserRolesRequest::getUserType() const {
|
||||
return userType_;
|
||||
}
|
||||
|
||||
void ModifyTenantUserRolesRequest::setUserType(const std::string &userType) {
|
||||
userType_ = userType;
|
||||
setBodyParameter(std::string("UserType"), userType);
|
||||
}
|
||||
|
||||
std::string ModifyTenantUserRolesRequest::getUserRole() const {
|
||||
return userRole_;
|
||||
}
|
||||
@@ -52,6 +61,15 @@ void ModifyTenantUserRolesRequest::setModifyType(const std::string &modifyType)
|
||||
setBodyParameter(std::string("ModifyType"), modifyType);
|
||||
}
|
||||
|
||||
std::string ModifyTenantUserRolesRequest::getGlobalPermissions() const {
|
||||
return globalPermissions_;
|
||||
}
|
||||
|
||||
void ModifyTenantUserRolesRequest::setGlobalPermissions(const std::string &globalPermissions) {
|
||||
globalPermissions_ = globalPermissions;
|
||||
setBodyParameter(std::string("GlobalPermissions"), globalPermissions);
|
||||
}
|
||||
|
||||
std::string ModifyTenantUserRolesRequest::getTenantId() const {
|
||||
return tenantId_;
|
||||
}
|
||||
|
||||
54
oceanbasepro/src/model/RemoveStandbyInstanceRequest.cc
Normal file
54
oceanbasepro/src/model/RemoveStandbyInstanceRequest.cc
Normal file
@@ -0,0 +1,54 @@
|
||||
/*
|
||||
* 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/oceanbasepro/model/RemoveStandbyInstanceRequest.h>
|
||||
|
||||
using AlibabaCloud::OceanBasePro::Model::RemoveStandbyInstanceRequest;
|
||||
|
||||
RemoveStandbyInstanceRequest::RemoveStandbyInstanceRequest()
|
||||
: RpcServiceRequest("oceanbasepro", "2019-09-01", "RemoveStandbyInstance") {
|
||||
setMethod(HttpRequest::Method::Post);
|
||||
}
|
||||
|
||||
RemoveStandbyInstanceRequest::~RemoveStandbyInstanceRequest() {}
|
||||
|
||||
bool RemoveStandbyInstanceRequest::getForced() const {
|
||||
return forced_;
|
||||
}
|
||||
|
||||
void RemoveStandbyInstanceRequest::setForced(bool forced) {
|
||||
forced_ = forced;
|
||||
setBodyParameter(std::string("Forced"), forced ? "true" : "false");
|
||||
}
|
||||
|
||||
std::string RemoveStandbyInstanceRequest::getInstanceId() const {
|
||||
return instanceId_;
|
||||
}
|
||||
|
||||
void RemoveStandbyInstanceRequest::setInstanceId(const std::string &instanceId) {
|
||||
instanceId_ = instanceId;
|
||||
setBodyParameter(std::string("InstanceId"), instanceId);
|
||||
}
|
||||
|
||||
std::string RemoveStandbyInstanceRequest::getTargetInstanceId() const {
|
||||
return targetInstanceId_;
|
||||
}
|
||||
|
||||
void RemoveStandbyInstanceRequest::setTargetInstanceId(const std::string &targetInstanceId) {
|
||||
targetInstanceId_ = targetInstanceId;
|
||||
setBodyParameter(std::string("TargetInstanceId"), targetInstanceId);
|
||||
}
|
||||
|
||||
44
oceanbasepro/src/model/RemoveStandbyInstanceResult.cc
Normal file
44
oceanbasepro/src/model/RemoveStandbyInstanceResult.cc
Normal file
@@ -0,0 +1,44 @@
|
||||
/*
|
||||
* 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/oceanbasepro/model/RemoveStandbyInstanceResult.h>
|
||||
#include <json/json.h>
|
||||
|
||||
using namespace AlibabaCloud::OceanBasePro;
|
||||
using namespace AlibabaCloud::OceanBasePro::Model;
|
||||
|
||||
RemoveStandbyInstanceResult::RemoveStandbyInstanceResult() :
|
||||
ServiceResult()
|
||||
{}
|
||||
|
||||
RemoveStandbyInstanceResult::RemoveStandbyInstanceResult(const std::string &payload) :
|
||||
ServiceResult()
|
||||
{
|
||||
parse(payload);
|
||||
}
|
||||
|
||||
RemoveStandbyInstanceResult::~RemoveStandbyInstanceResult()
|
||||
{}
|
||||
|
||||
void RemoveStandbyInstanceResult::parse(const std::string &payload)
|
||||
{
|
||||
Json::Reader reader;
|
||||
Json::Value value;
|
||||
reader.parse(payload, value);
|
||||
setRequestId(value["RequestId"].asString());
|
||||
|
||||
}
|
||||
|
||||
@@ -58,8 +58,10 @@ UpdateProjectConfigRequest::FullTransferConfig UpdateProjectConfigRequest::getFu
|
||||
|
||||
void UpdateProjectConfigRequest::setFullTransferConfig(const UpdateProjectConfigRequest::FullTransferConfig &fullTransferConfig) {
|
||||
fullTransferConfig_ = fullTransferConfig;
|
||||
setBodyParameter(std::string("FullTransferConfig") + ".IndexDDLConcurrencyLimit", std::to_string(fullTransferConfig.indexDDLConcurrencyLimit));
|
||||
setBodyParameter(std::string("FullTransferConfig") + ".ThrottleRps", std::to_string(fullTransferConfig.throttleRps));
|
||||
setBodyParameter(std::string("FullTransferConfig") + ".WriteWorkerNum", std::to_string(fullTransferConfig.writeWorkerNum));
|
||||
setBodyParameter(std::string("FullTransferConfig") + ".MaxConcurrentIndexDDLs", std::to_string(fullTransferConfig.maxConcurrentIndexDDLs));
|
||||
setBodyParameter(std::string("FullTransferConfig") + ".ReadWorkerNum", std::to_string(fullTransferConfig.readWorkerNum));
|
||||
setBodyParameter(std::string("FullTransferConfig") + ".ThrottleIOPS", std::to_string(fullTransferConfig.throttleIOPS));
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user