36 Var *var,
int levelsup);
39 const char *targetName,
51 bool make_target_entry);
56 int sublevels_up,
int location,
57 bool make_target_entry);
59 bool make_target_entry);
98 if (colname == NULL && !resjunk)
136 foreach(o_target, targetlist)
228 foreach(lc, exprlist)
294 foreach(l, targetlist)
299 if (restype == UNKNOWNOID)
302 restype, TEXTOID, -1,
324 foreach(l, targetlist)
346 Var *var,
int levelsup)
352 if (var == NULL || !
IsA(var,
Var))
372 if (ste == NULL || ste->
resjunk)
373 elog(
ERROR,
"subquery %s does not have attribute %d",
418 if (ste == NULL || ste->
resjunk)
419 elog(
ERROR,
"CTE %s does not have attribute %d",
481 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
482 errmsg(
"cannot assign to system column \"%s\"",
509 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
510 errmsg(
"cannot set an array element to DEFAULT"),
514 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
515 errmsg(
"cannot set a subfield to DEFAULT"),
551 attrtype, attrtypmod, attrcollation, 0);
554 colVar = (
Node *) var;
582 attrtype, attrtypmod,
588 (
errcode(ERRCODE_DATATYPE_MISMATCH),
589 errmsg(
"column \"%s\" is of type %s"
590 " but expression is of type %s",
594 errhint(
"You will need to rewrite or cast the expression."),
687 const char *targetName,
688 bool targetIsSubscripting,
700 bool isSlice =
false;
703 if (indirection_cell && !basenode)
714 ctest->
typeId = targetTypeId;
717 basenode = (
Node *) ctest;
731 subscripts =
lappend(subscripts, n);
738 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
739 errmsg(
"row expansion via \"*\" is not supported here"),
780 baseTypeMod = targetTypMod;
786 (
errcode(ERRCODE_DATATYPE_MISMATCH),
787 errmsg(
"cannot assign to field \"%s\" of column \"%s\" because its type %s is not a composite type",
795 (
errcode(ERRCODE_UNDEFINED_COLUMN),
796 errmsg(
"cannot assign to field \"%s\" of column \"%s\" because there is no such column in data type %s",
802 (
errcode(ERRCODE_UNDEFINED_COLUMN),
803 errmsg(
"cannot assign to system column \"%s\"",
808 &fieldTypeId, &fieldTypMod, &fieldCollation);
826 fstore->
arg = (
Expr *) basenode;
832 if (baseTypeId != targetTypeId)
834 baseTypeId, baseTypeMod,
841 return (
Node *) fstore;
868 targetTypeId, targetTypMod,
874 if (targetIsSubscripting)
876 (
errcode(ERRCODE_DATATYPE_MISMATCH),
877 errmsg(
"subscripted assignment to \"%s\" requires type %s"
878 " but expression is of type %s",
882 errhint(
"You will need to rewrite or cast the expression."),
886 (
errcode(ERRCODE_DATATYPE_MISMATCH),
887 errmsg(
"subfield \"%s\" is of type %s"
888 " but expression is of type %s",
892 errhint(
"You will need to rewrite or cast the expression."),
905 const char *targetName,
920 int32 containerTypMod;
928 containerType = targetTypeId;
929 containerTypMod = targetTypMod;
950 if (containerType == targetTypeId)
951 collationNeeded = targetCollation;
977 result = (
Node *) sbsref;
980 if (containerType != targetTypeId)
986 targetTypeId, targetTypMod,
993 (
errcode(ERRCODE_CANNOT_COERCE),
994 errmsg(
"cannot cast type %s to %s",
1024 for (
i = 0;
i < numcol;
i++)
1031 if (attr->attisdropped)
1062 (
errcode(ERRCODE_UNDEFINED_COLUMN),
1063 errmsg(
"column \"%s\" of relation \"%s\" does not exist",
1078 (
errcode(ERRCODE_DUPLICATE_COLUMN),
1079 errmsg(
"column \"%s\" specified more than once",
1089 (
errcode(ERRCODE_DUPLICATE_COLUMN),
1090 errmsg(
"column \"%s\" specified more than once",
1117 bool make_target_entry)
1132 Assert(make_target_entry);
1151 char *nspname = NULL;
1160 } crserr = CRSERR_NO_RTE;
1199 crserr = CRSERR_WRONG_DB;
1210 crserr = CRSERR_TOO_MANY;
1228 (
Node *) (nsitem ? nsitem->
p_rte : NULL));
1233 (
errcode(ERRCODE_AMBIGUOUS_COLUMN),
1234 errmsg(
"column reference \"%s\" is ambiguous",
1252 case CRSERR_WRONG_DB:
1254 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1255 errmsg(
"cross-database references are not implemented: %s",
1259 case CRSERR_TOO_MANY:
1261 (
errcode(ERRCODE_SYNTAX_ERROR),
1262 errmsg(
"improper qualified name (too many dotted names): %s",
1292 bool found_table =
false;
1322 (
errcode(ERRCODE_SYNTAX_ERROR),
1323 errmsg(
"SELECT * with no tables specified is not valid"),
1369 int sublevels_up,
int location,
bool make_target_entry)
1371 if (make_target_entry)
1416 bool make_target_entry)
1456 ((
Var *) expr)->vartype == RECORDOID)
1463 numAttrs = tupleDesc->
natts;
1464 for (
i = 0;
i < numAttrs;
i++)
1469 if (att->attisdropped)
1480 if (make_target_entry)
1492 result =
lappend(result, fselect);
1560 Assert(lname == NULL && lvar == NULL);
1565 expr = (
Node *) var;
1586 if (ste == NULL || ste->
resjunk)
1587 elog(
ERROR,
"subquery %s does not have attribute %d",
1599 MemSet(&mypstate, 0,
sizeof(mypstate));
1640 if (ste == NULL || ste->
resjunk)
1641 elog(
ERROR,
"CTE %s does not have attribute %d",
1655 MemSet(&mypstate, 0,
sizeof(mypstate));
1744 foreach(l, ((
ColumnRef *) node)->fields)
1765 foreach(l,
ind->indirection)
1796 if (((
TypeCast *) node)->typeName != NULL)
1810 switch (((
SubLink *) node)->subLinkType)
1890 *
name =
"current_date";
1894 *
name =
"current_time";
1898 *
name =
"current_timestamp";
1902 *
name =
"localtime";
1906 *
name =
"localtimestamp";
1909 *
name =
"current_role";
1912 *
name =
"current_user";
1918 *
name =
"session_user";
1921 *
name =
"current_catalog";
1924 *
name =
"current_schema";
1930 switch (((
XmlExpr *) node)->op)
1933 *
name =
"xmlconcat";
1936 *
name =
"xmlelement";
1939 *
name =
"xmlforest";
1951 *
name =
"xmlserialize";
1959 *
name =
"xmlserialize";
1965 *
name =
"json_scalar";
1968 *
name =
"json_serialize";
1971 *
name =
"json_object";
1975 *
name =
"json_array";
1978 *
name =
"json_objectagg";
1981 *
name =
"json_arrayagg";
1988 *
name =
"json_query";
1991 *
name =
"json_value";
1994 *
name =
"json_exists";
1997 *
name =
"json_table";
#define InvalidAttrNumber
bool bms_is_member(int x, const Bitmapset *a)
Bitmapset * bms_add_member(Bitmapset *a, int x)
#define MemSet(start, val, len)
char * get_database_name(Oid dbid)
static void PGresult * res
int errhint(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
TupleDesc get_expr_result_tupdesc(Node *expr, bool noError)
Assert(fmt[strlen(fmt) - 1] !='\n')
List * list_truncate(List *list, int new_size)
List * lappend(List *list, void *datum)
List * lappend_int(List *list, int datum)
List * list_concat(List *list1, const List *list2)
AttrNumber get_attnum(Oid relid, const char *attname)
Oid get_typcollation(Oid typid)
Oid getBaseTypeAndTypmod(Oid typid, int32 *typmod)
void get_atttypetypmodcoll(Oid relid, AttrNumber attnum, Oid *typid, int32 *typmod, Oid *collid)
TargetEntry * makeTargetEntry(Expr *expr, AttrNumber resno, char *resname, bool resjunk)
Const * makeNullConst(Oid consttype, int32 consttypmod, Oid constcollid)
RangeVar * makeRangeVar(char *schemaname, char *relname, int location)
Var * makeVar(int varno, AttrNumber varattno, Oid vartype, int32 vartypmod, Oid varcollid, Index varlevelsup)
char * pstrdup(const char *in)
char * NameListToString(List *names)
Oid exprType(const Node *expr)
int32 exprTypmod(const Node *expr)
Oid exprCollation(const Node *expr)
int exprLocation(const Node *expr)
#define IsA(nodeptr, _type_)
@ T_JsonObjectConstructor
@ T_JsonArrayQueryConstructor
Node * coerce_type(ParseState *pstate, Node *node, Oid inputTypeId, Oid targetTypeId, int32 targetTypeMod, CoercionContext ccontext, CoercionForm cformat, int location)
Node * coerce_to_domain(Node *arg, Oid baseTypeId, int32 baseTypeMod, Oid typeId, CoercionContext ccontext, CoercionForm cformat, int location, bool hideInputCoercion)
Node * coerce_to_target_type(ParseState *pstate, Node *expr, Oid exprtype, Oid targettype, int32 targettypmod, CoercionContext ccontext, CoercionForm cformat, int location)
Node * transformExpr(ParseState *pstate, Node *expr, ParseExprKind exprKind)
SubscriptingRef * transformContainerSubscripts(ParseState *pstate, Node *containerBase, Oid containerType, int32 containerTypMod, List *indirection, bool isAssignment)
int parser_errposition(ParseState *pstate, int location)
void transformContainerType(Oid *containerType, int32 *containerTypmod)
@ EXPR_KIND_UPDATE_TARGET
@ EXPR_KIND_UPDATE_SOURCE
RangeTblEntry * GetRTEByRangeTablePosn(ParseState *pstate, int varno, int sublevels_up)
void markVarForSelectPriv(ParseState *pstate, Var *var)
void errorMissingRTE(ParseState *pstate, RangeVar *relation)
TargetEntry * get_tle_by_resno(List *tlist, AttrNumber resno)
ParseNamespaceItem * GetNSItemByRangeTablePosn(ParseState *pstate, int varno, int sublevels_up)
ParseNamespaceItem * refnameNamespaceItem(ParseState *pstate, const char *schemaname, const char *refname, int location, int *sublevels_up)
Oid attnumTypeId(Relation rd, int attid)
List * expandNSItemAttrs(ParseState *pstate, ParseNamespaceItem *nsitem, int sublevels_up, bool require_col_privs, int location)
List * expandNSItemVars(ParseNamespaceItem *nsitem, int sublevels_up, int location, List **colnames)
void expandRTE(RangeTblEntry *rte, int rtindex, int sublevels_up, int location, bool include_dropped, List **colnames, List **colvars)
CommonTableExpr * GetCTEForRTE(ParseState *pstate, RangeTblEntry *rte, int rtelevelsup)
int attnameAttNum(Relation rd, const char *attname, bool sysColOK)
static List * ExpandColumnRefStar(ParseState *pstate, ColumnRef *cref, bool make_target_entry)
List * transformTargetList(ParseState *pstate, List *targetlist, ParseExprKind exprKind)
static int FigureColnameInternal(Node *node, char **name)
Expr * transformAssignedExpr(ParseState *pstate, Expr *expr, ParseExprKind exprKind, const char *colname, int attrno, List *indirection, int location)
static void markTargetListOrigin(ParseState *pstate, TargetEntry *tle, Var *var, int levelsup)
static List * ExpandSingleTable(ParseState *pstate, ParseNamespaceItem *nsitem, int sublevels_up, int location, bool make_target_entry)
char * FigureIndexColname(Node *node)
static List * ExpandRowReference(ParseState *pstate, Node *expr, bool make_target_entry)
void updateTargetListEntry(ParseState *pstate, TargetEntry *tle, char *colname, int attrno, List *indirection, int location)
void resolveTargetListUnknowns(ParseState *pstate, List *targetlist)
TargetEntry * transformTargetEntry(ParseState *pstate, Node *node, Node *expr, ParseExprKind exprKind, char *colname, bool resjunk)
void markTargetListOrigins(ParseState *pstate, List *targetlist)
List * checkInsertTargets(ParseState *pstate, List *cols, List **attrnos)
static List * ExpandIndirectionStar(ParseState *pstate, A_Indirection *ind, bool make_target_entry, ParseExprKind exprKind)
static Node * transformAssignmentSubscripts(ParseState *pstate, Node *basenode, const char *targetName, Oid targetTypeId, int32 targetTypMod, Oid targetCollation, List *subscripts, bool isSlice, List *indirection, ListCell *next_indirection, Node *rhs, CoercionContext ccontext, int location)
Node * transformAssignmentIndirection(ParseState *pstate, Node *basenode, const char *targetName, bool targetIsSubscripting, Oid targetTypeId, int32 targetTypMod, Oid targetCollation, List *indirection, ListCell *indirection_cell, Node *rhs, CoercionContext ccontext, int location)
static List * ExpandAllTables(ParseState *pstate, int location)
List * transformExpressionList(ParseState *pstate, List *exprlist, ParseExprKind exprKind, bool allowDefault)
char * FigureColname(Node *node)
TupleDesc expandRecordVariable(ParseState *pstate, Var *var, int levelsup)
Oid typeidTypeRelid(Oid type_id)
#define GetCTETargetList(cte)
FormData_pg_attribute * Form_pg_attribute
static int list_length(const List *l)
#define forboth(cell1, list1, cell2, list2)
#define for_each_cell(cell, lst, initcell)
static ListCell * list_head(const List *l)
static void * list_nth(const List *list, int n)
static ListCell * lnext(const List *l, const ListCell *c)
#define list_make1_int(x1)
@ SVFOP_CURRENT_TIMESTAMP
@ SVFOP_CURRENT_TIMESTAMP_N
#define RelationGetNumberOfAttributes(relation)
#define RelationGetRelationName(relation)
CTECycleClause * cycle_clause
CTESearchClause * search_clause
ParseState * parentParseState
ParseNamespaceItem * p_target_nsitem
ParseExprKind p_expr_kind
List * p_multiassign_exprs
PreParseColumnRefHook p_pre_columnref_hook
Relation p_target_relation
PostParseColumnRefHook p_post_columnref_hook
TupleDesc CreateTemplateTupleDesc(int natts)
void TupleDescInitEntryCollation(TupleDesc desc, AttrNumber attributeNumber, Oid collationid)
void TupleDescInitEntry(TupleDesc desc, AttrNumber attributeNumber, const char *attributeName, Oid oidtypeid, int32 typmod, int attdim)
#define TupleDescAttr(tupdesc, i)