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