--- parser3/src/classes/table.C 2001/03/29 15:00:19 1.38 +++ parser3/src/classes/table.C 2001/04/02 09:29:12 1.42 @@ -5,7 +5,7 @@ Author: Alexander Petrosyan (http://design.ru/paf) - $Id: table.C,v 1.38 2001/03/29 15:00:19 paf Exp $ + $Id: table.C,v 1.42 2001/04/02 09:29:12 paf Exp $ */ #include "pa_config_includes.h" @@ -20,7 +20,7 @@ VStateless_class *table_class; // methods - +/// @todo now remove CONFIG untaint, make pos() searches in String static void set_or_load( Request& r, const String& method_name, Array *params, @@ -34,14 +34,14 @@ static void set_or_load( 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 file_name + // data or table_name char *data; if(is_load) { // forcing untaint language - String lfile_name(pool); - lfile_name.append(vdata_or_filename->as_string(), String::UL_FILE_NAME, true); + 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(lfile_name)); + data=file_read_text(pool, r.absolute(ltable_name)); } else { // suggesting untaint language Temp_lang temp_lang(r, String::UL_TABLE); @@ -87,27 +87,24 @@ static void set_or_load( // replace any previous table value 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 *vfile_name=static_cast(params->get(params->size()-1)); + Value *vtable_name=static_cast(params->get(params->size()-1)); // forcing // ^save[this body type] - r.fail_if_junction_(true, *vfile_name, + r.fail_if_junction_(true, *vtable_name, method_name, "file name must not be junction"); // forcing untaint language - String lfile_name(pool); - lfile_name.append(vfile_name->as_string(), + String ltable_name(pool); + ltable_name.append(vtable_name->as_string(), String::UL_FILE_NAME, true); Table& table=static_cast(r.self)->table(); @@ -148,22 +145,22 @@ static void _save(Request& r, const Stri } // write - file_write(pool, r.absolute(lfile_name), sdata.cstr(), sdata.size(), true); + file_write(pool, r.absolute(ltable_name), sdata.cstr(), sdata.size(), true); } -static void _count(Request& r, const String&, Array *) { +static void _count(Request& r, const String&method_name, Array *) { Pool& pool=r.pool(); Value& value=*new(pool) VInt(pool, static_cast(r.self)->table().size()); r.write_no_lang(value); } -static void _line(Request& r, const String&, Array *) { +static void _line(Request& r, const String& method_name, Array *) { Pool& pool=r.pool(); Value& value=*new(pool) VInt(pool, 1+static_cast(r.self)->table().current()); r.write_no_lang(value); } -static void _offset(Request& r, const String&, Array *params) { +static void _offset(Request& r, const String& method_name, Array *params) { Pool& pool=r.pool(); Table& table=static_cast(r.self)->table(); if(params->size()) @@ -200,7 +197,7 @@ static void _menu(Request& r, const Stri table.set_current(saved_current); } -static void _empty(Request& r, const String&, Array *params) { +static void _empty(Request& r, const String& method_name, Array *params) { Table& table=static_cast(r.self)->table(); if(table.size()==0) { Value& value=r.process(*static_cast(params->get(0))); @@ -227,7 +224,7 @@ static void store_column_item_to_hash(Ar value=new(*ri.pool) VUnknown(*ri.pool); ri.hash->put(column_name, value); } -static void _record(Request& r, const String&, Array *params) { +static void _record(Request& r, const String& method_name, Array *params) { Table& table=static_cast(r.self)->table(); if(const Array *columns=table.columns()) { Pool& pool=r.pool(); @@ -312,7 +309,7 @@ static void _sort(Request& r, const Stri table.set_current(0); } -static void _locate(Request& r, const String&, Array *params) { +static void _locate(Request& r, const String& method_name, Array *params) { VTable& vtable=*static_cast(r.self); Table& table=vtable.table(); vtable.last_locate_was_successful=table.locate( @@ -336,49 +333,139 @@ static void _found(Request& r, const Str } } +static void _flip(Request& r, const String& method_name, Array *params) { + Pool& pool=r.pool(); + VTable& vtable=*static_cast(r.self); + + Table& old_table=*vtable.get_table(); + Table& new_table=*new(pool) Table(pool, &method_name, 0/*nameless*/); + if(old_table.size()) + if(int old_cols=old_table.at(0).size()) + for(int column=0; column(params->get(0)); + // forcing [this body type] + r.fail_if_junction_(true, *value, method_name, "body must not be junction"); + + const String& string=static_cast(value)->as_string(); + + // parse cells + Array& row=*new(pool) Array(pool); + size_t pos_after=0; + int pos_before; + while((pos_before=string.pos("\t", pos_after))>=0) { + row+=&string.piece(pos_after, pos_before); + pos_after=pos_before+1/*\t*/; + } + // last piece + if(pos_after(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