PostgreSQL Source Code git master
Functions
createas.h File Reference
#include "catalog/objectaddress.h"
#include "nodes/params.h"
#include "parser/parse_node.h"
#include "tcop/dest.h"
#include "utils/queryenvironment.h"
Include dependency graph for createas.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions

ObjectAddress  ExecCreateTableAs (ParseState *pstate, CreateTableAsStmt *stmt, ParamListInfo params, QueryEnvironment *queryEnv, QueryCompletion *qc)
 
int  GetIntoRelEFlags (IntoClause *intoClause)
 
DestReceiver *  CreateIntoRelDestReceiver (IntoClause *intoClause)
 
bool  CreateTableAsRelExists (CreateTableAsStmt *ctas)
 

Function Documentation

◆ CreateIntoRelDestReceiver()

DestReceiver * CreateIntoRelDestReceiver ( IntoClause *  intoClause )

Definition at line 440 of file createas.c.

441{
442 DR_intorel *self = (DR_intorel *) palloc0(sizeof(DR_intorel));
443
448 self->pub.mydest = DestIntoRel;
449 self->into = intoClause;
450 /* other private fields will be set during intorel_startup */
451
452 return (DestReceiver *) self;
453}
static void intorel_shutdown(DestReceiver *self)
Definition: createas.c:614
static bool intorel_receive(TupleTableSlot *slot, DestReceiver *self)
Definition: createas.c:583
static void intorel_startup(DestReceiver *self, int operation, TupleDesc typeinfo)
Definition: createas.c:459
static void intorel_destroy(DestReceiver *self)
Definition: createas.c:634
@ DestIntoRel
Definition: dest.h:94
void * palloc0(Size size)
Definition: mcxt.c:1395
Definition: createas.c:52
IntoClause * into
Definition: createas.c:54
DestReceiver pub
Definition: createas.c:53
Definition: dest.h:116
void(* rStartup)(DestReceiver *self, int operation, TupleDesc typeinfo)
Definition: dest.h:121
void(* rShutdown)(DestReceiver *self)
Definition: dest.h:124
bool(* receiveSlot)(TupleTableSlot *slot, DestReceiver *self)
Definition: dest.h:118
void(* rDestroy)(DestReceiver *self)
Definition: dest.h:126
CommandDest mydest
Definition: dest.h:128

References DestIntoRel, DR_intorel::into, intorel_destroy(), intorel_receive(), intorel_shutdown(), intorel_startup(), _DestReceiver::mydest, palloc0(), DR_intorel::pub, _DestReceiver::rDestroy, _DestReceiver::receiveSlot, _DestReceiver::rShutdown, and _DestReceiver::rStartup.

Referenced by CreateDestReceiver(), ExecCreateTableAs(), and ExplainOnePlan().

◆ CreateTableAsRelExists()

bool CreateTableAsRelExists ( CreateTableAsStmt *  ctas )

Definition at line 393 of file createas.c.

394{
395 Oid nspid;
396 Oid oldrelid;
397 ObjectAddress address;
398 IntoClause *into = ctas->into;
399
401
402 oldrelid = get_relname_relid(into->rel->relname, nspid);
403 if (OidIsValid(oldrelid))
404 {
405 if (!ctas->if_not_exists)
407 (errcode(ERRCODE_DUPLICATE_TABLE),
408 errmsg("relation \"%s\" already exists",
409 into->rel->relname)));
410
411 /*
412 * The relation exists and IF NOT EXISTS has been specified.
413 *
414 * If we are in an extension script, insist that the pre-existing
415 * object be a member of the extension, to avoid security risks.
416 */
417 ObjectAddressSet(address, RelationRelationId, oldrelid);
419
420 /* OK to skip */
422 (errcode(ERRCODE_DUPLICATE_TABLE),
423 errmsg("relation \"%s\" already exists, skipping",
424 into->rel->relname)));
425 return true;
426 }
427
428 /* Relation does not exist, it can be created */
429 return false;
430}
#define OidIsValid(objectId)
Definition: c.h:774
int nspid
Definition: collationcmds.c:696
int errcode(int sqlerrcode)
Definition: elog.c:854
int errmsg(const char *fmt,...)
Definition: elog.c:1071
#define ERROR
Definition: elog.h:39
#define NOTICE
Definition: elog.h:35
#define ereport(elevel,...)
Definition: elog.h:150
Oid get_relname_relid(const char *relname, Oid relnamespace)
Definition: lsyscache.c:2052
Oid RangeVarGetCreationNamespace(const RangeVar *newRelation)
Definition: namespace.c:653
#define ObjectAddressSet(addr, class_id, object_id)
Definition: objectaddress.h:40
void checkMembershipInCurrentExtension(const ObjectAddress *object)
Definition: pg_depend.c:258
unsigned int Oid
Definition: postgres_ext.h:32
IntoClause * into
Definition: parsenodes.h:4028
RangeVar * rel
Definition: primnodes.h:163
char * relname
Definition: primnodes.h:83

References checkMembershipInCurrentExtension(), ereport, errcode(), errmsg(), ERROR, get_relname_relid(), CreateTableAsStmt::if_not_exists, CreateTableAsStmt::into, NOTICE, nspid, ObjectAddressSet, OidIsValid, RangeVarGetCreationNamespace(), IntoClause::rel, and RangeVar::relname.

Referenced by ExecCreateTableAs(), and ExplainOneUtility().

◆ ExecCreateTableAs()

ObjectAddress ExecCreateTableAs ( ParseState *  pstate,
CreateTableAsStmt *  stmt,
ParamListInfo  params,
QueryEnvironment *  queryEnv,
QueryCompletion *  qc 
)

Definition at line 223 of file createas.c.

226{
227 Query *query = castNode(Query, stmt->query);
228 IntoClause *into = stmt->into;
229 JumbleState *jstate = NULL;
230 bool is_matview = (into->viewQuery != NULL);
231 bool do_refresh = false;
233 ObjectAddress address;
234
235 /* Check if the relation exists or not */
238
239 /*
240 * Create the tuple receiver object and insert info it will need
241 */
243
244 /* Query contained by CTAS needs to be jumbled if requested */
245 if (IsQueryIdEnabled())
246 jstate = JumbleQuery(query);
247
249 (*post_parse_analyze_hook) (pstate, query, jstate);
250
251 /*
252 * The contained Query could be a SELECT, or an EXECUTE utility command.
253 * If the latter, we just pass it off to ExecuteQuery.
254 */
255 if (query->commandType == CMD_UTILITY &&
256 IsA(query->utilityStmt, ExecuteStmt))
257 {
258 ExecuteStmt *estmt = castNode(ExecuteStmt, query->utilityStmt);
259
260 Assert(!is_matview); /* excluded by syntax */
261 ExecuteQuery(pstate, estmt, into, params, dest, qc);
262
263 /* get object address that intorel_startup saved for us */
264 address = ((DR_intorel *) dest)->reladdr;
265
266 return address;
267 }
268 Assert(query->commandType == CMD_SELECT);
269
270 /*
271 * For materialized views, always skip data during table creation, and use
272 * REFRESH instead (see below).
273 */
274 if (is_matview)
275 {
276 do_refresh = !into->skipData;
277 into->skipData = true;
278 }
279
280 if (into->skipData)
281 {
282 /*
283 * If WITH NO DATA was specified, do not go through the rewriter,
284 * planner and executor. Just define the relation using a code path
285 * similar to CREATE VIEW. This avoids dump/restore problems stemming
286 * from running the planner before all dependencies are set up.
287 */
288 address = create_ctas_nodata(query->targetList, into);
289
290 /*
291 * For materialized views, reuse the REFRESH logic, which locks down
292 * security-restricted operations and restricts the search_path. This
293 * reduces the chance that a subsequent refresh will fail.
294 */
295 if (do_refresh)
296 RefreshMatViewByOid(address.objectId, true, false, false,
297 pstate->p_sourcetext, qc);
298
299 }
300 else
301 {
302 List *rewritten;
304 QueryDesc *queryDesc;
305
306 Assert(!is_matview);
307
308 /*
309 * Parse analysis was done already, but we still have to run the rule
310 * rewriter. We do not do AcquireRewriteLocks: we assume the query
311 * either came straight from the parser, or suitable locks were
312 * acquired by plancache.c.
313 */
314 rewritten = QueryRewrite(query);
315
316 /* SELECT should never rewrite to more or less than one SELECT query */
317 if (list_length(rewritten) != 1)
318 elog(ERROR, "unexpected rewrite result for CREATE TABLE AS SELECT");
319 query = linitial_node(Query, rewritten);
320 Assert(query->commandType == CMD_SELECT);
321
322 /* plan the query */
323 plan = pg_plan_query(query, pstate->p_sourcetext,
324 CURSOR_OPT_PARALLEL_OK, params);
325
326 /*
327 * Use a snapshot with an updated command ID to ensure this query sees
328 * results of any previously executed queries. (This could only
329 * matter if the planner executed an allegedly-stable function that
330 * changed the database contents, but let's do it anyway to be
331 * parallel to the EXPLAIN code path.)
332 */
335
336 /* Create a QueryDesc, redirecting output to our tuple receiver */
337 queryDesc = CreateQueryDesc(plan, pstate->p_sourcetext,
339 dest, params, queryEnv, 0);
340
341 /* call ExecutorStart to prepare the plan for execution */
342 ExecutorStart(queryDesc, GetIntoRelEFlags(into));
343
344 /* run the plan to completion */
345 ExecutorRun(queryDesc, ForwardScanDirection, 0);
346
347 /* save the rowcount if we're given a qc to fill */
348 if (qc)
349 SetQueryCompletion(qc, CMDTAG_SELECT, queryDesc->estate->es_processed);
350
351 /* get object address that intorel_startup saved for us */
352 address = ((DR_intorel *) dest)->reladdr;
353
354 /* and clean up */
355 ExecutorFinish(queryDesc);
356 ExecutorEnd(queryDesc);
357
358 FreeQueryDesc(queryDesc);
359
361 }
362
363 return address;
364}
void ExecuteQuery(ParseState *pstate, ExecuteStmt *stmt, IntoClause *intoClause, ParamListInfo params, DestReceiver *dest, QueryCompletion *qc)
Definition: prepare.c:150
static void SetQueryCompletion(QueryCompletion *qc, CommandTag commandTag, uint64 nprocessed)
Definition: cmdtag.h:37
bool CreateTableAsRelExists(CreateTableAsStmt *ctas)
Definition: createas.c:393
static ObjectAddress create_ctas_nodata(List *tlist, IntoClause *into)
Definition: createas.c:155
int GetIntoRelEFlags(IntoClause *intoClause)
Definition: createas.c:375
DestReceiver * CreateIntoRelDestReceiver(IntoClause *intoClause)
Definition: createas.c:440
#define elog(elevel,...)
Definition: elog.h:226
void ExecutorEnd(QueryDesc *queryDesc)
Definition: execMain.c:466
void ExecutorFinish(QueryDesc *queryDesc)
Definition: execMain.c:406
void ExecutorStart(QueryDesc *queryDesc, int eflags)
Definition: execMain.c:122
void ExecutorRun(QueryDesc *queryDesc, ScanDirection direction, uint64 count)
Definition: execMain.c:297
Assert(PointerIsAligned(start, uint64))
#define stmt
Definition: indent_codes.h:59
ObjectAddress RefreshMatViewByOid(Oid matviewOid, bool is_create, bool skipData, bool concurrent, const char *queryString, QueryCompletion *qc)
Definition: matview.c:165
dest
#define IsA(nodeptr, _type_)
Definition: nodes.h:164
@ CMD_UTILITY
Definition: nodes.h:280
@ CMD_SELECT
Definition: nodes.h:275
#define castNode(_type_, nodeptr)
Definition: nodes.h:182
const ObjectAddress InvalidObjectAddress
Definition: objectaddress.c:836
#define CURSOR_OPT_PARALLEL_OK
Definition: parsenodes.h:3396
post_parse_analyze_hook_type post_parse_analyze_hook
Definition: analyze.c:67
static int list_length(const List *l)
Definition: pg_list.h:152
#define linitial_node(type, l)
Definition: pg_list.h:181
#define plan(x)
Definition: pg_regress.c:161
PlannedStmt * pg_plan_query(Query *querytree, const char *query_string, int cursorOptions, ParamListInfo boundParams)
Definition: postgres.c:886
void FreeQueryDesc(QueryDesc *qdesc)
Definition: pquery.c:106
QueryDesc * CreateQueryDesc(PlannedStmt *plannedstmt, const char *sourceText, Snapshot snapshot, Snapshot crosscheck_snapshot, DestReceiver *dest, ParamListInfo params, QueryEnvironment *queryEnv, int instrument_options)
Definition: pquery.c:68
static bool IsQueryIdEnabled(void)
Definition: queryjumble.h:104
JumbleState * JumbleQuery(Query *query)
List * QueryRewrite(Query *parsetree)
@ ForwardScanDirection
Definition: sdir.h:28
void UpdateActiveSnapshotCommandId(void)
Definition: snapmgr.c:742
void PopActiveSnapshot(void)
Definition: snapmgr.c:773
void PushCopiedSnapshot(Snapshot snapshot)
Definition: snapmgr.c:730
Snapshot GetActiveSnapshot(void)
Definition: snapmgr.c:798
#define InvalidSnapshot
Definition: snapshot.h:119
uint64 es_processed
Definition: execnodes.h:714
bool skipData
Definition: primnodes.h:171
Definition: pg_list.h:54
EState * estate
Definition: execdesc.h:48
Definition: parsenodes.h:118

References Assert(), castNode, CMD_SELECT, CMD_UTILITY, Query::commandType, create_ctas_nodata(), CreateIntoRelDestReceiver(), CreateQueryDesc(), CreateTableAsRelExists(), CURSOR_OPT_PARALLEL_OK, generate_unaccent_rules::dest, elog, ERROR, EState::es_processed, QueryDesc::estate, ExecuteQuery(), ExecutorEnd(), ExecutorFinish(), ExecutorRun(), ExecutorStart(), ForwardScanDirection, FreeQueryDesc(), GetActiveSnapshot(), GetIntoRelEFlags(), InvalidObjectAddress, InvalidSnapshot, IsA, IsQueryIdEnabled(), JumbleQuery(), linitial_node, list_length(), ObjectAddress::objectId, ParseState::p_sourcetext, pg_plan_query(), plan, PopActiveSnapshot(), post_parse_analyze_hook, PushCopiedSnapshot(), QueryRewrite(), RefreshMatViewByOid(), SetQueryCompletion(), IntoClause::skipData, stmt, Query::targetList, UpdateActiveSnapshotCommandId(), and Query::utilityStmt.

Referenced by ProcessUtilitySlow().

◆ GetIntoRelEFlags()

int GetIntoRelEFlags ( IntoClause *  intoClause )

Definition at line 375 of file createas.c.

376{
377 int flags = 0;
378
379 if (intoClause->skipData)
380 flags |= EXEC_FLAG_WITH_NO_DATA;
381
382 return flags;
383}
#define EXEC_FLAG_WITH_NO_DATA
Definition: executor.h:72

References EXEC_FLAG_WITH_NO_DATA, and IntoClause::skipData.

Referenced by ExecCreateTableAs(), ExecuteQuery(), and ExplainOnePlan().

AltStyle によって変換されたページ (->オリジナル) /