Documentation ¶
Index ¶
- type DmsClient
- func (c *DmsClient) AddPersonalSql(request *dms.AddPersonalSqlRequest) (*dms.AddPersonalSqlResponse, error)
- func (c *DmsClient) AuthPrivilege(request *dms.AuthPrivilegeRequest) (*dms.AuthPrivilegeResponse, error)
- func (c *DmsClient) CheckInstance(request *dms.CheckInstanceRequest) (*dms.CheckInstanceResponse, error)
- func (c *DmsClient) ConsoleExplain(request *dms.ConsoleExplainRequest) (*dms.ConsoleExplainResponse, error)
- func (c *DmsClient) ConsoleGeneralData(request *dms.ConsoleGeneralDataRequest) (*dms.ConsoleGeneralDataResponse, error)
- func (c *DmsClient) ConsoleSql(request *dms.ConsoleSqlRequest) (*dms.ConsoleSqlResponse, error)
- func (c *DmsClient) CreateDataFlow(request *dms.CreateDataFlowRequest) (*dms.CreateDataFlowResponse, error)
- func (c *DmsClient) CreateExportFlow(request *dms.CreateExportFlowRequest) (*dms.CreateExportFlowResponse, error)
- func (c *DmsClient) CreateImportFileTask(request *dms.CreateImportFileTaskRequest) (*dms.CreateImportFileTaskResponse, error)
- func (c *DmsClient) CreateOnlineSqlTask(request *dms.CreateOnlineSqlTaskRequest) (*dms.CreateOnlineSqlTaskResponse, error)
- func (c *DmsClient) CreateStructureFlow(request *dms.CreateStructureFlowRequest) (*dms.CreateStructureFlowResponse, error)
- func (c *DmsClient) CreateTableBatch(request *dms.CreateTableBatchRequest) (*dms.CreateTableBatchResponse, error)
- func (c *DmsClient) DatabaseList(request *dms.DatabaseListRequest) (*dms.DatabaseListResponse, error)
- func (c *DmsClient) DeletePersonalSql(request *dms.DeletePersonalSqlRequest) (*dms.DeletePersonalSqlResponse, error)
- func (c *DmsClient) DeleteUser(request *dms.DeleteUserRequest) (*dms.DeleteUserResponse, error)
- func (c *DmsClient) DisableLogger()
- func (c *DmsClient) DmsConsoleCheck(request *dms.DmsConsoleCheckRequest) (*dms.DmsConsoleCheckResponse, error)
- func (c *DmsClient) EnableUser(request *dms.EnableUserRequest) (*dms.EnableUserResponse, error)
- func (c *DmsClient) EventInfo(request *dms.EventInfoRequest) (*dms.EventInfoResponse, error)
- func (c *DmsClient) ExeProgram(request *dms.ExeProgramRequest) (*dms.ExeProgramResponse, error)
- func (c *DmsClient) FormatSql(request *dms.FormatSqlRequest) (*dms.FormatSqlResponse, error)
- func (c *DmsClient) FunctionInfo(request *dms.FunctionInfoRequest) (*dms.FunctionInfoResponse, error)
- func (c *DmsClient) FunctionInvoke(request *dms.FunctionInvokeRequest) (*dms.FunctionInvokeResponse, error)
- func (c *DmsClient) FunctionList(request *dms.FunctionListRequest) (*dms.FunctionListResponse, error)
- func (c *DmsClient) GeneralAlterEvent(request *dms.GeneralAlterEventRequest) (*dms.GeneralAlterEventResponse, error)
- func (c *DmsClient) GeneralAlterFunction(request *dms.GeneralAlterFunctionRequest) (*dms.GeneralAlterFunctionResponse, error)
- func (c *DmsClient) GeneralAlterProcedure(request *dms.GeneralAlterProcedureRequest) (*dms.GeneralAlterProcedureResponse, error)
- func (c *DmsClient) GeneralAlterTableSql(request *dms.GeneralAlterTableSqlRequest) (*dms.GeneralAlterTableSqlResponse, error)
- func (c *DmsClient) GeneralAlterTrigger(request *dms.GeneralAlterTriggerRequest) (*dms.GeneralAlterTriggerResponse, error)
- func (c *DmsClient) GeneralAlterView(request *dms.GeneralAlterViewRequest) (*dms.GeneralAlterViewResponse, error)
- func (c *DmsClient) GeneralCreateEvent(request *dms.GeneralCreateEventRequest) (*dms.GeneralCreateEventResponse, error)
- func (c *DmsClient) GeneralCreateFunction(request *dms.GeneralCreateFunctionRequest) (*dms.GeneralCreateFunctionResponse, error)
- func (c *DmsClient) GeneralCreateProcedure(request *dms.GeneralCreateProcedureRequest) (*dms.GeneralCreateProcedureResponse, error)
- func (c *DmsClient) GeneralCreateTableSql(request *dms.GeneralCreateTableSqlRequest) (*dms.GeneralCreateTableSqlResponse, error)
- func (c *DmsClient) GeneralCreateTrigger(request *dms.GeneralCreateTriggerRequest) (*dms.GeneralCreateTriggerResponse, error)
- func (c *DmsClient) GeneralCreateView(request *dms.GeneralCreateViewRequest) (*dms.GeneralCreateViewResponse, error)
- func (c *DmsClient) GeneralDropEvent(request *dms.GeneralDropEventRequest) (*dms.GeneralDropEventResponse, error)
- func (c *DmsClient) GeneralDropFunction(request *dms.GeneralDropFunctionRequest) (*dms.GeneralDropFunctionResponse, error)
- func (c *DmsClient) GeneralDropProcedure(request *dms.GeneralDropProcedureRequest) (*dms.GeneralDropProcedureResponse, error)
- func (c *DmsClient) GeneralDropTrigger(request *dms.GeneralDropTriggerRequest) (*dms.GeneralDropTriggerResponse, error)
- func (c *DmsClient) GeneralDropView(request *dms.GeneralDropViewRequest) (*dms.GeneralDropViewResponse, error)
- func (c *DmsClient) GetCreateTableBatchSql(request *dms.GetCreateTableBatchSqlRequest) (*dms.GetCreateTableBatchSqlResponse, error)
- func (c *DmsClient) GetDmsDomain(request *dms.GetDmsDomainRequest) (*dms.GetDmsDomainResponse, error)
- func (c *DmsClient) GetDmsDomains(request *dms.GetDmsDomainsRequest) (*dms.GetDmsDomainsResponse, error)
- func (c *DmsClient) GetUserInfo(request *dms.GetUserInfoRequest) (*dms.GetUserInfoResponse, error)
- func (c *DmsClient) HistoryImportData(request *dms.HistoryImportDataRequest) (*dms.HistoryImportDataResponse, error)
- func (c *DmsClient) HistorySql(request *dms.HistorySqlRequest) (*dms.HistorySqlResponse, error)
- func (c *DmsClient) Login(request *dms.LoginRequest) (*dms.LoginResponse, error)
- func (c *DmsClient) Logout(request *dms.LogoutRequest) (*dms.LogoutResponse, error)
- func (c *DmsClient) ModifyPrivilegeExpireDate(request *dms.ModifyPrivilegeExpireDateRequest) (*dms.ModifyPrivilegeExpireDateResponse, error)
- func (c *DmsClient) OnlineProxySubTaskQuery(request *dms.OnlineProxySubTaskQueryRequest) (*dms.OnlineProxySubTaskQueryResponse, error)
- func (c *DmsClient) OnlineSqlTaskQuery(request *dms.OnlineSqlTaskQueryRequest) (*dms.OnlineSqlTaskQueryResponse, error)
- func (c *DmsClient) OnlineSubSqlTaskQuery(request *dms.OnlineSubSqlTaskQueryRequest) (*dms.OnlineSubSqlTaskQueryResponse, error)
- func (c *DmsClient) Open(request *dms.OpenRequest) (*dms.OpenResponse, error)
- func (c *DmsClient) OperationDetail(request *dms.OperationDetailRequest) (*dms.OperationDetailResponse, error)
- func (c *DmsClient) ProcedureInfo(request *dms.ProcedureInfoRequest) (*dms.ProcedureInfoResponse, error)
- func (c *DmsClient) ProcedureInvoke(request *dms.ProcedureInvokeRequest) (*dms.ProcedureInvokeResponse, error)
- func (c *DmsClient) ProcedureList(request *dms.ProcedureListRequest) (*dms.ProcedureListResponse, error)
- func (c *DmsClient) ProgramList(request *dms.ProgramListRequest) (*dms.ProgramListResponse, error)
- func (c *DmsClient) QueryInstance(request *dms.QueryInstanceRequest) (*dms.QueryInstanceResponse, error)
- func (c *DmsClient) QueryOperationLog(request *dms.QueryOperationLogRequest) (*dms.QueryOperationLogResponse, error)
- func (c *DmsClient) QueryOperationType(request *dms.QueryOperationTypeRequest) (*dms.QueryOperationTypeResponse, error)
- func (c *DmsClient) QueryPersonalSqls(request *dms.QueryPersonalSqlsRequest) (*dms.QueryPersonalSqlsResponse, error)
- func (c *DmsClient) QueryPrivilegeList(request *dms.QueryPrivilegeListRequest) (*dms.QueryPrivilegeListResponse, error)
- func (c *DmsClient) QueryPrivilegeSelfList(request *dms.QueryPrivilegeSelfListRequest) (*dms.QueryPrivilegeSelfListResponse, error)
- func (c *DmsClient) QueryTypeInstance(request *dms.QueryTypeInstanceRequest) (*dms.QueryTypeInstanceResponse, error)
- func (c *DmsClient) QueryUserList(request *dms.QueryUserListRequest) (*dms.QueryUserListResponse, error)
- func (c *DmsClient) QueryUserNotSync(request *dms.QueryUserNotSyncRequest) (*dms.QueryUserNotSyncResponse, error)
- func (c *DmsClient) ReleasePrivilege(request *dms.ReleasePrivilegeRequest) (*dms.ReleasePrivilegeResponse, error)
- func (c *DmsClient) RestartOnlineSqlTask(request *dms.RestartOnlineSqlTaskRequest) (*dms.RestartOnlineSqlTaskResponse, error)
- func (c *DmsClient) SetConfig(config *core.Config)
- func (c *DmsClient) SetLogger(logger core.Logger)
- func (c *DmsClient) SqlTableInfo(request *dms.SqlTableInfoRequest) (*dms.SqlTableInfoResponse, error)
- func (c *DmsClient) StartFlow(request *dms.StartFlowRequest) (*dms.StartFlowResponse, error)
- func (c *DmsClient) StartOnlineSqlTask(request *dms.StartOnlineSqlTaskRequest) (*dms.StartOnlineSqlTaskResponse, error)
- func (c *DmsClient) SuspendOnlineSqlTask(request *dms.SuspendOnlineSqlTaskRequest) (*dms.SuspendOnlineSqlTaskResponse, error)
- func (c *DmsClient) SyncSubUser(request *dms.SyncSubUserRequest) (*dms.SyncSubUserResponse, error)
- func (c *DmsClient) TableInfo(request *dms.TableInfoRequest) (*dms.TableInfoResponse, error)
- func (c *DmsClient) TableList(request *dms.TableListRequest) (*dms.TableListResponse, error)
- func (c *DmsClient) TriggerInfo(request *dms.TriggerInfoRequest) (*dms.TriggerInfoResponse, error)
- func (c *DmsClient) TriggerList(request *dms.TriggerListRequest) (*dms.TriggerListResponse, error)
- func (c *DmsClient) UpdatePersonalSql(request *dms.UpdatePersonalSqlRequest) (*dms.UpdatePersonalSqlResponse, error)
- func (c *DmsClient) UpdateUserInfo(request *dms.UpdateUserInfoRequest) (*dms.UpdateUserInfoResponse, error)
- func (c *DmsClient) UploadImportFileTask(request *dms.UploadImportFileTaskRequest) (*dms.UploadImportFileTaskResponse, error)
- func (c *DmsClient) ViewInfo(request *dms.ViewInfoRequest) (*dms.ViewInfoResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DmsClient ¶
type DmsClient struct {
core.JDCloudClient
}
func NewDmsClient ¶
func NewDmsClient(credential *core.Credential) *DmsClient
func (*DmsClient) AddPersonalSql ¶
func (c *DmsClient) AddPersonalSql(request *dms.AddPersonalSqlRequest) (*dms.AddPersonalSqlResponse, error)
收藏sql
func (*DmsClient) AuthPrivilege ¶ added in v1.59.0
func (c *DmsClient) AuthPrivilege(request *dms.AuthPrivilegeRequest) (*dms.AuthPrivilegeResponse, error)
实例授权
func (*DmsClient) CheckInstance ¶ added in v1.59.0
func (c *DmsClient) CheckInstance(request *dms.CheckInstanceRequest) (*dms.CheckInstanceResponse, error)
校验用户是否有实例权限
func (*DmsClient) ConsoleExplain ¶
func (c *DmsClient) ConsoleExplain(request *dms.ConsoleExplainRequest) (*dms.ConsoleExplainResponse, error)
执行计划,支持Mysql,Stardb
func (*DmsClient) ConsoleGeneralData ¶
func (c *DmsClient) ConsoleGeneralData(request *dms.ConsoleGeneralDataRequest) (*dms.ConsoleGeneralDataResponse, error)
生成数据,支持Mysql,Stardb
func (*DmsClient) ConsoleSql ¶
func (c *DmsClient) ConsoleSql(request *dms.ConsoleSqlRequest) (*dms.ConsoleSqlResponse, error)
执行sql语句,支持Mysql,Stardb,Tidb,ClickHouse
func (*DmsClient) CreateDataFlow ¶
func (c *DmsClient) CreateDataFlow(request *dms.CreateDataFlowRequest) (*dms.CreateDataFlowResponse, error)
创建数据变更工单,支持Stardb
func (*DmsClient) CreateExportFlow ¶
func (c *DmsClient) CreateExportFlow(request *dms.CreateExportFlowRequest) (*dms.CreateExportFlowResponse, error)
创建数据导出工单,支持Stardb
func (*DmsClient) CreateImportFileTask ¶
func (c *DmsClient) CreateImportFileTask(request *dms.CreateImportFileTaskRequest) (*dms.CreateImportFileTaskResponse, error)
创建导入文件任务,支持Stardb
func (*DmsClient) CreateOnlineSqlTask ¶ added in v1.59.0
func (c *DmsClient) CreateOnlineSqlTask(request *dms.CreateOnlineSqlTaskRequest) (*dms.CreateOnlineSqlTaskResponse, error)
创建Sql任务
func (*DmsClient) CreateStructureFlow ¶
func (c *DmsClient) CreateStructureFlow(request *dms.CreateStructureFlowRequest) (*dms.CreateStructureFlowResponse, error)
创建结构变更工单,支持Stardb
func (*DmsClient) CreateTableBatch ¶
func (c *DmsClient) CreateTableBatch(request *dms.CreateTableBatchRequest) (*dms.CreateTableBatchResponse, error)
批量建表,支持Stardb
func (*DmsClient) DatabaseList ¶
func (c *DmsClient) DatabaseList(request *dms.DatabaseListRequest) (*dms.DatabaseListResponse, error)
获取数据库实例的库列表,支持Mysql,Stardb,Tidb,ClickHouse
func (*DmsClient) DeletePersonalSql ¶
func (c *DmsClient) DeletePersonalSql(request *dms.DeletePersonalSqlRequest) (*dms.DeletePersonalSqlResponse, error)
删除收藏sql
func (*DmsClient) DeleteUser ¶ added in v1.59.0
func (c *DmsClient) DeleteUser(request *dms.DeleteUserRequest) (*dms.DeleteUserResponse, error)
删除用户
func (*DmsClient) DisableLogger ¶
func (c *DmsClient) DisableLogger()
func (*DmsClient) DmsConsoleCheck ¶ added in v1.59.0
func (c *DmsClient) DmsConsoleCheck(request *dms.DmsConsoleCheckRequest) (*dms.DmsConsoleCheckResponse, error)
校验当前的用户是否允许访问DMS控制台
func (*DmsClient) EnableUser ¶ added in v1.59.0
func (c *DmsClient) EnableUser(request *dms.EnableUserRequest) (*dms.EnableUserResponse, error)
启用/禁用用户
func (*DmsClient) EventInfo ¶ added in v1.58.0
func (c *DmsClient) EventInfo(request *dms.EventInfoRequest) (*dms.EventInfoResponse, error)
获取事件详情,支持Mysql
func (*DmsClient) ExeProgram ¶
func (c *DmsClient) ExeProgram(request *dms.ExeProgramRequest) (*dms.ExeProgramResponse, error)
执行编程对象sql,支持Mysql
func (*DmsClient) FormatSql ¶
func (c *DmsClient) FormatSql(request *dms.FormatSqlRequest) (*dms.FormatSqlResponse, error)
sql格式化,支持Mysql,Stardb
func (*DmsClient) FunctionInfo ¶ added in v1.58.0
func (c *DmsClient) FunctionInfo(request *dms.FunctionInfoRequest) (*dms.FunctionInfoResponse, error)
获取函数详情,支持Mysql
func (*DmsClient) FunctionInvoke ¶ added in v1.58.0
func (c *DmsClient) FunctionInvoke(request *dms.FunctionInvokeRequest) (*dms.FunctionInvokeResponse, error)
调用函数,支持Mysql
func (*DmsClient) FunctionList ¶ added in v1.58.0
func (c *DmsClient) FunctionList(request *dms.FunctionListRequest) (*dms.FunctionListResponse, error)
获取函数列表,支持Mysql
func (*DmsClient) GeneralAlterEvent ¶ added in v1.58.0
func (c *DmsClient) GeneralAlterEvent(request *dms.GeneralAlterEventRequest) (*dms.GeneralAlterEventResponse, error)
生成修改事件sql语句,支持Mysql
func (*DmsClient) GeneralAlterFunction ¶ added in v1.58.0
func (c *DmsClient) GeneralAlterFunction(request *dms.GeneralAlterFunctionRequest) (*dms.GeneralAlterFunctionResponse, error)
生成修改函数sql语句,支持Mysql
func (*DmsClient) GeneralAlterProcedure ¶ added in v1.58.0
func (c *DmsClient) GeneralAlterProcedure(request *dms.GeneralAlterProcedureRequest) (*dms.GeneralAlterProcedureResponse, error)
生成修改存储过程sql语句,支持Mysql
func (*DmsClient) GeneralAlterTableSql ¶
func (c *DmsClient) GeneralAlterTableSql(request *dms.GeneralAlterTableSqlRequest) (*dms.GeneralAlterTableSqlResponse, error)
生成修改表结构语句sql,支持Mysql,Stardb
func (*DmsClient) GeneralAlterTrigger ¶ added in v1.58.0
func (c *DmsClient) GeneralAlterTrigger(request *dms.GeneralAlterTriggerRequest) (*dms.GeneralAlterTriggerResponse, error)
生成修改触发器sql语句,支持Mysql
func (*DmsClient) GeneralAlterView ¶
func (c *DmsClient) GeneralAlterView(request *dms.GeneralAlterViewRequest) (*dms.GeneralAlterViewResponse, error)
生成修改视图sql语句,支持Mysql
func (*DmsClient) GeneralCreateEvent ¶ added in v1.58.0
func (c *DmsClient) GeneralCreateEvent(request *dms.GeneralCreateEventRequest) (*dms.GeneralCreateEventResponse, error)
生产创建事件SQL语句,支持Mysql
func (*DmsClient) GeneralCreateFunction ¶ added in v1.58.0
func (c *DmsClient) GeneralCreateFunction(request *dms.GeneralCreateFunctionRequest) (*dms.GeneralCreateFunctionResponse, error)
生产创建函数过程SQL语句,支持Mysql
func (*DmsClient) GeneralCreateProcedure ¶ added in v1.58.0
func (c *DmsClient) GeneralCreateProcedure(request *dms.GeneralCreateProcedureRequest) (*dms.GeneralCreateProcedureResponse, error)
生产创建存储过程SQL语句,支持Mysql
func (*DmsClient) GeneralCreateTableSql ¶
func (c *DmsClient) GeneralCreateTableSql(request *dms.GeneralCreateTableSqlRequest) (*dms.GeneralCreateTableSqlResponse, error)
生成建表语句sql,支持Mysql,Stardb,OpenGauss
func (*DmsClient) GeneralCreateTrigger ¶ added in v1.58.0
func (c *DmsClient) GeneralCreateTrigger(request *dms.GeneralCreateTriggerRequest) (*dms.GeneralCreateTriggerResponse, error)
生成创建触发器SQL语句,支持Mysql
func (*DmsClient) GeneralCreateView ¶
func (c *DmsClient) GeneralCreateView(request *dms.GeneralCreateViewRequest) (*dms.GeneralCreateViewResponse, error)
生产创建视图SQL语句,支持Mysql
func (*DmsClient) GeneralDropEvent ¶ added in v1.58.0
func (c *DmsClient) GeneralDropEvent(request *dms.GeneralDropEventRequest) (*dms.GeneralDropEventResponse, error)
生成删除事件sql语句,支持Mysql
func (*DmsClient) GeneralDropFunction ¶ added in v1.58.0
func (c *DmsClient) GeneralDropFunction(request *dms.GeneralDropFunctionRequest) (*dms.GeneralDropFunctionResponse, error)
生成删除函数sql语句,支持Mysql
func (*DmsClient) GeneralDropProcedure ¶ added in v1.58.0
func (c *DmsClient) GeneralDropProcedure(request *dms.GeneralDropProcedureRequest) (*dms.GeneralDropProcedureResponse, error)
生成删除存储过程sql语句,支持Mysql
func (*DmsClient) GeneralDropTrigger ¶ added in v1.58.0
func (c *DmsClient) GeneralDropTrigger(request *dms.GeneralDropTriggerRequest) (*dms.GeneralDropTriggerResponse, error)
生成删除触发器sql语句,支持Mysql
func (*DmsClient) GeneralDropView ¶
func (c *DmsClient) GeneralDropView(request *dms.GeneralDropViewRequest) (*dms.GeneralDropViewResponse, error)
生成删除视图sql语句,支持Mysql
func (*DmsClient) GetCreateTableBatchSql ¶
func (c *DmsClient) GetCreateTableBatchSql(request *dms.GetCreateTableBatchSqlRequest) (*dms.GetCreateTableBatchSqlResponse, error)
获取批量建表sql,仅供前端使用,支持Stardb,OpenGauss
func (*DmsClient) GetDmsDomain ¶
func (c *DmsClient) GetDmsDomain(request *dms.GetDmsDomainRequest) (*dms.GetDmsDomainResponse, error)
获取Dms域名,仅供前端使用
func (*DmsClient) GetDmsDomains ¶ added in v1.59.0
func (c *DmsClient) GetDmsDomains(request *dms.GetDmsDomainsRequest) (*dms.GetDmsDomainsResponse, error)
获取Dms域名,仅供前端使用
func (*DmsClient) GetUserInfo ¶ added in v1.59.0
func (c *DmsClient) GetUserInfo(request *dms.GetUserInfoRequest) (*dms.GetUserInfoResponse, error)
获取用户信息
func (*DmsClient) HistoryImportData ¶
func (c *DmsClient) HistoryImportData(request *dms.HistoryImportDataRequest) (*dms.HistoryImportDataResponse, error)
获取当前实例用户查询导入数据sql历史
func (*DmsClient) HistorySql ¶
func (c *DmsClient) HistorySql(request *dms.HistorySqlRequest) (*dms.HistorySqlResponse, error)
获取当前实例用户查询sql历史
func (*DmsClient) Login ¶
func (c *DmsClient) Login(request *dms.LoginRequest) (*dms.LoginResponse, error)
rds,drds登录实例
func (*DmsClient) Logout ¶
func (c *DmsClient) Logout(request *dms.LogoutRequest) (*dms.LogoutResponse, error)
退出登录
func (*DmsClient) ModifyPrivilegeExpireDate ¶ added in v1.59.0
func (c *DmsClient) ModifyPrivilegeExpireDate(request *dms.ModifyPrivilegeExpireDateRequest) (*dms.ModifyPrivilegeExpireDateResponse, error)
修改权限到期时间
func (*DmsClient) OnlineProxySubTaskQuery ¶ added in v1.59.0
func (c *DmsClient) OnlineProxySubTaskQuery(request *dms.OnlineProxySubTaskQueryRequest) (*dms.OnlineProxySubTaskQueryResponse, error)
查询sql子任务状态
func (*DmsClient) OnlineSqlTaskQuery ¶ added in v1.59.0
func (c *DmsClient) OnlineSqlTaskQuery(request *dms.OnlineSqlTaskQueryRequest) (*dms.OnlineSqlTaskQueryResponse, error)
查询任务状态
func (*DmsClient) OnlineSubSqlTaskQuery ¶ added in v1.59.0
func (c *DmsClient) OnlineSubSqlTaskQuery(request *dms.OnlineSubSqlTaskQueryRequest) (*dms.OnlineSubSqlTaskQueryResponse, error)
查询sql子任务状态
func (*DmsClient) Open ¶
func (c *DmsClient) Open(request *dms.OpenRequest) (*dms.OpenResponse, error)
打开实例
func (*DmsClient) OperationDetail ¶ added in v1.59.0
func (c *DmsClient) OperationDetail(request *dms.OperationDetailRequest) (*dms.OperationDetailResponse, error)
获取操作详情
func (*DmsClient) ProcedureInfo ¶ added in v1.58.0
func (c *DmsClient) ProcedureInfo(request *dms.ProcedureInfoRequest) (*dms.ProcedureInfoResponse, error)
获取存储过程详情,支持Mysql
func (*DmsClient) ProcedureInvoke ¶ added in v1.58.0
func (c *DmsClient) ProcedureInvoke(request *dms.ProcedureInvokeRequest) (*dms.ProcedureInvokeResponse, error)
执行存储过程,支持Mysql
func (*DmsClient) ProcedureList ¶ added in v1.58.0
func (c *DmsClient) ProcedureList(request *dms.ProcedureListRequest) (*dms.ProcedureListResponse, error)
获取存储过程列表,支持Mysql
func (*DmsClient) ProgramList ¶
func (c *DmsClient) ProgramList(request *dms.ProgramListRequest) (*dms.ProgramListResponse, error)
获取视图列表,支持Mysql
func (*DmsClient) QueryInstance ¶
func (c *DmsClient) QueryInstance(request *dms.QueryInstanceRequest) (*dms.QueryInstanceResponse, error)
查询用户实例
func (*DmsClient) QueryOperationLog ¶ added in v1.59.0
func (c *DmsClient) QueryOperationLog(request *dms.QueryOperationLogRequest) (*dms.QueryOperationLogResponse, error)
获取操作日志列表
func (*DmsClient) QueryOperationType ¶ added in v1.59.0
func (c *DmsClient) QueryOperationType(request *dms.QueryOperationTypeRequest) (*dms.QueryOperationTypeResponse, error)
获取操作对应控制台功能
func (*DmsClient) QueryPersonalSqls ¶
func (c *DmsClient) QueryPersonalSqls(request *dms.QueryPersonalSqlsRequest) (*dms.QueryPersonalSqlsResponse, error)
获取当前实例用户收藏sql
func (*DmsClient) QueryPrivilegeList ¶ added in v1.59.0
func (c *DmsClient) QueryPrivilegeList(request *dms.QueryPrivilegeListRequest) (*dms.QueryPrivilegeListResponse, error)
用户授权信息列表
func (*DmsClient) QueryPrivilegeSelfList ¶ added in v1.59.0
func (c *DmsClient) QueryPrivilegeSelfList(request *dms.QueryPrivilegeSelfListRequest) (*dms.QueryPrivilegeSelfListResponse, error)
查看当前用户授权信息列表
func (*DmsClient) QueryTypeInstance ¶ added in v1.58.0
func (c *DmsClient) QueryTypeInstance(request *dms.QueryTypeInstanceRequest) (*dms.QueryTypeInstanceResponse, error)
查询用户数据类型实例
func (*DmsClient) QueryUserList ¶ added in v1.59.0
func (c *DmsClient) QueryUserList(request *dms.QueryUserListRequest) (*dms.QueryUserListResponse, error)
用户管理列表
func (*DmsClient) QueryUserNotSync ¶ added in v1.59.0
func (c *DmsClient) QueryUserNotSync(request *dms.QueryUserNotSyncRequest) (*dms.QueryUserNotSyncResponse, error)
获取主账号下未同步的子账号数据
func (*DmsClient) ReleasePrivilege ¶ added in v1.59.0
func (c *DmsClient) ReleasePrivilege(request *dms.ReleasePrivilegeRequest) (*dms.ReleasePrivilegeResponse, error)
释放权限
func (*DmsClient) RestartOnlineSqlTask ¶ added in v1.59.0
func (c *DmsClient) RestartOnlineSqlTask(request *dms.RestartOnlineSqlTaskRequest) (*dms.RestartOnlineSqlTaskResponse, error)
重启Sql任务
func (*DmsClient) SqlTableInfo ¶
func (c *DmsClient) SqlTableInfo(request *dms.SqlTableInfoRequest) (*dms.SqlTableInfoResponse, error)
获取sql中建表语句,表中列信息,支持Mysql,Stardb,Tidb,ClickHouse
func (*DmsClient) StartFlow ¶
func (c *DmsClient) StartFlow(request *dms.StartFlowRequest) (*dms.StartFlowResponse, error)
任务执行,支持Stardb
func (*DmsClient) StartOnlineSqlTask ¶ added in v1.59.0
func (c *DmsClient) StartOnlineSqlTask(request *dms.StartOnlineSqlTaskRequest) (*dms.StartOnlineSqlTaskResponse, error)
启动Sql任务
func (*DmsClient) SuspendOnlineSqlTask ¶ added in v1.59.0
func (c *DmsClient) SuspendOnlineSqlTask(request *dms.SuspendOnlineSqlTaskRequest) (*dms.SuspendOnlineSqlTaskResponse, error)
暂停Sql任务
func (*DmsClient) SyncSubUser ¶ added in v1.59.0
func (c *DmsClient) SyncSubUser(request *dms.SyncSubUserRequest) (*dms.SyncSubUserResponse, error)
同步子账号
func (*DmsClient) TableInfo ¶
func (c *DmsClient) TableInfo(request *dms.TableInfoRequest) (*dms.TableInfoResponse, error)
获取表元数据,支持Mysql,Stardb,Tidb,ClickHouse
func (*DmsClient) TableList ¶
func (c *DmsClient) TableList(request *dms.TableListRequest) (*dms.TableListResponse, error)
获取数据库中的表列表,支持Mysql,Stardb,Tidb,ClickHouse
func (*DmsClient) TriggerInfo ¶ added in v1.58.0
func (c *DmsClient) TriggerInfo(request *dms.TriggerInfoRequest) (*dms.TriggerInfoResponse, error)
获取触发器详情,支持Mysql
func (*DmsClient) TriggerList ¶ added in v1.58.0
func (c *DmsClient) TriggerList(request *dms.TriggerListRequest) (*dms.TriggerListResponse, error)
获取触发器列表,支持Mysql
func (*DmsClient) UpdatePersonalSql ¶
func (c *DmsClient) UpdatePersonalSql(request *dms.UpdatePersonalSqlRequest) (*dms.UpdatePersonalSqlResponse, error)
更新收藏sql
func (*DmsClient) UpdateUserInfo ¶ added in v1.59.0
func (c *DmsClient) UpdateUserInfo(request *dms.UpdateUserInfoRequest) (*dms.UpdateUserInfoResponse, error)
更新用户信息
func (*DmsClient) UploadImportFileTask ¶
func (c *DmsClient) UploadImportFileTask(request *dms.UploadImportFileTaskRequest) (*dms.UploadImportFileTaskResponse, error)
上传文件,支持Stardb,只支持前端页面使用
func (*DmsClient) ViewInfo ¶
func (c *DmsClient) ViewInfo(request *dms.ViewInfoRequest) (*dms.ViewInfoResponse, error)
获取视图详情,支持Mysql