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