--- parser3/src/classes/table.C 2021/12/21 14:24:54 1.359 +++ parser3/src/classes/table.C 2024/09/21 23:51:03 1.364 @@ -1,8 +1,8 @@ /** @file Parser: @b table parser class. - Copyright (c) 2001-2020 Art. Lebedev Studio (http://www.artlebedev.com) - Author: Alexandr Petrosian (http://paf.design.ru) + Copyright (c) 2001-2023 Art. Lebedev Studio (http://www.artlebedev.com) + Authors: Konstantin Morshnev , Alexandr Petrosian */ #include "pa_config_includes.h" @@ -25,7 +25,7 @@ #include "pa_vbool.h" #include "pa_array.h" -volatile const char * IDENT_TABLE_C="$Id: table.C,v 1.359 2021/12/21 14:24:54 moko Exp $"; +volatile const char * IDENT_TABLE_C="$Id: table.C,v 1.364 2024/09/21 23:51:03 moko Exp $"; // class @@ -69,19 +69,22 @@ static Table::Action_options get_action_ result.offset=source.current(); else throw Exception(PARSER_RUNTIME, &soffset, "must be 'cur' string or expression"); - } else - result.offset=r.process(*voffset).as_int(); + } else { + int offset=r.process(*voffset).as_int(); + result.offset=offset < 0 ? 0 : offset; + } } if(Value* vlimit=options->get(sql_limit_name)) { valid_options++; - result.limit=r.process(*vlimit).as_int(); + int limit=r.process(*vlimit).as_int(); + result.limit=limit < 0 ? 0: limit; } - if(Value *vreverse=(Value *)options->get(table_reverse_name)) { + if(Value *vreverse=(Value *)options->get(table_reverse_name)) { valid_options++; result.reverse=r.process(*vreverse).as_bool(); if(result.reverse && !defined_offset) result.offset=source.count()-1; - } + } if(valid_options!=options->count()) throw Exception(PARSER_RUNTIME, 0, CALLED_WITH_INVALID_OPTION); @@ -485,15 +488,15 @@ static void table_to_csv(pa_stringstream if(output_column_names) { if(table.columns()) { // named table if(control_chars.encloser){ - for(Array_iterator i(*table.columns()); i.has_next(); ) { + for(Array_iterator i(*table.columns()); i; ) { enclose( result, i.next(), control_chars.encloser ); - if(i.has_next()) + if(i) result< i(*table.columns()); i.has_next(); ) { + for(Array_iterator i(*table.columns()); i; ) { result<cstr(); - if(i.has_next()) + if(i) result< i(table); if(control_chars.encloser){ - while(i.has_next()) { - for(Array_iterator c(*i.next()); c.has_next(); ) { + while(i) { + for(Array_iterator c(*i.next()); c; ) { enclose( result, c.next(), control_chars.encloser ); - if(c.has_next()) + if(c) result< c(*i.next()); c.has_next(); ) { + while(i) { + for(Array_iterator c(*i.next()); c; ) { result<cstr(); - if(c.has_next()) + if(c) result< i(*table.columns()); i.has_next(); ) { + for(Array_iterator i(*table.columns()); i; ) { enclose( result, i.next(), control_chars.encloser, control_chars.sencloser ); - if(i.has_next()) + if(i) result<<*control_chars.sseparator; } } else { - for(Array_iterator i(*table.columns()); i.has_next(); ) { + for(Array_iterator i(*table.columns()); i; ) { result<<*i.next(); - if(i.has_next()) + if(i) result<<*control_chars.sseparator; } } @@ -580,9 +583,9 @@ static void table_to_csv(String& result, if(int lsize=table.count()?table[0]->count():0) for(int column=0; column i(table); if(control_chars.encloser){ - while(i.has_next()) { - for(Array_iterator c(*i.next()); c.has_next(); ) { + while(i) { + for(Array_iterator c(*i.next()); c; ) { enclose( result, c.next(), control_chars.encloser, control_chars.sencloser ); - if(c.has_next()) + if(c) result<<*control_chars.sseparator; } result.append_know_length("\n", 1, String::L_CLEAN); } } else { - while(i.has_next()) { - for(Array_iterator c(*i.next()); c.has_next(); ) { + while(i) { + for(Array_iterator c(*i.next()); c; ) { result<<*c.next(); - if(c.has_next()) + if(c) result<<*control_chars.sseparator; } result.append_know_length("\n", 1, String::L_CLEAN); @@ -843,7 +846,7 @@ static void table_row_to_hash(Table::ele HashStringValue& hash=vhash->hash(); Table::columns_type columns=info->table->columns(); if(info->value_fields){ // selected fields (can be empty) - for(Array_iterator i(*info->value_fields); i.has_next(); ) { + for(Array_iterator i(*info->value_fields); i; ) { size_t value_field=i.next(); if(value_fieldcount()) hash.put(columns ? *columns->get(value_field) : String(format(value_field, 0)), new VString(*row->get(value_field))); @@ -918,7 +921,6 @@ static Table2hash_distint get_distinct(V static void _hash(Request& r, MethodParams& params) { Table& self_table=GET_SELF(r, VTable).table(); VHash& result=*new VHash; - Table::columns_type columns=self_table.columns(); Table2hash_distint distinct=D_ILLEGAL; Table2hash_value_type value_type=C_HASH; @@ -973,7 +975,7 @@ static void _hash(Request& r, MethodPara if(!field_name.is_empty()) value_fields+=self_table.column_name2index(field_name, true); } else if(Table* value_fields_table=value_fields_param.get_table()) { // list of columns were specified in table - for(Array_iterator i(*value_fields_table); i.has_next(); ) { + for(Array_iterator i(*value_fields_table); i; ) { const String& value_field_name =*i.next()->get(0); value_fields +=self_table.column_name2index(value_field_name, true); } @@ -1159,7 +1161,7 @@ static void _foreach(Request& r, MethodP table.set_current(row); if(rownum_var_name) - r.put_element(*var_context, *rownum_var_name, new VString(*new String(String::Body::Format(row), String::L_CLEAN))); + r.put_element(*var_context, *rownum_var_name, new VString(*new String(pa_uitoa(row), String::L_CLEAN))); if(value_var_name) r.put_element(*var_context, *value_var_name, new VTable(&table)); @@ -1184,7 +1186,7 @@ static void _foreach(Request& r, MethodP table.set_current(row); if(rownum_var_name) - r.put_element(*var_context, *rownum_var_name, new VString(*new String(String::Body::Format(row), String::L_CLEAN))); + r.put_element(*var_context, *rownum_var_name, new VString(*new String(pa_uitoa(row), String::L_CLEAN))); if(value_var_name) r.put_element(*var_context, *value_var_name, new VTable(&table)); @@ -1430,7 +1432,7 @@ static void _columns(Request& r, MethodP Table& source_table=GET_SELF(r, VTable).table(); if(Table::columns_type source_columns=source_table.columns()) { - for(Array_iterator i(*source_columns); i.has_next(); ) { + for(Array_iterator i(*source_columns); i; ) { Table::element_type result_row(new ArrayString); *result_row+=i.next(); result_table+=result_row;