Annotation of parser3/src/classes/hash.C, revision 1.11
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.11 ! parser 8: $Id: hash.C,v 1.10 2001/07/07 16:38:01 parser Exp $
1.1 paf 9: */
1.11 ! parser 10: static const char *RCSId="$Id: hash.C,v 1.10 2001/07/07 16:38:01 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));
! 91: }
! 92:
! 93: private:
! 94: Pool& pool;
! 95: const String& method_name;
! 96: const String& statement_string; const char *statement_cstr;
! 97: Hash& rows_hash;
! 98: Hash *row_hash;
! 99: int column_index;
! 100: Array columns;
! 101: int row_index;
! 102: };
! 103: #endif
! 104:
1.2 parser 105: static void _sql(Request& r, const String& method_name, MethodParams *params) {
106: Pool& pool=r.pool();
107:
108: if(!r.connection)
109: PTHROW(0, 0,
110: &method_name,
111: "without connect");
112:
1.10 parser 113: Value& statement=params->as_junction(0, "statement must be code");
1.2 parser 114:
115: ulong limit=0;
116: if(params->size()>1) {
1.10 parser 117: Value& limit_code=params->as_junction(1, "limit must be expression");
1.2 parser 118: limit=(uint)r.process(limit_code).as_double();
119: }
120:
121: ulong offset=0;
122: if(params->size()>2) {
1.10 parser 123: Value& offset_code=params->as_junction(2, "offset must be expression");
1.2 parser 124: offset=(ulong)r.process(offset_code).as_double();
125: }
126:
127: Temp_lang temp_lang(r, String::UL_SQL);
128: const String& statement_string=r.process(statement).as_string();
129: const char *statement_cstr=
130: statement_string.cstr(String::UL_UNSPECIFIED, r.connection);
1.11 ! parser 131: Hash& hash=static_cast<VHash *>(r.self)->hash();
! 132: hash.clear();
! 133: Hash_sql_event_handlers handlers(pool, method_name,
! 134: statement_string, statement_cstr, hash);
1.2 parser 135: bool need_rethrow=false; Exception rethrow_me;
136: PTRY {
137: r.connection->query(
138: statement_cstr, offset, limit,
1.11 ! parser 139: handlers);
1.2 parser 140: }
1.3 parser 141: PCATCH(e) { // query problem
1.2 parser 142: rethrow_me=e; need_rethrow=true;
143: }
144: PEND_CATCH
145: if(need_rethrow)
146: PTHROW(rethrow_me.type(), rethrow_me.code(),
147: &statement_string, // setting more specific source [were url]
148: rethrow_me.comment());
149: }
150:
1.9 parser 151: static void keys_collector(const Hash::Key& key, Hash::Val *value, void *info) {
152: Table& table=*static_cast<Table *>(info);
153: Pool& pool=table.pool();
154:
155: Array& row=*new(pool) Array(pool);
156: row+=&key;
157: table+=&row;
158: }
159: static void _keys(Request& r, const String& method_name, MethodParams *) {
160: Pool& pool=r.pool();
161:
162: Array& columns=*new(pool) Array(pool);
163: columns+=new(pool) String(pool, "key");
164: Table& table=*new(pool) Table(pool, &method_name, &columns);
165:
166: static_cast<VHash *>(r.self)->hash().for_each(keys_collector, &table);
167:
168: VTable& result=*new(pool) VTable(pool, &table);
169: result.set_name(method_name);
170: r.write_no_lang(result);
171: }
172:
1.1 paf 173: // constructor
174:
175: MHash::MHash(Pool& apool) : Methoded(apool) {
1.2 parser 176: set_name(*NEW String(pool(), HASH_CLASS_NAME));
177:
1.1 paf 178: // ^hash.default[]
179: // ^hash.default[hash]
180: add_native_method("default", Method::CT_DYNAMIC, _default, 0, 1);
1.2 parser 181:
182: // ^hash:sql[query][(count[;offset])]
183: add_native_method("sql", Method::CT_DYNAMIC, _sql, 1, 3);
184:
1.9 parser 185: // ^hash.keys[]
186: add_native_method("keys", Method::CT_DYNAMIC, _keys, 0, 0);
1.1 paf 187: }
188:
189: // global variable
190:
191: Methoded *hash_base_class;
192:
193: // creator
194:
195: Methoded *MHash_create(Pool& pool) {
196: return hash_base_class=new(pool) MHash(pool);
197: }
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