Generated 2019-09-01 for OceanBasePro.

VERSION

@@ -1 +1 @@
-1.36.1943
+1.36.1944

oceanbasepro/CMakeLists.txt

@@ -23,6 +23,8 @@ set(oceanbasepro_public_header
 set(oceanbasepro_public_header_model 
 	include/alibabacloud/oceanbasepro/model/BatchKillProcessListRequest.h
 	include/alibabacloud/oceanbasepro/model/BatchKillProcessListResult.h
+	include/alibabacloud/oceanbasepro/model/BatchKillSessionListRequest.h
+	include/alibabacloud/oceanbasepro/model/BatchKillSessionListResult.h
 	include/alibabacloud/oceanbasepro/model/CancelProjectModifyRecordRequest.h
 	include/alibabacloud/oceanbasepro/model/CancelProjectModifyRecordResult.h
 	include/alibabacloud/oceanbasepro/model/CreateBackupSetDownloadLinkRequest.h
@@ -161,6 +163,8 @@ set(oceanbasepro_public_header_model
 	include/alibabacloud/oceanbasepro/model/DescribeSampleSqlRawTextsResult.h
 	include/alibabacloud/oceanbasepro/model/DescribeSecurityIpGroupsRequest.h
 	include/alibabacloud/oceanbasepro/model/DescribeSecurityIpGroupsResult.h
+	include/alibabacloud/oceanbasepro/model/DescribeSessionListRequest.h
+	include/alibabacloud/oceanbasepro/model/DescribeSessionListResult.h
 	include/alibabacloud/oceanbasepro/model/DescribeSlowSQLHistoryListRequest.h
 	include/alibabacloud/oceanbasepro/model/DescribeSlowSQLHistoryListResult.h
 	include/alibabacloud/oceanbasepro/model/DescribeSlowSQLListRequest.h
@@ -280,6 +284,8 @@ set(oceanbasepro_src
 	src/OceanBaseProClient.cc
 	src/model/BatchKillProcessListRequest.cc
 	src/model/BatchKillProcessListResult.cc
+	src/model/BatchKillSessionListRequest.cc
+	src/model/BatchKillSessionListResult.cc
 	src/model/CancelProjectModifyRecordRequest.cc
 	src/model/CancelProjectModifyRecordResult.cc
 	src/model/CreateBackupSetDownloadLinkRequest.cc
@@ -418,6 +424,8 @@ set(oceanbasepro_src
 	src/model/DescribeSampleSqlRawTextsResult.cc
 	src/model/DescribeSecurityIpGroupsRequest.cc
 	src/model/DescribeSecurityIpGroupsResult.cc
+	src/model/DescribeSessionListRequest.cc
+	src/model/DescribeSessionListResult.cc
 	src/model/DescribeSlowSQLHistoryListRequest.cc
 	src/model/DescribeSlowSQLHistoryListResult.cc
 	src/model/DescribeSlowSQLListRequest.cc

oceanbasepro/include/alibabacloud/oceanbasepro/OceanBaseProClient.h

@@ -24,6 +24,8 @@
 #include "OceanBaseProExport.h"
 #include "model/BatchKillProcessListRequest.h"
 #include "model/BatchKillProcessListResult.h"
+#include "model/BatchKillSessionListRequest.h"
+#include "model/BatchKillSessionListResult.h"
 #include "model/CancelProjectModifyRecordRequest.h"
 #include "model/CancelProjectModifyRecordResult.h"
 #include "model/CreateBackupSetDownloadLinkRequest.h"
@@ -162,6 +164,8 @@
 #include "model/DescribeSampleSqlRawTextsResult.h"
 #include "model/DescribeSecurityIpGroupsRequest.h"
 #include "model/DescribeSecurityIpGroupsResult.h"
+#include "model/DescribeSessionListRequest.h"
+#include "model/DescribeSessionListResult.h"
 #include "model/DescribeSlowSQLHistoryListRequest.h"
 #include "model/DescribeSlowSQLHistoryListResult.h"
 #include "model/DescribeSlowSQLListRequest.h"
@@ -288,6 +292,9 @@ namespace AlibabaCloud
 			typedef Outcome<Error, Model::BatchKillProcessListResult> BatchKillProcessListOutcome;
 			typedef std::future<BatchKillProcessListOutcome> BatchKillProcessListOutcomeCallable;
 			typedef std::function<void(const OceanBaseProClient*, const Model::BatchKillProcessListRequest&, const BatchKillProcessListOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> BatchKillProcessListAsyncHandler;
+			typedef Outcome<Error, Model::BatchKillSessionListResult> BatchKillSessionListOutcome;
+			typedef std::future<BatchKillSessionListOutcome> BatchKillSessionListOutcomeCallable;
+			typedef std::function<void(const OceanBaseProClient*, const Model::BatchKillSessionListRequest&, const BatchKillSessionListOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> BatchKillSessionListAsyncHandler;
 			typedef Outcome<Error, Model::CancelProjectModifyRecordResult> CancelProjectModifyRecordOutcome;
 			typedef std::future<CancelProjectModifyRecordOutcome> CancelProjectModifyRecordOutcomeCallable;
 			typedef std::function<void(const OceanBaseProClient*, const Model::CancelProjectModifyRecordRequest&, const CancelProjectModifyRecordOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> CancelProjectModifyRecordAsyncHandler;
@@ -495,6 +502,9 @@ namespace AlibabaCloud
 			typedef Outcome<Error, Model::DescribeSecurityIpGroupsResult> DescribeSecurityIpGroupsOutcome;
 			typedef std::future<DescribeSecurityIpGroupsOutcome> DescribeSecurityIpGroupsOutcomeCallable;
 			typedef std::function<void(const OceanBaseProClient*, const Model::DescribeSecurityIpGroupsRequest&, const DescribeSecurityIpGroupsOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> DescribeSecurityIpGroupsAsyncHandler;
+			typedef Outcome<Error, Model::DescribeSessionListResult> DescribeSessionListOutcome;
+			typedef std::future<DescribeSessionListOutcome> DescribeSessionListOutcomeCallable;
+			typedef std::function<void(const OceanBaseProClient*, const Model::DescribeSessionListRequest&, const DescribeSessionListOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> DescribeSessionListAsyncHandler;
 			typedef Outcome<Error, Model::DescribeSlowSQLHistoryListResult> DescribeSlowSQLHistoryListOutcome;
 			typedef std::future<DescribeSlowSQLHistoryListOutcome> DescribeSlowSQLHistoryListOutcomeCallable;
 			typedef std::function<void(const OceanBaseProClient*, const Model::DescribeSlowSQLHistoryListRequest&, const DescribeSlowSQLHistoryListOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> DescribeSlowSQLHistoryListAsyncHandler;
@@ -674,6 +684,9 @@ namespace AlibabaCloud
 			BatchKillProcessListOutcome batchKillProcessList(const Model::BatchKillProcessListRequest &request)const;
 			void batchKillProcessListAsync(const Model::BatchKillProcessListRequest& request, const BatchKillProcessListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
 			BatchKillProcessListOutcomeCallable batchKillProcessListCallable(const Model::BatchKillProcessListRequest& request) const;
+			BatchKillSessionListOutcome batchKillSessionList(const Model::BatchKillSessionListRequest &request)const;
+			void batchKillSessionListAsync(const Model::BatchKillSessionListRequest& request, const BatchKillSessionListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
+			BatchKillSessionListOutcomeCallable batchKillSessionListCallable(const Model::BatchKillSessionListRequest& request) const;
 			CancelProjectModifyRecordOutcome cancelProjectModifyRecord(const Model::CancelProjectModifyRecordRequest &request)const;
 			void cancelProjectModifyRecordAsync(const Model::CancelProjectModifyRecordRequest& request, const CancelProjectModifyRecordAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
 			CancelProjectModifyRecordOutcomeCallable cancelProjectModifyRecordCallable(const Model::CancelProjectModifyRecordRequest& request) const;
@@ -881,6 +894,9 @@ namespace AlibabaCloud
 			DescribeSecurityIpGroupsOutcome describeSecurityIpGroups(const Model::DescribeSecurityIpGroupsRequest &request)const;
 			void describeSecurityIpGroupsAsync(const Model::DescribeSecurityIpGroupsRequest& request, const DescribeSecurityIpGroupsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
 			DescribeSecurityIpGroupsOutcomeCallable describeSecurityIpGroupsCallable(const Model::DescribeSecurityIpGroupsRequest& request) const;
+			DescribeSessionListOutcome describeSessionList(const Model::DescribeSessionListRequest &request)const;
+			void describeSessionListAsync(const Model::DescribeSessionListRequest& request, const DescribeSessionListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
+			DescribeSessionListOutcomeCallable describeSessionListCallable(const Model::DescribeSessionListRequest& request) const;
 			DescribeSlowSQLHistoryListOutcome describeSlowSQLHistoryList(const Model::DescribeSlowSQLHistoryListRequest &request)const;
 			void describeSlowSQLHistoryListAsync(const Model::DescribeSlowSQLHistoryListRequest& request, const DescribeSlowSQLHistoryListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
 			DescribeSlowSQLHistoryListOutcomeCallable describeSlowSQLHistoryListCallable(const Model::DescribeSlowSQLHistoryListRequest& request) const;

oceanbasepro/include/alibabacloud/oceanbasepro/model/BatchKillSessionListRequest.h

@@ -0,0 +1,48 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_OCEANBASEPRO_MODEL_BATCHKILLSESSIONLISTREQUEST_H_
+#define ALIBABACLOUD_OCEANBASEPRO_MODEL_BATCHKILLSESSIONLISTREQUEST_H_
+
+#include <alibabacloud/oceanbasepro/OceanBaseProExport.h>
+#include <alibabacloud/core/RpcServiceRequest.h>
+#include <string>
+#include <vector>
+#include <map>
+
+namespace AlibabaCloud {
+namespace OceanBasePro {
+namespace Model {
+class ALIBABACLOUD_OCEANBASEPRO_EXPORT BatchKillSessionListRequest : public RpcServiceRequest {
+public:
+	BatchKillSessionListRequest();
+	~BatchKillSessionListRequest();
+	std::string getSessionList() const;
+	void setSessionList(const std::string &sessionList);
+	std::string getInstanceId() const;
+	void setInstanceId(const std::string &instanceId);
+	std::string getTenantId() const;
+	void setTenantId(const std::string &tenantId);
+
+private:
+	std::string sessionList_;
+	std::string instanceId_;
+	std::string tenantId_;
+};
+} // namespace Model
+} // namespace OceanBasePro
+} // namespace AlibabaCloud
+#endif // !ALIBABACLOUD_OCEANBASEPRO_MODEL_BATCHKILLSESSIONLISTREQUEST_H_

oceanbasepro/include/alibabacloud/oceanbasepro/model/BatchKillSessionListResult.h

@@ -0,0 +1,49 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_OCEANBASEPRO_MODEL_BATCHKILLSESSIONLISTRESULT_H_
+#define ALIBABACLOUD_OCEANBASEPRO_MODEL_BATCHKILLSESSIONLISTRESULT_H_
+
+#include <string>
+#include <vector>
+#include <utility>
+#include <alibabacloud/core/ServiceResult.h>
+#include <alibabacloud/oceanbasepro/OceanBaseProExport.h>
+
+namespace AlibabaCloud
+{
+	namespace OceanBasePro
+	{
+		namespace Model
+		{
+			class ALIBABACLOUD_OCEANBASEPRO_EXPORT BatchKillSessionListResult : public ServiceResult
+			{
+			public:
+
+
+				BatchKillSessionListResult();
+				explicit BatchKillSessionListResult(const std::string &payload);
+				~BatchKillSessionListResult();
+
+			protected:
+				void parse(const std::string &payload);
+			private:
+
+			};
+		}
+	}
+}
+#endif // !ALIBABACLOUD_OCEANBASEPRO_MODEL_BATCHKILLSESSIONLISTRESULT_H_

oceanbasepro/include/alibabacloud/oceanbasepro/model/CreateMySqlDataSourceRequest.h

@@ -36,6 +36,8 @@ public:
 	void setDescription(const std::string &description);
 	std::string getType() const;
 	void setType(const std::string &type);
+	bool getUseSsl() const;
+	void setUseSsl(bool useSsl);
 	std::string getPassword() const;
 	void setPassword(const std::string &password);
 	std::string getDgInstanceId() const;
@@ -57,6 +59,7 @@ private:
 	std::string schema_;
 	std::string description_;
 	std::string type_;
+	bool useSsl_;
 	std::string password_;
 	std::string dgInstanceId_;
 	std::string ip_;

oceanbasepro/include/alibabacloud/oceanbasepro/model/CreateProjectRequest.h

@@ -235,6 +235,7 @@ public:
 		int mqPartition;
 		std::string syncSchemaColumnName;
 		bool activeActive;
+		std::string sinkStoreFormat;
 		bool rocketMqEnableMsgTrace;
 		struct CustomColumnsItem {
 			std::string expression;
@@ -249,6 +250,7 @@ public:
 		std::string datahubTopicType;
 		std::string rocketMqMsgTags;
 		std::string dataWorksBusinessName;
+		std::string sourceStoreFormat;
 		bool syncSchema;
 		std::string mqSerializerType;
 	};

oceanbasepro/include/alibabacloud/oceanbasepro/model/DescribeSessionListRequest.h

@@ -0,0 +1,45 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_OCEANBASEPRO_MODEL_DESCRIBESESSIONLISTREQUEST_H_
+#define ALIBABACLOUD_OCEANBASEPRO_MODEL_DESCRIBESESSIONLISTREQUEST_H_
+
+#include <alibabacloud/oceanbasepro/OceanBaseProExport.h>
+#include <alibabacloud/core/RpcServiceRequest.h>
+#include <string>
+#include <vector>
+#include <map>
+
+namespace AlibabaCloud {
+namespace OceanBasePro {
+namespace Model {
+class ALIBABACLOUD_OCEANBASEPRO_EXPORT DescribeSessionListRequest : public RpcServiceRequest {
+public:
+	DescribeSessionListRequest();
+	~DescribeSessionListRequest();
+	std::string getInstanceId() const;
+	void setInstanceId(const std::string &instanceId);
+	std::string getTenantId() const;
+	void setTenantId(const std::string &tenantId);
+
+private:
+	std::string instanceId_;
+	std::string tenantId_;
+};
+} // namespace Model
+} // namespace OceanBasePro
+} // namespace AlibabaCloud
+#endif // !ALIBABACLOUD_OCEANBASEPRO_MODEL_DESCRIBESESSIONLISTREQUEST_H_

oceanbasepro/include/alibabacloud/oceanbasepro/model/DescribeSessionListResult.h

@@ -0,0 +1,56 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef ALIBABACLOUD_OCEANBASEPRO_MODEL_DESCRIBESESSIONLISTRESULT_H_
+#define ALIBABACLOUD_OCEANBASEPRO_MODEL_DESCRIBESESSIONLISTRESULT_H_
+
+#include <string>
+#include <vector>
+#include <utility>
+#include <alibabacloud/core/ServiceResult.h>
+#include <alibabacloud/oceanbasepro/OceanBaseProExport.h>
+
+namespace AlibabaCloud
+{
+	namespace OceanBasePro
+	{
+		namespace Model
+		{
+			class ALIBABACLOUD_OCEANBASEPRO_EXPORT DescribeSessionListResult : public ServiceResult
+			{
+			public:
+				struct DataItem
+				{
+					std::string host;
+					std::string sessionId;
+				};
+
+
+				DescribeSessionListResult();
+				explicit DescribeSessionListResult(const std::string &payload);
+				~DescribeSessionListResult();
+				std::vector<DataItem> getData()const;
+
+			protected:
+				void parse(const std::string &payload);
+			private:
+				std::vector<DataItem> data_;
+
+			};
+		}
+	}
+}
+#endif // !ALIBABACLOUD_OCEANBASEPRO_MODEL_DESCRIBESESSIONLISTRESULT_H_

oceanbasepro/include/alibabacloud/oceanbasepro/model/UpdateProjectConfigRequest.h

@@ -28,6 +28,10 @@ namespace OceanBasePro {
 namespace Model {
 class ALIBABACLOUD_OCEANBASEPRO_EXPORT UpdateProjectConfigRequest : public RpcServiceRequest {
 public:
+	struct CommonTransferConfig {
+		std::string sinkStoreFormat;
+		std::string sourceStoreFormat;
+	};
 	struct ReverseIncrTransferConfig {
 		int throttleRps;
 		std::string string;
@@ -54,6 +58,8 @@ public:
 	};
 	UpdateProjectConfigRequest();
 	~UpdateProjectConfigRequest();
+	CommonTransferConfig getCommonTransferConfig() const;
+	void setCommonTransferConfig(const CommonTransferConfig &commonTransferConfig);
 	ReverseIncrTransferConfig getReverseIncrTransferConfig() const;
 	void setReverseIncrTransferConfig(const ReverseIncrTransferConfig &reverseIncrTransferConfig);
 	FullTransferConfig getFullTransferConfig() const;
@@ -64,6 +70,7 @@ public:
 	void setIncrTransferConfig(const IncrTransferConfig &incrTransferConfig);
 
 private:
+	CommonTransferConfig commonTransferConfig_;
 	ReverseIncrTransferConfig reverseIncrTransferConfig_;
 	FullTransferConfig fullTransferConfig_;
 	std::string id_;

oceanbasepro/src/OceanBaseProClient.cc

@@ -87,6 +87,42 @@ OceanBaseProClient::BatchKillProcessListOutcomeCallable OceanBaseProClient::batc
 	return task->get_future();
 }
 
+OceanBaseProClient::BatchKillSessionListOutcome OceanBaseProClient::batchKillSessionList(const BatchKillSessionListRequest &request) const
+{
+	auto endpointOutcome = endpointProvider_->getEndpoint();
+	if (!endpointOutcome.isSuccess())
+		return BatchKillSessionListOutcome(endpointOutcome.error());
+
+	auto outcome = makeRequest(endpointOutcome.result(), request);
+
+	if (outcome.isSuccess())
+		return BatchKillSessionListOutcome(BatchKillSessionListResult(outcome.result()));
+	else
+		return BatchKillSessionListOutcome(outcome.error());
+}
+
+void OceanBaseProClient::batchKillSessionListAsync(const BatchKillSessionListRequest& request, const BatchKillSessionListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
+{
+	auto fn = [this, request, handler, context]()
+	{
+		handler(this, request, batchKillSessionList(request), context);
+	};
+
+	asyncExecute(new Runnable(fn));
+}
+
+OceanBaseProClient::BatchKillSessionListOutcomeCallable OceanBaseProClient::batchKillSessionListCallable(const BatchKillSessionListRequest &request) const
+{
+	auto task = std::make_shared<std::packaged_task<BatchKillSessionListOutcome()>>(
+			[this, request]()
+			{
+			return this->batchKillSessionList(request);
+			});
+
+	asyncExecute(new Runnable([task]() { (*task)(); }));
+	return task->get_future();
+}
+
 OceanBaseProClient::CancelProjectModifyRecordOutcome OceanBaseProClient::cancelProjectModifyRecord(const CancelProjectModifyRecordRequest &request) const
 {
 	auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -2571,6 +2607,42 @@ OceanBaseProClient::DescribeSecurityIpGroupsOutcomeCallable OceanBaseProClient::
 	return task->get_future();
 }
 
+OceanBaseProClient::DescribeSessionListOutcome OceanBaseProClient::describeSessionList(const DescribeSessionListRequest &request) const
+{
+	auto endpointOutcome = endpointProvider_->getEndpoint();
+	if (!endpointOutcome.isSuccess())
+		return DescribeSessionListOutcome(endpointOutcome.error());
+
+	auto outcome = makeRequest(endpointOutcome.result(), request);
+
+	if (outcome.isSuccess())
+		return DescribeSessionListOutcome(DescribeSessionListResult(outcome.result()));
+	else
+		return DescribeSessionListOutcome(outcome.error());
+}
+
+void OceanBaseProClient::describeSessionListAsync(const DescribeSessionListRequest& request, const DescribeSessionListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
+{
+	auto fn = [this, request, handler, context]()
+	{
+		handler(this, request, describeSessionList(request), context);
+	};
+
+	asyncExecute(new Runnable(fn));
+}
+
+OceanBaseProClient::DescribeSessionListOutcomeCallable OceanBaseProClient::describeSessionListCallable(const DescribeSessionListRequest &request) const
+{
+	auto task = std::make_shared<std::packaged_task<DescribeSessionListOutcome()>>(
+			[this, request]()
+			{
+			return this->describeSessionList(request);
+			});
+
+	asyncExecute(new Runnable([task]() { (*task)(); }));
+	return task->get_future();
+}
+
 OceanBaseProClient::DescribeSlowSQLHistoryListOutcome OceanBaseProClient::describeSlowSQLHistoryList(const DescribeSlowSQLHistoryListRequest &request) const
 {
 	auto endpointOutcome = endpointProvider_->getEndpoint();

oceanbasepro/src/model/BatchKillSessionListRequest.cc

@@ -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/BatchKillSessionListRequest.h>
+
+using AlibabaCloud::OceanBasePro::Model::BatchKillSessionListRequest;
+
+BatchKillSessionListRequest::BatchKillSessionListRequest()
+    : RpcServiceRequest("oceanbasepro", "2019-09-01", "BatchKillSessionList") {
+  setMethod(HttpRequest::Method::Post);
+}
+
+BatchKillSessionListRequest::~BatchKillSessionListRequest() {}
+
+std::string BatchKillSessionListRequest::getSessionList() const {
+  return sessionList_;
+}
+
+void BatchKillSessionListRequest::setSessionList(const std::string &sessionList) {
+  sessionList_ = sessionList;
+  setBodyParameter(std::string("SessionList"), sessionList);
+}
+
+std::string BatchKillSessionListRequest::getInstanceId() const {
+  return instanceId_;
+}
+
+void BatchKillSessionListRequest::setInstanceId(const std::string &instanceId) {
+  instanceId_ = instanceId;
+  setBodyParameter(std::string("InstanceId"), instanceId);
+}
+
+std::string BatchKillSessionListRequest::getTenantId() const {
+  return tenantId_;
+}
+
+void BatchKillSessionListRequest::setTenantId(const std::string &tenantId) {
+  tenantId_ = tenantId;
+  setBodyParameter(std::string("TenantId"), tenantId);
+}
+

oceanbasepro/src/model/BatchKillSessionListResult.cc

@@ -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/BatchKillSessionListResult.h>
+#include <json/json.h>
+
+using namespace AlibabaCloud::OceanBasePro;
+using namespace AlibabaCloud::OceanBasePro::Model;
+
+BatchKillSessionListResult::BatchKillSessionListResult() :
+	ServiceResult()
+{}
+
+BatchKillSessionListResult::BatchKillSessionListResult(const std::string &payload) :
+	ServiceResult()
+{
+	parse(payload);
+}
+
+BatchKillSessionListResult::~BatchKillSessionListResult()
+{}
+
+void BatchKillSessionListResult::parse(const std::string &payload)
+{
+	Json::Reader reader;
+	Json::Value value;
+	reader.parse(payload, value);
+	setRequestId(value["RequestId"].asString());
+
+}
+

oceanbasepro/src/model/CreateMySqlDataSourceRequest.cc

@@ -52,6 +52,15 @@ void CreateMySqlDataSourceRequest::setType(const std::string &type) {
   setBodyParameter(std::string("Type"), type);
 }
 
+bool CreateMySqlDataSourceRequest::getUseSsl() const {
+  return useSsl_;
+}
+
+void CreateMySqlDataSourceRequest::setUseSsl(bool useSsl) {
+  useSsl_ = useSsl;
+  setBodyParameter(std::string("UseSsl"), useSsl ? "true" : "false");
+}
+
 std::string CreateMySqlDataSourceRequest::getPassword() const {
   return password_;
 }

oceanbasepro/src/model/CreateProjectRequest.cc

@@ -311,6 +311,7 @@ void CreateProjectRequest::setCommonTransferConfig(const CreateProjectRequest::C
   setBodyParameter(std::string("CommonTransferConfig") + ".MqPartition", std::to_string(commonTransferConfig.mqPartition));
   setBodyParameter(std::string("CommonTransferConfig") + ".SyncSchemaColumnName", commonTransferConfig.syncSchemaColumnName);
   setBodyParameter(std::string("CommonTransferConfig") + ".ActiveActive", commonTransferConfig.activeActive ? "true" : "false");
+  setBodyParameter(std::string("CommonTransferConfig") + ".SinkStoreFormat", commonTransferConfig.sinkStoreFormat);
   setBodyParameter(std::string("CommonTransferConfig") + ".RocketMqEnableMsgTrace", commonTransferConfig.rocketMqEnableMsgTrace ? "true" : "false");
   for(int dep1 = 0; dep1 != commonTransferConfig.customColumns.size(); dep1++) {
     setBodyParameter(std::string("CommonTransferConfig") + ".CustomColumns." + std::to_string(dep1 + 1) + ".Expression", commonTransferConfig.customColumns[dep1].expression);
@@ -323,6 +324,7 @@ void CreateProjectRequest::setCommonTransferConfig(const CreateProjectRequest::C
   setBodyParameter(std::string("CommonTransferConfig") + ".DatahubTopicType", commonTransferConfig.datahubTopicType);
   setBodyParameter(std::string("CommonTransferConfig") + ".RocketMqMsgTags", commonTransferConfig.rocketMqMsgTags);
   setBodyParameter(std::string("CommonTransferConfig") + ".DataWorksBusinessName", commonTransferConfig.dataWorksBusinessName);
+  setBodyParameter(std::string("CommonTransferConfig") + ".SourceStoreFormat", commonTransferConfig.sourceStoreFormat);
   setBodyParameter(std::string("CommonTransferConfig") + ".SyncSchema", commonTransferConfig.syncSchema ? "true" : "false");
   setBodyParameter(std::string("CommonTransferConfig") + ".MqSerializerType", commonTransferConfig.mqSerializerType);
 }

oceanbasepro/src/model/DescribeSessionListRequest.cc

@@ -0,0 +1,45 @@
+/*
+ * 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/DescribeSessionListRequest.h>
+
+using AlibabaCloud::OceanBasePro::Model::DescribeSessionListRequest;
+
+DescribeSessionListRequest::DescribeSessionListRequest()
+    : RpcServiceRequest("oceanbasepro", "2019-09-01", "DescribeSessionList") {
+  setMethod(HttpRequest::Method::Post);
+}
+
+DescribeSessionListRequest::~DescribeSessionListRequest() {}
+
+std::string DescribeSessionListRequest::getInstanceId() const {
+  return instanceId_;
+}
+
+void DescribeSessionListRequest::setInstanceId(const std::string &instanceId) {
+  instanceId_ = instanceId;
+  setBodyParameter(std::string("InstanceId"), instanceId);
+}
+
+std::string DescribeSessionListRequest::getTenantId() const {
+  return tenantId_;
+}
+
+void DescribeSessionListRequest::setTenantId(const std::string &tenantId) {
+  tenantId_ = tenantId;
+  setBodyParameter(std::string("TenantId"), tenantId);
+}
+

oceanbasepro/src/model/DescribeSessionListResult.cc

@@ -0,0 +1,59 @@
+/*
+ * 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/DescribeSessionListResult.h>
+#include <json/json.h>
+
+using namespace AlibabaCloud::OceanBasePro;
+using namespace AlibabaCloud::OceanBasePro::Model;
+
+DescribeSessionListResult::DescribeSessionListResult() :
+	ServiceResult()
+{}
+
+DescribeSessionListResult::DescribeSessionListResult(const std::string &payload) :
+	ServiceResult()
+{
+	parse(payload);
+}
+
+DescribeSessionListResult::~DescribeSessionListResult()
+{}
+
+void DescribeSessionListResult::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["SessionId"].isNull())
+			dataObject.sessionId = valueDataDataItem["SessionId"].asString();
+		if(!valueDataDataItem["Host"].isNull())
+			dataObject.host = valueDataDataItem["Host"].asString();
+		data_.push_back(dataObject);
+	}
+
+}
+
+std::vector<DescribeSessionListResult::DataItem> DescribeSessionListResult::getData()const
+{
+	return data_;
+}
+

oceanbasepro/src/model/UpdateProjectConfigRequest.cc

@@ -25,6 +25,16 @@ UpdateProjectConfigRequest::UpdateProjectConfigRequest()
 
 UpdateProjectConfigRequest::~UpdateProjectConfigRequest() {}
 
+UpdateProjectConfigRequest::CommonTransferConfig UpdateProjectConfigRequest::getCommonTransferConfig() const {
+  return commonTransferConfig_;
+}
+
+void UpdateProjectConfigRequest::setCommonTransferConfig(const UpdateProjectConfigRequest::CommonTransferConfig &commonTransferConfig) {
+  commonTransferConfig_ = commonTransferConfig;
+  setBodyParameter(std::string("CommonTransferConfig") + ".SinkStoreFormat", commonTransferConfig.sinkStoreFormat);
+  setBodyParameter(std::string("CommonTransferConfig") + ".SourceStoreFormat", commonTransferConfig.sourceStoreFormat);
+}
+
 UpdateProjectConfigRequest::ReverseIncrTransferConfig UpdateProjectConfigRequest::getReverseIncrTransferConfig() const {
   return reverseIncrTransferConfig_;
 }