Propagate foreign server ops

src/backend/distributed/commands/dependencies.c

@@ -288,6 +288,11 @@ GetDependencyCreateDDLCommands(const ObjectAddress *dependency)
 			return CreateExtensionDDLCommand(dependency);
 		}
 
+		case OCLASS_FOREIGN_SERVER:
+		{
+			return GetForeignServerCreateDDLCommand(dependency->objectId);
+		}
+
 		default:
 		{
 			break;

src/backend/distributed/commands/distribute_object_ops.c

@@ -89,6 +89,14 @@ static DistributeObjectOps Any_AlterExtensionContents = {
 	.address = NULL,
 	.markDistributed = false,
 };
+static DistributeObjectOps Any_AlterForeignServer = {
+	.deparse = DeparseAlterForeignServerStmt,
+	.qualify = NULL,
+	.preprocess = PreprocessAlterForeignServerStmt,
+	.postprocess = NULL,
+	.address = NULL,
+	.markDistributed = false,
+};
 static DistributeObjectOps Any_AlterFunction = {
 	.deparse = DeparseAlterFunctionStmt,
 	.qualify = QualifyAlterFunctionStmt,
@@ -177,6 +185,14 @@ static DistributeObjectOps Any_CreatePolicy = {
 	.address = NULL,
 	.markDistributed = false,
 };
+static DistributeObjectOps Any_CreateForeignServer = {
+	.deparse = DeparseCreateForeignServerStmt,
+	.qualify = NULL,
+	.preprocess = PreprocessCreateForeignServerStmt,
+	.postprocess = PostprocessCreateForeignServerStmt,
+	.address = CreateForeignServerStmtObjectAddress,
+	.markDistributed = true,
+};
 static DistributeObjectOps Any_CreateStatistics = {
 	.deparse = DeparseCreateStatisticsStmt,
 	.qualify = QualifyCreateStatisticsStmt,
@@ -297,6 +313,30 @@ static DistributeObjectOps Extension_Drop = {
 	.address = NULL,
 	.markDistributed = false,
 };
+static DistributeObjectOps ForeignServer_Drop = {
+	.deparse = DeparseDropForeignServerStmt,
+	.qualify = NULL,
+	.preprocess = PreprocessDropForeignServerStmt,
+	.postprocess = NULL,
+	.address = NULL,
+	.markDistributed = false,
+};
+static DistributeObjectOps ForeignServer_Rename = {
+	.deparse = DeparseAlterForeignServerRenameStmt,
+	.qualify = NULL,
+	.preprocess = PreprocessRenameForeignServerStmt,
+	.postprocess = NULL,
+	.address = NULL,
+	.markDistributed = false,
+};
+static DistributeObjectOps ForeignServer_AlterOwner = {
+	.deparse = DeparseAlterForeignServerOwnerStmt,
+	.qualify = NULL,
+	.preprocess = PreprocessAlterForeignServerOwnerStmt,
+	.postprocess = PostprocessAlterForeignServerOwnerStmt,
+	.address = AlterForeignServerOwnerStmtObjectAddress,
+	.markDistributed = false,
+};
 static DistributeObjectOps ForeignTable_AlterTable = {
 	.deparse = NULL,
 	.qualify = NULL,
@@ -675,6 +715,11 @@ GetDistributeObjectOps(Node *node)
 			return &Any_AlterFunction;
 		}
 
+		case T_AlterForeignServerStmt:
+		{
+			return &Any_AlterForeignServer;
+		}
+
 		case T_AlterObjectDependsStmt:
 		{
 			AlterObjectDependsStmt *stmt = castNode(AlterObjectDependsStmt, node);
@@ -789,6 +834,11 @@ GetDistributeObjectOps(Node *node)
 					return &Database_AlterOwner;
 				}
 
+				case OBJECT_FOREIGN_SERVER:
+				{
+					return &ForeignServer_AlterOwner;
+				}
+
 				case OBJECT_FUNCTION:
 				{
 					return &Function_AlterOwner;
@@ -915,6 +965,11 @@ GetDistributeObjectOps(Node *node)
 			return &Any_CreateFunction;
 		}
 
+		case T_CreateForeignServerStmt:
+		{
+			return &Any_CreateForeignServer;
+		}
+
 		case T_CreatePolicyStmt:
 		{
 			return &Any_CreatePolicy;
@@ -977,6 +1032,11 @@ GetDistributeObjectOps(Node *node)
 					return &Function_Drop;
 				}
 
+				case OBJECT_FOREIGN_SERVER:
+				{
+					return &ForeignServer_Drop;
+				}
+
 				case OBJECT_INDEX:
 				{
 					return &Index_Drop;
@@ -1081,6 +1141,11 @@ GetDistributeObjectOps(Node *node)
 					return &Collation_Rename;
 				}
 
+				case OBJECT_FOREIGN_SERVER:
+				{
+					return &ForeignServer_Rename;
+				}
+
 				case OBJECT_FUNCTION:
 				{
 					return &Function_Rename;

src/backend/distributed/commands/extension.c

@@ -797,7 +797,7 @@ CreateExtensionDDLCommand(const ObjectAddress *extensionAddress)
 
 
 /*
- * RecreateEnumStmt returns a parsetree for a CREATE EXTENSION statement that would
+ * RecreateExtensionStmt returns a parsetree for a CREATE EXTENSION statement that would
  * recreate the given extension on a new node.
  */
 static Node *