From ce4dedf75caacc2ba3180ea042d4f44e316ad6d1 Mon Sep 17 00:00:00 2001 From: Shveta Malik Date: Mon, 22 May 2023 08:36:49 +0530 Subject: [PATCH 1/8] Deparser for Table DDL commands and extending event triggers This patch constructs JSON blobs representing DDL commands, which can later be re-processed into plain strings by well-defined sprintf-like expansion. These JSON objects are intended to allow for machine-editing of the commands, by replacing certain nodes within the objects. Much of the information in the output blob actually comes from system catalogs, not from the command parse node, as it is impossible to reliably construct a fully-specified command (i.e. one not dependent on search_path etc) looking only at the parse node. This provides a base for logical replication of DDL statements. Currently, the patch has support for: CREATE/ALTER/DROP TABLE --- doc/src/sgml/event-trigger.sgml | 133 +- src/backend/commands/Makefile | 2 + src/backend/commands/ddldeparse.c | 2978 ++++++++++++++++++++++++++ src/backend/commands/ddljson.c | 708 ++++++ src/backend/commands/event_trigger.c | 1 + src/backend/commands/meson.build | 2 + src/backend/commands/sequence.c | 43 + src/backend/commands/tablecmds.c | 3 +- src/backend/parser/parse_utilcmd.c | 1 + src/backend/tcop/utility.c | 17 + src/backend/utils/adt/format_type.c | 108 +- src/backend/utils/adt/ruleutils.c | 32 +- src/include/catalog/pg_proc.dat | 7 + src/include/commands/sequence.h | 9 + src/include/commands/tablecmds.h | 2 + src/include/nodes/parsenodes.h | 1 + src/include/tcop/ddldeparse.h | 22 + src/include/tcop/utility.h | 2 + src/include/utils/builtins.h | 5 + src/include/utils/ruleutils.h | 10 + src/tools/pgindent/typedefs.list | 5 + 21 files changed, 4069 insertions(+), 22 deletions(-) create mode 100644 src/backend/commands/ddldeparse.c create mode 100644 src/backend/commands/ddljson.c create mode 100644 src/include/tcop/ddldeparse.h diff --git a/doc/src/sgml/event-trigger.sgml b/doc/src/sgml/event-trigger.sgml index 3b6a5361b3..a349433819 100644 --- a/doc/src/sgml/event-trigger.sgml +++ b/doc/src/sgml/event-trigger.sgml @@ -30,7 +30,8 @@ supported events are ddl_command_start, ddl_command_end, - table_rewrite + table_rewrite, + table_init_write and sql_drop. Support for additional events may be added in future releases. @@ -82,16 +83,22 @@ the table_rewrite event is not triggered by them. + + The table_init_write event occurs just after the creation of + table while execution of CREATE TABLE AS and + SELECT INTO commands. + + Event triggers (like other functions) cannot be executed in an aborted transaction. Thus, if a DDL command fails with an error, any associated ddl_command_end triggers will not be executed. Conversely, if a ddl_command_start trigger fails with an error, no further event triggers will fire, and no attempt will be made to execute - the command itself. Similarly, if a ddl_command_end trigger - fails with an error, the effects of the DDL statement will be rolled - back, just as they would be in any other case where the containing - transaction aborts. + the command itself. Similarly, if a ddl_command_end or + table_init_write trigger fails with an error, the effects + of the DDL statement will be rolled back, just as they would be in any other + case where the containing transaction aborts. @@ -138,6 +145,7 @@ + Command Tag @@ -145,6 +153,7 @@ ddl_&zwsp;command_&zwsp;end sql_&zwsp;drop table_&zwsp;rewrite + table_&zwsp;init_&zwsp;write Notes @@ -155,6 +164,7 @@ X - - + - @@ -163,6 +173,7 @@ X - - + - @@ -171,6 +182,7 @@ X - - + - @@ -179,6 +191,7 @@ X - - + - @@ -187,6 +200,7 @@ X - - + - @@ -195,6 +209,7 @@ X - - + - @@ -203,6 +218,7 @@ X - - + - @@ -211,6 +227,7 @@ X X - + - @@ -219,6 +236,7 @@ X - - + - @@ -227,6 +245,7 @@ X - - + - @@ -235,6 +254,7 @@ X - - + - @@ -243,6 +263,7 @@ X - X + - @@ -251,6 +272,7 @@ X - - + - @@ -259,6 +281,7 @@ X - - + - @@ -267,6 +290,7 @@ X - - + - @@ -275,6 +299,7 @@ X - - + - @@ -283,6 +308,7 @@ X - - + - @@ -291,6 +317,7 @@ X - - + - @@ -299,6 +326,7 @@ X - - + - @@ -307,6 +335,7 @@ X - - + - @@ -315,6 +344,7 @@ X - - + - @@ -323,6 +353,7 @@ X - - + - @@ -331,6 +362,7 @@ X - - + - @@ -339,6 +371,7 @@ X - - + - @@ -347,6 +380,7 @@ X X X + - @@ -355,6 +389,7 @@ X - - + - @@ -363,6 +398,7 @@ X - - + - @@ -371,6 +407,7 @@ X - - + - @@ -379,6 +416,7 @@ X - - + - @@ -387,6 +425,7 @@ X - - + - @@ -395,6 +434,7 @@ X - X + - @@ -403,6 +443,7 @@ X - - + - @@ -411,6 +452,7 @@ X - - + - @@ -419,6 +461,7 @@ X - - + - Only for local objects @@ -427,6 +470,7 @@ X - - + - @@ -435,6 +479,7 @@ X - - + - @@ -443,6 +488,7 @@ X - - + - @@ -451,6 +497,7 @@ X - - + - @@ -459,6 +506,7 @@ X - - + - @@ -467,6 +515,7 @@ X - - + - @@ -475,6 +524,7 @@ X - - + - @@ -483,6 +533,7 @@ X - - + - @@ -491,6 +542,7 @@ X - - + - @@ -499,6 +551,7 @@ X - - + - @@ -507,6 +560,7 @@ X - - + - @@ -515,6 +569,7 @@ X - - + - @@ -523,6 +578,7 @@ X - - + - @@ -531,6 +587,7 @@ X - - + - @@ -539,6 +596,7 @@ X - - + - @@ -547,6 +605,7 @@ X - - + - @@ -555,6 +614,7 @@ X - - + - @@ -563,6 +623,7 @@ X - - + - @@ -571,6 +632,7 @@ X - - + - @@ -579,6 +641,7 @@ X - - + - @@ -587,6 +650,7 @@ X - - + - @@ -595,6 +659,7 @@ X - - + - @@ -603,6 +668,7 @@ X - - + - @@ -611,6 +677,7 @@ X - - + - @@ -619,6 +686,7 @@ X - - + - @@ -627,6 +695,7 @@ X - - + - @@ -635,6 +704,7 @@ X - - + X @@ -643,6 +713,7 @@ X - - + - @@ -651,6 +722,7 @@ X - - + - @@ -659,6 +731,7 @@ X - - + - @@ -667,6 +740,7 @@ X - - + - @@ -675,6 +749,7 @@ X - - + - @@ -683,6 +758,7 @@ X - - + - @@ -691,6 +767,7 @@ X - - + - @@ -699,6 +776,7 @@ X - - + - @@ -707,6 +785,7 @@ X X - + - @@ -715,6 +794,7 @@ X X - + - @@ -723,6 +803,7 @@ X X - + - @@ -731,6 +812,7 @@ X X - + - @@ -739,6 +821,7 @@ X X - + - @@ -747,6 +830,7 @@ X X - + - @@ -755,6 +839,7 @@ X X - + - @@ -763,6 +848,7 @@ X X - + - @@ -771,6 +857,7 @@ X X - + - @@ -779,6 +866,7 @@ X X - + - @@ -787,6 +875,7 @@ X X - + - @@ -795,6 +884,7 @@ X X - + - @@ -803,6 +893,7 @@ X X - + - @@ -811,6 +902,7 @@ X X - + - @@ -819,6 +911,7 @@ X X - + - @@ -827,6 +920,7 @@ X X - + - @@ -835,6 +929,7 @@ X X - + - @@ -843,6 +938,7 @@ X X - + - @@ -851,6 +947,7 @@ X X - + - @@ -859,6 +956,7 @@ X X - + - @@ -867,6 +965,7 @@ X X - + - @@ -875,6 +974,7 @@ X X - + - @@ -883,6 +983,7 @@ X X - + - @@ -891,6 +992,7 @@ X X - + - @@ -899,6 +1001,7 @@ X X - + - @@ -907,6 +1010,7 @@ X X - + - @@ -915,6 +1019,7 @@ X X - + - @@ -923,6 +1028,7 @@ X X - + - @@ -931,6 +1037,7 @@ X X - + - @@ -939,6 +1046,7 @@ X X - + - @@ -947,6 +1055,7 @@ X X - + - @@ -955,6 +1064,7 @@ X X - + - @@ -963,6 +1073,7 @@ X X - + - @@ -971,6 +1082,7 @@ X X - + - @@ -979,6 +1091,7 @@ X X - + - @@ -987,6 +1100,7 @@ X X - + - @@ -995,6 +1109,7 @@ X - - + - Only for local objects @@ -1003,6 +1118,7 @@ X - - + - @@ -1011,6 +1127,7 @@ X - - + - @@ -1019,6 +1136,7 @@ X - - + - Only for local objects @@ -1027,6 +1145,7 @@ X - - + - Only for local objects @@ -1035,6 +1154,7 @@ X - - + X @@ -1118,7 +1238,8 @@ typedef struct EventTriggerData Describes the event for which the function is called, one of "ddl_command_start", "ddl_command_end", - "sql_drop", "table_rewrite". + "sql_drop", "table_rewrite", + "table_init_write". See for the meaning of these events. diff --git a/src/backend/commands/Makefile b/src/backend/commands/Makefile index 48f7348f91..076ac4eb31 100644 --- a/src/backend/commands/Makefile +++ b/src/backend/commands/Makefile @@ -29,6 +29,8 @@ OBJS = \ copyto.o \ createas.o \ dbcommands.o \ + ddldeparse.o \ + ddljson.o \ define.o \ discard.o \ dropcmds.o \ diff --git a/src/backend/commands/ddldeparse.c b/src/backend/commands/ddldeparse.c new file mode 100644 index 0000000000..3eeaeee716 --- /dev/null +++ b/src/backend/commands/ddldeparse.c @@ -0,0 +1,2978 @@ +/*------------------------------------------------------------------------- + * + * ddldeparse.c + * Functions to convert utility commands to machine-parseable + * representation + * + * Portions Copyright (c) 1996-2023, PostgreSQL Global Development Group + * Portions Copyright (c) 1994, Regents of the University of California + * + * NOTES + * + * This is intended to provide JSON blobs representing DDL commands, which can + * later be re-processed into plain strings by well-defined sprintf-like + * expansion. These JSON objects are intended to allow for machine-editing of + * the commands, by replacing certain nodes within the objects. + * + * Much of the information in the output blob actually comes from system + * catalogs, not from the command parse node, as it is impossible to reliably + * construct a fully-specified command (i.e. one not dependent on search_path + * etc) looking only at the parse node. + * + * Deparse object tree is created by using: + * a) new_objtree("know contents") where the complete tree content is known or + * the initial tree content is known. + * b) new_objtree("") for the syntax where the object tree will be derived + * based on some conditional checks. + * c) new_objtree_VA where the complete tree can be derived using some fixed + * content or by using the initial tree content along with some variable + * arguments. + * + * IDENTIFICATION + * src/backend/commands/ddldeparse.c + * + *------------------------------------------------------------------------- + */ +#include "postgres.h" + +#include "access/amapi.h" +#include "access/relation.h" +#include "access/table.h" +#include "catalog/namespace.h" +#include "catalog/pg_collation.h" +#include "catalog/pg_constraint.h" +#include "catalog/pg_depend.h" +#include "catalog/pg_inherits.h" +#include "catalog/pg_namespace.h" +#include "catalog/pg_proc.h" +#include "catalog/pg_type.h" +#include "commands/defrem.h" +#include "commands/sequence.h" +#include "commands/tablespace.h" +#include "commands/tablecmds.h" +#include "funcapi.h" +#include "optimizer/optimizer.h" +#include "rewrite/rewriteHandler.h" +#include "tcop/ddldeparse.h" +#include "tcop/utility.h" +#include "utils/builtins.h" +#include "utils/fmgroids.h" +#include "utils/guc.h" +#include "utils/jsonb.h" +#include "utils/lsyscache.h" +#include "utils/rel.h" +#include "utils/ruleutils.h" +#include "utils/syscache.h" + +/* Estimated length of the generated jsonb string */ +#define JSONB_ESTIMATED_LEN 128 + +/* + * Before they are turned into JSONB representation, each command is + * represented as an object tree, using the structs below. + */ +typedef enum +{ + ObjTypeNull, + ObjTypeBool, + ObjTypeString, + ObjTypeArray, + ObjTypeInteger, + ObjTypeObject +} ObjType; + +/* + * Represent the command as an object tree. + */ +typedef struct ObjTree +{ + slist_head params; /* Object tree parameters */ + int numParams; /* Number of parameters in the object tree */ + StringInfo fmtinfo; /* Format string of the ObjTree */ + bool present; /* Indicates if boolean value should be stored */ +} ObjTree; + +/* + * An element of an object tree (ObjTree). + */ +typedef struct ObjElem +{ + char *name; /* Name of object element */ + ObjType objtype; /* Object type */ + + union + { + bool boolean; + char *string; + int64 integer; + float8 flt; + ObjTree *object; + List *array; + } value; /* Store the object value based on the object + * type */ + slist_node node; /* Used in converting back to ObjElem + * structure */ +} ObjElem; + +static void append_array_object(ObjTree *tree, char *object_name, List *array); +static void append_bool_object(ObjTree *tree, char *object_name, bool value); +static void append_object_object(ObjTree *tree, char *object_name, ObjTree *value); +static void append_premade_object(ObjTree *tree, ObjElem *elem); +static void append_string_object(ObjTree *tree, char *object_name, + char *value); +static ObjElem *new_object(ObjType type, char *name); +static ObjTree *new_objtree_for_qualname_id(Oid classId, Oid objectId); +static ObjElem *new_object_object(ObjTree *value); +static ObjTree *new_objtree_VA(char *fmt, int numobjs, ...); +static JsonbValue *objtree_to_jsonb_rec(ObjTree *tree, JsonbParseState *state); +static char *RelationGetColumnDefault(Relation rel, AttrNumber attno, + List *dpcontext); + +static ObjTree *deparse_ColumnDef(Relation relation, List *dpcontext, bool composite, + ColumnDef *coldef, bool is_alter); +static ObjTree *deparse_ColumnIdentity(Oid seqrelid, char identity, bool alter_table); +static ObjTree *deparse_ColumnSetOptions(AlterTableCmd *subcmd); + +static ObjTree *deparse_DefElem(DefElem *elem, bool is_reset); +static ObjTree *deparse_OnCommitClause(OnCommitAction option); +static ObjTree *deparse_RelSetOptions(AlterTableCmd *subcmd); + +static inline ObjElem *deparse_Seq_Cache(Form_pg_sequence seqdata, bool alter_table); +static inline ObjElem *deparse_Seq_Cycle(Form_pg_sequence seqdata, bool alter_table); +static inline ObjElem *deparse_Seq_IncrementBy(Form_pg_sequence seqdata, bool alter_table); +static inline ObjElem *deparse_Seq_Minvalue(Form_pg_sequence seqdata, bool alter_table); +static inline ObjElem *deparse_Seq_Maxvalue(Form_pg_sequence seqdata, bool alter_table); +static inline ObjElem *deparse_Seq_Restart(int64 last_value); +static inline ObjElem *deparse_Seq_Startwith(Form_pg_sequence seqdata, bool alter_table); +static inline ObjElem *deparse_Seq_As(Form_pg_sequence seqdata); + +static List *deparse_InhRelations(Oid objectId); +static List *deparse_TableElements(Relation relation, List *tableElements, List *dpcontext, + bool typed, bool composite); + +/* + * Append present as false to a tree. + */ +static void +append_not_present(ObjTree *tree) +{ + append_bool_object(tree, "present", false); +} + +/* + * Append an array parameter to a tree. + */ +static void +append_array_object(ObjTree *tree, char *object_name, List *array) +{ + ObjElem *param; + + param = new_object(ObjTypeArray, object_name); + param->value.array = array; + append_premade_object(tree, param); +} + +/* + * Append a boolean parameter to a tree. + */ +static void +append_bool_object(ObjTree *tree, char *object_name, bool value) +{ + ObjElem *param; + + Assert(object_name); + + /* + * Check if the format string is 'present' and if yes, store the boolean + * value + */ + if (strcmp(object_name, "present") == 0) + tree->present = value; + + param = new_object(ObjTypeBool, object_name); + param->value.boolean = value; + append_premade_object(tree, param); +} + +/* + * Append an object parameter to a tree. + */ +static void +append_object_object(ObjTree *tree, char *object_name, ObjTree *value) +{ + ObjElem *param; + + param = new_object(ObjTypeObject, object_name); + param->value.object = value; + append_premade_object(tree, param); +} + +/* + * Append a preallocated parameter to a tree. + */ +static inline void +append_premade_object(ObjTree *tree, ObjElem *elem) +{ + slist_push_head(&tree->params, &elem->node); + tree->numParams++; +} + +/* + * Append a string parameter to a tree. + */ +static void +append_string_object(ObjTree *tree, char *object_name, char *value) +{ + ObjElem *param; + + param = new_object(ObjTypeString, object_name); + param->value.string = value; + append_premade_object(tree, param); +} + +/* + * Return the string representation of the given RELPERSISTENCE value. + */ +static char * +get_persistence_str(char persistence) +{ + switch (persistence) + { + case RELPERSISTENCE_TEMP: + return "TEMPORARY"; + case RELPERSISTENCE_UNLOGGED: + return "UNLOGGED"; + case RELPERSISTENCE_PERMANENT: + return ""; + default: + elog(ERROR, "unexpected persistence marking %c", persistence); + return ""; /* make compiler happy */ + } +} + +/* + * Allocate a new parameter. + */ +static ObjElem * +new_object(ObjType type, char *name) +{ + ObjElem *param; + + param = palloc0(sizeof(ObjElem)); + param->name = name; + param->objtype = type; + + return param; +} + +/* + * Allocate a new object parameter. + */ +static ObjElem * +new_object_object(ObjTree *value) +{ + ObjElem *param; + + param = new_object(ObjTypeObject, NULL); + param->value.object = value; + + return param; +} + +/* + * Allocate a new object tree to store parameter values. + */ +static ObjTree * +new_objtree(char *fmt) +{ + ObjTree *objtree; + + objtree = palloc0(sizeof(ObjTree)); + objtree->present = true; + slist_init(&objtree->params); + + if (fmt) + { + objtree->fmtinfo = makeStringInfo(); + appendStringInfoString(objtree->fmtinfo, fmt); + } + + return objtree; +} + +/* + * A helper routine to set up %{}D and %{}O elements. + * + * Elements "schema_name" and "obj_name" are set. If the namespace OID + * corresponds to a temp schema, that's set to "pg_temp". + * + * The difference between those two element types is whether the obj_name will + * be quoted as an identifier or not, which is not something that this routine + * concerns itself with; that will be up to the expand function. + */ +static ObjTree * +new_objtree_for_qualname(Oid nspid, char *name) +{ + ObjTree *qualified; + char *namespace; + + if (isAnyTempNamespace(nspid)) + namespace = pstrdup("pg_temp"); + else + namespace = get_namespace_name(nspid); + + qualified = new_objtree_VA(NULL, 2, + "schemaname", ObjTypeString, namespace, + "objname", ObjTypeString, pstrdup(name)); + + return qualified; +} + +/* + * A helper routine to set up %{}D and %{}O elements, with the object specified + * by classId/objId. + */ +static ObjTree * +new_objtree_for_qualname_id(Oid classId, Oid objectId) +{ + ObjTree *qualified; + Relation catalog; + HeapTuple catobj; + Datum obj_nsp; + Datum obj_name; + AttrNumber Anum_name; + AttrNumber Anum_namespace; + AttrNumber Anum_oid = get_object_attnum_oid(classId); + bool isnull; + + catalog = table_open(classId, AccessShareLock); + + catobj = get_catalog_object_by_oid(catalog, Anum_oid, objectId); + if (!catobj) + elog(ERROR, "cache lookup failed for object with OID %u of catalog \"%s\"", + objectId, RelationGetRelationName(catalog)); + Anum_name = get_object_attnum_name(classId); + Anum_namespace = get_object_attnum_namespace(classId); + + obj_nsp = heap_getattr(catobj, Anum_namespace, RelationGetDescr(catalog), + &isnull); + if (isnull) + elog(ERROR, "null namespace for object %u", objectId); + + obj_name = heap_getattr(catobj, Anum_name, RelationGetDescr(catalog), + &isnull); + if (isnull) + elog(ERROR, "null attribute name for object %u", objectId); + + qualified = new_objtree_for_qualname(DatumGetObjectId(obj_nsp), + NameStr(*DatumGetName(obj_name))); + table_close(catalog, AccessShareLock); + + return qualified; +} + +/* + * A helper routine to setup %{}T elements. + */ +static ObjTree * +new_objtree_for_type(Oid typeId, int32 typmod) +{ + Oid typnspid; + char *type_nsp; + char *type_name = NULL; + char *typmodstr; + bool type_array; + + format_type_detailed(typeId, typmod, + &typnspid, &type_name, &typmodstr, &type_array); + + if (OidIsValid(typnspid)) + type_nsp = get_namespace_name_or_temp(typnspid); + else + type_nsp = pstrdup(""); + + return new_objtree_VA(NULL, 4, + "schemaname", ObjTypeString, type_nsp, + "typename", ObjTypeString, type_name, + "typmod", ObjTypeString, typmodstr, + "typarray", ObjTypeBool, type_array); +} + +/* + * Allocate a new object tree to store parameter values -- varargs version. + * + * The "fmt" argument is used to append as a "fmt" element in the output blob. + * numobjs indicates the number of extra elements to append; for each one, a + * name (string), type (from the ObjType enum) and value must be supplied. The + * value must match the type given; for instance, ObjTypeInteger requires an + * int64, ObjTypeString requires a char *, ObjTypeArray requires a list (of + * ObjElem), ObjTypeObject requires an ObjTree, and so on. Each element type * + * must match the conversion specifier given in the format string, as described + * in ddl_deparse_expand_command, q.v. + * + * Note we don't have the luxury of sprintf-like compiler warnings for + * malformed argument lists. + */ +static ObjTree * +new_objtree_VA(char *fmt, int numobjs, ...) +{ + ObjTree *tree; + va_list args; + int i; + + /* Set up the toplevel object and its "fmt" */ + tree = new_objtree(fmt); + + /* And process the given varargs */ + va_start(args, numobjs); + for (i = 0; i < numobjs; i++) + { + char *name; + ObjType type; + ObjElem *elem; + + name = va_arg(args, char *); + type = va_arg(args, ObjType); + elem = new_object(type, NULL); + + /* + * For all param types other than ObjTypeNull, there must be a value in + * the varargs. Fetch it and add the fully formed subobject into the + * main object. + */ + switch (type) + { + case ObjTypeNull: + /* Null params don't have a value (obviously) */ + break; + case ObjTypeBool: + elem->value.boolean = va_arg(args, int); + break; + case ObjTypeString: + elem->value.string = va_arg(args, char *); + break; + case ObjTypeArray: + elem->value.array = va_arg(args, List *); + break; + case ObjTypeInteger: + elem->value.integer = va_arg(args, int); + break; + case ObjTypeObject: + elem->value.object = va_arg(args, ObjTree *); + break; + default: + elog(ERROR, "invalid ObjTree element type %d", type); + } + + elem->name = name; + append_premade_object(tree, elem); + } + + va_end(args); + return tree; +} + +/* + * Process the pre-built format string from the ObjTree into the output parse + * state. + */ +static void +objtree_fmt_to_jsonb_element(JsonbParseState *state, ObjTree *tree) +{ + JsonbValue key; + JsonbValue val; + + if (tree->fmtinfo == NULL) + return; + + /* Push the key first */ + key.type = jbvString; + key.val.string.val = "fmt"; + key.val.string.len = strlen(key.val.string.val); + pushJsonbValue(&state, WJB_KEY, &key); + + /* Then process the pre-built format string */ + val.type = jbvString; + val.val.string.len = tree->fmtinfo->len; + val.val.string.val = tree->fmtinfo->data; + pushJsonbValue(&state, WJB_VALUE, &val); +} + +/* + * Create a JSONB representation from an ObjTree. + */ +static Jsonb * +objtree_to_jsonb(ObjTree *tree) +{ + JsonbValue *value; + + value = objtree_to_jsonb_rec(tree, NULL); + return JsonbValueToJsonb(value); +} + +/* + * Helper for objtree_to_jsonb_rec: process an individual element from an object or + * an array into the output parse state. + */ +static void +objtree_to_jsonb_element(JsonbParseState *state, ObjElem *object, + JsonbIteratorToken elem_token) +{ + JsonbValue val; + + switch (object->objtype) + { + case ObjTypeNull: + val.type = jbvNull; + pushJsonbValue(&state, elem_token, &val); + break; + + case ObjTypeString: + val.type = jbvString; + val.val.string.len = strlen(object->value.string); + val.val.string.val = object->value.string; + pushJsonbValue(&state, elem_token, &val); + break; + + case ObjTypeInteger: + val.type = jbvNumeric; + val.val.numeric = (Numeric) + DatumGetNumeric(DirectFunctionCall1(int8_numeric, + object->value.integer)); + pushJsonbValue(&state, elem_token, &val); + break; + + case ObjTypeBool: + val.type = jbvBool; + val.val.boolean = object->value.boolean; + pushJsonbValue(&state, elem_token, &val); + break; + + case ObjTypeObject: + /* Recursively add the object into the existing parse state */ + objtree_to_jsonb_rec(object->value.object, state); + break; + + case ObjTypeArray: + { + ListCell *cell; + + pushJsonbValue(&state, WJB_BEGIN_ARRAY, NULL); + foreach(cell, object->value.array) + { + ObjElem *elem = lfirst(cell); + + objtree_to_jsonb_element(state, elem, WJB_ELEM); + } + pushJsonbValue(&state, WJB_END_ARRAY, NULL); + } + break; + + default: + elog(ERROR, "unrecognized object type %d", object->objtype); + break; + } +} + +/* + * Recursive helper for objtree_to_jsonb. + */ +static JsonbValue * +objtree_to_jsonb_rec(ObjTree *tree, JsonbParseState *state) +{ + slist_iter iter; + + pushJsonbValue(&state, WJB_BEGIN_OBJECT, NULL); + + objtree_fmt_to_jsonb_element(state, tree); + + slist_foreach(iter, &tree->params) + { + ObjElem *object = slist_container(ObjElem, node, iter.cur); + JsonbValue key; + + /* Push the key first */ + key.type = jbvString; + key.val.string.len = strlen(object->name); + key.val.string.val = object->name; + pushJsonbValue(&state, WJB_KEY, &key); + + /* Then process the value according to its type */ + objtree_to_jsonb_element(state, object, WJB_VALUE); + } + + return pushJsonbValue(&state, WJB_END_OBJECT, NULL); +} + +/* + * Subroutine for CREATE TABLE deparsing. + * + * Given a table OID, obtain its constraints and append them to the given + * elements list. The updated list is returned. + * + * This works for typed tables, regular tables. + * + * Note that CONSTRAINT_FOREIGN constraints are always ignored. + */ +static List * +obtainConstraints(List *elements, Oid relationId) +{ + Relation conRel; + ScanKeyData key; + SysScanDesc scan; + HeapTuple tuple; + ObjTree *constr; + + Assert(OidIsValid(relationId)); + + /* + * Scan pg_constraint to fetch all constraints linked to the given + * relation. + */ + conRel = table_open(ConstraintRelationId, AccessShareLock); + ScanKeyInit(&key, Anum_pg_constraint_conrelid, BTEqualStrategyNumber, + F_OIDEQ, ObjectIdGetDatum(relationId)); + scan = systable_beginscan(conRel, ConstraintRelidTypidNameIndexId, true, + NULL, 1, &key); + + /* + * For each constraint, add a node to the list of table elements. In + * these nodes we include not only the printable information ("fmt"), but + * also separate attributes to indicate the type of constraint, for + * automatic processing. + */ + while (HeapTupleIsValid(tuple = systable_getnext(scan))) + { + Form_pg_constraint constrForm; + char *contype; + ObjTree *tmp_obj; + bool has_tblspc; + + constrForm = (Form_pg_constraint) GETSTRUCT(tuple); + + switch (constrForm->contype) + { + case CONSTRAINT_CHECK: + contype = "check"; + break; + case CONSTRAINT_FOREIGN: + continue; /* not here */ + case CONSTRAINT_PRIMARY: + contype = "primary key"; + break; + case CONSTRAINT_UNIQUE: + contype = "unique"; + break; + case CONSTRAINT_EXCLUSION: + contype = "exclusion"; + break; + default: + elog(ERROR, "unrecognized constraint type"); + } + + /* + * "type" and "contype" are not part of the printable output, but are + * useful to programmatically distinguish these from columns and among + * different constraint types. + * + * XXX it might be useful to also list the column names in a PK, etc. + */ + constr = new_objtree_VA("CONSTRAINT %{name}I %{definition}s %{tablespace}s", 4, + "type", ObjTypeString, "constraint", + "contype", ObjTypeString, contype, + "name", ObjTypeString, NameStr(constrForm->conname), + "definition", ObjTypeString, + pg_get_constraintdef_string(constrForm->oid)); + + tmp_obj = new_objtree("USING INDEX TABLESPACE %{tablespace}I"); + if (constrForm->conindid && + (constrForm->contype == CONSTRAINT_PRIMARY || + constrForm->contype == CONSTRAINT_UNIQUE || + constrForm->contype == CONSTRAINT_EXCLUSION)) + { + Oid tblspc = get_rel_tablespace(constrForm->conindid); + + if (OidIsValid(tblspc)) + { + char *tblspcname = get_tablespace_name(tblspc); + + if (!tblspcname) + { + elog(ERROR, "cache lookup failed for tablespace %u", + tblspc); + } + + append_string_object(tmp_obj, "tablespace", tblspcname); + has_tblspc = true; + } + } + + if (!has_tblspc) + append_not_present(tmp_obj); + + append_object_object(constr, "tablespace", tmp_obj); + + elements = lappend(elements, new_object_object(constr)); + } + + systable_endscan(scan); + table_close(conRel, AccessShareLock); + + return elements; +} + +/* + * Obtain the deparsed default value for the given column of the given table. + * + * Caller must have set a correct deparse context and must ensure that the + * passed attribute has a default value. + */ +static char * +RelationGetColumnDefault(Relation rel, AttrNumber attno, List *dpcontext) +{ + Node *defval; + char *defstr; + + defval = build_column_default(rel, attno); + Assert(defval != NULL); + + defstr = deparse_expression(defval, dpcontext, false, false); + + return defstr; +} + +/* + * Obtain the deparsed partition bound expression for the given table. + */ +static char * +RelationGetPartitionBound(Oid relid) +{ + Datum deparsed; + Datum boundDatum; + bool isnull; + HeapTuple tuple; + + tuple = SearchSysCache1(RELOID, relid); + if (!HeapTupleIsValid(tuple)) + elog(ERROR, "cache lookup failed for relation with OID %u", relid); + + boundDatum = SysCacheGetAttr(RELOID, tuple, + Anum_pg_class_relpartbound, + &isnull); + + deparsed = DirectFunctionCall2(pg_get_expr, + CStringGetTextDatum(TextDatumGetCString(boundDatum)), + relid); + + ReleaseSysCache(tuple); + + return TextDatumGetCString(deparsed); +} + +/* + * Deparse a ColumnDef node within a regular (non-typed) table creation. + * + * NOT NULL constraints in the column definition are emitted directly in the + * column definition by this routine; other constraints must be emitted + * elsewhere (the info in the parse node is incomplete anyway). + */ +static ObjTree * +deparse_ColumnDef(Relation relation, List *dpcontext, bool composite, + ColumnDef *coldef, bool is_alter) +{ + ObjTree *ret; + ObjTree *tmp_obj; + Oid relid = RelationGetRelid(relation); + HeapTuple attrTup; + Form_pg_attribute attrForm; + Oid typid; + int32 typmod; + Oid typcollation; + bool saw_notnull; + ListCell *cell; + + /* + * Inherited columns without local definitions must not be emitted. + * + * XXX maybe it is useful to have them with "present = false" or some + * such? + */ + if (!coldef->is_local) + return NULL; + + attrTup = SearchSysCacheAttName(relid, coldef->colname); + if (!HeapTupleIsValid(attrTup)) + elog(ERROR, "could not find cache entry for column \"%s\" of relation %u", + coldef->colname, relid); + attrForm = (Form_pg_attribute) GETSTRUCT(attrTup); + + get_atttypetypmodcoll(relid, attrForm->attnum, + &typid, &typmod, &typcollation); + + ret = new_objtree_VA("%{name}I %{coltype}T %{colstorage}s %{compression}s " + "%{collation}s %{not_null}s %{default}s " + "%{identity_column}s %{generated_column}s", 3, + "type", ObjTypeString, "column", + "name", ObjTypeString, coldef->colname, + "coltype", ObjTypeObject, + new_objtree_for_type(typid, typmod)); + /* STORAGE clause */ + tmp_obj = new_objtree("STORAGE %{storage_form}s"); + if (!composite) + append_string_object(tmp_obj, "storage_form", + storage_name(attrForm->attstorage)); + else + append_not_present(tmp_obj); + + append_object_object(ret, "colstorage", tmp_obj); + + /* COMPRESSION clause */ + tmp_obj = new_objtree("COMPRESSION %{compression_method}I"); + if (coldef->compression) + append_string_object(tmp_obj, "compression_method", + coldef->compression); + else + append_not_present(tmp_obj); + + append_object_object(ret, "compression", tmp_obj); + + tmp_obj = new_objtree("COLLATE %{collation_name}D"); + if (OidIsValid(typcollation)) + append_object_object(tmp_obj, "collation_name", + new_objtree_for_qualname_id(CollationRelationId, + typcollation)); + else + append_not_present(tmp_obj); + + append_object_object(ret, "collation", tmp_obj); + + if (!composite) + { + Oid seqrelid = InvalidOid; + + /* + * Emit a NOT NULL declaration if necessary. Note that we cannot + * trust pg_attribute.attnotnull here, because that bit is also set + * when primary keys are specified; we must not emit a NOT NULL + * constraint in that case, unless explicitly specified. Therefore, + * we scan the list of constraints attached to this column to + * determine whether we need to emit anything. (Fortunately, NOT NULL + * constraints cannot be table constraints.) + * + * In the ALTER TABLE cases, we also add a NOT NULL if the colDef is + * marked is_not_null. + */ + saw_notnull = false; + foreach(cell, coldef->constraints) + { + Constraint *constr = (Constraint *) lfirst(cell); + + if (constr->contype == CONSTR_NOTNULL) + { + saw_notnull = true; + break; + } + } + + if (is_alter && coldef->is_not_null) + saw_notnull = true; + + append_string_object(ret, "not_null", saw_notnull ? "NOT NULL" : ""); + + tmp_obj = new_objtree("DEFAULT %{default}s"); + if (attrForm->atthasdef && + coldef->generated != ATTRIBUTE_GENERATED_STORED) + { + char *defstr; + + defstr = RelationGetColumnDefault(relation, attrForm->attnum, + dpcontext); + + append_string_object(tmp_obj, "default", defstr); + } + else + append_not_present(tmp_obj); + + append_object_object(ret, "default", tmp_obj); + + /* IDENTITY COLUMN */ + if (coldef->identity) + { + /* + * For identity column, find the sequence owned by column in order + * to deparse the column definition. + */ + seqrelid = getIdentitySequence(relid, attrForm->attnum, true); + if (OidIsValid(seqrelid) && coldef->identitySequence) + seqrelid = RangeVarGetRelid(coldef->identitySequence, NoLock, false); + } + + tmp_obj = new_objtree("%{identity_column}s"); + if (OidIsValid(seqrelid)) + { + ObjTree *tmp_obj2; + + tmp_obj2 = deparse_ColumnIdentity(seqrelid, coldef->identity, is_alter); + append_object_object(tmp_obj, "identity_column", tmp_obj2); + } + else + append_not_present(tmp_obj); + + append_object_object(ret, "identity_column", tmp_obj); + + /* GENERATED COLUMN EXPRESSION */ + tmp_obj = new_objtree("GENERATED ALWAYS AS (%{generation_expr}s) STORED"); + if (coldef->generated == ATTRIBUTE_GENERATED_STORED) + { + char *defstr; + + defstr = RelationGetColumnDefault(relation, attrForm->attnum, + dpcontext); + append_string_object(tmp_obj, "generation_expr", defstr); + } + else + append_not_present(tmp_obj); + + append_object_object(ret, "generated_column", tmp_obj); + } + + ReleaseSysCache(attrTup); + + return ret; +} + +/* + * Deparse a ColumnDef node within a typed table creation. This is simpler + * than the regular case, because we don't have to emit the type declaration, + * collation, or default. Here we only return something if the column is being + * declared NOT NULL. + * + * As in deparse_ColumnDef, any other constraint is processed elsewhere. + */ +static ObjTree * +deparse_ColumnDef_typed(Relation relation, List *dpcontext, ColumnDef *coldef) +{ + ObjTree *ret = NULL; + ObjTree *tmp_obj; + Oid relid = RelationGetRelid(relation); + HeapTuple attrTup; + Form_pg_attribute attrForm; + Oid typid; + int32 typmod; + Oid typcollation; + bool saw_notnull; + ListCell *cell; + + attrTup = SearchSysCacheAttName(relid, coldef->colname); + if (!HeapTupleIsValid(attrTup)) + elog(ERROR, "could not find cache entry for column \"%s\" of relation %u", + coldef->colname, relid); + attrForm = (Form_pg_attribute) GETSTRUCT(attrTup); + + get_atttypetypmodcoll(relid, attrForm->attnum, + &typid, &typmod, &typcollation); + + /* + * Search for a NOT NULL declaration. As in deparse_ColumnDef, we rely on + * finding a constraint on the column rather than coldef->is_not_null. + * (This routine is never used for ALTER cases.) + */ + saw_notnull = false; + foreach(cell, coldef->constraints) + { + Constraint *constr = (Constraint *) lfirst(cell); + + if (constr->contype == CONSTR_NOTNULL) + { + saw_notnull = true; + break; + } + } + + if (!saw_notnull && !attrForm->atthasdef) + { + ReleaseSysCache(attrTup); + return NULL; + } + + tmp_obj = new_objtree("DEFAULT %{default}s"); + if (attrForm->atthasdef) + { + char *defstr; + + defstr = RelationGetColumnDefault(relation, attrForm->attnum, + dpcontext); + + append_string_object(tmp_obj, "default", defstr); + } + else + append_not_present(tmp_obj); + + ret = new_objtree_VA("%{name}I WITH OPTIONS %{not_null}s %{default}s", 4, + "type", ObjTypeString, "column", + "name", ObjTypeString, coldef->colname, + "not_null", ObjTypeString, + saw_notnull ? "NOT NULL" : "", + "default", ObjTypeObject, tmp_obj); + + /* Generated columns are not supported on typed tables, so we are done */ + + ReleaseSysCache(attrTup); + + return ret; +} + +/* + * Deparse the definition of column identity. + */ +static ObjTree * +deparse_ColumnIdentity(Oid seqrelid, char identity, bool alter_table) +{ + ObjTree *ret; + ObjTree *ident_obj; + List *elems = NIL; + Form_pg_sequence seqform; + Sequence_values *seqvalues; + char *identfmt; + + if (alter_table) + { + identfmt = "SET GENERATED %{option}s"; + ret = new_objtree("%{identity_type}s %{seq_definition: }s"); + } + else + { + identfmt = "GENERATED %{option}s AS IDENTITY"; + ret = new_objtree("%{identity_type}s ( %{seq_definition: }s )"); + } + + ident_obj = new_objtree(identfmt); + if (identity == ATTRIBUTE_IDENTITY_ALWAYS) + append_string_object(ident_obj, "option", "ALWAYS"); + else if (identity == ATTRIBUTE_IDENTITY_BY_DEFAULT) + append_string_object(ident_obj, "option", "BY DEFAULT"); + else + append_not_present(ident_obj); + + append_object_object(ret, "identity_type", ident_obj); + + seqvalues = get_sequence_values(seqrelid); + seqform = seqvalues->seqform; + + /* Definition elements */ + elems = lappend(elems, deparse_Seq_Cache(seqform, alter_table)); + elems = lappend(elems, deparse_Seq_Cycle(seqform, alter_table)); + elems = lappend(elems, deparse_Seq_IncrementBy(seqform, alter_table)); + elems = lappend(elems, deparse_Seq_Minvalue(seqform, alter_table)); + elems = lappend(elems, deparse_Seq_Maxvalue(seqform, alter_table)); + elems = lappend(elems, deparse_Seq_Startwith(seqform, alter_table)); + elems = lappend(elems, deparse_Seq_Restart(seqvalues->last_value)); + /* We purposefully do not emit OWNED BY here */ + + append_array_object(ret, "seq_definition", elems); + + return ret; +} + +/* + * ... ALTER COLUMN ... SET/RESET (...) + */ +static ObjTree * +deparse_ColumnSetOptions(AlterTableCmd *subcmd) +{ + List *sets = NIL; + ListCell *cell; + ObjTree *ret; + bool is_reset = subcmd->subtype == AT_ResetOptions; + + ret = new_objtree_VA("ALTER COLUMN %{column}I %{is_reset}s (%{options:, }s)", 2, + "column", ObjTypeString, subcmd->name, + "is_reset", ObjTypeString, is_reset ? "RESET" : "SET"); + + foreach(cell, (List *) subcmd->def) + { + DefElem *elem; + ObjTree *set; + + elem = (DefElem *) lfirst(cell); + set = deparse_DefElem(elem, is_reset); + sets = lappend(sets, new_object_object(set)); + } + + Assert(sets); + append_array_object(ret, "options", sets); + + return ret; +} + +/* + * Deparse SET/RESET clause as used by ALTER TABLE ... SET/RESET (...) + */ +static ObjTree * +deparse_RelSetOptions(AlterTableCmd *subcmd) +{ + List *sets = NIL; + ListCell *cell; + bool is_reset = subcmd->subtype == AT_ResetRelOptions; + + foreach(cell, (List *) subcmd->def) + { + DefElem *elem; + ObjTree *set; + + elem = (DefElem *) lfirst(cell); + set = deparse_DefElem(elem, is_reset); + sets = lappend(sets, new_object_object(set)); + } + + Assert(sets); + + return new_objtree_VA("%{set_reset}s (%{options:, }s)", 2, + "set_reset", ObjTypeString, is_reset ? "RESET" : "SET", + "options", ObjTypeArray, sets); +} + +/* + * Deparse DefElems, as used e.g. by ALTER COLUMN ... SET, into a list of SET + * (...) or RESET (...) contents. + */ +static ObjTree * +deparse_DefElem(DefElem *elem, bool is_reset) +{ + ObjTree *ret; + ObjTree *optname; + + if (elem->defnamespace != NULL) + optname = new_objtree_VA("%{schema}I.%{label}I", 1, + "schema", ObjTypeString, elem->defnamespace, + "label", ObjTypeString, elem->defname); + else + optname = new_objtree_VA("%{label}I", 1, + "label", ObjTypeString, elem->defname); + + if (is_reset) + ret = new_objtree_VA("%{label}s", 1, "label", ObjTypeObject, optname); + else + ret = new_objtree_VA("%{label}s = %{value}L", 2, + "label", ObjTypeObject, optname, + "value", ObjTypeString, + elem->arg ? defGetString(elem) : + defGetBoolean(elem) ? "TRUE" : "FALSE"); + + return ret; +} + +/* + * Deparse the INHERITS relations. + * + * Given a table OID, return a schema-qualified table list representing + * the parent tables. + */ +static List * +deparse_InhRelations(Oid objectId) +{ + List *parents = NIL; + Relation inhRel; + SysScanDesc scan; + ScanKeyData key; + HeapTuple tuple; + + inhRel = table_open(InheritsRelationId, RowExclusiveLock); + + ScanKeyInit(&key, + Anum_pg_inherits_inhrelid, + BTEqualStrategyNumber, F_OIDEQ, + ObjectIdGetDatum(objectId)); + + scan = systable_beginscan(inhRel, InheritsRelidSeqnoIndexId, + true, NULL, 1, &key); + + while (HeapTupleIsValid(tuple = systable_getnext(scan))) + { + ObjTree *parent; + Form_pg_inherits formInh = (Form_pg_inherits) GETSTRUCT(tuple); + + parent = new_objtree_for_qualname_id(RelationRelationId, + formInh->inhparent); + parents = lappend(parents, new_object_object(parent)); + } + + systable_endscan(scan); + table_close(inhRel, RowExclusiveLock); + + return parents; +} + +/* + * Deparse the ON COMMIT ... clause for CREATE ... TEMPORARY ... + */ +static ObjTree * +deparse_OnCommitClause(OnCommitAction option) +{ + ObjTree *ret = new_objtree("ON COMMIT %{on_commit_value}s"); + switch (option) + { + case ONCOMMIT_DROP: + append_string_object(ret, "on_commit_value", "DROP"); + break; + + case ONCOMMIT_DELETE_ROWS: + append_string_object(ret, "on_commit_value", "DELETE ROWS"); + break; + + case ONCOMMIT_PRESERVE_ROWS: + append_string_object(ret, "on_commit_value", "PRESERVE ROWS"); + break; + + case ONCOMMIT_NOOP: + append_not_present(ret); + break; + } + + return ret; +} + +/* + * Deparse the sequence CACHE option. + */ +static inline ObjElem * +deparse_Seq_Cache(Form_pg_sequence seqdata, bool alter_table) +{ + ObjTree *ret; + char *fmt; + + fmt = alter_table ? "SET CACHE %{value}s" : "CACHE %{value}s"; + + ret = new_objtree_VA(fmt, 2, + "clause", ObjTypeString, "cache", + "value", ObjTypeString, + psprintf(INT64_FORMAT, seqdata->seqcache)); + + return new_object_object(ret); +} + +/* + * Deparse the sequence CYCLE option. + */ +static inline ObjElem * +deparse_Seq_Cycle(Form_pg_sequence seqdata, bool alter_table) +{ + ObjTree *ret; + char *fmt; + + fmt = alter_table ? "SET %{no}s CYCLE" : "%{no}s CYCLE"; + + ret = new_objtree_VA(fmt, 2, + "clause", ObjTypeString, "cycle", + "no", ObjTypeString, + seqdata->seqcycle ? "" : "NO"); + + return new_object_object(ret); +} + +/* + * Deparse the sequence INCREMENT BY option. + */ +static inline ObjElem * +deparse_Seq_IncrementBy(Form_pg_sequence seqdata, bool alter_table) +{ + ObjTree *ret; + char *fmt; + + fmt = alter_table ? "SET INCREMENT BY %{value}s" : "INCREMENT BY %{value}s"; + + ret = new_objtree_VA(fmt, 2, + "clause", ObjTypeString, "seqincrement", + "value", ObjTypeString, + psprintf(INT64_FORMAT, seqdata->seqincrement)); + + return new_object_object(ret); +} + +/* + * Deparse the sequence MAXVALUE option. + */ +static inline ObjElem * +deparse_Seq_Maxvalue(Form_pg_sequence seqdata, bool alter_table) +{ + ObjTree *ret; + char *fmt; + + fmt = alter_table ? "SET MAXVALUE %{value}s" : "MAXVALUE %{value}s"; + + ret = new_objtree_VA(fmt, 2, + "clause", ObjTypeString, "maxvalue", + "value", ObjTypeString, + psprintf(INT64_FORMAT, seqdata->seqmax)); + + return new_object_object(ret); +} + +/* + * Deparse the sequence MINVALUE option. + */ +static inline ObjElem * +deparse_Seq_Minvalue(Form_pg_sequence seqdata, bool alter_table) +{ + ObjTree *ret; + char *fmt; + + fmt = alter_table ? "SET MINVALUE %{value}s" : "MINVALUE %{value}s"; + + ret = new_objtree_VA(fmt, 2, + "clause", ObjTypeString, "minvalue", + "value", ObjTypeString, + psprintf(INT64_FORMAT, seqdata->seqmin)); + + return new_object_object(ret); +} + +/* + * Deparse the sequence OWNED BY command. + */ +static ObjElem * +deparse_Seq_OwnedBy(Oid sequenceId, bool alter_table) +{ + ObjTree *ret = NULL; + Relation depRel; + SysScanDesc scan; + ScanKeyData keys[3]; + HeapTuple tuple; + + depRel = table_open(DependRelationId, AccessShareLock); + ScanKeyInit(&keys[0], + Anum_pg_depend_classid, + BTEqualStrategyNumber, F_OIDEQ, + ObjectIdGetDatum(RelationRelationId)); + ScanKeyInit(&keys[1], + Anum_pg_depend_objid, + BTEqualStrategyNumber, F_OIDEQ, + ObjectIdGetDatum(sequenceId)); + ScanKeyInit(&keys[2], + Anum_pg_depend_objsubid, + BTEqualStrategyNumber, F_INT4EQ, + Int32GetDatum(0)); + + scan = systable_beginscan(depRel, DependDependerIndexId, true, + NULL, 3, keys); + while (HeapTupleIsValid(tuple = systable_getnext(scan))) + { + Oid ownerId; + Form_pg_depend depform; + ObjTree *tmp_obj; + char *colname; + + depform = (Form_pg_depend) GETSTRUCT(tuple); + + /* Only consider AUTO dependencies on pg_class */ + if (depform->deptype != DEPENDENCY_AUTO) + continue; + if (depform->refclassid != RelationRelationId) + continue; + if (depform->refobjsubid <= 0) + continue; + + ownerId = depform->refobjid; + colname = get_attname(ownerId, depform->refobjsubid, false); + if (colname == NULL) + continue; + + tmp_obj = new_objtree_for_qualname_id(RelationRelationId, ownerId); + append_string_object(tmp_obj, "attrname", colname); + ret = new_objtree_VA("OWNED BY %{owner}D", 2, + "clause", ObjTypeString, "owned", + "owner", ObjTypeObject, tmp_obj); + } + + systable_endscan(scan); + relation_close(depRel, AccessShareLock); + + /* + * If there's no owner column, emit an empty OWNED BY element, set up so + * that it won't print anything. + */ + if (!ret) + /* XXX this shouldn't happen ... */ + ret = new_objtree_VA("OWNED BY %{owner}D", 3, + "clause", ObjTypeString, "owned", + "owner", ObjTypeNull, + "present", ObjTypeBool, false); + + return new_object_object(ret); +} + +/* + * Deparse the sequence RESTART option. + */ +static inline ObjElem * +deparse_Seq_Restart(int64 last_value) +{ + ObjTree *ret; + + ret = new_objtree_VA("RESTART %{value}s", 2, + "clause", ObjTypeString, "restart", + "value", ObjTypeString, + psprintf(INT64_FORMAT, last_value)); + + return new_object_object(ret); +} + +/* + * Deparse the sequence AS option. + */ +static inline ObjElem * +deparse_Seq_As(Form_pg_sequence seqdata) +{ + ObjTree *ret; + + ret = new_objtree("AS %{seqtype}T"); + if (OidIsValid(seqdata->seqtypid)) + append_object_object(ret, "seqtype", + new_objtree_for_type(seqdata->seqtypid, -1)); + else + append_not_present(ret); + + return new_object_object(ret); +} + +/* + * Deparse the sequence START WITH option. + */ +static inline ObjElem * +deparse_Seq_Startwith(Form_pg_sequence seqdata, bool alter_table) +{ + ObjTree *ret; + char *fmt; + + fmt = alter_table ? "SET START WITH %{value}s" : "START WITH %{value}s"; + + ret = new_objtree_VA(fmt, 2, + "clause", ObjTypeString, "start", + "value", ObjTypeString, + psprintf(INT64_FORMAT, seqdata->seqstart)); + + return new_object_object(ret); +} + +/* + * Subroutine for CREATE TABLE deparsing. + * + * Deal with all the table elements (columns and constraints). + * + * Note we ignore constraints in the parse node here; they are extracted from + * system catalogs instead. + */ +static List * +deparse_TableElements(Relation relation, List *tableElements, List *dpcontext, + bool typed, bool composite) +{ + List *elements = NIL; + ListCell *lc; + + foreach(lc, tableElements) + { + Node *elt = (Node *) lfirst(lc); + + switch (nodeTag(elt)) + { + case T_ColumnDef: + { + ObjTree *tree; + + tree = typed ? + deparse_ColumnDef_typed(relation, dpcontext, + (ColumnDef *) elt) : + deparse_ColumnDef(relation, dpcontext, + composite, (ColumnDef *) elt, + false); + if (tree != NULL) + elements = lappend(elements, new_object_object(tree)); + } + break; + case T_Constraint: + break; + default: + elog(ERROR, "invalid node type %d", nodeTag(elt)); + } + } + + return elements; +} + +/* + * Deparse a CreateSeqStmt. + * + * Given a sequence OID and the parse tree that created it, return an ObjTree + * representing the creation command. + * + * Note: We need to deparse the CREATE SEQUENCE command for the TABLE + * commands. For example, When creating a table, if we specify a column as a + * sequence type, then we will create a sequence for that column and set that + * sequence OWNED BY the table. + */ +static ObjTree * +deparse_CreateSeqStmt(Oid objectId, Node *parsetree) +{ + ObjTree *ret; + Relation relation; + List *elems = NIL; + Form_pg_sequence seqform; + Sequence_values *seqvalues; + CreateSeqStmt *createSeqStmt = (CreateSeqStmt *) parsetree; + + /* + * Only support sequence for IDENTITY COLUMN output separately (via CREATE + * TABLE or ALTER TABLE). Otherwise, return empty here. + */ + if (createSeqStmt->for_identity) + return NULL; + + seqvalues = get_sequence_values(objectId); + seqform = seqvalues->seqform; + + /* Definition elements */ + elems = lappend(elems, deparse_Seq_Cache(seqform, false)); + elems = lappend(elems, deparse_Seq_Cycle(seqform, false)); + elems = lappend(elems, deparse_Seq_IncrementBy(seqform, false)); + elems = lappend(elems, deparse_Seq_Minvalue(seqform, false)); + elems = lappend(elems, deparse_Seq_Maxvalue(seqform, false)); + elems = lappend(elems, deparse_Seq_Startwith(seqform, false)); + elems = lappend(elems, deparse_Seq_Restart(seqvalues->last_value)); + elems = lappend(elems, deparse_Seq_As(seqform)); + + /* We purposefully do not emit OWNED BY here */ + + relation = relation_open(objectId, AccessShareLock); + + ret = new_objtree_VA("CREATE %{persistence}s SEQUENCE %{if_not_exists}s %{identity}D %{definition: }s", 4, + "persistence", ObjTypeString, + get_persistence_str(relation->rd_rel->relpersistence), + "if_not_exists", ObjTypeString, + createSeqStmt->if_not_exists ? "IF NOT EXISTS" : "", + "identity", ObjTypeObject, + new_objtree_for_qualname(relation->rd_rel->relnamespace, + RelationGetRelationName(relation)), + "definition", ObjTypeArray, elems); + + relation_close(relation, AccessShareLock); + + return ret; +} + +/* + * Deparse a CreateStmt (CREATE TABLE). + * + * Given a table OID and the parse tree that created it, return an ObjTree + * representing the creation command. + */ +static ObjTree * +deparse_CreateStmt(Oid objectId, Node *parsetree) +{ + CreateStmt *node = (CreateStmt *) parsetree; + Relation relation = relation_open(objectId, AccessShareLock); + List *dpcontext; + ObjTree *ret; + ObjTree *tmp_obj; + List *list = NIL; + ListCell *cell; + char *fmtstr; + + if (node->ofTypename) + fmtstr = "CREATE %{persistence}s TABLE %{if_not_exists}s %{identity}D " + "%{of_type}s %{table_elements}s %{partition_by}s " + "%{access_method}s %{with_clause}s %{on_commit}s %{tablespace}s"; + else if (node->partbound) + fmtstr = "CREATE %{persistence}s TABLE %{if_not_exists}s %{identity}D " + "%{parent_identity}s %{table_elements}s %{partition_bound}s " + "%{partition_by}s %{access_method}s %{with_clause}s %{on_commit}s " + "%{tablespace}s"; + else + fmtstr = "CREATE %{persistence}s TABLE %{if_not_exists}s %{identity}D " + "(%{table_elements:, }s) %{inherits}s %{partition_by}s " + "%{access_method}s %{with_clause}s %{on_commit}s %{tablespace}s"; + + ret = new_objtree_VA(fmtstr, 3, + "persistence", ObjTypeString, + get_persistence_str(relation->rd_rel->relpersistence), + "if_not_exists", ObjTypeString, + node->if_not_exists ? "IF NOT EXISTS" : "", + "identity", ObjTypeObject, + new_objtree_for_qualname(relation->rd_rel->relnamespace, + RelationGetRelationName(relation))); + + dpcontext = deparse_context_for(RelationGetRelationName(relation), + objectId); + + /* + * Typed tables and partitions use a slightly different format string: we + * must not put table_elements with parents directly in the fmt string, + * because if there are no options the parentheses must not be emitted; + * and also, typed tables do not allow for inheritance. + */ + if (node->ofTypename || node->partbound) + { + List *tableelts = NIL; + + /* + * We can't put table elements directly in the fmt string as an array + * surrounded by parentheses here, because an empty clause would cause + * a syntax error. Therefore, we use an indirection element and set + * present=false when there are no elements. + */ + if (node->ofTypename) + { + tmp_obj = new_objtree_VA("OF %{of_type}T", 1, + "of_type", ObjTypeObject, + new_objtree_for_type(relation->rd_rel->reloftype, -1)); + append_object_object(ret, "of_type", tmp_obj); + } + else + { + List *parents; + ObjElem *elem; + + parents = deparse_InhRelations(objectId); + elem = (ObjElem *) linitial(parents); + + Assert(list_length(parents) == 1); + + tmp_obj = new_objtree_VA("PARTITION OF %{parent_identity}D", 1, + "parent_identity", ObjTypeObject, + elem->value.object); + + append_object_object(ret, "parent_identity", tmp_obj); + } + + tableelts = deparse_TableElements(relation, node->tableElts, dpcontext, + true, /* typed table */ + false); /* not composite */ + tableelts = obtainConstraints(tableelts, objectId); + + tmp_obj = new_objtree("(%{elements:, }s)"); + if (tableelts) + append_array_object(tmp_obj, "elements", tableelts); + else + append_not_present(tmp_obj); + + append_object_object(ret, "table_elements", tmp_obj); + } + else + { + List *tableelts = NIL; + + /* + * There is no need to process LIKE clauses separately; they have + * already been transformed into columns and constraints. + */ + + /* + * Process table elements: column definitions and constraints. Only + * the column definitions are obtained from the parse node itself. To + * get constraints we rely on pg_constraint, because the parse node + * might be missing some things such as the name of the constraints. + */ + tableelts = deparse_TableElements(relation, node->tableElts, dpcontext, + false, /* not typed table */ + false); /* not composite */ + tableelts = obtainConstraints(tableelts, objectId); + + append_array_object(ret, "table_elements", tableelts); + + /* + * Add inheritance specification. We cannot simply scan the list of + * parents from the parser node, because that may lack the actual + * qualified names of the parent relations. Rather than trying to + * re-resolve them from the information in the parse node, it seems + * more accurate and convenient to grab it from pg_inherits. + */ + tmp_obj = new_objtree("INHERITS (%{parents:, }D)"); + if (node->inhRelations != NIL) + append_array_object(tmp_obj, "parents", deparse_InhRelations(objectId)); + else + append_not_present(tmp_obj); + + append_object_object(ret, "inherits", tmp_obj); + } + + /* FOR VALUES clause */ + if (node->partbound) + { + /* + * Get pg_class.relpartbound. We cannot use partbound in the parsetree + * directly as it's the original partbound expression which haven't + * been transformed. + */ + append_string_object(ret, "partition_bound", + RelationGetPartitionBound(objectId)); + } + + /* PARTITION BY clause */ + tmp_obj = new_objtree("PARTITION BY %{definition}s"); + if (relation->rd_rel->relkind == RELKIND_PARTITIONED_TABLE) + append_string_object(tmp_obj, "definition", + pg_get_partkeydef_string(objectId)); + else + append_not_present(tmp_obj); + + append_object_object(ret, "partition_by", tmp_obj); + + /* USING clause */ + tmp_obj = new_objtree("USING %{access_method}I"); + if (node->accessMethod) + append_string_object(tmp_obj, "access_method", node->accessMethod); + else + append_not_present(tmp_obj); + + append_object_object(ret, "access_method", tmp_obj); + + /* WITH clause */ + tmp_obj = new_objtree("WITH (%{with:, }s)"); + + foreach(cell, node->options) + { + ObjTree *tmp_obj2; + DefElem *opt = (DefElem *) lfirst(cell); + + tmp_obj2 = deparse_DefElem(opt, false); + list = lappend(list, new_object_object(tmp_obj2)); + } + + if (list) + append_array_object(tmp_obj, "with", list); + else + append_not_present(tmp_obj); + + append_object_object(ret, "with_clause", tmp_obj); + + append_object_object(ret, "on_commit", + deparse_OnCommitClause(node->oncommit)); + + tmp_obj = new_objtree("TABLESPACE %{tablespace}I"); + if (node->tablespacename) + append_string_object(tmp_obj, "tablespace", + node->tablespacename); + else + append_not_present(tmp_obj); + + append_object_object(ret, "tablespace", tmp_obj); + + relation_close(relation, AccessShareLock); + + return ret; +} + +/* + * Deparse all the collected subcommands and return an ObjTree representing the + * alter command. + */ +static ObjTree * +deparse_AlterRelation(CollectedCommand *cmd) +{ + ObjTree *ret; + ObjTree *tmp_obj; + ObjTree *tmp_obj2; + List *dpcontext; + Relation rel; + List *subcmds = NIL; + ListCell *cell; + const char *reltype; + Oid relId = cmd->d.alterTable.objectId; + AlterTableStmt *stmt = NULL; + + Assert(cmd->type == SCT_AlterTable); + stmt = (AlterTableStmt *) cmd->parsetree; + Assert(IsA(stmt, AlterTableStmt)); + + /* + * ALTER TABLE subcommands generated for TableLikeClause is processed in + * the top level CREATE TABLE command; return empty here. + */ + if (stmt->table_like) + return NULL; + + rel = relation_open(relId, AccessShareLock); + + switch (rel->rd_rel->relkind) + { + case RELKIND_RELATION: + case RELKIND_PARTITIONED_TABLE: + reltype = "TABLE"; + break; + case RELKIND_INDEX: + case RELKIND_PARTITIONED_INDEX: + case RELKIND_VIEW: + case RELKIND_COMPOSITE_TYPE: + case RELKIND_FOREIGN_TABLE: + case RELKIND_MATVIEW: + /* unsupported relkind */ + table_close(rel, AccessShareLock); + return NULL; + + default: + elog(ERROR, "unexpected relkind %d", rel->rd_rel->relkind); + } + + dpcontext = deparse_context_for(RelationGetRelationName(rel), + relId); + + ret = new_objtree_VA("ALTER %{objtype}s %{only}s %{identity}D %{subcmds:, }s", 3, + "objtype", ObjTypeString, reltype, + "only", ObjTypeString, + stmt->relation->inh ? "" : "ONLY", + "identity", ObjTypeObject, + new_objtree_for_qualname(rel->rd_rel->relnamespace, + RelationGetRelationName(rel))); + + foreach(cell, cmd->d.alterTable.subcmds) + { + CollectedATSubcmd *sub = (CollectedATSubcmd *) lfirst(cell); + AlterTableCmd *subcmd = (AlterTableCmd *) sub->parsetree; + ObjTree *tree; + + Assert(IsA(subcmd, AlterTableCmd)); + + /* + * Skip deparse of the subcommand if the objectId doesn't match the + * target relation ID. It can happen for inherited tables when + * subcommands for inherited tables and the parent table are both + * collected in the ALTER TABLE command for the parent table. + */ + if (subcmd->subtype != AT_AttachPartition && + sub->address.objectId != relId && + has_superclass(sub->address.objectId)) + continue; + + switch (subcmd->subtype) + { + case AT_AddColumn: + /* XXX need to set the "recurse" bit somewhere? */ + Assert(IsA(subcmd->def, ColumnDef)); + tree = deparse_ColumnDef(rel, dpcontext, false, + (ColumnDef *) subcmd->def, true); + tmp_obj = new_objtree_VA("ADD %{objtype}s %{if_not_exists}s %{definition}s", 4, + "objtype", ObjTypeString, "COLUMN", + "type", ObjTypeString, "add column", + "if_not_exists", ObjTypeString, + subcmd->missing_ok ? "IF NOT EXISTS" : "", + "definition", ObjTypeObject, tree); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_AddIndexConstraint: + { + IndexStmt *istmt; + Relation idx; + Oid constrOid = sub->address.objectId; + + Assert(IsA(subcmd->def, IndexStmt)); + istmt = (IndexStmt *) subcmd->def; + + Assert(istmt->isconstraint && istmt->unique); + + idx = relation_open(istmt->indexOid, AccessShareLock); + + /* + * Verbose syntax + * + * ADD CONSTRAINT %{name}I %{constraint_type}s USING INDEX + * %index_name}I %{deferrable}s %{init_deferred}s + */ + tmp_obj = new_objtree_VA("ADD CONSTRAINT %{name}I %{constraint_type}s USING INDEX %{index_name}I %{deferrable}s %{init_deferred}s", 6, + "type", ObjTypeString, "add constraint using index", + "name", ObjTypeString, get_constraint_name(constrOid), + "constraint_type", ObjTypeString, + istmt->primary ? "PRIMARY KEY" : "UNIQUE", + "index_name", ObjTypeString, + RelationGetRelationName(idx), + "deferrable", ObjTypeString, + istmt->deferrable ? "DEFERRABLE" : "NOT DEFERRABLE", + "init_deferred", ObjTypeString, + istmt->initdeferred ? "INITIALLY DEFERRED" : "INITIALLY IMMEDIATE"); + + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + + relation_close(idx, AccessShareLock); + } + break; + + case AT_ReAddIndex: + case AT_ReAddConstraint: + case AT_ReAddDomainConstraint: + case AT_ReAddComment: + case AT_ReplaceRelOptions: + case AT_CheckNotNull: + case AT_ReAddStatistics: + /* Subtypes used for internal operations; nothing to do here */ + break; + + case AT_CookedColumnDefault: + { + Relation attrrel; + HeapTuple atttup; + Form_pg_attribute attStruct; + + attrrel = table_open(AttributeRelationId, RowExclusiveLock); + atttup = SearchSysCacheCopy2(ATTNUM, + ObjectIdGetDatum(RelationGetRelid(rel)), + Int16GetDatum(subcmd->num)); + if (!HeapTupleIsValid(atttup)) + elog(ERROR, "cache lookup failed for attribute %d of relation with OID %u", + subcmd->num, RelationGetRelid(rel)); + attStruct = (Form_pg_attribute) GETSTRUCT(atttup); + + /* + * Both default and generation expression not supported + * together. + */ + if (!attStruct->attgenerated) + elog(WARNING, "unsupported alter table subtype %d", + subcmd->subtype); + + heap_freetuple(atttup); + table_close(attrrel, RowExclusiveLock); + break; + } + + case AT_AddColumnToView: + /* CREATE OR REPLACE VIEW -- nothing to do here */ + break; + + case AT_ColumnDefault: + if (subcmd->def == NULL) + tmp_obj = new_objtree_VA("ALTER COLUMN %{column}I DROP DEFAULT", 2, + "type", ObjTypeString, "drop default", + "column", ObjTypeString, subcmd->name); + else + { + List *dpcontext_rel; + HeapTuple attrtup; + AttrNumber attno; + + tmp_obj = new_objtree_VA("ALTER COLUMN %{column}I SET DEFAULT %{definition}s", 2, + "type", ObjTypeString, "set default", + "column", ObjTypeString, subcmd->name); + + dpcontext_rel = deparse_context_for(RelationGetRelationName(rel), + RelationGetRelid(rel)); + attrtup = SearchSysCacheAttName(RelationGetRelid(rel), subcmd->name); + attno = ((Form_pg_attribute) GETSTRUCT(attrtup))->attnum; + append_string_object(tmp_obj, "definition", + RelationGetColumnDefault(rel, attno, + dpcontext_rel)); + ReleaseSysCache(attrtup); + } + + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_DropNotNull: + tmp_obj = new_objtree_VA("ALTER COLUMN %{column}I DROP NOT NULL", 2, + "type", ObjTypeString, "drop not null", + "column", ObjTypeString, subcmd->name); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_ForceRowSecurity: + tmp_obj = new_objtree("FORCE ROW LEVEL SECURITY"); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_NoForceRowSecurity: + tmp_obj = new_objtree("NO FORCE ROW LEVEL SECURITY"); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_SetNotNull: + tmp_obj = new_objtree_VA("ALTER COLUMN %{column}I SET NOT NULL", 2, + "type", ObjTypeString, "set not null", + "column", ObjTypeString, subcmd->name); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_DropExpression: + tmp_obj = new_objtree_VA("ALTER COLUMN %{column}I DROP EXPRESSION %{if_exists}s", 3, + "type", ObjTypeString, "drop expression", + "column", ObjTypeString, subcmd->name, + "if_exists", ObjTypeString, + subcmd->missing_ok ? "IF EXISTS" : ""); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_SetStatistics: + { + Assert(IsA(subcmd->def, Integer)); + if (subcmd->name) + tmp_obj = new_objtree_VA("ALTER COLUMN %{column}I SET STATISTICS %{statistics}n", 3, + "type", ObjTypeString, "set statistics", + "column", ObjTypeString, subcmd->name, + "statistics", ObjTypeInteger, + intVal((Integer *) subcmd->def)); + else + tmp_obj = new_objtree_VA("ALTER COLUMN %{column}n SET STATISTICS %{statistics}n", 3, + "type", ObjTypeString, "set statistics", + "column", ObjTypeInteger, subcmd->num, + "statistics", ObjTypeInteger, + intVal((Integer *) subcmd->def)); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + } + break; + + case AT_SetOptions: + case AT_ResetOptions: + subcmds = lappend(subcmds, new_object_object( + deparse_ColumnSetOptions(subcmd))); + break; + + case AT_SetStorage: + Assert(IsA(subcmd->def, String)); + tmp_obj = new_objtree_VA("ALTER COLUMN %{column}I SET STORAGE %{storage}s", 3, + "type", ObjTypeString, "set storage", + "column", ObjTypeString, subcmd->name, + "storage", ObjTypeString, + strVal((String *) subcmd->def)); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_SetCompression: + Assert(IsA(subcmd->def, String)); + tmp_obj = new_objtree_VA("ALTER COLUMN %{column}I SET COMPRESSION %{compression_method}s", 3, + "type", ObjTypeString, "set compression", + "column", ObjTypeString, subcmd->name, + "compression_method", ObjTypeString, + strVal((String *) subcmd->def)); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_DropColumn: + tmp_obj = new_objtree_VA("DROP %{objtype}s %{if_exists}s %{column}I %{cascade}s", 4, + "objtype", ObjTypeString, "COLUMN", + "type", ObjTypeString, "drop column", + "if_exists", ObjTypeString, + subcmd->missing_ok ? "IF EXISTS" : "", + "column", ObjTypeString, subcmd->name); + tmp_obj2 = new_objtree("CASCADE"); + if (subcmd->behavior != DROP_CASCADE) + append_not_present(tmp_obj2); + append_object_object(tmp_obj, "cascade", tmp_obj2); + + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_AddIndex: + { + Oid idxOid = sub->address.objectId; + IndexStmt *istmt; + Relation idx; + const char *idxname; + Oid constrOid; + + Assert(IsA(subcmd->def, IndexStmt)); + istmt = (IndexStmt *) subcmd->def; + + if (!istmt->isconstraint) + break; + + idx = relation_open(idxOid, AccessShareLock); + idxname = RelationGetRelationName(idx); + + constrOid = get_relation_constraint_oid( + cmd->d.alterTable.objectId, idxname, false); + + tmp_obj = new_objtree_VA("ADD CONSTRAINT %{name}I %{definition}s", 3, + "type", ObjTypeString, "add constraint", + "name", ObjTypeString, idxname, + "definition", ObjTypeString, + pg_get_constraintdef_string(constrOid)); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + + relation_close(idx, AccessShareLock); + } + break; + + case AT_AddConstraint: + { + /* XXX need to set the "recurse" bit somewhere? */ + Oid constrOid = sub->address.objectId; + + /* Skip adding constraint for inherits table sub command */ + if (!constrOid) + continue; + + Assert(IsA(subcmd->def, Constraint)); + + tmp_obj = new_objtree_VA("ADD CONSTRAINT %{name}I %{definition}s", 3, + "type", ObjTypeString, "add constraint", + "name", ObjTypeString, get_constraint_name(constrOid), + "definition", ObjTypeString, + pg_get_constraintdef_string(constrOid)); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + } + break; + + case AT_AlterConstraint: + { + Oid constrOid = sub->address.objectId; + Constraint *c = (Constraint *) subcmd->def; + + /* If no constraint was altered, silently skip it */ + if (!OidIsValid(constrOid)) + break; + + Assert(IsA(c, Constraint)); + tmp_obj = new_objtree_VA("ALTER CONSTRAINT %{name}I %{deferrable}s %{init_deferred}s", 4, + "type", ObjTypeString, "alter constraint", + "name", ObjTypeString, get_constraint_name(constrOid), + "deferrable", ObjTypeString, + c->deferrable ? "DEFERRABLE" : "NOT DEFERRABLE", + "init_deferred", ObjTypeString, + c->initdeferred ? "INITIALLY DEFERRED" : "INITIALLY IMMEDIATE"); + + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + } + break; + + case AT_ValidateConstraint: + tmp_obj = new_objtree_VA("VALIDATE CONSTRAINT %{constraint}I", 2, + "type", ObjTypeString, "validate constraint", + "constraint", ObjTypeString, subcmd->name); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_DropConstraint: + tmp_obj = new_objtree_VA("DROP CONSTRAINT %{if_exists}s %{constraint}I %{cascade}s", 4, + "type", ObjTypeString, "drop constraint", + "if_exists", ObjTypeString, + subcmd->missing_ok ? "IF EXISTS" : "", + "constraint", ObjTypeString, subcmd->name, + "cascade", ObjTypeString, + subcmd->behavior == DROP_CASCADE ? "CASCADE" : ""); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_AlterColumnType: + { + TupleDesc tupdesc = RelationGetDescr(rel); + Form_pg_attribute att; + ColumnDef *def; + + att = &(tupdesc->attrs[sub->address.objectSubId - 1]); + def = (ColumnDef *) subcmd->def; + Assert(IsA(def, ColumnDef)); + + tmp_obj = new_objtree_VA("ALTER COLUMN %{column}I SET DATA TYPE %{datatype}T %{collation}s %{using}s", 3, + "type", ObjTypeString, "alter column type", + "column", ObjTypeString, subcmd->name, + "datatype", ObjTypeObject, + new_objtree_for_type(att->atttypid, + att->atttypmod)); + + /* Add a COLLATE clause, if needed */ + tmp_obj2 = new_objtree("COLLATE %{name}D"); + if (OidIsValid(att->attcollation)) + { + ObjTree *collname; + + collname = new_objtree_for_qualname_id(CollationRelationId, + att->attcollation); + append_object_object(tmp_obj2, "name", collname); + } + else + append_not_present(tmp_obj2); + + append_object_object(tmp_obj, "collation", tmp_obj2); + + /* + * If there's a USING clause, transformAlterTableStmt ran + * it through transformExpr and stored the resulting node + * in cooked_default, which we can use here. + */ + tmp_obj2 = new_objtree("USING %{expression}s"); + if (def->raw_default) + { + Datum deparsed; + char *defexpr; + List *exprs = NIL; + + exprs = lappend(exprs, def->cooked_default); + defexpr = nodeToString(def->cooked_default); + deparsed = DirectFunctionCall2(pg_get_expr, + CStringGetTextDatum(defexpr), + RelationGetRelid(rel)); + + append_string_object(tmp_obj2, "expression", + TextDatumGetCString(deparsed)); + } + else + append_not_present(tmp_obj2); + + append_object_object(tmp_obj, "using", tmp_obj2); + + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + } + break; + +#ifdef TODOLIST + case AT_AlterColumnGenericOptions: + tmp_obj = deparse_FdwOptions((List *) subcmd->def, + subcmd->name); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; +#endif + case AT_ChangeOwner: + tmp_obj = new_objtree_VA("OWNER TO %{owner}I", 2, + "type", ObjTypeString, "change owner", + "owner", ObjTypeString, + get_rolespec_name(subcmd->newowner)); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_ClusterOn: + tmp_obj = new_objtree_VA("CLUSTER ON %{index}I", 2, + "type", ObjTypeString, "cluster on", + "index", ObjTypeString, subcmd->name); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_DropCluster: + tmp_obj = new_objtree_VA("SET WITHOUT CLUSTER", 1, + "type", ObjTypeString, "set without cluster"); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_SetLogged: + tmp_obj = new_objtree_VA("SET LOGGED", 1, + "type", ObjTypeString, "set logged"); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_SetUnLogged: + tmp_obj = new_objtree_VA("SET UNLOGGED", 1, + "type", ObjTypeString, "set unlogged"); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_DropOids: + tmp_obj = new_objtree_VA("SET WITHOUT OIDS", 1, + "type", ObjTypeString, "set without oids"); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + case AT_SetAccessMethod: + tmp_obj = new_objtree_VA("SET ACCESS METHOD %{access_method}I", 2, + "type", ObjTypeString, "set access method", + "access_method", ObjTypeString, subcmd->name); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + case AT_SetTableSpace: + tmp_obj = new_objtree_VA("SET TABLESPACE %{tablespace}I", 2, + "type", ObjTypeString, "set tablespace", + "tablespace", ObjTypeString, subcmd->name); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_SetRelOptions: + case AT_ResetRelOptions: + subcmds = lappend(subcmds, new_object_object( + deparse_RelSetOptions(subcmd))); + break; + + case AT_EnableTrig: + tmp_obj = new_objtree_VA("ENABLE TRIGGER %{trigger}I", 2, + "type", ObjTypeString, "enable trigger", + "trigger", ObjTypeString, subcmd->name); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_EnableAlwaysTrig: + tmp_obj = new_objtree_VA("ENABLE ALWAYS TRIGGER %{trigger}I", 2, + "type", ObjTypeString, "enable always trigger", + "trigger", ObjTypeString, subcmd->name); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_EnableReplicaTrig: + tmp_obj = new_objtree_VA("ENABLE REPLICA TRIGGER %{trigger}I", 2, + "type", ObjTypeString, "enable replica trigger", + "trigger", ObjTypeString, subcmd->name); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_DisableTrig: + tmp_obj = new_objtree_VA("DISABLE TRIGGER %{trigger}I", 2, + "type", ObjTypeString, "disable trigger", + "trigger", ObjTypeString, subcmd->name); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_EnableTrigAll: + tmp_obj = new_objtree_VA("ENABLE TRIGGER ALL", 1, + "type", ObjTypeString, "enable trigger all"); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_DisableTrigAll: + tmp_obj = new_objtree_VA("DISABLE TRIGGER ALL", 1, + "type", ObjTypeString, "disable trigger all"); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_EnableTrigUser: + tmp_obj = new_objtree_VA("ENABLE TRIGGER USER", 1, + "type", ObjTypeString, "enable trigger user"); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_DisableTrigUser: + tmp_obj = new_objtree_VA("DISABLE TRIGGER USER", 1, + "type", ObjTypeString, "disable trigger user"); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_EnableRule: + tmp_obj = new_objtree_VA("ENABLE RULE %{rule}I", 2, + "type", ObjTypeString, "enable rule", + "rule", ObjTypeString, subcmd->name); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_EnableAlwaysRule: + tmp_obj = new_objtree_VA("ENABLE ALWAYS RULE %{rule}I", 2, + "type", ObjTypeString, "enable always rule", + "rule", ObjTypeString, subcmd->name); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_EnableReplicaRule: + tmp_obj = new_objtree_VA("ENABLE REPLICA RULE %{rule}I", 2, + "type", ObjTypeString, "enable replica rule", + "rule", ObjTypeString, subcmd->name); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_DisableRule: + tmp_obj = new_objtree_VA("DISABLE RULE %{rule}I", 2, + "type", ObjTypeString, "disable rule", + "rule", ObjTypeString, subcmd->name); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_AddInherit: + tmp_obj = new_objtree_VA("INHERIT %{parent}D", 2, + "type", ObjTypeString, "inherit", + "parent", ObjTypeObject, + new_objtree_for_qualname_id(RelationRelationId, + sub->address.objectId)); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_DropInherit: + tmp_obj = new_objtree_VA("NO INHERIT %{parent}D", 2, + "type", ObjTypeString, "drop inherit", + "parent", ObjTypeObject, + new_objtree_for_qualname_id(RelationRelationId, + sub->address.objectId)); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_AddOf: + tmp_obj = new_objtree_VA("OF %{type_of}T", 2, + "type", ObjTypeString, "add of", + "type_of", ObjTypeObject, + new_objtree_for_type(sub->address.objectId, -1)); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_DropOf: + tmp_obj = new_objtree_VA("NOT OF", 1, + "type", ObjTypeString, "not of"); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_ReplicaIdentity: + tmp_obj = new_objtree_VA("REPLICA IDENTITY %{ident}s", 1, + "type", ObjTypeString, "replica identity"); + switch (((ReplicaIdentityStmt *) subcmd->def)->identity_type) + { + case REPLICA_IDENTITY_DEFAULT: + append_string_object(tmp_obj, "ident", "DEFAULT"); + break; + case REPLICA_IDENTITY_FULL: + append_string_object(tmp_obj, "ident", "FULL"); + break; + case REPLICA_IDENTITY_NOTHING: + append_string_object(tmp_obj, "ident", "NOTHING"); + break; + case REPLICA_IDENTITY_INDEX: + tmp_obj2 = new_objtree_VA("USING INDEX %{index}I", 1, + "index", ObjTypeString, + ((ReplicaIdentityStmt *) subcmd->def)->name); + append_object_object(tmp_obj, "ident", tmp_obj2); + break; + } + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_EnableRowSecurity: + tmp_obj = new_objtree_VA("ENABLE ROW LEVEL SECURITY", 1, + "type", ObjTypeString, "enable row security"); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + + case AT_DisableRowSecurity: + tmp_obj = new_objtree_VA("DISABLE ROW LEVEL SECURITY", 1, + "type", ObjTypeString, "disable row security"); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; +#ifdef TODOLIST + case AT_GenericOptions: + tmp_obj = deparse_FdwOptions((List *) subcmd->def, NULL); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; +#endif + case AT_AttachPartition: + tmp_obj = new_objtree_VA("ATTACH PARTITION %{partition_identity}D %{partition_bound}s", + 2, "type", ObjTypeString, "attach partition", + "partition_identity", ObjTypeObject, + new_objtree_for_qualname_id(RelationRelationId, + sub->address.objectId)); + + tmp_obj2 = new_objtree("%{partition_bound}s"); + if (rel->rd_rel->relkind == RELKIND_PARTITIONED_TABLE) + append_string_object(tmp_obj2, "partition_bound", + RelationGetPartitionBound(sub->address.objectId)); + else + append_not_present(tmp_obj2); + + append_object_object(tmp_obj, "partition_bound", tmp_obj2); + + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + case AT_DetachPartition: + { + PartitionCmd *cmd; + + Assert(IsA(subcmd->def, PartitionCmd)); + cmd = (PartitionCmd *) subcmd->def; + + tmp_obj = new_objtree_VA("DETACH PARTITION %{partition_identity}D %{concurrent}s", 3, + "type", ObjTypeString, + "detach partition", + "partition_identity", ObjTypeObject, + new_objtree_for_qualname_id(RelationRelationId, + sub->address.objectId), + "concurrent", ObjTypeString, + cmd->concurrent ? "CONCURRENTLY" : ""); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + } + case AT_DetachPartitionFinalize: + tmp_obj = new_objtree_VA("DETACH PARTITION %{partition_identity}D FINALIZE", 2, + "type", ObjTypeString, "detach partition finalize", + "partition_identity", ObjTypeObject, + new_objtree_for_qualname_id(RelationRelationId, + sub->address.objectId)); + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + case AT_AddIdentity: + { + AttrNumber attnum; + Oid seq_relid; + ObjTree *seqdef; + ColumnDef *coldef = (ColumnDef *) subcmd->def; + + tmp_obj = new_objtree_VA("ALTER COLUMN %{column}I %{definition}s", 2, + "type", ObjTypeString, "add identity", + "column", ObjTypeString, subcmd->name); + + attnum = get_attnum(RelationGetRelid(rel), subcmd->name); + seq_relid = getIdentitySequence(RelationGetRelid(rel), attnum, true); + + tmp_obj2 = new_objtree("ADD %{identity_column}s"); + if (OidIsValid(seq_relid)) + { + seqdef = deparse_ColumnIdentity(seq_relid, coldef->identity, false); + append_object_object(tmp_obj2, "identity_column", seqdef); + } + else + append_not_present(tmp_obj2); + + append_object_object(tmp_obj, "definition", tmp_obj2); + + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + } + break; + case AT_SetIdentity: + { + DefElem *defel; + char identity = 0; + ObjTree *seqdef; + AttrNumber attnum; + Oid seq_relid; + + + tmp_obj = new_objtree_VA("ALTER COLUMN %{column}I %{definition}s", 2, + "type", ObjTypeString, "set identity", + "column", ObjTypeString, subcmd->name); + + if (subcmd->def) + { + List *def = (List *) subcmd->def; + + Assert(IsA(subcmd->def, List)); + + defel = linitial_node(DefElem, def); + identity = defGetInt32(defel); + } + + attnum = get_attnum(RelationGetRelid(rel), subcmd->name); + seq_relid = getIdentitySequence(RelationGetRelid(rel), attnum, true); + + tmp_obj2 = new_objtree("%{definition}s"); + if (OidIsValid(seq_relid)) + { + seqdef = deparse_ColumnIdentity(seq_relid, identity, true); + append_object_object(tmp_obj2, "definition", seqdef); + } + else + append_not_present(tmp_obj2); + + append_object_object(tmp_obj, "definition", tmp_obj2); + + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + } + case AT_DropIdentity: + tmp_obj = new_objtree_VA("ALTER COLUMN %{column}I DROP IDENTITY %{if_exists}s", 3, + "type", ObjTypeString, "drop identity", + "column", ObjTypeString, subcmd->name, + "if_exists", ObjTypeString, + subcmd->missing_ok ? "IF EXISTS" : ""); + + subcmds = lappend(subcmds, new_object_object(tmp_obj)); + break; + default: + elog(WARNING, "unsupported alter table subtype %d", + subcmd->subtype); + break; + } + } + + table_close(rel, AccessShareLock); + + if (list_length(subcmds) == 0) + return NULL; + + append_array_object(ret, "subcmds", subcmds); + + return ret; +} + +/* + * Handle deparsing of DROP commands. + */ +char * +deparse_drop_command(const char *objidentity, const char *objecttype, + Node *parsetree) +{ + DropStmt *node = (DropStmt *) parsetree; + StringInfoData str; + char *command; + char *identity = (char *) objidentity; + ObjTree *stmt; + ObjTree *tmp_obj; + Jsonb *jsonb; + + initStringInfo(&str); + + stmt = new_objtree_VA("DROP %{objtype}s %{concurrently}s %{if_exists}s %{objidentity}s %{cascade}s", 4, + "objtype", ObjTypeString, objecttype, + "concurrently", ObjTypeString, + node->concurrent ? "CONCURRENTLY" : "", + "if_exists", ObjTypeString, + node->missing_ok ? "IF EXISTS" : "", + "objidentity", ObjTypeString, identity); + + tmp_obj = new_objtree("CASCADE"); + if (node->behavior != DROP_CASCADE) + append_not_present(tmp_obj); + append_object_object(stmt, "cascade", tmp_obj); + + jsonb = objtree_to_jsonb(stmt); + command = JsonbToCString(&str, &jsonb->root, JSONB_ESTIMATED_LEN); + + return command; +} + +/* + * Deparse an AlterObjectSchemaStmt (ALTER ... SET SCHEMA command) + * + * Given the object address and the parse tree that created it, return an + * ObjTree representing the alter command. + */ +static ObjTree * +deparse_AlterObjectSchemaStmt(ObjectAddress address, Node *parsetree, + ObjectAddress old_schema) +{ + AlterObjectSchemaStmt *node = (AlterObjectSchemaStmt *) parsetree; + char *identity; + char *new_schema = node->newschema; + char *old_schname; + char *ident; + + /* + * Since the command has already taken place from the point of view of + * catalogs, getObjectIdentity returns the object name with the already + * changed schema. The output of our deparsing must return the original + * schema name, however, so we chop the schema name off the identity + * string and then prepend the quoted schema name. + * + * XXX This is pretty clunky. Can we do better? + */ + identity = getObjectIdentity(&address, false); + old_schname = get_namespace_name(old_schema.objectId); + if (!old_schname) + elog(ERROR, "cache lookup failed for schema with OID %u", + old_schema.objectId); + + ident = psprintf("%s%s", quote_identifier(old_schname), + identity + strlen(quote_identifier(new_schema))); + + return new_objtree_VA("ALTER %{objtype}s %{identity}s SET SCHEMA %{newschema}I", 3, + "objtype", ObjTypeString, + stringify_objtype(node->objectType), + "identity", ObjTypeString, ident, + "newschema", ObjTypeString, new_schema); +} + +/* + * Deparse an AlterOwnerStmt (ALTER ... OWNER TO ...). + * + * Given the object address and the parse tree that created it, return an + * ObjTree representing the alter command. + */ +static ObjTree * +deparse_AlterOwnerStmt(ObjectAddress address, Node *parsetree) +{ + AlterOwnerStmt *node = (AlterOwnerStmt *) parsetree; + + return new_objtree_VA("ALTER %{objtype}s %{identity}s OWNER TO %{newowner}I", 3, + "objtype", ObjTypeString, + stringify_objtype(node->objectType), + "identity", ObjTypeString, + getObjectIdentity(&address, false), + "newowner", ObjTypeString, + get_rolespec_name(node->newowner)); +} + +/* + * Deparse an AlterSeqStmt. + * + * Given a sequence OID and a parse tree that modified it, return an ObjTree + * representing the alter command. + * + * Note: We need to deparse the ALTER SEQUENCE command for the TABLE commands. + * For example, When creating a table, if we specify a column as a sequence + * type, then we will create a sequence for that column and set that sequence + * OWNED BY the table. + */ +static ObjTree * +deparse_AlterSeqStmt(Oid objectId, Node *parsetree) +{ + ObjTree *ret; + Relation relation; + List *elems = NIL; + ListCell *cell; + Form_pg_sequence seqform; + Sequence_values *seqvalues; + AlterSeqStmt *alterSeqStmt = (AlterSeqStmt *) parsetree; + + /* + * Sequence for IDENTITY COLUMN output separately (via CREATE TABLE or + * ALTER TABLE); return empty here. + */ + if (alterSeqStmt->for_identity) + return NULL; + + seqvalues = get_sequence_values(objectId); + seqform = seqvalues->seqform; + + foreach(cell, ((AlterSeqStmt *) parsetree)->options) + { + DefElem *elem = (DefElem *) lfirst(cell); + ObjElem *newelm; + + if (strcmp(elem->defname, "cache") == 0) + newelm = deparse_Seq_Cache(seqform, false); + else if (strcmp(elem->defname, "cycle") == 0) + newelm = deparse_Seq_Cycle(seqform, false); + else if (strcmp(elem->defname, "increment") == 0) + newelm = deparse_Seq_IncrementBy(seqform, false); + else if (strcmp(elem->defname, "minvalue") == 0) + newelm = deparse_Seq_Minvalue(seqform, false); + else if (strcmp(elem->defname, "maxvalue") == 0) + newelm = deparse_Seq_Maxvalue(seqform, false); + else if (strcmp(elem->defname, "start") == 0) + newelm = deparse_Seq_Startwith(seqform, false); + else if (strcmp(elem->defname, "restart") == 0) + newelm = deparse_Seq_Restart(seqvalues->last_value); + else if (strcmp(elem->defname, "owned_by") == 0) + newelm = deparse_Seq_OwnedBy(objectId, false); + else if (strcmp(elem->defname, "as") == 0) + newelm = deparse_Seq_As(seqform); + else + elog(ERROR, "invalid sequence option %s", elem->defname); + + elems = lappend(elems, newelm); + } + + relation = relation_open(objectId, AccessShareLock); + + ret = new_objtree_VA("ALTER SEQUENCE %{identity}D %{definition: }s", 2, + "identity", ObjTypeObject, + new_objtree_for_qualname(relation->rd_rel->relnamespace, + RelationGetRelationName(relation)), + "definition", ObjTypeArray, elems); + + relation_close(relation, AccessShareLock); + + return ret; +} + +/* + * Deparse a RenameStmt. + */ +static ObjTree * +deparse_RenameStmt(ObjectAddress address, Node *parsetree) +{ + RenameStmt *node = (RenameStmt *) parsetree; + ObjTree *ret; + Relation relation; + Oid schemaId; + ObjTree *tmp_obj; + + /* + * In an ALTER .. RENAME command, we don't have the original name of the + * object in system catalogs: since we inspect them after the command has + * executed, the old name is already gone. Therefore, we extract it from + * the parse node. Note we still extract the schema name from the catalog + * (it might not be present in the parse node); it cannot possibly have + * changed anyway. + */ + switch (node->renameType) + { + case OBJECT_TABLE: + relation = relation_open(address.objectId, AccessShareLock); + schemaId = RelationGetNamespace(relation); + ret = new_objtree_VA("ALTER %{objtype}s %{if_exists}s %{identity}D RENAME TO %{newname}I", 4, + "objtype", ObjTypeString, + stringify_objtype(node->renameType), + "if_exists", ObjTypeString, + node->missing_ok ? "IF EXISTS" : "", + "identity", ObjTypeObject, + new_objtree_for_qualname(schemaId, + node->relation->relname), + "newname", ObjTypeString, + node->newname); + relation_close(relation, AccessShareLock); + break; + + case OBJECT_TABCONSTRAINT: + { + HeapTuple constrtup; + Form_pg_constraint constform; + + constrtup = SearchSysCache1(CONSTROID, + ObjectIdGetDatum(address.objectId)); + if (!HeapTupleIsValid(constrtup)) + elog(ERROR, "cache lookup failed for constraint with OID %u", + address.objectId); + constform = (Form_pg_constraint) GETSTRUCT(constrtup); + + ret = new_objtree_VA("ALTER TABLE %{only}s %{identity}D RENAME CONSTRAINT %{oldname}I TO %{newname}I", 4, + "only", ObjTypeString, + node->relation->inh ? "" : "ONLY", + "identity", ObjTypeObject, + new_objtree_for_qualname_id(RelationRelationId, + constform->conrelid), + "oldname", ObjTypeString, node->subname, + "newname", ObjTypeString, node->newname); + ReleaseSysCache(constrtup); + } + break; + + case OBJECT_COLUMN: + relation = relation_open(address.objectId, AccessShareLock); + schemaId = RelationGetNamespace(relation); + + ret = new_objtree_VA("ALTER %{objtype}s %{if_exists}s %{only}s %{identity}D RENAME COLUMN %{colname}I TO %{newname}I %{cascade}s", 5, + "objtype", ObjTypeString, + stringify_objtype(node->relationType), + "only", ObjTypeString, node->relation->inh ? "" : "ONLY", + "identity", ObjTypeObject, + new_objtree_for_qualname(schemaId, node->relation->relname), + "colname", ObjTypeString, node->subname, + "newname", ObjTypeString, node->newname + ); + + /* Composite types do not support IF EXISTS */ + tmp_obj = new_objtree("IF EXISTS"); + if (node->renameType != OBJECT_COLUMN || !node->missing_ok) + append_not_present(tmp_obj); + append_object_object(ret, "if_exists", tmp_obj); + + tmp_obj = new_objtree("CASCADE"); + if (node->renameType != OBJECT_ATTRIBUTE || + node->behavior != DROP_CASCADE) + append_not_present(tmp_obj); + append_object_object(ret, "cascade", tmp_obj); + + relation_close(relation, AccessShareLock); + break; + + default: + elog(ERROR, "unsupported object type %d", node->renameType); + } + + return ret; +} + +/* + * Handle deparsing of simple commands. + * + * This function should cover all cases handled in ProcessUtilitySlow. + */ +static ObjTree * +deparse_simple_command(CollectedCommand *cmd) +{ + Oid objectId; + Node *parsetree; + + Assert(cmd->type == SCT_Simple); + + parsetree = cmd->parsetree; + objectId = cmd->d.simple.address.objectId; + + if (cmd->in_extension && (nodeTag(parsetree) != T_CreateExtensionStmt)) + return NULL; + + /* This switch needs to handle everything that ProcessUtilitySlow does */ + switch (nodeTag(parsetree)) + { + case T_AlterObjectSchemaStmt: + return deparse_AlterObjectSchemaStmt(cmd->d.simple.address, + parsetree, + cmd->d.simple.secondaryObject); + + case T_AlterOwnerStmt: + return deparse_AlterOwnerStmt(cmd->d.simple.address, parsetree); + + case T_AlterSeqStmt: + return deparse_AlterSeqStmt(objectId, parsetree); + + case T_CreateSeqStmt: + return deparse_CreateSeqStmt(objectId, parsetree); + + case T_CreateStmt: + return deparse_CreateStmt(objectId, parsetree); + + case T_RenameStmt: + return deparse_RenameStmt(cmd->d.simple.address, parsetree); + + default: + elog(LOG, "unrecognized node type in deparse command: %d", + (int) nodeTag(parsetree)); + } + + return NULL; +} + +/* + * Workhorse to deparse a CollectedCommand. + */ +char * +deparse_utility_command(CollectedCommand *cmd) +{ + OverrideSearchPath *overridePath; + MemoryContext oldcxt; + MemoryContext tmpcxt; + ObjTree *tree; + char *command = NULL; + StringInfoData str; + + /* + * Allocate everything done by the deparsing routines into a temp context, + * to avoid having to sprinkle them with memory handling code, but + * allocate the output StringInfo before switching. + */ + initStringInfo(&str); + tmpcxt = AllocSetContextCreate(CurrentMemoryContext, + "deparse ctx", + ALLOCSET_DEFAULT_MINSIZE, + ALLOCSET_DEFAULT_INITSIZE, + ALLOCSET_DEFAULT_MAXSIZE); + oldcxt = MemoryContextSwitchTo(tmpcxt); + + /* + * Many routines underlying this one will invoke ruleutils.c functionality + * to obtain deparsed versions of expressions. In such results, we want + * all object names to be qualified, so that results are "portable" to + * environments with different search_path settings. Rather than + * injecting what would be repetitive calls to override search path all + * over the place, we do it centrally here. + */ + overridePath = GetOverrideSearchPath(CurrentMemoryContext); + overridePath->schemas = NIL; + overridePath->addCatalog = false; + overridePath->addTemp = true; + PushOverrideSearchPath(overridePath); + + switch (cmd->type) + { + case SCT_Simple: + tree = deparse_simple_command(cmd); + break; + case SCT_AlterTable: + tree = deparse_AlterRelation(cmd); + break; + default: + elog(ERROR, "unexpected deparse node type %d", cmd->type); + } + + PopOverrideSearchPath(); + + if (tree) + { + Jsonb *jsonb; + + jsonb = objtree_to_jsonb(tree); + command = JsonbToCString(&str, &jsonb->root, JSONB_ESTIMATED_LEN); + } + + /* + * Clean up. Note that since we created the StringInfo in the caller's + * context, the output string is not deleted here. + */ + MemoryContextSwitchTo(oldcxt); + MemoryContextDelete(tmpcxt); + + return command; +} + +/* + * Given a CollectedCommand, return a JSON representation of it. + * + * The command is expanded fully so that there are no ambiguities even in the + * face of search_path changes. + */ +Datum +ddl_deparse_to_json(PG_FUNCTION_ARGS) +{ + CollectedCommand *cmd = (CollectedCommand *) PG_GETARG_POINTER(0); + char *command; + + command = deparse_utility_command(cmd); + + if (command) + PG_RETURN_TEXT_P(cstring_to_text(command)); + + PG_RETURN_NULL(); +} diff --git a/src/backend/commands/ddljson.c b/src/backend/commands/ddljson.c new file mode 100644 index 0000000000..6d24e6a9aa --- /dev/null +++ b/src/backend/commands/ddljson.c @@ -0,0 +1,708 @@ +/*------------------------------------------------------------------------- + * + * ddljson.c + * JSON code related to DDL command deparsing + * + * Portions Copyright (c) 1996-2023, PostgreSQL Global Development Group + * Portions Copyright (c) 1994, Regents of the University of California + * + * IDENTIFICATION + * src/backend/commands/ddljson.c + * + *------------------------------------------------------------------------- + */ +#include "postgres.h" + +#include "tcop/ddldeparse.h" +#include "utils/builtins.h" +#include "utils/jsonb.h" + + +#define ADVANCE_PARSE_POINTER(ptr,end_ptr) \ + do { \ + if (++(ptr) >= (end_ptr)) \ + ereport(ERROR, \ + errcode(ERRCODE_INVALID_PARAMETER_VALUE), \ + errmsg("unterminated format specifier")); \ + } while (0) + +/* + * Conversion specifier which determines how to expand the JSON element + * into a string. + */ +typedef enum +{ + SpecDottedName, + SpecIdentifier, + SpecNumber, + SpecString, + SpecStringLiteral, + SpecTypeName +} convSpecifier; + +/* + * A ternary value that represents a boolean type JsonbValue. + */ +typedef enum +{ + tv_absent, + tv_true, + tv_false +} json_trivalue; + +static bool expand_one_jsonb_element(StringInfo buf, char *param, + JsonbValue *jsonval, convSpecifier specifier, + const char *fmt); +static void expand_jsonb_array(StringInfo buf, char *param, + JsonbValue *jsonarr, char *arraysep, + convSpecifier specifier, const char *fmt); +static void fmtstr_error_callback(void *arg); + +/* + * Given a JsonbContainer, find the JsonbValue with the given key name in it. + * If it's of a type other than jbvBool, an error is raised. If it doesn't + * exist, tv_absent is returned; otherwise return the actual json_trivalue. + */ +static json_trivalue +find_bool_in_jsonbcontainer(JsonbContainer *container, char *keyname) +{ + JsonbValue key; + JsonbValue *value; + json_trivalue result; + + key.type = jbvString; + key.val.string.val = keyname; + key.val.string.len = strlen(keyname); + value = findJsonbValueFromContainer(container, + JB_FOBJECT, &key); + if (value == NULL) + return tv_absent; + if (value->type != jbvBool) + ereport(ERROR, + errcode(ERRCODE_INVALID_PARAMETER_VALUE), + errmsg("element \"%s\" is not of type boolean", keyname)); + result = value->val.boolean ? tv_true : tv_false; + pfree(value); + + return result; +} + +/* + * Given a JsonbContainer, find the JsonbValue with the given key name in it. + * If it's of a type other than jbvString, an error is raised. If it doesn't + * exist, an error is raised unless missing_ok; otherwise return NULL. + * + * If it exists and is a string, a freshly palloc'ed copy is returned. + * + * If *length is not NULL, it is set to the length of the string. + */ +static char * +find_string_in_jsonbcontainer(JsonbContainer *container, char *keyname, + bool missing_ok, int *length) +{ + JsonbValue key; + JsonbValue *value; + char *str; + + /* XXX verify that this is an object, not an array */ + + key.type = jbvString; + key.val.string.val = keyname; + key.val.string.len = strlen(keyname); + value = findJsonbValueFromContainer(container, + JB_FOBJECT, &key); + if (value == NULL) + { + if (missing_ok) + return NULL; + ereport(ERROR, + errcode(ERRCODE_INVALID_PARAMETER_VALUE), + errmsg("missing element \"%s\" in JSON object", keyname)); + } + + if (value->type != jbvString) + ereport(ERROR, + errcode(ERRCODE_INVALID_PARAMETER_VALUE), + errmsg("element \"%s\" is not of type string", keyname)); + + str = pnstrdup(value->val.string.val, value->val.string.len); + if (length) + *length = value->val.string.len; + pfree(value); + return str; +} + +/* + * Recursive helper for deparse_ddl_json_to_string. + * + * Find the "fmt" element in the given container, and expand it into the + * provided StringInfo. + */ +static void +expand_fmt_recursive(StringInfo buf, JsonbContainer *container) +{ + JsonbValue key; + JsonbValue *value; + const char *cp; + const char *start_ptr; + const char *end_ptr; + int len; + + start_ptr = find_string_in_jsonbcontainer(container, "fmt", false, &len); + end_ptr = start_ptr + len; + + for (cp = start_ptr; cp < end_ptr; cp++) + { + convSpecifier specifier; + bool is_array = false; + char *param = NULL; + char *arraysep = NULL; + + if (*cp != '%') + { + appendStringInfoCharMacro(buf, *cp); + continue; + } + + ADVANCE_PARSE_POINTER(cp, end_ptr); + + /* Easy case: %% outputs a single % */ + if (*cp == '%') + { + appendStringInfoCharMacro(buf, *cp); + continue; + } + + /* + * Scan the mandatory element name. Allow for an array separator + * (which may be the empty string) to be specified after a colon. + */ + if (*cp == '{') + { + StringInfoData parbuf; + StringInfoData arraysepbuf; + StringInfo appendTo; + + initStringInfo(&parbuf); + appendTo = &parbuf; + + ADVANCE_PARSE_POINTER(cp, end_ptr); + while (cp < end_ptr) + { + if (*cp == ':') + { + /* + * Found array separator delimiter; element name is now + * complete, start filling the separator. + */ + initStringInfo(&arraysepbuf); + appendTo = &arraysepbuf; + is_array = true; + ADVANCE_PARSE_POINTER(cp, end_ptr); + continue; + } + + if (*cp == '}') + { + ADVANCE_PARSE_POINTER(cp, end_ptr); + break; + } + appendStringInfoCharMacro(appendTo, *cp); + ADVANCE_PARSE_POINTER(cp, end_ptr); + } + param = parbuf.data; + if (is_array) + arraysep = arraysepbuf.data; + } + if (param == NULL) + ereport(ERROR, + errcode(ERRCODE_INVALID_PARAMETER_VALUE), + errmsg("missing conversion name in conversion specifier")); + + switch (*cp) + { + case 'I': + specifier = SpecIdentifier; + break; + case 'D': + specifier = SpecDottedName; + break; + case 's': + specifier = SpecString; + break; + case 'L': + specifier = SpecStringLiteral; + break; + case 'T': + specifier = SpecTypeName; + break; + case 'n': + specifier = SpecNumber; + break; + default: + ereport(ERROR, + errcode(ERRCODE_INVALID_PARAMETER_VALUE), + errmsg("invalid conversion specifier \"%c\"", *cp)); + } + + /* + * Obtain the element to be expanded. + */ + key.type = jbvString; + key.val.string.val = param; + key.val.string.len = strlen(param); + + value = findJsonbValueFromContainer(container, JB_FOBJECT, &key); + Assert(value != NULL); + + /* + * Expand the data (possibly an array) into the output StringInfo. + */ + if (is_array) + expand_jsonb_array(buf, param, value, arraysep, specifier, start_ptr); + else + expand_one_jsonb_element(buf, param, value, specifier, start_ptr); + + pfree(value); + } +} + +/* + * Expand a json value as a quoted identifier. The value must be of type string. + */ +static void +expand_jsonval_identifier(StringInfo buf, JsonbValue *jsonval) +{ + char *str; + + Assert(jsonval->type == jbvString); + + str = pnstrdup(jsonval->val.string.val, jsonval->val.string.len); + appendStringInfoString(buf, quote_identifier(str)); + pfree(str); +} + +/* + * Expand a json value as a dot-separated-name. The value must be of type + * binary and may contain elements "schemaname" (optional), "objname" + * (mandatory), "attrname" (optional). Double quotes are added to each element + * as necessary, and dot separators where needed. + * + * One day we might need a "catalog" element as well, but no current use case + * needs that. + */ +static void +expand_jsonval_dottedname(StringInfo buf, JsonbValue *jsonval) +{ + char *str; + JsonbContainer *data = jsonval->val.binary.data; + + Assert(jsonval->type == jbvBinary); + + str = find_string_in_jsonbcontainer(data, "schemaname", true, NULL); + if (str) + { + appendStringInfo(buf, "%s.", quote_identifier(str)); + pfree(str); + } + + str = find_string_in_jsonbcontainer(data, "objname", false, NULL); + appendStringInfo(buf, "%s", quote_identifier(str)); + pfree(str); + + str = find_string_in_jsonbcontainer(data, "attrname", true, NULL); + if (str) + { + appendStringInfo(buf, ".%s", quote_identifier(str)); + pfree(str); + } +} + +/* + * Expand a JSON value as a type name. + */ +static void +expand_jsonval_typename(StringInfo buf, JsonbValue *jsonval) +{ + char *schema = NULL; + char *typename = NULL; + char *typmodstr = NULL; + json_trivalue is_array; + char *array_decor; + JsonbContainer *data = jsonval->val.binary.data; + + /* + * We omit schema-qualifying the output name if the schema element is + * either the empty string or NULL; the difference between those two cases + * is that in the latter we quote the type name, in the former we don't. + * This allows for types with special typmod needs, such as interval and + * timestamp (see format_type_detailed), while at the same time allowing + * for the schema name to be omitted from type names that require quotes + * but are to be obtained from a user schema. + */ + + schema = find_string_in_jsonbcontainer(data, "schemaname", true, NULL); + typename = find_string_in_jsonbcontainer(data, "typename", false, NULL); + typmodstr = find_string_in_jsonbcontainer(data, "typmod", true, NULL); + is_array = find_bool_in_jsonbcontainer(data, "typarray"); + switch (is_array) + { + case tv_true: + array_decor = "[]"; + break; + + case tv_false: + array_decor = ""; + break; + + case tv_absent: + default: + ereport(ERROR, + errcode(ERRCODE_INVALID_PARAMETER_VALUE), + errmsg("missing typarray element")); + } + + if (schema == NULL) + appendStringInfo(buf, "%s", quote_identifier(typename)); + else if (schema[0] == '\0') + appendStringInfo(buf, "%s", typename); /* Special typmod needs */ + else + appendStringInfo(buf, "%s.%s", quote_identifier(schema), + quote_identifier(typename)); + + appendStringInfo(buf, "%s%s", typmodstr ? typmodstr : "", array_decor); + + if (schema) + pfree(schema); + if (typename) + pfree(typename); + if (typmodstr) + pfree(typmodstr); +} + +/* + * Expand a JSON value as a string. The value must be of type string or of + * type Binary. In the latter case, it must contain a "fmt" element which will + * be recursively expanded; also, if the object contains an element "present" + * and it is set to false, the expansion is the empty string. + * + * Returns false if no actual expansion was made due to the "present" flag + * being set to "false". + * + * The caller is responsible to check jsonval is of type jbvString or jbvBinary. + */ +static bool +expand_jsonval_string(StringInfo buf, JsonbValue *jsonval) +{ + bool expanded = false; + + Assert((jsonval->type == jbvString) || (jsonval->type == jbvBinary)); + + if (jsonval->type == jbvString) + { + appendBinaryStringInfo(buf, jsonval->val.string.val, + jsonval->val.string.len); + expanded = true; + } + else if (jsonval->type == jbvBinary) + { + json_trivalue present; + + present = find_bool_in_jsonbcontainer(jsonval->val.binary.data, + "present"); + + /* + * If "present" is set to false, this element expands to empty; + * otherwise (either true or absent), expand "fmt". + */ + if (present != tv_false) + { + expand_fmt_recursive(buf, jsonval->val.binary.data); + expanded = true; + } + } + + return expanded; +} + +/* + * Expand a JSON value as a string literal. + */ +static void +expand_jsonval_strlit(StringInfo buf, JsonbValue *jsonval) +{ + char *str; + StringInfoData dqdelim; + static const char dqsuffixes[] = "_XYZZYX_"; + int dqnextchar = 0; + + Assert(jsonval->type == jbvString); + + str = pnstrdup(jsonval->val.string.val, jsonval->val.string.len); + + /* Easy case: if there are no ' and no \, just use a single quote */ + if (strpbrk(str, "\'\\") == NULL) + { + appendStringInfo(buf, "'%s'", str); + pfree(str); + return; + } + + /* Otherwise need to find a useful dollar-quote delimiter */ + initStringInfo(&dqdelim); + appendStringInfoString(&dqdelim, "$"); + while (strstr(str, dqdelim.data) != NULL) + { + appendStringInfoChar(&dqdelim, dqsuffixes[dqnextchar++]); + dqnextchar = dqnextchar % (sizeof(dqsuffixes) - 1); + } + /* Add trailing $ */ + appendStringInfoChar(&dqdelim, '$'); + + /* And finally produce the quoted literal into the output StringInfo */ + appendStringInfo(buf, "%s%s%s", dqdelim.data, str, dqdelim.data); + pfree(dqdelim.data); + pfree(str); +} + +/* + * Expand a JSON value as an integer quantity. + */ +static void +expand_jsonval_number(StringInfo buf, JsonbValue *jsonval) +{ + char *strdatum; + + Assert(jsonval->type == jbvNumeric); + + strdatum = DatumGetCString(DirectFunctionCall1(numeric_out, + NumericGetDatum(jsonval->val.numeric))); + appendStringInfoString(buf, strdatum); + pfree(strdatum); +} + +/* + * Expand one JSON element into the output StringInfo according to the + * conversion specifier. The element type is validated, and an error is raised + * if it doesn't match what we expect for the conversion specifier. + * + * Returns true, except for the formatted string case if no actual expansion + * was made (due to the "present" flag being set to "false"). + */ +static bool +expand_one_jsonb_element(StringInfo buf, char *param, JsonbValue *jsonval, + convSpecifier specifier, const char *fmt) +{ + bool string_expanded = true; + ErrorContextCallback sqlerrcontext; + + /* If we were given a format string, setup an ereport() context callback */ + if (fmt) + { + sqlerrcontext.callback = fmtstr_error_callback; + sqlerrcontext.arg = (void *) fmt; + sqlerrcontext.previous = error_context_stack; + error_context_stack = &sqlerrcontext; + } + + if (!jsonval) + ereport(ERROR, + errcode(ERRCODE_INVALID_PARAMETER_VALUE), + errmsg("element \"%s\" not found", param)); + + switch (specifier) + { + case SpecIdentifier: + if (jsonval->type != jbvString) + ereport(ERROR, + errcode(ERRCODE_INVALID_PARAMETER_VALUE), + errmsg("expected JSON string for %%I element \"%s\", got %d", + param, jsonval->type)); + expand_jsonval_identifier(buf, jsonval); + break; + + case SpecDottedName: + if (jsonval->type != jbvBinary) + ereport(ERROR, + errcode(ERRCODE_INVALID_PARAMETER_VALUE), + errmsg("expected JSON struct for %%D element \"%s\", got %d", + param, jsonval->type)); + expand_jsonval_dottedname(buf, jsonval); + break; + + case SpecString: + if (jsonval->type != jbvString && + jsonval->type != jbvBinary) + ereport(ERROR, + errcode(ERRCODE_INVALID_PARAMETER_VALUE), + errmsg("expected JSON string or struct for %%s element \"%s\", got %d", + param, jsonval->type)); + string_expanded = expand_jsonval_string(buf, jsonval); + break; + + case SpecStringLiteral: + if (jsonval->type != jbvString) + ereport(ERROR, + errcode(ERRCODE_INVALID_PARAMETER_VALUE), + errmsg("expected JSON string for %%L element \"%s\", got %d", + param, jsonval->type)); + expand_jsonval_strlit(buf, jsonval); + break; + + case SpecTypeName: + if (jsonval->type != jbvBinary) + ereport(ERROR, + errcode(ERRCODE_INVALID_PARAMETER_VALUE), + errmsg("expected JSON struct for %%T element \"%s\", got %d", + param, jsonval->type)); + expand_jsonval_typename(buf, jsonval); + break; + + case SpecNumber: + if (jsonval->type != jbvNumeric) + ereport(ERROR, + errcode(ERRCODE_INVALID_PARAMETER_VALUE), + errmsg("expected JSON numeric for %%n element \"%s\", got %d", + param, jsonval->type)); + expand_jsonval_number(buf, jsonval); + break; + } + + if (fmt) + error_context_stack = sqlerrcontext.previous; + + return string_expanded; +} + +/* + * Iterate on the elements of a JSON array, expanding each one into the output + * StringInfo per the given conversion specifier, separated by the given + * separator. + */ +static void +expand_jsonb_array(StringInfo buf, char *param, + JsonbValue *jsonarr, char *arraysep, convSpecifier specifier, + const char *fmt) +{ + ErrorContextCallback sqlerrcontext; + JsonbContainer *container; + JsonbIterator *it; + JsonbValue v; + int type; + bool first = true; + StringInfoData arrayelem; + + /* If we were given a format string, setup an ereport() context callback */ + if (fmt) + { + sqlerrcontext.callback = fmtstr_error_callback; + sqlerrcontext.arg = (void *) fmt; + sqlerrcontext.previous = error_context_stack; + error_context_stack = &sqlerrcontext; + } + + if (!jsonarr) + ereport(ERROR, + errcode(ERRCODE_INVALID_PARAMETER_VALUE), + errmsg("element \"%s\" not found", param)); + + if (jsonarr->type != jbvBinary) + ereport(ERROR, + errcode(ERRCODE_INVALID_PARAMETER_VALUE), + errmsg("element \"%s\" is not a JSON array", param)); + + container = jsonarr->val.binary.data; + if (!JsonContainerIsArray(container)) + ereport(ERROR, + errcode(ERRCODE_INVALID_PARAMETER_VALUE), + errmsg("element \"%s\" is not a JSON array", param)); + + initStringInfo(&arrayelem); + + it = JsonbIteratorInit(container); + while ((type = JsonbIteratorNext(&it, &v, true)) != WJB_DONE) + { + if (type == WJB_ELEM) + { + resetStringInfo(&arrayelem); + + if (expand_one_jsonb_element(&arrayelem, param, &v, specifier, NULL)) + { + if (!first) + appendStringInfoString(buf, arraysep); + + appendBinaryStringInfo(buf, arrayelem.data, arrayelem.len); + first = false; + } + } + } + + if (fmt) + error_context_stack = sqlerrcontext.previous; +} + +/* + * Workhorse for ddl_deparse_expand_command. + */ +char * +deparse_ddl_json_to_string(char *json_str) +{ + Datum d; + Jsonb *jsonb; + StringInfo buf = (StringInfo) palloc0(sizeof(StringInfoData)); + + initStringInfo(buf); + + d = DirectFunctionCall1(jsonb_in, PointerGetDatum(json_str)); + jsonb = (Jsonb *) DatumGetPointer(d); + + expand_fmt_recursive(buf, &jsonb->root); + + return buf->data; +} + +/*------ + * Returns a formatted string from a JSON object. + * + * The starting point is the element named "fmt" (which must be a string). + * This format string may contain zero or more %-escapes, which consist of an + * element name enclosed in { }, possibly followed by a conversion modifier, + * followed by a conversion specifier. Possible conversion specifiers are: + * + * % expand to a literal % + * I expand as a single, non-qualified identifier + * D expand as a possibly-qualified identifier + * T expand as a type name + * L expand as a string literal (quote using single quotes) + * s expand as a simple string (no quoting) + * n expand as a simple number (no quoting) + * + * The element name may have an optional separator specification preceded + * by a colon. Its presence indicates that the element is expected to be + * an array; the specified separator is used to join the array elements. + * + * The actual conversion of single JSON element into string according to + * above conversion specifiers takes place in expand_one_jsonb_element() + *------ + */ +Datum +ddl_deparse_expand_command(PG_FUNCTION_ARGS) +{ + text *json = PG_GETARG_TEXT_P(0); + char *json_str; + + json_str = text_to_cstring(json); + + PG_RETURN_TEXT_P(cstring_to_text(deparse_ddl_json_to_string(json_str))); +} + +/* + * Error context callback for JSON format string expansion. + * + * XXX: indicate which element we're expanding, if applicable. + */ +static void +fmtstr_error_callback(void *arg) +{ + errcontext("while expanding format string \"%s\"", (char *) arg); +} diff --git a/src/backend/commands/event_trigger.c b/src/backend/commands/event_trigger.c index d4b00d1a82..4d48e490ed 100644 --- a/src/backend/commands/event_trigger.c +++ b/src/backend/commands/event_trigger.c @@ -37,6 +37,7 @@ #include "miscadmin.h" #include "parser/parse_func.h" #include "pgstat.h" +#include "tcop/ddldeparse.h" #include "tcop/deparse_utility.h" #include "tcop/utility.h" #include "utils/acl.h" diff --git a/src/backend/commands/meson.build b/src/backend/commands/meson.build index 42cced9ebe..9539e53bac 100644 --- a/src/backend/commands/meson.build +++ b/src/backend/commands/meson.build @@ -17,6 +17,8 @@ backend_sources += files( 'copyto.c', 'createas.c', 'dbcommands.c', + 'ddldeparse.c', + 'ddljson.c', 'define.c', 'discard.c', 'dropcmds.c', diff --git a/src/backend/commands/sequence.c b/src/backend/commands/sequence.c index ef01449678..4bb731d5ff 100644 --- a/src/backend/commands/sequence.c +++ b/src/backend/commands/sequence.c @@ -1707,6 +1707,49 @@ process_owned_by(Relation seqrel, List *owned_by, bool for_identity) relation_close(tablerel, NoLock); } +/* + * Return sequence parameters, detailed + */ +Sequence_values * +get_sequence_values(Oid sequenceId) +{ + Buffer buf; + SeqTable elm; + Relation seqrel; + HeapTuple seqtuple; + HeapTupleData seqtupledata; + Form_pg_sequence seqform; + Form_pg_sequence_data seq; + Sequence_values *seqvalues; + + seqtuple = SearchSysCache1(SEQRELID, sequenceId); + if (!HeapTupleIsValid(seqtuple)) + elog(ERROR, "cache lookup failed for sequence %u", sequenceId); + seqform = (Form_pg_sequence) GETSTRUCT(seqtuple); + + ReleaseSysCache(seqtuple); + + /* Open and lock sequence */ + init_sequence(sequenceId, &elm, &seqrel); + + if (pg_class_aclcheck(sequenceId, GetUserId(), + ACL_SELECT | ACL_USAGE) != ACLCHECK_OK) + ereport(ERROR, + errcode(ERRCODE_INSUFFICIENT_PRIVILEGE), + errmsg("permission denied for sequence %s", + RelationGetRelationName(seqrel))); + + seq = read_seq_tuple(seqrel, &buf, &seqtupledata); + + seqvalues = (Sequence_values *) palloc(sizeof(Sequence_values)); + seqvalues->last_value = seq->last_value; + seqvalues->seqform = seqform; + + UnlockReleaseBuffer(buf); + relation_close(seqrel, NoLock); + + return seqvalues; +} /* * Return sequence parameters in a list of the form created by the parser. diff --git a/src/backend/commands/tablecmds.c b/src/backend/commands/tablecmds.c index 4d49d70c33..c15e943f1d 100644 --- a/src/backend/commands/tablecmds.c +++ b/src/backend/commands/tablecmds.c @@ -600,7 +600,6 @@ static ObjectAddress ATExecSetCompression(Relation rel, const char *column, Node *newValue, LOCKMODE lockmode); static void index_copy_data(Relation rel, RelFileLocator newrlocator); -static const char *storage_name(char c); static void RangeVarCallbackForDropRelation(const RangeVar *rel, Oid relOid, Oid oldRelOid, void *arg); @@ -2266,7 +2265,7 @@ truncate_check_activity(Relation rel) * storage_name * returns the name corresponding to a typstorage/attstorage enum value */ -static const char * +char * storage_name(char c) { switch (c) diff --git a/src/backend/parser/parse_utilcmd.c b/src/backend/parser/parse_utilcmd.c index d67580fc77..753456ecbc 100644 --- a/src/backend/parser/parse_utilcmd.c +++ b/src/backend/parser/parse_utilcmd.c @@ -1393,6 +1393,7 @@ expandTableLikeClause(RangeVar *heapRel, TableLikeClause *table_like_clause) atcmd->cmds = atsubcmds; atcmd->objtype = OBJECT_TABLE; atcmd->missing_ok = false; + atcmd->table_like = true; result = lcons(atcmd, result); } diff --git a/src/backend/tcop/utility.c b/src/backend/tcop/utility.c index 30b51bf4d3..c0f7f29747 100644 --- a/src/backend/tcop/utility.c +++ b/src/backend/tcop/utility.c @@ -2206,6 +2206,23 @@ UtilityContainsQuery(Node *parsetree) } } +/* + * stringify_objtype + * Return the given object type as a string. + */ +const char * +stringify_objtype(ObjectType objtype) +{ + switch (objtype) + { + case OBJECT_TABLE: + return "TABLE"; + default: + elog(ERROR, "unsupported object type %d", objtype); + } + + return "???"; /* keep compiler quiet */ +} /* * AlterObjectTypeCommandTag diff --git a/src/backend/utils/adt/format_type.c b/src/backend/utils/adt/format_type.c index 12402a0637..4318129558 100644 --- a/src/backend/utils/adt/format_type.c +++ b/src/backend/utils/adt/format_type.c @@ -27,8 +27,6 @@ #include "utils/numeric.h" #include "utils/syscache.h" -static char *printTypmod(const char *typname, int32 typmod, Oid typmodout); - /* * SQL function: format_type(type_oid, typemod) @@ -329,6 +327,110 @@ format_type_extended(Oid type_oid, int32 typemod, bits16 flags) return buf; } +/* + * Similar to format_type_extended, except we return each bit of information + * separately: + * + * - nspid is the schema OID. For certain SQL-standard types which have weird + * typmod rules, we return InvalidOid; the caller is expected to not schema- + * qualify the name nor add quotes to the type name in this case. + * + * - typname is set to the type name, without quotes + * + * - typemodstr is set to the typemod, if any, as a string with parentheses + * + * - typarray indicates whether []s must be added + * + * We don't try to decode type names to their standard-mandated names, except + * in the cases of types with unusual typmod rules. + */ +void +format_type_detailed(Oid type_oid, int32 typemod, + Oid *nspid, char **typname, char **typemodstr, + bool *typearray) +{ + HeapTuple tuple; + Form_pg_type typeform; + Oid array_base_type; + + tuple = SearchSysCache1(TYPEOID, ObjectIdGetDatum(type_oid)); + if (!HeapTupleIsValid(tuple)) + elog(ERROR, "cache lookup failed for type with OID %u", type_oid); + + typeform = (Form_pg_type) GETSTRUCT(tuple); + + /* + * We switch our attention to the array element type for certain cases. + * Check if it's a "true" array type. Pseudo-array types such as "name" + * shouldn't get deconstructed. Also check the toast property, and don't + * deconstruct "plain storage" array types --- this is because we don't + * want to show oidvector as oid[]. + */ + array_base_type = typeform->typelem; + + *typearray = (IsTrueArrayType(typeform) && typeform->typstorage != TYPSTORAGE_PLAIN); + + if (*typearray) + { + ReleaseSysCache(tuple); + tuple = SearchSysCache1(TYPEOID, ObjectIdGetDatum(array_base_type)); + if (!HeapTupleIsValid(tuple)) + elog(ERROR, "cache lookup failed for type with OID %u", type_oid); + + typeform = (Form_pg_type) GETSTRUCT(tuple); + type_oid = array_base_type; + } + + /* + * Special-case crock for types with strange typmod rules where we put + * typemod at the middle of name (e.g. TIME(6) with time zone). We cannot + * schema-qualify nor add quotes to the type name in these cases. + */ + *nspid = InvalidOid; + + switch (type_oid) + { + case TIMEOID: + *typname = pstrdup("TIME"); + break; + case TIMESTAMPOID: + *typname = pstrdup("TIMESTAMP"); + break; + case TIMESTAMPTZOID: + if (typemod < 0) + *typname = pstrdup("TIMESTAMP WITH TIME ZONE"); + else + /* otherwise, WITH TZ is added by typmod. */ + *typname = pstrdup("TIMESTAMP"); + break; + case INTERVALOID: + *typname = pstrdup("INTERVAL"); + break; + case TIMETZOID: + if (typemod < 0) + *typname = pstrdup("TIME WITH TIME ZONE"); + else + /* otherwise, WITH TZ is added by typmod. */ + *typname = pstrdup("TIME"); + break; + default: + + /* + * No additional processing is required for other types, so get + * the type name and schema directly from the catalog. + */ + *nspid = typeform->typnamespace; + *typname = pstrdup(NameStr(typeform->typname)); + } + + if (typemod >= 0) + *typemodstr = printTypmod("", typemod, typeform->typmodout); + else + *typemodstr = pstrdup(""); + + ReleaseSysCache(tuple); +} + /* * This version is for use within the backend in error messages, etc. * One difference is that it will fail for an invalid type. @@ -363,7 +465,7 @@ format_type_with_typemod(Oid type_oid, int32 typemod) /* * Add typmod decoration to the basic type name */ -static char * +char * printTypmod(const char *typname, int32 typmod, Oid typmodout) { char *res; diff --git a/src/backend/utils/adt/ruleutils.c b/src/backend/utils/adt/ruleutils.c index d3a973d86b..b8729d8e3d 100644 --- a/src/backend/utils/adt/ruleutils.c +++ b/src/backend/utils/adt/ruleutils.c @@ -51,7 +51,6 @@ #include "optimizer/optimizer.h" #include "parser/parse_agg.h" #include "parser/parse_func.h" -#include "parser/parse_node.h" #include "parser/parse_oper.h" #include "parser/parse_relation.h" #include "parser/parser.h" @@ -501,22 +500,15 @@ static void get_from_clause_coldeflist(RangeTblFunction *rtfunc, deparse_context *context); static void get_tablesample_def(TableSampleClause *tablesample, deparse_context *context); -static void get_opclass_name(Oid opclass, Oid actual_datatype, - StringInfo buf); static Node *processIndirection(Node *node, deparse_context *context); static void printSubscripts(SubscriptingRef *sbsref, deparse_context *context); static char *get_relation_name(Oid relid); static char *generate_relation_name(Oid relid, List *namespaces); static char *generate_qualified_relation_name(Oid relid); -static char *generate_function_name(Oid funcid, int nargs, - List *argnames, Oid *argtypes, - bool has_variadic, bool *use_variadic_p, - ParseExprKind special_exprkind); static char *generate_operator_name(Oid operid, Oid arg1, Oid arg2); static void add_cast_to(StringInfo buf, Oid typid); static char *generate_qualified_type_name(Oid typid); static text *string_to_text(char *str); -static char *flatten_reloptions(Oid relid); static void get_reloptions(StringInfo buf, Datum reloptions); #define only_marker(rte) ((rte)->inh ? "" : "ONLY ") @@ -1901,6 +1893,14 @@ pg_get_partkeydef_columns(Oid relid, bool pretty) return pg_get_partkeydef_worker(relid, prettyFlags, true, false); } +/* Internal version that reports the full partition key definition */ +char * +pg_get_partkeydef_string(Oid relid) +{ + return pg_get_partkeydef_worker(relid, GET_PRETTY_FLAGS(false), false, + false); +} + /* * Internal workhorse to decompile a partition key definition. */ @@ -2148,6 +2148,16 @@ pg_get_constraintdef_ext(PG_FUNCTION_ARGS) PG_RETURN_TEXT_P(string_to_text(res)); } +/* + * Internal version that returns the definition of a CONSTRAINT command + */ +char * +pg_get_constraintdef_string(Oid constraintId) +{ + return pg_get_constraintdef_worker(constraintId, false, + GET_PRETTY_FLAGS(false), false); +} + /* * Internal version that returns a full ALTER TABLE ... ADD CONSTRAINT command */ @@ -11758,7 +11768,7 @@ get_tablesample_def(TableSampleClause *tablesample, deparse_context *context) * actual_datatype. (If you don't want this behavior, just pass * InvalidOid for actual_datatype.) */ -static void +void get_opclass_name(Oid opclass, Oid actual_datatype, StringInfo buf) { @@ -12152,7 +12162,7 @@ generate_qualified_relation_name(Oid relid) * * The result includes all necessary quoting and schema-prefixing. */ -static char * +char * generate_function_name(Oid funcid, int nargs, List *argnames, Oid *argtypes, bool has_variadic, bool *use_variadic_p, ParseExprKind special_exprkind) @@ -12538,7 +12548,7 @@ get_reloptions(StringInfo buf, Datum reloptions) /* * Generate a C string representing a relation's reloptions, or NULL if none. */ -static char * +char * flatten_reloptions(Oid relid) { char *result = NULL; diff --git a/src/include/catalog/pg_proc.dat b/src/include/catalog/pg_proc.dat index 6996073989..76ff23b779 100644 --- a/src/include/catalog/pg_proc.dat +++ b/src/include/catalog/pg_proc.dat @@ -12043,4 +12043,11 @@ proname => 'any_value_transfn', prorettype => 'anyelement', proargtypes => 'anyelement anyelement', prosrc => 'any_value_transfn' }, +{ oid => '4642', descr => 'deparse the DDL command into a JSON format string', + proname => 'ddl_deparse_to_json', prorettype => 'text', + proargtypes => 'pg_ddl_command', prosrc => 'ddl_deparse_to_json' }, +{ oid => '4643', descr => 'expand JSON format DDL to a plain text DDL command', + proname => 'ddl_deparse_expand_command', prorettype => 'text', + proargtypes => 'text', prosrc => 'ddl_deparse_expand_command' }, + ] diff --git a/src/include/commands/sequence.h b/src/include/commands/sequence.h index 7db7b3da7b..c0a39596ac 100644 --- a/src/include/commands/sequence.h +++ b/src/include/commands/sequence.h @@ -15,6 +15,7 @@ #include "access/xlogreader.h" #include "catalog/objectaddress.h" +#include "catalog/pg_sequence.h" #include "fmgr.h" #include "lib/stringinfo.h" #include "nodes/parsenodes.h" @@ -51,9 +52,17 @@ typedef struct xl_seq_rec /* SEQUENCE TUPLE DATA FOLLOWS AT THE END */ } xl_seq_rec; +/* Information needed to define a sequence. */ +typedef struct Sequence_values +{ + Form_pg_sequence seqform; + int64 last_value; +} Sequence_values; + extern int64 nextval_internal(Oid relid, bool check_permissions); extern Datum nextval(PG_FUNCTION_ARGS); extern List *sequence_options(Oid relid); +extern Sequence_values *get_sequence_values(Oid sequenceId); extern ObjectAddress DefineSequence(ParseState *pstate, CreateSeqStmt *seq); extern ObjectAddress AlterSequence(ParseState *pstate, AlterSeqStmt *stmt); diff --git a/src/include/commands/tablecmds.h b/src/include/commands/tablecmds.h index 17b9404937..5a082e57ea 100644 --- a/src/include/commands/tablecmds.h +++ b/src/include/commands/tablecmds.h @@ -106,4 +106,6 @@ extern void RangeVarCallbackOwnsRelation(const RangeVar *relation, extern bool PartConstraintImpliedByRelConstraint(Relation scanrel, List *partConstraint); +extern char *storage_name(char c); + #endif /* TABLECMDS_H */ diff --git a/src/include/nodes/parsenodes.h b/src/include/nodes/parsenodes.h index 0ca298f5a1..71fb0d0874 100644 --- a/src/include/nodes/parsenodes.h +++ b/src/include/nodes/parsenodes.h @@ -2167,6 +2167,7 @@ typedef struct AlterTableStmt List *cmds; /* list of subcommands */ ObjectType objtype; /* type of object */ bool missing_ok; /* skip error if table missing */ + bool table_like; /* internally generated for TableLikeClause */ } AlterTableStmt; typedef enum AlterTableType diff --git a/src/include/tcop/ddldeparse.h b/src/include/tcop/ddldeparse.h new file mode 100644 index 0000000000..15481dc3c4 --- /dev/null +++ b/src/include/tcop/ddldeparse.h @@ -0,0 +1,22 @@ +/*------------------------------------------------------------------------- + * + * ddldeparse.h + * + * Portions Copyright (c) 1996-2023, PostgreSQL Global Development Group + * Portions Copyright (c) 1994, Regents of the University of California + * + * src/include/tcop/ddldeparse.h + * + *------------------------------------------------------------------------- + */ +#ifndef DDL_DEPARSE_H +#define DDL_DEPARSE_H + +#include "tcop/deparse_utility.h" + +extern char *deparse_utility_command(CollectedCommand *cmd); +extern char *deparse_ddl_json_to_string(char *jsonb); +extern char *deparse_drop_command(const char *objidentity, const char *objecttype, + Node *parsetree); + +#endif /* DDL_DEPARSE_H */ diff --git a/src/include/tcop/utility.h b/src/include/tcop/utility.h index 59e64aea07..22ce3e1b6f 100644 --- a/src/include/tcop/utility.h +++ b/src/include/tcop/utility.h @@ -99,6 +99,8 @@ extern Query *UtilityContainsQuery(Node *parsetree); extern CommandTag CreateCommandTag(Node *parsetree); +extern const char *stringify_objtype(ObjectType objtype); + static inline const char * CreateCommandName(Node *parsetree) { diff --git a/src/include/utils/builtins.h b/src/include/utils/builtins.h index 2f8b46d6da..cfda299dee 100644 --- a/src/include/utils/builtins.h +++ b/src/include/utils/builtins.h @@ -124,9 +124,14 @@ extern Datum numeric_float8_no_overflow(PG_FUNCTION_ARGS); #define FORMAT_TYPE_INVALID_AS_NULL 0x08 /* NULL if undefined */ extern char *format_type_extended(Oid type_oid, int32 typemod, bits16 flags); +extern void format_type_detailed(Oid type_oid, int32 typemod, + Oid *nspid, char **typname, + char **typemodstr, bool *typearray); + extern char *format_type_be(Oid type_oid); extern char *format_type_be_qualified(Oid type_oid); extern char *format_type_with_typemod(Oid type_oid, int32 typemod); +extern char *printTypmod(const char *typname, int32 typmod, Oid typmodout); extern int32 type_maximum_size(Oid type_oid, int32 typemod); diff --git a/src/include/utils/ruleutils.h b/src/include/utils/ruleutils.h index b006d9d475..fd1d85fc8d 100644 --- a/src/include/utils/ruleutils.h +++ b/src/include/utils/ruleutils.h @@ -16,6 +16,7 @@ #include "nodes/nodes.h" #include "nodes/parsenodes.h" #include "nodes/pg_list.h" +#include "parser/parse_node.h" struct Plan; /* avoid including plannodes.h here */ struct PlannedStmt; @@ -31,9 +32,11 @@ extern char *pg_get_indexdef_columns_extended(Oid indexrelid, extern char *pg_get_querydef(Query *query, bool pretty); extern char *pg_get_partkeydef_columns(Oid relid, bool pretty); +extern char *pg_get_partkeydef_string(Oid relid); extern char *pg_get_partconstrdef_string(Oid partitionId, char *aliasname); extern char *pg_get_constraintdef_command(Oid constraintId); +extern char *pg_get_constraintdef_string(Oid constraintId); extern char *deparse_expression(Node *expr, List *dpcontext, bool forceprefix, bool showimplicit); extern List *deparse_context_for(const char *aliasname, Oid relid); @@ -45,7 +48,14 @@ extern List *select_rtable_names_for_explain(List *rtable, Bitmapset *rels_used); extern char *generate_collation_name(Oid collid); extern char *generate_opclass_name(Oid opclass); +extern char *generate_function_name(Oid funcid, int nargs, List *argnames, + Oid *argtypes, bool has_variadic, + bool *use_variadic_p, + ParseExprKind special_exprkind); extern char *get_range_partbound_string(List *bound_datums); +extern void get_opclass_name(Oid opclass, Oid actual_datatype, + StringInfo buf); +extern char *flatten_reloptions(Oid relid); extern char *pg_get_statisticsobjdef_string(Oid statextid); diff --git a/src/tools/pgindent/typedefs.list b/src/tools/pgindent/typedefs.list index 260854747b..87c147dfdb 100644 --- a/src/tools/pgindent/typedefs.list +++ b/src/tools/pgindent/typedefs.list @@ -1636,6 +1636,9 @@ OSInfo OSSLCipher OSSLDigest OVERLAPPED +ObjElem +ObjTree +ObjType ObjectAccessDrop ObjectAccessNamespaceSearch ObjectAccessPostAlter @@ -3222,6 +3225,7 @@ config_var_value contain_aggs_of_level_context contain_placeholder_references_context convert_testexpr_context +convSpecifier copy_data_dest_cb copy_data_source_cb core_YYSTYPE @@ -3425,6 +3429,7 @@ json_manifest_perwalrange_callback json_ofield_action json_scalar_action json_struct_action +json_trivalue keyEntryData key_t lclContext -- 2.34.1