+ZEBRA_RES zebra_records_retrieve(ZebraHandle zh, ODR stream,
+ const char *setname,
+ Z_RecordComposition *comp,
+ oid_value input_format, int num_recs,
+ ZebraRetrievalRecord *recs)
+{
+ ZebraMetaRecord *poset;
+ int i;
+ ZEBRA_RES ret = ZEBRA_OK;
+ zint *pos_array;
+
+ ZEBRA_CHECK_HANDLE(zh);
+ assert(stream);
+ assert(setname);
+ assert(recs);
+ assert(num_recs>0);
+
+ yaz_log(log_level, "zebra_records_retrieve n=%d", num_recs);
+
+ if (!zh->res)
+ {
+ zebra_setError(zh, YAZ_BIB1_SPECIFIED_RESULT_SET_DOES_NOT_EXIST,
+ setname);
+ return ZEBRA_FAIL;
+ }
+
+ if (zebra_begin_read (zh) == ZEBRA_FAIL)
+ return ZEBRA_FAIL;
+
+ pos_array = (zint *) xmalloc(num_recs * sizeof(*pos_array));
+ for (i = 0; i<num_recs; i++)
+ pos_array[i] = recs[i].position;
+ poset = zebra_meta_records_create(zh, setname, num_recs, pos_array);
+ if (!poset)
+ {
+ yaz_log (YLOG_DEBUG, "zebraPosSetCreate error");
+ zebra_setError(zh, YAZ_BIB1_SPECIFIED_RESULT_SET_DOES_NOT_EXIST,
+ setname);
+ ret = ZEBRA_FAIL;
+ }
+ else
+ {
+ for (i = 0; i<num_recs; i++)
+ {
+ if (poset[i].term)
+ {
+ recs[i].errCode = 0;
+ recs[i].format = VAL_SUTRS;
+ recs[i].len = strlen(poset[i].term);
+ recs[i].buf = poset[i].term;
+ recs[i].base = poset[i].db;
+ }
+ else if (poset[i].sysno)
+ {
+ char *buf;
+ int len;
+ zebra_snippets *hit_snippet = zebra_snippets_create();
+
+ zebra_snippets_hit_vector(zh, setname, poset[i].sysno,
+ hit_snippet);
+
+ recs[i].errCode =
+ zebra_record_fetch(zh, poset[i].sysno, poset[i].score,
+ hit_snippet,
+ stream, input_format, comp,
+ &recs[i].format, &buf, &len,
+ &recs[i].base, &recs[i].errString);
+
+ recs[i].len = len;
+ if (len > 0)
+ {
+ recs[i].buf = (char*) odr_malloc(stream, len);
+ memcpy(recs[i].buf, buf, len);
+ }
+ else
+ recs[i].buf = buf;
+ recs[i].score = poset[i].score;
+ recs[i].sysno = poset[i].sysno;
+ zebra_snippets_destroy(hit_snippet);
+ }
+ else
+ {
+ /* only need to set it once */
+ if (pos_array[i] < zh->approx_limit && ret == ZEBRA_OK)
+ {
+ zebra_setError_zint(zh,
+ YAZ_BIB1_PRESENT_REQUEST_OUT_OF_RANGE,
+ pos_array[i]);
+ ret = ZEBRA_FAIL;
+ break;
+ }
+ recs[i].buf = 0; /* no record and no error issued */
+ recs[i].len = 0;
+ recs[i].errCode = 0;
+ recs[i].format = VAL_NONE;
+ recs[i].sysno = 0;
+ }
+ }
+ zebra_meta_records_destroy(zh, poset, num_recs);
+ }
+ zebra_end_read (zh);
+ xfree(pos_array);
+ return ret;
+}
+
+ZEBRA_RES zebra_scan_PQF(ZebraHandle zh, ODR stream, const char *query,
+ int *position,
+ int *num_entries, ZebraScanEntry **entries,
+ int *is_partial,
+ const char *setname)
+{
+ YAZ_PQF_Parser pqf_parser = yaz_pqf_create ();
+ Z_AttributesPlusTerm *zapt;
+ int *attributeSet;
+ ZEBRA_RES res;
+
+ if (!(zapt = yaz_pqf_scan(pqf_parser, stream, &attributeSet, query)))
+ {
+ res = ZEBRA_FAIL;
+ zh->errCode = YAZ_BIB1_SCAN_MALFORMED_SCAN;
+ }
+ else
+ res = zebra_scan(zh, stream, zapt, VAL_BIB1,
+ position, num_entries, entries, is_partial,
+ setname);
+ yaz_pqf_destroy (pqf_parser);
+ return res;
+}
+
+ZEBRA_RES zebra_scan(ZebraHandle zh, ODR stream, Z_AttributesPlusTerm *zapt,
+ oid_value attributeset,
+ int *position,
+ int *num_entries, ZebraScanEntry **entries,
+ int *is_partial,
+ const char *setname)
+{
+ ZEBRA_RES res;
+ RSET limit_rset = 0;
+
+ ZEBRA_CHECK_HANDLE(zh);
+
+ assert(stream);
+ assert(zapt);
+ assert(position);
+ assert(num_entries);
+ assert(is_partial);
+ assert(entries);
+ yaz_log(log_level, "zebra_scan");
+
+ if (zebra_begin_read (zh) == ZEBRA_FAIL)
+ {
+ *entries = 0;
+ *num_entries = 0;
+ return ZEBRA_FAIL;
+ }
+ if (setname)
+ {
+ limit_rset = resultSetRef(zh, setname);
+ if (!limit_rset)
+ {
+ zebra_setError(zh,
+ YAZ_BIB1_SPECIFIED_RESULT_SET_DOES_NOT_EXIST,
+ setname);
+ zebra_end_read (zh);
+ return ZEBRA_FAIL;
+ }
+ }
+ res = rpn_scan (zh, stream, zapt, attributeset,
+ zh->num_basenames, zh->basenames, position,
+ num_entries, entries, is_partial, limit_rset, 0);
+ zebra_end_read (zh);
+ return res;
+}
+
+ZEBRA_RES zebra_sort (ZebraHandle zh, ODR stream,
+ int num_input_setnames, const char **input_setnames,
+ const char *output_setname,
+ Z_SortKeySpecList *sort_sequence,
+ int *sort_status)
+{
+ ZEBRA_RES res;
+ ZEBRA_CHECK_HANDLE(zh);
+ assert(stream);
+ assert(num_input_setnames>0);
+ assert(input_setnames);
+ assert(sort_sequence);
+ assert(sort_status);
+ yaz_log(log_level, "zebra_sort");
+
+ if (zebra_begin_read(zh) == ZEBRA_FAIL)
+ return ZEBRA_FAIL;
+ res = resultSetSort(zh, stream->mem, num_input_setnames, input_setnames,
+ output_setname, sort_sequence, sort_status);
+ zebra_end_read(zh);
+ return res;
+}
+
+int zebra_deleteResultSet(ZebraHandle zh, int function,