diff options
Diffstat (limited to 'src/backend/replication/pgoutput/pgoutput.c')
| -rw-r--r-- | src/backend/replication/pgoutput/pgoutput.c | 26 |
1 files changed, 0 insertions, 26 deletions
diff --git a/src/backend/replication/pgoutput/pgoutput.c b/src/backend/replication/pgoutput/pgoutput.c index d538f25ede6..aa9cf5b54ed 100644 --- a/src/backend/replication/pgoutput/pgoutput.c +++ b/src/backend/replication/pgoutput/pgoutput.c @@ -21,7 +21,6 @@ #include "utils/inval.h" #include "utils/int8.h" -#include "utils/lsyscache.h" #include "utils/memutils.h" #include "utils/syscache.h" #include "utils/varlena.h" @@ -511,31 +510,6 @@ get_rel_sync_entry(PGOutputData *data, Oid relid) { Publication *pub = lfirst(lc); - /* - * Skip tables that look like they are from a heap rewrite (see - * make_new_heap()). We need to skip them because the subscriber - * won't have a table by that name to receive the data. That - * means we won't ship the new data in, say, an added column with - * a DEFAULT, but if the user applies the same DDL manually on the - * subscriber, then this will work out for them. - * - * We only need to consider the alltables case, because such a - * transient heap won't be an explicit member of a publication. - */ - if (pub->alltables) - { - char *relname = get_rel_name(relid); - unsigned int u; - int n; - - if (sscanf(relname, "pg_temp_%u%n", &u, &n) == 1 && - relname[n] == '\0') - { - if (get_rel_relkind(u) == RELKIND_RELATION) - break; - } - } - if (pub->alltables || list_member_oid(pubids, pub->oid)) { entry->pubactions.pubinsert |= pub->pubactions.pubinsert; |