Commitf3272ae

committed

handle CTA if not exists in SPI

1 parentcfe96ae commitf3272aeCopy full SHA for f3272ae

File tree

-3

lines changed

-3

lines changed

Lines changed: 9 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -2217,15 +2217,21 @@ _SPI_execute_plan(SPIPlanPtr plan, ParamListInfo paramLI,`
`2217`	`2217`	`*/`
`2218`	`2218`	`if (IsA(stmt,CreateTableAsStmt))`
`2219`	`2219`	`{`
`2220`		`-Assert(strncmp(completionTag,"SELECT ",7)==0);`
`2221`		`-_SPI_current->processed=pg_strtouint64(completionTag+7,`
	`2220`	`+CreateTableAsStmtctastmt= (CreateTableAsStmt)stmt;`
	`2221`	`+`
	`2222`	`+if (strncmp(completionTag,"SELECT ",7)==0)`
	`2223`	`+_SPI_current->processed=pg_strtouint64(completionTag+7,`
`2222`	`2224`	`NULL,10);`
	`2225`	`+elseif (*completionTag=='\0'&&ctastmt->if_not_exists)`
	`2226`	`+_SPI_current->processed=0;`
	`2227`	`+else`
	`2228`	`+Assert(false);`
`2223`	`2229`
`2224`	`2230`	`/*`
`2225`	`2231`	`* For historical reasons, if CREATE TABLE AS was spelled`
`2226`	`2232`	`* as SELECT INTO, return a special return code.`
`2227`	`2233`	`*/`
`2228`		`-if (((CreateTableAsStmt*)stmt)->is_select_into)`
	`2234`	`+if (ctastmt->is_select_into)`
`2229`	`2235`	`res=SPI_OK_SELINTO;`
`2230`	`2236`	`}`
`2231`	`2237`	`elseif (IsA(stmt,CopyStmt))`

Comments

(0)