X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=index%2Fzebraapi.c;h=b3c650f4553e1c15faaac9ac56920f25a58b2f79;hb=39d323b0aabcc0f1a08f37c3fa45fb187c7570ac;hp=7ce50b98b2603738f88b857812bc7193a47957cc;hpb=2ebb686ca09ee2e128f4db3fb418d4846991b6a0;p=idzebra-moved-to-github.git diff --git a/index/zebraapi.c b/index/zebraapi.c index 7ce50b9..b3c650f 100644 --- a/index/zebraapi.c +++ b/index/zebraapi.c @@ -1,4 +1,4 @@ -/* $Id: zebraapi.c,v 1.92 2003-03-12 17:11:23 pop Exp $ +/* $Id: zebraapi.c,v 1.101 2003-05-20 13:52:41 adam Exp $ Copyright (C) 1995,1996,1997,1998,1999,2000,2001,2002,2003 Index Data Aps @@ -196,9 +196,9 @@ struct zebra_register *zebra_register_open (ZebraService zs, const char *name, assert (res); - yaz_log (LOG_DEBUG, "zebra_register_open rw = %d useshadow=%d p=%p", + yaz_log (LOG_LOG, "zebra_register_open rw = %d useshadow=%d p=%p", rw, useshadow, reg); - + reg->dh = data1_createx (DATA1_FLAG_XML); if (!reg->dh) return 0; @@ -241,6 +241,7 @@ struct zebra_register *zebra_register_open (ZebraService zs, const char *name, zebraRankInstall (reg, rank1_class); zebraRankInstall (reg, rankzv_class); + zebraRankInstall (reg, rankliv_class); recordCompression = res_get_def (res, "recordCompression", "none"); if (!strcmp (recordCompression, "none")) @@ -376,7 +377,7 @@ void zebra_admin_start (ZebraHandle zh) static void zebra_register_close (ZebraService zs, struct zebra_register *reg) { ASSERTZS; - yaz_log(LOG_DEBUG, "zebra_register_close p=%p", reg); + yaz_log(LOG_LOG, "zebra_register_close p=%p", reg); reg->stop_flag = 0; zebra_chdir (zs); if (reg->records) @@ -743,7 +744,7 @@ int zebra_select_databases (ZebraHandle zh, int num_bases, return 0; } -void zebra_search_rpn (ZebraHandle zh, ODR decode, ODR stream, +void zebra_search_RPN (ZebraHandle zh, Z_RPNQuery *query, const char *setname, int *hits) { ASSERTZH; @@ -753,7 +754,10 @@ void zebra_search_rpn (ZebraHandle zh, ODR decode, ODR stream, if (zebra_begin_read (zh)) return; - resultSetAddRPN (zh, decode, stream, query, + + zebra_livcode_transform(zh, query); + + resultSetAddRPN (zh, query, zh->num_basenames, zh->basenames, setname); zebra_end_read (zh); @@ -1028,7 +1032,7 @@ int zebra_admin_exchange_record (ZebraHandle zh, return 0; } -void zebra_admin_create (ZebraHandle zh, const char *database) +void zebra_create_database (ZebraHandle zh, const char *database) { ZebraService zs; ASSERTZH; @@ -1124,6 +1128,12 @@ void zebra_end_read (ZebraHandle zh) int zebra_begin_trans (ZebraHandle zh, int rw) { + if (!zh->res) + { + zh->errCode = 2; + zh->errString = "zebra_begin_trans: no database selected"; + return -1; + } ASSERTZHRES; assert (zh->res); if (rw) @@ -1139,9 +1149,12 @@ int zebra_begin_trans (ZebraHandle zh, int rw) if (zh->trans_no != 1) { zh->errCode = 2; - zh->errString = "write trans not allowed within read trans"; + zh->errString = "zebra_begin_trans: write trans not allowed within read trans"; return -1; } + if (zh->reg) + zebra_register_close (zh->service, zh->reg); + zh->trans_w_no = zh->trans_no; zh->errCode=0; @@ -1210,8 +1223,8 @@ int zebra_begin_trans (ZebraHandle zh, int rw) zh->reg = zebra_register_open (zh->service, zh->reg_name, 1, rval ? 1 : 0, zh->res, zh->path_reg); - - zh->reg->seqno = seqno; + if (zh->reg) + zh->reg->seqno = seqno; } else { @@ -1284,12 +1297,13 @@ int zebra_begin_trans (ZebraHandle zh, int rw) return 0; } -void zebra_end_trans (ZebraHandle zh) { - ZebraTransactionStatus dummy; - zebra_end_transaction(zh, &dummy); +int zebra_end_trans (ZebraHandle zh) +{ + ZebraTransactionStatus dummy; + return zebra_end_transaction(zh, &dummy); } -void zebra_end_transaction (ZebraHandle zh, ZebraTransactionStatus *status) +int zebra_end_transaction (ZebraHandle zh, ZebraTransactionStatus *status) { char val; int seqno; @@ -1304,11 +1318,17 @@ void zebra_end_transaction (ZebraHandle zh, ZebraTransactionStatus *status) status->utime = 0; status->stime = 0; + if (!zh->res || !zh->reg) + { + zh->errCode = 2; + zh->errString = "zebra_end_trans: no open transaction"; + return -1; + } if (zh->trans_no != zh->trans_w_no) { zh->trans_no--; if (zh->trans_no != 0) - return; + return 0; /* release read lock */ @@ -1327,6 +1347,8 @@ void zebra_end_transaction (ZebraHandle zh, ZebraTransactionStatus *status) zebra_flush_reg (zh); + resultSetInvalidate (zh); + zebra_register_close (zh->service, zh->reg); zh->reg = 0; @@ -1364,6 +1386,7 @@ void zebra_end_transaction (ZebraHandle zh, ZebraTransactionStatus *status) status->utime = (long) (zh->tms2.tms_utime - zh->tms1.tms_utime); status->stime = (long) (zh->tms2.tms_stime - zh->tms1.tms_stime); #endif + return 0; } void zebra_repository_update (ZebraHandle zh) @@ -1389,7 +1412,7 @@ void zebra_repository_show (ZebraHandle zh) repositoryShow (zh); } -int zebra_commit (ZebraHandle zh) +static int zebra_commit_ex (ZebraHandle zh, int clean_only) { int seqno; char val; @@ -1422,13 +1445,18 @@ int zebra_commit (ZebraHandle zh) bf_cache (bfs, rval); if (bf_commitExists (bfs)) { - zebra_set_state (zh, 'c', seqno); - - logf (LOG_LOG, "commit start"); - bf_commitExec (bfs); + if (clean_only) + zebra_set_state (zh, 'd', seqno); + else + { + zebra_set_state (zh, 'c', seqno); + + logf (LOG_LOG, "commit start"); + bf_commitExec (bfs); #ifndef WIN32 - sync (); + sync (); #endif + } logf (LOG_LOG, "commit clean"); bf_commitClean (bfs, rval); seqno++; @@ -1445,6 +1473,16 @@ int zebra_commit (ZebraHandle zh) return 0; } +int zebra_clean (ZebraHandle zh) +{ + return zebra_commit_ex(zh, 1); +} + +int zebra_commit (ZebraHandle zh) +{ + return zebra_commit_ex(zh, 0); +} + int zebra_init (ZebraHandle zh) { const char *rval; @@ -1489,12 +1527,10 @@ int zebra_compact (ZebraHandle zh) int zebra_record_insert (ZebraHandle zh, const char *buf, int len) { int sysno = 0; - int olderr; ASSERTZH; zh->errCode=0; - zebra_begin_trans (zh, 1); - if (zh->errCode) - return 0; /* bad sysno */ + if (zebra_begin_trans (zh, 1)) + return 0; extract_rec_in_mem (zh, "grs.sgml", buf, len, "Default", /* database */ @@ -1504,10 +1540,8 @@ int zebra_record_insert (ZebraHandle zh, const char *buf, int len) 1 /* store_keys */, 1 /* store_data */, 0 /* match criteria */); - olderr=zh->errCode; - zebra_end_trans (zh); - if (olderr) - zh->errCode=olderr; + if (zebra_end_trans (zh)) + return 0; return sysno; } @@ -1571,7 +1605,7 @@ void zebra_set_resource(ZebraHandle zh, const char *name, const char *value) } const char *zebra_get_resource(ZebraHandle zh, - const char *name, const char *defaultvalue) + const char *name, const char *defaultvalue) { ASSERTZH; zh->errCode=0; @@ -1776,6 +1810,32 @@ void api_records_retrieve (ZebraHandle zh, ODR stream, If not, and a record is provided, then sysno is got from there */ +int zebra_insert_record (ZebraHandle zh, + struct recordGroup *rGroup, + const char *recordType, + int sysno, const char *match, const char *fname, + const char *buf, int buf_size, + int force_update) /* This one is ignored */ + +{ + int res; + + if (buf_size < 1) buf_size = strlen(buf); + + zebra_begin_trans(zh, 1); + res=bufferExtractRecord (zh, buf, buf_size, rGroup, + 0, /* delete_flag */ + 0, /* test_mode */ + recordType, + &sysno, + match, fname, + force_update, + 0); /* allow_update */ + zebra_end_trans(zh); + if (res < 0) return (res); + return sysno; +} + int zebra_update_record (ZebraHandle zh, struct recordGroup *rGroup, const char *recordType, @@ -1790,16 +1850,19 @@ int zebra_update_record (ZebraHandle zh, zebra_begin_trans(zh, 1); res=bufferExtractRecord (zh, buf, buf_size, rGroup, - 0, // delete_flag - 0, // test_mode, + 0, /* delete_flag */ + 0, /* test_mode */ recordType, &sysno, match, fname, - force_update); + force_update, + 1); /* allow_update */ zebra_end_trans(zh); return sysno; } + + int zebra_delete_record (ZebraHandle zh, struct recordGroup *rGroup, const char *recordType, @@ -1813,12 +1876,13 @@ int zebra_delete_record (ZebraHandle zh, zebra_begin_trans(zh, 1); res=bufferExtractRecord (zh, buf, buf_size, rGroup, - 1, // delete_flag - 0, // test_mode, + 1, /* delete_flag */ + 0, /* test_mode */ recordType, &sysno, match,fname, - force_update); + force_update, + 1); /* allow_update */ zebra_end_trans(zh); return sysno; } @@ -1830,43 +1894,23 @@ int zebra_delete_record (ZebraHandle zh, is not mandatory. (it's repeatable now, also in zebraapi.c) */ -void zebra_search_RPN (ZebraHandle zh, ODR decode, ODR stream, - Z_RPNQuery *query, const char *setname, int *hits) -{ - zh->hits = 0; - *hits = 0; - - if (zebra_begin_read (zh)) - return; - resultSetAddRPN (zh, decode, stream, query, - zh->num_basenames, zh->basenames, setname); - - zebra_end_read (zh); - - *hits = zh->hits; -} - -int zebra_search_PQF (ZebraHandle zh, - ODR odr_input, ODR odr_output, - const char *pqf_query, +int zebra_search_PQF (ZebraHandle zh, const char *pqf_query, const char *setname) - { - int hits; + int hits = 0; Z_RPNQuery *query; - query = p_query_rpn (odr_input, PROTO_Z3950, pqf_query); + ODR odr = odr_createmem(ODR_ENCODE); - if (!query) { - logf (LOG_WARN, "bad query %s\n", pqf_query); - odr_reset (odr_input); - return(0); - } - zebra_search_RPN (zh, odr_input, odr_output, query, setname, &hits); + query = p_query_rpn (odr, PROTO_Z3950, pqf_query); - odr_reset (odr_input); - odr_reset (odr_output); + if (!query) + yaz_log (LOG_WARN, "bad query %s\n", pqf_query); + else + zebra_search_RPN (zh, query, setname, &hits); - return(hits); + odr_destroy(odr); + + return hits; } /* ---------------------------------------------------------------------------