--- parser3/src/classes/table.C 2001/03/30 05:51:12 1.40 +++ parser3/src/classes/table.C 2001/04/03 08:23:06 1.47 @@ -1,11 +1,11 @@ /** @file - Parser: table parser class. + Parser: @b table parser class. Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) Author: Alexander Petrosyan (http://design.ru/paf) - $Id: table.C,v 1.40 2001/03/30 05:51:12 paf Exp $ + $Id: table.C,v 1.47 2001/04/03 08:23:06 paf Exp $ */ #include "pa_config_includes.h" @@ -20,34 +20,64 @@ VStateless_class *table_class; // methods - -static void set_or_load( - Request& r, - const String& method_name, Array *params, - bool is_load) { +static void _set(Request& r, const String& method_name, Array *params) { Pool& pool=r.pool(); // data is last parameter - Value *vdata_or_filename=static_cast(params->get(params->size()-1)); - // forcing - // ^load[this file name type] - // ^set{this body type} - r.fail_if_junction_(is_load, *vdata_or_filename, - method_name, is_load?"file name must not be junction":"body must be junction"); - - // data or table_name - char *data; - if(is_load) { - // forcing untaint language - String ltable_name(pool); - ltable_name.append(vdata_or_filename->as_string(), String::UL_FILE_NAME, true); - // loading text - data=file_read_text(pool, r.absolute(ltable_name)); + Value *vdata=static_cast(params->get(params->size()-1)); + // forcing {this body type} + r.fail_if_junction_(false, *vdata, method_name, "body must be junction"); + + Temp_lang temp_lang(r, String::UL_PASS_APPENDED); + const String& data=r.process(*vdata).as_string(); + + size_t pos_after=0; + // parse columns + Array *columns; + if(params->size()==2) { + columns=0; } else { - // suggesting untaint language - Temp_lang temp_lang(r, String::UL_TABLE); - data=r.process(*vdata_or_filename).as_string().cstr(); + columns=new(pool) Array(pool); + + Array head(pool); + data.split(head, &pos_after, "\n", 1, String::UL_CLEAN, 1); + if(head.size()) + head.get_string(0)->split(*columns, 0, "\t", 1, String::UL_CLEAN); } + Table& table=*new(pool) Table(pool, &method_name, columns); + // parse cells + Array rows(pool); + data.split(rows, &pos_after, "\n", 1, String::UL_CLEAN); + int size=rows.quick_size(); + for(int i=0; i(r.self)->set_table(table); +} + +static void _load(Request& r, const String& method_name, Array *params) { + Pool& pool=r.pool(); + // filename is last parameter + Value *vfilename=static_cast(params->get(params->size()-1)); + // forcing [this file name type] + r.fail_if_junction_(true, *vfilename, + method_name, "file name must not be junction"); + + // forcing untaint language + String lfilename(pool); + lfilename.append(vfilename->as_string(), String::UL_FILE_NAME, true); + // loading text + char *data=file_read_text(pool, r.absolute(lfilename)); + // parse columns Array *columns; #ifndef NO_STRING_ORIGIN @@ -63,7 +93,7 @@ static void set_or_load( if(char *row_chars=getrow(&data)) do { String *name=new(pool) String(pool); - name->APPEND_CLEAN(lsplit(&row_chars, '\t'), 0, file, line++); + name->APPEND_TAINTED(lsplit(&row_chars, '\t'), 0, file, line++); *columns+=name; } while(row_chars); } @@ -77,7 +107,7 @@ static void set_or_load( Array *row=new(pool) Array(pool); while(char *cell_chars=lsplit(&row_chars, '\t')) { String *cell=new(pool) String(pool); - cell->APPEND_CLEAN(cell_chars, 0, file, line); + cell->APPEND_TAINTED(cell_chars, 0, file, line); *row+=cell; } line++; @@ -88,20 +118,10 @@ static void set_or_load( static_cast(r.self)->set_table(table); } - -static void _set(Request& r, const String& method_name, Array *params) { - set_or_load(r, method_name, params, false); -} - -static void _load(Request& r, const String& method_name, Array *params) { - set_or_load(r, method_name, params, true); -} - static void _save(Request& r, const String& method_name, Array *params) { Pool& pool=r.pool(); Value *vtable_name=static_cast(params->get(params->size()-1)); - // forcing - // ^save[this body type] + // forcing this body type] r.fail_if_junction_(true, *vtable_name, method_name, "file name must not be junction"); @@ -356,6 +376,58 @@ static void _flip(Request& r, const Stri vtable.set_table(new_table); } +static void _append(Request& r, const String& method_name, Array *params) { + Pool& pool=r.pool(); + // data is last parameter + Value *value=static_cast(params->get(0)); + // forcing {this body type} + r.fail_if_junction_(false, *value, method_name, "body must be junction"); + + const String& string=r.process(*value).as_string(); + + // parse cells + Array& row=*new(pool) Array(pool); + string.split(row, 0, "\t", 1, String::UL_CLEAN); + + static_cast(r.self)->table()+=&row; +} + +static void _join(Request& r, const String& method_name, Array *params) { + Pool& pool=r.pool(); + + Value *value=static_cast(params->get(0)); + // forcing [this table ref type] + r.fail_if_junction_(true, *value, method_name, "table ref must not be junction"); + + Table *maybe_src=value->get_table(); + if(!maybe_src) + RTHROW(0, 0, + &method_name, + "source is not a table"); + + Table& src=*maybe_src; + Table& dest=static_cast(r.self)->table(); + if(&src == &dest) + RTHROW(0, 0, + &method_name, + "source and destination are same table"); + + if(const Array *dest_columns=dest.columns()) { // dest is named + int saved_src_current=src.current(); + for(int src_row=0; src_rowsize(); dest_column++) + dest_row+=src.item(*dest_columns->get_string(dest_column)); + dest+=&dest_row; + } + src.set_current(saved_src_current); + } else { // dest is nameless + for(int src_row=0; src_row