indxpath.c 35.8 KB
Newer Older
1 2 3
/*-------------------------------------------------------------------------
 *
 * indxpath.c--
4 5
 *	  Routines to determine which indices are usable for scanning a
 *	  given relation
6 7 8 9 10
 *
 * Copyright (c) 1994, Regents of the University of California
 *
 *
 * IDENTIFICATION
B
Bruce Momjian 已提交
11
 *	  $Header: /cvsroot/pgsql/src/backend/optimizer/path/indxpath.c,v 1.27 1998/08/10 04:49:37 momjian Exp $
12 13 14 15
 *
 *-------------------------------------------------------------------------
 */
#include <math.h>
B
Bruce Momjian 已提交
16

17
#include "postgres.h"
B
Bruce Momjian 已提交
18

19 20 21
#include "access/attnum.h"
#include "access/heapam.h"
#include "access/nbtree.h"
B
Bruce Momjian 已提交
22 23
#include "catalog/catname.h"
#include "catalog/pg_amop.h"
B
Bruce Momjian 已提交
24
#include "catalog/pg_type.h"
B
Bruce Momjian 已提交
25 26
#include "executor/executor.h"
#include "fmgr.h"
27 28
#include "nodes/makefuncs.h"
#include "nodes/nodeFuncs.h"
B
Bruce Momjian 已提交
29 30
#include "nodes/pg_list.h"
#include "nodes/relation.h"
31 32 33
#include "optimizer/clauses.h"
#include "optimizer/clauseinfo.h"
#include "optimizer/cost.h"
B
Bruce Momjian 已提交
34 35 36 37 38
#include "optimizer/internal.h"
#include "optimizer/keys.h"
#include "optimizer/ordering.h"
#include "optimizer/paths.h"
#include "optimizer/plancat.h"
39 40
#include "optimizer/pathnode.h"
#include "optimizer/xfunc.h"
41
#include "parser/parsetree.h"	/* for getrelid() */
B
Bruce Momjian 已提交
42
#include "utils/lsyscache.h"
43 44 45


static void
B
Bruce Momjian 已提交
46
match_index_orclauses(RelOptInfo *rel, RelOptInfo *index, int indexkey,
47
					  int xclass, List *clauseinfo_list);
48
static bool
49
match_index_to_operand(int indexkey, Expr *operand,
B
Bruce Momjian 已提交
50
					   RelOptInfo *rel, RelOptInfo *index);
51
static List *
B
Bruce Momjian 已提交
52
match_index_orclause(RelOptInfo *rel, RelOptInfo *index, int indexkey,
53
			 int xclass, List *or_clauses, List *other_matching_indices);
54
static List *
B
Bruce Momjian 已提交
55
group_clauses_by_indexkey(RelOptInfo *rel, RelOptInfo *index,
56
					int *indexkeys, Oid *classes, List *clauseinfo_list);
57
static List *
B
Bruce Momjian 已提交
58
group_clauses_by_ikey_for_joins(RelOptInfo *rel, RelOptInfo *index,
59
								int *indexkeys, Oid *classes, List *join_cinfo_list, List *restr_cinfo_list);
60
static CInfo *
B
Bruce Momjian 已提交
61
match_clause_to_indexkey(RelOptInfo *rel, RelOptInfo *index, int indexkey,
62
						 int xclass, CInfo *clauseInfo, bool join);
63
static bool
64 65 66 67 68 69
pred_test(List *predicate_list, List *clauseinfo_list,
		  List *joininfo_list);
static bool one_pred_test(Expr *predicate, List *clauseinfo_list);
static bool one_pred_clause_expr_test(Expr *predicate, Node *clause);
static bool one_pred_clause_test(Expr *predicate, Node *clause);
static bool clause_pred_clause_test(Expr *predicate, Node *clause);
70
static List *
B
Bruce Momjian 已提交
71
indexable_joinclauses(RelOptInfo *rel, RelOptInfo *index,
72
					  List *joininfo_list, List *clauseinfo_list);
73
static List *
B
Bruce Momjian 已提交
74 75
index_innerjoin(Query *root, RelOptInfo *rel,
				List *clausegroup_list, RelOptInfo *index);
76
static List *
B
Bruce Momjian 已提交
77
create_index_paths(Query *root, RelOptInfo *rel, RelOptInfo *index,
78 79
				   List *clausegroup_list, bool join);
static List *add_index_paths(List *indexpaths, List *new_indexpaths);
B
Bruce Momjian 已提交
80
static bool function_index_operand(Expr *funcOpnd, RelOptInfo *rel, RelOptInfo *index);
81 82


83
/*
84
 * find-index-paths--
85 86 87 88 89 90 91 92 93 94 95 96 97
 *	  Finds all possible index paths by determining which indices in the
 *	  list 'indices' are usable.
 *
 *	  To be usable, an index must match against either a set of
 *	  restriction clauses or join clauses.
 *
 *	  Note that the current implementation requires that there exist
 *	  matching clauses for every key in the index (i.e., no partial
 *	  matches are allowed).
 *
 *	  If an index can't be used with restriction clauses, but its keys
 *	  match those of the result sort order (according to information stored
 *	  within 'sortkeys'), then the index is also considered.
98 99 100 101 102 103
 *
 * 'rel' is the relation entry to which these index paths correspond
 * 'indices' is a list of possible index paths
 * 'clauseinfo-list' is a list of restriction clauseinfo nodes for 'rel'
 * 'joininfo-list' is a list of joininfo nodes for 'rel'
 * 'sortkeys' is a node describing the result sort order (from
104 105
 *		(find_sortkeys))
 *
106
 * Returns a list of index nodes.
107
 *
108
 */
109
List *
110
find_index_paths(Query *root,
B
Bruce Momjian 已提交
111
				 RelOptInfo *rel,
112 113 114
				 List *indices,
				 List *clauseinfo_list,
				 List *joininfo_list)
115
{
116 117
	List	   *scanclausegroups = NIL;
	List	   *scanpaths = NIL;
B
Bruce Momjian 已提交
118
	RelOptInfo		   *index = (RelOptInfo *) NULL;
119 120 121
	List	   *joinclausegroups = NIL;
	List	   *joinpaths = NIL;
	List	   *retval = NIL;
B
Bruce Momjian 已提交
122 123 124
	List	   *ilist;
	
	foreach(ilist, indices)
125
	{
B
Bruce Momjian 已提交
126 127 128 129 130 131 132 133 134 135 136 137 138 139 140
		index = (RelOptInfo *) lfirst(ilist);
	
		/* If this is a partial index, return if it fails the predicate test */
		if (index->indpred != NIL)
			if (!pred_test(index->indpred, clauseinfo_list, joininfo_list))
				continue;
	
		/*
		 * 1. Try matching the index against subclauses of an 'or' clause.
		 * The fields of the clauseinfo nodes are marked with lists of the
		 * matching indices.  No path are actually created.  We currently
		 * only look to match the first key.  We don't find multi-key index
		 * cases where an AND matches the first key, and the OR matches the
		 * second key.
		 */
141
		match_index_orclauses(rel,
B
Bruce Momjian 已提交
142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194
								  index,
								  index->indexkeys[0],
								  index->classlist[0],
								  clauseinfo_list);
	
		/*
		 * 2. If the keys of this index match any of the available restriction
		 * clauses, then create pathnodes corresponding to each group of
		 * usable clauses.
		 */
		scanclausegroups = group_clauses_by_indexkey(rel,
													 index,
													 index->indexkeys,
													 index->classlist,
													 clauseinfo_list);
	
		scanpaths = NIL;
		if (scanclausegroups != NIL)
			scanpaths = create_index_paths(root,
										   rel,
										   index,
										   scanclausegroups,
										   false);
	
		/*
		 * 3. If this index can be used with any join clause, then create
		 * pathnodes for each group of usable clauses.	An index can be used
		 * with a join clause if its ordering is useful for a mergejoin, or if
		 * the index can possibly be used for scanning the inner relation of a
		 * nestloop join.
		 */
		joinclausegroups = indexable_joinclauses(rel, index, joininfo_list, clauseinfo_list);
		joinpaths = NIL;
	
		if (joinclausegroups != NIL)
		{
			List	   *new_join_paths = create_index_paths(root, rel,
															index,
															joinclausegroups,
															true);
			List	   *innerjoin_paths = index_innerjoin(root, rel, joinclausegroups, index);
	
			rel->innerjoin = nconc(rel->innerjoin, innerjoin_paths);
			joinpaths = new_join_paths;
		}
	
		/*
		 * Some sanity checks to make sure that the indexpath is valid.
		 */
		if (joinpaths != NULL)
			retval = add_index_paths(joinpaths, retval);
		if (scanpaths != NULL)
			retval = add_index_paths(scanpaths, retval);
195
	}
B
Bruce Momjian 已提交
196
	
197
	return retval;
198 199 200 201 202

}


/****************************************************************************
203
 *		----  ROUTINES TO MATCH 'OR' CLAUSES  ----
204 205 206
 ****************************************************************************/


207
/*
208
 * match-index-orclauses--
209 210 211 212 213 214 215
 *	  Attempt to match an index against subclauses within 'or' clauses.
 *	  If the index does match, then the clause is marked with information
 *	  about the index.
 *
 *	  Essentially, this adds 'index' to the list of indices in the
 *	  ClauseInfo field of each of the clauses which it matches.
 *
216 217 218 219 220
 * 'rel' is the node of the relation on which the index is defined.
 * 'index' is the index node.
 * 'indexkey' is the (single) key of the index
 * 'class' is the class of the operator corresponding to 'indexkey'.
 * 'clauseinfo-list' is the list of available restriction clauses.
221
 *
222
 * Returns nothing.
223
 *
224 225
 */
static void
B
Bruce Momjian 已提交
226 227
match_index_orclauses(RelOptInfo *rel,
					  RelOptInfo *index,
228 229
					  int indexkey,
					  int xclass,
230
					  List *clauseinfo_list)
231
{
232 233
	CInfo	   *clauseinfo = (CInfo *) NULL;
	List	   *i = NIL;
234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251

	foreach(i, clauseinfo_list)
	{
		clauseinfo = (CInfo *) lfirst(i);
		if (valid_or_clause(clauseinfo))
		{

			/*
			 * Mark the 'or' clause with a list of indices which match
			 * each of its subclauses.	The list is generated by adding
			 * 'index' to the existing list where appropriate.
			 */
			clauseinfo->indexids =
				match_index_orclause(rel, index, indexkey,
									 xclass,
									 clauseinfo->clause->args,
									 clauseinfo->indexids);
		}
252 253 254 255 256
	}
}

/*
 * match_index_operand--
257 258 259
 *	  Generalize test for a match between an existing index's key
 *	  and the operand on the rhs of a restriction clause.  Now check
 *	  for functional indices as well.
260
 */
261
static bool
262
match_index_to_operand(int indexkey,
263
					   Expr *operand,
B
Bruce Momjian 已提交
264 265
					   RelOptInfo *rel,
					   RelOptInfo *index)
266
{
267 268 269 270 271 272 273 274 275 276 277

	/*
	 * Normal index.
	 */
	if (index->indproc == InvalidOid)
		return match_indexkey_operand(indexkey, (Var *) operand, rel);

	/*
	 * functional index check
	 */
	return (function_index_operand(operand, rel, index));
278 279
}

280
/*
281
 * match-index-orclause--
282 283 284 285 286 287
 *	  Attempts to match an index against the subclauses of an 'or' clause.
 *
 *	  A match means that:
 *	  (1) the operator within the subclause can be used with one
 *				of the index's operator classes, and
 *	  (2) there is a usable key that matches the variable within a
B
Bruce Momjian 已提交
288
 *				searchable clause.
289
 *
290 291
 * 'or-clauses' are the remaining subclauses within the 'or' clause
 * 'other-matching-indices' is the list of information on other indices
292 293 294 295
 *		that have already been matched to subclauses within this
 *		particular 'or' clause (i.e., a list previously generated by
 *		this routine)
 *
296 297 298 299 300
 * Returns a list of the form ((a b c) (d e f) nil (g h) ...) where
 * a,b,c are nodes of indices that match the first subclause in
 * 'or-clauses', d,e,f match the second subclause, no indices
 * match the third, g,h match the fourth, etc.
 */
301
static List *
B
Bruce Momjian 已提交
302 303
match_index_orclause(RelOptInfo *rel,
					 RelOptInfo *index,
304 305
					 int indexkey,
					 int xclass,
306 307
					 List *or_clauses,
					 List *other_matching_indices)
308
{
309
	Node	   *clause = NULL;
B
Bruce Momjian 已提交
310
	List	   *matching_indices = other_matching_indices;
311 312
	List	   *index_list = NIL;
	List	   *clist;
313

B
Bruce Momjian 已提交
314 315 316 317 318 319 320 321 322 323
	/* first time through, we create index list */
	if (!other_matching_indices)
	{
		foreach(clist, or_clauses)
			matching_indices = lcons(NIL, matching_indices);
	}
	else	matching_indices = other_matching_indices;

	index_list = matching_indices;
	
B
Bruce Momjian 已提交
324
	foreach(clist, or_clauses)
325
	{
326
		clause = lfirst(clist);
327
			
328 329 330
		if (is_opclause(clause) &&
			op_class(((Oper *) ((Expr *) clause)->oper)->opno,
					 xclass, index->relam) &&
B
Bruce Momjian 已提交
331 332 333 334 335 336
			((match_index_to_operand(indexkey,
								   (Expr *) get_leftop((Expr *) clause),
								   rel,
								   index) &&
			  IsA(get_rightop((Expr *) clause), Const)) ||
			 (match_index_to_operand(indexkey,
337 338 339
								   (Expr *) get_leftop((Expr *) clause),
								   rel,
								   index) &&
B
Bruce Momjian 已提交
340
			 IsA(get_rightop((Expr *) clause), Const))))
341
		{
B
Bruce Momjian 已提交
342
			lfirst(matching_indices) = lcons(index, lfirst(matching_indices));
343
		}
B
Bruce Momjian 已提交
344

B
Bruce Momjian 已提交
345
		matching_indices = lnext(matching_indices);
346
	}
347 348
	return (index_list);

349 350 351
}

/****************************************************************************
352
 *				----  ROUTINES TO CHECK RESTRICTIONS  ----
353 354 355 356 357 358 359 360 361 362 363 364 365
 ****************************************************************************/


/*
 * DoneMatchingIndexKeys() - MACRO
 *
 * Determine whether we should continue matching index keys in a clause.
 * Depends on if there are more to match or if this is a functional index.
 * In the latter case we stop after the first match since the there can
 * be only key (i.e. the function's return value) and the attributes in
 * keys list represent the arguments to the function.  -mer 3 Oct. 1991
 */
#define DoneMatchingIndexKeys(indexkeys, index) \
366 367
		(indexkeys[0] == 0 || \
		 (index->indproc != InvalidOid))
368

369
/*
370
 * group-clauses-by-indexkey--
371 372 373
 *	  Determines whether there are clauses which will match each and every
 *	  one of the remaining keys of an index.
 *
374 375 376 377
 * 'rel' is the node of the relation corresponding to the index.
 * 'indexkeys' are the remaining index keys to be matched.
 * 'classes' are the classes of the index operators on those keys.
 * 'clauses' is either:
378 379 380 381 382 383 384
 *		(1) the list of available restriction clauses on a single
 *				relation, or
 *		(2) a list of join clauses between 'rel' and a fixed set of
 *				relations,
 *		depending on the value of 'join'.
 *
 *		NOTE: it works now for restriction clauses only. - vadim 03/18/97
385
 *
386 387
 * Returns all possible groups of clauses that will match (given that
 * one or more clauses can match any of the remaining keys).
388
 * E.g., if you have clauses A, B, and C, ((A B) (A C)) might be
389
 * returned for an index with 2 keys.
390
 *
391
 */
392
static List *
B
Bruce Momjian 已提交
393 394
group_clauses_by_indexkey(RelOptInfo *rel,
						  RelOptInfo *index,
395
						  int *indexkeys,
396 397
						  Oid *classes,
						  List *clauseinfo_list)
398
{
399 400 401 402 403
	List	   *curCinfo = NIL;
	CInfo	   *matched_clause = (CInfo *) NULL;
	List	   *clausegroup = NIL;
	int			curIndxKey;
	Oid			curClass;
404

405
	if (clauseinfo_list == NIL || indexkeys[0] == 0)
406
		return NIL;
407

408
	do
409
	{
410
		List	   *tempgroup = NIL;
411 412 413 414 415 416

		curIndxKey = indexkeys[0];
		curClass = classes[0];

		foreach(curCinfo, clauseinfo_list)
		{
417
			CInfo	   *temp = (CInfo *) lfirst(curCinfo);
418 419 420 421 422 423 424 425 426

			matched_clause = match_clause_to_indexkey(rel,
													  index,
													  curIndxKey,
													  curClass,
													  temp,
													  false);
			if (!matched_clause)
				continue;
427

428 429 430 431
			tempgroup = lappend(tempgroup, matched_clause);
		}
		if (tempgroup == NIL)
			break;
432

433 434 435 436 437
		clausegroup = nconc(clausegroup, tempgroup);

		indexkeys++;
		classes++;

438
	} while (!DoneMatchingIndexKeys(indexkeys, index));
439

440 441 442 443 444
	/* clausegroup holds all matched clauses ordered by indexkeys */

	if (clausegroup != NIL)
		return (lcons(clausegroup, NIL));
	return NIL;
445 446
}

447
/*
448
 * group-clauses-by-ikey-for-joins--
449 450 451 452
 *	  special edition of group-clauses-by-indexkey - will
 *	  match join & restriction clauses. See comment in indexable_joinclauses.
 *		- vadim 03/18/97
 *
453
 */
454
static List *
B
Bruce Momjian 已提交
455 456
group_clauses_by_ikey_for_joins(RelOptInfo *rel,
								RelOptInfo *index,
457
								int *indexkeys,
458 459 460
								Oid *classes,
								List *join_cinfo_list,
								List *restr_cinfo_list)
461
{
462 463 464 465 466 467
	List	   *curCinfo = NIL;
	CInfo	   *matched_clause = (CInfo *) NULL;
	List	   *clausegroup = NIL;
	int			curIndxKey;
	Oid			curClass;
	bool		jfound = false;
468

469
	if (join_cinfo_list == NIL || indexkeys[0] == 0)
470 471
		return NIL;

472
	do
473
	{
474
		List	   *tempgroup = NIL;
475 476 477 478 479 480

		curIndxKey = indexkeys[0];
		curClass = classes[0];

		foreach(curCinfo, join_cinfo_list)
		{
481
			CInfo	   *temp = (CInfo *) lfirst(curCinfo);
482 483 484 485 486 487 488 489 490 491 492 493 494 495 496

			matched_clause = match_clause_to_indexkey(rel,
													  index,
													  curIndxKey,
													  curClass,
													  temp,
													  true);
			if (!matched_clause)
				continue;

			tempgroup = lappend(tempgroup, matched_clause);
			jfound = true;
		}
		foreach(curCinfo, restr_cinfo_list)
		{
497
			CInfo	   *temp = (CInfo *) lfirst(curCinfo);
498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516

			matched_clause = match_clause_to_indexkey(rel,
													  index,
													  curIndxKey,
													  curClass,
													  temp,
													  false);
			if (!matched_clause)
				continue;

			tempgroup = lappend(tempgroup, matched_clause);
		}
		if (tempgroup == NIL)
			break;

		clausegroup = nconc(clausegroup, tempgroup);

		indexkeys++;
		classes++;
517

518
	} while (!DoneMatchingIndexKeys(indexkeys, index));
519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534

	/* clausegroup holds all matched clauses ordered by indexkeys */

	if (clausegroup != NIL)
	{

		/*
		 * if no one join clause was matched then there ain't clauses for
		 * joins at all.
		 */
		if (!jfound)
		{
			freeList(clausegroup);
			return NIL;
		}
		return (lcons(clausegroup, NIL));
535
	}
536
	return NIL;
537 538
}

539 540 541 542 543 544 545
/*
 * IndexScanableClause ()  MACRO
 *
 * Generalize condition on which we match a clause with an index.
 * Now we can match with functional indices.
 */
#define IndexScanableOperand(opnd, indkeys, rel, index) \
546 547 548
	((index->indproc == InvalidOid) ? \
		match_indexkey_operand(indkeys, opnd, rel) : \
		function_index_operand((Expr*)opnd,rel,index))
549

550 551
/*
 * There was
552
 *		equal_indexkey_var(indkeys,opnd) : \
553
 * above, and now
554
 *		match_indexkey_operand(indkeys, opnd, rel) : \
555 556 557
 * - vadim 01/22/97
 */

558
/*
559
 * match_clause_to-indexkey--
560 561 562 563 564 565 566 567 568 569 570 571
 *	  Finds the first of a relation's available restriction clauses that
 *	  matches a key of an index.
 *
 *	  To match, the clause must:
 *	  (1) be in the form (op var const) if the clause is a single-
 *				relation clause, and
 *	  (2) contain an operator which is in the same class as the index
 *				operator for this key.
 *
 *	  If the clause being matched is a join clause, then 'join' is t.
 *
 * Returns a single clauseinfo node corresponding to the matching
572 573 574
 * clause.
 *
 * NOTE:  returns nil if clause is an or_clause.
575
 *
576
 */
577
static CInfo *
B
Bruce Momjian 已提交
578 579
match_clause_to_indexkey(RelOptInfo *rel,
						 RelOptInfo *index,
580 581
						 int indexkey,
						 int xclass,
582
						 CInfo *clauseInfo,
583
						 bool join)
584
{
585 586 587 588 589 590
	Expr	   *clause = clauseInfo->clause;
	Var		   *leftop,
			   *rightop;
	Oid			join_op = InvalidOid;
	Oid			restrict_op = InvalidOid;
	bool		isIndexable = false;
591 592 593 594 595 596 597 598

	if (or_clause((Node *) clause) ||
		not_clause((Node *) clause) || single_node((Node *) clause))
		return ((CInfo *) NULL);

	leftop = get_leftop(clause);
	rightop = get_rightop(clause);

599
	/*
600 601
	 * If this is not a join clause, check for clauses of the form:
	 * (operator var/func constant) and (operator constant var/func)
602
	 */
603
	if (!join)
604
	{
605 606 607 608 609 610 611
		/*
		 * Check for standard s-argable clause
		 */
		if ((rightop && IsA(rightop, Const)) ||
			(rightop && IsA(rightop, Param)))
		{
			restrict_op = ((Oper *) ((Expr *) clause)->oper)->opno;
B
Bruce Momjian 已提交
612 613 614 615 616
			isIndexable = (op_class(restrict_op, xclass, index->relam) &&
				 			IndexScanableOperand(leftop,
												  indexkey,
												  rel,
												  index));
617 618
		}

619
		/*
620
		 * Must try to commute the clause to standard s-arg format.
621
		 */
622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641
		else if ((leftop && IsA(leftop, Const)) ||
				 (leftop && IsA(leftop, Param)))
		{
			restrict_op =
				get_commutator(((Oper *) ((Expr *) clause)->oper)->opno);

			if ((restrict_op != InvalidOid) &&
				op_class(restrict_op, xclass, index->relam) &&
				IndexScanableOperand(rightop,
									 indexkey, rel, index))
			{
				isIndexable = true;

				/*
				 * In place list modification. (op const var/func) -> (op
				 * var/func const)
				 */
				CommuteClause((Node *) clause);
			}
		}
642
	}
643

644 645 646 647 648
	/*
	 * Check for an indexable scan on one of the join relations. clause is
	 * of the form (operator var/func var/func)
	 */
	else
649
	{
650 651 652 653 654 655 656 657 658 659 660 661 662
		if (rightop
		&& match_index_to_operand(indexkey, (Expr *) rightop, rel, index))
		{

			join_op = get_commutator(((Oper *) ((Expr *) clause)->oper)->opno);

		}
		else if (leftop
				 && match_index_to_operand(indexkey,
										   (Expr *) leftop, rel, index))
			join_op = ((Oper *) ((Expr *) clause)->oper)->opno;

		if (join_op && op_class(join_op, xclass, index->relam) &&
663
			is_joinable((Node *) clause))
664 665 666 667 668 669 670 671 672 673
		{
			isIndexable = true;

			/*
			 * If we're using the operand's commutator we must commute the
			 * clause.
			 */
			if (join_op != ((Oper *) ((Expr *) clause)->oper)->opno)
				CommuteClause((Node *) clause);
		}
674 675
	}

676 677
	if (isIndexable)
		return (clauseInfo);
678

679
	return (NULL);
680 681 682
}

/****************************************************************************
683
 *				----  ROUTINES TO DO PARTIAL INDEX PREDICATE TESTS	----
684 685
 ****************************************************************************/

686
/*
687
 * pred_test--
688
 *	  Does the "predicate inclusion test" for partial indexes.
689
 *
690 691
 *	  Recursively checks whether the clauses in clauseinfo_list imply
 *	  that the given predicate is true.
692
 *
693 694 695 696 697 698
 *	  This routine (together with the routines it calls) iterates over
 *	  ANDs in the predicate first, then reduces the qualification
 *	  clauses down to their constituent terms, and iterates over ORs
 *	  in the predicate last.  This order is important to make the test
 *	  succeed whenever possible (assuming the predicate has been
 *	  successfully cnfify()-ed). --Nels, Jan '93
699
 */
700
static bool
701
pred_test(List *predicate_list, List *clauseinfo_list, List *joininfo_list)
702
{
703 704 705
	List	   *pred,
			   *items,
			   *item;
706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740

	/*
	 * Note: if Postgres tried to optimize queries by forming equivalence
	 * classes over equi-joined attributes (i.e., if it recognized that a
	 * qualification such as "where a.b=c.d and a.b=5" could make use of
	 * an index on c.d), then we could use that equivalence class info
	 * here with joininfo_list to do more complete tests for the usability
	 * of a partial index.	For now, the test only uses restriction
	 * clauses (those in clauseinfo_list). --Nels, Dec '92
	 */

	if (predicate_list == NULL)
		return true;			/* no predicate: the index is usable */
	if (clauseinfo_list == NULL)
		return false;			/* no restriction clauses: the test must
								 * fail */

	foreach(pred, predicate_list)
	{

		/*
		 * if any clause is not implied, the whole predicate is not
		 * implied
		 */
		if (and_clause(lfirst(pred)))
		{
			items = ((Expr *) lfirst(pred))->args;
			foreach(item, items)
			{
				if (!one_pred_test(lfirst(item), clauseinfo_list))
					return false;
			}
		}
		else if (!one_pred_test(lfirst(pred), clauseinfo_list))
			return false;
741
	}
742
	return true;
743 744 745
}


746
/*
747
 * one_pred_test--
748 749
 *	  Does the "predicate inclusion test" for one conjunct of a predicate
 *	  expression.
750
 */
751
static bool
752
one_pred_test(Expr *predicate, List *clauseinfo_list)
753
{
754 755
	CInfo	   *clauseinfo;
	List	   *item;
756 757 758 759 760 761 762 763 764 765

	Assert(predicate != NULL);
	foreach(item, clauseinfo_list)
	{
		clauseinfo = (CInfo *) lfirst(item);
		/* if any clause implies the predicate, return true */
		if (one_pred_clause_expr_test(predicate, (Node *) clauseinfo->clause))
			return true;
	}
	return false;
766 767 768
}


769
/*
770
 * one_pred_clause_expr_test--
771 772
 *	  Does the "predicate inclusion test" for a general restriction-clause
 *	  expression.
773
 */
774
static bool
775
one_pred_clause_expr_test(Expr *predicate, Node *clause)
776
{
777 778
	List	   *items,
			   *item;
779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805

	if (is_opclause(clause))
		return one_pred_clause_test(predicate, clause);
	else if (or_clause(clause))
	{
		items = ((Expr *) clause)->args;
		foreach(item, items)
		{
			/* if any OR item doesn't imply the predicate, clause doesn't */
			if (!one_pred_clause_expr_test(predicate, lfirst(item)))
				return false;
		}
		return true;
	}
	else if (and_clause(clause))
	{
		items = ((Expr *) clause)->args;
		foreach(item, items)
		{

			/*
			 * if any AND item implies the predicate, the whole clause
			 * does
			 */
			if (one_pred_clause_expr_test(predicate, lfirst(item)))
				return true;
		}
806 807
		return false;
	}
808 809 810 811
	else
	{
		/* unknown clause type never implies the predicate */
		return false;
812 813 814 815
	}
}


816
/*
817
 * one_pred_clause_test--
818 819
 *	  Does the "predicate inclusion test" for one conjunct of a predicate
 *	  expression for a simple restriction clause.
820
 */
821
static bool
822
one_pred_clause_test(Expr *predicate, Node *clause)
823
{
824 825
	List	   *items,
			   *item;
826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852

	if (is_opclause((Node *) predicate))
		return clause_pred_clause_test(predicate, clause);
	else if (or_clause((Node *) predicate))
	{
		items = predicate->args;
		foreach(item, items)
		{
			/* if any item is implied, the whole predicate is implied */
			if (one_pred_clause_test(lfirst(item), clause))
				return true;
		}
		return false;
	}
	else if (and_clause((Node *) predicate))
	{
		items = predicate->args;
		foreach(item, items)
		{

			/*
			 * if any item is not implied, the whole predicate is not
			 * implied
			 */
			if (!one_pred_clause_test(lfirst(item), clause))
				return false;
		}
853 854
		return true;
	}
855 856 857
	else
	{
		elog(DEBUG, "Unsupported predicate type, index will not be used");
858 859 860 861 862 863 864
		return false;
	}
}


/*
 * Define an "operator implication table" for btree operators ("strategies").
865
 * The "strategy numbers" are:	(1) <	(2) <=	 (3) =	 (4) >=   (5) >
866 867 868
 *
 * The interpretation of:
 *
869
 *		test_op = BT_implic_table[given_op-1][target_op-1]
870 871 872 873
 *
 * where test_op, given_op and target_op are strategy numbers (from 1 to 5)
 * of btree operators, is as follows:
 *
874 875 876 877 878
 *	 If you know, for some ATTR, that "ATTR given_op CONST1" is true, and you
 *	 want to determine whether "ATTR target_op CONST2" must also be true, then
 *	 you can use "CONST1 test_op CONST2" as a test.  If this test returns true,
 *	 then the target expression must be true; if the test returns false, then
 *	 the target expression may be false.
879 880 881 882 883
 *
 * An entry where test_op==0 means the implication cannot be determined, i.e.,
 * this test should always be considered false.
 */

884
StrategyNumber BT_implic_table[BTMaxStrategyNumber][BTMaxStrategyNumber] = {
885 886 887 888 889
	{2, 2, 0, 0, 0},
	{1, 2, 0, 0, 0},
	{1, 2, 3, 4, 5},
	{0, 0, 0, 4, 5},
	{0, 0, 0, 4, 4}
890 891 892
};


893
/*
894
 * clause_pred_clause_test--
895 896 897 898 899 900 901
 *	  Use operator class info to check whether clause implies predicate.
 *
 *	  Does the "predicate inclusion test" for a "simple clause" predicate
 *	  for a single "simple clause" restriction.  Currently, this only handles
 *	  (binary boolean) operators that are in some btree operator class.
 *	  Eventually, rtree operators could also be handled by defining an
 *	  appropriate "RT_implic_table" array.
902
 */
903
static bool
904
clause_pred_clause_test(Expr *predicate, Node *clause)
905
{
906 907 908 909 910 911 912 913 914 915 916 917 918 919 920 921 922 923 924 925
	Var		   *pred_var,
			   *clause_var;
	Const	   *pred_const,
			   *clause_const;
	Oid			pred_op,
				clause_op,
				test_op;
	Oid			opclass_id;
	StrategyNumber pred_strategy,
				clause_strategy,
				test_strategy;
	Oper	   *test_oper;
	Expr	   *test_expr;
	bool		test_result,
				isNull;
	Relation	relation;
	HeapScanDesc scan;
	HeapTuple	tuple;
	ScanKeyData entry[3];
	Form_pg_amop form;
926 927 928 929 930 931 932 933 934 935 936 937 938 939

	pred_var = (Var *) get_leftop(predicate);
	pred_const = (Const *) get_rightop(predicate);
	clause_var = (Var *) get_leftop((Expr *) clause);
	clause_const = (Const *) get_rightop((Expr *) clause);

	/* Check the basic form; for now, only allow the simplest case */
	if (!is_opclause(clause) ||
		!IsA(clause_var, Var) ||
		!IsA(clause_const, Const) ||
		!IsA(predicate->oper, Oper) ||
		!IsA(pred_var, Var) ||
		!IsA(pred_const, Const))
		return false;
940

941 942 943 944 945 946
	/*
	 * The implication can't be determined unless the predicate and the
	 * clause refer to the same attribute.
	 */
	if (clause_var->varattno != pred_var->varattno)
		return false;
947

948 949 950
	/* Get the operators for the two clauses we're comparing */
	pred_op = ((Oper *) ((Expr *) predicate)->oper)->opno;
	clause_op = ((Oper *) ((Expr *) clause)->oper)->opno;
951 952


953 954 955 956 957 958
	/*
	 * 1. Find a "btree" strategy number for the pred_op
	 */
	/* XXX - hardcoded amopid value 403 to find "btree" operator classes */
	ScanKeyEntryInitialize(&entry[0], 0,
						   Anum_pg_amop_amopid,
B
Bruce Momjian 已提交
959
						   F_OIDEQ,
960
						   ObjectIdGetDatum(403));
961

962 963
	ScanKeyEntryInitialize(&entry[1], 0,
						   Anum_pg_amop_amopopr,
B
Bruce Momjian 已提交
964
						   F_OIDEQ,
965
						   ObjectIdGetDatum(pred_op));
966

967
	relation = heap_openr(AccessMethodOperatorRelationName);
968

969 970 971 972 973 974 975 976
	/*
	 * The following assumes that any given operator will only be in a
	 * single btree operator class.  This is true at least for all the
	 * pre-defined operator classes.  If it isn't true, then whichever
	 * operator class happens to be returned first for the given operator
	 * will be used to find the associated strategy numbers for the test.
	 * --Nels, Jan '93
	 */
977
	scan = heap_beginscan(relation, false, SnapshotNow, 2, entry);
978 979 980 981 982 983 984
	tuple = heap_getnext(scan, false, (Buffer *) NULL);
	if (!HeapTupleIsValid(tuple))
	{
		elog(DEBUG, "clause_pred_clause_test: unknown pred_op");
		return false;
	}
	form = (Form_pg_amop) GETSTRUCT(tuple);
985

986 987
	/* Get the predicate operator's strategy number (1 to 5) */
	pred_strategy = (StrategyNumber) form->amopstrategy;
988

989 990
	/* Remember which operator class this strategy number came from */
	opclass_id = form->amopclaid;
991

992
	heap_endscan(scan);
993 994


995 996 997 998 999
	/*
	 * 2. From the same opclass, find a strategy num for the clause_op
	 */
	ScanKeyEntryInitialize(&entry[1], 0,
						   Anum_pg_amop_amopclaid,
B
Bruce Momjian 已提交
1000
						   F_OIDEQ,
1001 1002 1003 1004
						   ObjectIdGetDatum(opclass_id));

	ScanKeyEntryInitialize(&entry[2], 0,
						   Anum_pg_amop_amopopr,
B
Bruce Momjian 已提交
1005
						   F_OIDEQ,
1006 1007
						   ObjectIdGetDatum(clause_op));

1008
	scan = heap_beginscan(relation, false, SnapshotNow, 3, entry);
1009 1010 1011 1012 1013 1014 1015
	tuple = heap_getnext(scan, false, (Buffer *) NULL);
	if (!HeapTupleIsValid(tuple))
	{
		elog(DEBUG, "clause_pred_clause_test: unknown clause_op");
		return false;
	}
	form = (Form_pg_amop) GETSTRUCT(tuple);
1016

1017 1018 1019
	/* Get the restriction clause operator's strategy number (1 to 5) */
	clause_strategy = (StrategyNumber) form->amopstrategy;
	heap_endscan(scan);
1020 1021


1022 1023 1024
	/*
	 * 3. Look up the "test" strategy number in the implication table
	 */
1025

1026 1027 1028
	test_strategy = BT_implic_table[clause_strategy - 1][pred_strategy - 1];
	if (test_strategy == 0)
		return false;			/* the implication cannot be determined */
1029 1030


1031 1032 1033
	/*
	 * 4. From the same opclass, find the operator for the test strategy
	 */
1034

1035 1036
	ScanKeyEntryInitialize(&entry[2], 0,
						   Anum_pg_amop_amopstrategy,
B
Bruce Momjian 已提交
1037
						   F_INT2EQ,
1038
						   Int16GetDatum(test_strategy));
1039

1040
	scan = heap_beginscan(relation, false, SnapshotNow, 3, entry);
1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051
	tuple = heap_getnext(scan, false, (Buffer *) NULL);
	if (!HeapTupleIsValid(tuple))
	{
		elog(DEBUG, "clause_pred_clause_test: unknown test_op");
		return false;
	}
	form = (Form_pg_amop) GETSTRUCT(tuple);

	/* Get the test operator */
	test_op = form->amopopr;
	heap_endscan(scan);
1052

1053 1054 1055 1056 1057 1058

	/*
	 * 5. Evaluate the test
	 */
	test_oper = makeOper(test_op,		/* opno */
						 InvalidOid,	/* opid */
B
Bruce Momjian 已提交
1059
						 BOOLOID,	/* opresulttype */
1060 1061 1062 1063 1064 1065 1066
						 0,		/* opsize */
						 NULL); /* op_fcache */
	replace_opid(test_oper);

	test_expr = make_opclause(test_oper,
							  copyObject(clause_const),
							  copyObject(pred_const));
1067 1068

#ifndef OMIT_PARTIAL_INDEX
1069 1070 1071 1072 1073 1074 1075 1076
	test_result = ExecEvalExpr((Node *) test_expr, NULL, &isNull, NULL);
#endif							/* OMIT_PARTIAL_INDEX */
	if (isNull)
	{
		elog(DEBUG, "clause_pred_clause_test: null test result");
		return false;
	}
	return test_result;
1077 1078 1079 1080
}


/****************************************************************************
1081
 *				----  ROUTINES TO CHECK JOIN CLAUSES  ----
1082 1083
 ****************************************************************************/

1084
/*
1085
 * indexable-joinclauses--
1086 1087 1088 1089 1090 1091
 *	  Finds all groups of join clauses from among 'joininfo-list' that can
 *	  be used in conjunction with 'index'.
 *
 *	  The first clause in the group is marked as having the other relation
 *	  in the join clause as its outer join relation.
 *
1092
 * Returns a list of these clause groups.
1093
 *
1094 1095 1096 1097
 *	  Added: clauseinfo_list - list of restriction CInfos. It's to
 *		support multi-column indices in joins and for cases
 *		when a key is in both join & restriction clauses. - vadim 03/18/97
 *
1098
 */
1099
static List *
B
Bruce Momjian 已提交
1100
indexable_joinclauses(RelOptInfo *rel, RelOptInfo *index,
1101
					  List *joininfo_list, List *clauseinfo_list)
1102
{
1103 1104 1105 1106
	JInfo	   *joininfo = (JInfo *) NULL;
	List	   *cg_list = NIL;
	List	   *i = NIL;
	List	   *clausegroups = NIL;
1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123

	foreach(i, joininfo_list)
	{
		joininfo = (JInfo *) lfirst(i);

		if (joininfo->jinfoclauseinfo == NIL)
			continue;
		clausegroups =
			group_clauses_by_ikey_for_joins(rel,
											index,
											index->indexkeys,
											index->classlist,
											joininfo->jinfoclauseinfo,
											clauseinfo_list);

		if (clausegroups != NIL)
		{
1124
			List	   *clauses = lfirst(clausegroups);
1125 1126 1127 1128 1129

			((CInfo *) lfirst(clauses))->cinfojoinid =
				joininfo->otherrels;
		}
		cg_list = nconc(cg_list, clausegroups);
1130
	}
1131
	return (cg_list);
1132 1133 1134
}

/****************************************************************************
1135
 *				----  PATH CREATION UTILITIES  ----
1136 1137 1138 1139
 ****************************************************************************/

/*
 * extract_restrict_clauses -
1140 1141
 *	  the list of clause info contains join clauses and restriction clauses.
 *	  This routine returns the restriction clauses only.
1142
 */
B
Bruce Momjian 已提交
1143
#ifdef NOT_USED
1144
static List *
1145
extract_restrict_clauses(List *clausegroup)
1146
{
1147 1148
	List	   *restrict_cls = NIL;
	List	   *l;
1149 1150 1151

	foreach(l, clausegroup)
	{
1152
		CInfo	   *cinfo = lfirst(l);
1153

1154
		if (!is_joinable((Node *) cinfo->clause))
1155
			restrict_cls = lappend(restrict_cls, cinfo);
1156
	}
1157
	return restrict_cls;
1158
}
1159

B
Bruce Momjian 已提交
1160
#endif
1161

1162
/*
1163
 * index-innerjoin--
1164 1165
 *	  Creates index path nodes corresponding to paths to be used as inner
 *	  relations in nestloop joins.
1166 1167 1168
 *
 * 'clausegroup-list' is a list of list of clauseinfo nodes which can use
 * 'index' on their inner relation.
1169
 *
1170
 * Returns a list of index pathnodes.
1171
 *
1172
 */
1173
static List *
B
Bruce Momjian 已提交
1174 1175
index_innerjoin(Query *root, RelOptInfo *rel, List *clausegroup_list,
				RelOptInfo *index)
1176
{
1177 1178 1179 1180 1181 1182
	List	   *clausegroup = NIL;
	List	   *cg_list = NIL;
	List	   *i = NIL;
	IndexPath  *pathnode = (IndexPath *) NULL;
	Cost		temp_selec;
	float		temp_pages;
1183 1184 1185

	foreach(i, clausegroup_list)
	{
1186 1187 1188
		List	   *attnos,
				   *values,
				   *flags;
1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 1208 1209 1210 1211 1212 1213 1214 1215 1216 1217 1218 1219 1220 1221 1222 1223 1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 1234 1235 1236 1237 1238

		clausegroup = lfirst(i);
		pathnode = makeNode(IndexPath);

		get_joinvars(lfirsti(rel->relids), clausegroup,
					 &attnos, &values, &flags);
		index_selectivity(lfirsti(index->relids),
						  index->classlist,
						  get_opnos(clausegroup),
						  getrelid(lfirsti(rel->relids),
								   root->rtable),
						  attnos,
						  values,
						  flags,
						  length(clausegroup),
						  &temp_pages,
						  &temp_selec);
		pathnode->path.pathtype = T_IndexScan;
		pathnode->path.parent = rel;
		pathnode->indexid = index->relids;
		pathnode->indexkeys = index->indexkeys;
		pathnode->indexqual = clausegroup;

		pathnode->path.joinid = ((CInfo *) lfirst(clausegroup))->cinfojoinid;

		pathnode->path.path_cost =
			cost_index((Oid) lfirsti(index->relids),
					   (int) temp_pages,
					   temp_selec,
					   rel->pages,
					   rel->tuples,
					   index->pages,
					   index->tuples,
					   true);

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

#if 0							/* fix xfunc */
		/* add in cost for expensive functions!  -- JMH, 7/7/92 */
		if (XfuncMode != XFUNC_OFF)
		{
			((Path *) pathnode)->path_cost +=
				xfunc_get_path_cost((Path *) pathnode);
		}
1239
#endif
1240 1241 1242
		cg_list = lappend(cg_list, pathnode);
	}
	return (cg_list);
1243 1244
}

1245
/*
1246
 * create-index-paths--
1247 1248 1249
 *	  Creates a list of index path nodes for each group of clauses
 *	  (restriction or join) that can be used in conjunction with an index.
 *
1250
 * 'rel' is the relation for which 'index' is defined
1251
 * 'clausegroup-list' is the list of clause groups (lists of clauseinfo
1252
 *				nodes) grouped by mergejoinorder
1253
 * 'join' is a flag indicating whether or not the clauses are join
1254 1255
 *				clauses
 *
1256
 * Returns a list of new index path nodes.
1257
 *
1258
 */
1259
static List *
1260
create_index_paths(Query *root,
B
Bruce Momjian 已提交
1261 1262
				   RelOptInfo *rel,
				   RelOptInfo *index,
1263
				   List *clausegroup_list,
1264
				   bool join)
1265
{
1266 1267 1268 1269 1270
	List	   *clausegroup = NIL;
	List	   *ip_list = NIL;
	List	   *i = NIL;
	List	   *j = NIL;
	IndexPath  *temp_path;
1271

1272 1273
	foreach(i, clausegroup_list)
	{
1274 1275 1276
		CInfo	   *clauseinfo;
		List	   *temp_node = NIL;
		bool		temp = true;
1277 1278 1279 1280 1281 1282

		clausegroup = lfirst(i);

		foreach(j, clausegroup)
		{
			clauseinfo = (CInfo *) lfirst(j);
1283
			if (!(is_joinable((Node *) clauseinfo->clause) &&
1284
				  equal_path_merge_ordering(index->ordering,
1285
											clauseinfo->mergejoinorder)))
1286 1287 1288 1289 1290 1291
				temp = false;
		}

		if (!join || temp)
		{						/* restriction, ordering scan */
			temp_path = create_index_path(root, rel, index, clausegroup, join);
B
Bruce Momjian 已提交
1292
			temp_node = lcons(temp_path, NIL);
1293 1294 1295 1296
			ip_list = nconc(ip_list, temp_node);
		}
	}
	return (ip_list);
1297 1298
}

1299
static List *
1300
add_index_paths(List *indexpaths, List *new_indexpaths)
1301
{
1302
	return append(indexpaths, new_indexpaths);
1303 1304
}

1305
static bool
B
Bruce Momjian 已提交
1306
function_index_operand(Expr *funcOpnd, RelOptInfo *rel, RelOptInfo *index)
1307
{
1308 1309 1310 1311 1312 1313
	Oid			heapRelid = (Oid) lfirsti(rel->relids);
	Func	   *function;
	List	   *funcargs;
	int		   *indexKeys = index->indexkeys;
	List	   *arg;
	int			i;
1314

1315 1316 1317 1318 1319 1320 1321
	/*
	 * sanity check, make sure we know what we're dealing with here.
	 */
	if (funcOpnd == NULL ||
		nodeTag(funcOpnd) != T_Expr || funcOpnd->opType != FUNC_EXPR ||
		funcOpnd->oper == NULL || indexKeys == NULL)
		return false;
1322

1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354
	function = (Func *) funcOpnd->oper;
	funcargs = funcOpnd->args;

	if (function->funcid != index->indproc)
		return false;

	/*
	 * Check that the arguments correspond to the same arguments used to
	 * create the functional index.  To do this we must check that 1.
	 * refer to the right relatiion. 2. the args have the right attr.
	 * numbers in the right order.
	 *
	 *
	 * Check all args refer to the correct relation (i.e. the one with the
	 * functional index defined on it (rel).  To do this we can simply
	 * compare range table entry numbers, they must be the same.
	 */
	foreach(arg, funcargs)
	{
		if (heapRelid != ((Var *) lfirst(arg))->varno)
			return false;
	}

	/*
	 * check attr numbers and order.
	 */
	i = 0;
	foreach(arg, funcargs)
	{

		if (indexKeys[i] == 0)
			return (false);
1355

1356 1357 1358 1359 1360 1361 1362
		if (((Var *) lfirst(arg))->varattno != indexKeys[i])
			return (false);

		i++;
	}

	return true;
1363
}