Fix/mysql db init (#885)

* fix: mysql db init after create

* fix: optimize init polling

* fix: mysql init vport

Author: Kagashino

tencentcloud/resource_tc_mysql_instance.go

@@ -564,7 +564,11 @@ func mysqlCreateInstancePayByUse(ctx context.Context, d *schema.ResourceData, me
 	if len(response.Response.InstanceIds) != 1 {
 		return fmt.Errorf("mysql CreateDBInstanceHour return len(InstanceIds) is not 1,but %d", len(response.Response.InstanceIds))
 	}
-	d.SetId(*response.Response.InstanceIds[0])
+
+	id := *response.Response.InstanceIds[0]
+
+	d.SetId(id)
+
 	return nil
 }
 
@@ -618,6 +622,52 @@ func resourceTencentCloudMysqlInstanceCreate(d *schema.ResourceData, meta interf
 		return err
 	}
 
+	// Initialize mysql instance
+	var (
+		password  = d.Get("root_password").(string)
+		charset   = d.Get("parameters.character_set_server").(string)
+		lowercase = d.Get("parameters.lower_case_table_names").(string)
+		vPort     int
+	)
+
+	port, portOk := d.GetOk("intranet_port")
+
+	if portOk && port.(int) != 0 {
+		vPort = port.(int)
+	}
+
+	aReqId, err := mysqlService.InitDBInstances(ctx, mysqlID, password, charset, lowercase, vPort)
+
+	if err != nil {
+		return err
+	}
+
+	err = resource.Retry(readRetryTimeout, func() *resource.RetryError {
+		// Available status：INITIAL, RUNNING, SUCCESS, FAILED, KILLED, REMOVED, PAUSED
+		taskStatus, message, err := mysqlService.DescribeAsyncRequestInfo(ctx, aReqId)
+
+		if err != nil {
+			if _, ok := err.(*errors.TencentCloudSDKError); !ok {
+				return resource.RetryableError(err)
+			} else {
+				return resource.NonRetryableError(err)
+			}
+		}
+		if taskStatus == MYSQL_TASK_STATUS_SUCCESS {
+			return nil
+		}
+		if taskStatus == MYSQL_TASK_STATUS_INITIAL || taskStatus == MYSQL_TASK_STATUS_RUNNING {
+			return resource.RetryableError(fmt.Errorf("create account task  status is %s", taskStatus))
+		}
+		err = fmt.Errorf("initialize db task status is %s,we won't wait for it finish ,it show message:%s", ",",
+			message)
+		return resource.NonRetryableError(err)
+	})
+
+	if err != nil {
+		log.Printf("[WARN] initial DB error: %s", err.Error())
+	}
+
 	//internet service
 	internetService := d.Get("internet_service").(int)
 	if internetService == 1 {

tencentcloud/service_tencentcloud_mysql.go

@@ -932,16 +932,31 @@ func (me *MysqlService) DescribeDBInstanceConfig(ctx context.Context, mysqlId st
 	return
 }
 
-func (me *MysqlService) InitDBInstances(ctx context.Context, mysqlId string, password string) (asyncRequestId string, errRet error) {
+func (me *MysqlService) InitDBInstances(ctx context.Context, mysqlId, password, charset, lowerCase string, port int) (asyncRequestId string, errRet error) {
 	logId := getLogId(ctx)
 	request := cdb.NewInitDBInstancesRequest()
 	request.InstanceIds = []*string{&mysqlId}
-	request.NewPassword = &password
+	if password != "" {
+		request.NewPassword = &password
+	}
+
+	if port != 0 {
+		request.Vport = helper.IntInt64(port)
+	}
 
 	paramsMap := map[string]string{
-		"character_set_server":   "utf8mb4", // ["utf8","latin1","gbk","utf8mb4"]
-		"lower_case_table_names": "1",       // ["0","1"]
+		"character_set_server":   "LATIN1", // ["utf8","latin1","gbk","utf8mb4"]
+		"lower_case_table_names": "1",      // ["0","1"]
+	}
+
+	if charset != "" {
+		paramsMap["character_set_server"] = charset // ["utf8","latin1","gbk","utf8mb4"]
+	}
+
+	if lowerCase != "" {
+		paramsMap["lower_case_table_names"] = lowerCase // ["0","1"]
 	}
+
 	request.Parameters = make([]*cdb.ParamInfo, 0, len(paramsMap))
 	for k, v := range paramsMap {
 		name := k