support cynosdb: cluster slave zone, ro_access and slow queries

.changelog/1915.txt

@@ -0,0 +1,11 @@
+```release-note:new-resource
+tencentcloud_cynosdb_cluster_slave_zone
+```
+
+```release-note:new-resource
+tencentcloud_cynosdb_read_only_instance_exclusive_access
+```
+
+```release-note:new-data-source
+tencentcloud_cynosdb_instance_slow_queries
+```

tencentcloud/data_source_tc_cynosdb_instance_slow_queries.go

@@ -0,0 +1,314 @@
+/*
+Use this data source to query detailed information of cynosdb instance_slow_queries
+
+Example Usage
+
+Query slow queries of instance
+```hcl
+variable "cynosdb_cluster_id" {
+  default = "default_cynosdb_cluster"
+}
+
+data "tencentcloud_cynosdb_instance_slow_queries" "instance_slow_queries" {
+  instance_id   = var.cynosdb_cluster_id
+  start_time    = "2023-06-20 23:19:03"
+  end_time      = "2023-06-30 23:19:03"
+  username      = "keep_dts"
+  host          = "%%"
+  database      = "tf_ci_test"
+  order_by      = "QueryTime"
+  order_by_type = "desc"
+}
+```
+
+Query slow queries by time range
+```hcl
+variable "cynosdb_cluster_id" {
+  default = "default_cynosdb_cluster"
+}
+
+data "tencentcloud_cynosdb_instance_slow_queries" "instance_slow_queries" {
+  instance_id   = var.cynosdb_cluster_id
+  start_time    = "2023-06-20 23:19:03"
+  end_time      = "2023-06-30 23:19:03"
+  order_by      = "QueryTime"
+  order_by_type = "desc"
+}
+```
+
+Query slow queries by user and db name
+```hcl
+variable "cynosdb_cluster_id" {
+  default = "default_cynosdb_cluster"
+}
+
+data "tencentcloud_cynosdb_instance_slow_queries" "instance_slow_queries" {
+  instance_id   = var.cynosdb_cluster_id
+  username      = "keep_dts"
+  host          = "%%"
+  database      = "tf_ci_test"
+  order_by      = "QueryTime"
+  order_by_type = "desc"
+}
+```
+*/
+package tencentcloud
+
+import (
+	"context"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	cynosdb "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cynosdb/v20190107"
+	"github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper"
+)
+
+func dataSourceTencentCloudCynosdbInstanceSlowQueries() *schema.Resource {
+	return &schema.Resource{
+		Read: dataSourceTencentCloudCynosdbInstanceSlowQueriesRead,
+		Schema: map[string]*schema.Schema{
+			"instance_id": {
+				Required:    true,
+				Type:        schema.TypeString,
+				Description: "Instance ID.",
+			},
+
+			"start_time": {
+				Optional:    true,
+				Type:        schema.TypeString,
+				Description: "Earliest transaction start time.",
+			},
+
+			"end_time": {
+				Optional:    true,
+				Type:        schema.TypeString,
+				Description: "Latest transaction start time.",
+			},
+
+			"username": {
+				Optional:    true,
+				Type:        schema.TypeString,
+				Description: "user name.",
+			},
+
+			"host": {
+				Optional:    true,
+				Type:        schema.TypeString,
+				Description: "Client host.",
+			},
+
+			"database": {
+				Optional:    true,
+				Type:        schema.TypeString,
+				Description: "Database name.",
+			},
+
+			"order_by": {
+				Optional:    true,
+				Type:        schema.TypeString,
+				Description: "Sort field, optional values: QueryTime, LockTime, RowsExamined, RowsSent.",
+			},
+
+			"order_by_type": {
+				Optional:    true,
+				Type:        schema.TypeString,
+				Description: "Sort type, optional values: asc, desc.",
+			},
+
+			"slow_queries": {
+				Computed:    true,
+				Type:        schema.TypeList,
+				Description: "Slow query records.",
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"timestamp": {
+							Type:        schema.TypeInt,
+							Computed:    true,
+							Description: "Execution timestamp.",
+						},
+						"query_time": {
+							Type:        schema.TypeFloat,
+							Computed:    true,
+							Description: "Execution time in seconds.",
+						},
+						"sql_text": {
+							Type:        schema.TypeString,
+							Computed:    true,
+							Description: "SQL statement.",
+						},
+						"user_host": {
+							Type:        schema.TypeString,
+							Computed:    true,
+							Description: "Client host.",
+						},
+						"user_name": {
+							Type:        schema.TypeString,
+							Computed:    true,
+							Description: "user name.",
+						},
+						"database": {
+							Type:        schema.TypeString,
+							Computed:    true,
+							Description: "Database name.",
+						},
+						"lock_time": {
+							Type:        schema.TypeFloat,
+							Computed:    true,
+							Description: "Lock duration in seconds.",
+						},
+						"rows_examined": {
+							Type:        schema.TypeInt,
+							Computed:    true,
+							Description: "Scan Rows.",
+						},
+						"rows_sent": {
+							Type:        schema.TypeInt,
+							Computed:    true,
+							Description: "Return the number of rows.",
+						},
+						"sql_template": {
+							Type:        schema.TypeString,
+							Computed:    true,
+							Description: "SQL template.",
+						},
+						"sql_md5": {
+							Type:        schema.TypeString,
+							Computed:    true,
+							Description: "SQL statement md5.",
+						},
+					},
+				},
+			},
+
+			"result_output_file": {
+				Type:        schema.TypeString,
+				Optional:    true,
+				Description: "Used to save results.",
+			},
+		},
+	}
+}
+
+func dataSourceTencentCloudCynosdbInstanceSlowQueriesRead(d *schema.ResourceData, meta interface{}) error {
+	defer logElapsed("data_source.tencentcloud_cynosdb_instance_slow_queries.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["InstanceId"] = helper.String(v.(string))
+	}
+
+	if v, ok := d.GetOk("start_time"); ok {
+		paramMap["StartTime"] = helper.String(v.(string))
+	}
+
+	if v, ok := d.GetOk("end_time"); ok {
+		paramMap["EndTime"] = helper.String(v.(string))
+	}
+
+	if v, ok := d.GetOk("username"); ok {
+		paramMap["Username"] = helper.String(v.(string))
+	}
+
+	if v, ok := d.GetOk("host"); ok {
+		paramMap["Host"] = helper.String(v.(string))
+	}
+
+	if v, ok := d.GetOk("database"); ok {
+		paramMap["Database"] = helper.String(v.(string))
+	}
+
+	if v, ok := d.GetOk("order_by"); ok {
+		paramMap["OrderBy"] = helper.String(v.(string))
+	}
+
+	if v, ok := d.GetOk("order_by_type"); ok {
+		paramMap["OrderByType"] = helper.String(v.(string))
+	}
+
+	service := CynosdbService{client: meta.(*TencentCloudClient).apiV3Conn}
+
+	var slowQueries []*cynosdb.SlowQueriesItem
+
+	err := resource.Retry(readRetryTimeout, func() *resource.RetryError {
+		result, e := service.DescribeCynosdbInstanceSlowQueriesByFilter(ctx, paramMap)
+		if e != nil {
+			return retryError(e)
+		}
+		slowQueries = result
+		return nil
+	})
+	if err != nil {
+		return err
+	}
+
+	ids := make([]string, 0, len(slowQueries))
+	tmpList := make([]map[string]interface{}, 0, len(slowQueries))
+
+	if slowQueries != nil {
+		for _, slowQueriesItem := range slowQueries {
+			slowQueriesItemMap := map[string]interface{}{}
+
+			if slowQueriesItem.Timestamp != nil {
+				slowQueriesItemMap["timestamp"] = slowQueriesItem.Timestamp
+			}
+
+			if slowQueriesItem.QueryTime != nil {
+				slowQueriesItemMap["query_time"] = slowQueriesItem.QueryTime
+			}
+
+			if slowQueriesItem.SqlText != nil {
+				slowQueriesItemMap["sql_text"] = slowQueriesItem.SqlText
+			}
+
+			if slowQueriesItem.UserHost != nil {
+				slowQueriesItemMap["user_host"] = slowQueriesItem.UserHost
+			}
+
+			if slowQueriesItem.UserName != nil {
+				slowQueriesItemMap["user_name"] = slowQueriesItem.UserName
+			}
+
+			if slowQueriesItem.Database != nil {
+				slowQueriesItemMap["database"] = slowQueriesItem.Database
+			}
+
+			if slowQueriesItem.LockTime != nil {
+				slowQueriesItemMap["lock_time"] = slowQueriesItem.LockTime
+			}
+
+			if slowQueriesItem.RowsExamined != nil {
+				slowQueriesItemMap["rows_examined"] = slowQueriesItem.RowsExamined
+			}
+
+			if slowQueriesItem.RowsSent != nil {
+				slowQueriesItemMap["rows_sent"] = slowQueriesItem.RowsSent
+			}
+
+			if slowQueriesItem.SqlTemplate != nil {
+				slowQueriesItemMap["sql_template"] = slowQueriesItem.SqlTemplate
+			}
+
+			if slowQueriesItem.SqlMd5 != nil {
+				slowQueriesItemMap["sql_md5"] = slowQueriesItem.SqlMd5
+			}
+
+			ids = append(ids, *slowQueriesItem.SqlMd5)
+			tmpList = append(tmpList, slowQueriesItemMap)
+		}
+
+		_ = d.Set("slow_queries", tmpList)
+	}
+
+	d.SetId(helper.DataResourceIdsHash(ids))
+	output, ok := d.GetOk("result_output_file")
+	if ok && output.(string) != "" {
+		if e := writeToFile(output.(string), tmpList); e != nil {
+			return e
+		}
+	}
+	return nil
+}

tencentcloud/data_source_tc_cynosdb_instance_slow_queries_test.go

@@ -0,0 +1,64 @@
+package tencentcloud
+
+import (
+	"fmt"
+	"testing"
+	"time"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+)
+
+func TestAccTencentCloudCynosdbInstanceSlowQueriesDataSource_basic(t *testing.T) {
+	t.Parallel()
+	loc, _ := time.LoadLocation("Asia/Chongqing")
+	startTime := time.Now().AddDate(0, 0, -7).In(loc).Format("2006-01-02 15:04:05")
+	endTime := time.Now().In(loc).Format("2006-01-02 15:04:05")
+	resource.Test(t, resource.TestCase{
+		PreCheck: func() {
+			testAccPreCheck(t)
+		},
+		Providers: testAccProviders,
+		Steps: []resource.TestStep{
+			{
+				Config: fmt.Sprintf(testAccCynosdbInstanceSlowQueriesDataSource, startTime, endTime),
+				Check: resource.ComposeTestCheckFunc(
+					testAccCheckTencentCloudDataSourceID("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "id"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "instance_id"),
+					// resource.TestCheckResourceAttrSet("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "start_time"),
+					// resource.TestCheckResourceAttrSet("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "end_time"),
+					resource.TestCheckResourceAttr("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "username", "keep_dts"),
+					resource.TestCheckResourceAttr("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "database", "tf_ci_test"),
+					resource.TestCheckResourceAttr("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "order_by", "QueryTime"),
+					resource.TestCheckResourceAttr("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "order_by_type", "desc"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "slow_queries.#"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "slow_queries.0.timestamp"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "slow_queries.0.query_time"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "slow_queries.0.sql_text"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "slow_queries.0.user_host"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "slow_queries.0.user_name"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "slow_queries.0.database"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "slow_queries.0.lock_time"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "slow_queries.0.rows_examined"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "slow_queries.0.rows_sent"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "slow_queries.0.sql_template"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_cynosdb_instance_slow_queries.instance_slow_queries", "slow_queries.0.sql_md5"),
+				),
+			},
+		},
+	})
+}
+
+const testAccCynosdbInstanceSlowQueriesDataSource = CommonCynosdb + `
+
+data "tencentcloud_cynosdb_instance_slow_queries" "instance_slow_queries" {
+  instance_id = var.cynosdb_cluster_instance_id
+//   start_time = "%s"
+//   end_time = "%s"
+  username = "keep_dts"
+  database = "tf_ci_test"
+  order_by = "QueryTime"
+  order_by_type = "desc"
+}
+
+`