+
−/* -*- sql -*-
+
−
+
−   postgres specific registered procedures for the Bytes File System storage,
+
−   require the plpythonu language installed
+
−
+
−*/
+
−
+
−
+
−CREATE OR REPLACE FUNCTION _fsopen(bytea) RETURNS bytea AS $$
+
−    fpath = args[0]
+
−    if fpath:
+
−        try:
+
−            data = file(fpath, 'rb').read()
+
−            #/* XXX due to plpython bug we have to replace some characters... */
+
−            return data.replace("\\", r"\134").replace("\000", r"\000").replace("'", r"\047") #'
+
−        except Exception, ex:
+
−            plpy.warning('failed to get content for %s: %s', fpath, ex)
+
−    return None
+
−$$ LANGUAGE plpythonu
+
−/* WITH(ISCACHABLE) XXX does postgres handle caching of large data nicely */
+
−;;
+
−
+
−/* fspath(eid, entity type, attribute) */
+
−CREATE OR REPLACE FUNCTION fspath(bigint, text, text) RETURNS bytea AS $$
+
−    pkey = 'plan%s%s' % (args[1], args[2])
+
−    try:
+
−        plan = SD[pkey]
+
−    except KeyError:
+
−        #/* then prepare and cache plan to get versioned file information from a
+
−        # version content eid */
+
−        plan = plpy.prepare(
+
−            'SELECT X.cw_%s FROM cw_%s as X WHERE X.cw_eid=$1' % (args[2], args[1]),
+
−            ['bigint'])
+
−        SD[pkey] = plan
+
−    return plpy.execute(plan, [args[0]])[0]
+
−$$ LANGUAGE plpythonu
+
−/* WITH(ISCACHABLE) XXX does postgres handle caching of large data nicely */
+
−;;