| 1 | /*------------------------------------------------------------------------- |
| 2 | * |
| 3 | * ginarrayproc.c |
| 4 | * support functions for GIN's indexing of any array |
| 5 | * |
| 6 | * |
| 7 | * Portions Copyright (c) 1996-2019, PostgreSQL Global Development Group |
| 8 | * Portions Copyright (c) 1994, Regents of the University of California |
| 9 | * |
| 10 | * IDENTIFICATION |
| 11 | * src/backend/access/gin/ginarrayproc.c |
| 12 | *------------------------------------------------------------------------- |
| 13 | */ |
| 14 | #include "postgres.h" |
| 15 | |
| 16 | #include "access/gin.h" |
| 17 | #include "access/stratnum.h" |
| 18 | #include "utils/array.h" |
| 19 | #include "utils/builtins.h" |
| 20 | #include "utils/lsyscache.h" |
| 21 | |
| 22 | |
| 23 | #define GinOverlapStrategy 1 |
| 24 | #define GinContainsStrategy 2 |
| 25 | #define GinContainedStrategy 3 |
| 26 | #define GinEqualStrategy 4 |
| 27 | |
| 28 | |
| 29 | /* |
| 30 | * extractValue support function |
| 31 | */ |
| 32 | Datum |
| 33 | (PG_FUNCTION_ARGS) |
| 34 | { |
| 35 | /* Make copy of array input to ensure it doesn't disappear while in use */ |
| 36 | ArrayType *array = PG_GETARG_ARRAYTYPE_P_COPY(0); |
| 37 | int32 *nkeys = (int32 *) PG_GETARG_POINTER(1); |
| 38 | bool **nullFlags = (bool **) PG_GETARG_POINTER(2); |
| 39 | int16 elmlen; |
| 40 | bool elmbyval; |
| 41 | char elmalign; |
| 42 | Datum *elems; |
| 43 | bool *nulls; |
| 44 | int nelems; |
| 45 | |
| 46 | get_typlenbyvalalign(ARR_ELEMTYPE(array), |
| 47 | &elmlen, &elmbyval, &elmalign); |
| 48 | |
| 49 | deconstruct_array(array, |
| 50 | ARR_ELEMTYPE(array), |
| 51 | elmlen, elmbyval, elmalign, |
| 52 | &elems, &nulls, &nelems); |
| 53 | |
| 54 | *nkeys = nelems; |
| 55 | *nullFlags = nulls; |
| 56 | |
| 57 | /* we should not free array, elems[i] points into it */ |
| 58 | PG_RETURN_POINTER(elems); |
| 59 | } |
| 60 | |
| 61 | /* |
| 62 | * Formerly, ginarrayextract had only two arguments. Now it has three, |
| 63 | * but we still need a pg_proc entry with two args to support reloading |
| 64 | * pre-9.1 contrib/intarray opclass declarations. This compatibility |
| 65 | * function should go away eventually. |
| 66 | */ |
| 67 | Datum |
| 68 | (PG_FUNCTION_ARGS) |
| 69 | { |
| 70 | if (PG_NARGS() < 3) /* should not happen */ |
| 71 | elog(ERROR, "ginarrayextract requires three arguments" ); |
| 72 | return ginarrayextract(fcinfo); |
| 73 | } |
| 74 | |
| 75 | /* |
| 76 | * extractQuery support function |
| 77 | */ |
| 78 | Datum |
| 79 | (PG_FUNCTION_ARGS) |
| 80 | { |
| 81 | /* Make copy of array input to ensure it doesn't disappear while in use */ |
| 82 | ArrayType *array = PG_GETARG_ARRAYTYPE_P_COPY(0); |
| 83 | int32 *nkeys = (int32 *) PG_GETARG_POINTER(1); |
| 84 | StrategyNumber strategy = PG_GETARG_UINT16(2); |
| 85 | |
| 86 | /* bool **pmatch = (bool **) PG_GETARG_POINTER(3); */ |
| 87 | /* Pointer *extra_data = (Pointer *) PG_GETARG_POINTER(4); */ |
| 88 | bool **nullFlags = (bool **) PG_GETARG_POINTER(5); |
| 89 | int32 *searchMode = (int32 *) PG_GETARG_POINTER(6); |
| 90 | int16 elmlen; |
| 91 | bool elmbyval; |
| 92 | char elmalign; |
| 93 | Datum *elems; |
| 94 | bool *nulls; |
| 95 | int nelems; |
| 96 | |
| 97 | get_typlenbyvalalign(ARR_ELEMTYPE(array), |
| 98 | &elmlen, &elmbyval, &elmalign); |
| 99 | |
| 100 | deconstruct_array(array, |
| 101 | ARR_ELEMTYPE(array), |
| 102 | elmlen, elmbyval, elmalign, |
| 103 | &elems, &nulls, &nelems); |
| 104 | |
| 105 | *nkeys = nelems; |
| 106 | *nullFlags = nulls; |
| 107 | |
| 108 | switch (strategy) |
| 109 | { |
| 110 | case GinOverlapStrategy: |
| 111 | *searchMode = GIN_SEARCH_MODE_DEFAULT; |
| 112 | break; |
| 113 | case GinContainsStrategy: |
| 114 | if (nelems > 0) |
| 115 | *searchMode = GIN_SEARCH_MODE_DEFAULT; |
| 116 | else /* everything contains the empty set */ |
| 117 | *searchMode = GIN_SEARCH_MODE_ALL; |
| 118 | break; |
| 119 | case GinContainedStrategy: |
| 120 | /* empty set is contained in everything */ |
| 121 | *searchMode = GIN_SEARCH_MODE_INCLUDE_EMPTY; |
| 122 | break; |
| 123 | case GinEqualStrategy: |
| 124 | if (nelems > 0) |
| 125 | *searchMode = GIN_SEARCH_MODE_DEFAULT; |
| 126 | else |
| 127 | *searchMode = GIN_SEARCH_MODE_INCLUDE_EMPTY; |
| 128 | break; |
| 129 | default: |
| 130 | elog(ERROR, "ginqueryarrayextract: unknown strategy number: %d" , |
| 131 | strategy); |
| 132 | } |
| 133 | |
| 134 | /* we should not free array, elems[i] points into it */ |
| 135 | PG_RETURN_POINTER(elems); |
| 136 | } |
| 137 | |
| 138 | /* |
| 139 | * consistent support function |
| 140 | */ |
| 141 | Datum |
| 142 | ginarrayconsistent(PG_FUNCTION_ARGS) |
| 143 | { |
| 144 | bool *check = (bool *) PG_GETARG_POINTER(0); |
| 145 | StrategyNumber strategy = PG_GETARG_UINT16(1); |
| 146 | |
| 147 | /* ArrayType *query = PG_GETARG_ARRAYTYPE_P(2); */ |
| 148 | int32 nkeys = PG_GETARG_INT32(3); |
| 149 | |
| 150 | /* Pointer *extra_data = (Pointer *) PG_GETARG_POINTER(4); */ |
| 151 | bool *recheck = (bool *) PG_GETARG_POINTER(5); |
| 152 | |
| 153 | /* Datum *queryKeys = (Datum *) PG_GETARG_POINTER(6); */ |
| 154 | bool *nullFlags = (bool *) PG_GETARG_POINTER(7); |
| 155 | bool res; |
| 156 | int32 i; |
| 157 | |
| 158 | switch (strategy) |
| 159 | { |
| 160 | case GinOverlapStrategy: |
| 161 | /* result is not lossy */ |
| 162 | *recheck = false; |
| 163 | /* must have a match for at least one non-null element */ |
| 164 | res = false; |
| 165 | for (i = 0; i < nkeys; i++) |
| 166 | { |
| 167 | if (check[i] && !nullFlags[i]) |
| 168 | { |
| 169 | res = true; |
| 170 | break; |
| 171 | } |
| 172 | } |
| 173 | break; |
| 174 | case GinContainsStrategy: |
| 175 | /* result is not lossy */ |
| 176 | *recheck = false; |
| 177 | /* must have all elements in check[] true, and no nulls */ |
| 178 | res = true; |
| 179 | for (i = 0; i < nkeys; i++) |
| 180 | { |
| 181 | if (!check[i] || nullFlags[i]) |
| 182 | { |
| 183 | res = false; |
| 184 | break; |
| 185 | } |
| 186 | } |
| 187 | break; |
| 188 | case GinContainedStrategy: |
| 189 | /* we will need recheck */ |
| 190 | *recheck = true; |
| 191 | /* can't do anything else useful here */ |
| 192 | res = true; |
| 193 | break; |
| 194 | case GinEqualStrategy: |
| 195 | /* we will need recheck */ |
| 196 | *recheck = true; |
| 197 | |
| 198 | /* |
| 199 | * Must have all elements in check[] true; no discrimination |
| 200 | * against nulls here. This is because array_contain_compare and |
| 201 | * array_eq handle nulls differently ... |
| 202 | */ |
| 203 | res = true; |
| 204 | for (i = 0; i < nkeys; i++) |
| 205 | { |
| 206 | if (!check[i]) |
| 207 | { |
| 208 | res = false; |
| 209 | break; |
| 210 | } |
| 211 | } |
| 212 | break; |
| 213 | default: |
| 214 | elog(ERROR, "ginarrayconsistent: unknown strategy number: %d" , |
| 215 | strategy); |
| 216 | res = false; |
| 217 | } |
| 218 | |
| 219 | PG_RETURN_BOOL(res); |
| 220 | } |
| 221 | |
| 222 | /* |
| 223 | * triconsistent support function |
| 224 | */ |
| 225 | Datum |
| 226 | ginarraytriconsistent(PG_FUNCTION_ARGS) |
| 227 | { |
| 228 | GinTernaryValue *check = (GinTernaryValue *) PG_GETARG_POINTER(0); |
| 229 | StrategyNumber strategy = PG_GETARG_UINT16(1); |
| 230 | |
| 231 | /* ArrayType *query = PG_GETARG_ARRAYTYPE_P(2); */ |
| 232 | int32 nkeys = PG_GETARG_INT32(3); |
| 233 | |
| 234 | /* Pointer *extra_data = (Pointer *) PG_GETARG_POINTER(4); */ |
| 235 | /* Datum *queryKeys = (Datum *) PG_GETARG_POINTER(5); */ |
| 236 | bool *nullFlags = (bool *) PG_GETARG_POINTER(6); |
| 237 | GinTernaryValue res; |
| 238 | int32 i; |
| 239 | |
| 240 | switch (strategy) |
| 241 | { |
| 242 | case GinOverlapStrategy: |
| 243 | /* must have a match for at least one non-null element */ |
| 244 | res = GIN_FALSE; |
| 245 | for (i = 0; i < nkeys; i++) |
| 246 | { |
| 247 | if (!nullFlags[i]) |
| 248 | { |
| 249 | if (check[i] == GIN_TRUE) |
| 250 | { |
| 251 | res = GIN_TRUE; |
| 252 | break; |
| 253 | } |
| 254 | else if (check[i] == GIN_MAYBE && res == GIN_FALSE) |
| 255 | { |
| 256 | res = GIN_MAYBE; |
| 257 | } |
| 258 | } |
| 259 | } |
| 260 | break; |
| 261 | case GinContainsStrategy: |
| 262 | /* must have all elements in check[] true, and no nulls */ |
| 263 | res = GIN_TRUE; |
| 264 | for (i = 0; i < nkeys; i++) |
| 265 | { |
| 266 | if (check[i] == GIN_FALSE || nullFlags[i]) |
| 267 | { |
| 268 | res = GIN_FALSE; |
| 269 | break; |
| 270 | } |
| 271 | if (check[i] == GIN_MAYBE) |
| 272 | { |
| 273 | res = GIN_MAYBE; |
| 274 | } |
| 275 | } |
| 276 | break; |
| 277 | case GinContainedStrategy: |
| 278 | /* can't do anything else useful here */ |
| 279 | res = GIN_MAYBE; |
| 280 | break; |
| 281 | case GinEqualStrategy: |
| 282 | |
| 283 | /* |
| 284 | * Must have all elements in check[] true; no discrimination |
| 285 | * against nulls here. This is because array_contain_compare and |
| 286 | * array_eq handle nulls differently ... |
| 287 | */ |
| 288 | res = GIN_MAYBE; |
| 289 | for (i = 0; i < nkeys; i++) |
| 290 | { |
| 291 | if (check[i] == GIN_FALSE) |
| 292 | { |
| 293 | res = GIN_FALSE; |
| 294 | break; |
| 295 | } |
| 296 | } |
| 297 | break; |
| 298 | default: |
| 299 | elog(ERROR, "ginarrayconsistent: unknown strategy number: %d" , |
| 300 | strategy); |
| 301 | res = false; |
| 302 | } |
| 303 | |
| 304 | PG_RETURN_GIN_TERNARY_VALUE(res); |
| 305 | } |
| 306 | |