--- parser3/src/classes/table.C 2020/12/14 20:58:15 1.352 +++ parser3/src/classes/table.C 2020/12/26 23:09:08 1.357 @@ -1,14 +1,12 @@ /** @file Parser: @b table parser class. - Copyright (c) 2001-2017 Art. Lebedev Studio (http://www.artlebedev.com) + Copyright (c) 2001-2020 Art. Lebedev Studio (http://www.artlebedev.com) Author: Alexandr Petrosian (http://paf.design.ru) */ #include "pa_config_includes.h" -#define NO_STRINGSTREAM - #if (!defined(NO_STRINGSTREAM) && !defined(FREEBSD4) && !defined(PA_DEBUG_DISABLE_GC)) #include #include "../lib/gc/include/gc_allocator.h" @@ -27,7 +25,7 @@ #include "pa_vbool.h" #include "pa_array.h" -volatile const char * IDENT_TABLE_C="$Id: table.C,v 1.352 2020/12/14 20:58:15 moko Exp $"; +volatile const char * IDENT_TABLE_C="$Id: table.C,v 1.357 2020/12/26 23:09:08 moko Exp $"; // class @@ -1261,18 +1259,18 @@ static void join_nameless_row(Table& src *dest+=src[src.current()]; } static void _join(Request& r, MethodParams& params) { - Table& src=*params.as_table(0, "source"); - - Table::Action_options o=get_action_options(r, params, 1, src); + if(Table* src=params.as_table(0, "source")){ + Table::Action_options o=get_action_options(r, params, 1, *src); - Table& dest=GET_SELF(r, VTable).table(); - if(&src == &dest) - throw Exception(PARSER_RUNTIME, 0, "source and destination are same table"); - - if(dest.columns()) // dest is named - src.table_for_each(join_named_row, &dest, o); - else // dest is nameless - src.table_for_each(join_nameless_row, &dest, o); + Table& dest=GET_SELF(r, VTable).table(); + if(src == &dest) + throw Exception(PARSER_RUNTIME, 0, "source and destination are same table"); + + if(dest.columns()) // dest is named + src->table_for_each(join_named_row, &dest, o); + else // dest is nameless + src->table_for_each(join_nameless_row, &dest, o); + } } #ifndef DOXYGEN @@ -1503,6 +1501,42 @@ static void _select(Request& r, MethodPa r.write(*new VTable(&result_table)); } + +static void _rename(Request& r, MethodParams& params) { + const String* name_from=NULL; + const String* name_to=NULL; + HashStringValue* names=NULL; + + if(params.count()>1){ + name_from=¶ms.as_string(0, COLUMN_NAME_MUST_BE_STRING); + name_to=¶ms.as_string(1, COLUMN_NAME_MUST_BE_STRING); + } else + names=params.as_hash(0); + + Table& table=GET_SELF(r, VTable).table(); + if(Table::columns_type columns=table.columns()) { + if(names){ + for(int i=0; icount(); i++) { + const String *column = columns->get(i); + if(Value* vto=names->get(*column)){ + if(const String *sto=vto->get_string()) + columns->put(i, sto); + else + throw Exception(PARSER_RUNTIME, column, COLUMN_NAME_MUST_BE_STRING); + } + } + } else if(name_from){ + for(int i=0; icount(); i++) { + const String *column = columns->get(i); + if(*column == *name_from) + columns->put(i, name_to); + } + } + table.column_names_init(); + } else + throw Exception(PARSER_RUNTIME, 0, "columns renaming is not supported for nameless tables"); +} + // constructor MTable::MTable(): Methoded("table") { @@ -1586,4 +1620,8 @@ MTable::MTable(): Methoded("table") { // ^table.select(expression) = table add_native_method("select", Method::CT_DYNAMIC, _select, 1, 2); + + // ^table.rename[column name from;column name to] + // ^table.rename[ $.[column name from][column name to] ... ] + add_native_method("rename", Method::CT_DYNAMIC, _rename, 1, 2); }