X-Git-Url: http://git.indexdata.com/?p=idzebra-moved-to-github.git;a=blobdiff_plain;f=index%2Fextract.c;h=69b449ca5d13ce0d886831907cd148e4dc56be23;hp=0d648a6d7de890fbfde525d6f41f7fbf35b54a06;hb=89d16cf15eda0e4802d18b8ad09bd3653508ebfc;hpb=40869f1460c8b3804904ec207b18c5607f82de6e diff --git a/index/extract.c b/index/extract.c index 0d648a6..69b449c 100644 --- a/index/extract.c +++ b/index/extract.c @@ -1,5 +1,5 @@ /* This file is part of the Zebra server. - Copyright (C) 1995-2008 Index Data + Copyright (C) 1994-2009 Index Data Zebra is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free @@ -64,6 +64,21 @@ static void zebra_init_log_level(void) } } +static WRBUF wrbuf_hex_str(const char *cstr) +{ + size_t i; + WRBUF w = wrbuf_alloc(); + for (i = 0; cstr[i]; i++) + { + if (cstr[i] < ' ' || cstr[i] > 126) + wrbuf_printf(w, "\\%02X", cstr[i] & 0xff); + else + wrbuf_putc(w, cstr[i]); + } + return w; +} + + static void extract_flush_sort_keys(ZebraHandle zh, zint sysno, int cmd, zebra_rec_keys_t skp); static void extract_schema_add(struct recExtractCtrl *p, Odr_oid *oid); @@ -440,9 +455,6 @@ static char *get_match_from_spec(ZebraHandle zh, attname_str[i++] = *s; attname_str[i] = '\0'; } - - searchRecordKey(zh, reckeys, attname_str, ws, 32); - if (*s != ')') { yaz_log(YLOG_WARN, "Missing ) in match criteria %s in group %s", @@ -451,6 +463,20 @@ static char *get_match_from_spec(ZebraHandle zh, } s++; + searchRecordKey(zh, reckeys, attname_str, ws, 32); + if (0) /* for debugging */ + { + for (i = 0; i<32; i++) + { + if (ws[i]) + { + WRBUF w = wrbuf_hex_str(ws[i]); + yaz_log(YLOG_LOG, "ws[%d] = %s", i, wrbuf_cstr(w)); + wrbuf_destroy(w); + } + } + } + for (i = 0; i<32; i++) if (ws[i]) { @@ -534,6 +560,14 @@ static char *get_match_from_spec(ZebraHandle zh, return NULL; } *dst = '\0'; + + if (0) /* for debugging */ + { + WRBUF w = wrbuf_hex_str(dstBuf); + yaz_log(YLOG_LOG, "get_match_from_spec %s", wrbuf_cstr(w)); + wrbuf_destroy(w); + } + return dstBuf; } @@ -570,10 +604,10 @@ static void all_matches_add(struct recExtractCtrl *ctrl, zint record_id, "", 0); } +/* forward declaration */ ZEBRA_RES zebra_extract_records_stream(ZebraHandle zh, struct ZebraRecStream *stream, enum zebra_recctrl_action_t action, - int test_mode, const char *recordType, zint *sysno, const char *match_criteria, @@ -682,7 +716,6 @@ ZEBRA_RES zebra_extract_file(ZebraHandle zh, zint *sysno, const char *fname, } r = zebra_extract_records_stream(zh, streamp, action, - 0, /* tst_mode */ zh->m_record_type, sysno, 0, /*match_criteria */ @@ -704,7 +737,6 @@ ZEBRA_RES zebra_extract_file(ZebraHandle zh, zint *sysno, const char *fname, ZEBRA_RES zebra_buffer_extract_record(ZebraHandle zh, const char *buf, size_t buf_size, enum zebra_recctrl_action_t action, - int test_mode, const char *recordType, zint *sysno, const char *match_criteria, @@ -746,7 +778,6 @@ ZEBRA_RES zebra_buffer_extract_record(ZebraHandle zh, res = zebra_extract_records_stream(zh, &stream, action, - test_mode, recordType, sysno, match_criteria, @@ -756,69 +787,17 @@ ZEBRA_RES zebra_buffer_extract_record(ZebraHandle zh, return res; } -ZEBRA_RES zebra_extract_records_stream(ZebraHandle zh, - struct ZebraRecStream *stream, - enum zebra_recctrl_action_t action, - int test_mode, - const char *recordType, - zint *sysno, - const char *match_criteria, - const char *fname, - RecType recType, - void *recTypeClientData) -{ - ZEBRA_RES res = ZEBRA_OK; - while (1) - { - int more = 0; - res = zebra_extract_record_stream(zh, stream, - action, - test_mode, - recordType, - sysno, - match_criteria, - fname, - recType, recTypeClientData, &more); - if (!more) - { - res = ZEBRA_OK; - break; - } - if (res != ZEBRA_OK) - break; - if (sysno) - break; - } - return res; -} - - -static WRBUF wrbuf_hex_str(const char *cstr) -{ - size_t i; - WRBUF w = wrbuf_alloc(); - for (i = 0; cstr[i]; i++) - { - if (cstr[i] < ' ' || cstr[i] > 126) - wrbuf_printf(w, "\\%02X", cstr[i] & 0xff); - else - wrbuf_putc(w, cstr[i]); - } - return w; -} - -ZEBRA_RES zebra_extract_record_stream(ZebraHandle zh, - struct ZebraRecStream *stream, - enum zebra_recctrl_action_t action, - int test_mode, - const char *recordType, - zint *sysno, - const char *match_criteria, - const char *fname, - RecType recType, - void *recTypeClientData, - int *more) - +static ZEBRA_RES zebra_extract_record_stream(ZebraHandle zh, + struct ZebraRecStream *stream, + enum zebra_recctrl_action_t action, + const char *recordType, + zint *sysno, + const char *match_criteria, + const char *fname, + RecType recType, + void *recTypeClientData, + int *more) + { zint sysno0 = 0; RecordAttr *recordAttr; @@ -917,14 +896,25 @@ ZEBRA_RES zebra_extract_record_stream(ZebraHandle zh, } *more = 1; + + if (zh->m_flag_rw == 0) + { + yaz_log(YLOG_LOG, "test %s %s " ZINT_FORMAT, recordType, + pr_fname, (zint) start_offset); + /* test mode .. Do not perform match */ + return ZEBRA_OK; + } + if (!sysno) { sysno = &sysno0; - - if (match_criteria && *match_criteria) { + + if (match_criteria && *match_criteria) matchStr = match_criteria; - } else { - if (zh->m_record_id && *zh->m_record_id) { + else + { + if (zh->m_record_id && *zh->m_record_id) + { matchStr = get_match_from_spec(zh, zh->reg->keys, pr_fname, zh->m_record_id); if (!matchStr) @@ -933,6 +923,17 @@ ZEBRA_RES zebra_extract_record_stream(ZebraHandle zh, pr_fname, (zint) start_offset); return ZEBRA_FAIL; } + if (0 && matchStr) + { + WRBUF w = wrbuf_alloc(); + size_t i; + for (i = 0; i < strlen(matchStr); i++) + { + wrbuf_printf(w, "%02X", matchStr[i] & 0xff); + } + yaz_log(YLOG_LOG, "Got match %s", wrbuf_cstr(w)); + wrbuf_destroy(w); + } } } if (matchStr) @@ -956,21 +957,13 @@ ZEBRA_RES zebra_extract_record_stream(ZebraHandle zh, } } - if (zebra_rec_keys_empty(zh->reg->keys)) - { - /* the extraction process returned no information - the record - is probably empty - unless flagShowRecords is in use */ - if (test_mode) - return ZEBRA_OK; - } - if (! *sysno) { /* new record AKA does not exist already */ if (action == action_delete) { - yaz_log(YLOG_LOG, "delete %s %s " ZINT_FORMAT, recordType, - pr_fname, (zint) start_offset); + yaz_log(YLOG_LOG, "delete %s %s " ZINT_FORMAT, recordType, + pr_fname, (zint) start_offset); yaz_log(YLOG_WARN, "cannot delete record above (seems new)"); return ZEBRA_FAIL; } @@ -1210,6 +1203,52 @@ ZEBRA_RES zebra_extract_record_stream(ZebraHandle zh, return ZEBRA_OK; } +/** \brief extracts records from stream + \param zh Zebra Handle + \param stream stream that we read from + \param action (action_insert, action_replace, action_delete, ..) + \param recordType Record filter type "grs.xml", etc. + \param sysno pointer to sysno if already known; NULL otherwise + \param match_criteria (NULL if not already given) + \param fname filename that we read from (for logging purposes only) + \param recType record type + \param recTypeClientData client data for record type + \returns ZEBRA_OK for success; ZEBRA_FAIL for failure +*/ +ZEBRA_RES zebra_extract_records_stream(ZebraHandle zh, + struct ZebraRecStream *stream, + enum zebra_recctrl_action_t action, + const char *recordType, + zint *sysno, + const char *match_criteria, + const char *fname, + RecType recType, + void *recTypeClientData) +{ + ZEBRA_RES res = ZEBRA_OK; + while (1) + { + int more = 0; + res = zebra_extract_record_stream(zh, stream, + action, + recordType, + sysno, + match_criteria, + fname, + recType, recTypeClientData, &more); + if (!more) + { + res = ZEBRA_OK; + break; + } + if (res != ZEBRA_OK) + break; + if (sysno) + break; + } + return res; +} + ZEBRA_RES zebra_extract_explain(void *handle, Record rec, data1_node *n) { ZebraHandle zh = (ZebraHandle) handle; @@ -1584,9 +1623,10 @@ static void extract_add_sort_string(RecWord *p, const char *str, int length) ch = zebraExplain_lookup_attr_str(zei, cat, p->index_type, p->index_name); if (ch < 0) ch = zebraExplain_add_attr_str(zei, cat, p->index_type, p->index_name); - key.len = 2; + key.len = 3; key.mem[0] = ch; key.mem[1] = p->record_id; + key.mem[2] = p->section_id; zebra_rec_keys_write(zh->reg->sortKeys, str, length, &key); } @@ -1867,73 +1907,68 @@ void extract_flush_sort_keys(ZebraHandle zh, zint sysno, const char *str; struct it_key key_in; -#define USE_SORT_ENT 1 -#if USE_SORT_ENT NMEM nmem = nmem_create(); struct sort_add_ent { int ord; int cmd; struct sort_add_ent *next; - struct zebra_sort_ent sort_ent; + WRBUF wrbuf; + zint sysno; + zint section_id; }; struct sort_add_ent *sort_ent_list = 0; -#endif - zebra_sort_sysno(si, sysno); -#if USE_SORT_ENT while (zebra_rec_keys_read(reckeys, &str, &slen, &key_in)) { int ord = CAST_ZINT_TO_INT(key_in.mem[0]); + zint filter_sysno = key_in.mem[1]; + zint section_id = key_in.mem[2]; struct sort_add_ent **e = &sort_ent_list; - while (*e && (*e)->ord != ord) - e = &(*e)->next; + for (; *e; e = &(*e)->next) + if ((*e)->ord == ord && section_id == (*e)->section_id) + break; if (!*e) { *e = nmem_malloc(nmem, sizeof(**e)); (*e)->next = 0; - (*e)->sort_ent.wrbuf = wrbuf_alloc(); - (*e)->sort_ent.num = 0; + (*e)->wrbuf = wrbuf_alloc(); (*e)->ord = ord; (*e)->cmd = cmd; + (*e)->sysno = filter_sysno ? filter_sysno : sysno; + (*e)->section_id = section_id; } - wrbuf_write((*e)->sort_ent.wrbuf, str, slen); - wrbuf_putc((*e)->sort_ent.wrbuf, '\0'); - (*e)->sort_ent.num++; + wrbuf_write((*e)->wrbuf, str, slen); + wrbuf_putc((*e)->wrbuf, '\0'); } if (sort_ent_list) { + zint last_sysno = 0; struct sort_add_ent *e = sort_ent_list; for (; e; e = e->next) { + if (last_sysno != e->sysno) + { + zebra_sort_sysno(si, e->sysno); + last_sysno = e->sysno; + } zebra_sort_type(si, e->ord); if (e->cmd == 1) - zebra_sort_add_ent(si, &e->sort_ent); + zebra_sort_add(si, e->section_id, e->wrbuf); else - zebra_sort_delete(si); - wrbuf_destroy(e->sort_ent.wrbuf); + zebra_sort_delete(si, e->section_id); + wrbuf_destroy(e->wrbuf); } } nmem_destroy(nmem); -#else - while (zebra_rec_keys_read(reckeys, &str, &slen, &key_in)) - { - int ord = CAST_ZINT_TO_INT(key_in.mem[0]); - - zebra_sort_type(si, ord); - if (cmd == 1) - zebra_sort_add(si, str, slen); - else - zebra_sort_delete(si); - } -#endif } } /* * Local variables: * c-basic-offset: 4 + * c-file-style: "Stroustrup" * indent-tabs-mode: nil * End: * vim: shiftwidth=4 tabstop=8 expandtab