|
|
| version 1.6, 2001/01/30 13:07:31 | version 1.72, 2020/12/25 22:05:31 |
|---|---|
| Line 1 | Line 1 |
| /* | /** @file |
| $Id$ | Parser: table class. |
| */ | |
| #include <stdlib.h> | Copyright (c) 2001-2020 Art. Lebedev Studio (http://www.artlebedev.com) |
| Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) | |
| */ | |
| #include "pa_table.h" | #include "pa_table.h" |
| #include "pa_pool.h" | |
| Table::Table(Request& arequest, | volatile const char * IDENT_PA_TABLE_C="$Id$" IDENT_PA_TABLE_H; |
| char *afile, uint aline, | |
| Array *acolumns, | #include "pa_exception.h" |
| int initial_rows) : | |
| Array(arequest.pool(), initial_rows), | |
| request(arequest), | |
| fcurrent(0), | |
| fcolumns(acolumns), | |
| name2number(arequest.pool(), false) { | |
| #ifndef NO_STRING_ORIGIN | |
| forigin.file=afile; | |
| forigin.line=aline; | |
| #endif | |
| if(fcolumns) | Table::Table(columns_type acolumns, size_t initial_rows): Array<element_type>(initial_rows), fcurrent(0), fcolumns(acolumns), name2number(NULL){ |
| for(int i=0; i<fcolumns->size(); i++) { | column_names_init(); |
| String name(pool); | } |
| name.APPEND(fcolumns->get_cstr(i), 0, 0); | |
| name2number.put(name, i+1); | void Table::column_names_init(){ |
| if(fcolumns){ | |
| name2number = new name2number_hash_class; | |
| size_t number=1; | |
| for(Array_iterator<const String*> i(*fcolumns); i.has_next(); ) { | |
| 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; | |
| } | } |
| const Array *Table::at(int index) { | Table::Table(const Table& src, Action_options& options) : |
| if(index<0 || index>=size()) | Array<element_type>( (options.limit==ARRAY_OPTION_LIMIT_ALL || options.limit>src.count()) ? src.count() : options.limit), |
| request.exception().raise(0, 0, | |
| 0, | fcurrent(0), |
| "table column index %d is out of range [0..%d]", | fcolumns(src.fcolumns), |
| index, size()-1); | name2number(src.name2number) { |
| return static_cast<const Array *>(get(index)); | ((Table &)src).table_for_each(append_row, this, options); |
| } | } |
| const char *Table::item(int index) { | size_t Table::max_cells() const { |
| const Array *row=at(fcurrent); | size_t result=0; |
| return row->get_cstr(index); | for(size_t i=0; i<count(); i++){ |
| } | element_type row=get(i); |
| if(row->count()>result) | |
| const char *Table::item(const String& column_name) { | result=row->count(); |
| int column_index; | |
| if(fcolumns) { | |
| int found_index=name2number.get_int(column_name); | |
| if(found_index) | |
| column_index=found_index-1; | |
| else | |
| request.exception().raise(0, 0, | |
| &column_name, | |
| "column not found"); | |
| } else { | |
| column_index=atoi(column_name.cstr()); | |
| const Array *row=at(fcurrent); | |
| if(column_index<0 || column_index>=row->size()) | |
| request.exception().raise(0, 0, | |
| &column_name, | |
| "table column index %d is out of range [0..%d]", | |
| column_index, row->size()-1); | |
| } | } |
| return result; | |
| } | |
| return item(column_index); | int Table::column_name2index(const String& column_name, bool bark) const { |
| if(fcolumns) {// named | |
| int result=name2number->get(column_name)-1; // -1 = column not found | |
| if(bark && result<0) | |
| throw Exception(PARSER_RUNTIME, &column_name, "column not found"); | |
| return result; | |
| } else // nameless | |
| return column_name.as_int(); | |
| } | } |
| const String* Table::item(size_t column) { | |
| if(valid(fcurrent)) { | |
| element_type row=get(fcurrent); | |
| if(column<row->count()) // proper index? | |
| return row->get(column); | |
| } | |
| return 0; // it's OK we don't have row|column, just return nothing | |
| } | |
| void Table::put_item(size_t column, const String* value) { | |
| if(!valid(fcurrent)) { | |
| throw Exception(PARSER_RUNTIME, 0, "invalid current row"); | |
| } | |
| element_type row=get(fcurrent); | |
| 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--; | |
| } | |
| } | |
| #ifndef DOXYGEN | |
| 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, Table::Action_options& options) { | |
| return locate(column_name2index(column, true), value, options); | |
| } | |
| void Table::offset(bool absolute, int offset) { | |
| // not +lcount, but "if either operand is unsigned, the other shall be converted to unsigned" C++ rule works here | |
| if(size_t lcount=count()) | |
| fcurrent=((absolute?0:fcurrent)+offset+lcount)%lcount; | |
| } |