|
|
| version 1.45, 2002/03/27 15:30:37 | version 1.79, 2026/04/25 13:38:46 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: table class. | Parser: table class. |
| Copyright (c) 2001, 2002 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001-2026 Art. Lebedev Studio (https://www.artlebedev.com) |
| Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) | Authors: Konstantin Morshnev <moko@design.ru>, Alexandr Petrosian <paf@design.ru> |
| $Id$ | |
| */ | */ |
| #include <stdlib.h> | |
| #include "pa_table.h" | #include "pa_table.h" |
| #include "pa_pool.h" | |
| #include "pa_exception.h" | |
| Table::Table(Pool& apool, | volatile const char * IDENT_PA_TABLE_C="$Id$" IDENT_PA_TABLE_H; |
| const String *aorigin_string, | |
| const Array *acolumns, | |
| int initial_rows) : | |
| Array(apool, initial_rows), | |
| forigin_string(aorigin_string), | #include "pa_exception.h" |
| fcurrent(0), | |
| fcolumns(acolumns), | Table::Table(columns_type acolumns, size_t initial_rows): Array<element_type>(initial_rows), fcurrent(0), fcolumns(acolumns), name2number(NULL){ |
| name2number(pool()) { | column_names_init(); |
| } | |
| if(fcolumns) | void Table::column_names_init(){ |
| for(int i=0; i<fcolumns->size(); i++) { | if(fcolumns){ |
| const String& name=*fcolumns->get_string(i); | name2number = new name2number_hash_class; |
| name2number.put(name, i+1); | size_t number=1; |
| for(ArrayString::Iterator i(*fcolumns); i; ) { | |
| const String& name=*i.next(); | |
| name2number->put(name, number++); | |
| } | } |
| } | |
| } | |
| static void append_row(Table& src, Table* dest) { | |
| Table::element_type src_row(src[src.current()]); | |
| Table::element_type row(new ArrayString(src_row->count())); | |
| row->append(*src_row); | |
| *dest+=row; | |
| } | } |
| Table::Table(const Table& source) : | Table::Table(const Table& src, Action_options& options) : |
| Array(source), | Array<element_type>(options.limit > src.count() ? src.count() : options.limit), |
| forigin_string(source.forigin_string), | fcurrent(0), |
| fcurrent(source.fcurrent), | fcolumns(src.fcolumns), |
| fcolumns(source.fcolumns), | name2number(src.name2number) { |
| name2number(source.name2number) { | |
| ((Table &)src).table_for_each(append_row, this, options); | |
| } | |
| size_t Table::max_cells() const { | |
| size_t result=0; | |
| for(size_t i=0; i<count(); i++){ | |
| element_type row=get(i); | |
| if(row->count()>result) | |
| result=row->count(); | |
| } | |
| return result; | |
| } | } |
| int Table::column_name2index(const String& column_name, bool bark) const { | int Table::column_name2index(const String& column_name, bool bark) const { |
| if(fcolumns) {// named | if(fcolumns) {// named |
| int result=name2number.get_int(column_name)-1; // -1 = column not found | int result=name2number->get(column_name)-1; // -1 = column not found |
| if(bark && result<0) | if(bark && result<0) |
| throw Exception("parser.runtime", | throw Exception(PARSER_RUNTIME, &column_name, "column not found"); |
| &column_name, | |
| "column not found"); | |
| return result; | |
| } else { // nameless | |
| char *error_pos; | |
| const char *cstr=column_name.cstr(); | |
| int result=(int)strtol(cstr, &error_pos, 0); | |
| if(*error_pos/*not EOS*/) { | |
| result=-1; | |
| if(bark) | |
| throw Exception("parser.runtime", | |
| &column_name, | |
| "invalid column number"); | |
| } | |
| return result; | return result; |
| } | } else // nameless |
| return column_name.as_int(); | |
| } | } |
| const String *Table::item(int column) const { | const String* Table::item(size_t column) { |
| if(valid(fcurrent)) { | if(valid(fcurrent)) { |
| const Array& row=at(fcurrent); | element_type row=get(fcurrent); |
| if(column>=0 && column<row.size()) // proper index? | if(column<row->count()) // proper index? |
| return row.get_string(column); | return row->get(column); |
| } | } |
| return 0; // it's OK we don't have row|column, just return nothing | return 0; // it's OK we don't have row|column, just return nothing |
| } | } |
| bool Table::locate(int column, const String& value) { | void Table::put_item(size_t column, const String* value) { |
| int scurrent=fcurrent; | if(!valid(fcurrent)) { |
| for(fcurrent=0; fcurrent<size(); fcurrent++) { | throw Exception(PARSER_RUNTIME, 0, "invalid current row"); |
| const String *item_value=item(column); | } |
| if(item_value && *item_value==value) | element_type row=get(fcurrent); |
| return true; | while(row->count()<=column){ |
| *row+=&String::Empty; | |
| } | } |
| row->put(column, value); | |
| } | |
| void Table::remove_current(){ | |
| if(!valid(fcurrent)) { | |
| throw Exception(PARSER_RUNTIME, 0, "invalid current row"); | |
| } | |
| remove(fcurrent); | |
| if(fcurrent>=count() && count()>0){ | |
| fcurrent--; | |
| } | |
| } | |
| fcurrent=scurrent; | #ifndef DOXYGEN |
| return false; | struct Locate_int_string_info { |
| int column; | |
| const String* value; | |
| }; | |
| #endif | |
| bool locate_int_string(Table& self, Locate_int_string_info* info) { | |
| const String *item_value=self.item(info->column); | |
| return item_value && *item_value==*info->value; | |
| } | |
| bool Table::locate(int column, const String& value, Table::Action_options& options) { | |
| Locate_int_string_info info={column, &value}; | |
| return table_first_that(locate_int_string, &info, options); | |
| } | } |
| bool Table::locate(const String& column, const String& value) { | bool Table::locate(const String& column, const String& value, Table::Action_options& options) { |
| return locate(column_name2index(column, true), value); | return locate(column_name2index(column, true), value, options); |
| } | } |
| void Table::offset(bool absolute, int offset) { | void Table::offset(bool absolute, int offset) { |
| if(size()) | // not +lcount, but "if either operand is unsigned, the other shall be converted to unsigned" C++ rule works here |
| fcurrent=((absolute?0:fcurrent)+offset+size())%size(); | if(size_t lcount=count()) |
| fcurrent=((absolute?0:fcurrent)+offset+lcount)%lcount; | |
| } | } |