pathnode.c 15.2 KB
Newer Older
1 2 3
/*-------------------------------------------------------------------------
 *
 * pathnode.c--
4
 *	  Routines to manipulate pathlists and create path nodes
5 6 7 8 9
 *
 * Copyright (c) 1994, Regents of the University of California
 *
 *
 * IDENTIFICATION
B
Bruce Momjian 已提交
10
 *	  $Header: /cvsroot/pgsql/src/backend/optimizer/util/pathnode.c,v 1.14 1999/02/02 23:53:25 momjian Exp $
11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29
 *
 *-------------------------------------------------------------------------
 */
#include <math.h>

#include "postgres.h"

#include "nodes/relation.h"
#include "utils/elog.h"

#include "optimizer/internal.h"
#include "optimizer/pathnode.h"
#include "optimizer/clauseinfo.h"
#include "optimizer/plancat.h"
#include "optimizer/cost.h"
#include "optimizer/keys.h"
#include "optimizer/xfunc.h"
#include "optimizer/ordering.h"

30
#include "parser/parsetree.h"	/* for getrelid() */
31

32
static Path *better_path(Path *new_path, List *unique_paths, bool *noOther);
33 34 35


/*****************************************************************************
36
 *		MISC. PATH UTILITIES
37 38
 *****************************************************************************/

39
/*
40
 * path-is-cheaper--
41 42
 *	  Returns t iff 'path1' is cheaper than 'path2'.
 *
43 44
 */
bool
45
path_is_cheaper(Path *path1, Path *path2)
46
{
47 48
	Cost		cost1 = path1->path_cost;
	Cost		cost2 = path2->path_cost;
49

50
	return (bool) (cost1 < cost2);
51 52
}

53
/*
54
 * set_cheapest--
55 56
 *	  Finds the minimum cost path from among a relation's paths.
 *
57 58
 * 'parent-rel' is the parent relation
 * 'pathlist' is a list of path nodes corresponding to 'parent-rel'
59 60
 *
 * Returns and sets the relation entry field with the pathnode that
61
 * is minimum.
62
 *
63
 */
64
Path *
65
set_cheapest(RelOptInfo * parent_rel, List *pathlist)
66
{
67 68
	List	   *p;
	Path	   *cheapest_so_far;
69

70
	Assert(pathlist != NIL);
B
Bruce Momjian 已提交
71
	Assert(IsA(parent_rel, RelOptInfo));
72

73
	cheapest_so_far = (Path *) lfirst(pathlist);
74

75 76
	foreach(p, lnext(pathlist))
	{
77
		Path	   *path = (Path *) lfirst(p);
78

79 80
		if (path_is_cheaper(path, cheapest_so_far))
			cheapest_so_far = path;
81 82
	}

83
	parent_rel->cheapestpath = cheapest_so_far;
84

85
	return cheapest_so_far;
86 87
}

88
/*
89
 * add_pathlist--
90 91 92 93 94 95
 *	  For each path in the list 'new-paths', add to the list 'unique-paths'
 *	  only those paths that are unique (i.e., unique ordering and ordering
 *	  keys).  Should a conflict arise, the more expensive path is thrown out,
 *	  thereby pruning the plan space.  But we don't prune if xfunc
 *	  told us not to.
 *
96
 * 'parent-rel' is the relation entry to which these paths correspond.
97
 *
98
 * Returns the list of unique pathnodes.
99
 *
100
 */
101
List *
102
add_pathlist(RelOptInfo * parent_rel, List *unique_paths, List *new_paths)
103
{
104 105 106 107
	List	   *x;
	Path	   *new_path;
	Path	   *old_path;
	bool		noOther;
108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134

	foreach(x, new_paths)
	{
		new_path = (Path *) lfirst(x);
		if (member(new_path, unique_paths))
			continue;
		old_path = better_path(new_path, unique_paths, &noOther);

		if (noOther)
		{
			/* Is a brand new path.  */
			new_path->parent = parent_rel;
			unique_paths = lcons(new_path, unique_paths);
		}
		else if (old_path == NULL)
		{
			;					/* do nothing if path is not cheaper */
		}
		else if (old_path != NULL)
		{						/* (IsA(old_path,Path)) { */
			new_path->parent = parent_rel;
			if (!parent_rel->pruneable)
				unique_paths = lcons(new_path, unique_paths);
			else
				unique_paths = lcons(new_path,
									 LispRemove(old_path, unique_paths));
		}
135
	}
136
	return unique_paths;
137 138
}

139
/*
140
 * better_path--
141 142 143 144
 *	  Determines whether 'new-path' has the same ordering and keys as some
 *	  path in the list 'unique-paths'.	If there is a redundant path,
 *	  eliminate the more expensive path.
 *
145
 * Returns:
146 147 148 149 150
 *	  The old path - if 'new-path' matches some path in 'unique-paths' and is
 *				cheaper
 *	  nil - if 'new-path' matches but isn't cheaper
 *	  t - if there is no path in the list with the same ordering and keys
 *
151
 */
152
static Path *
153
better_path(Path *new_path, List *unique_paths, bool *noOther)
154
{
155 156 157 158
	Path	   *old_path = (Path *) NULL;
	Path	   *path = (Path *) NULL;
	List	   *temp = NIL;
	Path	   *retval = NULL;
159 160 161 162 163

	foreach(temp, unique_paths)
	{
		path = (Path *) lfirst(temp);

B
Bruce Momjian 已提交
164 165 166
		if (samekeys(path->keys, new_path->keys) &&
			equal_path_path_ordering(&path->p_ordering,
									 &new_path->p_ordering))
167 168 169 170
		{
			old_path = path;
			break;
		}
171
	}
172 173 174 175 176 177 178 179

	if (old_path == NULL)
		*noOther = true;
	else
	{
		*noOther = false;
		if (path_is_cheaper(new_path, old_path))
			retval = old_path;
180
	}
181

182
	return retval;
183 184 185 186 187
}



/*****************************************************************************
188
 *		PATH NODE CREATION ROUTINES
189 190
 *****************************************************************************/

191
/*
192
 * create_seqscan_path--
193 194 195
 *	  Creates a path corresponding to a sequential scan, returning the
 *	  pathnode.
 *
196
 */
197
Path *
198
create_seqscan_path(RelOptInfo * rel)
199
{
200
	int			relid = 0;
201

202
	Path	   *pathnode = makeNode(Path);
203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223

	pathnode->pathtype = T_SeqScan;
	pathnode->parent = rel;
	pathnode->path_cost = 0.0;
	pathnode->p_ordering.ordtype = SORTOP_ORDER;
	pathnode->p_ordering.ord.sortop = NULL;
	pathnode->keys = NIL;

	/*
	 * copy clauseinfo list into path for expensive function processing --
	 * JMH, 7/7/92
	 */
	pathnode->locclauseinfo =
		(List *) copyObject((Node *) rel->clauseinfo);

	if (rel->relids != NULL)
		relid = lfirsti(rel->relids);

	pathnode->path_cost = cost_seqscan(relid,
									   rel->pages, rel->tuples);
	/* add in expensive functions cost!  -- JMH, 7/7/92 */
224
#if 0
225 226 227 228 229
	if (XfuncMode != XFUNC_OFF)
	{
		pathnode->path_cost +=
			xfunc_get_path_cost(pathnode);
	}
230
#endif
231
	return pathnode;
232 233
}

234
/*
235
 * create_index_path--
236 237
 *	  Creates a single path node for an index scan.
 *
238 239 240 241
 * 'rel' is the parent rel
 * 'index' is the pathnode for the index on 'rel'
 * 'restriction-clauses' is a list of restriction clause nodes.
 * 'is-join-scan' is a flag indicating whether or not the index is being
242 243
 *		considered because of its sort order.
 *
244
 * Returns the new path node.
245
 *
246
 */
247
IndexPath  *
248
create_index_path(Query *root,
249 250
				  RelOptInfo * rel,
				  RelOptInfo * index,
251
				  List *restriction_clauses,
252
				  bool is_join_scan)
253
{
254
	IndexPath  *pathnode = makeNode(IndexPath);
255 256 257 258 259 260 261 262 263 264

	pathnode->path.pathtype = T_IndexScan;
	pathnode->path.parent = rel;
	pathnode->path.p_ordering.ordtype = SORTOP_ORDER;
	pathnode->path.p_ordering.ord.sortop = index->ordering;

	pathnode->indexid = index->relids;
	pathnode->indexkeys = index->indexkeys;
	pathnode->indexqual = NIL;

265
	/*
266 267
	 * copy clauseinfo list into path for expensive function processing --
	 * JMH, 7/7/92
268
	 */
269 270 271
	pathnode->path.locclauseinfo =
		set_difference((List *) copyObject((Node *) rel->clauseinfo),
					   (List *) restriction_clauses);
272 273

	/*
274 275
	 * The index must have an ordering for the path to have (ordering)
	 * keys, and vice versa.
276
	 */
277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302
	if (pathnode->path.p_ordering.ord.sortop)
	{
		pathnode->path.keys = collect_index_pathkeys(index->indexkeys,
													 rel->targetlist);

		/*
		 * Check that the keys haven't 'disappeared', since they may no
		 * longer be in the target list (i.e., index keys that are not
		 * relevant to the scan are not applied to the scan path node, so
		 * if no index keys were found, we can't order the path).
		 */
		if (pathnode->path.keys == NULL)
			pathnode->path.p_ordering.ord.sortop = NULL;
	}
	else
		pathnode->path.keys = NULL;

	if (is_join_scan || restriction_clauses == NULL)
	{

		/*
		 * Indices used for joins or sorting result nodes don't restrict
		 * the result at all, they simply order it, so compute the scan
		 * cost accordingly -- use a selectivity of 1.0.
		 */
/* is the statement above really true?	what about IndexScan as the
303
   inner of a join? */
304 305 306 307 308 309 310 311 312 313
		pathnode->path.path_cost =
			cost_index(lfirsti(index->relids),
					   index->pages,
					   1.0,
					   rel->pages,
					   rel->tuples,
					   index->pages,
					   index->tuples,
					   false);
		/* add in expensive functions cost!  -- JMH, 7/7/92 */
314
#if 0
315 316 317 318 319 320
		if (XfuncMode != XFUNC_OFF)
		{
			pathnode->path_cost =
				(pathnode->path_cost +
				 xfunc_get_path_cost((Path *) pathnode));
		}
321
#endif
322 323 324 325 326 327 328 329
	}
	else
	{

		/*
		 * Compute scan cost for the case when 'index' is used with a
		 * restriction clause.
		 */
330 331 332 333 334 335
		List	   *attnos;
		List	   *values;
		List	   *flags;
		float		npages;
		float		selec;
		Cost		clausesel;
336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352

		get_relattvals(restriction_clauses,
					   &attnos,
					   &values,
					   &flags);
		index_selectivity(lfirsti(index->relids),
						  index->classlist,
						  get_opnos(restriction_clauses),
						  getrelid(lfirsti(rel->relids),
								   root->rtable),
						  attnos,
						  values,
						  flags,
						  length(restriction_clauses),
						  &npages,
						  &selec);
		/* each clause gets an equal selectivity */
B
Bruce Momjian 已提交
353
		clausesel =	pow(selec, 1.0 / (double) length(restriction_clauses));
354 355

		pathnode->indexqual = restriction_clauses;
B
Bruce Momjian 已提交
356 357 358 359 360 361 362 363
		pathnode->path.path_cost = cost_index(lfirsti(index->relids),
											   (int) npages,
											   selec,
											   rel->pages,
											   rel->tuples,
											   index->pages,
											   index->tuples,
											   false);
364 365

#if 0
366 367 368 369 370 371
		/* add in expensive functions cost!  -- JMH, 7/7/92 */
		if (XfuncMode != XFUNC_OFF)
		{
			pathnode->path_cost +=
				xfunc_get_path_cost((Path *) pathnode);
		}
372 373
#endif

374 375 376 377 378 379 380 381 382
		/*
		 * Set selectivities of clauses used with index to the selectivity
		 * of this index, subdividing the selectivity equally over each of
		 * the clauses.
		 */

		/* XXX Can this divide the selectivities in a better way? */
		set_clause_selectivities(restriction_clauses, clausesel);
	}
383
	return pathnode;
384 385
}

386
/*
387
 * create_nestloop_path--
388 389 390
 *	  Creates a pathnode corresponding to a nestloop join between two
 *	  relations.
 *
391 392 393 394 395
 * 'joinrel' is the join relation.
 * 'outer_rel' is the outer join relation
 * 'outer_path' is the outer join path.
 * 'inner_path' is the inner join path.
 * 'keys' are the keys of the path
396
 *
397
 * Returns the resulting path node.
398
 *
399
 */
400
JoinPath   *
401 402
create_nestloop_path(RelOptInfo * joinrel,
					 RelOptInfo * outer_rel,
403 404 405
					 Path *outer_path,
					 Path *inner_path,
					 List *keys)
406
{
407
	JoinPath   *pathnode = makeNode(JoinPath);
408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432

	pathnode->path.pathtype = T_NestLoop;
	pathnode->path.parent = joinrel;
	pathnode->outerjoinpath = outer_path;
	pathnode->innerjoinpath = inner_path;
	pathnode->pathclauseinfo = joinrel->clauseinfo;
	pathnode->path.keys = keys;
	pathnode->path.joinid = NIL;
	pathnode->path.outerjoincost = (Cost) 0.0;
	pathnode->path.locclauseinfo = NIL;

	if (keys)
	{
		pathnode->path.p_ordering.ordtype =
			outer_path->p_ordering.ordtype;
		if (outer_path->p_ordering.ordtype == SORTOP_ORDER)
		{
			pathnode->path.p_ordering.ord.sortop =
				outer_path->p_ordering.ord.sortop;
		}
		else
		{
			pathnode->path.p_ordering.ord.merge =
				outer_path->p_ordering.ord.merge;
		}
433
	}
434 435 436 437 438 439 440 441 442 443 444 445 446 447 448
	else
	{
		pathnode->path.p_ordering.ordtype = SORTOP_ORDER;
		pathnode->path.p_ordering.ord.sortop = NULL;
	}

	pathnode->path.path_cost =
		cost_nestloop(outer_path->path_cost,
					  inner_path->path_cost,
					  outer_rel->size,
					  inner_path->parent->size,
					  page_size(outer_rel->size,
								outer_rel->width),
					  IsA(inner_path, IndexPath));
	/* add in expensive function costs -- JMH 7/7/92 */
449
#if 0
450 451
	if (XfuncMode != XFUNC_OFF)
		pathnode->path_cost += xfunc_get_path_cost((Path *) pathnode);
452
#endif
453
	return pathnode;
454 455
}

456
/*
457 458
 * create_mergejoin_path--
 *	  Creates a pathnode corresponding to a mergejoin join between
459 460
 *	  two relations
 *
461 462 463 464 465 466 467 468 469 470 471 472
 * 'joinrel' is the join relation
 * 'outersize' is the number of tuples in the outer relation
 * 'innersize' is the number of tuples in the inner relation
 * 'outerwidth' is the number of bytes per tuple in the outer relation
 * 'innerwidth' is the number of bytes per tuple in the inner relation
 * 'outer_path' is the outer path
 * 'inner_path' is the inner path
 * 'keys' are the new keys of the join relation
 * 'order' is the sort order required for the merge
 * 'mergeclauses' are the applicable join/restriction clauses
 * 'outersortkeys' are the sort varkeys for the outer relation
 * 'innersortkeys' are the sort varkeys for the inner relation
473
 *
474
 */
475
MergePath  *
476
create_mergejoin_path(RelOptInfo * joinrel,
477 478 479 480
					  int outersize,
					  int innersize,
					  int outerwidth,
					  int innerwidth,
481 482 483 484 485 486 487
					  Path *outer_path,
					  Path *inner_path,
					  List *keys,
					  MergeOrder *order,
					  List *mergeclauses,
					  List *outersortkeys,
					  List *innersortkeys)
488
{
489
	MergePath  *pathnode = makeNode(MergePath);
490 491 492 493 494 495 496 497 498 499 500 501 502 503

	pathnode->jpath.path.pathtype = T_MergeJoin;
	pathnode->jpath.path.parent = joinrel;
	pathnode->jpath.outerjoinpath = outer_path;
	pathnode->jpath.innerjoinpath = inner_path;
	pathnode->jpath.pathclauseinfo = joinrel->clauseinfo;
	pathnode->jpath.path.keys = keys;
	pathnode->jpath.path.p_ordering.ordtype = MERGE_ORDER;
	pathnode->jpath.path.p_ordering.ord.merge = order;
	pathnode->path_mergeclauses = mergeclauses;
	pathnode->jpath.path.locclauseinfo = NIL;
	pathnode->outersortkeys = outersortkeys;
	pathnode->innersortkeys = innersortkeys;
	pathnode->jpath.path.path_cost =
504
		cost_mergejoin(outer_path->path_cost,
505 506 507 508 509 510 511 512
					   inner_path->path_cost,
					   outersortkeys,
					   innersortkeys,
					   outersize,
					   innersize,
					   outerwidth,
					   innerwidth);
	/* add in expensive function costs -- JMH 7/7/92 */
513
#if 0
514 515 516 517 518
	if (XfuncMode != XFUNC_OFF)
	{
		pathnode->path_cost +=
			xfunc_get_path_cost((Path *) pathnode);
	}
519
#endif
520
	return pathnode;
521 522
}

523 524 525 526
/*
 * create_hashjoin_path--						XXX HASH
 *	  Creates a pathnode corresponding to a hash join between two relations.
 *
527 528 529 530 531 532 533 534 535 536 537 538
 * 'joinrel' is the join relation
 * 'outersize' is the number of tuples in the outer relation
 * 'innersize' is the number of tuples in the inner relation
 * 'outerwidth' is the number of bytes per tuple in the outer relation
 * 'innerwidth' is the number of bytes per tuple in the inner relation
 * 'outer_path' is the outer path
 * 'inner_path' is the inner path
 * 'keys' are the new keys of the join relation
 * 'operator' is the hashjoin operator
 * 'hashclauses' are the applicable join/restriction clauses
 * 'outerkeys' are the sort varkeys for the outer relation
 * 'innerkeys' are the sort varkeys for the inner relation
539
 *
540
 */
541
HashPath   *
542
create_hashjoin_path(RelOptInfo * joinrel,
543 544 545 546
					 int outersize,
					 int innersize,
					 int outerwidth,
					 int innerwidth,
547 548 549
					 Path *outer_path,
					 Path *inner_path,
					 List *keys,
550
					 Oid operator,
551 552 553
					 List *hashclauses,
					 List *outerkeys,
					 List *innerkeys)
554
{
555
	HashPath   *pathnode = makeNode(HashPath);
556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579

	pathnode->jpath.path.pathtype = T_HashJoin;
	pathnode->jpath.path.parent = joinrel;
	pathnode->jpath.outerjoinpath = outer_path;
	pathnode->jpath.innerjoinpath = inner_path;
	pathnode->jpath.pathclauseinfo = joinrel->clauseinfo;
	pathnode->jpath.path.locclauseinfo = NIL;
	pathnode->jpath.path.keys = keys;
	pathnode->jpath.path.p_ordering.ordtype = SORTOP_ORDER;
	pathnode->jpath.path.p_ordering.ord.sortop = NULL;
	pathnode->jpath.path.outerjoincost = (Cost) 0.0;
	pathnode->jpath.path.joinid = (Relid) NULL;
	/* pathnode->hashjoinoperator = operator;  */
	pathnode->path_hashclauses = hashclauses;
	pathnode->outerhashkeys = outerkeys;
	pathnode->innerhashkeys = innerkeys;
	pathnode->jpath.path.path_cost =
		cost_hashjoin(outer_path->path_cost,
					  inner_path->path_cost,
					  outerkeys,
					  innerkeys,
					  outersize, innersize,
					  outerwidth, innerwidth);
	/* add in expensive function costs -- JMH 7/7/92 */
580
#if 0
581 582 583 584 585
	if (XfuncMode != XFUNC_OFF)
	{
		pathnode->path_cost +=
			xfunc_get_path_cost((Path *) pathnode);
	}
586
#endif
587
	return pathnode;
588
}