Commitd27f363

Jan Wieck

authored and

Jan Wieck

committed

Enhancement of SPI to get access to portals

- New functions to create a portal using a prepared/saved SPI plan or lookup an existing portal by name.- Functions to fetch/move from/in portals. Results are placed in the usual SPI_processed and SPI_tuptable, so the entire set of utility functions can be used to gain attribute access.- Prepared/saved SPI plans now use their own memory context and SPI_freeplan(plan) can remove them.- Tuple result sets (SPI_tuptable) now uses it's own memory context and can be free'd by SPI_freetuptable(tuptab).Enhancement of PL/pgSQL- Uses generic named portals internally in FOR ... SELECT loops to avoid running out of memory on huge result sets.- Support for CURSOR and REFCURSOR syntax using the new SPI functionality. Cursors used internally only need no explicit transaction block. Refcursor variables can be used inside of explicit transaction block to pass cursors between main application and functions.Jan

1 parentbe03eb2 commitd27f363Copy full SHA for d27f363

File tree

13 files changed

+1514

-114

lines changed

src
- backend
  - commands
    - command.c
  - executor
    - spi.c
- include
  - catalog
    - catversion.h
    - pg_type.h
  - executor
    - spi.h
    - spi_priv.h
  - utils
    - portal.h
- pl/plpgsql/src

13 files changed

+1514

-114

lines changed

`‎src/backend/commands/command.c`

Lines changed: 5 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -8,7 +8,7 @@`
`8`	`8`	`*`
`9`	`9`	`*`
`10`	`10`	`* IDENTIFICATION`
`11`		`- * $Header: /cvsroot/pgsql/src/backend/commands/Attic/command.c,v 1.127 2001/05/09 21:10:38 momjian Exp $`
	`11`	`+ * $Header: /cvsroot/pgsql/src/backend/commands/Attic/command.c,v 1.128 2001/05/21 14:22:11 wieck Exp $`
`12`	`12`	`*`
`13`	`13`	`* NOTES`
`14`	`14`	`* The PerformAddAttribute() code, like most of the relation`
`@@ -108,6 +108,7 @@ PerformPortalFetch(char *name,`
`108`	`108`	`QueryDesc*queryDesc;`
`109`	`109`	`EState*estate;`
`110`	`110`	`MemoryContextoldcontext;`
	`111`	`+boolfaked_desc= false;`
`111`	`112`
`112`	`113`	`/*`
`113`	`114`	`* sanity checks`
`@@ -143,13 +144,14 @@ PerformPortalFetch(char *name,`
`143`	`144`	`queryDesc=PortalGetQueryDesc(portal);`
`144`	`145`	`estate=PortalGetState(portal);`
`145`	`146`
`146`		`-if (dest==None)/* MOVE */`
	`147`	`+if (dest!=queryDesc->dest)/* MOVE */`
`147`	`148`	`{`
`148`	`149`	`QueryDescqdesc= (QueryDesc)palloc(sizeof(QueryDesc));`
`149`	`150`
`150`	`151`	`memcpy(qdesc,queryDesc,sizeof(QueryDesc));`
`151`	`152`	`qdesc->dest=dest;`
`152`	`153`	`queryDesc=qdesc;`
	`154`	`+faked_desc= true;`
`153`	`155`	`}`
`154`	`156`
`155`	`157`	`BeginCommand(name,`
`@@ -197,7 +199,7 @@ PerformPortalFetch(char *name,`
`197`	`199`	`/*`
`198`	`200`	`* Clean up and switch back to old context.`
`199`	`201`	`*/`
`200`		`-if (dest==None)/* MOVE */`
	`202`	`+if (faked_desc)/* MOVE */`
`201`	`203`	`pfree(queryDesc);`
`202`	`204`
`203`	`205`	`MemoryContextSwitchTo(oldcontext);`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commitd27f363

File tree

13 files changed

13 files changed

`‎src/backend/commands/command.c`

0 commit comments