in alicloud/resource_alicloud_rds_upgrade_db_instance.go [567:1132]
func resourceAlicloudRdsUpgradeDbInstanceUpdate(d *schema.ResourceData, meta interface{}) error {
client := meta.(*connectivity.AliyunClient)
rdsService := RdsService{client}
var response map[string]interface{}
var err error
d.Partial(true)
if d.HasChange("deletion_protection") && d.Get("payment_type") == "PayAsYouGo" {
err := rdsService.ModifyDBInstanceDeletionProtection(d, "deletion_protection")
if err != nil {
return WrapError(err)
}
}
if d.HasChange("parameters") {
if err := rdsService.ModifyParameters(d, "parameters"); err != nil {
return WrapError(err)
}
}
if d.HasChange("pg_hba_conf") {
err := rdsService.ModifyPgHbaConfig(d, "pg_hba_conf")
if err != nil {
return WrapError(err)
}
}
if d.HasChange("tcp_connection_type") {
err := rdsService.ModifyHADiagnoseConfig(d, "tcp_connection_type")
if err != nil {
return WrapError(err)
}
}
update := false
request := map[string]interface{}{
"DBInstanceId": d.Id(),
}
if d.HasChange("auto_upgrade_minor_version") {
update = true
}
if v, ok := d.GetOk("auto_upgrade_minor_version"); ok {
request["AutoUpgradeMinorVersion"] = v
}
if update {
action := "ModifyDBInstanceAutoUpgradeMinorVersion"
request["ClientToken"] = buildClientToken("ModifyDBInstanceAutoUpgradeMinorVersion")
wait := incrementalWait(3*time.Second, 3*time.Second)
err = resource.Retry(d.Timeout(schema.TimeoutUpdate), func() *resource.RetryError {
response, err = client.RpcPost("Rds", "2014-08-15", action, nil, request, true)
if err != nil {
if NeedRetry(err) {
wait()
return resource.RetryableError(err)
}
return resource.NonRetryableError(err)
}
return nil
})
addDebug(action, response, request)
if err != nil {
return WrapErrorf(err, DefaultErrorMsg, d.Id(), action, AlibabaCloudSdkGoERROR)
}
d.SetPartial("auto_upgrade_minor_version")
}
update = false
modifyDBInstanceDescriptionReq := map[string]interface{}{
"DBInstanceId": d.Id(),
}
if d.HasChange("db_instance_description") {
update = true
}
if v, ok := d.GetOk("db_instance_description"); ok {
modifyDBInstanceDescriptionReq["DBInstanceDescription"] = v
}
if update {
action := "ModifyDBInstanceDescription"
wait := incrementalWait(3*time.Second, 3*time.Second)
err = resource.Retry(d.Timeout(schema.TimeoutUpdate), func() *resource.RetryError {
response, err = client.RpcPost("Rds", "2014-08-15", action, nil, modifyDBInstanceDescriptionReq, false)
if err != nil {
if NeedRetry(err) {
wait()
return resource.RetryableError(err)
}
return resource.NonRetryableError(err)
}
return nil
})
addDebug(action, response, modifyDBInstanceDescriptionReq)
if err != nil {
return WrapErrorf(err, DefaultErrorMsg, d.Id(), action, AlibabaCloudSdkGoERROR)
}
d.SetPartial("db_instance_description")
}
update = false
modifyDBInstanceMaintainTimeReq := map[string]interface{}{
"DBInstanceId": d.Id(),
}
if d.HasChange("maintain_time") {
update = true
}
if v, ok := d.GetOk("maintain_time"); ok {
modifyDBInstanceMaintainTimeReq["MaintainTime"] = v
}
if update {
action := "ModifyDBInstanceMaintainTime"
request["ClientToken"] = buildClientToken("ModifyDBInstanceMaintainTime")
wait := incrementalWait(3*time.Second, 3*time.Second)
err = resource.Retry(d.Timeout(schema.TimeoutUpdate), func() *resource.RetryError {
response, err = client.RpcPost("Rds", "2014-08-15", action, nil, modifyDBInstanceMaintainTimeReq, true)
if err != nil {
if NeedRetry(err) {
wait()
return resource.RetryableError(err)
}
return resource.NonRetryableError(err)
}
return nil
})
addDebug(action, response, modifyDBInstanceMaintainTimeReq)
if err != nil {
return WrapErrorf(err, DefaultErrorMsg, d.Id(), action, AlibabaCloudSdkGoERROR)
}
d.SetPartial("maintain_time")
}
update = false
modifyDBInstanceHAConfigReq := map[string]interface{}{
"DbInstanceId": d.Id(),
}
if d.HasChange("sync_mode") {
update = true
}
if d.HasChange("ha_mode") {
update = true
}
if update {
if v, ok := d.GetOk("sync_mode"); ok {
modifyDBInstanceHAConfigReq["SyncMode"] = v
}
if v, ok := d.GetOk("ha_mode"); ok {
modifyDBInstanceHAConfigReq["HAMode"] = v
}
action := "ModifyDBInstanceHAConfig"
wait := incrementalWait(3*time.Second, 3*time.Second)
err = resource.Retry(d.Timeout(schema.TimeoutUpdate), func() *resource.RetryError {
response, err = client.RpcPost("Rds", "2014-08-15", action, nil, modifyDBInstanceHAConfigReq, false)
if err != nil {
if NeedRetry(err) {
wait()
return resource.RetryableError(err)
}
return resource.NonRetryableError(err)
}
return nil
})
addDebug(action, response, modifyDBInstanceHAConfigReq)
if err != nil {
return WrapErrorf(err, DefaultErrorMsg, d.Id(), action, AlibabaCloudSdkGoERROR)
}
d.SetPartial("sync_mode")
}
update = false
switchDBInstanceVpcReq := map[string]interface{}{
"DBInstanceId": d.Id(),
}
if !d.IsNewResource() && d.HasChange("private_ip_address") {
update = true
if v, ok := d.GetOk("private_ip_address"); ok {
switchDBInstanceVpcReq["PrivateIpAddress"] = v
}
}
if !d.IsNewResource() && d.HasChange("vpc_id") {
update = true
if v, ok := d.GetOk("vpc_id"); ok {
switchDBInstanceVpcReq["VPCId"] = v
}
}
if !d.IsNewResource() && d.HasChange("vswitch_id") {
update = true
if v, ok := d.GetOk("vswitch_id"); ok {
switchDBInstanceVpcReq["VSwitchId"] = v
}
}
if update {
action := "SwitchDBInstanceVpc"
wait := incrementalWait(3*time.Second, 3*time.Second)
err = resource.Retry(d.Timeout(schema.TimeoutUpdate), func() *resource.RetryError {
response, err = client.RpcPost("Rds", "2014-08-15", action, nil, switchDBInstanceVpcReq, false)
if err != nil {
if NeedRetry(err) {
wait()
return resource.RetryableError(err)
}
return resource.NonRetryableError(err)
}
return nil
})
addDebug(action, response, switchDBInstanceVpcReq)
if err != nil {
return WrapErrorf(err, DefaultErrorMsg, d.Id(), action, AlibabaCloudSdkGoERROR)
}
// wait instance status change from Creating to running
stateConf := BuildStateConf([]string{}, []string{"Running"}, d.Timeout(schema.TimeoutUpdate), 3*time.Minute, rdsService.RdsDBInstanceStateRefreshFunc(d.Id(), []string{"Deleting"}))
if _, err := stateConf.WaitForState(); err != nil {
return WrapErrorf(err, IdMsg, d.Id())
}
d.SetPartial("private_ip_address")
d.SetPartial("vpc_id")
d.SetPartial("vswitch_id")
}
update = false
modifyDBInstanceConnectionStringReq := map[string]interface{}{
"DBInstanceId": d.Id(),
}
if d.HasChange("port") {
update = true
}
if d.HasChange("connection_string_prefix") {
update = true
}
if v, ok := d.GetOk("connection_string"); ok {
modifyDBInstanceConnectionStringReq["CurrentConnectionString"] = v
}
if update {
if v, ok := d.GetOk("connection_string_prefix"); ok {
modifyDBInstanceConnectionStringReq["ConnectionStringPrefix"] = v
}
if v, ok := d.GetOk("port"); ok {
modifyDBInstanceConnectionStringReq["Port"] = v
}
action := "ModifyDBInstanceConnectionString"
wait := incrementalWait(3*time.Second, 3*time.Second)
err = resource.Retry(d.Timeout(schema.TimeoutUpdate), func() *resource.RetryError {
response, err = client.RpcPost("Rds", "2014-08-15", action, nil, modifyDBInstanceConnectionStringReq, false)
if err != nil {
if NeedRetry(err) {
wait()
return resource.RetryableError(err)
}
return resource.NonRetryableError(err)
}
return nil
})
addDebug(action, response, modifyDBInstanceConnectionStringReq)
if err != nil {
return WrapErrorf(err, DefaultErrorMsg, d.Id(), action, AlibabaCloudSdkGoERROR)
}
// wait instance status change from Creating to running
stateConf := BuildStateConf([]string{}, []string{"Running"}, d.Timeout(schema.TimeoutUpdate), 3*time.Minute, rdsService.RdsDBInstanceStateRefreshFunc(d.Id(), []string{"Deleting"}))
if _, err := stateConf.WaitForState(); err != nil {
return WrapErrorf(err, IdMsg, d.Id())
}
d.SetPartial("connection_string")
}
update = false
modifyDBInstanceTDEReq := map[string]interface{}{
"DBInstanceId": d.Id(),
}
if d.HasChange("encryption_key") {
update = true
if v, ok := d.GetOk("encryption_key"); ok {
modifyDBInstanceTDEReq["EncryptionKey"] = v
}
}
if update {
if v, ok := d.GetOk("tde_status"); ok {
modifyDBInstanceTDEReq["TDEStatus"] = v
}
if v, ok := d.GetOk("certificate"); ok {
modifyDBInstanceTDEReq["Certificate"] = v
}
if v, ok := d.GetOk("db_name"); ok {
modifyDBInstanceTDEReq["DBName"] = v
}
if v, ok := d.GetOk("password"); ok {
modifyDBInstanceTDEReq["PassWord"] = v
}
if v, ok := d.GetOk("private_key"); ok {
modifyDBInstanceTDEReq["PrivateKey"] = v
}
if v, ok := d.GetOk("role_arn"); ok {
modifyDBInstanceTDEReq["RoleArn"] = v
}
action := "ModifyDBInstanceTDE"
wait := incrementalWait(3*time.Second, 3*time.Second)
err = resource.Retry(d.Timeout(schema.TimeoutUpdate), func() *resource.RetryError {
response, err = client.RpcPost("Rds", "2014-08-15", action, nil, modifyDBInstanceTDEReq, false)
if err != nil {
if NeedRetry(err) {
wait()
return resource.RetryableError(err)
}
return resource.NonRetryableError(err)
}
return nil
})
addDebug(action, response, modifyDBInstanceTDEReq)
if err != nil {
return WrapErrorf(err, DefaultErrorMsg, d.Id(), action, AlibabaCloudSdkGoERROR)
}
// wait instance status change from Creating to running
stateConf := BuildStateConf([]string{}, []string{"Running"}, d.Timeout(schema.TimeoutUpdate), 3*time.Minute, rdsService.RdsDBInstanceStateRefreshFunc(d.Id(), []string{"Deleting"}))
if _, err := stateConf.WaitForState(); err != nil {
return WrapErrorf(err, IdMsg, d.Id())
}
d.SetPartial("encryption_key")
}
update = false
modifySecurityIpsReq := map[string]interface{}{
"DBInstanceId": d.Id(),
}
if d.HasChange("security_ips") {
update = true
ipList := expandStringList(d.Get("security_ips").(*schema.Set).List())
ipstr := strings.Join(ipList[:], COMMA_SEPARATED)
if ipstr == "" {
ipstr = LOCAL_HOST_IP
}
modifySecurityIpsReq["SecurityIps"] = ipstr
}
if update {
action := "ModifySecurityIps"
wait := incrementalWait(3*time.Second, 3*time.Second)
err = resource.Retry(d.Timeout(schema.TimeoutUpdate), func() *resource.RetryError {
response, err = client.RpcPost("Rds", "2014-08-15", action, nil, modifySecurityIpsReq, false)
if err != nil {
if NeedRetry(err) {
wait()
return resource.RetryableError(err)
}
return resource.NonRetryableError(err)
}
return nil
})
addDebug(action, response, modifySecurityIpsReq)
if err != nil {
return WrapErrorf(err, DefaultErrorMsg, d.Id(), action, AlibabaCloudSdkGoERROR)
}
d.SetPartial("security_ips")
}
update = false
modifyDBInstanceSSLReq := map[string]interface{}{
"DBInstanceId": d.Id(),
}
if v, ok := d.GetOk("connection_string"); ok {
modifyDBInstanceSSLReq["ConnectionString"] = v
}
if d.HasChange("acl") {
update = true
if v, ok := d.GetOk("acl"); ok {
modifyDBInstanceSSLReq["ACL"] = v
}
}
if d.HasChange("ca_type") {
update = true
if v, ok := d.GetOk("ca_type"); ok {
modifyDBInstanceSSLReq["CAType"] = v
}
}
if d.HasChange("client_ca_cert") {
update = true
if v, ok := d.GetOk("client_ca_cert"); ok {
modifyDBInstanceSSLReq["ClientCACert"] = v
}
}
if d.HasChange("client_cert_revocation_list") {
update = true
if v, ok := d.GetOk("client_cert_revocation_list"); ok {
modifyDBInstanceSSLReq["ClientCertRevocationList"] = v
}
}
if d.HasChange("replication_acl") {
update = true
if v, ok := d.GetOk("replication_acl"); ok {
modifyDBInstanceSSLReq["ReplicationACL"] = v
}
}
if d.HasChange("server_cert") {
update = true
if v, ok := d.GetOk("server_cert"); ok {
modifyDBInstanceSSLReq["ServerCert"] = v
}
}
if d.HasChange("server_key") {
update = true
if v, ok := d.GetOk("server_key"); ok {
modifyDBInstanceSSLReq["ServerKey"] = v
}
}
if d.HasChange("client_ca_enabled") {
update = true
if v, ok := d.GetOk("client_ca_enabled"); ok {
modifyDBInstanceSSLReq["ClientCAEnabled"] = v
}
}
if d.HasChange("client_crl_enabled") {
update = true
if v, ok := d.GetOk("client_crl_enabled"); ok {
modifyDBInstanceSSLReq["ClientCrlEnabled"] = v
}
}
if d.HasChange("ssl_enabled") {
update = true
if v, ok := d.GetOk("ssl_enabled"); ok {
modifyDBInstanceSSLReq["SSLEnabled"] = v
}
}
instance, err := rdsService.DescribeDBInstance(d.Id())
if err != nil {
return WrapError(err)
}
// When upgrading to a larger version, SSL was immediately enabled. As no instance information was queried, there was no ConnectionString information available, so the queried ConnectionString was used
modifyDBInstanceSSLReq["ConnectionString"] = instance["ConnectionString"]
if update {
action := "ModifyDBInstanceSSL"
wait := incrementalWait(3*time.Second, 3*time.Second)
err = resource.Retry(d.Timeout(schema.TimeoutUpdate), func() *resource.RetryError {
response, err = client.RpcPost("Rds", "2014-08-15", action, nil, modifyDBInstanceSSLReq, false)
if err != nil {
if NeedRetry(err) {
wait()
return resource.RetryableError(err)
}
return resource.NonRetryableError(err)
}
return nil
})
addDebug(action, response, modifyDBInstanceSSLReq)
if err != nil {
return WrapErrorf(err, DefaultErrorMsg, d.Id(), action, AlibabaCloudSdkGoERROR)
}
// wait instance status change from Creating to running
stateConf := BuildStateConf([]string{}, []string{"Running"}, d.Timeout(schema.TimeoutUpdate), 3*time.Minute, rdsService.RdsDBInstanceStateRefreshFunc(d.Id(), []string{"Deleting"}))
if _, err := stateConf.WaitForState(); err != nil {
return WrapErrorf(err, IdMsg, d.Id())
}
d.SetPartial("connection_string")
d.SetPartial("acl")
d.SetPartial("ca_type")
d.SetPartial("client_ca_cert")
d.SetPartial("client_cert_revocation_list")
d.SetPartial("replication_acl")
d.SetPartial("server_cert")
d.SetPartial("server_key")
d.SetPartial("ssl_enabled")
}
if d.HasChange("resource_group_id") {
if v, ok := d.GetOk("resource_group_id"); ok {
action := "ModifyResourceGroup"
groupRequest := map[string]interface{}{
"DBInstanceId": d.Id(),
"ResourceGroupId": v.(string),
"ClientToken": buildClientToken(action),
"SourceIp": client.SourceIp,
}
wait := incrementalWait(3*time.Second, 3*time.Second)
err = resource.Retry(d.Timeout(schema.TimeoutUpdate), func() *resource.RetryError {
response, err = client.RpcPost("Rds", "2014-08-15", action, nil, groupRequest, true)
if err != nil {
if NeedRetry(err) {
wait()
return resource.RetryableError(err)
}
return resource.NonRetryableError(err)
}
return nil
})
if err != nil {
return WrapErrorf(err, DefaultErrorMsg, d.Id(), action, AlibabaCloudSdkGoERROR)
}
addDebug(action, response, groupRequest)
stateConf := BuildStateConf([]string{}, []string{"Running"}, d.Timeout(schema.TimeoutUpdate), 0, rdsService.RdsDBInstanceStateRefreshFunc(d.Id(), []string{"Deleting"}))
if _, err := stateConf.WaitForState(); err != nil {
return WrapErrorf(err, IdMsg, d.Id())
}
d.SetPartial("resource_group_id")
}
}
update = false
modifyDBInstanceSpecReq := map[string]interface{}{
"DBInstanceId": d.Id(),
}
if !d.IsNewResource() && d.HasChange("payment_type") {
update = true
}
if v, ok := d.GetOk("payment_type"); ok {
modifyDBInstanceSpecReq["PayType"] = convertRdsInstancePaymentTypeRequest(v)
}
if !d.IsNewResource() && d.HasChange("db_instance_class") {
update = true
if v, ok := d.GetOk("db_instance_class"); ok {
modifyDBInstanceSpecReq["DBInstanceClass"] = v
}
}
if !d.IsNewResource() && d.HasChange("db_instance_storage") {
update = true
if v, ok := d.GetOk("db_instance_storage"); ok {
modifyDBInstanceSpecReq["DBInstanceStorage"] = v
}
}
if !d.IsNewResource() && d.HasChange("db_instance_storage_type") {
update = true
modifyDBInstanceSpecReq["DBInstanceStorageType"] = d.Get("db_instance_storage_type")
}
if !d.IsNewResource() && d.HasChange("dedicated_host_group_id") {
update = true
if v, ok := d.GetOk("dedicated_host_group_id"); ok {
modifyDBInstanceSpecReq["DedicatedHostGroupId"] = v
}
}
if d.HasChange("engine_version") {
update = true
if v, ok := d.GetOk("engine_version"); ok {
modifyDBInstanceSpecReq["EngineVersion"] = v
}
}
if !d.IsNewResource() && d.HasChange("zone_id") {
update = true
if v, ok := d.GetOk("zone_id"); ok {
modifyDBInstanceSpecReq["ZoneId"] = v
}
}
if update {
if v, ok := d.GetOk("direction"); ok {
modifyDBInstanceSpecReq["Direction"] = v
}
if v, ok := d.GetOk("effective_time"); ok {
modifyDBInstanceSpecReq["EffectiveTime"] = v
}
if v, ok := d.GetOk("source_biz"); ok {
modifyDBInstanceSpecReq["SourceBiz"] = v
}
if v, ok := d.GetOk("switch_time"); ok {
modifyDBInstanceSpecReq["SwitchTime"] = v
}
action := "ModifyDBInstanceSpec"
wait := incrementalWait(3*time.Second, 3*time.Second)
err = resource.Retry(d.Timeout(schema.TimeoutUpdate), func() *resource.RetryError {
response, err = client.RpcPost("Rds", "2014-08-15", action, nil, modifyDBInstanceSpecReq, false)
if err != nil {
if NeedRetry(err) {
wait()
return resource.RetryableError(err)
}
return resource.NonRetryableError(err)
}
return nil
})
addDebug(action, response, modifyDBInstanceSpecReq)
if err != nil {
return WrapErrorf(err, DefaultErrorMsg, d.Id(), action, AlibabaCloudSdkGoERROR)
}
// wait instance status change from Creating to running
stateConf := BuildStateConf([]string{}, []string{"Running"}, d.Timeout(schema.TimeoutUpdate), 3*time.Minute, rdsService.RdsDBInstanceStateRefreshFunc(d.Id(), []string{"Deleting"}))
if _, err := stateConf.WaitForState(); err != nil {
return WrapErrorf(err, IdMsg, d.Id())
}
d.SetPartial("db_instance_class")
d.SetPartial("db_instance_storage")
d.SetPartial("db_instance_storage_type")
d.SetPartial("dedicated_host_group_id")
d.SetPartial("engine_version")
d.SetPartial("zone_id")
}
d.Partial(false)
return resourceAlicloudRdsUpgradeDbInstanceRead(d, meta)
}