hstore_plperl.c File Reference

#include "postgres.h"
#include "fmgr.h"
#include "hstore/hstore.h"
#include "plperl.h"

Include dependency graph for hstore_plperl.c:

Go to the source code of this file.

Macros
#define	hstoreUpgrade   hstoreUpgrade_p
#define	hstoreUniquePairs   hstoreUniquePairs_p
#define	hstorePairs   hstorePairs_p
#define	hstoreCheckKeyLen   hstoreCheckKeyLen_p
#define	hstoreCheckValLen   hstoreCheckValLen_p

Typedefs
typedef HStore *(*	hstoreUpgrade_t) (Datum orig)
typedef int(*	hstoreUniquePairs_t) (Pairs *a, int32 l, int32 *buflen)
typedef HStore *(*	hstorePairs_t) (Pairs *pairs, int32 pcount, int32 buflen)
typedef size_t(*	hstoreCheckKeyLen_t) (size_t len)
typedef size_t(*	hstoreCheckValLen_t) (size_t len)

Functions
void	_PG_init (void)
	PG_FUNCTION_INFO_V1 (hstore_to_plperl)
Datum	hstore_to_plperl (PG_FUNCTION_ARGS)
	PG_FUNCTION_INFO_V1 (plperl_to_hstore)
Datum	plperl_to_hstore (PG_FUNCTION_ARGS)

Variables
	PG_MODULE_MAGIC
static hstoreUpgrade_t	hstoreUpgrade_p
static hstoreUniquePairs_t	hstoreUniquePairs_p
static hstorePairs_t	hstorePairs_p
static hstoreCheckKeyLen_t	hstoreCheckKeyLen_p
static hstoreCheckValLen_t	hstoreCheckValLen_p

Macro Definition Documentation

hstoreCheckKeyLen

#define hstoreCheckKeyLen   hstoreCheckKeyLen_p

Definition at line 56 of file hstore_plperl.c.

hstoreCheckValLen

#define hstoreCheckValLen   hstoreCheckValLen_p

Definition at line 57 of file hstore_plperl.c.

hstorePairs

#define hstorePairs   hstorePairs_p

Definition at line 55 of file hstore_plperl.c.

hstoreUniquePairs

#define hstoreUniquePairs   hstoreUniquePairs_p

Definition at line 54 of file hstore_plperl.c.

hstoreUpgrade

#define hstoreUpgrade   hstoreUpgrade_p

Definition at line 53 of file hstore_plperl.c.

Typedef Documentation

hstoreCheckKeyLen_t

typedef size_t(* hstoreCheckKeyLen_t) (size_t len)

Definition at line 16 of file hstore_plperl.c.

hstoreCheckValLen_t

typedef size_t(* hstoreCheckValLen_t) (size_t len)

Definition at line 18 of file hstore_plperl.c.

hstorePairs_t

typedef HStore *(* hstorePairs_t) (Pairs *pairs, int32 pcount, int32 buflen)

Definition at line 14 of file hstore_plperl.c.

hstoreUniquePairs_t

typedef int(* hstoreUniquePairs_t) (Pairs *a, int32 l, int32 *buflen)

Definition at line 12 of file hstore_plperl.c.

hstoreUpgrade_t

typedef HStore *(* hstoreUpgrade_t) (Datum orig)

Definition at line 10 of file hstore_plperl.c.

Function Documentation

_PG_init()

void _PG_init

(

void

)

Definition at line 26 of file hstore_plperl.c.

{
    /* Asserts verify that typedefs above match original declarations */
    AssertVariableIsOfType(&hstoreUpgrade, hstoreUpgrade_t);
    hstoreUpgrade_p = (hstoreUpgrade_t)
        load_external_function("$libdir/hstore", "hstoreUpgrade",
                               true, NULL);
    AssertVariableIsOfType(&hstoreUniquePairs, hstoreUniquePairs_t);
    hstoreUniquePairs_p = (hstoreUniquePairs_t)
        load_external_function("$libdir/hstore", "hstoreUniquePairs",
                               true, NULL);
    AssertVariableIsOfType(&hstorePairs, hstorePairs_t);
    hstorePairs_p = (hstorePairs_t)
        load_external_function("$libdir/hstore", "hstorePairs",
                               true, NULL);
    AssertVariableIsOfType(&hstoreCheckKeyLen, hstoreCheckKeyLen_t);
    hstoreCheckKeyLen_p = (hstoreCheckKeyLen_t)
        load_external_function("$libdir/hstore", "hstoreCheckKeyLen",
                               true, NULL);
    AssertVariableIsOfType(&hstoreCheckValLen, hstoreCheckValLen_t);
    hstoreCheckValLen_p = (hstoreCheckValLen_t)
        load_external_function("$libdir/hstore", "hstoreCheckValLen",
                               true, NULL);
}

References AssertVariableIsOfType, hstoreCheckKeyLen, hstoreCheckKeyLen_p, hstoreCheckValLen, hstoreCheckValLen_p, hstorePairs, hstorePairs_p, hstoreUniquePairs, hstoreUniquePairs_p, hstoreUpgrade, hstoreUpgrade_p, and load_external_function().

hstore_to_plperl()

Datum hstore_to_plperl

(

PG_FUNCTION_ARGS

)

Definition at line 63 of file hstore_plperl.c.

{
    dTHX;
    HStore     *in = PG_GETARG_HSTORE_P(0);
    int         i;
    int         count = HS_COUNT(in);
    char       *base = STRPTR(in);
    HEntry     *entries = ARRPTR(in);
    HV         *hv;
 
    hv = newHV();
 
    for (i = 0; i < count; i++)
    {
        const char *key;
        SV         *value;
 
        key = pnstrdup(HSTORE_KEY(entries, base, i),
                       HSTORE_KEYLEN(entries, i));
        value = HSTORE_VALISNULL(entries, i) ? newSV(0) :
            cstr2sv(pnstrdup(HSTORE_VAL(entries, base, i),
                             HSTORE_VALLEN(entries, i)));
 
        (void) hv_store(hv, key, strlen(key), value, 0);
    }
 
    return PointerGetDatum(newRV((SV *) hv));
}

References ARRPTR, cstr2sv(), dTHX, HS_COUNT, HSTORE_KEY, HSTORE_KEYLEN, HSTORE_VAL, HSTORE_VALISNULL, HSTORE_VALLEN, i, sort-test::key, PG_GETARG_HSTORE_P, pnstrdup(), PointerGetDatum(), STRPTR, and value.

PG_FUNCTION_INFO_V1() [1/2]

PG_FUNCTION_INFO_V1

(

hstore_to_plperl

)

PG_FUNCTION_INFO_V1() [2/2]

PG_FUNCTION_INFO_V1

(

plperl_to_hstore

)

plperl_to_hstore()

Datum plperl_to_hstore

(

PG_FUNCTION_ARGS

)

Definition at line 96 of file hstore_plperl.c.

{
    dTHX;
    SV         *in = (SV *) PG_GETARG_POINTER(0);
    HV         *hv;
    HE         *he;
    int32       buflen;
    int32       i;
    int32       pcount;
    HStore     *out;
    Pairs      *pairs;
 
    /* Dereference references recursively. */
    while (SvROK(in))
        in = SvRV(in);
 
    /* Now we must have a hash. */
    if (SvTYPE(in) != SVt_PVHV)
        ereport(ERROR,
                (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
                 errmsg("cannot transform non-hash Perl value to hstore")));
    hv = (HV *) in;
 
    pcount = hv_iterinit(hv);
 
    pairs = palloc(pcount * sizeof(Pairs));
 
    i = 0;
    while ((he = hv_iternext(hv)))
    {
        char       *key = sv2cstr(HeSVKEY_force(he));
        SV         *value = HeVAL(he);
 
        pairs[i].key = pstrdup(key);
        pairs[i].keylen = hstoreCheckKeyLen(strlen(pairs[i].key));
        pairs[i].needfree = true;
 
        if (!SvOK(value))
        {
            pairs[i].val = NULL;
            pairs[i].vallen = 0;
            pairs[i].isnull = true;
        }
        else
        {
            pairs[i].val = pstrdup(sv2cstr(value));
            pairs[i].vallen = hstoreCheckValLen(strlen(pairs[i].val));
            pairs[i].isnull = false;
        }
 
        i++;
    }
 
    pcount = hstoreUniquePairs(pairs, pcount, &buflen);
    out = hstorePairs(pairs, pcount, buflen);
    PG_RETURN_POINTER(out);
}

References dTHX, ereport, errcode(), errmsg(), ERROR, hstoreCheckKeyLen, hstoreCheckValLen, hstorePairs, hstoreUniquePairs, i, Pairs::isnull, Pairs::key, sort-test::key, Pairs::keylen, Pairs::needfree, palloc(), PG_GETARG_POINTER, PG_RETURN_POINTER, pstrdup(), sv2cstr(), Pairs::val, val, Pairs::vallen, and value.

Variable Documentation

hstoreCheckKeyLen_p

hstoreCheckKeyLen_t hstoreCheckKeyLen_p

static

Definition at line 17 of file hstore_plperl.c.

Referenced by _PG_init().

hstoreCheckValLen_p

hstoreCheckValLen_t hstoreCheckValLen_p

static

Definition at line 19 of file hstore_plperl.c.

Referenced by _PG_init().

hstorePairs_p

hstorePairs_t hstorePairs_p

static

Definition at line 15 of file hstore_plperl.c.

Referenced by _PG_init().

hstoreUniquePairs_p

hstoreUniquePairs_t hstoreUniquePairs_p

static

Definition at line 13 of file hstore_plperl.c.

Referenced by _PG_init().

hstoreUpgrade_p

hstoreUpgrade_t hstoreUpgrade_p

static

Definition at line 11 of file hstore_plperl.c.

Referenced by _PG_init().

PG_MODULE_MAGIC

PG_MODULE_MAGIC

Definition at line 7 of file hstore_plperl.c.