Skip to content

Commit d725c2f

Browse files
authored
Update resource_postgresql_subscription.go
Adding retrieval of optional parameter
1 parent d10a9f9 commit d725c2f

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

postgresql/resource_postgresql_subscription.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -319,8 +319,9 @@ func getOptionalParameters(d *schema.ResourceData) string {
319319

320320
createSlot, okCreate := d.GetOkExists("create_slot") //nolint:staticcheck
321321
slotName, okName := d.GetOk("slot_name")
322+
enabled, okEnabled := d.GetOk("enabled")
322323

323-
if !okCreate && !okName {
324+
if !okCreate && !okName && !okEnabled {
324325
// use default behavior, no WITH statement
325326
return ""
326327
}
@@ -332,6 +333,9 @@ func getOptionalParameters(d *schema.ResourceData) string {
332333
if okName {
333334
params = append(params, fmt.Sprintf("%s = %s", "slot_name", pq.QuoteLiteral(slotName.(string))))
334335
}
336+
if okEnabled {
337+
params = append(params, fmt.Sprintf("%s = %t", "enabled", enabled.(bool)))
338+
}
335339

336340
returnValue = fmt.Sprintf(parameterSQLTemplate, strings.Join(params, ", "))
337341
return returnValue

0 commit comments

Comments
 (0)