diff --git a/CHANGELOG b/CHANGELOG index 430f48890..225953acf 100644 --- a/CHANGELOG +++ b/CHANGELOG @@ -1,3 +1,6 @@ +2022-03-31 Version: 1.36.1095 +- Supported ListTaskFlow, ListTaskFlowInstance, GetTaskInstanceRelation, GetLhSpaceByName, DeleteLakeHouseSpace, DeleteTaskFlow API. + 2022-03-31 Version: 1.36.1094 - CreateDataSourceItem. - ListDataSourceItem. diff --git a/VERSION b/VERSION index cf1c809db..2bbf3b31a 100644 --- a/VERSION +++ b/VERSION @@ -1 +1 @@ -1.36.1094 \ No newline at end of file +1.36.1095 \ No newline at end of file diff --git a/dms-enterprise/CMakeLists.txt b/dms-enterprise/CMakeLists.txt index 7a08ab3be..e5af70057 100644 --- a/dms-enterprise/CMakeLists.txt +++ b/dms-enterprise/CMakeLists.txt @@ -65,6 +65,8 @@ set(dms-enterprise_public_header_model include/alibabacloud/dms-enterprise/model/CreateUploadOSSFileJobResult.h include/alibabacloud/dms-enterprise/model/DeleteInstanceRequest.h include/alibabacloud/dms-enterprise/model/DeleteInstanceResult.h + include/alibabacloud/dms-enterprise/model/DeleteLakeHouseSpaceRequest.h + include/alibabacloud/dms-enterprise/model/DeleteLakeHouseSpaceResult.h include/alibabacloud/dms-enterprise/model/DeleteLhMembersRequest.h include/alibabacloud/dms-enterprise/model/DeleteLhMembersResult.h include/alibabacloud/dms-enterprise/model/DeleteLogicDatabaseRequest.h @@ -75,6 +77,8 @@ set(dms-enterprise_public_header_model include/alibabacloud/dms-enterprise/model/DeleteProxyResult.h include/alibabacloud/dms-enterprise/model/DeleteProxyAccessRequest.h include/alibabacloud/dms-enterprise/model/DeleteProxyAccessResult.h + include/alibabacloud/dms-enterprise/model/DeleteTaskFlowRequest.h + include/alibabacloud/dms-enterprise/model/DeleteTaskFlowResult.h include/alibabacloud/dms-enterprise/model/DeleteUserRequest.h include/alibabacloud/dms-enterprise/model/DeleteUserResult.h include/alibabacloud/dms-enterprise/model/DisableUserRequest.h @@ -115,6 +119,8 @@ set(dms-enterprise_public_header_model include/alibabacloud/dms-enterprise/model/GetDatabaseResult.h include/alibabacloud/dms-enterprise/model/GetInstanceRequest.h include/alibabacloud/dms-enterprise/model/GetInstanceResult.h + include/alibabacloud/dms-enterprise/model/GetLhSpaceByNameRequest.h + include/alibabacloud/dms-enterprise/model/GetLhSpaceByNameResult.h include/alibabacloud/dms-enterprise/model/GetLogicDatabaseRequest.h include/alibabacloud/dms-enterprise/model/GetLogicDatabaseResult.h include/alibabacloud/dms-enterprise/model/GetMetaTableColumnRequest.h @@ -149,6 +155,8 @@ set(dms-enterprise_public_header_model include/alibabacloud/dms-enterprise/model/GetTableDBTopologyResult.h include/alibabacloud/dms-enterprise/model/GetTableTopologyRequest.h include/alibabacloud/dms-enterprise/model/GetTableTopologyResult.h + include/alibabacloud/dms-enterprise/model/GetTaskInstanceRelationRequest.h + include/alibabacloud/dms-enterprise/model/GetTaskInstanceRelationResult.h include/alibabacloud/dms-enterprise/model/GetUserRequest.h include/alibabacloud/dms-enterprise/model/GetUserResult.h include/alibabacloud/dms-enterprise/model/GetUserActiveTenantRequest.h @@ -211,6 +219,10 @@ set(dms-enterprise_public_header_model include/alibabacloud/dms-enterprise/model/ListStandardGroupsResult.h include/alibabacloud/dms-enterprise/model/ListTablesRequest.h include/alibabacloud/dms-enterprise/model/ListTablesResult.h + include/alibabacloud/dms-enterprise/model/ListTaskFlowRequest.h + include/alibabacloud/dms-enterprise/model/ListTaskFlowResult.h + include/alibabacloud/dms-enterprise/model/ListTaskFlowInstanceRequest.h + include/alibabacloud/dms-enterprise/model/ListTaskFlowInstanceResult.h include/alibabacloud/dms-enterprise/model/ListUserPermissionsRequest.h include/alibabacloud/dms-enterprise/model/ListUserPermissionsResult.h include/alibabacloud/dms-enterprise/model/ListUserTenantsRequest.h @@ -302,6 +314,8 @@ set(dms-enterprise_src src/model/CreateUploadOSSFileJobResult.cc src/model/DeleteInstanceRequest.cc src/model/DeleteInstanceResult.cc + src/model/DeleteLakeHouseSpaceRequest.cc + src/model/DeleteLakeHouseSpaceResult.cc src/model/DeleteLhMembersRequest.cc src/model/DeleteLhMembersResult.cc src/model/DeleteLogicDatabaseRequest.cc @@ -312,6 +326,8 @@ set(dms-enterprise_src src/model/DeleteProxyResult.cc src/model/DeleteProxyAccessRequest.cc src/model/DeleteProxyAccessResult.cc + src/model/DeleteTaskFlowRequest.cc + src/model/DeleteTaskFlowResult.cc src/model/DeleteUserRequest.cc src/model/DeleteUserResult.cc src/model/DisableUserRequest.cc @@ -352,6 +368,8 @@ set(dms-enterprise_src src/model/GetDatabaseResult.cc src/model/GetInstanceRequest.cc src/model/GetInstanceResult.cc + src/model/GetLhSpaceByNameRequest.cc + src/model/GetLhSpaceByNameResult.cc src/model/GetLogicDatabaseRequest.cc src/model/GetLogicDatabaseResult.cc src/model/GetMetaTableColumnRequest.cc @@ -386,6 +404,8 @@ set(dms-enterprise_src src/model/GetTableDBTopologyResult.cc src/model/GetTableTopologyRequest.cc src/model/GetTableTopologyResult.cc + src/model/GetTaskInstanceRelationRequest.cc + src/model/GetTaskInstanceRelationResult.cc src/model/GetUserRequest.cc src/model/GetUserResult.cc src/model/GetUserActiveTenantRequest.cc @@ -448,6 +468,10 @@ set(dms-enterprise_src src/model/ListStandardGroupsResult.cc src/model/ListTablesRequest.cc src/model/ListTablesResult.cc + src/model/ListTaskFlowRequest.cc + src/model/ListTaskFlowResult.cc + src/model/ListTaskFlowInstanceRequest.cc + src/model/ListTaskFlowInstanceResult.cc src/model/ListUserPermissionsRequest.cc src/model/ListUserPermissionsResult.cc src/model/ListUserTenantsRequest.cc diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/Dms_enterpriseClient.h b/dms-enterprise/include/alibabacloud/dms-enterprise/Dms_enterpriseClient.h index 536525de4..8f6678d0e 100644 --- a/dms-enterprise/include/alibabacloud/dms-enterprise/Dms_enterpriseClient.h +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/Dms_enterpriseClient.h @@ -66,6 +66,8 @@ #include "model/CreateUploadOSSFileJobResult.h" #include "model/DeleteInstanceRequest.h" #include "model/DeleteInstanceResult.h" +#include "model/DeleteLakeHouseSpaceRequest.h" +#include "model/DeleteLakeHouseSpaceResult.h" #include "model/DeleteLhMembersRequest.h" #include "model/DeleteLhMembersResult.h" #include "model/DeleteLogicDatabaseRequest.h" @@ -76,6 +78,8 @@ #include "model/DeleteProxyResult.h" #include "model/DeleteProxyAccessRequest.h" #include "model/DeleteProxyAccessResult.h" +#include "model/DeleteTaskFlowRequest.h" +#include "model/DeleteTaskFlowResult.h" #include "model/DeleteUserRequest.h" #include "model/DeleteUserResult.h" #include "model/DisableUserRequest.h" @@ -116,6 +120,8 @@ #include "model/GetDatabaseResult.h" #include "model/GetInstanceRequest.h" #include "model/GetInstanceResult.h" +#include "model/GetLhSpaceByNameRequest.h" +#include "model/GetLhSpaceByNameResult.h" #include "model/GetLogicDatabaseRequest.h" #include "model/GetLogicDatabaseResult.h" #include "model/GetMetaTableColumnRequest.h" @@ -150,6 +156,8 @@ #include "model/GetTableDBTopologyResult.h" #include "model/GetTableTopologyRequest.h" #include "model/GetTableTopologyResult.h" +#include "model/GetTaskInstanceRelationRequest.h" +#include "model/GetTaskInstanceRelationResult.h" #include "model/GetUserRequest.h" #include "model/GetUserResult.h" #include "model/GetUserActiveTenantRequest.h" @@ -212,6 +220,10 @@ #include "model/ListStandardGroupsResult.h" #include "model/ListTablesRequest.h" #include "model/ListTablesResult.h" +#include "model/ListTaskFlowRequest.h" +#include "model/ListTaskFlowResult.h" +#include "model/ListTaskFlowInstanceRequest.h" +#include "model/ListTaskFlowInstanceResult.h" #include "model/ListUserPermissionsRequest.h" #include "model/ListUserPermissionsResult.h" #include "model/ListUserTenantsRequest.h" @@ -331,6 +343,9 @@ namespace AlibabaCloud typedef Outcome DeleteInstanceOutcome; typedef std::future DeleteInstanceOutcomeCallable; typedef std::function&)> DeleteInstanceAsyncHandler; + typedef Outcome DeleteLakeHouseSpaceOutcome; + typedef std::future DeleteLakeHouseSpaceOutcomeCallable; + typedef std::function&)> DeleteLakeHouseSpaceAsyncHandler; typedef Outcome DeleteLhMembersOutcome; typedef std::future DeleteLhMembersOutcomeCallable; typedef std::function&)> DeleteLhMembersAsyncHandler; @@ -346,6 +361,9 @@ namespace AlibabaCloud typedef Outcome DeleteProxyAccessOutcome; typedef std::future DeleteProxyAccessOutcomeCallable; typedef std::function&)> DeleteProxyAccessAsyncHandler; + typedef Outcome DeleteTaskFlowOutcome; + typedef std::future DeleteTaskFlowOutcomeCallable; + typedef std::function&)> DeleteTaskFlowAsyncHandler; typedef Outcome DeleteUserOutcome; typedef std::future DeleteUserOutcomeCallable; typedef std::function&)> DeleteUserAsyncHandler; @@ -406,6 +424,9 @@ namespace AlibabaCloud typedef Outcome GetInstanceOutcome; typedef std::future GetInstanceOutcomeCallable; typedef std::function&)> GetInstanceAsyncHandler; + typedef Outcome GetLhSpaceByNameOutcome; + typedef std::future GetLhSpaceByNameOutcomeCallable; + typedef std::function&)> GetLhSpaceByNameAsyncHandler; typedef Outcome GetLogicDatabaseOutcome; typedef std::future GetLogicDatabaseOutcomeCallable; typedef std::function&)> GetLogicDatabaseAsyncHandler; @@ -457,6 +478,9 @@ namespace AlibabaCloud typedef Outcome GetTableTopologyOutcome; typedef std::future GetTableTopologyOutcomeCallable; typedef std::function&)> GetTableTopologyAsyncHandler; + typedef Outcome GetTaskInstanceRelationOutcome; + typedef std::future GetTaskInstanceRelationOutcomeCallable; + typedef std::function&)> GetTaskInstanceRelationAsyncHandler; typedef Outcome GetUserOutcome; typedef std::future GetUserOutcomeCallable; typedef std::function&)> GetUserAsyncHandler; @@ -550,6 +574,12 @@ namespace AlibabaCloud typedef Outcome ListTablesOutcome; typedef std::future ListTablesOutcomeCallable; typedef std::function&)> ListTablesAsyncHandler; + typedef Outcome ListTaskFlowOutcome; + typedef std::future ListTaskFlowOutcomeCallable; + typedef std::function&)> ListTaskFlowAsyncHandler; + typedef Outcome ListTaskFlowInstanceOutcome; + typedef std::future ListTaskFlowInstanceOutcomeCallable; + typedef std::function&)> ListTaskFlowInstanceAsyncHandler; typedef Outcome ListUserPermissionsOutcome; typedef std::future ListUserPermissionsOutcomeCallable; typedef std::function&)> ListUserPermissionsAsyncHandler; @@ -687,6 +717,9 @@ namespace AlibabaCloud DeleteInstanceOutcome deleteInstance(const Model::DeleteInstanceRequest &request)const; void deleteInstanceAsync(const Model::DeleteInstanceRequest& request, const DeleteInstanceAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; DeleteInstanceOutcomeCallable deleteInstanceCallable(const Model::DeleteInstanceRequest& request) const; + DeleteLakeHouseSpaceOutcome deleteLakeHouseSpace(const Model::DeleteLakeHouseSpaceRequest &request)const; + void deleteLakeHouseSpaceAsync(const Model::DeleteLakeHouseSpaceRequest& request, const DeleteLakeHouseSpaceAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + DeleteLakeHouseSpaceOutcomeCallable deleteLakeHouseSpaceCallable(const Model::DeleteLakeHouseSpaceRequest& request) const; DeleteLhMembersOutcome deleteLhMembers(const Model::DeleteLhMembersRequest &request)const; void deleteLhMembersAsync(const Model::DeleteLhMembersRequest& request, const DeleteLhMembersAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; DeleteLhMembersOutcomeCallable deleteLhMembersCallable(const Model::DeleteLhMembersRequest& request) const; @@ -702,6 +735,9 @@ namespace AlibabaCloud DeleteProxyAccessOutcome deleteProxyAccess(const Model::DeleteProxyAccessRequest &request)const; void deleteProxyAccessAsync(const Model::DeleteProxyAccessRequest& request, const DeleteProxyAccessAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; DeleteProxyAccessOutcomeCallable deleteProxyAccessCallable(const Model::DeleteProxyAccessRequest& request) const; + DeleteTaskFlowOutcome deleteTaskFlow(const Model::DeleteTaskFlowRequest &request)const; + void deleteTaskFlowAsync(const Model::DeleteTaskFlowRequest& request, const DeleteTaskFlowAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + DeleteTaskFlowOutcomeCallable deleteTaskFlowCallable(const Model::DeleteTaskFlowRequest& request) const; DeleteUserOutcome deleteUser(const Model::DeleteUserRequest &request)const; void deleteUserAsync(const Model::DeleteUserRequest& request, const DeleteUserAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; DeleteUserOutcomeCallable deleteUserCallable(const Model::DeleteUserRequest& request) const; @@ -762,6 +798,9 @@ namespace AlibabaCloud GetInstanceOutcome getInstance(const Model::GetInstanceRequest &request)const; void getInstanceAsync(const Model::GetInstanceRequest& request, const GetInstanceAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; GetInstanceOutcomeCallable getInstanceCallable(const Model::GetInstanceRequest& request) const; + GetLhSpaceByNameOutcome getLhSpaceByName(const Model::GetLhSpaceByNameRequest &request)const; + void getLhSpaceByNameAsync(const Model::GetLhSpaceByNameRequest& request, const GetLhSpaceByNameAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + GetLhSpaceByNameOutcomeCallable getLhSpaceByNameCallable(const Model::GetLhSpaceByNameRequest& request) const; GetLogicDatabaseOutcome getLogicDatabase(const Model::GetLogicDatabaseRequest &request)const; void getLogicDatabaseAsync(const Model::GetLogicDatabaseRequest& request, const GetLogicDatabaseAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; GetLogicDatabaseOutcomeCallable getLogicDatabaseCallable(const Model::GetLogicDatabaseRequest& request) const; @@ -813,6 +852,9 @@ namespace AlibabaCloud GetTableTopologyOutcome getTableTopology(const Model::GetTableTopologyRequest &request)const; void getTableTopologyAsync(const Model::GetTableTopologyRequest& request, const GetTableTopologyAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; GetTableTopologyOutcomeCallable getTableTopologyCallable(const Model::GetTableTopologyRequest& request) const; + GetTaskInstanceRelationOutcome getTaskInstanceRelation(const Model::GetTaskInstanceRelationRequest &request)const; + void getTaskInstanceRelationAsync(const Model::GetTaskInstanceRelationRequest& request, const GetTaskInstanceRelationAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + GetTaskInstanceRelationOutcomeCallable getTaskInstanceRelationCallable(const Model::GetTaskInstanceRelationRequest& request) const; GetUserOutcome getUser(const Model::GetUserRequest &request)const; void getUserAsync(const Model::GetUserRequest& request, const GetUserAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; GetUserOutcomeCallable getUserCallable(const Model::GetUserRequest& request) const; @@ -906,6 +948,12 @@ namespace AlibabaCloud ListTablesOutcome listTables(const Model::ListTablesRequest &request)const; void listTablesAsync(const Model::ListTablesRequest& request, const ListTablesAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ListTablesOutcomeCallable listTablesCallable(const Model::ListTablesRequest& request) const; + ListTaskFlowOutcome listTaskFlow(const Model::ListTaskFlowRequest &request)const; + void listTaskFlowAsync(const Model::ListTaskFlowRequest& request, const ListTaskFlowAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + ListTaskFlowOutcomeCallable listTaskFlowCallable(const Model::ListTaskFlowRequest& request) const; + ListTaskFlowInstanceOutcome listTaskFlowInstance(const Model::ListTaskFlowInstanceRequest &request)const; + void listTaskFlowInstanceAsync(const Model::ListTaskFlowInstanceRequest& request, const ListTaskFlowInstanceAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; + ListTaskFlowInstanceOutcomeCallable listTaskFlowInstanceCallable(const Model::ListTaskFlowInstanceRequest& request) const; ListUserPermissionsOutcome listUserPermissions(const Model::ListUserPermissionsRequest &request)const; void listUserPermissionsAsync(const Model::ListUserPermissionsRequest& request, const ListUserPermissionsAsyncHandler& handler, const std::shared_ptr& context = nullptr) const; ListUserPermissionsOutcomeCallable listUserPermissionsCallable(const Model::ListUserPermissionsRequest& request) const; diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/CreateLakeHouseSpaceRequest.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/CreateLakeHouseSpaceRequest.h index 23b3901d1..4a40b3495 100644 --- a/dms-enterprise/include/alibabacloud/dms-enterprise/model/CreateLakeHouseSpaceRequest.h +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/model/CreateLakeHouseSpaceRequest.h @@ -34,8 +34,6 @@ public: void setSpaceName(const std::string &spaceName); std::string getDescription() const; void setDescription(const std::string &description); - long getUserId() const; - void setUserId(long userId); long getTid() const; void setTid(long tid); std::string getMode() const; @@ -52,7 +50,6 @@ public: private: std::string spaceName_; std::string description_; - long userId_; long tid_; std::string mode_; std::string dwDbType_; diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/DeleteLakeHouseSpaceRequest.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/DeleteLakeHouseSpaceRequest.h new file mode 100644 index 000000000..efde4a26f --- /dev/null +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/model/DeleteLakeHouseSpaceRequest.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_DMS_ENTERPRISE_MODEL_DELETELAKEHOUSESPACEREQUEST_H_ +#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETELAKEHOUSESPACEREQUEST_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud { +namespace Dms_enterprise { +namespace Model { +class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT DeleteLakeHouseSpaceRequest : public RpcServiceRequest { +public: + DeleteLakeHouseSpaceRequest(); + ~DeleteLakeHouseSpaceRequest(); + long getSpaceId() const; + void setSpaceId(long spaceId); + long getTid() const; + void setTid(long tid); + +private: + long spaceId_; + long tid_; +}; +} // namespace Model +} // namespace Dms_enterprise +} // namespace AlibabaCloud +#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETELAKEHOUSESPACEREQUEST_H_ diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/DeleteLakeHouseSpaceResult.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/DeleteLakeHouseSpaceResult.h new file mode 100644 index 000000000..3d8f30d42 --- /dev/null +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/model/DeleteLakeHouseSpaceResult.h @@ -0,0 +1,55 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETELAKEHOUSESPACERESULT_H_ +#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETELAKEHOUSESPACERESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dms_enterprise + { + namespace Model + { + class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT DeleteLakeHouseSpaceResult : public ServiceResult + { + public: + + + DeleteLakeHouseSpaceResult(); + explicit DeleteLakeHouseSpaceResult(const std::string &payload); + ~DeleteLakeHouseSpaceResult(); + std::string getErrorCode()const; + std::string getErrorMessage()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + std::string errorCode_; + std::string errorMessage_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETELAKEHOUSESPACERESULT_H_ \ No newline at end of file diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/DeleteTaskFlowRequest.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/DeleteTaskFlowRequest.h new file mode 100644 index 000000000..02ede1b62 --- /dev/null +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/model/DeleteTaskFlowRequest.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_DMS_ENTERPRISE_MODEL_DELETETASKFLOWREQUEST_H_ +#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETETASKFLOWREQUEST_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud { +namespace Dms_enterprise { +namespace Model { +class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT DeleteTaskFlowRequest : public RpcServiceRequest { +public: + DeleteTaskFlowRequest(); + ~DeleteTaskFlowRequest(); + long getDagId() const; + void setDagId(long dagId); + long getTid() const; + void setTid(long tid); + +private: + long dagId_; + long tid_; +}; +} // namespace Model +} // namespace Dms_enterprise +} // namespace AlibabaCloud +#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETETASKFLOWREQUEST_H_ diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/DeleteTaskFlowResult.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/DeleteTaskFlowResult.h new file mode 100644 index 000000000..e7d202578 --- /dev/null +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/model/DeleteTaskFlowResult.h @@ -0,0 +1,55 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETETASKFLOWRESULT_H_ +#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETETASKFLOWRESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dms_enterprise + { + namespace Model + { + class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT DeleteTaskFlowResult : public ServiceResult + { + public: + + + DeleteTaskFlowResult(); + explicit DeleteTaskFlowResult(const std::string &payload); + ~DeleteTaskFlowResult(); + std::string getErrorCode()const; + std::string getErrorMessage()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + std::string errorCode_; + std::string errorMessage_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_DELETETASKFLOWRESULT_H_ \ No newline at end of file diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetLhSpaceByNameRequest.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetLhSpaceByNameRequest.h new file mode 100644 index 000000000..7b05046e4 --- /dev/null +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetLhSpaceByNameRequest.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_DMS_ENTERPRISE_MODEL_GETLHSPACEBYNAMEREQUEST_H_ +#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETLHSPACEBYNAMEREQUEST_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud { +namespace Dms_enterprise { +namespace Model { +class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT GetLhSpaceByNameRequest : public RpcServiceRequest { +public: + GetLhSpaceByNameRequest(); + ~GetLhSpaceByNameRequest(); + std::string getSpaceName() const; + void setSpaceName(const std::string &spaceName); + long getTid() const; + void setTid(long tid); + +private: + std::string spaceName_; + long tid_; +}; +} // namespace Model +} // namespace Dms_enterprise +} // namespace AlibabaCloud +#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETLHSPACEBYNAMEREQUEST_H_ diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetLhSpaceByNameResult.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetLhSpaceByNameResult.h new file mode 100644 index 000000000..b5ce3a80e --- /dev/null +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetLhSpaceByNameResult.h @@ -0,0 +1,71 @@ +/* + * 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_DMS_ENTERPRISE_MODEL_GETLHSPACEBYNAMERESULT_H_ +#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETLHSPACEBYNAMERESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dms_enterprise + { + namespace Model + { + class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT GetLhSpaceByNameResult : public ServiceResult + { + public: + struct LakehouseSpace + { + std::string tenantId; + bool isDeleted; + std::string description; + std::string spaceName; + std::string creatorId; + int mode; + long id; + std::string spaceConfig; + std::string dbType; + int devDbId; + int prodDbId; + }; + + + GetLhSpaceByNameResult(); + explicit GetLhSpaceByNameResult(const std::string &payload); + ~GetLhSpaceByNameResult(); + LakehouseSpace getLakehouseSpace()const; + std::string getErrorCode()const; + std::string getErrorMessage()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + LakehouseSpace lakehouseSpace_; + std::string errorCode_; + std::string errorMessage_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETLHSPACEBYNAMERESULT_H_ \ No newline at end of file diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetTaskInstanceRelationRequest.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetTaskInstanceRelationRequest.h new file mode 100644 index 000000000..239e2233b --- /dev/null +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetTaskInstanceRelationRequest.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_DMS_ENTERPRISE_MODEL_GETTASKINSTANCERELATIONREQUEST_H_ +#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETTASKINSTANCERELATIONREQUEST_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud { +namespace Dms_enterprise { +namespace Model { +class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT GetTaskInstanceRelationRequest : public RpcServiceRequest { +public: + GetTaskInstanceRelationRequest(); + ~GetTaskInstanceRelationRequest(); + long getDagId() const; + void setDagId(long dagId); + long getTid() const; + void setTid(long tid); + long getDagInstanceId() const; + void setDagInstanceId(long dagInstanceId); + +private: + long dagId_; + long tid_; + long dagInstanceId_; +}; +} // namespace Model +} // namespace Dms_enterprise +} // namespace AlibabaCloud +#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETTASKINSTANCERELATIONREQUEST_H_ diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetTaskInstanceRelationResult.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetTaskInstanceRelationResult.h new file mode 100644 index 000000000..ccd14fde2 --- /dev/null +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/model/GetTaskInstanceRelationResult.h @@ -0,0 +1,69 @@ +/* + * 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_DMS_ENTERPRISE_MODEL_GETTASKINSTANCERELATIONRESULT_H_ +#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETTASKINSTANCERELATIONRESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dms_enterprise + { + namespace Model + { + class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT GetTaskInstanceRelationResult : public ServiceResult + { + public: + struct Node + { + int status; + std::string message; + std::string endTime; + std::string nodeName; + long executeTime; + int nodeType; + long nodeId; + long id; + std::string businessTime; + }; + + + GetTaskInstanceRelationResult(); + explicit GetTaskInstanceRelationResult(const std::string &payload); + ~GetTaskInstanceRelationResult(); + std::vector getNodeList()const; + std::string getErrorCode()const; + std::string getErrorMessage()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + std::vector nodeList_; + std::string errorCode_; + std::string errorMessage_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_GETTASKINSTANCERELATIONRESULT_H_ \ No newline at end of file diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/ListTaskFlowInstanceRequest.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/ListTaskFlowInstanceRequest.h new file mode 100644 index 000000000..7c5b36156 --- /dev/null +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/model/ListTaskFlowInstanceRequest.h @@ -0,0 +1,60 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWINSTANCEREQUEST_H_ +#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWINSTANCEREQUEST_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud { +namespace Dms_enterprise { +namespace Model { +class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT ListTaskFlowInstanceRequest : public RpcServiceRequest { +public: + ListTaskFlowInstanceRequest(); + ~ListTaskFlowInstanceRequest(); + int getTriggerType() const; + void setTriggerType(int triggerType); + long getDagId() const; + void setDagId(long dagId); + long getTid() const; + void setTid(long tid); + int getPageSize() const; + void setPageSize(int pageSize); + int getPageIndex() const; + void setPageIndex(int pageIndex); + std::string getStartTimeBegin() const; + void setStartTimeBegin(const std::string &startTimeBegin); + std::string getStartTimeEnd() const; + void setStartTimeEnd(const std::string &startTimeEnd); + +private: + int triggerType_; + long dagId_; + long tid_; + int pageSize_; + int pageIndex_; + std::string startTimeBegin_; + std::string startTimeEnd_; +}; +} // namespace Model +} // namespace Dms_enterprise +} // namespace AlibabaCloud +#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWINSTANCEREQUEST_H_ diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/ListTaskFlowInstanceResult.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/ListTaskFlowInstanceResult.h new file mode 100644 index 000000000..ab473ac00 --- /dev/null +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/model/ListTaskFlowInstanceResult.h @@ -0,0 +1,72 @@ +/* + * 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_DMS_ENTERPRISE_MODEL_LISTTASKFLOWINSTANCERESULT_H_ +#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWINSTANCERESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dms_enterprise + { + namespace Model + { + class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT ListTaskFlowInstanceResult : public ServiceResult + { + public: + struct DAGInstance + { + int status; + int triggerType; + long historyDagId; + std::string ownerName; + std::string endTime; + std::string message; + long id; + std::string dagName; + std::string businessTime; + std::string dagId; + }; + + + ListTaskFlowInstanceResult(); + explicit ListTaskFlowInstanceResult(const std::string &payload); + ~ListTaskFlowInstanceResult(); + int getTotalCount()const; + std::vector getDAGInstanceList()const; + std::string getErrorCode()const; + std::string getErrorMessage()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + int totalCount_; + std::vector dAGInstanceList_; + std::string errorCode_; + std::string errorMessage_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWINSTANCERESULT_H_ \ No newline at end of file diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/ListTaskFlowRequest.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/ListTaskFlowRequest.h new file mode 100644 index 000000000..3ca27f673 --- /dev/null +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/model/ListTaskFlowRequest.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_DMS_ENTERPRISE_MODEL_LISTTASKFLOWREQUEST_H_ +#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWREQUEST_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud { +namespace Dms_enterprise { +namespace Model { +class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT ListTaskFlowRequest : public RpcServiceRequest { +public: + ListTaskFlowRequest(); + ~ListTaskFlowRequest(); + long getDagId() const; + void setDagId(long dagId); + long getTid() const; + void setTid(long tid); + long getDagInstanceId() const; + void setDagInstanceId(long dagInstanceId); + +private: + long dagId_; + long tid_; + long dagInstanceId_; +}; +} // namespace Model +} // namespace Dms_enterprise +} // namespace AlibabaCloud +#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWREQUEST_H_ diff --git a/dms-enterprise/include/alibabacloud/dms-enterprise/model/ListTaskFlowResult.h b/dms-enterprise/include/alibabacloud/dms-enterprise/model/ListTaskFlowResult.h new file mode 100644 index 000000000..3f424d53d --- /dev/null +++ b/dms-enterprise/include/alibabacloud/dms-enterprise/model/ListTaskFlowResult.h @@ -0,0 +1,68 @@ +/* + * 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_DMS_ENTERPRISE_MODEL_LISTTASKFLOWRESULT_H_ +#define ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWRESULT_H_ + +#include +#include +#include +#include +#include + +namespace AlibabaCloud +{ + namespace Dms_enterprise + { + namespace Model + { + class ALIBABACLOUD_DMS_ENTERPRISE_EXPORT ListTaskFlowResult : public ServiceResult + { + public: + struct DAGInstance + { + int status; + int latestInstanceStatus; + std::string latestInstanceTime; + std::string creatorId; + long deployId; + long id; + std::string creatorNickName; + std::string dagOwnerNickName; + }; + + + ListTaskFlowResult(); + explicit ListTaskFlowResult(const std::string &payload); + ~ListTaskFlowResult(); + std::vector getTaskFlowList()const; + std::string getErrorCode()const; + std::string getErrorMessage()const; + bool getSuccess()const; + + protected: + void parse(const std::string &payload); + private: + std::vector taskFlowList_; + std::string errorCode_; + std::string errorMessage_; + bool success_; + + }; + } + } +} +#endif // !ALIBABACLOUD_DMS_ENTERPRISE_MODEL_LISTTASKFLOWRESULT_H_ \ No newline at end of file diff --git a/dms-enterprise/src/Dms-enterpriseClient.cc b/dms-enterprise/src/Dms-enterpriseClient.cc index b722580fb..0bfd6b72e 100644 --- a/dms-enterprise/src/Dms-enterpriseClient.cc +++ b/dms-enterprise/src/Dms-enterpriseClient.cc @@ -843,6 +843,42 @@ Dms_enterpriseClient::DeleteInstanceOutcomeCallable Dms_enterpriseClient::delete return task->get_future(); } +Dms_enterpriseClient::DeleteLakeHouseSpaceOutcome Dms_enterpriseClient::deleteLakeHouseSpace(const DeleteLakeHouseSpaceRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return DeleteLakeHouseSpaceOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return DeleteLakeHouseSpaceOutcome(DeleteLakeHouseSpaceResult(outcome.result())); + else + return DeleteLakeHouseSpaceOutcome(outcome.error()); +} + +void Dms_enterpriseClient::deleteLakeHouseSpaceAsync(const DeleteLakeHouseSpaceRequest& request, const DeleteLakeHouseSpaceAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, deleteLakeHouseSpace(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +Dms_enterpriseClient::DeleteLakeHouseSpaceOutcomeCallable Dms_enterpriseClient::deleteLakeHouseSpaceCallable(const DeleteLakeHouseSpaceRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->deleteLakeHouseSpace(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + Dms_enterpriseClient::DeleteLhMembersOutcome Dms_enterpriseClient::deleteLhMembers(const DeleteLhMembersRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -1023,6 +1059,42 @@ Dms_enterpriseClient::DeleteProxyAccessOutcomeCallable Dms_enterpriseClient::del return task->get_future(); } +Dms_enterpriseClient::DeleteTaskFlowOutcome Dms_enterpriseClient::deleteTaskFlow(const DeleteTaskFlowRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return DeleteTaskFlowOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return DeleteTaskFlowOutcome(DeleteTaskFlowResult(outcome.result())); + else + return DeleteTaskFlowOutcome(outcome.error()); +} + +void Dms_enterpriseClient::deleteTaskFlowAsync(const DeleteTaskFlowRequest& request, const DeleteTaskFlowAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, deleteTaskFlow(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +Dms_enterpriseClient::DeleteTaskFlowOutcomeCallable Dms_enterpriseClient::deleteTaskFlowCallable(const DeleteTaskFlowRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->deleteTaskFlow(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + Dms_enterpriseClient::DeleteUserOutcome Dms_enterpriseClient::deleteUser(const DeleteUserRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -1743,6 +1815,42 @@ Dms_enterpriseClient::GetInstanceOutcomeCallable Dms_enterpriseClient::getInstan return task->get_future(); } +Dms_enterpriseClient::GetLhSpaceByNameOutcome Dms_enterpriseClient::getLhSpaceByName(const GetLhSpaceByNameRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return GetLhSpaceByNameOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return GetLhSpaceByNameOutcome(GetLhSpaceByNameResult(outcome.result())); + else + return GetLhSpaceByNameOutcome(outcome.error()); +} + +void Dms_enterpriseClient::getLhSpaceByNameAsync(const GetLhSpaceByNameRequest& request, const GetLhSpaceByNameAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, getLhSpaceByName(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +Dms_enterpriseClient::GetLhSpaceByNameOutcomeCallable Dms_enterpriseClient::getLhSpaceByNameCallable(const GetLhSpaceByNameRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->getLhSpaceByName(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + Dms_enterpriseClient::GetLogicDatabaseOutcome Dms_enterpriseClient::getLogicDatabase(const GetLogicDatabaseRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -2355,6 +2463,42 @@ Dms_enterpriseClient::GetTableTopologyOutcomeCallable Dms_enterpriseClient::getT return task->get_future(); } +Dms_enterpriseClient::GetTaskInstanceRelationOutcome Dms_enterpriseClient::getTaskInstanceRelation(const GetTaskInstanceRelationRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return GetTaskInstanceRelationOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return GetTaskInstanceRelationOutcome(GetTaskInstanceRelationResult(outcome.result())); + else + return GetTaskInstanceRelationOutcome(outcome.error()); +} + +void Dms_enterpriseClient::getTaskInstanceRelationAsync(const GetTaskInstanceRelationRequest& request, const GetTaskInstanceRelationAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, getTaskInstanceRelation(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +Dms_enterpriseClient::GetTaskInstanceRelationOutcomeCallable Dms_enterpriseClient::getTaskInstanceRelationCallable(const GetTaskInstanceRelationRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->getTaskInstanceRelation(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + Dms_enterpriseClient::GetUserOutcome Dms_enterpriseClient::getUser(const GetUserRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); @@ -3471,6 +3615,78 @@ Dms_enterpriseClient::ListTablesOutcomeCallable Dms_enterpriseClient::listTables return task->get_future(); } +Dms_enterpriseClient::ListTaskFlowOutcome Dms_enterpriseClient::listTaskFlow(const ListTaskFlowRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return ListTaskFlowOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return ListTaskFlowOutcome(ListTaskFlowResult(outcome.result())); + else + return ListTaskFlowOutcome(outcome.error()); +} + +void Dms_enterpriseClient::listTaskFlowAsync(const ListTaskFlowRequest& request, const ListTaskFlowAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, listTaskFlow(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +Dms_enterpriseClient::ListTaskFlowOutcomeCallable Dms_enterpriseClient::listTaskFlowCallable(const ListTaskFlowRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->listTaskFlow(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + +Dms_enterpriseClient::ListTaskFlowInstanceOutcome Dms_enterpriseClient::listTaskFlowInstance(const ListTaskFlowInstanceRequest &request) const +{ + auto endpointOutcome = endpointProvider_->getEndpoint(); + if (!endpointOutcome.isSuccess()) + return ListTaskFlowInstanceOutcome(endpointOutcome.error()); + + auto outcome = makeRequest(endpointOutcome.result(), request); + + if (outcome.isSuccess()) + return ListTaskFlowInstanceOutcome(ListTaskFlowInstanceResult(outcome.result())); + else + return ListTaskFlowInstanceOutcome(outcome.error()); +} + +void Dms_enterpriseClient::listTaskFlowInstanceAsync(const ListTaskFlowInstanceRequest& request, const ListTaskFlowInstanceAsyncHandler& handler, const std::shared_ptr& context) const +{ + auto fn = [this, request, handler, context]() + { + handler(this, request, listTaskFlowInstance(request), context); + }; + + asyncExecute(new Runnable(fn)); +} + +Dms_enterpriseClient::ListTaskFlowInstanceOutcomeCallable Dms_enterpriseClient::listTaskFlowInstanceCallable(const ListTaskFlowInstanceRequest &request) const +{ + auto task = std::make_shared>( + [this, request]() + { + return this->listTaskFlowInstance(request); + }); + + asyncExecute(new Runnable([task]() { (*task)(); })); + return task->get_future(); +} + Dms_enterpriseClient::ListUserPermissionsOutcome Dms_enterpriseClient::listUserPermissions(const ListUserPermissionsRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); diff --git a/dms-enterprise/src/model/CreateLakeHouseSpaceRequest.cc b/dms-enterprise/src/model/CreateLakeHouseSpaceRequest.cc index 300ea507e..df8b3bf7d 100644 --- a/dms-enterprise/src/model/CreateLakeHouseSpaceRequest.cc +++ b/dms-enterprise/src/model/CreateLakeHouseSpaceRequest.cc @@ -43,15 +43,6 @@ void CreateLakeHouseSpaceRequest::setDescription(const std::string &description) setParameter(std::string("Description"), description); } -long CreateLakeHouseSpaceRequest::getUserId() const { - return userId_; -} - -void CreateLakeHouseSpaceRequest::setUserId(long userId) { - userId_ = userId; - setParameter(std::string("UserId"), std::to_string(userId)); -} - long CreateLakeHouseSpaceRequest::getTid() const { return tid_; } diff --git a/dms-enterprise/src/model/DeleteLakeHouseSpaceRequest.cc b/dms-enterprise/src/model/DeleteLakeHouseSpaceRequest.cc new file mode 100644 index 000000000..223955dd3 --- /dev/null +++ b/dms-enterprise/src/model/DeleteLakeHouseSpaceRequest.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 + +using AlibabaCloud::Dms_enterprise::Model::DeleteLakeHouseSpaceRequest; + +DeleteLakeHouseSpaceRequest::DeleteLakeHouseSpaceRequest() + : RpcServiceRequest("dms-enterprise", "2018-11-01", "DeleteLakeHouseSpace") { + setMethod(HttpRequest::Method::Post); +} + +DeleteLakeHouseSpaceRequest::~DeleteLakeHouseSpaceRequest() {} + +long DeleteLakeHouseSpaceRequest::getSpaceId() const { + return spaceId_; +} + +void DeleteLakeHouseSpaceRequest::setSpaceId(long spaceId) { + spaceId_ = spaceId; + setParameter(std::string("SpaceId"), std::to_string(spaceId)); +} + +long DeleteLakeHouseSpaceRequest::getTid() const { + return tid_; +} + +void DeleteLakeHouseSpaceRequest::setTid(long tid) { + tid_ = tid; + setParameter(std::string("Tid"), std::to_string(tid)); +} + diff --git a/dms-enterprise/src/model/DeleteLakeHouseSpaceResult.cc b/dms-enterprise/src/model/DeleteLakeHouseSpaceResult.cc new file mode 100644 index 000000000..bd90a6d93 --- /dev/null +++ b/dms-enterprise/src/model/DeleteLakeHouseSpaceResult.cc @@ -0,0 +1,65 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include +#include + +using namespace AlibabaCloud::Dms_enterprise; +using namespace AlibabaCloud::Dms_enterprise::Model; + +DeleteLakeHouseSpaceResult::DeleteLakeHouseSpaceResult() : + ServiceResult() +{} + +DeleteLakeHouseSpaceResult::DeleteLakeHouseSpaceResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +DeleteLakeHouseSpaceResult::~DeleteLakeHouseSpaceResult() +{} + +void DeleteLakeHouseSpaceResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + if(!value["ErrorCode"].isNull()) + errorCode_ = value["ErrorCode"].asString(); + if(!value["ErrorMessage"].isNull()) + errorMessage_ = value["ErrorMessage"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + +} + +std::string DeleteLakeHouseSpaceResult::getErrorCode()const +{ + return errorCode_; +} + +std::string DeleteLakeHouseSpaceResult::getErrorMessage()const +{ + return errorMessage_; +} + +bool DeleteLakeHouseSpaceResult::getSuccess()const +{ + return success_; +} + diff --git a/dms-enterprise/src/model/DeleteTaskFlowRequest.cc b/dms-enterprise/src/model/DeleteTaskFlowRequest.cc new file mode 100644 index 000000000..bbc9e1e80 --- /dev/null +++ b/dms-enterprise/src/model/DeleteTaskFlowRequest.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 + +using AlibabaCloud::Dms_enterprise::Model::DeleteTaskFlowRequest; + +DeleteTaskFlowRequest::DeleteTaskFlowRequest() + : RpcServiceRequest("dms-enterprise", "2018-11-01", "DeleteTaskFlow") { + setMethod(HttpRequest::Method::Post); +} + +DeleteTaskFlowRequest::~DeleteTaskFlowRequest() {} + +long DeleteTaskFlowRequest::getDagId() const { + return dagId_; +} + +void DeleteTaskFlowRequest::setDagId(long dagId) { + dagId_ = dagId; + setParameter(std::string("DagId"), std::to_string(dagId)); +} + +long DeleteTaskFlowRequest::getTid() const { + return tid_; +} + +void DeleteTaskFlowRequest::setTid(long tid) { + tid_ = tid; + setParameter(std::string("Tid"), std::to_string(tid)); +} + diff --git a/dms-enterprise/src/model/DeleteTaskFlowResult.cc b/dms-enterprise/src/model/DeleteTaskFlowResult.cc new file mode 100644 index 000000000..4bd8764f3 --- /dev/null +++ b/dms-enterprise/src/model/DeleteTaskFlowResult.cc @@ -0,0 +1,65 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include +#include + +using namespace AlibabaCloud::Dms_enterprise; +using namespace AlibabaCloud::Dms_enterprise::Model; + +DeleteTaskFlowResult::DeleteTaskFlowResult() : + ServiceResult() +{} + +DeleteTaskFlowResult::DeleteTaskFlowResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +DeleteTaskFlowResult::~DeleteTaskFlowResult() +{} + +void DeleteTaskFlowResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + if(!value["ErrorCode"].isNull()) + errorCode_ = value["ErrorCode"].asString(); + if(!value["ErrorMessage"].isNull()) + errorMessage_ = value["ErrorMessage"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + +} + +std::string DeleteTaskFlowResult::getErrorCode()const +{ + return errorCode_; +} + +std::string DeleteTaskFlowResult::getErrorMessage()const +{ + return errorMessage_; +} + +bool DeleteTaskFlowResult::getSuccess()const +{ + return success_; +} + diff --git a/dms-enterprise/src/model/GetLhSpaceByNameRequest.cc b/dms-enterprise/src/model/GetLhSpaceByNameRequest.cc new file mode 100644 index 000000000..aa412810b --- /dev/null +++ b/dms-enterprise/src/model/GetLhSpaceByNameRequest.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 + +using AlibabaCloud::Dms_enterprise::Model::GetLhSpaceByNameRequest; + +GetLhSpaceByNameRequest::GetLhSpaceByNameRequest() + : RpcServiceRequest("dms-enterprise", "2018-11-01", "GetLhSpaceByName") { + setMethod(HttpRequest::Method::Post); +} + +GetLhSpaceByNameRequest::~GetLhSpaceByNameRequest() {} + +std::string GetLhSpaceByNameRequest::getSpaceName() const { + return spaceName_; +} + +void GetLhSpaceByNameRequest::setSpaceName(const std::string &spaceName) { + spaceName_ = spaceName; + setParameter(std::string("SpaceName"), spaceName); +} + +long GetLhSpaceByNameRequest::getTid() const { + return tid_; +} + +void GetLhSpaceByNameRequest::setTid(long tid) { + tid_ = tid; + setParameter(std::string("Tid"), std::to_string(tid)); +} + diff --git a/dms-enterprise/src/model/GetLhSpaceByNameResult.cc b/dms-enterprise/src/model/GetLhSpaceByNameResult.cc new file mode 100644 index 000000000..03aa7d35e --- /dev/null +++ b/dms-enterprise/src/model/GetLhSpaceByNameResult.cc @@ -0,0 +1,93 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include +#include + +using namespace AlibabaCloud::Dms_enterprise; +using namespace AlibabaCloud::Dms_enterprise::Model; + +GetLhSpaceByNameResult::GetLhSpaceByNameResult() : + ServiceResult() +{} + +GetLhSpaceByNameResult::GetLhSpaceByNameResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +GetLhSpaceByNameResult::~GetLhSpaceByNameResult() +{} + +void GetLhSpaceByNameResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + auto lakehouseSpaceNode = value["LakehouseSpace"]; + if(!lakehouseSpaceNode["Id"].isNull()) + lakehouseSpace_.id = std::stol(lakehouseSpaceNode["Id"].asString()); + if(!lakehouseSpaceNode["SpaceName"].isNull()) + lakehouseSpace_.spaceName = lakehouseSpaceNode["SpaceName"].asString(); + if(!lakehouseSpaceNode["CreatorId"].isNull()) + lakehouseSpace_.creatorId = lakehouseSpaceNode["CreatorId"].asString(); + if(!lakehouseSpaceNode["TenantId"].isNull()) + lakehouseSpace_.tenantId = lakehouseSpaceNode["TenantId"].asString(); + if(!lakehouseSpaceNode["Description"].isNull()) + lakehouseSpace_.description = lakehouseSpaceNode["Description"].asString(); + if(!lakehouseSpaceNode["Mode"].isNull()) + lakehouseSpace_.mode = std::stoi(lakehouseSpaceNode["Mode"].asString()); + if(!lakehouseSpaceNode["DbType"].isNull()) + lakehouseSpace_.dbType = lakehouseSpaceNode["DbType"].asString(); + if(!lakehouseSpaceNode["SpaceConfig"].isNull()) + lakehouseSpace_.spaceConfig = lakehouseSpaceNode["SpaceConfig"].asString(); + if(!lakehouseSpaceNode["DevDbId"].isNull()) + lakehouseSpace_.devDbId = std::stoi(lakehouseSpaceNode["DevDbId"].asString()); + if(!lakehouseSpaceNode["ProdDbId"].isNull()) + lakehouseSpace_.prodDbId = std::stoi(lakehouseSpaceNode["ProdDbId"].asString()); + if(!lakehouseSpaceNode["IsDeleted"].isNull()) + lakehouseSpace_.isDeleted = lakehouseSpaceNode["IsDeleted"].asString() == "true"; + if(!value["ErrorCode"].isNull()) + errorCode_ = value["ErrorCode"].asString(); + if(!value["ErrorMessage"].isNull()) + errorMessage_ = value["ErrorMessage"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + +} + +GetLhSpaceByNameResult::LakehouseSpace GetLhSpaceByNameResult::getLakehouseSpace()const +{ + return lakehouseSpace_; +} + +std::string GetLhSpaceByNameResult::getErrorCode()const +{ + return errorCode_; +} + +std::string GetLhSpaceByNameResult::getErrorMessage()const +{ + return errorMessage_; +} + +bool GetLhSpaceByNameResult::getSuccess()const +{ + return success_; +} + diff --git a/dms-enterprise/src/model/GetTaskInstanceRelationRequest.cc b/dms-enterprise/src/model/GetTaskInstanceRelationRequest.cc new file mode 100644 index 000000000..909fc6ae3 --- /dev/null +++ b/dms-enterprise/src/model/GetTaskInstanceRelationRequest.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 + +using AlibabaCloud::Dms_enterprise::Model::GetTaskInstanceRelationRequest; + +GetTaskInstanceRelationRequest::GetTaskInstanceRelationRequest() + : RpcServiceRequest("dms-enterprise", "2018-11-01", "GetTaskInstanceRelation") { + setMethod(HttpRequest::Method::Post); +} + +GetTaskInstanceRelationRequest::~GetTaskInstanceRelationRequest() {} + +long GetTaskInstanceRelationRequest::getDagId() const { + return dagId_; +} + +void GetTaskInstanceRelationRequest::setDagId(long dagId) { + dagId_ = dagId; + setParameter(std::string("DagId"), std::to_string(dagId)); +} + +long GetTaskInstanceRelationRequest::getTid() const { + return tid_; +} + +void GetTaskInstanceRelationRequest::setTid(long tid) { + tid_ = tid; + setParameter(std::string("Tid"), std::to_string(tid)); +} + +long GetTaskInstanceRelationRequest::getDagInstanceId() const { + return dagInstanceId_; +} + +void GetTaskInstanceRelationRequest::setDagInstanceId(long dagInstanceId) { + dagInstanceId_ = dagInstanceId; + setParameter(std::string("DagInstanceId"), std::to_string(dagInstanceId)); +} + diff --git a/dms-enterprise/src/model/GetTaskInstanceRelationResult.cc b/dms-enterprise/src/model/GetTaskInstanceRelationResult.cc new file mode 100644 index 000000000..03ab87386 --- /dev/null +++ b/dms-enterprise/src/model/GetTaskInstanceRelationResult.cc @@ -0,0 +1,94 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include +#include + +using namespace AlibabaCloud::Dms_enterprise; +using namespace AlibabaCloud::Dms_enterprise::Model; + +GetTaskInstanceRelationResult::GetTaskInstanceRelationResult() : + ServiceResult() +{} + +GetTaskInstanceRelationResult::GetTaskInstanceRelationResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +GetTaskInstanceRelationResult::~GetTaskInstanceRelationResult() +{} + +void GetTaskInstanceRelationResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + auto allNodeListNode = value["NodeList"]["Node"]; + for (auto valueNodeListNode : allNodeListNode) + { + Node nodeListObject; + if(!valueNodeListNode["Id"].isNull()) + nodeListObject.id = std::stol(valueNodeListNode["Id"].asString()); + if(!valueNodeListNode["NodeId"].isNull()) + nodeListObject.nodeId = std::stol(valueNodeListNode["NodeId"].asString()); + if(!valueNodeListNode["NodeName"].isNull()) + nodeListObject.nodeName = valueNodeListNode["NodeName"].asString(); + if(!valueNodeListNode["NodeType"].isNull()) + nodeListObject.nodeType = std::stoi(valueNodeListNode["NodeType"].asString()); + if(!valueNodeListNode["BusinessTime"].isNull()) + nodeListObject.businessTime = valueNodeListNode["BusinessTime"].asString(); + if(!valueNodeListNode["Status"].isNull()) + nodeListObject.status = std::stoi(valueNodeListNode["Status"].asString()); + if(!valueNodeListNode["Message"].isNull()) + nodeListObject.message = valueNodeListNode["Message"].asString(); + if(!valueNodeListNode["ExecuteTime"].isNull()) + nodeListObject.executeTime = std::stol(valueNodeListNode["ExecuteTime"].asString()); + if(!valueNodeListNode["EndTime"].isNull()) + nodeListObject.endTime = valueNodeListNode["EndTime"].asString(); + nodeList_.push_back(nodeListObject); + } + if(!value["ErrorCode"].isNull()) + errorCode_ = value["ErrorCode"].asString(); + if(!value["ErrorMessage"].isNull()) + errorMessage_ = value["ErrorMessage"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + +} + +std::vector GetTaskInstanceRelationResult::getNodeList()const +{ + return nodeList_; +} + +std::string GetTaskInstanceRelationResult::getErrorCode()const +{ + return errorCode_; +} + +std::string GetTaskInstanceRelationResult::getErrorMessage()const +{ + return errorMessage_; +} + +bool GetTaskInstanceRelationResult::getSuccess()const +{ + return success_; +} + diff --git a/dms-enterprise/src/model/ListTaskFlowInstanceRequest.cc b/dms-enterprise/src/model/ListTaskFlowInstanceRequest.cc new file mode 100644 index 000000000..b1c7f283f --- /dev/null +++ b/dms-enterprise/src/model/ListTaskFlowInstanceRequest.cc @@ -0,0 +1,90 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +using AlibabaCloud::Dms_enterprise::Model::ListTaskFlowInstanceRequest; + +ListTaskFlowInstanceRequest::ListTaskFlowInstanceRequest() + : RpcServiceRequest("dms-enterprise", "2018-11-01", "ListTaskFlowInstance") { + setMethod(HttpRequest::Method::Post); +} + +ListTaskFlowInstanceRequest::~ListTaskFlowInstanceRequest() {} + +int ListTaskFlowInstanceRequest::getTriggerType() const { + return triggerType_; +} + +void ListTaskFlowInstanceRequest::setTriggerType(int triggerType) { + triggerType_ = triggerType; + setParameter(std::string("TriggerType"), std::to_string(triggerType)); +} + +long ListTaskFlowInstanceRequest::getDagId() const { + return dagId_; +} + +void ListTaskFlowInstanceRequest::setDagId(long dagId) { + dagId_ = dagId; + setParameter(std::string("DagId"), std::to_string(dagId)); +} + +long ListTaskFlowInstanceRequest::getTid() const { + return tid_; +} + +void ListTaskFlowInstanceRequest::setTid(long tid) { + tid_ = tid; + setParameter(std::string("Tid"), std::to_string(tid)); +} + +int ListTaskFlowInstanceRequest::getPageSize() const { + return pageSize_; +} + +void ListTaskFlowInstanceRequest::setPageSize(int pageSize) { + pageSize_ = pageSize; + setParameter(std::string("PageSize"), std::to_string(pageSize)); +} + +int ListTaskFlowInstanceRequest::getPageIndex() const { + return pageIndex_; +} + +void ListTaskFlowInstanceRequest::setPageIndex(int pageIndex) { + pageIndex_ = pageIndex; + setParameter(std::string("PageIndex"), std::to_string(pageIndex)); +} + +std::string ListTaskFlowInstanceRequest::getStartTimeBegin() const { + return startTimeBegin_; +} + +void ListTaskFlowInstanceRequest::setStartTimeBegin(const std::string &startTimeBegin) { + startTimeBegin_ = startTimeBegin; + setParameter(std::string("StartTimeBegin"), startTimeBegin); +} + +std::string ListTaskFlowInstanceRequest::getStartTimeEnd() const { + return startTimeEnd_; +} + +void ListTaskFlowInstanceRequest::setStartTimeEnd(const std::string &startTimeEnd) { + startTimeEnd_ = startTimeEnd; + setParameter(std::string("StartTimeEnd"), startTimeEnd); +} + diff --git a/dms-enterprise/src/model/ListTaskFlowInstanceResult.cc b/dms-enterprise/src/model/ListTaskFlowInstanceResult.cc new file mode 100644 index 000000000..bd90a788d --- /dev/null +++ b/dms-enterprise/src/model/ListTaskFlowInstanceResult.cc @@ -0,0 +1,103 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include +#include + +using namespace AlibabaCloud::Dms_enterprise; +using namespace AlibabaCloud::Dms_enterprise::Model; + +ListTaskFlowInstanceResult::ListTaskFlowInstanceResult() : + ServiceResult() +{} + +ListTaskFlowInstanceResult::ListTaskFlowInstanceResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +ListTaskFlowInstanceResult::~ListTaskFlowInstanceResult() +{} + +void ListTaskFlowInstanceResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + auto allDAGInstanceListNode = value["DAGInstanceList"]["DAGInstance"]; + for (auto valueDAGInstanceListDAGInstance : allDAGInstanceListNode) + { + DAGInstance dAGInstanceListObject; + if(!valueDAGInstanceListDAGInstance["Id"].isNull()) + dAGInstanceListObject.id = std::stol(valueDAGInstanceListDAGInstance["Id"].asString()); + if(!valueDAGInstanceListDAGInstance["BusinessTime"].isNull()) + dAGInstanceListObject.businessTime = valueDAGInstanceListDAGInstance["BusinessTime"].asString(); + if(!valueDAGInstanceListDAGInstance["EndTime"].isNull()) + dAGInstanceListObject.endTime = valueDAGInstanceListDAGInstance["EndTime"].asString(); + if(!valueDAGInstanceListDAGInstance["DagId"].isNull()) + dAGInstanceListObject.dagId = valueDAGInstanceListDAGInstance["DagId"].asString(); + if(!valueDAGInstanceListDAGInstance["TriggerType"].isNull()) + dAGInstanceListObject.triggerType = std::stoi(valueDAGInstanceListDAGInstance["TriggerType"].asString()); + if(!valueDAGInstanceListDAGInstance["Status"].isNull()) + dAGInstanceListObject.status = std::stoi(valueDAGInstanceListDAGInstance["Status"].asString()); + if(!valueDAGInstanceListDAGInstance["Message"].isNull()) + dAGInstanceListObject.message = valueDAGInstanceListDAGInstance["Message"].asString(); + if(!valueDAGInstanceListDAGInstance["HistoryDagId"].isNull()) + dAGInstanceListObject.historyDagId = std::stol(valueDAGInstanceListDAGInstance["HistoryDagId"].asString()); + if(!valueDAGInstanceListDAGInstance["DagName"].isNull()) + dAGInstanceListObject.dagName = valueDAGInstanceListDAGInstance["DagName"].asString(); + if(!valueDAGInstanceListDAGInstance["OwnerName"].isNull()) + dAGInstanceListObject.ownerName = valueDAGInstanceListDAGInstance["OwnerName"].asString(); + dAGInstanceList_.push_back(dAGInstanceListObject); + } + if(!value["ErrorCode"].isNull()) + errorCode_ = value["ErrorCode"].asString(); + if(!value["ErrorMessage"].isNull()) + errorMessage_ = value["ErrorMessage"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + if(!value["TotalCount"].isNull()) + totalCount_ = std::stoi(value["TotalCount"].asString()); + +} + +int ListTaskFlowInstanceResult::getTotalCount()const +{ + return totalCount_; +} + +std::vector ListTaskFlowInstanceResult::getDAGInstanceList()const +{ + return dAGInstanceList_; +} + +std::string ListTaskFlowInstanceResult::getErrorCode()const +{ + return errorCode_; +} + +std::string ListTaskFlowInstanceResult::getErrorMessage()const +{ + return errorMessage_; +} + +bool ListTaskFlowInstanceResult::getSuccess()const +{ + return success_; +} + diff --git a/dms-enterprise/src/model/ListTaskFlowRequest.cc b/dms-enterprise/src/model/ListTaskFlowRequest.cc new file mode 100644 index 000000000..0788d1b72 --- /dev/null +++ b/dms-enterprise/src/model/ListTaskFlowRequest.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 + +using AlibabaCloud::Dms_enterprise::Model::ListTaskFlowRequest; + +ListTaskFlowRequest::ListTaskFlowRequest() + : RpcServiceRequest("dms-enterprise", "2018-11-01", "ListTaskFlow") { + setMethod(HttpRequest::Method::Post); +} + +ListTaskFlowRequest::~ListTaskFlowRequest() {} + +long ListTaskFlowRequest::getDagId() const { + return dagId_; +} + +void ListTaskFlowRequest::setDagId(long dagId) { + dagId_ = dagId; + setParameter(std::string("DagId"), std::to_string(dagId)); +} + +long ListTaskFlowRequest::getTid() const { + return tid_; +} + +void ListTaskFlowRequest::setTid(long tid) { + tid_ = tid; + setParameter(std::string("Tid"), std::to_string(tid)); +} + +long ListTaskFlowRequest::getDagInstanceId() const { + return dagInstanceId_; +} + +void ListTaskFlowRequest::setDagInstanceId(long dagInstanceId) { + dagInstanceId_ = dagInstanceId; + setParameter(std::string("DagInstanceId"), std::to_string(dagInstanceId)); +} + diff --git a/dms-enterprise/src/model/ListTaskFlowResult.cc b/dms-enterprise/src/model/ListTaskFlowResult.cc new file mode 100644 index 000000000..dc17ec668 --- /dev/null +++ b/dms-enterprise/src/model/ListTaskFlowResult.cc @@ -0,0 +1,92 @@ +/* + * Copyright 2009-2017 Alibaba Cloud All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include +#include + +using namespace AlibabaCloud::Dms_enterprise; +using namespace AlibabaCloud::Dms_enterprise::Model; + +ListTaskFlowResult::ListTaskFlowResult() : + ServiceResult() +{} + +ListTaskFlowResult::ListTaskFlowResult(const std::string &payload) : + ServiceResult() +{ + parse(payload); +} + +ListTaskFlowResult::~ListTaskFlowResult() +{} + +void ListTaskFlowResult::parse(const std::string &payload) +{ + Json::Reader reader; + Json::Value value; + reader.parse(payload, value); + setRequestId(value["RequestId"].asString()); + auto allTaskFlowListNode = value["TaskFlowList"]["DAGInstance"]; + for (auto valueTaskFlowListDAGInstance : allTaskFlowListNode) + { + DAGInstance taskFlowListObject; + if(!valueTaskFlowListDAGInstance["Id"].isNull()) + taskFlowListObject.id = std::stol(valueTaskFlowListDAGInstance["Id"].asString()); + if(!valueTaskFlowListDAGInstance["CreatorId"].isNull()) + taskFlowListObject.creatorId = valueTaskFlowListDAGInstance["CreatorId"].asString(); + if(!valueTaskFlowListDAGInstance["CreatorNickName"].isNull()) + taskFlowListObject.creatorNickName = valueTaskFlowListDAGInstance["CreatorNickName"].asString(); + if(!valueTaskFlowListDAGInstance["DagOwnerNickName"].isNull()) + taskFlowListObject.dagOwnerNickName = valueTaskFlowListDAGInstance["DagOwnerNickName"].asString(); + if(!valueTaskFlowListDAGInstance["DeployId"].isNull()) + taskFlowListObject.deployId = std::stol(valueTaskFlowListDAGInstance["DeployId"].asString()); + if(!valueTaskFlowListDAGInstance["Status"].isNull()) + taskFlowListObject.status = std::stoi(valueTaskFlowListDAGInstance["Status"].asString()); + if(!valueTaskFlowListDAGInstance["LatestInstanceStatus"].isNull()) + taskFlowListObject.latestInstanceStatus = std::stoi(valueTaskFlowListDAGInstance["LatestInstanceStatus"].asString()); + if(!valueTaskFlowListDAGInstance["LatestInstanceTime"].isNull()) + taskFlowListObject.latestInstanceTime = valueTaskFlowListDAGInstance["LatestInstanceTime"].asString(); + taskFlowList_.push_back(taskFlowListObject); + } + if(!value["ErrorCode"].isNull()) + errorCode_ = value["ErrorCode"].asString(); + if(!value["ErrorMessage"].isNull()) + errorMessage_ = value["ErrorMessage"].asString(); + if(!value["Success"].isNull()) + success_ = value["Success"].asString() == "true"; + +} + +std::vector ListTaskFlowResult::getTaskFlowList()const +{ + return taskFlowList_; +} + +std::string ListTaskFlowResult::getErrorCode()const +{ + return errorCode_; +} + +std::string ListTaskFlowResult::getErrorMessage()const +{ + return errorMessage_; +} + +bool ListTaskFlowResult::getSuccess()const +{ + return success_; +} +