X-Git-Url: http://git.indexdata.com/?p=yaz-moved-to-github.git;a=blobdiff_plain;f=src%2Frecord_conv.c;h=02eebb6472393acf5d731790d94a9a33df3df076;hp=9ab5b71218da80cba4181ec279ffb296d6b04843;hb=1cb13d30835efee957d72558d419e78de9804e8b;hpb=8ceaeefe2e491935cba91f56007308be6e4996e6 diff --git a/src/record_conv.c b/src/record_conv.c index 9ab5b71..02eebb6 100644 --- a/src/record_conv.c +++ b/src/record_conv.c @@ -20,11 +20,14 @@ #include #include #include +#include #if YAZ_HAVE_XML2 #include #include #include +#include +#include #if YAZ_HAVE_XSLT #include #include @@ -187,8 +190,7 @@ static void *construct_xslt(const xmlNode *ptr, info->xsl_parms[2 * no_parms + 1] = qvalue; no_parms++; } - - info->xsl_parms[2 * no_parms] = '\0'; + info->xsl_parms[2 * no_parms] = 0; if (!stylesheet) { @@ -317,6 +319,95 @@ static void destroy_xslt(void *vinfo) /* YAZ_HAVE_XSLT */ #endif +struct select_info { + NMEM nmem; + char *xpath_expr; +}; + +static void *construct_select(const xmlNode *ptr, + const char *path, WRBUF wr_error) +{ + if (strcmp((const char *) ptr->name, "select")) + return 0; + else + { + NMEM nmem = nmem_create(); + struct select_info *info = nmem_malloc(nmem, sizeof(*info)); + const char *attr_str; + const char *xpath = 0; + + info->nmem = nmem; + info->xpath_expr = 0; + attr_str = yaz_xml_get_prop(ptr, "path%s", &xpath); + if (attr_str) + { + wrbuf_printf(wr_error, "Bad attribute '%s'" + "Expected xpath.", attr_str); + nmem_destroy(nmem); + return 0; + } + if (xpath) + info->xpath_expr = nmem_strdup(nmem, xpath); + return info; + } +} + +static int convert_select(void *vinfo, WRBUF record, WRBUF wr_error) +{ + int ret = 0; + struct select_info *info = vinfo; + + xmlDocPtr doc = xmlParseMemory(wrbuf_buf(record), + wrbuf_len(record)); + if (!doc) + { + wrbuf_printf(wr_error, "xmlParseMemory failed"); + ret = -1; + } + else + { + xmlXPathContextPtr xpathCtx = xmlXPathNewContext(doc); + if (xpathCtx && info->xpath_expr) + { + xmlXPathObjectPtr xpathObj = + xmlXPathEvalExpression((const xmlChar *) info->xpath_expr, + xpathCtx); + if (xpathObj) + { + xmlNodeSetPtr nodes = xpathObj->nodesetval; + if (nodes) + { + int i; + if (nodes->nodeNr > 0) + wrbuf_rewind(record); + for (i = 0; i < nodes->nodeNr; i++) + { + xmlNode *ptr = nodes->nodeTab[i]; + if (ptr->type == XML_ELEMENT_NODE) + ptr = ptr->children; + for (; ptr; ptr = ptr->next) + if (ptr->type == XML_TEXT_NODE) + wrbuf_puts(record, (const char *) ptr->content); + } + } + xmlXPathFreeObject(xpathObj); + } + xmlXPathFreeContext(xpathCtx); + } + xmlFreeDoc(doc); + } + return ret; +} + +static void destroy_select(void *vinfo) +{ + struct select_info *info = vinfo; + + if (info) + nmem_destroy(info->nmem); +} + + static void *construct_solrmarc(const xmlNode *ptr, const char *path, WRBUF wr_error) { @@ -592,7 +683,7 @@ static void destroy_marc(void *info) int yaz_record_conv_configure_t(yaz_record_conv_t p, const xmlNode *ptr, struct yaz_record_conv_type *types) { - struct yaz_record_conv_type bt[3]; + struct yaz_record_conv_type bt[4]; size_t i = 0; /* register marc */ @@ -605,6 +696,11 @@ int yaz_record_conv_configure_t(yaz_record_conv_t p, const xmlNode *ptr, bt[i].convert = convert_solrmarc; bt[i++].destroy = destroy_solrmarc; + bt[i-1].next = &bt[i]; + bt[i].construct = construct_select; + bt[i].convert = convert_select; + bt[i++].destroy = destroy_select; + #if YAZ_HAVE_XSLT /* register xslt */ bt[i-1].next = &bt[i];