|
|
| version 1.161, 2002/09/17 08:44:45 | version 1.172.2.14, 2003/03/08 12:22:06 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: @b table parser class. | Parser: @b table parser class. |
| Copyright (c) 2001, 2002 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001-2003 ArtLebedev Group (http://www.artlebedev.com) |
| Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) | Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) |
| */ | */ |
| static const char* IDENT_TABLE_C="$Date$"; | static const char* IDENT_TABLE_C="$Date$"; |
| #include "classes.h" | #include "classes.h" |
| #include "pa_vmethod_frame.h" | |
| #include "pa_common.h" | #include "pa_common.h" |
| #include "pa_request.h" | #include "pa_request.h" |
| #include "pa_vtable.h" | #include "pa_vtable.h" |
| Line 17 static const char* IDENT_TABLE_C="$Date$ | Line 19 static const char* IDENT_TABLE_C="$Date$ |
| // class | // class |
| class MTable : public Methoded { | class MTable: public Methoded { |
| public: // VStateless_class | public: // VStateless_class |
| Value *create_new_value(Pool& pool) { return new(pool) VTable(pool); } | ValuePtr create_new_value() { return ValuePtr(new VTable()); } |
| public: | public: |
| MTable(Pool& pool); | MTable(); |
| public: // Methoded | public: // Methoded |
| bool used_directly() { return true; } | bool used_directly() { return true; } |
| }; | }; |
| // global variable | |
| DECLARE_CLASS_VAR(table, new MTable, 0); | |
| // defines for globals | |
| #define SQL_LIMIT_NAME "limit" | |
| #define SQL_OFFSET_NAME "offset" | |
| #define SQL_DEFAULT_NAME "default" | |
| #define SQL_DISTINCT_NAME "distinct" | |
| // globals | |
| StringPtr sql_limit_name(new String(SQL_LIMIT_NAME)); | |
| StringPtr sql_offset_name(new String(SQL_OFFSET_NAME)); | |
| StringPtr sql_default_name(new String(SQL_DEFAULT_NAME)); | |
| StringPtr sql_distinct_name(new String(SQL_DISTINCT_NAME)); | |
| // methods | // methods |
| static void get_copy_options(Request& r, const String& method_name, MethodParams *params, int param_index, | static void get_copy_options(Request& r, StringPtr method_name, MethodParams* params, int param_index, |
| const Table& source, | const Table& source, |
| int& offset, | int& offset, |
| int& limit) { | int& limit) { |
| Pool& pool=r.pool(); | |
| offset=0; | offset=0; |
| limit=0; | limit=0; |
| if(params->size()<=param_index) | if(params->count()<=param_index) |
| return; | return; |
| Value& voptions=params->as_no_junction(param_index, "options must be hash, not code"); | ValuePtr voptions=params->as_no_junction(param_index, "options must be hash, not code"); |
| if(!voptions.is_string()) { | if(!voptions->is_string()) { |
| if(Hash *options=voptions.get_hash(&method_name)) { | if(HashStringValue* options=voptions->get_hash(method_name)) { |
| if(Value *voffset=(Value *)options->get(*sql_offset_name)) | int valid_options=0; |
| if(ValuePtr voffset=options->get(sql_offset_name)) { | |
| valid_options++; | |
| if(voffset->is_string()) { | if(voffset->is_string()) { |
| const String& soffset=*voffset->get_string(); | StringPtr soffset=voffset->get_string(&pool); |
| if(soffset == "cur") | if(*soffset == "cur") |
| offset=source.current(); | offset=source.current(); |
| else | else |
| throw Exception("parser.runtime", | throw Exception("parser.runtime", |
| &soffset, | soffset, |
| "must be 'cur' string or expression"); | "must be 'cur' string or expression"); |
| } else | } else |
| offset=r.process_to_value(*voffset).as_int(); | offset=r.process_to_value(voffset)->as_int(); |
| if(Value *vlimit=(Value *)options->get(*sql_limit_name)) | } |
| limit=r.process_to_value(*vlimit).as_int(); | if(ValuePtr vlimit=options->get(sql_limit_name)) { |
| valid_options++; | |
| limit=r.process_to_value(vlimit)->as_int(); | |
| if(!limit) // zero limit = should be 'nothing to copy', for methods zero means 'all' | |
| limit=-1; // thus fixing | |
| } | |
| if(valid_options!=options->count()) | |
| throw Exception("parser.runtime", | |
| method_name, | |
| "called with invalid option"); | |
| } else | } else |
| throw Exception("parser.runtime", | throw Exception("parser.runtime", |
| &method_name, | method_name, |
| "options must be hash"); | "options must be hash"); |
| } | } |
| if(!limit) // zero limit = sould be 'nothing to copy', for methods zero means 'all' | |
| limit=-1; // thus fixing | |
| } | } |
| static void _create(Request& r, const String& method_name, MethodParams *params) { | static void _create(Request& r, StringPtr method_name, MethodParams* params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| // clone/copy part? | // clone/copy part? |
| if(const Table *source=params->get(0).get_table()) { | if(const Table *source=(*params)[0]->get_table()) { |
| int offset, limit; | int offset, limit; |
| get_copy_options(r, method_name, params, 1, *source, | get_copy_options(r, method_name, params, 1, *source, |
| offset, limit); | offset, limit); |
| static_cast<VTable *>(r.self)->set_table(*new(pool) Table(pool, *source, offset, limit)); | GET_SELF(r, VTable).set_table(TablePtr(new Table(*source, offset, limit))); |
| return; | return; |
| } | } |
| // data is last parameter | // data is last parameter |
| Temp_lang temp_lang(r, String::UL_PASS_APPENDED); | Temp_lang temp_lang(r, String::UL_PASS_APPENDED); |
| const String& data= | StringPtr data= |
| r.process_to_string(params->as_junction(params->size()-1, "body must be code")); | r.process_to_string(params->as_junction(params->count()-1, "body must be code")); |
| size_t pos_after=0; | size_t pos_after=0; |
| // parse columns | // parse columns |
| Array *columns; | Table::columns_type columns; |
| if(params->size()==2) { | if(params->count()==2) { |
| columns=0; | columns=Table::columns_type(0); // nameless |
| } else { | } else { |
| columns=new(pool) Array(pool); | columns=Table::columns_type(new ArrayString); |
| Array head(pool); | ArrayString head; |
| data.split(head, &pos_after, "\n", 1, String::UL_AS_IS, 1); | data->split(head, &pos_after, "\n", 1, String::UL_AS_IS, 1); |
| if(head.size()) | if(head.count()) |
| head.get_string(0)->split(*columns, 0, "\t", 1, String::UL_AS_IS); | head[0]->split(*columns, 0, "\t", 1, String::UL_AS_IS); |
| } | } |
| Table& table=*new(pool) Table(pool, &method_name, columns); | TablePtr table(new Table(method_name, columns)); |
| // parse cells | // parse cells |
| Array rows(pool); | |
| data.split(rows, &pos_after, "\n", 1, String::UL_AS_IS); | ArrayString rows; |
| Array_iter i(rows); | data->split(rows, &pos_after, "\n", 1, String::UL_AS_IS); |
| Array_iterator<StringPtr> i(rows); | |
| while(i.has_next()) { | while(i.has_next()) { |
| Array& row=*new(pool) Array(pool); | Table::element_type row(new ArrayString); |
| const String& string=*i.next_string(); | StringPtr string=i.next(); |
| // remove comment lines | // remove comment lines |
| if(!string.size()) | if(!string->size()) |
| continue; | continue; |
| string.split(row, 0, "\t", 1, String::UL_AS_IS); | string->split(*row, 0, "\t", 1, String::UL_AS_IS); |
| table+=&row; | *table+=row; |
| } | } |
| // replace any previous table value | // replace any previous table value |
| static_cast<VTable *>(r.self)->set_table(table); | GET_SELF(r, VTable).set_table(table); |
| } | } |
| static void _load(Request& r, const String& method_name, MethodParams *params) { | static void _load(Request& r, StringPtr method_name, MethodParams* params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| // filename is last parameter | StringPtr first_param=params->as_string(0, "file name must be string"); |
| Value& vfile_name=params->as_no_junction(params->size()-1, | int filename_param_index=0; |
| "file name must not be code"); | bool nameless=*first_param=="nameless"; |
| if(nameless) | |
| filename_param_index++; | |
| int options_param_index=filename_param_index+1; | |
| // loading text | // loading text |
| char *data=file_read_text(pool, r.absolute(vfile_name.as_string())); | char *data=file_read_text(pool, r.charsets.source(), |
| r.absolute(params->as_string(filename_param_index, "file name must be string")), | |
| true, | |
| options_param_index<params->count()?params->as_no_junction(options_param_index, "additional params must be hash")->get_hash(method_name):0 | |
| ); | |
| // parse columns | // parse columns |
| Array *columns; | Table::columns_type columns; |
| #ifndef NO_STRING_ORIGIN | #ifndef NO_STRING_ORIGIN |
| const Origin& origin=method_name.origin(); | const String_fragment::Origin& origin=method_name->origin(); |
| const char *file=origin.file; | const char* file=origin.file; |
| uint line=origin.line; | uint line=origin.line; |
| #endif | #endif |
| if(params->size()==2) { | if(nameless) { |
| columns=0; // nameless | columns=Table::columns_type(0); // nameless |
| } else { | } else { |
| columns=new(pool) Array(pool); | columns=Table::columns_type(new ArrayString); |
| while(char *row_chars=getrow(&data)) { | while(char *row_chars=getrow(&data)) { |
| // remove empty&comment lines | // remove empty&comment lines |
| if(!*row_chars || *row_chars == '#') | if(!*row_chars || *row_chars == '#') |
| continue; | continue; |
| do { | do { |
| String *name=new(pool) String(pool); | StringPtr name(new String); |
| name->APPEND_TAINTED(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 150 static void _load(Request& r, const Stri | Line 189 static void _load(Request& r, const Stri |
| } | } |
| // parse cells | // parse cells |
| Table& table=*new(pool) Table(pool, &method_name, columns); | TablePtr table(new Table(method_name, columns)); |
| char *row_chars; | char *row_chars; |
| while(row_chars=getrow(&data)) { | while(row_chars=getrow(&data)) { |
| // remove empty&comment lines | // remove empty&comment lines |
| if(!*row_chars || *row_chars == '#') | if(!*row_chars || *row_chars == '#') |
| continue; | continue; |
| Array *row=new(pool) Array(pool); | Table::element_type row(new ArrayString); |
| while(char *cell_chars=lsplit(&row_chars, '\t')) { | while(char *cell_chars=lsplit(&row_chars, '\t')) { |
| String *cell=new(pool) String(pool); | StringPtr cell(new String); |
| cell->APPEND_TAINTED(cell_chars, 0, file, line); | cell->APPEND_TAINTED(cell_chars, 0, file, line); |
| *row+=cell; | *row+=cell; |
| } | } |
| #ifndef NO_STRING_ORIGIN | #ifndef NO_STRING_ORIGIN |
| line++; | line++; |
| #endif | #endif |
| table+=row; | *table+=row; |
| }; | }; |
| // replace any previous table value | // replace any previous table value |
| static_cast<VTable *>(r.self)->set_table(table); | GET_SELF(r, VTable).set_table(table); |
| } | } |
| /// @todo "x\nx" "xxx""xx" | /// @todo "x\nx" "xxx""xx" |
| static void _save(Request& r, const String& method_name, MethodParams *params) { | static void _save(Request& r, StringPtr method_name, MethodParams* params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Value& vfile_name=params->as_no_junction(params->size()-1, | ValuePtr vfile_name=params->as_no_junction(params->count()-1, |
| "file name must not be code"); | "file name must not be code"); |
| Table& table=static_cast<VTable *>(r.self)->table(&method_name); | Table& table=GET_SELF(r, VTable).table(method_name); |
| bool do_append=false; | bool do_append=false; |
| String sdata(pool); | String sdata; |
| if(params->size()==1) { // named output | if(params->count()==1) { // named output |
| // write out names line | // write out names line |
| if(table.columns()) { // named table | if(table.columns()) { // named table |
| Array_iter i(*table.columns()); | Array_iterator<StringPtr> i(*table.columns()); |
| while(i.has_next()) { | while(i.has_next()) { |
| sdata.append(*i.next_string(), //*static_cast<String *>(table.columns()->quick_get(column)), | sdata.append(*i.next(), String::UL_TABLE); |
| String::UL_TABLE); | |
| if(i.has_next()) | if(i.has_next()) |
| sdata.APPEND_CONST("\t"); | sdata.APPEND_CONST("\t"); |
| } | } |
| } else { // nameless table | } else { // nameless table |
| if(int lsize=table.size()?static_cast<Array *>(table.get(0))->size():0) | if(int lsize=table.count()?table[0]->count():0) |
| for(int column=0; column<lsize; column++) { | for(int column=0; column<lsize; column++) { |
| char *cindex_tab=(char *)pool.malloc(MAX_NUMBER); | char *cindex_tab=new(pool) char[MAX_NUMBER]; |
| snprintf(cindex_tab, MAX_NUMBER, "%d\t", column); | snprintf(cindex_tab, MAX_NUMBER, "%d\t", column); |
| sdata.APPEND_CONST(cindex_tab); | sdata.APPEND_CONST(cindex_tab); |
| } | } |
| Line 204 static void _save(Request& r, const Stri | Line 242 static void _save(Request& r, const Stri |
| } | } |
| sdata.APPEND_CONST("\n"); | sdata.APPEND_CONST("\n"); |
| } else { // mode specified | } else { // mode specified |
| const String& mode=params->as_string(0, "mode must be string"); | StringPtr mode=params->as_string(0, "mode must be string"); |
| if(mode=="append") | if(*mode=="append") |
| do_append=true; | do_append=true; |
| else if(mode=="nameless") | else if(*mode=="nameless") |
| /*ok, already skipped names output*/; | /*ok, already skipped names output*/; |
| else | else |
| throw Exception("parser.runtime", | throw Exception("parser.runtime", |
| &mode, | mode, |
| "unknown mode, must be 'append'"); | "unknown mode, must be 'append'"); |
| } | } |
| // data lines | // data lines |
| Array_iter i(table); | Array_iterator<ArrayStringPtr> i(table); |
| while(i.has_next()) { | while(i.has_next()) { |
| Array_iter c(*static_cast<Array *>(i.next())); | Array_iterator<StringPtr> c(*i.next()); |
| while(c.has_next()) { | while(c.has_next()) { |
| if(const String *s=c.next_string()) | if(StringPtr s=c.next()) |
| sdata.append(*s, | sdata.append(*s, String::UL_TABLE); |
| String::UL_TABLE); | |
| if(c.has_next()) | if(c.has_next()) |
| sdata.APPEND_CONST("\t"); | sdata.APPEND_CONST("\t"); |
| } | } |
| Line 230 static void _save(Request& r, const Stri | Line 267 static void _save(Request& r, const Stri |
| } | } |
| // write | // write |
| file_write(r.absolute(vfile_name.as_string()), | file_write(r.absolute(vfile_name->as_string(&pool)), |
| sdata.cstr(), sdata.size(), true, do_append); | sdata.cstr(), sdata.size(), true, do_append); |
| } | } |
| static void _count(Request& r, const String& method_name, MethodParams *) { | static void _count(Request& r, StringPtr method_name, MethodParams* ) { |
| Pool& pool=r.pool(); | int result=GET_SELF(r, VTable).table(method_name).count(); |
| int result=static_cast<VTable *>(r.self)->table(&method_name).size(); | r.write_no_lang(ValuePtr(new VInt(result))); |
| r.write_no_lang(*new(pool) VInt(pool, result)); | |
| } | } |
| static void _line(Request& r, const String& method_name, MethodParams *) { | static void _line(Request& r, StringPtr method_name, MethodParams* ) { |
| Pool& pool=r.pool(); | int result=1+GET_SELF(r, VTable).table(method_name).current(); |
| int result=1+static_cast<VTable *>(r.self)->table(&method_name).current(); | r.write_no_lang(ValuePtr(new VInt(result))); |
| r.write_no_lang(*new(pool) VInt(pool, result)); | |
| } | } |
| static void _offset(Request& r, const String& method_name, MethodParams *params) { | static void _offset(Request& r, StringPtr method_name, MethodParams* params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Table& table=static_cast<VTable *>(r.self)->table(&method_name); | Table& table=GET_SELF(r, VTable).table(method_name); |
| if(params->size()) { | if(params->count()) { |
| bool absolute=false; | bool absolute=false; |
| if(params->size()>1) { | if(params->count()>1) { |
| const String& whence=params->as_string(0, "whence must be string"); | StringPtr whence=params->as_string(0, "whence must be string"); |
| if(whence=="cur") | if(*whence=="cur") |
| absolute=false; | absolute=false; |
| else if(whence=="set") | else if(*whence=="set") |
| absolute=true; | absolute=true; |
| else | else |
| throw Exception("parser.runtime", | throw Exception("parser.runtime", |
| &whence, | whence, |
| "is invalid whence, valid are 'cur' or 'set'"); | "is invalid whence, valid are 'cur' or 'set'"); |
| } | } |
| Value& offset_expr=params->as_junction(params->size()-1, "offset must be expression"); | ValuePtr offset_expr=params->as_junction(params->count()-1, "offset must be expression"); |
| table.offset(absolute, r.process_to_value(offset_expr).as_int()); | table.offset(absolute, r.process_to_value(offset_expr)->as_int()); |
| } else | } else |
| r.write_no_lang(*new(pool) VInt(pool, table.current())); | r.write_no_lang(ValuePtr(new VInt(table.current()))); |
| } | } |
| static void _menu(Request& r, const String& method_name, MethodParams *params) { | static void _menu(Request& r, StringPtr method_name, MethodParams* params) { |
| Value& body_code=params->as_junction(0, "body must be code"); | ValuePtr body_code=params->as_junction(0, "body must be code"); |
| Value *delim_maybe_code=params->size()>1?¶ms->get(1):0; | ValuePtr delim_maybe_code=params->count()>1?(*params)[1]:ValuePtr(0); |
| Table& table=static_cast<VTable *>(r.self)->table(&method_name); | Table& table=GET_SELF(r, VTable).table(method_name); |
| bool need_delim=false; | bool need_delim=false; |
| int saved_current=table.current(); | int saved_current=table.current(); |
| int size=table.size(); | int size=table.count(); |
| for(int row=0; row<size; row++) { | for(int row=0; row<size; row++) { |
| table.set_current(row); | table.set_current(row); |
| StringOrValue sv_processed=r.process(body_code); | StringOrValue sv_processed=r.process(body_code); |
| const String *s_processed=sv_processed.get_string(); | StringPtr s_processed=sv_processed.get_string(); |
| if(delim_maybe_code && s_processed && s_processed->size()) { // delimiter set and we have body | if(delim_maybe_code && s_processed && s_processed->size()) { // delimiter set and we have body |
| if(need_delim) // need delim & iteration produced string? | if(need_delim) // need delim & iteration produced string? |
| r.write_pass_lang(r.process(*delim_maybe_code)); | r.write_pass_lang(r.process(delim_maybe_code)); |
| need_delim=true; | need_delim=true; |
| } | } |
| r.write_pass_lang(sv_processed); | r.write_pass_lang(sv_processed); |
| Line 295 static void _menu(Request& r, const Stri | Line 330 static void _menu(Request& r, const Stri |
| #ifndef DOXYGEN | #ifndef DOXYGEN |
| struct Row_info { | struct Row_info { |
| Request *r; | |
| Table *table; | Table *table; |
| ValuePtr key_code; | |
| int key_field; | int key_field; |
| Array *value_fields; | Array<int>* value_fields; |
| Hash *hash; | HashStringValue* hash; |
| bool distinct; | |
| int row; | |
| }; | }; |
| #endif | #endif |
| static void table_row_to_hash(Array::Item *value, void *info) { | static void table_row_to_hash(Table::element_type row, Row_info *info) { |
| Array& row=*static_cast<Array *>(value); | Pool& pool=info->r->pool(); |
| Row_info& ri=*static_cast<Row_info *>(info); | |
| Pool& pool=ri.table->pool(); | StringPtr key; |
| if(info->key_code) { | |
| if(ri.key_field<row.size()) { | info->table->set_current(info->row++); // change context row |
| VHash& result=*new(pool) VHash(pool); | StringOrValue sv_processed=info->r->process(info->key_code); |
| Hash& hash=*result.get_hash(0); | key=sv_processed.as_string(&pool); |
| for(int i=0; i<ri.value_fields->size(); i++) { | } else |
| int value_field=ri.value_fields->get_int(i); | key=info->key_field<row->count()?row->get(info->key_field):StringPtr(0); |
| if(value_field<row.size()) | |
| hash.put( | if(!key) |
| *ri.table->columns()->get_string(value_field), | return; // ignore rows without key [too-short-record_array if-indexed] |
| new(pool) VString(*row.get_string(value_field))); | |
| } | |
| ri.hash->put(*row.get_string(ri.key_field), &result); | VHashPtr vhash(new VHash); |
| HashStringValue& hash=vhash->hash(); | |
| for(int i=0; i<info->value_fields->count(); i++) { | |
| int value_field=info->value_fields->get(i); | |
| if(value_field<row->count()) | |
| hash.put( | |
| info->table->columns()->get(value_field), | |
| ValuePtr(new VString(row->get(value_field)))); | |
| } | } |
| if(info->hash->put_dont_replace(key, vhash)) // put. existed? | |
| if(!info->distinct) | |
| throw Exception("parser.runtime", | |
| key, | |
| "duplicate key"); | |
| } | } |
| static void _hash(Request& r, const String& method_name, MethodParams *params) { | static void _hash(Request& r, StringPtr method_name, MethodParams* params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Table& self_table=static_cast<VTable *>(r.self)->table(&method_name); | Table& self_table=GET_SELF(r, VTable).table(method_name); |
| Value& result=*new(pool) VHash(pool); | VHashPtr result(new VHash); |
| if(const Array *columns=self_table.columns()) | if(Table::columns_type columns=self_table.columns()) |
| if(columns->size()>0) { | if(columns->count()>0) { |
| const String& key_field_name=params->as_no_junction(0, | bool distinct=false; |
| "key field name must not be code").as_string(); | int param_index=params->count()-1; |
| int key_field=self_table.column_name2index(key_field_name, true); | if(param_index>0) { |
| if(HashStringValue* options= | |
| Array value_fields(pool); | params->as_no_junction(param_index, "param must not be code")->get_hash(method_name)) { |
| if(params->size()>1) { | --param_index; |
| Value& value_fields_param=params->as_no_junction(1, "value field(s) must not be code"); | int valid_options=0; |
| if(value_fields_param.is_string()) { | if(ValuePtr vdistinct=options->get(sql_distinct_name)) { |
| value_fields+=self_table.column_name2index(value_fields_param.as_string(), true); | valid_options++; |
| } else if(Table *value_fields_table=value_fields_param.get_table()) { | distinct=r.process_to_value(vdistinct)->as_bool(); |
| for(int i=0; i<value_fields_table->size(); i++) { | } |
| const String& value_field_name= | if(valid_options!=options->count()) |
| *static_cast<Array *>(value_fields_table->get(i))->get_string(0); | throw Exception("parser.runtime", |
| method_name, | |
| "called with invalid option"); | |
| } | |
| } | |
| if(param_index==2) // bad options param type | |
| throw Exception("parser.runtime", | |
| method_name, | |
| "options must be hash"); | |
| Array<int> value_fields; | |
| if(param_index>0) { | |
| ValuePtr value_fields_param=params->as_no_junction(param_index, "value field(s) must not be code"); | |
| if(value_fields_param->is_string()) { | |
| value_fields+=self_table.column_name2index( | |
| value_fields_param->as_string(&pool), true); | |
| } else if(Table* value_fields_table=value_fields_param->get_table()) { | |
| for(int i=0; i<value_fields_table->count(); i++) { | |
| StringPtr value_field_name= | |
| value_fields_table->get(i)->get(0); | |
| value_fields+=self_table.column_name2index(value_field_name, true); | value_fields+=self_table.column_name2index(value_field_name, true); |
| } | } |
| } else | } else |
| throw Exception("parser.runtime", | throw Exception("parser.runtime", |
| &method_name, | method_name, |
| "value field(s) must be string or self_table" | "value field(s) must be string or self_table" |
| ); | ); |
| } else { // by all columns, including key | } else { // by all columns, including key |
| for(int i=0; i<columns->size(); i++) | for(int i=0; i<columns->count(); i++) |
| value_fields+=i; | value_fields+=i; |
| } | } |
| // integers: key_field & value_fields | |
| Row_info row_info={&self_table, key_field, &value_fields, result.get_hash(0)}; | { |
| self_table.for_each(table_row_to_hash, &row_info); | Row_info info; |
| info.r=&r; | |
| info.table=&self_table; | |
| ValuePtr key_param=(*params)[0]; | |
| info.key_code=key_param->get_junction()?key_param:ValuePtr(0); | |
| info.key_field=info.key_code?-1 | |
| :self_table.column_name2index(key_param->as_string(&pool), true); | |
| info.value_fields=&value_fields; | |
| info.hash=&result->hash(); | |
| info.distinct=distinct; | |
| info.row=0; | |
| int saved_current=self_table.current(); | |
| self_table.for_each(table_row_to_hash, &info); | |
| self_table.set_current(saved_current); | |
| } | |
| } | } |
| r.write_no_lang(result); | r.write_no_lang(result); |
| } | } |
| #ifndef DOXYGEN | #ifndef DOXYGEN |
| struct Table_seq_item { | struct Table_seq_item { |
| Array *row; | ArrayString* row; |
| union { | union { |
| char *c_str; | char *c_str; |
| double d; | double d; |
| Line 383 static int sort_cmp_double(const void *a | Line 467 static int sort_cmp_double(const void *a |
| else | else |
| return 0; | return 0; |
| } | } |
| static void _sort(Request& r, const String& method_name, MethodParams *params) { | static void _sort(Request& r, StringPtr method_name, MethodParams* params) { |
| Pool& pool=r.pool(); | Pool local_pool; |
| Value& key_maker=params->as_junction(0, "key-maker must be code"); | ValuePtr key_maker=params->as_junction(0, "key-maker must be code"); |
| bool reverse=params->size()>1/*..[desc|asc|]*/? | bool reverse=params->count()>1/*..[desc|asc|]*/? |
| reverse=params->as_no_junction(1, "order must not be code").as_string()=="desc": | reverse=*params->as_no_junction(1, "order must not be code")->as_string(&local_pool)=="desc": |
| false; // default=asc | false; // default=asc |
| Table& old_table=static_cast<VTable *>(r.self)->table(&method_name); | Table& old_table=GET_SELF(r, VTable).table(method_name); |
| Table& new_table=*new(pool) Table(pool, &method_name, old_table.columns()); | TablePtr new_table(new Table(method_name, old_table.columns())); |
| Table_seq_item *seq=(Table_seq_item *)pool.malloc(sizeof(Table_seq_item)*old_table.size()); | smart_ptr<Table_seq_item> seq(new Table_seq_item[old_table.count()]); |
| int i; | int i; |
| // calculate key values | // calculate key values |
| bool key_values_are_strings=true; | bool key_values_are_strings=true; |
| // save 'current' | for(i=0; i<old_table.count(); i++) { |
| int saved_current=old_table.current(); | |
| for(i=0; i<old_table.size(); i++) { | |
| old_table.set_current(i); | old_table.set_current(i); |
| // calculate key value | // calculate key value |
| seq[i].row=(MethodParams *)old_table.get(i); | seq[i].row=old_table[i].get(); |
| Value& value=*r.process_to_value(key_maker).as_expr_result(true/*return string as-is*/); | ValuePtr value=r.process_to_value(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(); |
| if(key_values_are_strings) | if(key_values_are_strings) |
| seq[i].value.c_str=value.as_string().cstr(); | seq[i].value.c_str=value->as_string(&local_pool)->cstr(local_pool); |
| else | else |
| seq[i].value.d=value.as_double(); | seq[i].value.d=value->as_double(); |
| } | } |
| // restore 'current' | |
| old_table.set_current(saved_current); | |
| // sort keys | // sort keys |
| _qsort(seq, old_table.size(), sizeof(Table_seq_item), | _qsort(seq, old_table.count(), sizeof(Table_seq_item), |
| key_values_are_strings?sort_cmp_string:sort_cmp_double); | key_values_are_strings?sort_cmp_string:sort_cmp_double); |
| // reorder table as they require in 'seq' | // reorder table as they require in 'seq' |
| for(i=0; i<old_table.size(); i++) | for(i=0; i<old_table.count(); i++) |
| new_table+=seq[reverse?old_table.size()-1-i:i].row; | *new_table+=Table::element_type(seq[reverse?old_table.count()-1-i:i].row); |
| // replace any previous table value | // replace any previous table value |
| static_cast<VTable *>(r.self)->set_table(new_table); | GET_SELF(r, VTable).set_table(new_table); |
| } | } |
| static bool _locate_expression(Request& r, const String& method_name, MethodParams *params) { | static bool _locate_expression(Request& r, StringPtr method_name, MethodParams* params) { |
| if(params->size()>1) | if(params->count()>1) |
| throw Exception("parser.runtime", | throw Exception("parser.runtime", |
| &method_name, | method_name, |
| "locate by expression has only one parameter - expression"); | "locate by expression has only one parameter - expression"); |
| Value& expression_code=params->as_junction(0, "must be expression"); | ValuePtr expression_code=params->as_junction(0, "must be expression"); |
| Table& table=static_cast<VTable *>(r.self)->table(&method_name); | Table& table=GET_SELF(r, VTable).table(method_name); |
| int saved_current=table.current(); | int saved_current=table.current(); |
| int size=table.size(); | int size=table.count(); |
| for(int row=0; row<size; row++) { | for(int row=0; row<size; row++) { |
| table.set_current(row); | table.set_current(row); |
| if(r.process_to_value(expression_code).as_bool()) | if(r.process_to_value(expression_code)->as_bool()) |
| return true; | return true; |
| } | } |
| table.set_current(saved_current); | table.set_current(saved_current); |
| return false; | return false; |
| } | } |
| static bool _locate_name_value(Request& r, const String& method_name, MethodParams *params) { | static bool _locate_name_value(Request& r, StringPtr method_name, MethodParams* params) { |
| if(params->size()>2) | if(params->count()>2) |
| throw Exception("parser.runtime", | throw Exception("parser.runtime", |
| &method_name, | method_name, |
| "locate by name and value has only two parameters - name and value"); | "locate by name and value has only two parameters - name and value"); |
| Table& table=static_cast<VTable *>(r.self)->table(&method_name); | Table& table=GET_SELF(r, VTable).table(method_name); |
| return table.locate( | return table.locate( |
| params->as_string(0, "column name must be string"), | params->as_string(0, "column name must be string"), |
| params->as_string(1, "value must be string") | params->as_string(1, "value must be string") |
| ); | ); |
| } | } |
| static void _locate(Request& r, const String& method_name, MethodParams *params) { | static void _locate(Request& r, StringPtr method_name, MethodParams* params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| bool result=params->get(0).get_junction()? | bool result=(*params)[0]->get_junction()? |
| _locate_expression(r, method_name, params) : | _locate_expression(r, method_name, params) : |
| _locate_name_value(r, method_name, params); | _locate_name_value(r, method_name, params); |
| r.write_no_lang(*new(pool) VBool(pool, result)); | r.write_no_lang(ValuePtr(new VBool(result))); |
| } | } |
| static void _flip(Request& r, const String& method_name, MethodParams *params) { | static void _flip(Request& r, StringPtr method_name, MethodParams* params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Table& old_table=static_cast<VTable *>(r.self)->table(&method_name); | Table& old_table=GET_SELF(r, VTable).table(method_name); |
| Table& new_table=*new(pool) Table(pool, &method_name, 0/*nameless*/); | TablePtr new_table(new Table(method_name, old_table.columns())); |
| if(old_table.size()) | if(old_table.count()) |
| if(int old_cols=old_table.at(0).size()) | if(int old_cols=old_table[0]->count()) |
| for(int column=0; column<old_cols; column++) { | for(int column=0; column<old_cols; column++) { |
| Array& new_row=*new(pool) Array(pool, old_table.size()); | Table::element_type new_row(new ArrayString(old_table.count())); |
| for(int i=0; i<old_table.size(); i++) { | for(int i=0; i<old_table.count(); i++) { |
| const Array& old_row=old_table.at(i); | Table::element_type old_row=old_table[i]; |
| new_row+=column<old_row.size()?old_row.get(column):new(pool) String(pool); | *new_row+=column<old_row->count()?old_row->get(column):StringPtr(new String); |
| } | } |
| new_table+=&new_row; | *new_table+=new_row; |
| } | } |
| r.write_no_lang(*new(pool) VTable(pool, &new_table)); | r.write_no_lang(ValuePtr(new VTable(new_table))); |
| } | } |
| static void _append(Request& r, const String& method_name, MethodParams *params) { | static void _append(Request& r, StringPtr method_name, MethodParams* params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| // data | // data |
| Temp_lang temp_lang(r, String::UL_PASS_APPENDED); | Temp_lang temp_lang(r, String::UL_PASS_APPENDED); |
| const String& string= | StringPtr string=r.process_to_string(params->as_junction(0, "body must be code")); |
| r.process_to_string(params->as_junction(0, "body must be code")); | |
| // parse cells | // parse cells |
| Array& row=*new(pool) Array(pool); | ArrayStringPtr row(new ArrayString); |
| string.split(row, 0, "\t", 1, String::UL_AS_IS); | string->split(*row, 0, "\t", 1, String::UL_AS_IS); |
| static_cast<VTable *>(r.self)->table(&method_name)+=&row; | GET_SELF(r, VTable).table(method_name)+=row; |
| } | } |
| static void _join(Request& r, const String& method_name, MethodParams *params) { | static void _join(Request& r, StringPtr method_name, MethodParams* params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Table *maybe_src=params->as_no_junction(0, "table ref must not be code").get_table(); | Table* maybe_src=params->as_no_junction(0, "table ref must not be code")->get_table(); |
| if(!maybe_src) | if(!maybe_src) |
| throw Exception("parser.runtime", | throw Exception("parser.runtime", |
| &method_name, | method_name, |
| "source is not a table"); | "source is not a table"); |
| Table& src=*maybe_src; | Table& src=*maybe_src; |
| Table& dest=static_cast<VTable *>(r.self)->table(&method_name); | Table& dest=GET_SELF(r, VTable).table(method_name); |
| if(&src == &dest) | if(&src == &dest) |
| throw Exception("parser.runtime", | throw Exception("parser.runtime", |
| &method_name, | method_name, |
| "source and destination are same table"); | "source and destination are same table"); |
| int offset, limit; | int offset, limit; |
| get_copy_options(r, method_name, params, 1, src, | get_copy_options(r, method_name, params, 1, src, |
| offset, limit); | offset, limit); |
| if(const Array *dest_columns=dest.columns()) { // dest is named | if(Table::columns_type dest_columns=dest.columns()) { // dest is named |
| int saved_src_current=src.current(); | int saved_src_current=src.current(); |
| int m=src.size()-offset; | int m=src.count()-offset; |
| if(!limit || limit>m) | if(!limit || limit>m) |
| limit=m; | limit=m; |
| int end=offset+limit; | int end=offset+limit; |
| for(int src_row=offset; src_row<end; src_row++) { | for(int src_row=offset; src_row<end; src_row++) { |
| src.set_current(src_row); | src.set_current(src_row); |
| Array& dest_row=*new(pool) Array(pool); | Table::element_type dest_row(new ArrayString(src.count())); |
| for(int dest_column=0; dest_column<dest_columns->size(); dest_column++) { | for(int dest_column=0; dest_column<dest_columns->count(); dest_column++) { |
| const String *src_item=src.item(*dest_columns->get_string(dest_column)); | StringPtr src_item=src.item(dest_columns->get(dest_column)); |
| dest_row+=src_item?src_item:new(pool) String(pool); | *dest_row+=src_item?src_item:StringPtr(new String); |
| } | } |
| dest+=&dest_row; | dest+=dest_row; |
| } | } |
| src.set_current(saved_src_current); | src.set_current(saved_src_current); |
| } else { // dest is nameless | } else { // dest is nameless |
| for(int src_row=0; src_row<src.size(); src_row++) | for(int src_row=0; src_row<src.count(); src_row++) |
| dest+=&src.at(src_row); | dest+=src[src_row]; |
| } | } |
| } | } |
| #ifndef DOXYGEN | #ifndef DOXYGEN |
| class Table_sql_event_handlers : public SQL_Driver_query_event_handlers { | class Table_sql_event_handlers: public SQL_Driver_query_event_handlers { |
| StringPtr method_name; | |
| StringPtr statement_string; const char* statement_cstr; | |
| ArrayStringPtr columns; | |
| ArrayString* row; | |
| public: | public: |
| Table_sql_event_handlers(Pool& apool, const String& amethod_name, | TablePtr table; |
| const String& astatement_string, const char *astatement_cstr) : | |
| pool(apool), | |
| method_name(amethod_name), | |
| statement_string(astatement_string), | |
| statement_cstr(astatement_cstr), | |
| columns(*new(pool) Array(pool)), | |
| row(0), | |
| table(0) | |
| { | |
| } | |
| void add_column(void *ptr, size_t size) { | |
| String *column=new(pool) String(pool); | |
| column->APPEND_TAINTED( | |
| (const char *)ptr, size, | |
| statement_cstr, 0); | |
| columns+=column; | |
| } | |
| void before_rows() { | |
| table=new(pool) Table(pool, &method_name, &columns); | |
| } | |
| void add_row() { | |
| (*table)+=(row=new(pool) Array(pool)); | |
| } | |
| void add_row_cell(void *ptr, size_t size) { | |
| String *cell=new(pool) String(pool); | |
| if(size) | |
| cell->APPEND_TAINTED( | |
| (const char *)ptr, size, | |
| statement_cstr, table->size()-1); | |
| (*row)+=cell; | |
| } | |
| private: | |
| Pool& pool; | |
| const String& method_name; | |
| const String& statement_string; const char *statement_cstr; | |
| Array& columns; | |
| Array *row; | |
| public: | public: |
| Table *table; | Table_sql_event_handlers(StringPtr amethod_name, |
| StringPtr astatement_string, const char* astatement_cstr) : | |
| method_name(amethod_name), | |
| statement_string(astatement_string), statement_cstr(astatement_cstr), | |
| columns(new ArrayString), row(0) { | |
| } | |
| bool add_column(SQL_Error& error, void *ptr, size_t size) { | |
| try { | |
| StringPtr column(new String); | |
| column->APPEND_TAINTED( | |
| (const char* )ptr, size, | |
| statement_cstr, 0); | |
| *columns+=column; | |
| return false; | |
| } catch(...) { | |
| error=SQL_Error("exception occured in Table_sql_event_handlers::add_column"); | |
| return true; | |
| } | |
| } | |
| bool before_rows(SQL_Error& error) { | |
| try { | |
| table=TablePtr(new Table( method_name, columns)); | |
| return false; | |
| } catch(...) { | |
| error=SQL_Error("exception occured in Table_sql_event_handlers::before_rows"); | |
| return true; | |
| } | |
| } | |
| bool add_row(SQL_Error& error) { | |
| try { | |
| *table+=(ArrayStringPtr(row=new ArrayString)); | |
| return false; | |
| } catch(...) { | |
| error=SQL_Error("exception occured in Table_sql_event_handlers::add_row"); | |
| return true; | |
| } | |
| } | |
| bool add_row_cell(SQL_Error& error, void *ptr, size_t size) { | |
| try { | |
| StringPtr cell(new String); | |
| if(size) | |
| cell->APPEND_TAINTED( | |
| (const char* )ptr, size, | |
| statement_cstr, table->count()-1); | |
| *row+=cell; | |
| return false; | |
| } catch(...) { | |
| error=SQL_Error("exception occured in Table_sql_event_handlers::add_row_cell"); | |
| return true; | |
| } | |
| } | |
| }; | }; |
| #endif | #endif |
| static void _sql(Request& r, const String& method_name, MethodParams *params) { | static void _sql(Request& r, StringPtr method_name, MethodParams* params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Value& statement=params->as_junction(0, "statement must be code"); | ValuePtr statement=params->as_junction(0, "statement must be code"); |
| ulong limit=0; | ulong limit=0; |
| ulong offset=0; | ulong offset=0; |
| if(params->size()>1) { | if(params->count()>1) { |
| Value& voptions=params->as_no_junction(1, "options must be hash, not code"); | ValuePtr voptions=params->as_no_junction(1, "options must be hash, not code"); |
| if(!voptions.is_string()) | if(!voptions->is_string()) |
| if(Hash *options=voptions.get_hash(&method_name)) { | if(HashStringValue* options=voptions->get_hash(method_name)) { |
| if(Value *vlimit=(Value *)options->get(*sql_limit_name)) | int valid_options=0; |
| limit=(ulong)r.process_to_value(*vlimit).as_double(); | if(ValuePtr vlimit=options->get(sql_limit_name)) { |
| if(Value *voffset=(Value *)options->get(*sql_offset_name)) | valid_options++; |
| offset=(ulong)r.process_to_value(*voffset).as_double(); | limit=(ulong)r.process_to_value(vlimit)->as_double(); |
| } | |
| if(ValuePtr voffset=options->get(sql_offset_name)) { | |
| valid_options++; | |
| offset=(ulong)r.process_to_value(voffset)->as_double(); | |
| } | |
| if(valid_options!=options->count()) | |
| throw Exception("parser.runtime", | |
| method_name, | |
| "called with invalid option"); | |
| } else | } else |
| throw Exception("parser.runtime", | throw Exception("parser.runtime", |
| &method_name, | method_name, |
| "options must be hash"); | "options must be hash"); |
| } | } |
| Temp_lang temp_lang(r, String::UL_SQL); | Temp_lang temp_lang(r, String::UL_SQL); |
| const String& statement_string=r.process_to_string(statement); | StringPtr statement_string=r.process_to_string(statement); |
| const char *statement_cstr= | const char* statement_cstr= |
| statement_string.cstr(String::UL_UNSPECIFIED, r.connection(&method_name)); | statement_string->cstr(pool, String::UL_UNSPECIFIED, r.connection(method_name)); |
| Table_sql_event_handlers handlers(pool, method_name, | Table_sql_event_handlers handlers(method_name, |
| statement_string, statement_cstr); | statement_string, statement_cstr); |
| #ifdef RESOURCES_DEBUG | #ifdef RESOURCES_DEBUG |
| struct timeval mt[2]; | struct timeval mt[2]; |
| //measure:before | //measure:before |
| gettimeofday(&mt[0],NULL); | gettimeofday(&mt[0],NULL); |
| #endif | #endif |
| r.connection(&method_name)->query( | r.connection(method_name)->query( |
| statement_cstr, offset, limit, | statement_cstr, offset, limit, |
| handlers, | handlers, |
| statement_string); | statement_string); |
| Line 637 static void _sql(Request& r, const Strin | Line 741 static void _sql(Request& r, const Strin |
| r.sql_request_time+=t[1]-t[0]; | r.sql_request_time+=t[1]-t[0]; |
| #endif | #endif |
| Table *result= | TablePtr result= |
| handlers.table?handlers.table: // query resulted in table? return it | handlers.table?handlers.table: // query resulted in table? return it |
| new(pool) Table(pool, &method_name, 0); // query returned no table, fake it | TablePtr(new Table(method_name, Table::columns_type(0))); // query returned no table, fake it |
| // replace any previous table value | // replace any previous table value |
| static_cast<VTable *>(r.self)->set_table(*result); | GET_SELF(r, VTable).set_table(result); |
| } | } |
| static void _columns(Request& r, const String& method_name, MethodParams *) { | static void _columns(Request& r, StringPtr method_name, MethodParams* ) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Array& result_columns=*new(pool) Array(pool); | Table::columns_type result_columns(new ArrayString); |
| result_columns+=new(pool) String(pool, "column"); | *result_columns+=StringPtr(new String("column")); |
| Table& result_table=*new(pool) Table(pool, &method_name, &result_columns); | TablePtr result_table(new Table(method_name, result_columns)); |
| Table& source_table=static_cast<VTable *>(r.self)->table(&method_name); | Table& source_table=GET_SELF(r, VTable).table(method_name); |
| if(const Array *source_columns=source_table.columns()) { | if(Table::columns_type source_columns=source_table.columns()) { |
| Array_iter i(*source_columns); | Array_iterator<StringPtr> i(*source_columns); |
| while(i.has_next()) { | while(i.has_next()) { |
| Array& result_row=*new(pool) Array(pool); | Table::element_type result_row(new ArrayString); |
| result_row+=i.next(); | *result_row+=i.next(); |
| result_table+=&result_row; | *result_table+=result_row; |
| } | } |
| } | } |
| r.write_no_lang(*new(pool) VTable(pool, &result_table)); | r.write_no_lang(ValuePtr(new VTable(result_table))); |
| } | } |
| static void _select(Request& r, const String& method_name, MethodParams *params) { | static void _select(Request& r, StringPtr method_name, MethodParams* params) { |
| Pool& pool=r.pool(); | Pool& pool=r.pool(); |
| Value& vcondition=params->as_junction(0, "condition must be expression"); | ValuePtr vcondition=params->as_junction(0, "condition must be expression"); |
| Table& source_table=static_cast<VTable *>(r.self)->table(&method_name); | Table& source_table=GET_SELF(r, VTable).table(method_name); |
| Table& result_table=*new(pool) Table(pool, | TablePtr result_table(new Table( |
| source_table.origin_string(), | source_table.origin_string(), |
| source_table.columns() | source_table.columns() |
| ); | )); |
| int saved_current=source_table.current(); | int saved_current=source_table.current(); |
| int size=source_table.size(); | int size=source_table.count(); |
| for(int row=0; row<size; row++) { | for(int row=0; row<size; row++) { |
| source_table.set_current(row); | source_table.set_current(row); |
| bool condition=r.process_to_value(vcondition, | bool condition=r.process_to_value(vcondition, |
| /*0/*no name* /,*/ | /*0/*no name* /,*/ |
| false/*don't intercept string*/).as_bool(); | false/*don't intercept string*/)->as_bool(); |
| if(condition) // ...condition is true= | if(condition) // ...condition is true= |
| result_table+=&source_table.at(row); // =green light to go to result | *result_table+=source_table[row]; // =green light to go to result |
| } | } |
| source_table.set_current(saved_current); | source_table.set_current(saved_current); |
| r.write_no_lang(*new(pool) VTable(pool, &result_table)); | r.write_no_lang(ValuePtr(new VTable(result_table))); |
| } | } |
| // constructor | // constructor |
| MTable::MTable(Pool& apool) : Methoded(apool, "table") { | MTable::MTable(): Methoded("table") { |
| // ^table::create{data} | // ^table::create{data} |
| // ^table::create[nameless]{data} | // ^table::create[nameless]{data} |
| // ^table::create[table] | // ^table::create[table] |
| Line 705 MTable::MTable(Pool& apool) : Methoded(a | Line 809 MTable::MTable(Pool& apool) : Methoded(a |
| // ^table::load[file] | // ^table::load[file] |
| // ^table::load[nameless;file] | // ^table::load[nameless;file] |
| add_native_method("load", Method::CT_DYNAMIC, _load, 1, 2); | add_native_method("load", Method::CT_DYNAMIC, _load, 1, 3); |
| // ^table.save[file] | // ^table.save[file] |
| // ^table.save[nameless;file] | // ^table.save[nameless;file] |
| Line 728 MTable::MTable(Pool& apool) : Methoded(a | Line 832 MTable::MTable(Pool& apool) : Methoded(a |
| // ^table:hash[key field name] | // ^table:hash[key field name] |
| // ^table:hash[key field name][value field name(s) string/table] | // ^table:hash[key field name][value field name(s) string/table] |
| add_native_method("hash", Method::CT_DYNAMIC, _hash, 1, 2); | add_native_method("hash", Method::CT_DYNAMIC, _hash, 1, 3); |
| // ^table.sort{string-key-maker} ^table.sort{string-key-maker}[desc|asc] | // ^table.sort{string-key-maker} ^table.sort{string-key-maker}[desc|asc] |
| // ^table.sort(numeric-key-maker) ^table.sort(numeric-key-maker)[desc|asc] | // ^table.sort(numeric-key-maker) ^table.sort(numeric-key-maker)[desc|asc] |
| Line 757 MTable::MTable(Pool& apool) : Methoded(a | Line 861 MTable::MTable(Pool& apool) : Methoded(a |
| // ^table.select(expression) = table | // ^table.select(expression) = table |
| add_native_method("select", Method::CT_DYNAMIC, _select, 1, 1); | add_native_method("select", Method::CT_DYNAMIC, _select, 1, 1); |
| } | } |
| // global variable | |
| Methoded *table_class; | |
| // creator | |
| Methoded *MTable_create(Pool& pool) { | |
| return table_class=new(pool) MTable(pool); | |
| } |