[BACK]Return to string.C CVS log [TXT] [DIR] Up to [parser3project] / parser3 / src / classes

Diff for /parser3/src/classes/string.C between versions 1.78 and 1.98

version 1.78, 2001/10/09 07:06:00 version 1.98, 2002/03/27 15:30:34
Line 1 Line 1
 /** @file  /** @file
         Parser: @b string parser class.          Parser: @b string parser class.
   
         Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com)          Copyright (c) 2001, 2002 ArtLebedev Group (http://www.artlebedev.com)
         Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf)          Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)
   
         $Id$          $Id$
 */  */
Line 41  static void _length(Request& r, const St Line 41  static void _length(Request& r, const St
   
 static void _int(Request& r, const String& method_name, MethodParams *params) {  static void _int(Request& r, const String& method_name, MethodParams *params) {
         Pool& pool=r.pool();          Pool& pool=r.pool();
         bool convert_problem=false; Exception rethrow_me;  
         int converted;          int converted;
         PTRY {          Value *default_code=params->size()>0?
                   default_code=&params->as_junction(0, "default must be int"):0; // (default)
           try {
                 converted=r.self->as_int();                  converted=r.self->as_int();
           } catch(...) { // convert problem
                   if(!default_code) // we have a problem when no default
                           /*re*/throw;
                   else
                           converted=r.process(*default_code).as_int();
         }          }
         PCATCH(e) { // convert problem  
                 if(convert_problem=params->size()==0) { // we have a problem when do not have default  
                         rethrow_me=e;    
                         converted=0;  
                 } else  
                         converted=params->as_int(0, "default must be int", r); // (default)  
         }  
         PEND_CATCH  
         if(convert_problem)  
                 PTHROW(rethrow_me.type(), rethrow_me.code(),   
                         rethrow_me.problem_source(),  
                         rethrow_me.comment());  
   
         Value& result=*new(pool) VInt(pool, converted);          Value& result=*new(pool) VInt(pool, converted);
         result.set_name(method_name);          result.set_name(method_name);
Line 66  static void _int(Request& r, const Strin Line 60  static void _int(Request& r, const Strin
   
 static void _double(Request& r, const String& method_name, MethodParams *params) {  static void _double(Request& r, const String& method_name, MethodParams *params) {
         Pool& pool=r.pool();          Pool& pool=r.pool();
         bool convert_problem=false; Exception rethrow_me;  
         double converted;          double converted;
         PTRY {          Value *default_code=params->size()>0?
                   default_code=&params->as_junction(0, "default must be double"):0; // (default)
           try {
                 converted=r.self->as_double();                  converted=r.self->as_double();
           } catch(...) { // convert problem
                   if(!default_code) // we have a problem when no default
                           /*re*/throw;  
                   else
                           converted=r.process(*default_code).as_double();
         }          }
         PCATCH(e) { // convert problem  
                 if(convert_problem=params->size()==0) { // we have a problem when do not have default  
                         rethrow_me=e;    
                         converted=0;  
                 } else  
                         converted=params->as_double(0, "default must be double", r); // (default)  
         }  
         PEND_CATCH  
         if(convert_problem)  
                 PTHROW(rethrow_me.type(), rethrow_me.code(),   
                         rethrow_me.problem_source(),  
                         rethrow_me.comment());  
   
         Value& result=*new(pool) VDouble(pool, converted);          Value& result=*new(pool) VDouble(pool, converted);
         result.set_name(method_name);          result.set_name(method_name);
Line 92  static void _double(Request& r, const St Line 80  static void _double(Request& r, const St
 /*not static*/void _string_format(Request& r, const String& method_name, MethodParams *params) {  /*not static*/void _string_format(Request& r, const String& method_name, MethodParams *params) {
         Pool& pool=r.pool();          Pool& pool=r.pool();
   
         Value& fmt=params->as_junction(0, "fmt must be code");          Value& fmt_maybe_code=params->get(0);
           // for some time due to stupid {} in original design
           const String& fmt=
                   (fmt_maybe_code.get_junction()?r.process(fmt_maybe_code):fmt_maybe_code).as_string();
   
         Temp_lang temp_lang(r, String::UL_PASS_APPENDED);          char *buf=format(pool, r.self->as_double(), fmt.cstr());
         char *buf=format(pool, r.self->as_double(), r.process(fmt).as_string().cstr());  
   
         String result(pool);          String result(pool);
         result.APPEND_CLEAN(buf, 0,           result.APPEND_CLEAN(buf, 0, 
Line 125  static void _right(Request& r, const Str Line 115  static void _right(Request& r, const Str
 static void _mid(Request& r, const String&, MethodParams *params) {  static void _mid(Request& r, const String&, MethodParams *params) {
         Pool& pool=r.pool();          Pool& pool=r.pool();
   
           const String& string=*static_cast<VString *>(r.self)->get_string();
   
         size_t p=(size_t)params->as_int(0, "p must be int", r);          size_t p=(size_t)params->as_int(0, "p must be int", r);
         size_t n=(size_t)params->as_int(1, "n must be int", r);          size_t n=params->size()>1?
                   (size_t)params->as_int(1, "n must be int", r):string.size();
                   
         const String& string=*static_cast<VString *>(r.self)->get_string();  
         r.write_assign_lang(*new(pool) VString(string.mid(p, p+n)));          r.write_assign_lang(*new(pool) VString(string.mid(p, p+n)));
 }  }
   
Line 254  static void _match(Request& r, const Str Line 246  static void _match(Request& r, const Str
         Table *table;          Table *table;
         if(params->size()<3) { // search          if(params->size()<3) { // search
                 bool was_global;                  bool was_global;
                 bool matched=src.match(r.pcre_tables(),                  bool matched=src.match(
                         &method_name,                           &method_name, 
                         regexp.as_string(), options,                          regexp.as_string(), options,
                         &table,                          &table,
Line 267  static void _match(Request& r, const Str Line 259  static void _match(Request& r, const Str
                 else                   else 
                         result=new(pool) VBool(pool, matched);                                            result=new(pool) VBool(pool, matched);                  
         } else { // replace          } else { // replace
                 Value& replacement_code=params->as_junction(2, "replacement code must be code");                  Value& replacement_code=params->as_junction(2, "replacement param must be code");
   
                 String& dest=*new(pool) String(pool);                  String& dest=*new(pool) String(pool);
                 Replace_action_info replace_action_info={                  Replace_action_info replace_action_info={
Line 276  static void _match(Request& r, const Str Line 268  static void _match(Request& r, const Str
                         &replacement_code,                          &replacement_code,
                         &src                          &src
                 };                  };
                 src.match(r.pcre_tables(),                  src.match(
                         &method_name,                           &method_name, 
                         r.process(regexp).as_string(), options,                          r.process(regexp).as_string(), options,
                         &table,                          &table,
Line 292  static void change_case(Request& r, cons Line 284  static void change_case(Request& r, cons
         Pool& pool=r.pool();          Pool& pool=r.pool();
         const String& src=*static_cast<VString *>(r.self)->get_string();          const String& src=*static_cast<VString *>(r.self)->get_string();
   
         r.write_assign_lang(*new(pool) VString(src.change_case(pool, r.pcre_tables(),          r.write_assign_lang(*new(pool) VString(src.change_case(pool, 
                 kind)));                  kind)));
 }  }
 static void _upper(Request& r, const String& method_name, MethodParams *params) {  static void _upper(Request& r, const String& method_name, MethodParams *params) {
Line 316  public: Line 308  public:
   
         void add_column(void *ptr, size_t size) {          void add_column(void *ptr, size_t size) {
                 if(got_column)                  if(got_column)
                         PTHROW(0, 0,                          throw Exception("parser.runtime",
                                 &statement_string,                                  &statement_string,
                                 "result must contain exactly one column");                                  "result must contain exactly one column");
                 got_column=true;                  got_column=true;
Line 325  public: Line 317  public:
         void add_row() { /* ignore */ }          void add_row() { /* ignore */ }
         void add_row_cell(void *ptr, size_t size) {          void add_row_cell(void *ptr, size_t size) {
                 if(got_cell)                  if(got_cell)
                         PTHROW(0, 0,                          throw Exception("parser.runtime",
                                 &statement_string,                                  &statement_string,
                                 "result must not contain more then one row");                                  "result must not contain more then one row");
                 got_cell=true;                  got_cell=true;
Line 343  public: Line 335  public:
 };  };
 #endif  #endif
 const String* sql_result_string(Request& r, const String& method_name, MethodParams *params,  const String* sql_result_string(Request& r, const String& method_name, MethodParams *params,
                                                                 Hash *&options) {                                                                  Hash *& options, Value *& default_code) {
         Pool& pool=r.pool();          Pool& pool=r.pool();
   
         if(!r.connection)  
                 PTHROW(0, 0,  
                         &method_name,  
                         "without connect");  
   
         Value& statement=params->as_junction(0, "statement must be code");          Value& statement=params->as_junction(0, "statement must be code");
   
         ulong limit=0;          ulong limit=0;
         ulong offset=0;          ulong offset=0;
           default_code=0;
         if(params->size()>1) {          if(params->size()>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_defined())                  if(voptions.is_defined())
                         if(options=voptions.get_hash()) {                          if(options=voptions.get_hash(&method_name)) {
                                 if(Value *vlimit=(Value *)options->get(*sql_limit_name))                                  if(Value *vlimit=(Value *)options->get(*sql_limit_name))
                                         limit=(ulong)r.process(*vlimit).as_double();                                          limit=(ulong)r.process(*vlimit).as_double();
                                 if(Value *voffset=(Value *)options->get(*sql_offset_name))                                  if(Value *voffset=(Value *)options->get(*sql_offset_name))
                                         offset=(ulong)r.process(*voffset).as_double();                                          offset=(ulong)r.process(*voffset).as_double();
                                   if(default_code=(Value *)options->get(*sql_default_name)) {
                                           if(!default_code->get_junction())
                                                   throw Exception("parser.runtime",
                                                           &method_name,
                                                           "default option must be code");
                                   }
                         } else                          } else
                                 PTHROW(0, 0,                                  throw Exception("parser.runtime",
                                         &method_name,                                          &method_name,
                                         "options must be hash");                                          "options must be hash");
         } else          } else
Line 373  const String* sql_result_string(Request& Line 367  const String* sql_result_string(Request&
         Temp_lang temp_lang(r, String::UL_SQL);          Temp_lang temp_lang(r, String::UL_SQL);
         const String& statement_string=r.process(statement).as_string();          const String& statement_string=r.process(statement).as_string();
         const char *statement_cstr=          const char *statement_cstr=
                 statement_string.cstr(String::UL_UNSPECIFIED, r.connection);                  statement_string.cstr(String::UL_UNSPECIFIED, r.connection(&method_name));
         String_sql_event_handlers handlers(pool, statement_string, statement_cstr);          String_sql_event_handlers handlers(pool, statement_string, statement_cstr);
         bool need_rethrow=false; Exception rethrow_me;          try {
         PTRY {                  r.connection(&method_name)->query(
                 r.connection->query(  
                         statement_cstr, offset, limit,                           statement_cstr, offset, limit, 
                         handlers);                          handlers);
           } catch(const Exception& e) { // query problem
                   // give more specific source [were url]
                   throw Exception("sql.execute",
                           &statement_string, 
                           "%s", e.comment());
         }          }
         PCATCH(e) { // query 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());  
                   
         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 400  static void _sql(Request& r, const Strin Line 390  static void _sql(Request& r, const Strin
         Pool& pool=r.pool();          Pool& pool=r.pool();
   
         Hash *options;          Hash *options;
         const String *string=sql_result_string(r, method_name, params, options);          Value *default_code;
           const String *string=sql_result_string(r, method_name, params, options, default_code);
         if(!string) {          if(!string) {
                 if(options) {                  if(default_code) {
                         if(Value *vdefault=(Value *)options->get(*sql_default_name)) {                          string=r.process(*default_code).get_string();
                                 if(!vdefault->get_junction())                          if(!string)
                                         PTHROW(0, 0,                                  string=new(pool) String(pool);
                                                 &method_name,  
                                                 "default option must be code");  
                                 string=r.process(*vdefault).get_string();  
                                 if(!string)  
                                         string=empty_string;  
                         } else  
                                 PTHROW(0, 0,  
                                         &method_name,  
                                         "produced no result, but no default option specified");  
                 } else                  } else
                         PTHROW(0, 0,                          throw Exception("parser.runtime",
                                 &method_name,                                  &method_name,
                                 "produced no result, but no options (no default) specified");                                  "produced no result, but no default option specified");
         }          }
         VString& result=*new(pool) VString(*string);          VString& result=*new(pool) VString(*string);
         result.set_name(method_name);          result.set_name(method_name);
Line 431  static void _replace(Request& r, const S Line 413  static void _replace(Request& r, const S
   
         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)
                 PTHROW(0, 0,                  throw Exception("parser.runtime",
                         &method_name,                          &method_name,
                         "parameter must be table");                          "parameter must be table");
   
         Dictionary dict(*table);          Dictionary dict(*table);
         r.write_assign_lang(*new(pool) VString(src.replace(pool, dict)));          r.write_assign_lang(*new(pool) VString(src.replace(pool, dict)));
 }  }
   
   static void _save(Request& r, const String& method_name, MethodParams *params) {
           const String& file_name=params->as_string(params->size()-1, 
                   "file name must be string");
   
           const String& src=*static_cast<VString *>(r.self)->get_string();
   
           bool do_append=false;
           if(params->size()>1) {
                   const String& mode=params->as_string(0, "mode must be string");
                   if(mode=="append")
                           do_append=true;
                   else
                           throw Exception("parser.runtime",
                                   &mode,
                                   "unknown mode, must be 'append'");
           }               
   
           // write
           const char *buf=src.cstr(String::UL_UNSPECIFIED);
           file_write(r.absolute(file_name), 
                   buf, strlen(buf), true, do_append);
   }
   
 // constructor  // constructor
   
 MString::MString(Pool& apool) : Methoded(apool) {  MString::MString(Pool& apool) : Methoded(apool) {
Line 462  MString::MString(Pool& apool) : Methoded Line 468  MString::MString(Pool& apool) : Methoded
         // ^string.right(n)          // ^string.right(n)
         add_native_method("right", Method::CT_DYNAMIC, _right, 1, 1);          add_native_method("right", Method::CT_DYNAMIC, _right, 1, 1);
         // ^string.mid(p;n)          // ^string.mid(p;n)
         add_native_method("mid", Method::CT_DYNAMIC, _mid, 2, 2);          add_native_method("mid", Method::CT_DYNAMIC, _mid, 1, 2);
   
         // ^string.pos[substr]          // ^string.pos[substr]
         add_native_method("pos", Method::CT_DYNAMIC, _pos, 1, 1);          add_native_method("pos", Method::CT_DYNAMIC, _pos, 1, 1);
Line 487  MString::MString(Pool& apool) : Methoded Line 493  MString::MString(Pool& apool) : Methoded
   
         // ^string.replace[table]          // ^string.replace[table]
         add_native_method("replace", Method::CT_DYNAMIC, _replace, 1, 1);          add_native_method("replace", Method::CT_DYNAMIC, _replace, 1, 1);
   
           // ^string.save[file]  
           add_native_method("save", Method::CT_DYNAMIC, _save, 1, 2);
 }         }       
   
 // global variable  // global variable
Removed from v.1.78  
changed lines
  Added in v.1.98

E-mail: