Age Owner Branch data TLA Line data Source code
1 : : /*
2 : : * contrib/ltree/_ltree_gist.c
3 : : *
4 : : *
5 : : * GiST support for ltree[]
6 : : * Teodor Sigaev <teodor@stack.net>
7 : : */
8 : : #include "postgres.h"
9 : :
10 : : #include "access/gist.h"
11 : : #include "access/reloptions.h"
12 : : #include "access/stratnum.h"
13 : : #include "crc32.h"
14 : : #include "ltree.h"
15 : : #include "port/pg_bitutils.h"
16 : : #include "utils/array.h"
17 : :
8593 bruce@momjian.us 18 :CBC 3 : PG_FUNCTION_INFO_V1(_ltree_compress);
19 : 3 : PG_FUNCTION_INFO_V1(_ltree_same);
20 : 3 : PG_FUNCTION_INFO_V1(_ltree_union);
21 : 3 : PG_FUNCTION_INFO_V1(_ltree_penalty);
22 : 3 : PG_FUNCTION_INFO_V1(_ltree_picksplit);
23 : 3 : PG_FUNCTION_INFO_V1(_ltree_consistent);
2176 akorotkov@postgresql 24 : 3 : PG_FUNCTION_INFO_V1(_ltree_gist_options);
25 : :
26 : : #define GETENTRY(vec,pos) ((ltree_gist *) DatumGetPointer((vec)->vector[(pos)].key))
27 : : #define NEXTVAL(x) ( (ltree*)( (char*)(x) + INTALIGN( VARSIZE(x) ) ) )
28 : :
29 : : #define WISH_F(a,b,c) (double)( -(double)(((a)-(b))*((a)-(b))*((a)-(b)))*(c) )
30 : :
31 : :
32 : : static void
33 : 7058 : hashing(BITVECP sign, ltree *t, int siglen)
34 : : {
8593 bruce@momjian.us 35 : 7058 : int tlen = t->numlevel;
8629 36 : 7058 : ltree_level *cur = LTREE_FIRST(t);
37 : : int hash;
38 : :
8593 39 [ + + ]: 53466 : while (tlen > 0)
40 : : {
41 : 46408 : hash = ltree_crc32_sz(cur->name, cur->len);
2176 akorotkov@postgresql 42 : 46408 : AHASH(sign, hash, siglen);
8629 bruce@momjian.us 43 : 46408 : cur = LEVEL_NEXT(cur);
44 : 46408 : tlen--;
45 : : }
46 : 7058 : }
47 : :
48 : : Datum
8593 49 : 5845 : _ltree_compress(PG_FUNCTION_ARGS)
50 : : {
51 : 5845 : GISTENTRY *entry = (GISTENTRY *) PG_GETARG_POINTER(0);
8629 52 : 5845 : GISTENTRY *retval = entry;
2176 akorotkov@postgresql 53 [ + - ]: 5845 : int siglen = LTREE_GET_ASIGLEN();
54 : :
8593 bruce@momjian.us 55 [ + + ]: 5845 : if (entry->leafkey)
56 : : { /* ltree */
57 : : ltree_gist *key;
58 : 2000 : ArrayType *val = DatumGetArrayTypeP(entry->key);
59 : 2000 : int num = ArrayGetNItems(ARR_NDIM(val), ARR_DIMS(val));
60 [ - + ]: 2000 : ltree *item = (ltree *) ARR_DATA_PTR(val);
61 : :
5863 tgl@sss.pgh.pa.us 62 [ - + ]: 2000 : if (ARR_NDIM(val) > 1)
8270 tgl@sss.pgh.pa.us 63 [ # # ]:UBC 0 : ereport(ERROR,
64 : : (errcode(ERRCODE_ARRAY_SUBSCRIPT_ERROR),
65 : : errmsg("array must be one-dimensional")));
5544 tgl@sss.pgh.pa.us 66 [ - + ]:CBC 2000 : if (array_contains_nulls(val))
7421 tgl@sss.pgh.pa.us 67 [ # # ]:UBC 0 : ereport(ERROR,
68 : : (errcode(ERRCODE_NULL_VALUE_NOT_ALLOWED),
69 : : errmsg("array must not contain nulls")));
70 : :
2176 akorotkov@postgresql 71 :CBC 2000 : key = ltree_gist_alloc(false, NULL, siglen, NULL, NULL);
72 : :
8593 bruce@momjian.us 73 [ + + ]: 9058 : while (num > 0)
74 : : {
2176 akorotkov@postgresql 75 : 7058 : hashing(LTG_SIGN(key), item, siglen);
8629 bruce@momjian.us 76 : 7058 : num--;
77 : 7058 : item = NEXTVAL(item);
78 : : }
79 : :
100 michael@paquier.xyz 80 :GNC 2000 : retval = palloc_object(GISTENTRY);
8629 bruce@momjian.us 81 :CBC 2000 : gistentryinit(*retval, PointerGetDatum(key),
82 : : entry->rel, entry->page,
83 : : entry->offset, false);
84 : : }
219 tgl@sss.pgh.pa.us 85 [ + - ]:GNC 3845 : else if (!LTG_ISALLTRUE(DatumGetPointer(entry->key)))
86 : : {
87 : : int32 i;
88 : : ltree_gist *key;
8593 bruce@momjian.us 89 :CBC 3845 : BITVECP sign = LTG_SIGN(DatumGetPointer(entry->key));
90 : :
2176 akorotkov@postgresql 91 [ + - ]: 3845 : ALOOPBYTE(siglen)
92 : : {
6694 bruce@momjian.us 93 [ + - ]: 3845 : if ((sign[i] & 0xff) != 0xff)
94 : 3845 : PG_RETURN_POINTER(retval);
95 : : }
96 : :
2176 akorotkov@postgresql 97 :UBC 0 : key = ltree_gist_alloc(true, sign, siglen, NULL, NULL);
100 michael@paquier.xyz 98 :UNC 0 : retval = palloc_object(GISTENTRY);
8629 bruce@momjian.us 99 :UBC 0 : gistentryinit(*retval, PointerGetDatum(key),
100 : : entry->rel, entry->page,
101 : : entry->offset, false);
102 : : }
8629 bruce@momjian.us 103 :CBC 2000 : PG_RETURN_POINTER(retval);
104 : : }
105 : :
106 : : Datum
8593 107 : 7716 : _ltree_same(PG_FUNCTION_ARGS)
108 : : {
109 : 7716 : ltree_gist *a = (ltree_gist *) PG_GETARG_POINTER(0);
110 : 7716 : ltree_gist *b = (ltree_gist *) PG_GETARG_POINTER(1);
111 : 7716 : bool *result = (bool *) PG_GETARG_POINTER(2);
2176 akorotkov@postgresql 112 [ + - ]: 7716 : int siglen = LTREE_GET_ASIGLEN();
113 : :
8593 bruce@momjian.us 114 [ - + - - ]: 7716 : if (LTG_ISALLTRUE(a) && LTG_ISALLTRUE(b))
8629 bruce@momjian.us 115 :UBC 0 : *result = true;
8593 bruce@momjian.us 116 [ - + ]:CBC 7716 : else if (LTG_ISALLTRUE(a))
8629 bruce@momjian.us 117 :UBC 0 : *result = false;
8593 bruce@momjian.us 118 [ - + ]:CBC 7716 : else if (LTG_ISALLTRUE(b))
8629 bruce@momjian.us 119 :UBC 0 : *result = false;
120 : : else
121 : : {
122 : : int32 i;
8593 bruce@momjian.us 123 :CBC 7716 : BITVECP sa = LTG_SIGN(a),
124 : 7716 : sb = LTG_SIGN(b);
125 : :
8629 126 : 7716 : *result = true;
2176 akorotkov@postgresql 127 [ + + ]: 11030310 : ALOOPBYTE(siglen)
128 : : {
6694 bruce@momjian.us 129 [ + + ]: 11024675 : if (sa[i] != sb[i])
130 : : {
131 : 2081 : *result = false;
132 : 2081 : break;
133 : : }
134 : : }
135 : : }
8593 136 : 7716 : PG_RETURN_POINTER(result);
137 : : }
138 : :
139 : : static int32
2176 akorotkov@postgresql 140 : 15432 : unionkey(BITVECP sbase, ltree_gist *add, int siglen)
141 : : {
142 : : int32 i;
8593 bruce@momjian.us 143 : 15432 : BITVECP sadd = LTG_SIGN(add);
144 : :
145 [ - + ]: 15432 : if (LTG_ISALLTRUE(add))
8629 bruce@momjian.us 146 :UBC 0 : return 1;
147 : :
2176 akorotkov@postgresql 148 [ + + ]:CBC 27820672 : ALOOPBYTE(siglen)
6694 bruce@momjian.us 149 : 27805240 : sbase[i] |= sadd[i];
8629 150 : 15432 : return 0;
151 : : }
152 : :
153 : : Datum
8593 154 : 7716 : _ltree_union(PG_FUNCTION_ARGS)
155 : : {
7868 156 : 7716 : GistEntryVector *entryvec = (GistEntryVector *) PG_GETARG_POINTER(0);
8593 157 : 7716 : int *size = (int *) PG_GETARG_POINTER(1);
2176 akorotkov@postgresql 158 [ + - ]: 7716 : int siglen = LTREE_GET_ASIGLEN();
159 : : int32 i;
160 : 7716 : ltree_gist *result = ltree_gist_alloc(false, NULL, siglen, NULL, NULL);
161 : 7716 : BITVECP base = LTG_SIGN(result);
162 : :
8020 teodor@sigaev.ru 163 [ + + ]: 23148 : for (i = 0; i < entryvec->n; i++)
164 : : {
2176 akorotkov@postgresql 165 [ - + ]: 15432 : if (unionkey(base, GETENTRY(entryvec, i), siglen))
166 : : {
2176 akorotkov@postgresql 167 :UBC 0 : result->flag |= LTG_ALLTRUE;
168 : 0 : SET_VARSIZE(result, LTG_HDRSIZE);
8629 bruce@momjian.us 169 : 0 : break;
170 : : }
171 : : }
172 : :
2176 akorotkov@postgresql 173 :CBC 7716 : *size = VARSIZE(result);
174 : :
8593 bruce@momjian.us 175 : 7716 : PG_RETURN_POINTER(result);
176 : : }
177 : :
178 : : static int32
2176 akorotkov@postgresql 179 :UBC 0 : sizebitvec(BITVECP sign, int siglen)
180 : : {
181 : 0 : return pg_popcount((const char *) sign, siglen);
182 : : }
183 : :
184 : : static int
2176 akorotkov@postgresql 185 :CBC 135009 : hemdistsign(BITVECP a, BITVECP b, int siglen)
186 : : {
187 : : int i,
188 : : diff,
7868 bruce@momjian.us 189 : 135009 : dist = 0;
190 : :
2176 akorotkov@postgresql 191 [ + + ]: 58445981 : ALOOPBYTE(siglen)
192 : : {
6694 bruce@momjian.us 193 : 58310972 : diff = (unsigned char) (a[i] ^ b[i]);
194 : : /* Using the popcount functions here isn't likely to win */
2585 tgl@sss.pgh.pa.us 195 : 58310972 : dist += pg_number_of_ones[diff];
196 : : }
8313 bruce@momjian.us 197 : 135009 : return dist;
198 : : }
199 : :
200 : : static int
2176 akorotkov@postgresql 201 : 135009 : hemdist(ltree_gist *a, ltree_gist *b, int siglen)
202 : : {
7868 bruce@momjian.us 203 [ - + ]: 135009 : if (LTG_ISALLTRUE(a))
204 : : {
7868 bruce@momjian.us 205 [ # # ]:UBC 0 : if (LTG_ISALLTRUE(b))
206 : 0 : return 0;
207 : : else
2176 akorotkov@postgresql 208 : 0 : return ASIGLENBIT(siglen) - sizebitvec(LTG_SIGN(b), siglen);
209 : : }
7868 bruce@momjian.us 210 [ - + ]:CBC 135009 : else if (LTG_ISALLTRUE(b))
2176 akorotkov@postgresql 211 :UBC 0 : return ASIGLENBIT(siglen) - sizebitvec(LTG_SIGN(a), siglen);
212 : :
2176 akorotkov@postgresql 213 :CBC 135009 : return hemdistsign(LTG_SIGN(a), LTG_SIGN(b), siglen);
214 : : }
215 : :
216 : :
217 : : Datum
8593 bruce@momjian.us 218 : 19029 : _ltree_penalty(PG_FUNCTION_ARGS)
219 : : {
220 : 19029 : ltree_gist *origval = (ltree_gist *) DatumGetPointer(((GISTENTRY *) PG_GETARG_POINTER(0))->key);
221 : 19029 : ltree_gist *newval = (ltree_gist *) DatumGetPointer(((GISTENTRY *) PG_GETARG_POINTER(1))->key);
222 : 19029 : float *penalty = (float *) PG_GETARG_POINTER(2);
2176 akorotkov@postgresql 223 [ + - ]: 19029 : int siglen = LTREE_GET_ASIGLEN();
224 : :
225 : 19029 : *penalty = hemdist(origval, newval, siglen);
8593 bruce@momjian.us 226 : 19029 : PG_RETURN_POINTER(penalty);
227 : : }
228 : :
229 : : typedef struct
230 : : {
231 : : OffsetNumber pos;
232 : : int32 cost;
233 : : } SPLITCOST;
234 : :
235 : : static int
236 : 8271 : comparecost(const void *a, const void *b)
237 : : {
5299 peter_e@gmx.net 238 : 8271 : return ((const SPLITCOST *) a)->cost - ((const SPLITCOST *) b)->cost;
239 : : }
240 : :
241 : : Datum
8593 bruce@momjian.us 242 : 882 : _ltree_picksplit(PG_FUNCTION_ARGS)
243 : : {
7868 244 : 882 : GistEntryVector *entryvec = (GistEntryVector *) PG_GETARG_POINTER(0);
8593 245 : 882 : GIST_SPLITVEC *v = (GIST_SPLITVEC *) PG_GETARG_POINTER(1);
2176 akorotkov@postgresql 246 [ + - ]: 882 : int siglen = LTREE_GET_ASIGLEN();
247 : : OffsetNumber k,
248 : : j;
249 : : ltree_gist *datum_l,
250 : : *datum_r;
251 : : BITVECP union_l,
252 : : union_r;
253 : : int32 size_alpha,
254 : : size_beta;
255 : : int32 size_waste,
8313 bruce@momjian.us 256 : 882 : waste = -1;
257 : : int32 nbytes;
8593 258 : 882 : OffsetNumber seed_1 = 0,
259 : 882 : seed_2 = 0;
260 : : OffsetNumber *left,
261 : : *right;
262 : : OffsetNumber maxoff;
263 : : BITVECP ptr;
264 : : int i;
265 : : SPLITCOST *costvector;
266 : : ltree_gist *_k,
267 : : *_j;
268 : :
8020 teodor@sigaev.ru 269 : 882 : maxoff = entryvec->n - 2;
8629 bruce@momjian.us 270 : 882 : nbytes = (maxoff + 2) * sizeof(OffsetNumber);
271 : 882 : v->spl_left = (OffsetNumber *) palloc(nbytes);
272 : 882 : v->spl_right = (OffsetNumber *) palloc(nbytes);
273 : :
7868 274 [ + + ]: 4016 : for (k = FirstOffsetNumber; k < maxoff; k = OffsetNumberNext(k))
275 : : {
8593 276 : 3134 : _k = GETENTRY(entryvec, k);
7868 277 [ + + ]: 103050 : for (j = OffsetNumberNext(k); j <= maxoff; j = OffsetNumberNext(j))
278 : : {
2176 akorotkov@postgresql 279 : 99916 : size_waste = hemdist(_k, GETENTRY(entryvec, j), siglen);
7868 bruce@momjian.us 280 [ + + ]: 99916 : if (size_waste > waste)
281 : : {
8629 282 : 1642 : waste = size_waste;
283 : 1642 : seed_1 = k;
284 : 1642 : seed_2 = j;
285 : : }
286 : : }
287 : : }
288 : :
289 : 882 : left = v->spl_left;
290 : 882 : v->spl_nleft = 0;
291 : 882 : right = v->spl_right;
292 : 882 : v->spl_nright = 0;
293 : :
8593 294 [ + - - + ]: 882 : if (seed_1 == 0 || seed_2 == 0)
295 : : {
8629 bruce@momjian.us 296 :UBC 0 : seed_1 = 1;
297 : 0 : seed_2 = 2;
298 : : }
299 : :
300 : : /* form initial .. */
2176 akorotkov@postgresql 301 :CBC 882 : datum_l = ltree_gist_alloc(LTG_ISALLTRUE(GETENTRY(entryvec, seed_1)),
302 : 882 : LTG_SIGN(GETENTRY(entryvec, seed_1)),
303 : : siglen, NULL, NULL);
304 : :
305 : 882 : datum_r = ltree_gist_alloc(LTG_ISALLTRUE(GETENTRY(entryvec, seed_2)),
306 : 882 : LTG_SIGN(GETENTRY(entryvec, seed_2)),
307 : : siglen, NULL, NULL);
308 : :
8629 bruce@momjian.us 309 : 882 : maxoff = OffsetNumberNext(maxoff);
310 : : /* sort before ... */
100 michael@paquier.xyz 311 :GNC 882 : costvector = palloc_array(SPLITCOST, maxoff);
8593 bruce@momjian.us 312 [ + + ]:CBC 5780 : for (j = FirstOffsetNumber; j <= maxoff; j = OffsetNumberNext(j))
313 : : {
314 : 4898 : costvector[j - 1].pos = j;
315 : 4898 : _j = GETENTRY(entryvec, j);
2176 akorotkov@postgresql 316 : 4898 : size_alpha = hemdist(datum_l, _j, siglen);
317 : 4898 : size_beta = hemdist(datum_r, _j, siglen);
1255 peter@eisentraut.org 318 : 4898 : costvector[j - 1].cost = abs(size_alpha - size_beta);
319 : : }
1132 320 : 882 : qsort(costvector, maxoff, sizeof(SPLITCOST), comparecost);
321 : :
7868 bruce@momjian.us 322 : 882 : union_l = LTG_SIGN(datum_l);
323 : 882 : union_r = LTG_SIGN(datum_r);
324 : :
8593 325 [ + + ]: 5780 : for (k = 0; k < maxoff; k++)
326 : : {
8629 327 : 4898 : j = costvector[k].pos;
8593 328 [ + + ]: 4898 : if (j == seed_1)
329 : : {
8629 330 : 882 : *left++ = j;
331 : 882 : v->spl_nleft++;
332 : 882 : continue;
333 : : }
8593 334 [ + + ]: 4016 : else if (j == seed_2)
335 : : {
8629 336 : 882 : *right++ = j;
337 : 882 : v->spl_nright++;
338 : 882 : continue;
339 : : }
8313 340 : 3134 : _j = GETENTRY(entryvec, j);
2176 akorotkov@postgresql 341 : 3134 : size_alpha = hemdist(datum_l, _j, siglen);
342 : 3134 : size_beta = hemdist(datum_r, _j, siglen);
343 : :
7868 bruce@momjian.us 344 [ + + ]: 3134 : if (size_alpha < size_beta + WISH_F(v->spl_nleft, v->spl_nright, 0.00001))
345 : : {
346 [ + - - + ]: 1454 : if (LTG_ISALLTRUE(datum_l) || LTG_ISALLTRUE(_j))
347 : : {
8313 bruce@momjian.us 348 [ # # ]:UBC 0 : if (!LTG_ISALLTRUE(datum_l))
1132 peter@eisentraut.org 349 : 0 : memset(union_l, 0xff, siglen);
350 : : }
351 : : else
352 : : {
7868 bruce@momjian.us 353 :CBC 1454 : ptr = LTG_SIGN(_j);
2176 akorotkov@postgresql 354 [ + + ]: 1680882 : ALOOPBYTE(siglen)
6694 bruce@momjian.us 355 : 1679428 : union_l[i] |= ptr[i];
356 : : }
8629 357 : 1454 : *left++ = j;
358 : 1454 : v->spl_nleft++;
359 : : }
360 : : else
361 : : {
7868 362 [ + - - + ]: 1680 : if (LTG_ISALLTRUE(datum_r) || LTG_ISALLTRUE(_j))
363 : : {
8313 bruce@momjian.us 364 [ # # ]:UBC 0 : if (!LTG_ISALLTRUE(datum_r))
1132 peter@eisentraut.org 365 : 0 : memset(union_r, 0xff, siglen);
366 : : }
367 : : else
368 : : {
7868 bruce@momjian.us 369 :CBC 1680 : ptr = LTG_SIGN(_j);
2176 akorotkov@postgresql 370 [ + + ]: 1891028 : ALOOPBYTE(siglen)
6694 bruce@momjian.us 371 : 1889348 : union_r[i] |= ptr[i];
372 : : }
8629 373 : 1680 : *right++ = j;
374 : 1680 : v->spl_nright++;
375 : : }
376 : : }
377 : :
378 : 882 : *right = *left = FirstOffsetNumber;
379 : :
380 : 882 : v->spl_ldatum = PointerGetDatum(datum_l);
381 : 882 : v->spl_rdatum = PointerGetDatum(datum_r);
382 : :
8593 383 : 882 : PG_RETURN_POINTER(v);
384 : : }
385 : :
386 : : static bool
2176 akorotkov@postgresql 387 : 2526 : gist_te(ltree_gist *key, ltree *query, int siglen)
388 : : {
8593 bruce@momjian.us 389 : 2526 : ltree_level *curq = LTREE_FIRST(query);
390 : 2526 : BITVECP sign = LTG_SIGN(key);
391 : 2526 : int qlen = query->numlevel;
392 : : unsigned int hv;
393 : :
394 [ - + ]: 2526 : if (LTG_ISALLTRUE(key))
8629 bruce@momjian.us 395 :UBC 0 : return true;
396 : :
8593 bruce@momjian.us 397 [ + + ]:CBC 8550 : while (qlen > 0)
398 : : {
399 : 6542 : hv = ltree_crc32_sz(curq->name, curq->len);
2176 akorotkov@postgresql 400 [ + + ]: 6542 : if (!GETBIT(sign, AHASHVAL(hv, siglen)))
8593 bruce@momjian.us 401 : 518 : return false;
8629 402 : 6024 : curq = LEVEL_NEXT(curq);
403 : 6024 : qlen--;
404 : : }
405 : :
406 : 2008 : return true;
407 : : }
408 : :
409 : : typedef struct LtreeSignature
410 : : {
411 : : BITVECP sign;
412 : : int siglen;
413 : : } LtreeSignature;
414 : :
415 : : static bool
2176 akorotkov@postgresql 416 : 3573 : checkcondition_bit(void *cxt, ITEM *val)
417 : : {
418 : 3573 : LtreeSignature *sig = cxt;
419 : :
420 [ + - + + ]: 3573 : return (FLG_CANLOOKSIGN(val->flag)) ? GETBIT(sig->sign, AHASHVAL(val->val, sig->siglen)) : true;
421 : : }
422 : :
423 : : static bool
424 : 2055 : gist_qtxt(ltree_gist *key, ltxtquery *query, int siglen)
425 : : {
426 : : LtreeSignature sig;
427 : :
8593 bruce@momjian.us 428 [ - + ]: 2055 : if (LTG_ISALLTRUE(key))
8629 bruce@momjian.us 429 :UBC 0 : return true;
430 : :
2176 akorotkov@postgresql 431 :CBC 2055 : sig.sign = LTG_SIGN(key);
432 : 2055 : sig.siglen = siglen;
433 : :
2236 alvherre@alvh.no-ip. 434 : 2055 : return ltree_execute(GETQUERY(query),
435 : : &sig, false,
436 : : checkcondition_bit);
437 : : }
438 : :
439 : : static bool
2176 akorotkov@postgresql 440 : 14238 : gist_qe(ltree_gist *key, lquery *query, int siglen)
441 : : {
8593 bruce@momjian.us 442 : 14238 : lquery_level *curq = LQUERY_FIRST(query);
443 : 14238 : BITVECP sign = LTG_SIGN(key);
444 : 14238 : int qlen = query->numlevel;
445 : :
446 [ - + ]: 14238 : if (LTG_ISALLTRUE(key))
8629 bruce@momjian.us 447 :UBC 0 : return true;
448 : :
8593 bruce@momjian.us 449 [ + + ]:CBC 44803 : while (qlen > 0)
450 : : {
451 [ + + + - ]: 35718 : if (curq->numvar && LQL_CANLOOKSIGN(curq))
452 : : {
453 : 24719 : bool isexist = false;
454 : 24719 : int vlen = curq->numvar;
8629 455 : 24719 : lquery_variant *curv = LQL_FIRST(curq);
456 : :
8593 457 [ + + ]: 29872 : while (vlen > 0)
458 : : {
2176 akorotkov@postgresql 459 [ + + ]: 24719 : if (GETBIT(sign, AHASHVAL(curv->val, siglen)))
460 : : {
8593 bruce@momjian.us 461 : 19566 : isexist = true;
8629 462 : 19566 : break;
463 : : }
464 : 5153 : curv = LVAR_NEXT(curv);
465 : 5153 : vlen--;
466 : : }
8593 467 [ + + ]: 24719 : if (!isexist)
8629 468 : 5153 : return false;
469 : : }
470 : :
471 : 30565 : curq = LQL_NEXT(curq);
472 : 30565 : qlen--;
473 : : }
474 : :
475 : 9085 : return true;
476 : : }
477 : :
478 : : static bool
2176 akorotkov@postgresql 479 : 2189 : _arrq_cons(ltree_gist *key, ArrayType *_query, int siglen)
480 : : {
7868 bruce@momjian.us 481 [ - + ]: 2189 : lquery *query = (lquery *) ARR_DATA_PTR(_query);
482 : 2189 : int num = ArrayGetNItems(ARR_NDIM(_query), ARR_DIMS(_query));
483 : :
5863 tgl@sss.pgh.pa.us 484 [ - + ]: 2189 : if (ARR_NDIM(_query) > 1)
7868 bruce@momjian.us 485 [ # # ]:UBC 0 : ereport(ERROR,
486 : : (errcode(ERRCODE_ARRAY_SUBSCRIPT_ERROR),
487 : : errmsg("array must be one-dimensional")));
5544 tgl@sss.pgh.pa.us 488 [ - + ]:CBC 2189 : if (array_contains_nulls(_query))
7421 tgl@sss.pgh.pa.us 489 [ # # ]:UBC 0 : ereport(ERROR,
490 : : (errcode(ERRCODE_NULL_VALUE_NOT_ALLOWED),
491 : : errmsg("array must not contain nulls")));
492 : :
7868 bruce@momjian.us 493 [ + + ]:CBC 3805 : while (num > 0)
494 : : {
2176 akorotkov@postgresql 495 [ + + ]: 3104 : if (gist_qe(key, query, siglen))
7868 bruce@momjian.us 496 : 1488 : return true;
497 : 1616 : num--;
498 : 1616 : query = (lquery *) NEXTVAL(query);
499 : : }
500 : 701 : return false;
501 : : }
502 : :
503 : : Datum
8593 504 : 17904 : _ltree_consistent(PG_FUNCTION_ARGS)
505 : : {
506 : 17904 : GISTENTRY *entry = (GISTENTRY *) PG_GETARG_POINTER(0);
472 peter@eisentraut.org 507 : 17904 : void *query = PG_DETOAST_DATUM(PG_GETARG_DATUM(1));
8629 bruce@momjian.us 508 : 17904 : StrategyNumber strategy = (StrategyNumber) PG_GETARG_UINT16(2);
509 : : #ifdef NOT_USED
510 : : Oid subtype = PG_GETARG_OID(3);
511 : : #endif
6544 tgl@sss.pgh.pa.us 512 : 17904 : bool *recheck = (bool *) PG_GETARG_POINTER(4);
2176 akorotkov@postgresql 513 [ + - ]: 17904 : int siglen = LTREE_GET_ASIGLEN();
6544 tgl@sss.pgh.pa.us 514 : 17904 : ltree_gist *key = (ltree_gist *) DatumGetPointer(entry->key);
8593 bruce@momjian.us 515 : 17904 : bool res = false;
516 : :
517 : : /* All cases served by this function are inexact */
6544 tgl@sss.pgh.pa.us 518 : 17904 : *recheck = true;
519 : :
8593 bruce@momjian.us 520 [ + + + + : 17904 : switch (strategy)
- ]
521 : : {
8629 522 : 2526 : case 10:
523 : : case 11:
2176 akorotkov@postgresql 524 : 2526 : res = gist_te(key, (ltree *) query, siglen);
8629 bruce@momjian.us 525 : 2526 : break;
526 : 11134 : case 12:
527 : : case 13:
2176 akorotkov@postgresql 528 : 11134 : res = gist_qe(key, (lquery *) query, siglen);
8593 bruce@momjian.us 529 : 11134 : break;
8629 530 : 2055 : case 14:
531 : : case 15:
2176 akorotkov@postgresql 532 : 2055 : res = gist_qtxt(key, (ltxtquery *) query, siglen);
8593 bruce@momjian.us 533 : 2055 : break;
8425 534 : 2189 : case 16:
535 : : case 17:
2176 akorotkov@postgresql 536 : 2189 : res = _arrq_cons(key, (ArrayType *) query, siglen);
8425 bruce@momjian.us 537 : 2189 : break;
8629 bruce@momjian.us 538 :UBC 0 : default:
539 : : /* internal error */
8270 tgl@sss.pgh.pa.us 540 [ # # ]: 0 : elog(ERROR, "unrecognized StrategyNumber: %d", strategy);
541 : : }
7102 bruce@momjian.us 542 [ - + ]:CBC 17904 : PG_FREE_IF_COPY(query, 1);
8629 543 : 17904 : PG_RETURN_BOOL(res);
544 : : }
545 : :
546 : : Datum
2176 akorotkov@postgresql 547 : 10 : _ltree_gist_options(PG_FUNCTION_ARGS)
548 : : {
549 : 10 : local_relopts *relopts = (local_relopts *) PG_GETARG_POINTER(0);
550 : :
551 : 10 : init_local_reloptions(relopts, sizeof(LtreeGistOptions));
552 : 10 : add_local_int_reloption(relopts, "siglen", "signature length",
553 : : LTREE_ASIGLEN_DEFAULT, 1, LTREE_ASIGLEN_MAX,
554 : : offsetof(LtreeGistOptions, siglen));
555 : :
556 : 10 : PG_RETURN_VOID();
557 : : }
|
