]> granicus.if.org Git - postgresql/commitdiff
pg_dump, pg_upgrade: allow postgres/template1 tablespace moves
authorBruce Momjian <bruce@momjian.us>
Fri, 11 Sep 2015 19:51:10 +0000 (15:51 -0400)
committerBruce Momjian <bruce@momjian.us>
Fri, 11 Sep 2015 19:51:10 +0000 (15:51 -0400)
Modify pg_dump to restore postgres/template1 databases to non-default
tablespaces by switching out of the database to be moved, then switching
back.

Also, to fix potentially cases where the old/new tablespaces might not
match, fix pg_upgrade to process new/old tablespaces separately in all
cases.

Report by Marti Raudsepp

Patch by Marti Raudsepp, me

Backpatch through 9.0

contrib/pg_upgrade/info.c
src/bin/pg_dump/pg_dumpall.c

index eec087fc486444fa0a4629d42912ecb3f282f673..709b45ba188e281db9098fd328647a67730fa12f 100644 (file)
@@ -137,6 +137,7 @@ create_rel_filename_map(const char *old_data, const char *new_data,
                                                const RelInfo *old_rel, const RelInfo *new_rel,
                                                FileNameMap *map)
 {
+       /* In case old/new tablespaces don't match, do them separately. */
        if (strlen(old_rel->tablespace) == 0)
        {
                /*
@@ -145,14 +146,27 @@ create_rel_filename_map(const char *old_data, const char *new_data,
                 */
                snprintf(map->old_dir, sizeof(map->old_dir), "%s/base/%u", old_data,
                                 old_db->db_oid);
-               snprintf(map->new_dir, sizeof(map->new_dir), "%s/base/%u", new_data,
-                                new_db->db_oid);
        }
        else
        {
                /* relation belongs to a tablespace, so use the tablespace location */
                snprintf(map->old_dir, sizeof(map->old_dir), "%s%s/%u", old_rel->tablespace,
                                 old_cluster.tablespace_suffix, old_db->db_oid);
+       }
+
+       /* Do the same for new tablespaces */
+       if (strlen(new_rel->tablespace) == 0)
+       {
+               /*
+                * relation belongs to the default tablespace, hence relfiles should
+                * exist in the data directories.
+                */
+               snprintf(map->new_dir, sizeof(map->new_dir), "%s/base/%u", new_data,
+                                new_db->db_oid);
+       }
+       else
+       {
+               /* relation belongs to a tablespace, so use the tablespace location */
                snprintf(map->new_dir, sizeof(map->new_dir), "%s%s/%u", new_rel->tablespace,
                                 new_cluster.tablespace_suffix, new_db->db_oid);
        }
index 5cb7f442d9077c94e9e8e3cde05f92a9b6e9189c..3529c5c0b0aa6b9231802b4126582a84dfa734b9 100644 (file)
@@ -1357,6 +1357,28 @@ dumpCreateDB(PGconn *conn)
                                appendPQExpBuffer(buf, ";\n");
                        }
                }
+               else if (strcmp(dbtablespace, "pg_default") != 0 && !no_tablespaces)
+               {
+                       /*
+                        * Cannot change tablespace of the database we're connected to,
+                        * so to move "postgres" to another tablespace, we connect to
+                        * "template1", and vice versa.
+                        */
+                       if (strcmp(dbname, "postgres") == 0)
+                               appendPQExpBuffer(buf, "%s\\connect template1\n",
+                                       /* Add a space before \\connect so pg_upgrade can split */
+                                       binary_upgrade ? " " : "");
+                       else
+                               appendPQExpBuffer(buf, "%s\\connect postgres\n",
+                                       binary_upgrade ? " " : "");
+
+                       appendPQExpBuffer(buf, "ALTER DATABASE %s SET TABLESPACE %s;\n",
+                                                         fdbname, fmtId(dbtablespace));
+
+                       /* connect to original database */
+                       appendPQExpBuffer(buf, "%s\\connect %s\n",
+                               binary_upgrade ? " " : "", fdbname);
+               }
 
                if (binary_upgrade)
                {