PostgreSQL Source Code  git master
test_predtest.c
Go to the documentation of this file.
1 /*--------------------------------------------------------------------------
2  *
3  * test_predtest.c
4  * Test correctness of optimizer's predicate proof logic.
5  *
6  * Copyright (c) 2018-2023, PostgreSQL Global Development Group
7  *
8  * IDENTIFICATION
9  * src/test/modules/test_predtest/test_predtest.c
10  *
11  * -------------------------------------------------------------------------
12  */
13 
14 #include "postgres.h"
15 
16 #include "access/htup_details.h"
17 #include "catalog/pg_type.h"
18 #include "executor/spi.h"
19 #include "funcapi.h"
20 #include "nodes/makefuncs.h"
21 #include "optimizer/optimizer.h"
22 #include "utils/builtins.h"
23 
25 
26 /*
27  * test_predtest(query text) returns record
28  */
30 
31 Datum
33 {
34  text *txt = PG_GETARG_TEXT_PP(0);
35  char *query_string = text_to_cstring(txt);
36  SPIPlanPtr spiplan;
37  int spirc;
38  TupleDesc tupdesc;
39  bool s_i_holds,
40  w_i_holds,
41  s_r_holds,
42  w_r_holds;
43  CachedPlan *cplan;
45  Plan *plan;
46  Expr *clause1;
47  Expr *clause2;
48  bool strong_implied_by,
49  weak_implied_by,
50  strong_refuted_by,
51  weak_refuted_by;
52  Datum values[8];
53  bool nulls[8] = {0};
54  int i;
55 
56  /* We use SPI to parse, plan, and execute the test query */
57  if (SPI_connect() != SPI_OK_CONNECT)
58  elog(ERROR, "SPI_connect failed");
59 
60  /*
61  * First, plan and execute the query, and inspect the results. To the
62  * extent that the query fully exercises the two expressions, this
63  * provides an experimental indication of whether implication or
64  * refutation holds.
65  */
66  spiplan = SPI_prepare(query_string, 0, NULL);
67  if (spiplan == NULL)
68  elog(ERROR, "SPI_prepare failed for \"%s\"", query_string);
69 
70  spirc = SPI_execute_plan(spiplan, NULL, NULL, true, 0);
71  if (spirc != SPI_OK_SELECT)
72  elog(ERROR, "failed to execute \"%s\"", query_string);
73  tupdesc = SPI_tuptable->tupdesc;
74  if (tupdesc->natts != 2 ||
75  TupleDescAttr(tupdesc, 0)->atttypid != BOOLOID ||
76  TupleDescAttr(tupdesc, 1)->atttypid != BOOLOID)
77  elog(ERROR, "query must yield two boolean columns");
78 
79  s_i_holds = w_i_holds = s_r_holds = w_r_holds = true;
80  for (i = 0; i < SPI_processed; i++)
81  {
82  HeapTuple tup = SPI_tuptable->vals[i];
83  Datum dat;
84  bool isnull;
85  char c1,
86  c2;
87 
88  /* Extract column values in a 3-way representation */
89  dat = SPI_getbinval(tup, tupdesc, 1, &isnull);
90  if (isnull)
91  c1 = 'n';
92  else if (DatumGetBool(dat))
93  c1 = 't';
94  else
95  c1 = 'f';
96 
97  dat = SPI_getbinval(tup, tupdesc, 2, &isnull);
98  if (isnull)
99  c2 = 'n';
100  else if (DatumGetBool(dat))
101  c2 = 't';
102  else
103  c2 = 'f';
104 
105  /* Check for violations of various proof conditions */
106 
107  /* strong implication: truth of c2 implies truth of c1 */
108  if (c2 == 't' && c1 != 't')
109  s_i_holds = false;
110  /* weak implication: non-falsity of c2 implies non-falsity of c1 */
111  if (c2 != 'f' && c1 == 'f')
112  w_i_holds = false;
113  /* strong refutation: truth of c2 implies falsity of c1 */
114  if (c2 == 't' && c1 != 'f')
115  s_r_holds = false;
116  /* weak refutation: truth of c2 implies non-truth of c1 */
117  if (c2 == 't' && c1 == 't')
118  w_r_holds = false;
119  }
120 
121  /*
122  * Now, dig the clause querytrees out of the plan, and see what predtest.c
123  * does with them.
124  */
125  cplan = SPI_plan_get_cached_plan(spiplan);
126 
127  if (list_length(cplan->stmt_list) != 1)
128  elog(ERROR, "failed to decipher query plan");
130  if (stmt->commandType != CMD_SELECT)
131  elog(ERROR, "failed to decipher query plan");
132  plan = stmt->planTree;
133  Assert(list_length(plan->targetlist) >= 2);
134  clause1 = linitial_node(TargetEntry, plan->targetlist)->expr;
135  clause2 = lsecond_node(TargetEntry, plan->targetlist)->expr;
136 
137  /*
138  * Because the clauses are in the SELECT list, preprocess_expression did
139  * not pass them through canonicalize_qual nor make_ands_implicit.
140  *
141  * We can't do canonicalize_qual here, since it's unclear whether the
142  * expressions ought to be treated as WHERE or CHECK clauses. Fortunately,
143  * useful test expressions wouldn't be affected by those transformations
144  * anyway. We should do make_ands_implicit, though.
145  *
146  * Another way in which this does not exactly duplicate the normal usage
147  * of the proof functions is that they are often given qual clauses
148  * containing RestrictInfo nodes. But since predtest.c just looks through
149  * those anyway, it seems OK to not worry about that point.
150  */
151  clause1 = (Expr *) make_ands_implicit(clause1);
152  clause2 = (Expr *) make_ands_implicit(clause2);
153 
154  strong_implied_by = predicate_implied_by((List *) clause1,
155  (List *) clause2,
156  false);
157 
158  weak_implied_by = predicate_implied_by((List *) clause1,
159  (List *) clause2,
160  true);
161 
162  strong_refuted_by = predicate_refuted_by((List *) clause1,
163  (List *) clause2,
164  false);
165 
166  weak_refuted_by = predicate_refuted_by((List *) clause1,
167  (List *) clause2,
168  true);
169 
170  /*
171  * Issue warning if any proof is demonstrably incorrect.
172  */
173  if (strong_implied_by && !s_i_holds)
174  elog(WARNING, "strong_implied_by result is incorrect");
175  if (weak_implied_by && !w_i_holds)
176  elog(WARNING, "weak_implied_by result is incorrect");
177  if (strong_refuted_by && !s_r_holds)
178  elog(WARNING, "strong_refuted_by result is incorrect");
179  if (weak_refuted_by && !w_r_holds)
180  elog(WARNING, "weak_refuted_by result is incorrect");
181 
182  /*
183  * Clean up and return a record of the results.
184  */
185  if (SPI_finish() != SPI_OK_FINISH)
186  elog(ERROR, "SPI_finish failed");
187 
188  tupdesc = CreateTemplateTupleDesc(8);
189  TupleDescInitEntry(tupdesc, (AttrNumber) 1,
190  "strong_implied_by", BOOLOID, -1, 0);
191  TupleDescInitEntry(tupdesc, (AttrNumber) 2,
192  "weak_implied_by", BOOLOID, -1, 0);
193  TupleDescInitEntry(tupdesc, (AttrNumber) 3,
194  "strong_refuted_by", BOOLOID, -1, 0);
195  TupleDescInitEntry(tupdesc, (AttrNumber) 4,
196  "weak_refuted_by", BOOLOID, -1, 0);
197  TupleDescInitEntry(tupdesc, (AttrNumber) 5,
198  "s_i_holds", BOOLOID, -1, 0);
199  TupleDescInitEntry(tupdesc, (AttrNumber) 6,
200  "w_i_holds", BOOLOID, -1, 0);
201  TupleDescInitEntry(tupdesc, (AttrNumber) 7,
202  "s_r_holds", BOOLOID, -1, 0);
203  TupleDescInitEntry(tupdesc, (AttrNumber) 8,
204  "w_r_holds", BOOLOID, -1, 0);
205  tupdesc = BlessTupleDesc(tupdesc);
206 
207  values[0] = BoolGetDatum(strong_implied_by);
208  values[1] = BoolGetDatum(weak_implied_by);
209  values[2] = BoolGetDatum(strong_refuted_by);
210  values[3] = BoolGetDatum(weak_refuted_by);
211  values[4] = BoolGetDatum(s_i_holds);
212  values[5] = BoolGetDatum(w_i_holds);
213  values[6] = BoolGetDatum(s_r_holds);
214  values[7] = BoolGetDatum(w_r_holds);
215 
217 }
int16 AttrNumber
Definition: attnum.h:21
static Datum values[MAXATTR]
Definition: bootstrap.c:156
#define WARNING
Definition: elog.h:36
#define ERROR
Definition: elog.h:39
TupleDesc BlessTupleDesc(TupleDesc tupdesc)
Definition: execTuples.c:2072
#define PG_GETARG_TEXT_PP(n)
Definition: fmgr.h:309
#define PG_RETURN_DATUM(x)
Definition: fmgr.h:353
#define PG_FUNCTION_ARGS
Definition: fmgr.h:193
static Datum HeapTupleGetDatum(const HeapTupleData *tuple)
Definition: funcapi.h:230
HeapTuple heap_form_tuple(TupleDesc tupleDescriptor, Datum *values, bool *isnull)
Definition: heaptuple.c:1020
#define stmt
Definition: indent_codes.h:59
int i
Definition: isn.c:73
Assert(fmt[strlen(fmt) - 1] !='\n')
List * make_ands_implicit(Expr *clause)
Definition: makefuncs.c:722
@ CMD_SELECT
Definition: nodes.h:276
static int list_length(const List *l)
Definition: pg_list.h:152
#define linitial_node(type, l)
Definition: pg_list.h:181
#define lsecond_node(type, l)
Definition: pg_list.h:186
#define plan(x)
Definition: pg_regress.c:154
static bool DatumGetBool(Datum X)
Definition: postgres.h:90
uintptr_t Datum
Definition: postgres.h:64
static Datum BoolGetDatum(bool X)
Definition: postgres.h:102
bool predicate_refuted_by(List *predicate_list, List *clause_list, bool weak)
Definition: predtest.c:222
bool predicate_implied_by(List *predicate_list, List *clause_list, bool weak)
Definition: predtest.c:152
CachedPlan * SPI_plan_get_cached_plan(SPIPlanPtr plan)
Definition: spi.c:2070
uint64 SPI_processed
Definition: spi.c:45
SPITupleTable * SPI_tuptable
Definition: spi.c:46
int SPI_connect(void)
Definition: spi.c:95
int SPI_finish(void)
Definition: spi.c:183
int SPI_execute_plan(SPIPlanPtr plan, Datum *Values, const char *Nulls, bool read_only, long tcount)
Definition: spi.c:670
SPIPlanPtr SPI_prepare(const char *src, int nargs, Oid *argtypes)
Definition: spi.c:858
Datum SPI_getbinval(HeapTuple tuple, TupleDesc tupdesc, int fnumber, bool *isnull)
Definition: spi.c:1250
#define SPI_OK_CONNECT
Definition: spi.h:82
#define SPI_OK_FINISH
Definition: spi.h:83
#define SPI_OK_SELECT
Definition: spi.h:86
List * stmt_list
Definition: plancache.h:150
Definition: pg_list.h:54
TupleDesc tupdesc
Definition: spi.h:25
HeapTuple * vals
Definition: spi.h:26
Definition: c.h:671
PG_MODULE_MAGIC
Definition: test_predtest.c:24
Datum test_predtest(PG_FUNCTION_ARGS)
Definition: test_predtest.c:32
PG_FUNCTION_INFO_V1(test_predtest)
TupleDesc CreateTemplateTupleDesc(int natts)
Definition: tupdesc.c:45
void TupleDescInitEntry(TupleDesc desc, AttrNumber attributeNumber, const char *attributeName, Oid oidtypeid, int32 typmod, int attdim)
Definition: tupdesc.c:583
#define TupleDescAttr(tupdesc, i)
Definition: tupdesc.h:92
char * text_to_cstring(const text *t)
Definition: varlena.c:215