@@ -845,30 +845,29 @@ prepare_rri_fdw_for_insert(EState *estate,
845845 break ;
846846
847847 case PF_FDW_INSERT_POSTGRES :
848+ case PF_FDW_INSERT_ANY_FDW :
848849 {
849850 ForeignDataWrapper * fdw ;
850851 ForeignServer * fserver ;
851852
852853 /* Check if it's PostgreSQL FDW */
853854 fserver = GetForeignServer (GetForeignTable (partid )-> serverid );
854855 fdw = GetForeignDataWrapper (fserver -> fdwid );
855- if (strcmp ("postgres_fdw" , fdw -> fdwname ) != 0 )
856- elog (ERROR , "FDWs other than postgres_fdw are restricted" );
857- }
858- break ;
859-
860- case PF_FDW_INSERT_ANY_FDW :
861- {
862- ForeignDataWrapper * fdw ;
863- ForeignServer * fserver ;
864856
865- fserver = GetForeignServer (GetForeignTable (partid )-> serverid );
866- fdw = GetForeignDataWrapper (fserver -> fdwid );
857+ /* Show message if not postgres_fdw */
867858 if (strcmp ("postgres_fdw" , fdw -> fdwname ) != 0 )
868- elog (WARNING , "unrestricted FDW mode may lead to \"%s\" crashes" ,
869- fdw -> fdwname );
859+ switch (pg_pathman_insert_into_fdw )
860+ {
861+ case PF_FDW_INSERT_POSTGRES :
862+ elog (ERROR ,
863+ "FDWs other than postgres_fdw are restricted" );
864+
865+ case PF_FDW_INSERT_ANY_FDW :
866+ elog (WARNING ,
867+ "unrestricted FDW mode may lead to crashes" );
868+ }
870869 }
871- break ; /* do nothing */
870+ break ;
872871
873872 default :
874873 elog (ERROR , "Mode is not implemented yet" );
0 commit comments