|
|
| version 1.126, 2001/10/11 10:21:44 | version 1.153, 2002/05/17 12:19:12 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: @b table parser class. | Parser: @b table parser class. |
| Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001, 2002 ArtLebedev Group (http://www.artlebedev.com) |
| Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf) | Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) |
| $Id$ | $Id$ |
| */ | */ |
| #include "classes.h" | #include "classes.h" |
| #include "pa_config_includes.h" | |
| #include "pa_common.h" | #include "pa_common.h" |
| #include "pa_request.h" | #include "pa_request.h" |
| #include "pa_vtable.h" | #include "pa_vtable.h" |
| Line 16 | Line 15 |
| #include "pa_sql_connection.h" | #include "pa_sql_connection.h" |
| #include "pa_vbool.h" | #include "pa_vbool.h" |
| // defines | |
| #define TABLE_CLASS_NAME "table" | |
| // class | // class |
| class MTable : public Methoded { | class MTable : public Methoded { |
| Line 35 public: // Methoded | Line 30 public: // Methoded |
| // methods | // methods |
| static void _set(Request& r, const String& method_name, MethodParams *params) { | static void _create(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| // data is last parameter | // clone? |
| Value& vdata=params->as_junction(params->size()-1, "body must be code"); | if(params->size()==1) |
| if(const Table *source=params->get(0).get_table()) { | |
| static_cast<VTable *>(r.self)->set_table(*new(pool) Table(*source)); | |
| return; | |
| } | |
| // data is last parameter | |
| Temp_lang temp_lang(r, String::UL_PASS_APPENDED); | Temp_lang temp_lang(r, String::UL_PASS_APPENDED); |
| const String& data=r.process(vdata).as_string(); | const String& data= |
| r.process_to_string(params->as_junction(params->size()-1, "body must be code")); | |
| size_t pos_after=0; | size_t pos_after=0; |
| // parse columns | // parse columns |
| Line 52 static void _set(Request& r, const Strin | Line 53 static void _set(Request& r, const Strin |
| columns=new(pool) Array(pool); | columns=new(pool) Array(pool); |
| Array head(pool); | Array head(pool); |
| data.split(head, &pos_after, "\n", 1, String::UL_CLEAN, 1); | data.split(head, &pos_after, "\n", 1, String::UL_AS_IS, 1); |
| if(head.size()) | if(head.size()) |
| head.get_string(0)->split(*columns, 0, "\t", 1, String::UL_CLEAN); | head.get_string(0)->split(*columns, 0, "\t", 1, String::UL_AS_IS); |
| } | } |
| Table& table=*new(pool) Table(pool, &method_name, columns); | Table& table=*new(pool) Table(pool, &method_name, columns); |
| // parse cells | // parse cells |
| Array rows(pool); | Array rows(pool); |
| data.split(rows, &pos_after, "\n", 1, String::UL_CLEAN); | data.split(rows, &pos_after, "\n", 1, String::UL_AS_IS); |
| Array_iter i(rows); | Array_iter i(rows); |
| while(i.has_next()) { | while(i.has_next()) { |
| Array& row=*new(pool) Array(pool); | Array& row=*new(pool) Array(pool); |
| Line 69 static void _set(Request& r, const Strin | Line 70 static void _set(Request& r, const Strin |
| if(!string.size()) | if(!string.size()) |
| continue; | continue; |
| string.split(row, 0, "\t", 1, String::UL_CLEAN); | string.split(row, 0, "\t", 1, String::UL_AS_IS); |
| table+=&row; | table+=&row; |
| } | } |
| Line 94 static void _load(Request& r, const Stri | Line 95 static void _load(Request& r, const Stri |
| uint line=origin.line; | uint line=origin.line; |
| #endif | #endif |
| if(params->size()==2) { | if(params->size()==2) { |
| columns=0; | columns=0; // nameless |
| } else { | } else { |
| columns=new(pool) Array(pool); | columns=new(pool) Array(pool); |
| if(char *row_chars=getrow(&data)) | while(char *row_chars=getrow(&data)) { |
| // remove empty&comment lines | |
| if(!*row_chars || *row_chars == '#') | |
| continue; | |
| do { | do { |
| String *name=new(pool) String(pool); | String *name=new(pool) String(pool); |
| name->APPEND_TAINTED(lsplit(&row_chars, '\t'), 0, file, line++); | name->APPEND_TAINTED(lsplit(&row_chars, '\t'), 0, file, line++); |
| *columns+=name; | *columns+=name; |
| } while(row_chars); | } while(row_chars); |
| break; | |
| } | |
| } | } |
| // parse cells | // parse cells |
| Line 129 static void _load(Request& r, const Stri | Line 136 static void _load(Request& r, const Stri |
| static_cast<VTable *>(r.self)->set_table(table); | static_cast<VTable *>(r.self)->set_table(table); |
| } | } |
| /// @todo "x\nx" "xxx""xx" | |
| static void _save(Request& r, const String& method_name, MethodParams *params) { | static void _save(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Value& vfile_name=params->as_no_junction(params->size()-1, | Value& vfile_name=params->as_no_junction(params->size()-1, |
| Line 136 static void _save(Request& r, const Stri | Line 144 static void _save(Request& r, const Stri |
| Table& table=static_cast<VTable *>(r.self)->table(); | Table& table=static_cast<VTable *>(r.self)->table(); |
| bool do_append=false; | |
| String sdata(pool); | String sdata(pool); |
| if(params->size()==1) { // not nameless=named output | if(params->size()==1) { // named output |
| // write out names line | // write out names line |
| if(table.columns()) { // named table | if(table.columns()) { // named table |
| Array_iter i(*table.columns()); | Array_iter i(*table.columns()); |
| Line 158 static void _save(Request& r, const Stri | Line 167 static void _save(Request& r, const Stri |
| sdata.APPEND_CONST("empty nameless table"); | sdata.APPEND_CONST("empty nameless table"); |
| } | } |
| sdata.APPEND_CONST("\n"); | sdata.APPEND_CONST("\n"); |
| } else { // mode specified | |
| const String& mode=params->as_string(0, "mode must be string"); | |
| if(mode=="append") | |
| do_append=true; | |
| else if(mode=="nameless") | |
| /*ok, already skipped names output*/; | |
| else | |
| throw Exception("parser.runtime", | |
| &mode, | |
| "unknown mode, must be 'append'"); | |
| } | } |
| // data lines | // data lines |
| Array_iter i(table); | Array_iter i(table); |
| while(i.has_next()) { | while(i.has_next()) { |
| Array_iter c(*static_cast<Array *>(i.next())); | Array_iter c(*static_cast<Array *>(i.next())); |
| while(c.has_next()) { | while(c.has_next()) { |
| sdata.append(*c.next_string(), //*static_cast<String *>(row->quick_get(column)), | if(const String *s=c.next_string()) |
| String::UL_TABLE); | sdata.append(*s, |
| String::UL_TABLE); | |
| if(c.has_next()) | if(c.has_next()) |
| sdata.APPEND_CONST("\t"); | sdata.APPEND_CONST("\t"); |
| } | } |
| Line 173 static void _save(Request& r, const Stri | Line 194 static void _save(Request& r, const Stri |
| } | } |
| // write | // write |
| file_write(pool, r.absolute(vfile_name.as_string()), | file_write(r.absolute(vfile_name.as_string()), |
| sdata.cstr(), sdata.size(), true); | sdata.cstr(), sdata.size(), true, do_append); |
| } | } |
| static void _count(Request& r, const String& method_name, MethodParams *) { | static void _count(Request& r, const String& method_name, MethodParams *) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Value& value=*new(pool) VInt(pool, static_cast<VTable *>(r.self)->table().size()); | int result=static_cast<VTable *>(r.self)->table().size(); |
| value.set_name(method_name); | r.write_no_lang(*new(pool) VInt(pool, result)); |
| r.write_no_lang(value); | |
| } | } |
| static void _line(Request& r, const String& method_name, MethodParams *) { | static void _line(Request& r, const String& method_name, MethodParams *) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Value& value=*new(pool) VInt(pool, 1+static_cast<VTable *>(r.self)->table().current()); | int result=1+static_cast<VTable *>(r.self)->table().current(); |
| value.set_name(method_name); | r.write_no_lang(*new(pool) VInt(pool, result)); |
| r.write_no_lang(value); | |
| } | } |
| static void _offset(Request& r, const String& method_name, MethodParams *params) { | static void _offset(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Table& table=static_cast<VTable *>(r.self)->table(); | Table& table=static_cast<VTable *>(r.self)->table(); |
| if(params->size()) { | if(params->size()) { |
| Value& offset_expr=params->as_junction(0, "offset must be expression"); | bool absolute=false; |
| table.shift(r.process(offset_expr).as_int()); | if(params->size()>1) { |
| } else { | const String& whence=params->as_string(0, "whence must be string"); |
| Value& value=*new(pool) VInt(pool, table.current()); | if(whence=="cur") |
| value.set_name(method_name); | absolute=false; |
| r.write_no_lang(value); | else if(whence=="set") |
| } | absolute=true; |
| else | |
| throw Exception("parser.runtime", | |
| &whence, | |
| "is invalid whence, valid are 'cur' or 'set'"); | |
| } | |
| Value& offset_expr=params->as_junction(params->size()-1, "offset must be expression"); | |
| table.offset(absolute, r.process_to_value(offset_expr).as_int()); | |
| } else | |
| r.write_no_lang(*new(pool) VInt(pool, table.current())); | |
| } | } |
| static void _menu(Request& r, const String& method_name, MethodParams *params) { | static void _menu(Request& r, const String& method_name, MethodParams *params) { |
| Line 209 static void _menu(Request& r, const Stri | Line 238 static void _menu(Request& r, const Stri |
| Value *delim_maybe_code=params->size()>1?¶ms->get(1):0; | Value *delim_maybe_code=params->size()>1?¶ms->get(1):0; |
| VTable& vtable=*static_cast<VTable *>(r.self); | Table& table=static_cast<VTable *>(r.self)->table(); |
| Table& table=vtable.table(); | |
| bool need_delim=false; | bool need_delim=false; |
| int saved_current=table.current(); | int saved_current=table.current(); |
| int size=table.size(); | int size=table.size(); |
| for(int row=0; row<size; row++) { | for(int row=0; row<size; row++) { |
| table.set_current(row); | table.set_current(row); |
| Value& processed_body=r.process(body_code); | StringOrValue processed_body=r.process(body_code); |
| if(delim_maybe_code) { // delimiter set? | if(delim_maybe_code) { // delimiter set? |
| const String *string=processed_body.get_string(); | const String *string=processed_body.get_string(); |
| if(need_delim && string && string->size()) // need delim & iteration produced string? | if(need_delim && string && string->size()) // need delim & iteration produced string? |
| Line 244 static void table_row_to_hash(Array::Ite | Line 272 static void table_row_to_hash(Array::Ite |
| if(ri.key_field<row.size()) { | if(ri.key_field<row.size()) { |
| VHash& result=*new(pool) VHash(pool); | VHash& result=*new(pool) VHash(pool); |
| Hash& hash=*result.get_hash(); | Hash& hash=*result.get_hash(0); |
| for(int i=0; i<ri.value_fields->size(); i++) { | for(int i=0; i<ri.value_fields->size(); i++) { |
| int value_field=ri.value_fields->get_int(i); | int value_field=ri.value_fields->get_int(i); |
| if(value_field<row.size()) | if(value_field<row.size()) |
| Line 260 static void _hash(Request& r, const Stri | Line 288 static void _hash(Request& r, const Stri |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Table& self_table=static_cast<VTable *>(r.self)->table(); | Table& self_table=static_cast<VTable *>(r.self)->table(); |
| Value& result=*new(pool) VHash(pool); | Value& result=*new(pool) VHash(pool); |
| if(const Array *columns=self_table.columns()) | if(const Array *columns=self_table.columns()) |
| if(columns->size()>1) { | if(columns->size()>0) { |
| const String& key_field_name=params->as_no_junction(0, | const String& key_field_name=params->as_no_junction(0, |
| "key field name must not be code").as_string(); | "key field name must not be code").as_string(); |
| int key_field=self_table.column_name2index(key_field_name, true); | int key_field=self_table.column_name2index(key_field_name, true); |
| Line 278 static void _hash(Request& r, const Stri | Line 306 static void _hash(Request& r, const Stri |
| value_fields+=self_table.column_name2index(value_field_name, true); | value_fields+=self_table.column_name2index(value_field_name, true); |
| } | } |
| } else | } else |
| PTHROW(0, 0, | throw Exception("parser.runtime", |
| &method_name, | &method_name, |
| "value field(s) must be string or self_table" | "value field(s) must be string or self_table" |
| ); | ); |
| Line 288 static void _hash(Request& r, const Stri | Line 316 static void _hash(Request& r, const Stri |
| } | } |
| // integers: key_field & value_fields | // integers: key_field & value_fields |
| Row_info row_info={&self_table, key_field, &value_fields, result.get_hash()}; | Row_info row_info={&self_table, key_field, &value_fields, result.get_hash(0)}; |
| self_table.for_each(table_row_to_hash, &row_info); | self_table.for_each(table_row_to_hash, &row_info); |
| } | } |
| result.set_name(method_name); | |
| r.write_no_lang(result); | r.write_no_lang(result); |
| } | } |
| Line 342 static void _sort(Request& r, const Stri | Line 369 static void _sort(Request& r, const Stri |
| old_table.set_current(i); | old_table.set_current(i); |
| // calculate key value | // calculate key value |
| seq[i].row=(MethodParams *)old_table.get(i); | seq[i].row=(MethodParams *)old_table.get(i); |
| Value& value=*r.process(key_maker).as_expr_result(true/*return string as-is*/); | Value& value=*r.process_to_value(key_maker).as_expr_result(true/*return string as-is*/); |
| if(i==0) // determining key values type by first one | if(i==0) // determining key values type by first one |
| key_values_are_strings=value.is_string(); | key_values_are_strings=value.is_string(); |
| Line 365 static void _sort(Request& r, const Stri | Line 392 static void _sort(Request& r, const Stri |
| static_cast<VTable *>(r.self)->set_table(new_table); | static_cast<VTable *>(r.self)->set_table(new_table); |
| } | } |
| static void _locate(Request& r, const String& method_name, MethodParams *params) { | static bool _locate_expression(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | if(params->size()>1) |
| throw Exception("parser.runtime", | |
| &method_name, | |
| "locate by expression has only one parameter - expression"); | |
| VTable& vtable=*static_cast<VTable *>(r.self); | Value& expression_code=params->as_junction(0, "must be expression"); |
| Table& table=vtable.table(); | |
| Value& result=*new(pool) VBool(pool, table.locate( | Table& table=static_cast<VTable *>(r.self)->table(); |
| int saved_current=table.current(); | |
| int size=table.size(); | |
| for(int row=0; row<size; row++) { | |
| table.set_current(row); | |
| if(r.process_to_value(expression_code).as_bool()) | |
| return true; | |
| } | |
| table.set_current(saved_current); | |
| return false; | |
| } | |
| static bool _locate_name_value(Request& r, const String& method_name, MethodParams *params) { | |
| if(params->size()>2) | |
| throw Exception("parser.runtime", | |
| &method_name, | |
| "locate by name and value has only two parameters - name and value"); | |
| Table& table=static_cast<VTable *>(r.self)->table(); | |
| return table.locate( | |
| params->as_string(0, "column name must be string"), | params->as_string(0, "column name must be string"), |
| params->as_string(1, "value must be string") | params->as_string(1, "value must be string") |
| )); | ); |
| result.set_name(method_name); | } |
| r.write_no_lang(result); | static void _locate(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | |
| bool result=params->get(0).get_junction()? | |
| _locate_expression(r, method_name, params) : | |
| _locate_name_value(r, method_name, params); | |
| r.write_no_lang(*new(pool) VBool(pool, result)); | |
| } | } |
| static void _flip(Request& r, const String& method_name, MethodParams *params) { | static void _flip(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| VTable& vtable=*static_cast<VTable *>(r.self); | Table& old_table=static_cast<VTable *>(r.self)->table(); |
| Table& old_table=*vtable.get_table(); | |
| Table& new_table=*new(pool) Table(pool, &method_name, 0/*nameless*/); | Table& new_table=*new(pool) Table(pool, &method_name, 0/*nameless*/); |
| if(old_table.size()) | if(old_table.size()) |
| if(int old_cols=old_table.at(0).size()) | if(int old_cols=old_table.at(0).size()) |
| Line 400 static void _flip(Request& r, const Stri | Line 452 static void _flip(Request& r, const Stri |
| static void _append(Request& r, const String& method_name, MethodParams *params) { | static void _append(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| // data is last parameter | // data |
| Temp_lang temp_lang(r, String::UL_PASS_APPENDED); | |
| const String& string= | const String& string= |
| r.process(params->as_junction(0, "body must be code")).as_string(); | r.process_to_string(params->as_junction(0, "body must be code")); |
| // parse cells | // parse cells |
| Array& row=*new(pool) Array(pool); | Array& row=*new(pool) Array(pool); |
| string.split(row, 0, "\t", 1, String::UL_CLEAN); | string.split(row, 0, "\t", 1, String::UL_AS_IS); |
| VTable& vtable=*static_cast<VTable *>(r.self); | static_cast<VTable *>(r.self)->table()+=&row; |
| vtable.table()+=&row; | |
| } | } |
| static void _join(Request& r, const String& method_name, MethodParams *params) { | static void _join(Request& r, const String& method_name, MethodParams *params) { |
| Line 417 static void _join(Request& r, const Stri | Line 469 static void _join(Request& r, const Stri |
| Table *maybe_src=params->as_no_junction(0, "table ref must not be code").get_table(); | Table *maybe_src=params->as_no_junction(0, "table ref must not be code").get_table(); |
| if(!maybe_src) | if(!maybe_src) |
| PTHROW(0, 0, | throw Exception("parser.runtime", |
| &method_name, | &method_name, |
| "source is not a table"); | "source is not a table"); |
| Table& src=*maybe_src; | Table& src=*maybe_src; |
| Table& dest=static_cast<VTable *>(r.self)->table(); | Table& dest=static_cast<VTable *>(r.self)->table(); |
| if(&src == &dest) | if(&src == &dest) |
| PTHROW(0, 0, | throw Exception("parser.runtime", |
| &method_name, | &method_name, |
| "source and destination are same table"); | "source and destination are same table"); |
| Line 433 static void _join(Request& r, const Stri | Line 485 static void _join(Request& r, const Stri |
| for(int src_row=0; src_row<src.size(); src_row++) { | for(int src_row=0; src_row<src.size(); src_row++) { |
| src.set_current(src_row); | src.set_current(src_row); |
| Array& dest_row=*new(pool) Array(pool); | Array& dest_row=*new(pool) Array(pool); |
| for(int dest_column=0; dest_column<dest_columns->size(); dest_column++) | for(int dest_column=0; dest_column<dest_columns->size(); dest_column++) { |
| dest_row+=src.item(*dest_columns->get_string(dest_column)); | const String *src_item=src.item(*dest_columns->get_string(dest_column)); |
| dest_row+=src_item?src_item:new(pool) String(pool); | |
| } | |
| dest+=&dest_row; | dest+=&dest_row; |
| } | } |
| src.set_current(saved_src_current); | src.set_current(saved_src_current); |
| Line 454 public: | Line 508 public: |
| statement_string(astatement_string), | statement_string(astatement_string), |
| statement_cstr(astatement_cstr), | statement_cstr(astatement_cstr), |
| columns(*new(pool) Array(pool)), | columns(*new(pool) Array(pool)), |
| row(0), row_index(0), | row(0), |
| table(0) | table(0) |
| { | { |
| } | } |
| Line 477 public: | Line 531 public: |
| if(size) | if(size) |
| cell->APPEND_TAINTED( | cell->APPEND_TAINTED( |
| (const char *)ptr, size, | (const char *)ptr, size, |
| statement_cstr, row_index++); | statement_cstr, table->size()-1); |
| (*row)+=cell; | (*row)+=cell; |
| } | } |
| Line 487 private: | Line 541 private: |
| const String& statement_string; const char *statement_cstr; | const String& statement_string; const char *statement_cstr; |
| Array& columns; | Array& columns; |
| Array *row; | Array *row; |
| uint row_index; | |
| public: | public: |
| Table *table; | Table *table; |
| }; | }; |
| Line 495 public: | Line 548 public: |
| static void _sql(Request& r, const String& method_name, MethodParams *params) { | static void _sql(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| if(!r.connection) | |
| PTHROW(0, 0, | |
| &method_name, | |
| "without connect"); | |
| Value& statement=params->as_junction(0, "statement must be code"); | Value& statement=params->as_junction(0, "statement must be code"); |
| ulong limit=0; | ulong limit=0; |
| Line 507 static void _sql(Request& r, const Strin | Line 555 static void _sql(Request& r, const Strin |
| if(params->size()>1) { | if(params->size()>1) { |
| Value& voptions=params->as_no_junction(1, "options must be hash, not code"); | Value& voptions=params->as_no_junction(1, "options must be hash, not code"); |
| if(voptions.is_defined()) | if(voptions.is_defined()) |
| if(Hash *options=voptions.get_hash()) { | if(Hash *options=voptions.get_hash(&method_name)) { |
| if(Value *vlimit=(Value *)options->get(*sql_limit_name)) | if(Value *vlimit=(Value *)options->get(*sql_limit_name)) |
| limit=(ulong)r.process(*vlimit).as_double(); | limit=(ulong)r.process_to_value(*vlimit).as_double(); |
| if(Value *voffset=(Value *)options->get(*sql_offset_name)) | if(Value *voffset=(Value *)options->get(*sql_offset_name)) |
| offset=(ulong)r.process(*voffset).as_double(); | offset=(ulong)r.process_to_value(*voffset).as_double(); |
| } else | } else |
| PTHROW(0, 0, | throw Exception("parser.runtime", |
| &method_name, | &method_name, |
| "options must be hash"); | "options must be hash"); |
| } | } |
| Temp_lang temp_lang(r, String::UL_SQL); | Temp_lang temp_lang(r, String::UL_SQL); |
| const String& statement_string=r.process(statement).as_string(); | const String& statement_string=r.process_to_string(statement); |
| const char *statement_cstr= | const char *statement_cstr= |
| statement_string.cstr(String::UL_UNSPECIFIED, r.connection); | statement_string.cstr(String::UL_UNSPECIFIED, r.connection(&method_name)); |
| Table_sql_event_handlers handlers(pool, method_name, | Table_sql_event_handlers handlers(pool, method_name, |
| statement_string, statement_cstr); | statement_string, statement_cstr); |
| bool need_rethrow=false; Exception rethrow_me; | try { |
| PTRY { | #ifdef RESOURCES_DEBUG |
| r.connection->query( | struct timeval mt[2]; |
| //measure:before | |
| gettimeofday(&mt[0],NULL); | |
| #endif | |
| r.connection(&method_name)->query( | |
| statement_cstr, offset, limit, | statement_cstr, offset, limit, |
| handlers); | handlers); |
| #ifdef RESOURCES_DEBUG | |
| //measure:after connect | |
| gettimeofday(&mt[1],NULL); | |
| double t[2]; | |
| for(int i=0;i<2;i++) | |
| t[i]=mt[i].tv_sec+mt[i].tv_usec/1000000.0; | |
| r.sql_request_time+=t[1]-t[0]; | |
| #endif | |
| } catch(const Exception& e) { // query problem | |
| // more specific source [were url] | |
| throw Exception("sql.execute", | |
| &statement_string, | |
| "%s", e.comment()); | |
| } | } |
| PCATCH(e) { // query problem | |
| rethrow_me=e; need_rethrow=true; | |
| } | |
| PEND_CATCH | |
| if(need_rethrow) | |
| PTHROW(rethrow_me.type(), rethrow_me.code(), | |
| &statement_string, // setting more specific source [were url] | |
| rethrow_me.comment()); | |
| Table *result= | Table *result= |
| handlers.table?handlers.table: // query resulted in table? return it | handlers.table?handlers.table: // query resulted in table? return it |
| Line 564 static void _columns(Request& r, const S | Line 624 static void _columns(Request& r, const S |
| } | } |
| } | } |
| VTable& result=*new(pool) VTable(pool, &result_table); | r.write_no_lang(*new(pool) VTable(pool, &result_table)); |
| result.set_name(method_name); | |
| r.write_no_lang(result); | |
| } | } |
| // constructor | static void _select(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | |
| Value& vcondition=params->as_junction(0, "condition must be expression"); | |
| Table& source_table=static_cast<VTable *>(r.self)->table(); | |
| Table& result_table=*new(pool) Table(pool, | |
| source_table.origin_string(), | |
| source_table.columns() | |
| ); | |
| MTable::MTable(Pool& apool) : Methoded(apool) { | int saved_current=source_table.current(); |
| set_name(*NEW String(pool(), TABLE_CLASS_NAME)); | int size=source_table.size(); |
| for(int row=0; row<size; row++) { | |
| source_table.set_current(row); | |
| // ^table:set{data} | bool condition=r.process_to_value(vcondition, |
| // ^table:set[nameless]{data} | /*0/*no name* /,*/ |
| add_native_method("set", Method::CT_DYNAMIC, _set, 1, 2); | false/*don't intercept string*/).as_bool(); |
| // ^table:load[file] | if(condition) // ...condition is true= |
| // ^table:load[nameless;file] | result_table+=&source_table.at(row); // =green light to go to result |
| } | |
| source_table.set_current(saved_current); | |
| r.write_no_lang(*new(pool) VTable(pool, &result_table)); | |
| } | |
| // constructor | |
| MTable::MTable(Pool& apool) : Methoded(apool, "table") { | |
| // ^table::create{data} | |
| // ^table::create[nameless]{data} | |
| // ^table::create[table] | |
| add_native_method("create", Method::CT_DYNAMIC, _create, 1, 2); | |
| // old name for compatibility with <= v 1.141 2002/01/25 11:33:45 paf | |
| add_native_method("set", Method::CT_DYNAMIC, _create, 1, 2); | |
| // ^table::load[file] | |
| // ^table::load[nameless;file] | |
| add_native_method("load", Method::CT_DYNAMIC, _load, 1, 2); | add_native_method("load", Method::CT_DYNAMIC, _load, 1, 2); |
| // ^table.save[file] | // ^table.save[file] |
| Line 593 MTable::MTable(Pool& apool) : Methoded(a | Line 680 MTable::MTable(Pool& apool) : Methoded(a |
| add_native_method("line", Method::CT_DYNAMIC, _line, 0, 0); | add_native_method("line", Method::CT_DYNAMIC, _line, 0, 0); |
| // ^table.offset[] | // ^table.offset[] |
| // ^table.offset[offset] | // ^table.offset(offset) |
| add_native_method("offset", Method::CT_DYNAMIC, _offset, 0, 1); | // ^table.offset[cur|set](offset) |
| add_native_method("offset", Method::CT_DYNAMIC, _offset, 0, 2); | |
| // ^table.menu{code} | // ^table.menu{code} |
| // ^table.menu{code}[delim] | // ^table.menu{code}[delim] |
| Line 609 MTable::MTable(Pool& apool) : Methoded(a | Line 697 MTable::MTable(Pool& apool) : Methoded(a |
| add_native_method("sort", Method::CT_DYNAMIC, _sort, 1, 2); | add_native_method("sort", Method::CT_DYNAMIC, _sort, 1, 2); |
| // ^table.locate[field;value] | // ^table.locate[field;value] |
| add_native_method("locate", Method::CT_DYNAMIC, _locate, 2, 2); | add_native_method("locate", Method::CT_DYNAMIC, _locate, 1, 2); |
| // ^table.flip[] | // ^table.flip[] |
| add_native_method("flip", Method::CT_DYNAMIC, _flip, 0, 0); | add_native_method("flip", Method::CT_DYNAMIC, _flip, 0, 0); |
| Line 627 MTable::MTable(Pool& apool) : Methoded(a | Line 715 MTable::MTable(Pool& apool) : Methoded(a |
| // ^table:columns[] | // ^table:columns[] |
| add_native_method("columns", Method::CT_DYNAMIC, _columns, 0, 0); | add_native_method("columns", Method::CT_DYNAMIC, _columns, 0, 0); |
| // ^table.select(expression) = table | |
| add_native_method("select", Method::CT_DYNAMIC, _select, 1, 1); | |
| } | } |
| // global variable | // global variable |