Add new resource: postgresql_publication (#192)

Author: Dmitry Mischenko

postgresql/config.go

@@ -34,6 +34,10 @@ const (
 	featurePrivilegesOnSchemas
 	featureForceDropDatabase
 	featurePid
+	featurePublishViaRoot
+	featurePubTruncate
+	featurePublication
+	featurePubWithoutTruncate
 	featureFunction
 )
 
@@ -88,6 +92,17 @@ var (
 		// for Postgresql >= 9.2 and above
 		featurePid: semver.MustParseRange(">=9.2.0"),
 
+		// attribute publish_via_partition_root for partition is supported
+		featurePublishViaRoot: semver.MustParseRange(">=13.0.0"),
+
+		// attribute pubtruncate for publications is supported
+		featurePubTruncate: semver.MustParseRange(">=11.0.0"),
+
+		// attribute pubtruncate for publications is supported
+		featurePubWithoutTruncate: semver.MustParseRange("<11.0.0"),
+
+		// publication is Supported
+		featurePublication: semver.MustParseRange(">=10.0.0"),
 		// We do not support CREATE FUNCTION for Postgresql < 8.4
 		featureFunction: semver.MustParseRange(">=8.4.0"),
 	}

postgresql/helpers.go

@@ -476,3 +476,29 @@ func pgLockRole(txn *sql.Tx, role string) error {
 
 	return nil
 }
+
+func arrayDifference(a, b []interface{}) (diff []interface{}) {
+	m := make(map[interface{}]bool)
+
+	for _, item := range b {
+		m[item] = true
+	}
+
+	for _, item := range a {
+		if _, ok := m[item]; !ok {
+			diff = append(diff, item)
+		}
+	}
+	return
+}
+
+func isUniqueArr(arr []interface{}) (interface{}, bool) {
+	keys := make(map[interface{}]bool, len(arr))
+	for _, entry := range arr {
+		if _, value := keys[entry]; value {
+			return entry, false
+		}
+		keys[entry] = true
+	}
+	return nil, true
+}

postgresql/provider.go

@@ -161,6 +161,7 @@ func Provider() *schema.Provider {
 			"postgresql_grant":                     resourcePostgreSQLGrant(),
 			"postgresql_grant_role":                resourcePostgreSQLGrantRole(),
 			"postgresql_replication_slot":          resourcePostgreSQLReplicationSlot(),
+			"postgresql_publication":               resourcePostgreSQLPublication(),
 			"postgresql_physical_replication_slot": resourcePostgreSQLPhysicalReplicationSlot(),
 			"postgresql_schema":                    resourcePostgreSQLSchema(),
 			"postgresql_role":                      resourcePostgreSQLRole(),