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