|
|
| version 1.136, 2004/03/01 08:54:16 | version 1.154, 2007/08/20 10:02:51 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: @b string parser class. | Parser: @b string parser class. |
| Copyright (c) 2001-2004 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) |
| */ | */ |
| Line 54 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, |
| 0, | 0, |
| "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 74 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, |
| 0, | 0, |
| "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 92 static void _double(Request& r, MethodPa | Line 88 static void _double(Request& r, MethodPa |
| r.write_no_lang(*new VDouble(converted)); | r.write_no_lang(*new VDouble(converted)); |
| } | } |
| static void _bool(Request& r, MethodParams& params) { | |
| const String& self_string=GET_SELF(r, VString).string(); | |
| bool converted; | |
| try { | |
| if(self_string.is_empty()) | |
| throw Exception(PARSER_RUNTIME, | |
| 0, | |
| "parameter is empty string, error converting"); | |
| converted=self_string.as_bool(); | |
| } catch(...) { // convert problem | |
| if(params.count()>0) | |
| converted=params.as_bool(0, "default must be bool", r); // (default) | |
| else | |
| rethrow; // we have a problem when no default | |
| } | |
| r.write_no_lang(*new VBool(converted)); | |
| } | |
| /*not static*/void _string_format(Request& r, MethodParams& params) { | /*not static*/void _string_format(Request& r, MethodParams& params) { |
| Value& fmt_maybe_code=params[0]; | Value& fmt_maybe_code=params[0]; |
| Line 104 static void _double(Request& r, MethodPa | Line 119 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(); |
| size_t length=string.length(); | size_t length=string.length(); |
| Line 121 static void _right(Request& r, MethodPar | Line 147 static void _right(Request& r, MethodPar |
| 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 169 static int split_options(const String* o | Line 209 static int split_options(const String* o |
| if(options->pos(o->keyL)!=STRING_NOT_FOUND | if(options->pos(o->keyL)!=STRING_NOT_FOUND |
| || (o->keyU && options->pos(o->keyU)!=STRING_NOT_FOUND)) { | || (o->keyU && options->pos(o->keyU)!=STRING_NOT_FOUND)) { |
| if(result & o->checkBit) | if(result & o->checkBit) |
| throw Exception("parser.runtime", | throw Exception(PARSER_RUNTIME, |
| options, | options, |
| "conflicting split options"); | "conflicting split options"); |
| result |= o->setBit; | result |= o->setBit; |
| Line 296 static void _match(Request& r, MethodPar | Line 336 static void _match(Request& r, MethodPar |
| Temp_lang temp_lang(r, String::L_PASS_APPENDED); | Temp_lang temp_lang(r, String::L_PASS_APPENDED); |
| const String& src=GET_SELF(r, VString).string(); | const String& src=GET_SELF(r, VString).string(); |
| bool just_matched; | int matches_count=0; |
| if(params.count()<3) { // search | if(params.count()<3) { // search |
| Table* table=src.match(r.charsets.source(), | Table* table=src.match(r.charsets.source(), |
| regexp.as_string(), options, | regexp.as_string(), options, |
| search_action, 0, | search_action, 0, |
| just_matched); | matches_count); |
| Value* result; | // r.write_assign_lang(*new VTable(table)); |
| if(table) | if(table){ |
| result=new VTable(table); // table of pre/match/post+substrings | r.write_assign_lang(*new VTable(table)); |
| else | } else { |
| result=new VBool(just_matched); | r.write_assign_lang(*new VInt(matches_count)); |
| r.write_assign_lang(*result); | } |
| } else { // replace | } else { // replace |
| Value& replacement_code=params.as_junction(2, "replacement param must be code"); | Value& replacement_code=params.as_junction(2, "replacement param must be code"); |
| Line 326 static void _match(Request& r, MethodPar | Line 367 static void _match(Request& r, MethodPar |
| src.match(r.charsets.source(), | src.match(r.charsets.source(), |
| r.process_to_string(regexp), options, | r.process_to_string(regexp), options, |
| replace_action, &info, | replace_action, &info, |
| just_matched); | matches_count); |
| r.write_assign_lang(result); | r.write_assign_lang(result); |
| } | } |
| } | } |
| Line 361 public: | Line 402 public: |
| 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, |
| "result must contain exactly one column"); | "result must contain exactly one column"); |
| return true; | return true; |
| Line 373 public: | Line 414 public: |
| bool add_row(SQL_Error& /*error*/) { /* ignore */ return false; } | bool add_row(SQL_Error& /*error*/) { /* ignore */ return false; } |
| bool add_row_cell(SQL_Error& error, const char* str, size_t length) { | bool add_row_cell(SQL_Error& error, const char* str, size_t length) { |
| if(got_cell) { | if(got_cell) { |
| error=SQL_Error("parser.runtime", | error=SQL_Error(PARSER_RUNTIME, |
| //statement_string, | //statement_string, |
| "result must not contain more then one row"); | "result must not contain more then one row"); |
| return true; | return true; |
| Line 390 public: | Line 431 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((default_code=options->get(sql_default_name))) { |
| if(!default_code->get_junction()) | valid_options++; |
| throw Exception("parser.runtime", | |
| 0, | |
| "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, |
| "options must be hash"); | "options must be hash"); |
| } 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 447 static void _sql(Request& r, MethodParam | Line 513 static void _sql(Request& r, MethodParam |
| if(default_code) { | if(default_code) { |
| string=&r.process_to_string(*default_code); | string=&r.process_to_string(*default_code); |
| } else | } else |
| throw Exception("parser.runtime", | throw Exception(PARSER_RUNTIME, |
| 0, | 0, |
| "produced no result, but no default option specified"); | "produced no result, but no default option specified"); |
| } | } |
| Line 460 static void _replace(Request& r, MethodP | Line 526 static void _replace(Request& r, MethodP |
| Table* table=params.as_no_junction(0, "parameter must not be code").get_table(); | Table* table=params.as_no_junction(0, "parameter must not be code").get_table(); |
| if(!table) | if(!table) |
| throw Exception("parser.runtime", | throw Exception(PARSER_RUNTIME, |
| 0, | 0, |
| "parameter must be table"); | "parameter must be table"); |
| Line 469 static void _replace(Request& r, MethodP | Line 535 static void _replace(Request& r, MethodP |
| } | } |
| static void _save(Request& r, MethodParams& params) { | static void _save(Request& r, MethodParams& params) { |
| const String& file_name=params.as_string(params.count()-1, | const String& file_name=params.as_string(params.count()-1, FILE_NAME_MUST_BE_STRING); |
| "file name must be string"); | |
| const String& src=GET_SELF(r, VString).string(); | const String& src=GET_SELF(r, VString).string(); |
| Line 480 static void _save(Request& r, MethodPara | Line 545 static void _save(Request& r, MethodPara |
| if(mode=="append") | if(mode=="append") |
| do_append=true; | do_append=true; |
| else | else |
| throw Exception("parser.runtime", | throw Exception(PARSER_RUNTIME, |
| &mode, | &mode, |
| "unknown mode, must be 'append'"); | "unknown mode, must be 'append'"); |
| } | } |
| Line 505 static void _trim(Request& r, MethodPara | Line 570 static void _trim(Request& r, MethodPara |
| if(params.count()>0) { | if(params.count()>0) { |
| const String& skind=params.as_string(0, | const String& skind=params.as_string(0, |
| "'where' must be string"); | "'where' must be string"); |
| if(skind==TRIM_START_OPTION) | if(skind.length()) |
| kind=String::TRIM_START; | if(skind==TRIM_START_OPTION) |
| else if(skind==TRIM_END_OPTION) | kind=String::TRIM_START; |
| kind=String::TRIM_END; | else if(skind==TRIM_END_OPTION) |
| else if(skind==TRIM_BOTH_OPTION) | kind=String::TRIM_END; |
| kind=String::TRIM_BOTH; | else if(skind==TRIM_BOTH_OPTION) |
| else | kind=String::TRIM_BOTH; |
| throw Exception("parser.runtime", | else |
| &skind, | throw Exception(PARSER_RUNTIME, |
| "'kind' should be one of "TRIM_START_OPTION", "TRIM_BOTH_OPTION", "TRIM_END_OPTION); | &skind, |
| "'kind' must be one of "TRIM_START_OPTION", "TRIM_BOTH_OPTION", "TRIM_END_OPTION); | |
| if(params.count()>1) { | if(params.count()>1) { |
| const String& schars=params.as_string(1, "'chars' must be string"); | const String& schars=params.as_string(1, "'chars' must be string"); |
| if(!schars.length()) | if(schars.length()) |
| throw Exception("parser.runtime", | chars=schars.cstr(); |
| 0, | |
| "'chars' must not be empty"); | |
| chars=schars.cstr(); | |
| } | } |
| } | } |
| r.write_assign_lang(src.trim(kind, chars)); | 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); | |
| } | |
| static void _base64(Request& r, MethodParams& params) { | |
| if(params.count()) { | |
| // decode | |
| const char* cstr=params.as_string(0, "parameter must be string").cstr(); | |
| char* decoded_cstr=0; | |
| size_t decoded_size=0; | |
| pa_base64_decode(cstr, strlen(cstr), decoded_cstr, decoded_size); | |
| if(decoded_cstr && decoded_size) | |
| r.write_assign_lang(*new String(decoded_cstr, decoded_size, true)); | |
| } else { | |
| // encode | |
| VString& self=GET_SELF(r, VString); | |
| const char* cstr=self.string().cstr(); | |
| const char* encoded=pa_base64_encode(cstr, strlen(cstr)); | |
| r.write_assign_lang(*new String(encoded, 0, true/*once ?param=base64(something) was needed*/)); | |
| } | |
| } | |
| // constructor | // constructor |
| MString::MString(): Methoded("string") { | MString::MString(): Methoded("string") { |
| Line 541 MString::MString(): Methoded("string") { | Line 632 MString::MString(): Methoded("string") { |
| // ^string.double[] | // ^string.double[] |
| // ^string.double(default) | // ^string.double(default) |
| add_native_method("double", Method::CT_DYNAMIC, _double, 0, 1); | add_native_method("double", Method::CT_DYNAMIC, _double, 0, 1); |
| // ^void.bool[] | |
| // ^void.bool(default) | |
| add_native_method("bool", Method::CT_DYNAMIC, _bool, 0, 1); | |
| // ^string.format{format} | // ^string.format{format} |
| add_native_method("format", Method::CT_DYNAMIC, _string_format, 1, 1); | add_native_method("format", Method::CT_DYNAMIC, _string_format, 1, 1); |
| Line 574 MString::MString(): Methoded("string") { | Line 668 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 588 MString::MString(): Methoded("string") { | Line 682 MString::MString(): Methoded("string") { |
| // ^string.trim[[start|both|end][;chars]] | // ^string.trim[[start|both|end][;chars]] |
| add_native_method("trim", Method::CT_DYNAMIC, _trim, 0, 2); | add_native_method("trim", Method::CT_DYNAMIC, _trim, 0, 2); |
| // ^string.append[string] | |
| add_native_method("append", Method::CT_DYNAMIC, _append, 1, 1); | |
| // ^string.base64[] << encode | |
| // ^string:base64[encoded string] << decode | |
| add_native_method("base64", Method::CT_ANY, _base64, 0, 1); | |
| } | } |