|
|
| version 1.41, 2001/03/30 09:58:57 | version 1.67, 2001/04/28 13:49:14 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: table parser class. | Parser: @b table parser class. |
| Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) |
| Line 9 | Line 9 |
| */ | */ |
| #include "pa_config_includes.h" | #include "pa_config_includes.h" |
| #include "pcre.h" | |
| #include "pa_methoded.h" | |
| #include "pa_common.h" | #include "pa_common.h" |
| #include "pa_request.h" | #include "pa_request.h" |
| #include "_table.h" | |
| #include "pa_vtable.h" | #include "pa_vtable.h" |
| #include "pa_vint.h" | #include "pa_vint.h" |
| #include "pa_sql_connection.h" | |
| #include "pa_dir.h" | |
| // defines | |
| // global var | #define TABLE_CLASS_NAME "table" |
| // class | |
| class MTable : public Methoded { | |
| public: // VStateless_class | |
| Value *create_new_value(Pool& pool) { return new(pool) VTable(pool); } | |
| VStateless_class *table_class; | public: |
| MTable(Pool& pool); | |
| bool used_directly() { return true; } | |
| }; | |
| // methods | // methods |
| /// @todo now remove CONFIG untaint, make pos() searches in String | |
| static void set_or_load( | static void _set(Request& r, const String& method_name, MethodParams *params) { |
| Request& r, | |
| const String& method_name, Array *params, | |
| bool is_load) { | |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| // data is last parameter | // data is last parameter |
| Value *vdata_or_filename=static_cast<Value *>(params->get(params->size()-1)); | Value& vdata=params->get_junction(params->size()-1, "body must be code"); |
| // forcing | |
| // ^load[this file name type] | Temp_lang temp_lang(r, String::UL_PASS_APPENDED); |
| // ^set{this body type} | const String& data=r.process(vdata).as_string(); |
| r.fail_if_junction_(is_load, *vdata_or_filename, | |
| method_name, is_load?"file name must not be junction":"body must be junction"); | size_t pos_after=0; |
| // parse columns | |
| // data or table_name | Array *columns; |
| char *data; | if(params->size()==2) { |
| if(is_load) { | columns=0; |
| // forcing untaint language | |
| 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(ltable_name)); | |
| } else { | } else { |
| // suggesting untaint language | columns=new(pool) Array(pool); |
| Temp_lang temp_lang(r, String::UL_TABLE); | |
| data=r.process(*vdata_or_filename).as_string().cstr(); | Array head(pool); |
| data.split(head, &pos_after, "\n", 1, String::UL_CLEAN, 1); | |
| if(head.size()) | |
| head.get_string(0)->split(*columns, 0, "\t", 1, String::UL_CLEAN); | |
| } | |
| Table& table=*new(pool) Table(pool, &method_name, columns); | |
| // parse cells | |
| Array rows(pool); | |
| data.split(rows, &pos_after, "\n", 1, String::UL_CLEAN); | |
| int size=rows.quick_size(); | |
| for(int i=0; i<size; i++) { | |
| Array& row=*new(pool) Array(pool); | |
| const String& string=*rows.quick_get_string(i); | |
| // remove empty lines | |
| if(!string.size()) | |
| continue; | |
| string.split(row, 0, "\t", 1, String::UL_CLEAN); | |
| table+=&row; | |
| } | } |
| // replace any previous table value | |
| static_cast<VTable *>(r.self)->set_table(table); | |
| } | |
| static void _load(Request& r, const String& method_name, MethodParams *params) { | |
| Pool& pool=r.pool(); | |
| // filename is last parameter | |
| Value& vfilename=params->get_no_junction(params->size()-1, | |
| "file name must not be code"); | |
| // loading text | |
| char *data=file_read_text(pool, r.absolute(vfilename.as_string())); | |
| // parse columns | // parse columns |
| Array *columns; | Array *columns; |
| #ifndef NO_STRING_ORIGIN | #ifndef NO_STRING_ORIGIN |
| Line 63 static void set_or_load( | Line 105 static void set_or_load( |
| if(char *row_chars=getrow(&data)) | if(char *row_chars=getrow(&data)) |
| do { | do { |
| String *name=new(pool) String(pool); | String *name=new(pool) String(pool); |
| name->APPEND_CLEAN(lsplit(&row_chars, '\t'), 0, file, line++); | name->APPEND_TAINTED(lsplit(&row_chars, '\t'), 0, file, line++); |
| *columns+=name; | *columns+=name; |
| } while(row_chars); | } while(row_chars); |
| } | } |
| Line 77 static void set_or_load( | Line 119 static void set_or_load( |
| Array *row=new(pool) Array(pool); | Array *row=new(pool) Array(pool); |
| while(char *cell_chars=lsplit(&row_chars, '\t')) { | while(char *cell_chars=lsplit(&row_chars, '\t')) { |
| String *cell=new(pool) String(pool); | String *cell=new(pool) String(pool); |
| cell->APPEND_CLEAN(cell_chars, 0, file, line); | cell->APPEND_TAINTED(cell_chars, 0, file, line); |
| *row+=cell; | *row+=cell; |
| } | } |
| line++; | line++; |
| Line 87 static void set_or_load( | Line 129 static void set_or_load( |
| // replace any previous table value | // replace any previous table value |
| static_cast<VTable *>(r.self)->set_table(table); | static_cast<VTable *>(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) { | static void _save(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Value *vtable_name=static_cast<Value *>(params->get(params->size()-1)); | Value& vtable_name=params->get_no_junction(params->size()-1, |
| // forcing | "file name must not be code"); |
| // ^save[this body type] | |
| r.fail_if_junction_(true, *vtable_name, | |
| method_name, "file name must not be junction"); | |
| // forcing untaint language | |
| String ltable_name(pool); | |
| ltable_name.append(vtable_name->as_string(), | |
| String::UL_FILE_NAME, true); | |
| Table& table=static_cast<VTable *>(r.self)->table(); | Table& table=static_cast<VTable *>(r.self)->table(); |
| Line 145 static void _save(Request& r, const Stri | Line 173 static void _save(Request& r, const Stri |
| } | } |
| // write | // write |
| file_write(pool, r.absolute(ltable_name), sdata.cstr(), sdata.size(), true); | file_write(pool, r.absolute(vtable_name.as_string()), |
| sdata.cstr(), sdata.size(), true); | |
| } | } |
| static void _count(Request& r, const String&method_name, Array *) { | static void _count(Request& r, const String&, MethodParams *) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Value& value=*new(pool) VInt(pool, static_cast<VTable *>(r.self)->table().size()); | Value& value=*new(pool) VInt(pool, static_cast<VTable *>(r.self)->table().size()); |
| r.write_no_lang(value); | r.write_no_lang(value); |
| } | } |
| static void _line(Request& r, const String& method_name, Array *) { | static void _line(Request& r, const String& method_name, MethodParams *) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Value& value=*new(pool) VInt(pool, 1+static_cast<VTable *>(r.self)->table().current()); | Value& value=*new(pool) VInt(pool, 1+static_cast<VTable *>(r.self)->table().current()); |
| r.write_no_lang(value); | r.write_no_lang(value); |
| } | } |
| static void _offset(Request& r, const String& method_name, Array *params) { | static void _offset(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Table& table=static_cast<VTable *>(r.self)->table(); | Table& table=static_cast<VTable *>(r.self)->table(); |
| if(params->size()) | if(params->size()) |
| table.shift((int)r.process(*static_cast<Value *>(params->get(0))).as_double()); | table.shift((int)r.process(params->get(0)).as_double()); |
| else { | else { |
| Value& value=*new(pool) VInt(pool, table.current()); | Value& value=*new(pool) VInt(pool, table.current()); |
| r.write_no_lang(value); | r.write_no_lang(value); |
| } | } |
| } | } |
| static void _menu(Request& r, const String& method_name, Array *params) { | static void _menu(Request& r, const String& method_name, MethodParams *params) { |
| Value& body_code=*static_cast<Value *>(params->get(0)); | Value& body_code=params->get_junction(0, "body must be code"); |
| // forcing ^menu{this param type} | |
| r.fail_if_junction_(false, body_code, | |
| method_name, "body must be junction"); | |
| Value *delim_code=params->size()==2?static_cast<Value *>(params->get(1)):0; | Value *delim_code=params->size()==2?¶ms->get(1):0; |
| Table& table=static_cast<VTable *>(r.self)->table(); | VTable& vtable=*static_cast<VTable *>(r.self); |
| Table& table=vtable.table(); | |
| bool need_delim=false; | bool need_delim=false; |
| int saved_current=table.current(); | vtable.lock(); int saved_current=table.current(); |
| for(int row=0; row<table.size(); row++) { | for(int row=0; row<table.size(); row++) { |
| table.set_current(row); | table.set_current(row); |
| Line 194 static void _menu(Request& r, const Stri | Line 221 static void _menu(Request& r, const Stri |
| } | } |
| r.write_pass_lang(processed_body); | r.write_pass_lang(processed_body); |
| } | } |
| table.set_current(saved_current); | table.set_current(saved_current); vtable.unlock(); |
| } | } |
| static void _empty(Request& r, const String& method_name, Array *params) { | static void _empty(Request& r, const String& method_name, MethodParams *params) { |
| Table& table=static_cast<VTable *>(r.self)->table(); | Table& table=static_cast<VTable *>(r.self)->table(); |
| if(table.size()==0) { | if(table.size()==0) |
| Value& value=r.process(*static_cast<Value *>(params->get(0))); | r.write_pass_lang(r.process(params->get(0))); |
| r.write_pass_lang(value); | else if(params->size()>1) |
| } else if(params->size()==2) { | r.write_pass_lang(r.process(params->get(1))); |
| Value& value=r.process(*static_cast<Value *>(params->get(1))); | |
| r.write_pass_lang(value); | |
| } | |
| } | } |
| /// used by table: _record / store_column_item_to_hash | |
| struct Record_info { | struct Record_info { |
| Pool *pool; | Pool *pool; |
| Table *table; | Table *table; |
| Line 224 static void store_column_item_to_hash(Ar | Line 249 static void store_column_item_to_hash(Ar |
| value=new(*ri.pool) VUnknown(*ri.pool); | value=new(*ri.pool) VUnknown(*ri.pool); |
| ri.hash->put(column_name, value); | ri.hash->put(column_name, value); |
| } | } |
| static void _record(Request& r, const String& method_name, Array *params) { | static void _record(Request& r, const String& method_name, MethodParams *params) { |
| Table& table=static_cast<VTable *>(r.self)->table(); | Table& table=static_cast<VTable *>(r.self)->table(); |
| if(const Array *columns=table.columns()) { | if(const Array *columns=table.columns()) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Line 259 static int sort_cmp_double(const void *a | Line 284 static int sort_cmp_double(const void *a |
| else | else |
| return 0; | return 0; |
| } | } |
| static void _sort(Request& r, const String& method_name, Array *params) { | static void _sort(Request& r, const String& method_name, MethodParams *params) { |
| Value& key_maker=*(Value *)params->get(0); | Value& key_maker=params->get_junction(0, "key-maker must be code"); |
| // forcing ^sort{this} ^sort(or this) param type | |
| r.fail_if_junction_(false, key_maker, method_name, "key-maker must be junction"); | bool reverse=params->size()==2/*..[asc|desc]*/? |
| reverse=params->get_no_junction(1, "order must not be code").as_string()=="desc": | |
| bool reverse; | false; |
| if(params->size()==2) { // ..[asc|desc] | |
| Value& order=*(Value *)params->get(1); | |
| // forcing ..[this param-type] | |
| r.fail_if_junction_(true, order, method_name, "order must not be junction"); | |
| reverse=order.as_string()=="desc"; | |
| } else | |
| reverse=false; | |
| Table& table=static_cast<VTable *>(r.self)->table(); | Table& table=static_cast<VTable *>(r.self)->table(); |
| Line 287 static void _sort(Request& r, const Stri | Line 305 static void _sort(Request& r, const Stri |
| for(i=0; i<table.size(); i++) { | for(i=0; i<table.size(); i++) { |
| table.set_current(i); | table.set_current(i); |
| // calculate key value | // calculate key value |
| seq[i].row=(Array *)table.get(i); | seq[i].row=(MethodParams *)table.get(i); |
| Value& value=*r.process(key_maker).as_expr_result(true/*return string as-is*/); | Value& value=*r.process(key_maker).as_expr_result(true/*return string as-is*/); |
| if(i==0) // determining key values type by first one | if(i==0) // determining key values type by first one |
| key_values_are_strings=value.is_string(); | key_values_are_strings=value.is_string(); |
| Line 309 static void _sort(Request& r, const Stri | Line 327 static void _sort(Request& r, const Stri |
| table.set_current(0); | table.set_current(0); |
| } | } |
| static void _locate(Request& r, const String& method_name, Array *params) { | static void _locate(Request& r, const String& method_name, MethodParams *params) { |
| VTable& vtable=*static_cast<VTable *>(r.self); | VTable& vtable=*static_cast<VTable *>(r.self); |
| Table& table=vtable.table(); | Table& table=vtable.table(); |
| vtable.last_locate_was_successful=table.locate( | vtable.last_locate_was_successful=table.locate( |
| static_cast<Value *>(params->get(0))->as_string(), | params->get(0).as_string(), |
| static_cast<Value *>(params->get(1))->as_string()); | params->get(1).as_string()); |
| } | } |
| static void _found(Request& r, const String& method_name, Array *params) { | static void _found(Request& r, const String& method_name, MethodParams *params) { |
| if(static_cast<VTable *>(r.self)->last_locate_was_successful) { | if(static_cast<VTable *>(r.self)->last_locate_was_successful) |
| Value& then_code=*static_cast<Value *>(params->get(0)); | r.write_pass_lang(r.process(params->get_junction(0, "found-parameter must be code"))); |
| // forcing ^found{this param type} | else if(params->size()==2) |
| r.fail_if_junction_(false, then_code, | r.write_pass_lang(r.process(params->get_junction(0, "else-parameter must be code"))); |
| method_name, "found-parameter must be junction"); | |
| r.write_pass_lang(r.process(then_code)); | |
| } else if(params->size()==2) { | |
| Value& else_code=*static_cast<Value *>(params->get(1)); | |
| // forcing ^found{this param type} | |
| r.fail_if_junction_(false, else_code, | |
| method_name, "not found-parameter must be junction"); | |
| r.write_pass_lang(r.process(else_code)); | |
| } | |
| } | } |
| static void _flip(Request& r, const String& method_name, Array *params) { | static void _flip(Request& r, const String& method_name, MethodParams *params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| VTable& vtable=*static_cast<VTable *>(r.self); | VTable& vtable=*static_cast<VTable *>(r.self); |
| Line 353 static void _flip(Request& r, const Stri | Line 362 static void _flip(Request& r, const Stri |
| vtable.set_table(new_table); | vtable.set_table(new_table); |
| } | } |
| /// @todo now require \t to be clean [UL_NO] | static void _append(Request& r, const String& method_name, MethodParams *params) { |
| static void _append(Request& r, const String& method_name, Array *params) { | |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| // data is last parameter | // data is last parameter |
| Value *value=static_cast<Value *>(params->get(0)); | const String& string= |
| // forcing [this body type] | r.process(params->get_junction(0, "body must be code")).as_string(); |
| r.fail_if_junction_(true, *value, method_name, "body must not be junction"); | |
| const String& string=static_cast<VString *>(value)->as_string(); | |
| // parse cells | // parse cells |
| Array& row=*new(pool) Array(pool); | Array& row=*new(pool) Array(pool); |
| size_t pos_after=0; | string.split(row, 0, "\t", 1, String::UL_CLEAN); |
| int pos_before; | |
| while((pos_before=string.pos("\t", pos_after))>=0) { | VTable& vtable=*static_cast<VTable *>(r.self); |
| row+=&string.piece(pos_after, pos_before); | // disable ^a.menu{^a.append[]} |
| pos_after=pos_before+1/*\t*/; | vtable.lock(); |
| vtable.table()+=&row; | |
| vtable.unlock(); | |
| } | |
| static void _join(Request& r, const String& method_name, MethodParams *params) { | |
| Pool& pool=r.pool(); | |
| Table *maybe_src=params->get_no_junction(0, "table ref must not be code").get_table(); | |
| if(!maybe_src) | |
| PTHROW(0, 0, | |
| &method_name, | |
| "source is not a table"); | |
| Table& src=*maybe_src; | |
| Table& dest=static_cast<VTable *>(r.self)->table(); | |
| if(&src == &dest) | |
| PTHROW(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_row<src.size(); src_row++) { | |
| src.set_current(src_row); | |
| Array& dest_row=*new(pool) Array(pool); | |
| for(int dest_column=0; dest_column<dest_columns->size(); 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<src.size(); src_row++) | |
| dest+=&src.at(src_row); | |
| } | } |
| // last piece | } |
| if(pos_after<string.size()) | |
| row+=&string.piece(pos_after, string.size()); | |
| static_cast<VTable *>(r.self)->table()+=&row; | /// ^table:sql{query}[(count[;offset])] |
| static void _sql(Request& r, const String& method_name, MethodParams *params) { | |
| Pool& pool=r.pool(); | |
| if(!r.connection) | |
| PTHROW(0, 0, | |
| &method_name, | |
| "without connect"); | |
| Value& statement=params->get_junction(0, "statement must be code"); | |
| ulong limit=0; | |
| if(params->size()>1) { | |
| Value& limit_code=params->get_junction(1, "limit must be expression"); | |
| limit=(uint)r.process(limit_code).as_double(); | |
| } | |
| ulong offset=0; | |
| if(params->size()>2) { | |
| Value& offset_code=params->get_junction(2, "offset must be expression"); | |
| offset=(ulong)r.process(offset_code).as_double(); | |
| } | |
| Temp_lang temp_lang(r, String::UL_SQL); | |
| const String& statement_string=r.process(statement).as_string(); | |
| const char *statement_cstr= | |
| statement_string.cstr(String::UL_UNSPECIFIED, r.connection); | |
| unsigned int sql_column_count; SQL_Driver::Cell *sql_columns; | |
| unsigned long sql_row_count; SQL_Driver::Cell **sql_rows; | |
| bool need_rethrow=false; Exception rethrow_me; | |
| PTRY { | |
| r.connection->query( | |
| statement_cstr, offset, limit, | |
| &sql_column_count, &sql_columns, | |
| &sql_row_count, &sql_rows); | |
| } | |
| PCATCH(e) { // connect/process problem | |
| rethrow_me=e; need_rethrow=true; | |
| } | |
| PEND_CATCH | |
| if(need_rethrow) | |
| PTHROW(rethrow_me.type(), rethrow_me.code(), | |
| &statement_string, // setting more specific source [were url] | |
| rethrow_me.comment()); | |
| Array& table_columns=*new(pool) Array(pool); | |
| for(unsigned int i=0; i<sql_column_count; i++) { | |
| String& table_column=*new(pool) String(pool); | |
| table_column.APPEND_TAINTED( | |
| (const char *)sql_columns[i].ptr, sql_columns[i].size, | |
| statement_cstr, 0); | |
| table_columns+=&table_column; | |
| } | |
| Table& table=*new(pool) Table(pool, &method_name, &table_columns); | |
| { | |
| for(unsigned long r=0; r<sql_row_count; r++) { | |
| SQL_Driver::Cell *sql_cells=sql_rows[r]; | |
| Array& table_row=*new(pool) Array(pool); | |
| for(unsigned int i=0; i<sql_column_count; i++) { | |
| String& table_cell=*new(pool) String(pool); | |
| table_cell.APPEND_TAINTED( | |
| (const char *)sql_cells[i].ptr, sql_cells[i].size, | |
| statement_cstr, r); | |
| table_row+=&table_cell; | |
| } | |
| table+=&table_row; | |
| } | |
| } | |
| // replace any previous table value | |
| static_cast<VTable *>(r.self)->set_table(table); | |
| } | } |
| // initialize | /// ^table:dir[path] |
| /// ^table:dir[path][regexp] | |
| static void _dir(Request& r, const String& method_name, MethodParams *params) { | |
| Pool& pool=r.pool(); | |
| void initialize_table_class(Pool& pool, VStateless_class& vclass) { | Value& relative_path=params->get_no_junction(0, "path must not be code"); |
| // ^table.set{data} | |
| // ^table.set[nameless]{data} | |
| vclass.add_native_method("set", Method::CT_DYNAMIC, _set, 1, 2); | |
| // ^table.load[file] | const String *regexp; |
| // ^table.load[nameless;file] | pcre *regexp_code; |
| vclass.add_native_method("load", Method::CT_DYNAMIC, _load, 1, 2); | int ovecsize; |
| int *ovector; | |
| if(params->size()>1) { | |
| regexp=¶ms->get_no_junction(1, "regexp must not be code").as_string(); | |
| const char *pattern=regexp->cstr(String::UL_AS_IS); | |
| const char *errptr; | |
| int erroffset; | |
| regexp_code=pcre_compile(pattern, PCRE_EXTRA | PCRE_DOTALL, | |
| &errptr, &erroffset, | |
| r.pcre_tables); | |
| if(!regexp_code) | |
| PTHROW(0, 0, | |
| ®exp->mid(erroffset, regexp->size()), | |
| "regular expression syntax error - %s", errptr); | |
| ovector=(int *)malloc(sizeof(int)*(ovecsize=(1/*match*/)*3)); | |
| } else | |
| regexp_code=0; | |
| const char* absolute_path_cstr=r.absolute(relative_path.as_string()) | |
| .cstr(String::UL_FILE_NAME); | |
| Array& columns=*new(pool) Array(pool); | |
| columns+=new(pool) String(pool, "name"); | |
| Table& table=*new(pool) Table(pool, &method_name, &columns); | |
| LOAD_DIR(absolute_path_cstr, | |
| size_t file_name_size=strlen(ffblk.ff_name); | |
| bool suits=true; | |
| if(regexp_code) { | |
| int exec_result=pcre_exec(regexp_code, 0, | |
| ffblk.ff_name, file_name_size, 0, | |
| 0, ovector, ovecsize); | |
| if(exec_result==PCRE_ERROR_NOMATCH) | |
| suits=false; | |
| else if(exec_result<0) { | |
| (*pcre_free)(regexp_code); | |
| PTHROW(0, 0, | |
| regexp, | |
| "regular expression execute (%d)", | |
| exec_result); | |
| } | |
| } | |
| if(suits) { | |
| char *file_name_cstr=(char *)r.malloc(file_name_size); | |
| memcpy(file_name_cstr, ffblk.ff_name, file_name_size); | |
| String &file_name=*new(pool) String(pool); | |
| file_name.APPEND_TAINTED(file_name_cstr, file_name_size, | |
| method_name.origin().file, method_name.origin().line); | |
| Array& row=*new(pool) Array(pool); | |
| row+=&file_name; | |
| table+=&row; | |
| } | |
| ); | |
| if(regexp_code) | |
| (*pcre_free)(regexp_code); | |
| // replace any previous table value | |
| static_cast<VTable *>(r.self)->set_table(table); | |
| } | |
| // constructor | |
| MTable::MTable(Pool& apool) : Methoded(apool) { | |
| set_name(*NEW String(pool(), TABLE_CLASS_NAME)); | |
| // ^table:set{data} | |
| // ^table:set[nameless]{data} | |
| add_native_method("set", Method::CT_DYNAMIC, _set, 1, 2); | |
| // ^table:load[file] | |
| // ^table:load[nameless;file] | |
| add_native_method("load", Method::CT_DYNAMIC, _load, 1, 2); | |
| // ^table.save[file] | // ^table.save[file] |
| // ^table.save[nameless;file] | // ^table.save[nameless;file] |
| vclass.add_native_method("save", Method::CT_DYNAMIC, _save, 1, 2); | add_native_method("save", Method::CT_DYNAMIC, _save, 1, 2); |
| // ^table.count[] | // ^table.count[] |
| vclass.add_native_method("count", Method::CT_DYNAMIC, _count, 0, 0); | add_native_method("count", Method::CT_DYNAMIC, _count, 0, 0); |
| // ^table.line[] | // ^table.line[] |
| vclass.add_native_method("line", Method::CT_DYNAMIC, _line, 0, 0); | add_native_method("line", Method::CT_DYNAMIC, _line, 0, 0); |
| // ^table.offset[] | // ^table.offset[] |
| // ^table.offset[offset] | // ^table.offset[offset] |
| vclass.add_native_method("offset", Method::CT_DYNAMIC, _offset, 0, 1); | add_native_method("offset", Method::CT_DYNAMIC, _offset, 0, 1); |
| // ^table.menu{code} | // ^table.menu{code} |
| // ^table.menu{code}[delim] | // ^table.menu{code}[delim] |
| vclass.add_native_method("menu", Method::CT_DYNAMIC, _menu, 1, 2); | add_native_method("menu", Method::CT_DYNAMIC, _menu, 1, 2); |
| // ^table.empty{code-when-empty} | // ^table.empty{code-when-empty} |
| // ^table.empty{code-when-empty}{code-when-not} | // ^table.empty{code-when-empty}{code-when-not} |
| vclass.add_native_method("empty", Method::CT_DYNAMIC, _empty, 1, 2); | add_native_method("empty", Method::CT_DYNAMIC, _empty, 1, 2); |
| // ^table.record[] | // ^table.record[] |
| vclass.add_native_method("record", Method::CT_DYNAMIC, _record, 0, 0); | add_native_method("record", Method::CT_DYNAMIC, _record, 0, 0); |
| // ^table.sort{string-key-maker} ^table.sort{string-key-maker}[asc|desc] | // ^table.sort{string-key-maker} ^table.sort{string-key-maker}[asc|desc] |
| // ^table.sort(numeric-key-maker) ^table.sort(numeric-key-maker)[asc|desc] | // ^table.sort(numeric-key-maker) ^table.sort(numeric-key-maker)[asc|desc] |
| vclass.add_native_method("sort", Method::CT_DYNAMIC, _sort, 1, 2); | add_native_method("sort", Method::CT_DYNAMIC, _sort, 1, 2); |
| // ^table.locate[field;value] | // ^table.locate[field;value] |
| vclass.add_native_method("locate", Method::CT_DYNAMIC, _locate, 2, 2); | add_native_method("locate", Method::CT_DYNAMIC, _locate, 2, 2); |
| // ^table.found{when-found} | // ^table.found{when-found} |
| // ^table.found{when-found}{when-not-found} | // ^table.found{when-found}{when-not-found} |
| vclass.add_native_method("found", Method::CT_DYNAMIC, _found, 1, 2); | add_native_method("found", Method::CT_DYNAMIC, _found, 1, 2); |
| // ^table.flip[] | // ^table.flip[] |
| vclass.add_native_method("flip", Method::CT_DYNAMIC, _flip, 0, 0); | add_native_method("flip", Method::CT_DYNAMIC, _flip, 0, 0); |
| // ^table.append{r{tab}e{tab}c{tab}o{tab}r{tab}d} | // ^table.append{r{tab}e{tab}c{tab}o{tab}r{tab}d} |
| vclass.add_native_method("append", Method::CT_DYNAMIC, _append, 1, 1); | add_native_method("append", Method::CT_DYNAMIC, _append, 1, 1); |
| // ^table.join[table] | |
| add_native_method("join", Method::CT_DYNAMIC, _join, 1, 1); | |
| // ^table:sql[query][(count[;offset])] | |
| add_native_method("sql", Method::CT_DYNAMIC, _sql, 1, 3); | |
| // ^table:dir[path] | |
| // ^table:dir[path][regexp] | |
| add_native_method("dir", Method::CT_DYNAMIC, _dir, 1, 2); | |
| } | |
| // global variable | |
| Methoded *table_class; | |
| // creator | |
| Methoded *MTable_create(Pool& pool) { | |
| return table_class=new(pool) MTable(pool); | |
| } | } |