aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/pl/plpgsql/src/pl_exec.c18
1 files changed, 13 insertions, 5 deletions
diff --git a/src/pl/plpgsql/src/pl_exec.c b/src/pl/plpgsql/src/pl_exec.c
index a69af302306..0f42d048236 100644
--- a/src/pl/plpgsql/src/pl_exec.c
+++ b/src/pl/plpgsql/src/pl_exec.c
@@ -3,7 +3,7 @@
* procedural language
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/pl/plpgsql/src/pl_exec.c,v 1.93 2003/10/01 21:47:42 tgl Exp $
+ * $Header: /cvsroot/pgsql/src/pl/plpgsql/src/pl_exec.c,v 1.93.2.1 2004/02/24 01:44:47 tgl Exp $
*
* This software is copyrighted by Jan Wieck - Hamburg.
*
@@ -262,10 +262,18 @@ plpgsql_exec_function(PLpgSQL_function * func, FunctionCallInfo fcinfo)
HeapTuple tup;
TupleDesc tupdesc;
- Assert(slot != NULL && !fcinfo->argnull[i]);
- tup = slot->val;
- tupdesc = slot->ttc_tupleDescriptor;
- exec_move_row(&estate, NULL, row, tup, tupdesc);
+ if (!fcinfo->argnull[i])
+ {
+ Assert(slot != NULL);
+ tup = slot->val;
+ tupdesc = slot->ttc_tupleDescriptor;
+ exec_move_row(&estate, NULL, row, tup, tupdesc);
+ }
+ else
+ {
+ /* If arg is null, treat it as an empty row */
+ exec_move_row(&estate, NULL, row, NULL, NULL);
+ }
}
break;