Annotation of parser3/src/types/pa_vhashfile.C, revision 1.23
1.1 parser 1: /** @file
2: Parser: @b table class.
3:
1.20 paf 4: Copyright(c) 2001, 2002 ArtLebedev Group (http://www.artlebedev.com)
1.19 paf 5: Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)
1.1 parser 6: */
7:
1.23 ! paf 8: static const char* IDENT="$Date: 2003/11/06 08:22:50 $";
1.1 parser 9:
10: #include "pa_vtable.h"
11: #include "pa_vstring.h"
12: #include "pa_vhashfile.h"
13: #include "pa_threads.h"
1.8 parser 14: #include "pa_globals.h"
1.1 parser 15:
16: // methods
17:
1.22 paf 18: void check(const char *step, apr_status_t status) {
19: if(status==APR_SUCCESS)
20: return;
21:
22: throw Exception("todo.todo",
23: 0,
24: "%s error: %d", step, status);
25: }
26:
27: void VHashfile::open(const String& afile_name) {
28: check("apr_sdbm_open", apr_sdbm_open(&db, afile_name.cstr(String::L_FILE_SPEC),
29: APR_WRITE|APR_CREATE,
30: 0664, 0));
31: }
32:
33: VHashfile::~VHashfile() {
34: if(db)
35: check("apr_sdbm_close", apr_sdbm_close(db));
36: }
37:
38: void VHashfile::clear() {
39: }
40:
1.8 parser 41: void VHashfile::put_field(const String& aname, Value *avalue) {
42: time_t time_to_die=0;
43: const String *value_string;
44:
1.23 ! paf 45: if(HashStringValue *hash=avalue->get_hash()) {
! 46: if(Value *value_value=hash->get(value_name)) {
1.9 parser 47: if(value_value->get_junction())
1.23 ! paf 48: throw Exception(0,
! 49: 0,
! 50: VALUE_NAME" must not be code");
1.8 parser 51:
52: value_string=&value_value->as_string();
53:
1.23 ! paf 54: if(Value *expires_value=hash->get(expires_name))
1.8 parser 55: time_to_die=time(0)+(time_t)expires_value->as_double();
56: } else
1.23 ! paf 57: throw Exception(0,
1.8 parser 58: &aname,
1.23 ! paf 59: "put hash value must contain ."VALUE_NAME);
1.8 parser 60: } else
61: value_string=&avalue->as_string();
1.5 parser 62:
1.23 ! paf 63: // get_table_ptr(&aname)->put(aname, *value_string, time_to_die);
! 64:
! 65: apr_sdbm_datum_t key;
! 66: key.dptr=const_cast<char*>(aname.cstr());
! 67: key.dsize=strlen(key.dptr);
! 68:
! 69: apr_sdbm_datum_t value;
! 70: value.dptr=const_cast<char*>(value_string->cstr());
! 71: value.dsize=strlen(key.dptr);
! 72:
! 73: // * APR_SDBM_INSERT return an error if the record exists
! 74: check("apr_sdbm_store", apr_sdbm_store(db, key, value, APR_SDBM_REPLACE));
1.1 parser 75: }
76:
1.11 paf 77: Value *VHashfile::get_field(const String& aname) {
1.23 ! paf 78: apr_sdbm_datum_t key;
! 79: key.dptr=const_cast<char*>(aname.cstr());
! 80: key.dsize=strlen(key.dptr);
! 81:
! 82: apr_sdbm_datum_t value;
! 83:
! 84: check("apr_sdbm_fetch", apr_sdbm_fetch(db, &value, key));
! 85:
! 86: if(value.dptr)
! 87: return new VString(String(pa_strdup(value.dptr, value.dsize)));
1.3 parser 88: else
89: return 0;
1.1 parser 90: }
91:
1.22 paf 92: HashStringValue *VHashfile::get_hash(const String *source) {
93: #if LATER
1.17 paf 94: DB_Cursor cursor(*get_table_ptr(source), source);
1.11 paf 95:
1.22 paf 96: HashStringValue& result=*NEW HashStringValue(pool());
1.4 parser 97:
98: while(true) {
1.5 parser 99: String *key;
100: String *data;
1.11 paf 101: if(!cursor.get(pool(), key, data, DB_NEXT))
1.4 parser 102: break;
103:
1.13 paf 104: if(!key)
105: continue; // expired
106:
107: result.put(*key, NEW VString(*data));
1.4 parser 108: }
109:
110: return &result;
1.22 paf 111: #endif
112: return 0;
1.1 parser 113: }
E-mail: