support dts: sync job operation (#1857)

* support dts: sync job operation

* add e2e case

* add sync job config code

* passed the e2e case

* adjust e2e case

* adjust e2e case

* update doc

* adjust e2e case

Author: lyu571

.changelog/1857.txt

@@ -0,0 +1,27 @@
+```release-note:new-resource
+tencentcloud_dts_sync_job_start_operation
+```
+
+```release-note:new-resource
+tencentcloud_dts_sync_job_stop_operation
+```
+
+```release-note:new-resource
+tencentcloud_dts_sync_job_resize_operation
+```
+
+```release-note:new-resource
+tencentcloud_dts_sync_job_recover_operation
+```
+
+```release-note:new-resource
+tencentcloud_dts_sync_job_isolate_operation
+```
+
+```release-note:new-resource
+tencentcloud_dts_sync_job_continue_operation
+```
+
+```release-note:new-resource
+tencentcloud_dts_sync_job_pause_operation
+```

tencentcloud/provider.go

@@ -1215,14 +1215,23 @@ Data Transmission Service(DTS)
 
   Resource
 	tencentcloud_dts_sync_job
-	tencentcloud_dts_compare_task
+	tencentcloud_dts_sync_config
+	tencentcloud_dts_sync_check_job_operation
+	tencentcloud_dts_sync_job_resume_operation
+	tencentcloud_dts_sync_job_start_operation
+	tencentcloud_dts_sync_job_stop_operation
+	tencentcloud_dts_sync_job_resize_operation
+	tencentcloud_dts_sync_job_recover_operation
+	tencentcloud_dts_sync_job_isolate_operation
+	tencentcloud_dts_sync_job_continue_operation
+	tencentcloud_dts_sync_job_pause_operation
 	tencentcloud_dts_migrate_service
 	tencentcloud_dts_migrate_job
+	tencentcloud_dts_migrate_job_config
 	tencentcloud_dts_migrate_job_start_operation
 	tencentcloud_dts_migrate_job_resume_operation
 	tencentcloud_dts_compare_task_stop_operation
-	tencentcloud_dts_migrate_job_config
-	tencentcloud_dts_sync_config
+	tencentcloud_dts_compare_task
 
 TDMQ for RocketMQ(trocket)
   Data Source
@@ -2394,21 +2403,28 @@ func Provider() *schema.Provider {
 			"tencentcloud_rum_taw_instance":                           resourceTencentCloudRumTawInstance(),
 			"tencentcloud_rum_whitelist":                              resourceTencentCloudRumWhitelist(),
 			"tencentcloud_rum_offline_log_config_attachment":          resourceTencentCloudRumOfflineLogConfigAttachment(),
-			"tencentcloud_dts_sync_job":                               resourceTencentCloudDtsSyncJob(),
-			"tencentcloud_dts_sync_config":                            resourceTencentCloudDtsSyncConfig(),
 			"tencentcloud_tdmq_rocketmq_cluster":                      resourceTencentCloudTdmqRocketmqCluster(),
 			"tencentcloud_tdmq_rocketmq_namespace":                    resourceTencentCloudTdmqRocketmqNamespace(),
 			"tencentcloud_tdmq_rocketmq_role":                         resourceTencentCloudTdmqRocketmqRole(),
 			"tencentcloud_tdmq_rocketmq_topic":                        resourceTencentCloudTdmqRocketmqTopic(),
 			"tencentcloud_tdmq_rocketmq_group":                        resourceTencentCloudTdmqRocketmqGroup(),
 			"tencentcloud_tdmq_rocketmq_environment_role":             resourceTencentCloudTdmqRocketmqEnvironmentRole(),
+			"tencentcloud_dts_sync_job":                               resourceTencentCloudDtsSyncJob(),
+			"tencentcloud_dts_sync_config":                            resourceTencentCloudDtsSyncConfig(),
+			"tencentcloud_dts_sync_check_job_operation":               resourceTencentCloudDtsSyncCheckJobOperation(),
+			"tencentcloud_dts_sync_job_resume_operation":              resourceTencentCloudDtsSyncJobResumeOperation(),
+			"tencentcloud_dts_sync_job_start_operation":               resourceTencentCloudDtsSyncJobStartOperation(),
+			"tencentcloud_dts_sync_job_stop_operation":                resourceTencentCloudDtsSyncJobStopOperation(),
+			"tencentcloud_dts_sync_job_resize_operation":              resourceTencentCloudDtsSyncJobResizeOperation(),
+			"tencentcloud_dts_sync_job_recover_operation":             resourceTencentCloudDtsSyncJobRecoverOperation(),
+			"tencentcloud_dts_sync_job_isolate_operation":             resourceTencentCloudDtsSyncJobIsolateOperation(),
+			"tencentcloud_dts_sync_job_continue_operation":            resourceTencentCloudDtsSyncJobContinueOperation(),
+			"tencentcloud_dts_sync_job_pause_operation":               resourceTencentCloudDtsSyncJobPauseOperation(),
 			"tencentcloud_dts_migrate_service":                        resourceTencentCloudDtsMigrateService(),
 			"tencentcloud_dts_migrate_job":                            resourceTencentCloudDtsMigrateJob(),
 			"tencentcloud_dts_migrate_job_config":                     resourceTencentCloudDtsMigrateJobConfig(),
 			"tencentcloud_dts_migrate_job_start_operation":            resourceTencentCloudDtsMigrateJobStartOperation(),
 			"tencentcloud_dts_migrate_job_resume_operation":           resourceTencentCloudDtsMigrateJobResumeOperation(),
-			"tencentcloud_dts_sync_check_job_operation":               resourceTencentCloudDtsSyncCheckJobOperation(),
-			"tencentcloud_dts_sync_job_resume_operation":              resourceTencentCloudDtsSyncJobResumeOperation(),
 			"tencentcloud_dts_compare_task_stop_operation":            resourceTencentCloudDtsCompareTaskStopOperation(),
 			"tencentcloud_dts_compare_task":                           resourceTencentCloudDtsCompareTask(),
 			"tencentcloud_cvm_hpc_cluster":                            resourceTencentCloudCvmHpcCluster(),

tencentcloud/resource_tc_dts_sync_config.go

@@ -12,7 +12,7 @@ resource "tencentcloud_cynosdb_cluster" "foo" {
 	db_version                   = "5.7"
 	storage_limit                = 1000
 	cluster_name                 = "tf-cynosdb-mysql-sync-dst"
-	password                     = "cynos@123"
+	password                     = "*"
 	instance_maintain_duration   = 3600
 	instance_maintain_start_time = 10800
 	instance_maintain_weekdays   = [
@@ -66,46 +66,46 @@ resource "tencentcloud_dts_sync_job" "sync_job" {
   }
 
 resource "tencentcloud_dts_sync_config" "sync_config" {
-	job_id = tencentcloud_dts_sync_job.sync_job.job_id
-	src_access_type = "cdb"
-	dst_access_type = "cdb"
-
-	job_name = "tf_test_sync_config"
-	job_mode = "liteMode"
-	run_mode = "Immediate"
-
-	objects {
-		mode = "Partial"
-		databases {
-			db_name = "tf_ci_test"
+  job_id = tencentcloud_dts_sync_job.sync_job.job_id
+  src_access_type = "cdb"
+  dst_access_type = "cdb"
+
+  job_name = "tf_test_sync_config"
+  job_mode = "liteMode"
+  run_mode = "Immediate"
+
+  objects {
+	mode = "Partial"
+      databases {
+	    db_name = "tf_ci_test"
 			new_db_name = "tf_ci_test_new"
 			db_mode = "Partial"
 			table_mode = "All"
 			tables {
 				table_name = "test"
 				new_table_name = "test_new"
 			}
-		}
-	}
-	src_info {
+	  }
+  }
+  src_info {
 		region        = "ap-guangzhou"
 		instance_id   = "cdb-fitq5t9h"
 		user          = "keep_dts"
-		password      = "Letmein123"
+		password      = "*"
 		db_name       = "tf_ci_test"
 		vpc_id        = local.vpc_id
 		subnet_id     = local.subnet_id
-	}
-	dst_info {
+  }
+  dst_info {
 		region        = "ap-guangzhou"
 		instance_id   = tencentcloud_cynosdb_cluster.foo.id
 		user          = "root"
-		password      = "cynos@123"
+		password      = "*"
 		db_name       = "tf_ci_test_new"
 		vpc_id        = local.vpc_id
 		subnet_id     = local.subnet_id
-	}
-	auto_retry_time_range_minutes = 0
+  }
+  auto_retry_time_range_minutes = 0
 }
 ```
 
@@ -122,6 +122,7 @@ package tencentcloud
 import (
 	"context"
 	"log"
+	"time"
 
 	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
 	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
@@ -1663,6 +1664,13 @@ func resourceTencentCloudDtsSyncConfigUpdate(d *schema.ResourceData, meta interf
 		return err
 	}
 
+	service := DtsService{client: meta.(*TencentCloudClient).apiV3Conn}
+	conf := BuildStateChangeConf([]string{}, []string{"Initialized"}, readRetryTimeout, time.Second, service.DtsSyncJobStateRefreshFunc(d.Id(), "", []string{}))
+
+	if _, e := conf.WaitForState(); e != nil {
+		return e
+	}
+
 	return resourceTencentCloudDtsSyncConfigRead(d, meta)
 }
 

tencentcloud/resource_tc_dts_sync_config_test.go

@@ -125,46 +125,46 @@ resource "tencentcloud_dts_sync_job" "sync_job" {
   }
 
 resource "tencentcloud_dts_sync_config" "sync_config" {
-	job_id = tencentcloud_dts_sync_job.sync_job.job_id
-	src_access_type = "cdb"
-	dst_access_type = "cdb"
-
-	job_name = "tf_test_sync_config"
-	job_mode = "liteMode"
-	run_mode = "Immediate"
+  job_id = tencentcloud_dts_sync_job.sync_job.job_id
+  src_access_type = "cdb"
+  dst_access_type = "cdb"
+  
+  job_name = "tf_test_sync_config"
+  job_mode = "liteMode"
+  run_mode = "Immediate"
 
-	objects {
-		mode = "Partial"
-		databases {
-			db_name = "tf_ci_test"
+  objects {
+	mode = "Partial"
+      databases {
+	    db_name = "tf_ci_test"
 			new_db_name = "tf_ci_test_new"
 			db_mode = "Partial"
 			table_mode = "All"
 			tables {
 				table_name = "test"
 				new_table_name = "test_new"
 			}
-		}
-	}
-	src_info {
+	  }
+  }
+  src_info {
 		region        = "ap-guangzhou"
 		instance_id   = "cdb-fitq5t9h"
 		user          = "keep_dts"
 		password      = "Letmein123"
 		db_name       = "tf_ci_test"
 		vpc_id        = local.vpc_id
 		subnet_id     = local.subnet_id
-	}
-	dst_info {
+  }
+  dst_info {
 		region        = "ap-guangzhou"
 		instance_id   = tencentcloud_cynosdb_cluster.foo.id
 		user          = "root"
 		password      = "cynos@123"
 		db_name       = "tf_ci_test_new"
 		vpc_id        = local.vpc_id
 		subnet_id     = local.subnet_id
-	}
-	auto_retry_time_range_minutes = 0
+  }
+  auto_retry_time_range_minutes = 0
 }
 
 `

tencentcloud/resource_tc_dts_sync_job.go

@@ -326,7 +326,7 @@ func resourceTencentCloudDtsSyncJobDelete(d *schema.ResourceData, meta interface
 		return err
 	}
 
-	conf := BuildStateChangeConf([]string{}, []string{"Isolated"}, 2*readRetryTimeout, time.Second, service.DtsSyncJobConfigIsolateStateRefreshFunc(d.Id(), []string{}))
+	conf := BuildStateChangeConf([]string{}, []string{"Isolated", "Stopped"}, 2*readRetryTimeout, time.Second, service.DtsSyncJobConfigIsolateStateRefreshFunc(d.Id(), []string{}))
 
 	if _, e := conf.WaitForState(); e != nil {
 		return e
@@ -336,7 +336,7 @@ func resourceTencentCloudDtsSyncJobDelete(d *schema.ResourceData, meta interface
 		return err
 	}
 
-	conf = BuildStateChangeConf([]string{}, []string{"Deleted"}, 2*readRetryTimeout, time.Second, service.DtsSyncJobConfigDeleteStateRefreshFunc(d.Id(), []string{}))
+	conf = BuildStateChangeConf([]string{}, []string{"Offlined"}, 2*readRetryTimeout, time.Second, service.DtsSyncJobConfigDeleteStateRefreshFunc(d.Id(), []string{}))
 
 	if _, e := conf.WaitForState(); e != nil {
 		return e