|
|
| version 1.125.2.15.2.26, 2003/06/26 11:51:30 | version 1.145, 2005/08/26 12:01:38 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: @b string parser class. | Parser: @b string parser class. |
| Copyright (c) 2001-2003 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001-2005 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_STRING_C="$Date$"; | static const char * const IDENT_STRING_C="$Date$"; |
| #include "classes.h" | #include "classes.h" |
| #include "pa_vmethod_frame.h" | #include "pa_vmethod_frame.h" |
| Line 36 DECLARE_CLASS_VAR(string, new MString, 0 | Line 36 DECLARE_CLASS_VAR(string, new MString, 0 |
| // defines for statics | // defines for statics |
| #define MATCH_VAR_NAME "match" | #define MATCH_VAR_NAME "match" |
| #define TRIM_START_OPTION "start" | |
| #define TRIM_BOTH_OPTION "both" | |
| #define TRIM_END_OPTION "end" | |
| // statics | // statics |
| Line 51 static void _length(Request& r, MethodPa | Line 54 static void _length(Request& r, MethodPa |
| static void _int(Request& r, MethodParams& params) { | static void _int(Request& r, MethodParams& params) { |
| const String& self_string=GET_SELF(r, VString).string(); | const String& self_string=GET_SELF(r, VString).string(); |
| int converted; | int converted; |
| Value* default_code=params.count()>0?¶ms.as_junction(0, "default must be int") | |
| :0; // (default) | |
| try { | try { |
| if(self_string.is_empty()) | if(self_string.is_empty()) |
| throw Exception("parser.runtime", | throw Exception("parser.runtime", |
| Line 60 static void _int(Request& r, MethodParam | Line 61 static void _int(Request& r, MethodParam |
| "parameter is empty string, error converting"); | "parameter is empty string, error converting"); |
| converted=self_string.as_int(); | converted=self_string.as_int(); |
| } catch(...) { // convert problem | } catch(...) { // convert problem |
| if(default_code) | if(params.count()>0) |
| converted=r.process_to_value(*default_code).as_int(); | converted=params.as_int(0, "default must be int", r); // (default) |
| else | else |
| rethrow; // we have a problem when no default | rethrow; // we have a problem when no default |
| } | } |
| Line 71 static void _int(Request& r, MethodParam | Line 72 static void _int(Request& r, MethodParam |
| static void _double(Request& r, MethodParams& params) { | static void _double(Request& r, MethodParams& params) { |
| const String& self_string=GET_SELF(r, VString).string(); | const String& self_string=GET_SELF(r, VString).string(); |
| double converted; | double converted; |
| Value* default_code=params.count()>0?¶ms.as_junction(0, "default must be double") | |
| :0; // (default) | |
| try { | try { |
| if(self_string.is_empty()) | if(self_string.is_empty()) |
| throw Exception("parser.runtime", | throw Exception("parser.runtime", |
| Line 80 static void _double(Request& r, MethodPa | Line 79 static void _double(Request& r, MethodPa |
| "parameter is empty string, error converting"); | "parameter is empty string, error converting"); |
| converted=self_string.as_double(); | converted=self_string.as_double(); |
| } catch(...) { // convert problem | } catch(...) { // convert problem |
| if(default_code) | if(params.count()>0) |
| converted=r.process_to_value(*default_code).as_double(); | converted=params.as_double(0, "default must be double", r); // (default) |
| else | else |
| rethrow; // we have a problem when no default | rethrow; // we have a problem when no default |
| } | } |
| Line 101 static void _double(Request& r, MethodPa | Line 100 static void _double(Request& r, MethodPa |
| } | } |
| static void _left(Request& r, MethodParams& params) { | static void _left(Request& r, MethodParams& params) { |
| size_t n=(size_t)params.as_int(0, "n must be int", r); | ssize_t sn=params.as_int(0, "n must be int", r); |
| if(sn<0) | |
| throw Exception("parser.runtime", | |
| 0, | |
| "n(%d) must be >=0", sn); | |
| size_t n=(size_t)sn; | |
| const String& string=GET_SELF(r, VString).string(); | const String& string=GET_SELF(r, VString).string(); |
| r.write_assign_lang(string.mid(0, n)); | r.write_assign_lang(string.mid(0, n)); |
| } | } |
| static void _right(Request& r, MethodParams& params) { | static void _right(Request& r, MethodParams& params) { |
| size_t n=(size_t)params.as_int(0, "n must be int", r); | ssize_t sn=(size_t)params.as_int(0, "n must be int", r); |
| if(sn<0) | |
| throw Exception("parser.runtime", | |
| 0, | |
| "n(%d) must be >=0", sn); | |
| size_t n=(size_t)sn; | |
| const String& string=GET_SELF(r, VString).string(); | const String& string=GET_SELF(r, VString).string(); |
| r.write_assign_lang(string.mid(string.length()-n, string.length())); | size_t length=string.length(); |
| r.write_assign_lang(n<length?string.mid(length-n, string.length()):string); | |
| } | } |
| static void _mid(Request& r, MethodParams& params) { | static void _mid(Request& r, MethodParams& params) { |
| const String& string=GET_SELF(r, VString).string(); | const String& string=GET_SELF(r, VString).string(); |
| size_t p=(size_t)max(0, params.as_int(0, "p must be int", r)); | ssize_t sbegin=params.as_int(0, "p must be int", r); |
| size_t n=params.count()>1? | if(sbegin<0) |
| (size_t)max(0, params.as_int(1, "n must be int", r)):string.length(); | throw Exception("parser.runtime", |
| 0, | |
| "p(%d) must be >=0", sbegin); | |
| size_t begin=(size_t)sbegin; | |
| size_t end; | |
| if(params.count()>1) { | |
| ssize_t sn=params.as_int(1, "n must be int", r); | |
| if(sn<0) | |
| throw Exception("parser.runtime", | |
| 0, | |
| "n(%d) must be >=0", sn); | |
| end=begin+(size_t)sn; | |
| } else | |
| end=string.length(); | |
| r.write_assign_lang(string.mid(p, p+n)); | r.write_assign_lang(string.mid(begin, end)); |
| } | } |
| static void _pos(Request& r, MethodParams& params) { | static void _pos(Request& r, MethodParams& params) { |
| Line 131 static void _pos(Request& r, MethodParam | Line 156 static void _pos(Request& r, MethodParam |
| r.write_assign_lang(*new VInt((int)string.pos(substr.as_string()))); | r.write_assign_lang(*new VInt((int)string.pos(substr.as_string()))); |
| } | } |
| static void split_list(Request& r, | static void split_list(MethodParams& params, int paramIndex, |
| MethodParams& params, int paramIndex, | |
| const String& string, | const String& string, |
| ArrayString& result) { | ArrayString& result) { |
| Value& delim_value=params.as_no_junction(paramIndex, "delimiter must not be code"); | Value& delim_value=params.as_no_junction(paramIndex, "delimiter must not be code"); |
| Line 157 static int split_options(const String* o | Line 181 static int split_options(const String* o |
| {"r", "R", SPLIT_RIGHT, SPLIT_LEFT}, | {"r", "R", SPLIT_RIGHT, SPLIT_LEFT}, |
| {"h", "H", SPLIT_HORIZONTAL, SPLIT_VERTICAL}, | {"h", "H", SPLIT_HORIZONTAL, SPLIT_VERTICAL}, |
| {"v", "V", SPLIT_VERTICAL, SPLIT_HORIZONTAL}, | {"v", "V", SPLIT_VERTICAL, SPLIT_HORIZONTAL}, |
| {0} | {0, 0, 0, 0} |
| }; | }; |
| int result=0; | int result=0; |
| Line 176 static int split_options(const String* o | Line 200 static int split_options(const String* o |
| return result; | return result; |
| } | } |
| static Table& split_vertical(Request& r, ArrayString& pieces, bool right) { | static Table& split_vertical(ArrayString& pieces, bool right) { |
| Table::columns_type columns(new ArrayString); | Table::columns_type columns(new ArrayString); |
| *columns+=new String("piece"); | *columns+=new String("piece"); |
| Line 200 static Table& split_vertical(Request& r, | Line 223 static Table& split_vertical(Request& r, |
| return table; | return table; |
| } | } |
| static Table& split_horizontal(Request& r, ArrayString& pieces, bool right) { | static Table& split_horizontal(ArrayString& pieces, bool right) { |
| Table& table=*new Table(Table::columns_type(0) /* nameless */); | Table& table=*new Table(Table::columns_type(0) /* nameless */); |
| Table::element_type row(new ArrayString(pieces.count())); | Table::element_type row(new ArrayString(pieces.count())); |
| if(right) { // right | if(right) { // right |
| for(size_t i=pieces.count(); --i>=0; ) | for(int i=pieces.count(); --i>=0; ) |
| *row+=pieces[i]; | *row+=pieces[i]; |
| } else { // left | } else { // left |
| for(Array_iterator<const String*> i(pieces); i.has_next(); ) | for(Array_iterator<const String*> i(pieces); i.has_next(); ) |
| Line 220 static void split_with_options(Request& | Line 243 static void split_with_options(Request& |
| const String& string=GET_SELF(r, VString).string(); | const String& string=GET_SELF(r, VString).string(); |
| ArrayString pieces; | ArrayString pieces; |
| split_list(r, params, 0, string, pieces); | split_list(params, 0, string, pieces); |
| if(!bits) { | if(!bits) { |
| const String* options=0; | const String* options=0; |
| Line 232 static void split_with_options(Request& | Line 255 static void split_with_options(Request& |
| bool right=(bits & SPLIT_RIGHT) != 0; | bool right=(bits & SPLIT_RIGHT) != 0; |
| bool horizontal=(bits & SPLIT_HORIZONTAL) !=0; | bool horizontal=(bits & SPLIT_HORIZONTAL) !=0; |
| Table& table=horizontal?split_horizontal(r, pieces, right) | Table& table=horizontal?split_horizontal(pieces, right) |
| :split_vertical(r, pieces, right); | :split_vertical(pieces, right); |
| r.write_no_lang(*new VTable(&table)); | r.write_no_lang(*new VTable(&table)); |
| } | } |
| Line 311 static void _match(Request& r, MethodPar | Line 334 static void _match(Request& r, MethodPar |
| String result; | String result; |
| VTable* vtable=new VTable; | VTable* vtable=new VTable; |
| Replace_action_info info={0}; | Replace_action_info info={ |
| info.request=&r; | &r, |
| info.src=&src; | &src, |
| info.dest=&result; | &result, |
| info.vtable=vtable; | vtable, |
| info.replacement_code=&replacement_code; | &replacement_code |
| }; | |
| Temp_value_element temp_match_var( | Temp_value_element temp_match_var( |
| *replacement_code.get_junction()->method_frame, | *replacement_code.get_junction()->method_frame, |
| match_var_name, vtable); | match_var_name, vtable); |
| Line 328 static void _match(Request& r, MethodPar | Line 352 static void _match(Request& r, MethodPar |
| } | } |
| } | } |
| static void change_case(Request& r, MethodParams& params, | static void change_case(Request& r, MethodParams&, |
| String::Change_case_kind kind) { | String::Change_case_kind kind) { |
| const String& src=GET_SELF(r, VString).string(); | const String& src=GET_SELF(r, VString).string(); |
| Line 356 public: | Line 380 public: |
| got_cell(false), | got_cell(false), |
| result(*new String) {} | result(*new String) {} |
| bool add_column(SQL_Error& error, const char* str, size_t /*length*/) { | bool add_column(SQL_Error& error, const char* /*str*/, size_t /*length*/) { |
| if(got_column) { | if(got_column) { |
| error=SQL_Error("parser.runtime", | error=SQL_Error("parser.runtime", |
| //statement_string, | //statement_string, |
| Line 387 public: | Line 411 public: |
| } | } |
| }; | }; |
| #endif | #endif |
| extern String sql_bind_name; | |
| extern String sql_limit_name; | extern String sql_limit_name; |
| extern String sql_offset_name; | extern String sql_offset_name; |
| extern String sql_default_name; | extern String sql_default_name; |
| extern String sql_distinct_name; | extern String sql_distinct_name; |
| extern int marshal_binds(HashStringValue& hash, SQL_Driver::Placeholder*& placeholders); | |
| extern void unmarshal_bind_updates(HashStringValue& hash, int placeholder_count, SQL_Driver::Placeholder* placeholders); | |
| const String* sql_result_string(Request& r, MethodParams& params, | const String* sql_result_string(Request& r, MethodParams& params, |
| HashStringValue*& options, Value*& default_code) { | HashStringValue*& options, Value*& default_code) { |
| Value& statement=params.as_junction(0, "statement must be code"); | Value& statement=params.as_junction(0, "statement must be code"); |
| HashStringValue* bind=0; | |
| ulong limit=0; | ulong limit=0; |
| ulong offset=0; | ulong offset=0; |
| default_code=0; | default_code=0; |
| if(params.count()>1) { | if(params.count()>1) { |
| Value& voptions=params.as_no_junction(1, "options must be hash, not code"); | Value& voptions=params.as_no_junction(1, "options must be hash, not code"); |
| if(!voptions.is_string()) | if(voptions.is_defined() && !voptions.is_string()) |
| if(options=voptions.get_hash()) { | if((options=voptions.get_hash())) { |
| if(Value* vlimit=options->get(sql_limit_name)) | int valid_options=0; |
| if(Value* vbind=options->get(sql_bind_name)) { | |
| valid_options++; | |
| bind=vbind->get_hash(); | |
| } | |
| if(Value* vlimit=options->get(sql_limit_name)) { | |
| valid_options++; | |
| limit=(ulong)r.process_to_value(*vlimit).as_double(); | limit=(ulong)r.process_to_value(*vlimit).as_double(); |
| if(Value* voffset=options->get(sql_offset_name)) | } |
| if(Value* voffset=options->get(sql_offset_name)) { | |
| valid_options++; | |
| offset=(ulong)r.process_to_value(*voffset).as_double(); | offset=(ulong)r.process_to_value(*voffset).as_double(); |
| if(default_code=options->get(sql_default_name)) { | } |
| if(Junction* default_junction=default_code->get_junction()) | if((default_code=options->get(sql_default_name))) { |
| ;//default_junction->change_context(statement.get_junction()); | valid_options++; |
| else | if(!default_code->get_junction()) |
| throw Exception("parser.runtime", | throw Exception("parser.runtime", |
| 0, | 0, |
| "default option must be code"); | "default option must be code"); |
| } | } |
| if(valid_options!=options->count()) | |
| throw Exception("parser.runtime", | |
| 0, | |
| "called with invalid option"); | |
| } else | } else |
| throw Exception("parser.runtime", | throw Exception("parser.runtime", |
| 0, | 0, |
| Line 421 const String* sql_result_string(Request& | Line 462 const String* sql_result_string(Request& |
| } else | } else |
| options=0; | options=0; |
| SQL_Driver::Placeholder* placeholders=0; | |
| uint placeholders_count=0; | |
| if(bind) | |
| placeholders_count=marshal_binds(*bind, placeholders); | |
| Temp_lang temp_lang(r, String::L_SQL); | Temp_lang temp_lang(r, String::L_SQL); |
| const String& statement_string=r.process_to_string(statement); | const String& statement_string=r.process_to_string(statement); |
| const char* statement_cstr= | const char* statement_cstr= |
| statement_string.cstr(String::L_UNSPECIFIED, r.connection()); | statement_string.cstr(String::L_UNSPECIFIED, r.connection()); |
| String_sql_event_handlers handlers(statement_string, statement_cstr); | String_sql_event_handlers handlers(statement_string, statement_cstr); |
| r.connection()->query( | r.connection()->query( |
| statement_cstr, offset, limit, | statement_cstr, |
| placeholders_count, placeholders, | |
| offset, limit, | |
| handlers, | handlers, |
| statement_string); | statement_string); |
| if(bind) | |
| unmarshal_bind_updates(*bind, placeholders_count, placeholders); | |
| if(!handlers.got_cell) | if(!handlers.got_cell) |
| return 0; // no lines, caller should return second param[default value] | return 0; // no lines, caller should return second param[default value] |
| Line 496 static void _normalize(Request& r, Metho | Line 547 static void _normalize(Request& r, Metho |
| r.write_assign_lang(src); | r.write_assign_lang(src); |
| } | } |
| static void _trim(Request& r, MethodParams& params) { | |
| const String& src=GET_SELF(r, VString).string(); | |
| String::Trim_kind kind=String::TRIM_BOTH; | |
| const char* chars=0; | |
| if(params.count()>0) { | |
| const String& skind=params.as_string(0, | |
| "'where' must be string"); | |
| if(skind.length()) | |
| if(skind==TRIM_START_OPTION) | |
| kind=String::TRIM_START; | |
| else if(skind==TRIM_END_OPTION) | |
| kind=String::TRIM_END; | |
| else if(skind==TRIM_BOTH_OPTION) | |
| kind=String::TRIM_BOTH; | |
| else | |
| throw Exception("parser.runtime", | |
| &skind, | |
| "'kind' must be one of "TRIM_START_OPTION", "TRIM_BOTH_OPTION", "TRIM_END_OPTION); | |
| if(params.count()>1) { | |
| const String& schars=params.as_string(1, "'chars' must be string"); | |
| if(schars.length()) | |
| chars=schars.cstr(); | |
| } | |
| } | |
| r.write_assign_lang(src.trim(kind, chars)); | |
| } | |
| static void _append(Request& r, MethodParams& params) { | |
| // c=a+b | |
| VString& va=GET_SELF(r, VString); | |
| const String& a=va.string(); | |
| const String& b=params.as_string(0, "parameter must be string"); | |
| String& c=*new String(a); | |
| c.append(b, String::L_PASS_APPENDED); | |
| va.set_string(c); | |
| } | |
| // constructor | // constructor |
| MString::MString(): Methoded("string") { | MString::MString(): Methoded("string") { |
| Line 541 MString::MString(): Methoded("string") { | Line 632 MString::MString(): Methoded("string") { |
| add_native_method("lower", Method::CT_DYNAMIC, _lower, 0, 0); | add_native_method("lower", Method::CT_DYNAMIC, _lower, 0, 0); |
| // ^sql[query] | // ^sql[query] |
| // ^sql[query][$.limit(1) $.offset(2) $.default[n/a]] | // ^sql[query][options hash] |
| add_native_method("sql", Method::CT_STATIC, _sql, 1, 2); | add_native_method("sql", Method::CT_STATIC, _sql, 1, 2); |
| // ^string.replace[table] | // ^string.replace[table] |
| Line 552 MString::MString(): Methoded("string") { | Line 643 MString::MString(): Methoded("string") { |
| // ^string.normalize[] | // ^string.normalize[] |
| add_native_method("normalize", Method::CT_DYNAMIC, _normalize, 0, 0); | add_native_method("normalize", Method::CT_DYNAMIC, _normalize, 0, 0); |
| // ^string.trim[[start|both|end][;chars]] | |
| add_native_method("trim", Method::CT_DYNAMIC, _trim, 0, 2); | |
| // ^string.append[string] | |
| add_native_method("append", Method::CT_DYNAMIC, _append, 1, 1); | |
| } | } |