Feat/support dcdb resource (#1500)

* update dts mode

* support tencentcloud_dcdb_db_instance

* update doc

* update e2e case

* update misspell

* support tencentcloud_dcdb_account_privileges

* update tencentcloud_dcdb_account_privileges e2e

* update e2e case

* update provider

* feat/support tencentcloud_dcdb_db_parameters

* add changelog

* add data_source

Author: lyu571

.changelog/1500.txt

@@ -0,0 +1,16 @@
+
+```release-note:new-resource
+tencentcloud_dcdb_db_parameters
+```
+
+```release-note:new-data-source
+tencentcloud_dcdb_database_objects
+```
+
+```release-note:new-data-source
+tencentcloud_dcdb_database_tables
+```
+
+```release-note:enhancement
+resource/tencentcloud_dcdb_account_privileges: optimize the logic after modifing the AccountPrivileges
+```

tencentcloud/data_source_tc_dcdb_database_objects.go

@@ -0,0 +1,217 @@
+/*
+Use this data source to query detailed information of dcdb database_objects
+
+Example Usage
+
+```hcl
+data "tencentcloud_dcdb_database_objects" "database_objects" {
+  instance_id = "dcdbt-ow7t8lmc"
+  db_name = <nil>
+        }
+```
+*/
+package tencentcloud
+
+import (
+	"context"
+	"strings"
+
+	"github.com/hashicorp/terraform-plugin-sdk/helper/resource"
+	"github.com/hashicorp/terraform-plugin-sdk/helper/schema"
+	dcdb "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/dcdb/v20180411"
+	"github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper"
+)
+
+func dataSourceTencentCloudDcdbDatabaseObjects() *schema.Resource {
+	return &schema.Resource{
+		Read: dataSourceTencentCloudDcdbDatabaseObjectsRead,
+		Schema: map[string]*schema.Schema{
+			"instance_id": {
+				Required:    true,
+				Type:        schema.TypeString,
+				Description: "The ID of instance.",
+			},
+
+			"db_name": {
+				Required:    true,
+				Type:        schema.TypeString,
+				Description: "Database name, obtained through the DescribeDatabases api.",
+			},
+
+			"tables": {
+				Computed:    true,
+				Type:        schema.TypeList,
+				Description: "Table list.",
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"table": {
+							Type:        schema.TypeString,
+							Computed:    true,
+							Description: "The name of table.",
+						},
+					},
+				},
+			},
+
+			"views": {
+				Computed:    true,
+				Type:        schema.TypeList,
+				Description: "View list.",
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"view": {
+							Type:        schema.TypeString,
+							Computed:    true,
+							Description: "The name of view.",
+						},
+					},
+				},
+			},
+
+			"procs": {
+				Computed:    true,
+				Type:        schema.TypeList,
+				Description: "Procedure list.",
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"proc": {
+							Type:        schema.TypeString,
+							Computed:    true,
+							Description: "The name of procedure.",
+						},
+					},
+				},
+			},
+
+			"funcs": {
+				Computed:    true,
+				Type:        schema.TypeList,
+				Description: "Function list.",
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"func": {
+							Type:        schema.TypeString,
+							Computed:    true,
+							Description: "The name of function.",
+						},
+					},
+				},
+			},
+
+			"result_output_file": {
+				Type:        schema.TypeString,
+				Optional:    true,
+				Description: "Used to save results.",
+			},
+		},
+	}
+}
+
+func dataSourceTencentCloudDcdbDatabaseObjectsRead(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("data_source.tencentcloud_dcdb_database_objects.read")()
+	defer inconsistentCheck(d, meta)()
+
+	logId := getLogId(contextNil)
+
+	ctx := context.WithValue(context.TODO(), logIdKey, logId)
+
+	paramMap := make(map[string]interface{})
+	if v, ok := d.GetOk("instance_id"); ok {
+		paramMap["instance_id"] = helper.String(v.(string))
+	}
+
+	if v, ok := d.GetOk("db_name"); ok {
+		paramMap["db_name"] = helper.String(v.(string))
+	}
+
+	service := DcdbService{client: meta.(*TencentCloudClient).apiV3Conn}
+	var result *dcdb.DescribeDatabaseObjectsResponseParams
+
+	err := resource.Retry(readRetryTimeout, func() *resource.RetryError {
+		var e error
+		result, e = service.DescribeDcdbDBObjectsByFilter(ctx, paramMap)
+		if e != nil {
+			return retryError(e)
+		}
+		return nil
+	})
+	if err != nil {
+		return err
+	}
+
+	ids := make([]string, 0)
+	data := make(map[string]interface{})
+
+	if result != nil {
+		tables := result.Tables
+		tabList := make([]map[string]interface{}, 0, len(tables))
+		if tables != nil {
+			for _, databaseTable := range tables {
+				databaseTableMap := map[string]interface{}{}
+
+				if databaseTable.Table != nil {
+					databaseTableMap["table"] = databaseTable.Table
+				}
+				tabList = append(tabList, databaseTableMap)
+			}
+			_ = d.Set("tables", tabList)
+			data["tables"] = tabList
+		}
+
+		views := result.Views
+		viewList := make([]map[string]interface{}, 0, len(views))
+		if views != nil {
+			for _, databaseView := range views {
+				databaseViewMap := map[string]interface{}{}
+
+				if databaseView.View != nil {
+					databaseViewMap["view"] = databaseView.View
+				}
+				viewList = append(viewList, databaseViewMap)
+			}
+			_ = d.Set("views", viewList)
+			data["views"] = viewList
+		}
+
+		procs := result.Procs
+		procList := make([]map[string]interface{}, 0, len(procs))
+		if procs != nil {
+			for _, databaseProcedure := range procs {
+				databaseProcedureMap := map[string]interface{}{}
+
+				if databaseProcedure.Proc != nil {
+					databaseProcedureMap["proc"] = databaseProcedure.Proc
+				}
+				procList = append(procList, databaseProcedureMap)
+			}
+			_ = d.Set("procs", procList)
+			data["procs"] = procList
+		}
+
+		funcs := result.Funcs
+		funcList := make([]map[string]interface{}, 0, len(funcs))
+		if funcs != nil {
+			for _, databaseFunction := range funcs {
+				databaseFunctionMap := map[string]interface{}{}
+
+				if databaseFunction.Func != nil {
+					databaseFunctionMap["func"] = databaseFunction.Func
+				}
+				funcList = append(funcList, databaseFunctionMap)
+			}
+			_ = d.Set("funcs", funcList)
+			data["funcs"] = funcList
+		}
+	}
+
+	ids = append(ids, strings.Join([]string{*result.InstanceId, *result.DbName}, FILED_SP))
+
+	d.SetId(helper.DataResourceIdsHash(ids))
+	output, ok := d.GetOk("result_output_file")
+	if ok && output.(string) != "" {
+		if e := writeToFile(output.(string), data); e != nil {
+			return e
+		}
+	}
+	return nil
+}

tencentcloud/data_source_tc_dcdb_database_objects_test.go

@@ -0,0 +1,40 @@
+package tencentcloud
+
+import (
+	"fmt"
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/helper/resource"
+)
+
+func TestAccTencentCloudDCDBDatabaseObjectsDataSource_basic(t *testing.T) {
+	t.Parallel()
+	resource.Test(t, resource.TestCase{
+		PreCheck: func() {
+			testAccPreCheck(t)
+		},
+		Providers: testAccProviders,
+		Steps: []resource.TestStep{
+			{
+				Config: fmt.Sprintf(testAccDCDBDatabaseObjectsDataSource, defaultDcdbInstanceId),
+				Check: resource.ComposeTestCheckFunc(
+					testAccCheckTencentCloudDataSourceID("data.tencentcloud_dcdb_database_objects.database_objects"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_dcdb_database_objects.database_objects", "tables.#"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_dcdb_database_objects.database_objects", "views.#"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_dcdb_database_objects.database_objects", "procs.#"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_dcdb_database_objects.database_objects", "funcs.#"),
+					resource.TestCheckResourceAttr("data.tencentcloud_dcdb_database_objects.database_objects", "db_name", "tf_test_db"),
+				),
+			},
+		},
+	})
+}
+
+const testAccDCDBDatabaseObjectsDataSource = `
+
+data "tencentcloud_dcdb_database_objects" "database_objects" {
+	instance_id = "%s"
+	db_name = "tf_test_db"
+}
+
+`