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