Annotation of parser3/src/classes/hash.C, revision 1.16
1.1 paf 1: /** @file
2: Parser: @b hash parser class.
3:
4: Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com)
5:
6: Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf)
7:
1.16 ! parser 8: $Id: hash.C,v 1.15 2001/09/06 08:25:08 parser Exp $
1.1 paf 9: */
1.16 ! parser 10: static const char *RCSId="$Id: hash.C,v 1.15 2001/09/06 08:25:08 parser Exp $";
1.1 paf 11:
12: #include "classes.h"
13: #include "pa_request.h"
14: #include "pa_vhash.h"
1.6 parser 15: #include "pa_vvoid.h"
1.2 parser 16: #include "pa_sql_connection.h"
1.9 parser 17: #include "pa_vtable.h"
1.16 ! parser 18: #include "pa_vint.h"
1.2 parser 19:
20: // defines
21:
22: #define HASH_CLASS_NAME "hash"
1.1 paf 23:
24: // class
25:
26: class MHash : public Methoded {
1.2 parser 27: public: // VStateless_class
28: Value *create_new_value(Pool& pool) { return new(pool) VHash(pool); }
29:
1.1 paf 30: public:
31: MHash(Pool& pool);
32: public: // Methoded
1.2 parser 33: bool used_directly() { return true; }
1.1 paf 34: };
35:
36: // methods
37:
1.11 parser 38: #ifndef DOXYGEN
39: class Hash_sql_event_handlers : public SQL_Driver_query_event_handlers {
40: public:
41: Hash_sql_event_handlers(Pool& apool, const String& amethod_name,
42: const String& astatement_string, const char *astatement_cstr,
43: Hash& arows_hash) :
44: pool(apool),
45: method_name(amethod_name),
46: statement_string(astatement_string),
47: statement_cstr(astatement_cstr),
48: rows_hash(arows_hash),
49: columns(pool),
50: row_index(0) {
51: }
52: void add_column(void *ptr, size_t size) {
53: String *column=new(pool) String(pool);
54: column->APPEND_TAINTED(
55: (const char *)ptr, size,
56: statement_cstr, 0);
57: columns+=column;
58: }
59: void before_rows() {
60: if(columns.size()<=1)
61: PTHROW(0, 0,
62: &method_name,
63: "column count must be more than 1 to create a hash");
64: }
65: void add_row() {
66: column_index=0;
67: }
68: void add_row_cell(void *ptr, size_t size) {
69: String *cell=new(pool) String(pool);
70: if(size)
71: cell->APPEND_TAINTED(
72: (const char *)ptr, size,
73: statement_cstr, row_index++);
74: if(column_index==0) {
75: VHash *row_vhash=new(pool) VHash(pool);
76: row_hash=row_vhash->get_hash();
77: rows_hash.put(*cell, row_vhash);
78: } else
79: row_hash->put(*columns.get_string(column_index), new(pool) VString(*cell));
1.12 parser 80: column_index++;
1.11 parser 81: }
82:
83: private:
84: Pool& pool;
85: const String& method_name;
86: const String& statement_string; const char *statement_cstr;
87: Hash& rows_hash;
88: Hash *row_hash;
89: int column_index;
90: Array columns;
91: int row_index;
92: };
93: #endif
94:
1.2 parser 95: static void _sql(Request& r, const String& method_name, MethodParams *params) {
96: Pool& pool=r.pool();
97:
98: if(!r.connection)
99: PTHROW(0, 0,
100: &method_name,
101: "without connect");
102:
1.10 parser 103: Value& statement=params->as_junction(0, "statement must be code");
1.2 parser 104:
105: ulong limit=0;
106: if(params->size()>1) {
1.10 parser 107: Value& limit_code=params->as_junction(1, "limit must be expression");
1.2 parser 108: limit=(uint)r.process(limit_code).as_double();
109: }
110:
111: ulong offset=0;
112: if(params->size()>2) {
1.10 parser 113: Value& offset_code=params->as_junction(2, "offset must be expression");
1.2 parser 114: offset=(ulong)r.process(offset_code).as_double();
115: }
116:
117: Temp_lang temp_lang(r, String::UL_SQL);
118: const String& statement_string=r.process(statement).as_string();
119: const char *statement_cstr=
120: statement_string.cstr(String::UL_UNSPECIFIED, r.connection);
1.11 parser 121: Hash& hash=static_cast<VHash *>(r.self)->hash();
122: hash.clear();
123: Hash_sql_event_handlers handlers(pool, method_name,
124: statement_string, statement_cstr, hash);
1.2 parser 125: bool need_rethrow=false; Exception rethrow_me;
126: PTRY {
127: r.connection->query(
128: statement_cstr, offset, limit,
1.11 parser 129: handlers);
1.2 parser 130: }
1.3 parser 131: PCATCH(e) { // query problem
1.2 parser 132: rethrow_me=e; need_rethrow=true;
133: }
134: PEND_CATCH
135: if(need_rethrow)
136: PTHROW(rethrow_me.type(), rethrow_me.code(),
137: &statement_string, // setting more specific source [were url]
138: rethrow_me.comment());
139: }
140:
1.9 parser 141: static void keys_collector(const Hash::Key& key, Hash::Val *value, void *info) {
142: Table& table=*static_cast<Table *>(info);
143: Pool& pool=table.pool();
144:
145: Array& row=*new(pool) Array(pool);
146: row+=&key;
147: table+=&row;
148: }
149: static void _keys(Request& r, const String& method_name, MethodParams *) {
150: Pool& pool=r.pool();
151:
152: Array& columns=*new(pool) Array(pool);
153: columns+=new(pool) String(pool, "key");
154: Table& table=*new(pool) Table(pool, &method_name, &columns);
155:
156: static_cast<VHash *>(r.self)->hash().for_each(keys_collector, &table);
157:
158: VTable& result=*new(pool) VTable(pool, &table);
159: result.set_name(method_name);
160: r.write_no_lang(result);
161: }
162:
1.16 ! parser 163: static void _count(Request& r, const String& method_name, MethodParams *) {
! 164: Pool& pool=r.pool();
! 165:
! 166: Value& value=*new(pool) VInt(pool, static_cast<VHash *>(r.self)->hash().size());
! 167: value.set_name(method_name);
! 168: r.write_no_lang(value);
! 169: }
! 170:
1.1 paf 171: // constructor
172:
173: MHash::MHash(Pool& apool) : Methoded(apool) {
1.2 parser 174: set_name(*NEW String(pool(), HASH_CLASS_NAME));
175:
176: // ^hash:sql[query][(count[;offset])]
177: add_native_method("sql", Method::CT_DYNAMIC, _sql, 1, 3);
178:
1.14 parser 179: // ^hash._keys[]
1.13 parser 180: add_native_method("_keys", Method::CT_DYNAMIC, _keys, 0, 0);
1.16 ! parser 181:
! 182: // ^hash._count[]
! 183: add_native_method("_count", Method::CT_DYNAMIC, _count, 0, 0);
1.1 paf 184: }
185:
186: // global variable
187:
188: Methoded *hash_base_class;
189:
190: // creator
191:
192: Methoded *MHash_create(Pool& pool) {
193: return hash_base_class=new(pool) MHash(pool);
194: }
E-mail:
![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to hash.C CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [parser3project] / parser3 / src / classes