66 #include "utils/fmgroids.h"
114 static void movedb(
const char *
dbname,
const char *tblspcname);
117 Oid *dbIdP,
Oid *ownerIdP,
118 int *encodingP,
bool *dbIsTemplateP,
bool *dbAllowConnP,
bool *dbHasLoginEvtP,
120 Oid *dbTablespace,
char **dbCollate,
char **dbCtype,
char **dbLocale,
123 char **dbCollversion);
131 Oid dbid,
char *srcpath,
139 Oid src_tsid,
Oid dst_tsid);
149 Oid src_tsid,
Oid dst_tsid)
153 List *rlocatorlist = NULL;
179 srcrelid.
dbId = src_dboid;
180 dstrelid.
dbId = dst_dboid;
183 foreach(cell, rlocatorlist)
194 if (srcrlocator.
spcOid == src_tsid)
195 dstrlocator.
spcOid = dst_tsid;
199 dstrlocator.
dbOid = dst_dboid;
270 relid.
relId = RelationRelationId;
275 rlocator.
dbOid = dbid;
294 for (blkno = 0; blkno < nblocks; blkno++)
311 srcpath, rlocatorlist,
329 char *srcpath,
List *rlocatorlist,
375 rlocatorlist =
lappend(rlocatorlist, relinfo);
411 if (classForm->reltablespace == GLOBALTABLESPACE_OID ||
412 !RELKIND_HAS_STORAGE(classForm->relkind) ||
413 classForm->relpersistence == RELPERSISTENCE_TEMP)
421 relfilenumber = classForm->relfilenode;
428 elog(
ERROR,
"relation with OID %u does not have a valid relfilenumber",
440 relinfo->
reloid = classForm->oid;
443 Assert(classForm->relpersistence != RELPERSISTENCE_TEMP);
445 (classForm->relpersistence == RELPERSISTENCE_PERMANENT) ?
true :
false;
468 nbytes = strlen(PG_MAJORVERSION) + 1;
474 if (errno != EEXIST || !isRedo)
477 errmsg(
"could not create directory \"%s\": %m", dbpath)));
485 snprintf(versionfile,
sizeof(versionfile),
"%s/%s", dbpath,
"PG_VERSION");
488 if (
fd < 0 && errno == EEXIST && isRedo)
494 errmsg(
"could not create file \"%s\": %m", versionfile)));
506 errmsg(
"could not write to file \"%s\": %m", versionfile)));
514 errmsg(
"could not fsync file \"%s\": %m", versionfile)));
584 Oid srctablespace = spaceform->oid;
591 if (srctablespace == GLOBALTABLESPACE_OID)
604 if (srctablespace == src_tsid)
605 dsttablespace = dst_tsid;
607 dsttablespace = srctablespace;
622 xlrec.
db_id = dst_dboid;
686 int src_encoding = -1;
687 char *src_collate = NULL;
688 char *src_ctype = NULL;
689 char *src_locale = NULL;
690 char *src_icurules = NULL;
691 char src_locprovider =
'\0';
692 char *src_collversion = NULL;
694 bool src_hasloginevt =
false;
698 Oid src_deftablespace;
699 volatile Oid dst_deftablespace;
702 Datum new_record[Natts_pg_database] = {0};
703 bool new_record_nulls[Natts_pg_database] = {0};
707 DefElem *dtablespacename = NULL;
712 DefElem *dbuiltinlocale = NULL;
719 DefElem *dallowconnections = NULL;
724 char *dbowner = NULL;
725 const char *dbtemplate = NULL;
726 char *dbcollate = NULL;
727 char *dbctype = NULL;
728 const char *dblocale = NULL;
729 char *dbicurules = NULL;
730 char dblocprovider =
'\0';
733 bool dbistemplate =
false;
734 bool dballowconnections =
true;
736 char *dbcollversion = NULL;
747 if (strcmp(defel->
defname,
"tablespace") == 0)
751 dtablespacename = defel;
753 else if (strcmp(defel->
defname,
"owner") == 0)
759 else if (strcmp(defel->
defname,
"template") == 0)
765 else if (strcmp(defel->
defname,
"encoding") == 0)
771 else if (strcmp(defel->
defname,
"locale") == 0)
777 else if (strcmp(defel->
defname,
"builtin_locale") == 0)
781 dbuiltinlocale = defel;
783 else if (strcmp(defel->
defname,
"lc_collate") == 0)
789 else if (strcmp(defel->
defname,
"lc_ctype") == 0)
795 else if (strcmp(defel->
defname,
"icu_locale") == 0)
801 else if (strcmp(defel->
defname,
"icu_rules") == 0)
807 else if (strcmp(defel->
defname,
"locale_provider") == 0)
811 dlocprovider = defel;
813 else if (strcmp(defel->
defname,
"is_template") == 0)
819 else if (strcmp(defel->
defname,
"allow_connections") == 0)
821 if (dallowconnections)
823 dallowconnections = defel;
825 else if (strcmp(defel->
defname,
"connection_limit") == 0)
831 else if (strcmp(defel->
defname,
"collation_version") == 0)
835 dcollversion = defel;
837 else if (strcmp(defel->
defname,
"location") == 0)
840 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
841 errmsg(
"LOCATION is not supported anymore"),
842 errhint(
"Consider using tablespaces instead."),
845 else if (strcmp(defel->
defname,
"oid") == 0)
866 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE)),
869 else if (strcmp(defel->
defname,
"strategy") == 0)
877 (
errcode(ERRCODE_SYNTAX_ERROR),
882 if (downer && downer->
arg)
884 if (dtemplate && dtemplate->
arg)
886 if (dencoding && dencoding->
arg)
888 const char *encoding_name;
894 if (strcmp(encoding_name,
"") == 0 ||
897 (
errcode(ERRCODE_UNDEFINED_OBJECT),
898 errmsg(
"%d is not a valid encoding code",
908 (
errcode(ERRCODE_UNDEFINED_OBJECT),
909 errmsg(
"%s is not a valid encoding name",
914 if (dlocale && dlocale->
arg)
920 if (dbuiltinlocale && dbuiltinlocale->
arg)
922 if (dcollate && dcollate->
arg)
924 if (dctype && dctype->
arg)
926 if (diculocale && diculocale->
arg)
928 if (dicurules && dicurules->
arg)
930 if (dlocprovider && dlocprovider->
arg)
935 dblocprovider = COLLPROVIDER_BUILTIN;
937 dblocprovider = COLLPROVIDER_ICU;
939 dblocprovider = COLLPROVIDER_LIBC;
942 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
943 errmsg(
"unrecognized locale provider: %s",
946 if (distemplate && distemplate->
arg)
948 if (dallowconnections && dallowconnections->
arg)
950 if (dconnlimit && dconnlimit->
arg)
955 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
956 errmsg(
"invalid connection limit: %d", dbconnlimit)));
976 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
977 errmsg(
"permission denied to create database")));
991 dbtemplate =
"template1";
994 &src_dboid, &src_owner, &src_encoding,
995 &src_istemplate, &src_allowconn, &src_hasloginevt,
996 &src_frozenxid, &src_minmxid, &src_deftablespace,
997 &src_collate, &src_ctype, &src_locale, &src_icurules, &src_locprovider,
1000 (
errcode(ERRCODE_UNDEFINED_DATABASE),
1001 errmsg(
"template database \"%s\" does not exist",
1010 errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
1011 errmsg(
"cannot use invalid database \"%s\" as template", dbtemplate),
1012 errhint(
"Use DROP DATABASE to drop invalid databases."));
1018 if (!src_istemplate)
1022 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
1023 errmsg(
"permission denied to copy database \"%s\"",
1028 if (dstrategy && dstrategy->
arg)
1039 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1040 errmsg(
"invalid create database strategy \"%s\"", strategy),
1041 errhint(
"Valid strategies are \"wal_log\" and \"file_copy\".")));
1047 if (dbcollate == NULL)
1048 dbcollate = src_collate;
1049 if (dbctype == NULL)
1050 dbctype = src_ctype;
1051 if (dblocprovider ==
'\0')
1052 dblocprovider = src_locprovider;
1053 if (dblocale == NULL)
1054 dblocale = src_locale;
1055 if (dbicurules == NULL)
1056 dbicurules = src_icurules;
1061 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1067 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1068 errmsg(
"invalid LC_COLLATE locale name: \"%s\"", dbcollate),
1069 errhint(
"If the locale name is specific to ICU, use ICU_LOCALE.")));
1070 dbcollate = canonname;
1073 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1074 errmsg(
"invalid LC_CTYPE locale name: \"%s\"", dbctype),
1075 errhint(
"If the locale name is specific to ICU, use ICU_LOCALE.")));
1076 dbctype = canonname;
1081 if (dblocprovider != COLLPROVIDER_BUILTIN)
1085 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1086 errmsg(
"BUILTIN_LOCALE cannot be specified unless locale provider is builtin")));
1089 if (dblocprovider != COLLPROVIDER_ICU)
1093 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1094 errmsg(
"ICU locale cannot be specified unless locale provider is ICU")));
1098 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1099 errmsg(
"ICU rules cannot be specified unless locale provider is ICU")));
1103 if (dblocprovider == COLLPROVIDER_BUILTIN)
1111 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1112 errmsg(
"LOCALE or BUILTIN_LOCALE must be specified")));
1116 else if (dblocprovider == COLLPROVIDER_ICU)
1120 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1121 errmsg(
"encoding \"%s\" is not supported with ICU provider",
1130 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1131 errmsg(
"LOCALE or ICU_LOCALE must be specified")));
1143 if (langtag && strcmp(dblocale, langtag) != 0)
1146 (
errmsg(
"using standard form \"%s\" for ICU locale \"%s\"",
1147 langtag, dblocale)));
1157 if (dblocprovider == COLLPROVIDER_LIBC)
1170 if (strcmp(dbtemplate,
"template0") != 0)
1174 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1175 errmsg(
"new encoding (%s) is incompatible with the encoding of the template database (%s)",
1178 errhint(
"Use the same encoding as in the template database, or use template0 as template.")));
1180 if (strcmp(dbcollate, src_collate) != 0)
1182 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1183 errmsg(
"new collation (%s) is incompatible with the collation of the template database (%s)",
1184 dbcollate, src_collate),
1185 errhint(
"Use the same collation as in the template database, or use template0 as template.")));
1187 if (strcmp(dbctype, src_ctype) != 0)
1189 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1190 errmsg(
"new LC_CTYPE (%s) is incompatible with the LC_CTYPE of the template database (%s)",
1191 dbctype, src_ctype),
1192 errhint(
"Use the same LC_CTYPE as in the template database, or use template0 as template.")));
1194 if (dblocprovider != src_locprovider)
1196 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1197 errmsg(
"new locale provider (%s) does not match locale provider of the template database (%s)",
1198 collprovider_name(dblocprovider), collprovider_name(src_locprovider)),
1199 errhint(
"Use the same locale provider as in the template database, or use template0 as template.")));
1201 if (dblocprovider == COLLPROVIDER_ICU)
1208 if (strcmp(dblocale, src_locale) != 0)
1210 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1211 errmsg(
"new ICU locale (%s) is incompatible with the ICU locale of the template database (%s)",
1212 dblocale, src_locale),
1213 errhint(
"Use the same ICU locale as in the template database, or use template0 as template.")));
1218 val2 = src_icurules;
1221 if (strcmp(val1, val2) != 0)
1223 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1224 errmsg(
"new ICU collation rules (%s) are incompatible with the ICU collation rules of the template database (%s)",
1226 errhint(
"Use the same ICU collation rules as in the template database, or use template0 as template.")));
1242 if (src_collversion && !dcollversion)
1244 char *actual_versionstr;
1247 if (dblocprovider == COLLPROVIDER_LIBC)
1253 if (!actual_versionstr)
1255 (
errmsg(
"template database \"%s\" has a collation version, but no actual collation version could be determined",
1258 if (strcmp(actual_versionstr, src_collversion) != 0)
1260 (
errmsg(
"template database \"%s\" has a collation version mismatch",
1262 errdetail(
"The template database was created using collation version %s, "
1263 "but the operating system provides version %s.",
1264 src_collversion, actual_versionstr),
1265 errhint(
"Rebuild all objects in the template database that use the default collation and run "
1266 "ALTER DATABASE %s REFRESH COLLATION VERSION, "
1267 "or build PostgreSQL with the right library version.",
1271 if (dbcollversion == NULL)
1272 dbcollversion = src_collversion;
1279 if (dbcollversion == NULL)
1283 if (dblocprovider == COLLPROVIDER_LIBC)
1292 if (dtablespacename && dtablespacename->
arg)
1294 char *tablespacename;
1307 if (dst_deftablespace == GLOBALTABLESPACE_OID)
1309 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1310 errmsg(
"pg_global cannot be used as default tablespace")));
1324 if (dst_deftablespace != src_deftablespace)
1331 if (
stat(srcpath, &st) == 0 &&
1335 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1336 errmsg(
"cannot assign new default tablespace \"%s\"",
1338 errdetail(
"There is a conflict because database \"%s\" already has some tables in this tablespace.",
1346 dst_deftablespace = src_deftablespace;
1355 #ifdef ENFORCE_REGRESSION_TEST_NAME_RESTRICTIONS
1357 elog(
WARNING,
"databases created by regression test cases should have names including \"regression\"");
1367 (
errcode(ERRCODE_DUPLICATE_DATABASE),
1381 (
errcode(ERRCODE_OBJECT_IN_USE),
1382 errmsg(
"source database \"%s\" is being accessed by other users",
1401 if (existing_dbname != NULL)
1403 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE)),
1404 errmsg(
"database OID %u is already in use by database \"%s\"",
1405 dboid, existing_dbname));
1409 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE)),
1410 errmsg(
"data directory with the specified OID %u already exists", dboid));
1418 Anum_pg_database_oid);
1428 Assert((dblocprovider != COLLPROVIDER_LIBC && dblocale) ||
1429 (dblocprovider == COLLPROVIDER_LIBC && !dblocale));
1433 new_record[Anum_pg_database_datname - 1] =
1437 new_record[Anum_pg_database_datlocprovider - 1] =
CharGetDatum(dblocprovider);
1438 new_record[Anum_pg_database_datistemplate - 1] =
BoolGetDatum(dbistemplate);
1439 new_record[Anum_pg_database_datallowconn - 1] =
BoolGetDatum(dballowconnections);
1440 new_record[Anum_pg_database_dathasloginevt - 1] =
BoolGetDatum(src_hasloginevt);
1441 new_record[Anum_pg_database_datconnlimit - 1] =
Int32GetDatum(dbconnlimit);
1444 new_record[Anum_pg_database_dattablespace - 1] =
ObjectIdGetDatum(dst_deftablespace);
1450 new_record_nulls[Anum_pg_database_datlocale - 1] =
true;
1454 new_record_nulls[Anum_pg_database_daticurules - 1] =
true;
1458 new_record_nulls[Anum_pg_database_datcollversion - 1] =
true;
1465 new_record_nulls[Anum_pg_database_datacl - 1] =
true;
1468 new_record, new_record_nulls);
1574 if (!(ctype_encoding ==
encoding ||
1576 ctype_encoding == -1 ||
1582 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1583 errmsg(
"encoding \"%s\" does not match locale \"%s\"",
1586 errdetail(
"The chosen LC_CTYPE setting requires encoding \"%s\".",
1589 if (!(collate_encoding ==
encoding ||
1591 collate_encoding == -1 ||
1597 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1598 errmsg(
"encoding \"%s\" does not match locale \"%s\"",
1601 errdetail(
"The chosen LC_COLLATE setting requires encoding \"%s\".",
1669 &db_istemplate, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL))
1674 (
errcode(ERRCODE_UNDEFINED_DATABASE),
1682 (
errmsg(
"database \"%s\" does not exist, skipping",
1705 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1706 errmsg(
"cannot drop a template database")));
1711 (
errcode(ERRCODE_OBJECT_IN_USE),
1712 errmsg(
"cannot drop the currently open database")));
1724 (
errcode(ERRCODE_OBJECT_IN_USE),
1725 errmsg(
"database \"%s\" is used by an active logical replication slot",
1728 "There are %d active slots.",
1729 nslots_active, nslots_active)));
1740 (
errcode(ERRCODE_OBJECT_IN_USE),
1741 errmsg(
"database \"%s\" is being used by logical replication subscription",
1744 "There are %d subscriptions.",
1745 nsubscriptions, nsubscriptions)));
1763 (
errcode(ERRCODE_OBJECT_IN_USE),
1764 errmsg(
"database \"%s\" is being accessed by other users",
1791 elog(
ERROR,
"cache lookup failed for database %u", db_id);
1884 NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL))
1886 (
errcode(ERRCODE_UNDEFINED_DATABASE),
1887 errmsg(
"database \"%s\" does not exist", oldname)));
1897 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
1898 errmsg(
"permission denied to rename database")));
1904 #ifdef ENFORCE_REGRESSION_TEST_NAME_RESTRICTIONS
1905 if (strstr(newname,
"regression") == NULL)
1906 elog(
WARNING,
"databases created by regression test cases should have names including \"regression\"");
1915 (
errcode(ERRCODE_DUPLICATE_DATABASE),
1916 errmsg(
"database \"%s\" already exists", newname)));
1926 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1927 errmsg(
"current database cannot be renamed")));
1937 (
errcode(ERRCODE_OBJECT_IN_USE),
1938 errmsg(
"database \"%s\" is being accessed by other users",
1945 elog(
ERROR,
"cache lookup failed for database %u", db_id);
1994 NULL, NULL, NULL, NULL, &src_tblspcoid, NULL, NULL, NULL, NULL, NULL, NULL))
1996 (
errcode(ERRCODE_UNDEFINED_DATABASE),
2020 (
errcode(ERRCODE_OBJECT_IN_USE),
2021 errmsg(
"cannot change the tablespace of the currently open database")));
2040 if (dst_tblspcoid == GLOBALTABLESPACE_OID)
2042 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2043 errmsg(
"pg_global cannot be used as default tablespace")));
2048 if (src_tblspcoid == dst_tblspcoid)
2064 (
errcode(ERRCODE_OBJECT_IN_USE),
2065 errmsg(
"database \"%s\" is being accessed by other users",
2119 while ((xlde =
ReadDir(dstdir, dst_dbpath)) != NULL)
2121 if (strcmp(xlde->
d_name,
".") == 0 ||
2122 strcmp(xlde->
d_name,
"..") == 0)
2126 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
2127 errmsg(
"some relations of database \"%s\" are already in tablespace \"%s\"",
2129 errhint(
"You must move them back to the database's default tablespace before using this command.")));
2138 if (rmdir(dst_dbpath) != 0)
2139 elog(
ERROR,
"could not remove directory \"%s\": %m",
2154 Datum new_record[Natts_pg_database] = {0};
2155 bool new_record_nulls[Natts_pg_database] = {0};
2156 bool new_record_repl[Natts_pg_database] = {0};
2161 copydir(src_dbpath, dst_dbpath,
false);
2169 xlrec.
db_id = db_id;
2186 Anum_pg_database_datname,
2194 (
errcode(ERRCODE_UNDEFINED_DATABASE),
2197 new_record[Anum_pg_database_dattablespace - 1] =
ObjectIdGetDatum(dst_tblspcoid);
2198 new_record_repl[Anum_pg_database_dattablespace - 1] =
true;
2202 new_record_nulls, new_record_repl);
2254 if (!
rmtree(src_dbpath,
true))
2256 (
errmsg(
"some useless files may be left behind in old database directory \"%s\"",
2265 xlrec.
db_id = db_id;
2308 foreach(lc,
stmt->options)
2312 if (strcmp(opt->
defname,
"force") == 0)
2316 (
errcode(ERRCODE_SYNTAX_ERROR),
2317 errmsg(
"unrecognized DROP DATABASE option \"%s\"", opt->
defname),
2338 bool dbistemplate =
false;
2339 bool dballowconnections =
true;
2342 DefElem *dallowconnections = NULL;
2345 Datum new_record[Natts_pg_database] = {0};
2346 bool new_record_nulls[Natts_pg_database] = {0};
2347 bool new_record_repl[Natts_pg_database] = {0};
2354 if (strcmp(defel->
defname,
"is_template") == 0)
2358 distemplate = defel;
2360 else if (strcmp(defel->
defname,
"allow_connections") == 0)
2362 if (dallowconnections)
2364 dallowconnections = defel;
2366 else if (strcmp(defel->
defname,
"connection_limit") == 0)
2372 else if (strcmp(defel->
defname,
"tablespace") == 0)
2376 dtablespace = defel;
2380 (
errcode(ERRCODE_SYNTAX_ERROR),
2394 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
2395 errmsg(
"option \"%s\" cannot be specified with other options",
2404 if (distemplate && distemplate->
arg)
2406 if (dallowconnections && dallowconnections->
arg)
2408 if (dconnlimit && dconnlimit->
arg)
2413 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2414 errmsg(
"invalid connection limit: %d", dbconnlimit)));
2424 Anum_pg_database_datname,
2432 (
errcode(ERRCODE_UNDEFINED_DATABASE),
2433 errmsg(
"database \"%s\" does not exist",
stmt->dbname)));
2436 dboid = datform->oid;
2441 errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
2442 errmsg(
"cannot alter invalid database \"%s\"",
stmt->dbname),
2443 errhint(
"Use DROP DATABASE to drop invalid databases."));
2458 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2459 errmsg(
"cannot disallow connections for current database")));
2466 new_record[Anum_pg_database_datistemplate - 1] =
BoolGetDatum(dbistemplate);
2467 new_record_repl[Anum_pg_database_datistemplate - 1] =
true;
2469 if (dallowconnections)
2471 new_record[Anum_pg_database_datallowconn - 1] =
BoolGetDatum(dballowconnections);
2472 new_record_repl[Anum_pg_database_datallowconn - 1] =
true;
2476 new_record[Anum_pg_database_datconnlimit - 1] =
Int32GetDatum(dbconnlimit);
2477 new_record_repl[Anum_pg_database_datconnlimit - 1] =
true;
2481 new_record_nulls, new_record_repl);
2515 Anum_pg_database_datname,
2523 (
errcode(ERRCODE_UNDEFINED_DATABASE),
2524 errmsg(
"database \"%s\" does not exist",
stmt->dbname)));
2527 db_id = datForm->oid;
2536 if (datForm->datlocprovider == COLLPROVIDER_LIBC)
2540 elog(
ERROR,
"unexpected null in pg_database");
2546 elog(
ERROR,
"unexpected null in pg_database");
2553 if ((!oldversion && newversion) || (oldversion && !newversion))
2554 elog(
ERROR,
"invalid collation version change");
2555 else if (oldversion && newversion && strcmp(newversion, oldversion) != 0)
2557 bool nulls[Natts_pg_database] = {0};
2558 bool replaces[Natts_pg_database] = {0};
2562 (
errmsg(
"changing version from %s to %s",
2563 oldversion, newversion)));
2566 replaces[Anum_pg_database_datcollversion - 1] =
true;
2569 values, nulls, replaces);
2575 (
errmsg(
"version has not changed")));
2636 Anum_pg_database_datname,
2644 (
errcode(ERRCODE_UNDEFINED_DATABASE),
2648 db_id = datForm->oid;
2655 if (datForm->datdba != newOwnerId)
2657 Datum repl_val[Natts_pg_database];
2658 bool repl_null[Natts_pg_database] = {0};
2659 bool repl_repl[Natts_pg_database] = {0};
2684 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2685 errmsg(
"permission denied to change owner of database")));
2687 repl_repl[Anum_pg_database_datdba - 1] =
true;
2695 Anum_pg_database_datacl,
2701 datForm->datdba, newOwnerId);
2702 repl_repl[Anum_pg_database_datacl - 1] =
true;
2740 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2741 errmsg(
"database with OID %u does not exist", dbid)));
2774 Oid *dbIdP,
Oid *ownerIdP,
2775 int *encodingP,
bool *dbIsTemplateP,
bool *dbAllowConnP,
bool *dbHasLoginEvtP,
2777 Oid *dbTablespace,
char **dbCollate,
char **dbCtype,
char **dbLocale,
2779 char *dbLocProvider,
2780 char **dbCollversion)
2782 bool result =
false;
2807 Anum_pg_database_datname,
2853 *ownerIdP = dbform->datdba;
2856 *encodingP = dbform->encoding;
2859 *dbIsTemplateP = dbform->datistemplate;
2862 *dbHasLoginEvtP = dbform->dathasloginevt;
2865 *dbAllowConnP = dbform->datallowconn;
2868 *dbFrozenXidP = dbform->datfrozenxid;
2871 *dbMinMultiP = dbform->datminmxid;
2874 *dbTablespace = dbform->dattablespace;
2877 *dbLocProvider = dbform->datlocprovider;
2890 datum =
SysCacheGetAttr(DATABASEOID, tuple, Anum_pg_database_datlocale, &isnull);
2898 datum =
SysCacheGetAttr(DATABASEOID, tuple, Anum_pg_database_daticurules, &isnull);
2906 datum =
SysCacheGetAttr(DATABASEOID, tuple, Anum_pg_database_datcollversion, &isnull);
2908 *dbCollversion = NULL;
2933 bool result =
false;
2965 Oid *tablespace_ids;
2972 Oid dsttablespace = spcform->oid;
2977 if (dsttablespace == GLOBALTABLESPACE_OID)
2991 (
errmsg(
"some useless files may be left behind in old database directory \"%s\"",
3006 tablespace_ids = (
Oid *)
palloc(ntblspc *
sizeof(
Oid));
3008 foreach(cell, ltblspc)
3015 xlrec.
db_id = db_id;
3027 pfree(tablespace_ids);
3048 bool result =
false;
3058 Oid dsttablespace = spcform->oid;
3063 if (dsttablespace == GLOBALTABLESPACE_OID)
3091 if (notherbackends > 0 && npreparedxacts > 0)
3097 errdetail(
"There are %d other session(s) and %d prepared transaction(s) using the database.",
3098 notherbackends, npreparedxacts);
3099 else if (notherbackends > 0)
3101 "There are %d other sessions using the database.",
3106 "There are %d prepared transactions using the database.",
3133 Anum_pg_database_datname,
3152 (
errcode(ERRCODE_UNDEFINED_DATABASE),
3153 errmsg(
"database \"%s\" does not exist",
3208 elog(
ERROR,
"cache lookup failed for database %u", dboid);
3239 if (
stat(path, &st) == 0)
3242 if (only_tblspc && strstr(path,
"pg_tblspc/") == NULL)
3243 elog(
PANIC,
"requested to created invalid directory: %s", path);
3247 errmsg(
"missing directory \"%s\"", path));
3250 "creating missing directory: %s", path);
3254 errmsg(
"could not create missing directory \"%s\": %m", path));
3288 if (!
rmtree(dst_path,
true))
3291 (
errmsg(
"some useless files may be left behind in old database directory \"%s\"",
3299 parent_path =
pstrdup(dst_path);
3301 if (
stat(parent_path, &st) < 0)
3303 if (errno != ENOENT)
3305 errmsg(
"could not stat directory \"%s\": %m",
3319 if (
stat(src_path, &st) < 0 && errno == ENOENT)
3336 copydir(src_path, dst_path,
false);
3351 parent_path =
pstrdup(dbpath);
3402 if (!
rmtree(dst_path,
true))
3404 (
errmsg(
"some useless files may be left behind in old database directory \"%s\"",
3422 elog(
PANIC,
"dbase_redo: unknown op code %u", info);
Acl * aclnewowner(const Acl *old_acl, Oid oldOwnerId, Oid newOwnerId)
Oid get_role_oid(const char *rolname, bool missing_ok)
void check_can_set_role(Oid member, Oid role)
void aclcheck_error(AclResult aclerr, ObjectType objtype, const char *objectname)
AclResult object_aclcheck(Oid classid, Oid objectid, Oid roleid, AclMode mode)
bool object_ownercheck(Oid classid, Oid objectid, Oid roleid)
bool directory_is_empty(const char *path)
Oid get_tablespace_oid(const char *tablespacename, bool missing_ok)
bool allow_in_place_tablespaces
static Datum values[MAXATTR]
void DropDatabaseBuffers(Oid dbid)
BlockNumber BufferGetBlockNumber(Buffer buffer)
void CreateAndCopyRelationData(RelFileLocator src_rlocator, RelFileLocator dst_rlocator, bool permanent)
void UnlockReleaseBuffer(Buffer buffer)
void LockBuffer(Buffer buffer, int mode)
Buffer ReadBufferWithoutRelcache(RelFileLocator rlocator, ForkNumber forkNum, BlockNumber blockNum, ReadBufferMode mode, BufferAccessStrategy strategy, bool permanent)
void FlushDatabaseBuffers(Oid dbid)
#define BUFFER_LOCK_SHARE
static Page BufferGetPage(Buffer buffer)
static bool PageIsEmpty(Page page)
static Item PageGetItem(Page page, ItemId itemId)
static ItemId PageGetItemId(Page page, OffsetNumber offsetNumber)
static bool PageIsNew(Page page)
static OffsetNumber PageGetMaxOffsetNumber(Page page)
#define CStringGetTextDatum(s)
#define TextDatumGetCString(d)
#define Assert(condition)
TransactionId MultiXactId
#define OidIsValid(objectId)
Oid GetNewOidWithIndex(Relation relation, Oid indexId, AttrNumber oidcolumn)
void RequestCheckpoint(int flags)
void copydir(const char *fromdir, const char *todir, bool recurse)
static void remove_dbtablespaces(Oid db_id)
static void CreateDirAndVersionFile(char *dbpath, Oid dbid, Oid tsid, bool isRedo)
ObjectAddress AlterDatabaseRefreshColl(AlterDatabaseRefreshCollStmt *stmt)
bool have_createdb_privilege(void)
ObjectAddress RenameDatabase(const char *oldname, const char *newname)
char * get_database_name(Oid dbid)
Oid get_database_oid(const char *dbname, bool missing_ok)
static void movedb_failure_callback(int code, Datum arg)
static void CreateDatabaseUsingWalLog(Oid src_dboid, Oid dst_dboid, Oid src_tsid, Oid dst_tsid)
static List * ScanSourceDatabasePgClass(Oid tbid, Oid dbid, char *srcpath)
static void recovery_create_dbdir(char *path, bool only_tblspc)
ObjectAddress AlterDatabaseOwner(const char *dbname, Oid newOwnerId)
bool database_is_invalid_form(Form_pg_database datform)
Datum pg_database_collation_actual_version(PG_FUNCTION_ARGS)
static void movedb(const char *dbname, const char *tblspcname)
static List * ScanSourceDatabasePgClassPage(Page page, Buffer buf, Oid tbid, Oid dbid, char *srcpath, List *rlocatorlist, Snapshot snapshot)
void check_encoding_locale_matches(int encoding, const char *collate, const char *ctype)
Oid createdb(ParseState *pstate, const CreatedbStmt *stmt)
Oid AlterDatabase(ParseState *pstate, AlterDatabaseStmt *stmt, bool isTopLevel)
static int errdetail_busy_db(int notherbackends, int npreparedxacts)
static CreateDBRelInfo * ScanSourceDatabasePgClassTuple(HeapTupleData *tuple, Oid tbid, Oid dbid, char *srcpath)
static bool check_db_file_conflict(Oid db_id)
struct CreateDBRelInfo CreateDBRelInfo
void dbase_redo(XLogReaderState *record)
static void CreateDatabaseUsingFileCopy(Oid src_dboid, Oid dst_dboid, Oid src_tsid, Oid dst_tsid)
void DropDatabase(ParseState *pstate, DropdbStmt *stmt)
void dropdb(const char *dbname, bool missing_ok, bool force)
Oid AlterDatabaseSet(AlterDatabaseSetStmt *stmt)
static bool get_db_info(const char *name, LOCKMODE lockmode, Oid *dbIdP, Oid *ownerIdP, int *encodingP, bool *dbIsTemplateP, bool *dbAllowConnP, bool *dbHasLoginEvtP, TransactionId *dbFrozenXidP, MultiXactId *dbMinMultiP, Oid *dbTablespace, char **dbCollate, char **dbCtype, char **dbLocale, char **dbIcurules, char *dbLocProvider, char **dbCollversion)
static void createdb_failure_callback(int code, Datum arg)
bool database_is_invalid_oid(Oid dboid)
#define XLOG_DBASE_CREATE_WAL_LOG
#define MinSizeOfDbaseDropRec
#define XLOG_DBASE_CREATE_FILE_COPY
int32 defGetInt32(DefElem *def)
bool defGetBoolean(DefElem *def)
char * defGetString(DefElem *def)
void errorConflictingDefElem(DefElem *defel, ParseState *pstate)
Oid defGetObjectId(DefElem *def)
int errcode_for_file_access(void)
int errdetail(const char *fmt,...)
int errdetail_plural(const char *fmt_singular, const char *fmt_plural, unsigned long n,...)
int errhint(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
bool is_encoding_supported_by_icu(int encoding)
struct dirent * ReadDir(DIR *dir, const char *dirname)
int MakePGDirectory(const char *directoryName)
int CloseTransientFile(int fd)
void fsync_fname(const char *fname, bool isdir)
int data_sync_elevel(int elevel)
int OpenTransientFile(const char *fileName, int fileFlags)
DIR * AllocateDir(const char *dirname)
static char dstpath[MAXPGPATH]
#define DirectFunctionCall1(func, arg1)
#define PG_RETURN_TEXT_P(x)
BufferAccessStrategy GetAccessStrategy(BufferAccessStrategyType btype)
void systable_endscan(SysScanDesc sysscan)
HeapTuple systable_getnext(SysScanDesc sysscan)
SysScanDesc systable_beginscan(Relation heapRelation, Oid indexId, bool indexOK, Snapshot snapshot, int nkeys, ScanKey key)
bool allowSystemTableMods
void heap_inplace_update(Relation relation, HeapTuple tuple)
HeapTuple heap_getnext(TableScanDesc sscan, ScanDirection direction)
bool HeapTupleSatisfiesVisibility(HeapTuple htup, Snapshot snapshot, Buffer buffer)
HeapTuple heap_modify_tuple(HeapTuple tuple, TupleDesc tupleDesc, const Datum *replValues, const bool *replIsnull, const bool *doReplace)
HeapTuple heap_form_tuple(TupleDesc tupleDescriptor, const Datum *values, const bool *isnull)
void heap_freetuple(HeapTuple htup)
HeapTupleHeaderData * HeapTupleHeader
#define HeapTupleIsValid(tuple)
static Datum heap_getattr(HeapTuple tup, int attnum, TupleDesc tupleDesc, bool *isnull)
void CatalogTupleUpdate(Relation heapRel, ItemPointer otid, HeapTuple tup)
void CatalogTupleInsert(Relation heapRel, HeapTuple tup)
void CatalogTupleDelete(Relation heapRel, ItemPointer tid)
#define PG_ENSURE_ERROR_CLEANUP(cleanup_function, arg)
#define PG_END_ENSURE_ERROR_CLEANUP(cleanup_function, arg)
invalidindex index d is invalid
#define ItemIdGetLength(itemId)
#define ItemIdIsNormal(itemId)
#define ItemIdIsDead(itemId)
#define ItemIdIsUsed(itemId)
#define ItemIdIsRedirected(itemId)
static void ItemPointerSet(ItemPointerData *pointer, BlockNumber blockNumber, OffsetNumber offNum)
List * lappend(List *list, void *datum)
List * lappend_oid(List *list, Oid datum)
void list_free(List *list)
void list_free_deep(List *list)
void LockSharedObject(Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
void UnlockSharedObjectForSession(Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
void UnlockRelationId(LockRelId *relid, LOCKMODE lockmode)
void UnlockSharedObject(Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
void LockSharedObjectForSession(Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
void LockRelationId(LockRelId *relid, LOCKMODE lockmode)
#define AccessExclusiveLock
char * pstrdup(const char *in)
void pfree(void *pointer)
void ForgetDatabaseSyncRequests(Oid dbid)
#define START_CRIT_SECTION()
#define CHECK_FOR_INTERRUPTS()
#define END_CRIT_SECTION()
#define InvalidMultiXactId
void namestrcpy(Name name, const char *str)
Datum namein(PG_FUNCTION_ARGS)
#define IsA(nodeptr, _type_)
#define InvokeObjectPostCreateHook(classId, objectId, subId)
#define InvokeObjectPostAlterHook(classId, objectId, subId)
#define InvokeObjectDropHook(classId, objectId, subId)
#define ObjectAddressSet(addr, class_id, object_id)
#define OffsetNumberNext(offsetNumber)
#define FirstOffsetNumber
int parser_errposition(ParseState *pstate, int location)
FormData_pg_authid * Form_pg_authid
FormData_pg_class * Form_pg_class
FormData_pg_database * Form_pg_database
#define DATCONNLIMIT_INVALID_DB
#define DATCONNLIMIT_UNLIMITED
void DropSetting(Oid databaseid, Oid roleid)
void AlterSetting(Oid databaseid, Oid roleid, VariableSetStmt *setstmt)
static int list_length(const List *l)
void icu_validate_locale(const char *loc_str)
char * get_collation_actual_version(char collprovider, const char *collcollate)
char * icu_language_tag(const char *loc_str, int elevel)
const char * builtin_validate_locale(int encoding, const char *locale)
bool check_locale(int category, const char *locale, char **canonname)
void dropDatabaseDependencies(Oid databaseId)
void changeDependencyOnOwner(Oid classId, Oid objectId, Oid newOwnerId)
void copyTemplateDependencies(Oid templateDbId, Oid newDbId)
void recordDependencyOnOwner(Oid classId, Oid objectId, Oid owner)
void shdepLockAndCheckObject(Oid classId, Oid objectId)
int CountDBSubscriptions(Oid dbid)
FormData_pg_tablespace * Form_pg_tablespace
#define PG_VALID_BE_ENCODING(_enc)
#define pg_encoding_to_char
#define pg_valid_server_encoding
void pgstat_drop_database(Oid databaseid)
int pg_mkdir_p(char *path, int omode)
int pg_strcasecmp(const char *s1, const char *s2)
void get_parent_directory(char *path)
int pg_get_encoding_from_locale(const char *ctype, bool write_message)
static Datum PointerGetDatum(const void *X)
static Datum TransactionIdGetDatum(TransactionId X)
static Datum BoolGetDatum(bool X)
static Datum ObjectIdGetDatum(Oid X)
static Pointer DatumGetPointer(Datum X)
static Datum CStringGetDatum(const char *X)
static Datum Int32GetDatum(int32 X)
static Datum CharGetDatum(char X)
static int fd(const char *x, int i)
void TerminateOtherDBBackends(Oid databaseId)
bool CountOtherDBBackends(Oid databaseId, int *nbackends, int *nprepared)
#define INVALID_PROC_NUMBER
void WaitForProcSignalBarrier(uint64 generation)
uint64 EmitProcSignalBarrier(ProcSignalBarrierType type)
@ PROCSIGNAL_BARRIER_SMGRRELEASE
#define RelationGetDescr(relation)
RelFileNumber RelationMapOidToFilenumberForDatabase(char *dbpath, Oid relationId)
void RelationMapCopy(Oid dbid, Oid tsid, char *srcdbpath, char *dstdbpath)
char * GetDatabasePath(Oid dbOid, Oid spcOid)
#define InvalidRelFileNumber
#define RelFileNumberIsValid(relnumber)
bool rmtree(const char *path, bool rmtopdir)
const char * quote_identifier(const char *ident)
void ScanKeyInit(ScanKey entry, AttrNumber attributeNumber, StrategyNumber strategy, RegProcedure procedure, Datum argument)
void DeleteSharedSecurityLabel(Oid objectId, Oid classId)
bool ReplicationSlotsCountDBSlots(Oid dboid, int *nslots, int *nactive)
void ReplicationSlotsDropDBSlots(Oid dboid)
BlockNumber smgrnblocks(SMgrRelation reln, ForkNumber forknum)
SMgrRelation smgropen(RelFileLocator rlocator, ProcNumber backend)
void smgrclose(SMgrRelation reln)
Snapshot GetLatestSnapshot(void)
void PopActiveSnapshot(void)
void ResolveRecoveryConflictWithDatabase(Oid dbid)
#define BTEqualStrategyNumber
CreateDBStrategy strategy
Oid tablespace_ids[FLEXIBLE_ARRAY_MEMBER]
void ReleaseSysCache(HeapTuple tuple)
HeapTuple SearchSysCache1(int cacheId, Datum key1)
Datum SysCacheGetAttr(int cacheId, HeapTuple tup, AttrNumber attributeNumber, bool *isNull)
Datum SysCacheGetAttrNotNull(int cacheId, HeapTuple tup, AttrNumber attributeNumber)
#define SearchSysCacheCopy1(cacheId, key1)
void table_close(Relation relation, LOCKMODE lockmode)
Relation table_open(Oid relationId, LOCKMODE lockmode)
TableScanDesc table_beginscan_catalog(Relation relation, int nkeys, struct ScanKeyData *key)
static void table_endscan(TableScanDesc scan)
#define InvalidTransactionId
#define FirstNormalObjectId
text * cstring_to_text(const char *s)
static void pgstat_report_wait_start(uint32 wait_event_info)
static void pgstat_report_wait_end(void)
void PreventInTransactionBlock(bool isTopLevel, const char *stmtType)
void StartTransactionCommand(void)
void ForceSyncCommit(void)
void CommitTransactionCommand(void)
bool RecoveryInProgress(void)
XLogRecPtr XactLastRecEnd
void XLogFlush(XLogRecPtr record)
#define CHECKPOINT_FLUSH_ALL
#define CHECKPOINT_IMMEDIATE
void XLogRegisterData(char *data, uint32 len)
XLogRecPtr XLogInsert(RmgrId rmid, uint8 info)
void XLogBeginInsert(void)
#define XLogRecGetInfo(decoder)
#define XLogRecGetData(decoder)
#define XLogRecHasAnyBlockRefs(decoder)
#define XLR_SPECIAL_REL_UPDATE
void XLogDropDatabase(Oid dbid)