X-Git-Url: http://git.indexdata.com/?p=mp-xquery-moved-to-github.git;a=blobdiff_plain;f=src%2Fmetaproxy_filter_xquery.cpp;h=466164c28b786ff8da208c7853e386a7157a7532;hp=bd2948785eab45988d1b17e396905b9089241c7a;hb=b9f90637a6c007fd488f925be8dbfd144caee05b;hpb=c10a1166fba0a58f91aab8924259df04ca7115dc diff --git a/src/metaproxy_filter_xquery.cpp b/src/metaproxy_filter_xquery.cpp index bd29487..466164c 100644 --- a/src/metaproxy_filter_xquery.cpp +++ b/src/metaproxy_filter_xquery.cpp @@ -20,6 +20,7 @@ Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA #include #include #include +#include #include #include #include @@ -108,8 +109,8 @@ bool yf::XQuery::convert_one_record(const char *input_buf, result = ss.str(); return true; } catch ( ZorbaException &e) { - std::string msg = e.what(); - yaz_log(YLOG_WARN, "XQuery execute failure: %s", msg.c_str()); + result = e.what(); + yaz_log(YLOG_WARN, "XQuery execute: %s", result.c_str()); return false; } } @@ -278,11 +279,11 @@ void yf::XQuery::process(Package &package) const int i; for (i = 0; i < records->num_records; i++) { - Z_NamePlusRecord *npr = records->records[i]; - if (npr->which == Z_NamePlusRecord_databaseRecord) + Z_NamePlusRecord **npr = &records->records[i]; + if ((*npr)->which == Z_NamePlusRecord_databaseRecord) { const char *details = 0; - Z_External *r = npr->u.databaseRecord; + Z_External *r = (*npr)->u.databaseRecord; int ret_trans = -1; if (r->which == Z_External_octet && !oid_oidcmp(r->direct_reference, yaz_oid_recsyn_xml)) @@ -292,11 +293,18 @@ void yf::XQuery::process(Package &package) const r->u.octet_aligned->buf, r->u.octet_aligned->len, result)) { - npr->u.databaseRecord = + (*npr)->u.databaseRecord = z_ext_record_oid(odr_en, yaz_oid_recsyn_xml, result.c_str(), result.length()); } + else + { + *npr = zget_surrogateDiagRec( + odr_en, (*npr)->databaseName, + YAZ_BIB1_SYSTEM_ERROR_IN_PRESENTING_RECORDS, + result.c_str()); + } } } } @@ -311,7 +319,7 @@ void yf::XQuery::configure(const xmlNode * ptr, bool test_only, { if (ptr->type != XML_ELEMENT_NODE) continue; - if (!strcmp((const char *) ptr->name, "setVariable")) + if (!strcmp((const char *) ptr->name, "variable")) { std::string name; std::string value; @@ -330,29 +338,29 @@ void yf::XQuery::configure(const xmlNode * ptr, bool test_only, } else if (!strcmp((const char *) ptr->name, "script")) { - std::string value; + std::string name; struct _xmlAttr *attr; for (attr = ptr->properties; attr; attr = attr->next) - if (!strcmp((const char *) attr->name, "value")) - value = mp::xml::get_text(attr->children); + if (!strcmp((const char *) attr->name, "name")) + name = mp::xml::get_text(attr->children); else throw mp::filter::FilterException( "Bad attribute " + std::string((const char *) attr->name)); - zorba_script = value; + zorba_script = name; } else if (!strcmp((const char *) ptr->name, "record")) { - std::string value; + std::string name; struct _xmlAttr *attr; for (attr = ptr->properties; attr; attr = attr->next) - if (!strcmp((const char *) attr->name, "value")) - value = mp::xml::get_text(attr->children); + if (!strcmp((const char *) attr->name, "name")) + name = mp::xml::get_text(attr->children); else throw mp::filter::FilterException( "Bad attribute " + std::string((const char *) attr->name)); - zorba_record_variable = value; + zorba_record_variable = name; } else { @@ -381,7 +389,7 @@ void yf::XQuery::configure(const xmlNode * ptr, bool test_only, Zorba_CompilerHints lHints; lQuery->compile(*qfile, lHints); } catch ( ZorbaException &e) { - std::string msg = "XQuery compile failure: "; + std::string msg = "XQuery compile: "; msg += e.what(); throw mp::filter::FilterException(msg); }