diff options
author | Tom Lane <tgl@sss.pgh.pa.us> | 2003-09-25 23:02:12 +0000 |
---|---|---|
committer | Tom Lane <tgl@sss.pgh.pa.us> | 2003-09-25 23:02:12 +0000 |
commit | 2848dc5feaa3bc4b0449c132bc94641b3cb7813e (patch) | |
tree | 4a259add292c9a016ac11bd2dfb29b7a65b128e8 /src/backend/executor/nodeFunctionscan.c | |
parent | a039148cad93b117d3317ee5e30fbf3f87568ac1 (diff) | |
download | postgresql-2848dc5feaa3bc4b0449c132bc94641b3cb7813e.tar.gz postgresql-2848dc5feaa3bc4b0449c132bc94641b3cb7813e.zip |
Make the world safe (more or less) for dropped columns in plpgsql rowtypes.
Diffstat (limited to 'src/backend/executor/nodeFunctionscan.c')
-rw-r--r-- | src/backend/executor/nodeFunctionscan.c | 45 |
1 files changed, 27 insertions, 18 deletions
diff --git a/src/backend/executor/nodeFunctionscan.c b/src/backend/executor/nodeFunctionscan.c index ca25774805b..a47e37d7e55 100644 --- a/src/backend/executor/nodeFunctionscan.c +++ b/src/backend/executor/nodeFunctionscan.c @@ -8,7 +8,7 @@ * * * IDENTIFICATION - * $Header: /cvsroot/pgsql/src/backend/executor/nodeFunctionscan.c,v 1.21 2003/09/25 06:57:59 petere Exp $ + * $Header: /cvsroot/pgsql/src/backend/executor/nodeFunctionscan.c,v 1.22 2003/09/25 23:02:12 tgl Exp $ * *------------------------------------------------------------------------- */ @@ -35,7 +35,7 @@ static TupleTableSlot *FunctionNext(FunctionScanState *node); -static bool tupledesc_mismatch(TupleDesc tupdesc1, TupleDesc tupdesc2); +static bool tupledesc_match(TupleDesc dst_tupdesc, TupleDesc src_tupdesc); /* ---------------------------------------------------------------- * Scan Support @@ -86,8 +86,7 @@ FunctionNext(FunctionScanState *node) * need to do this for functions returning RECORD, but might as * well do it always. */ - if (funcTupdesc && - tupledesc_mismatch(node->tupdesc, funcTupdesc)) + if (funcTupdesc && !tupledesc_match(node->tupdesc, funcTupdesc)) ereport(ERROR, (errcode(ERRCODE_DATATYPE_MISMATCH), errmsg("query-specified return row and actual function return row do not match"))); @@ -364,26 +363,36 @@ ExecFunctionReScan(FunctionScanState *node, ExprContext *exprCtxt) tuplestore_rescan(node->tuplestorestate); } - +/* + * Check that function result tuple type (src_tupdesc) matches or can be + * considered to match what the query expects (dst_tupdesc). + * + * We really only care about number of attributes and data type. + * Also, we can ignore type mismatch on columns that are dropped in the + * destination type, so long as the physical storage matches. This is + * helpful in some cases involving out-of-date cached plans. + */ static bool -tupledesc_mismatch(TupleDesc tupdesc1, TupleDesc tupdesc2) +tupledesc_match(TupleDesc dst_tupdesc, TupleDesc src_tupdesc) { int i; - if (tupdesc1->natts != tupdesc2->natts) - return true; + if (dst_tupdesc->natts != src_tupdesc->natts) + return false; - for (i = 0; i < tupdesc1->natts; i++) + for (i = 0; i < dst_tupdesc->natts; i++) { - Form_pg_attribute attr1 = tupdesc1->attrs[i]; - Form_pg_attribute attr2 = tupdesc2->attrs[i]; - - /* - * We really only care about number of attributes and data type - */ - if (attr1->atttypid != attr2->atttypid) - return true; + Form_pg_attribute dattr = dst_tupdesc->attrs[i]; + Form_pg_attribute sattr = src_tupdesc->attrs[i]; + + if (dattr->atttypid == sattr->atttypid) + continue; /* no worries */ + if (!dattr->attisdropped) + return false; + if (dattr->attlen != sattr->attlen || + dattr->attalign != sattr->attalign) + return false; } - return false; + return true; } |