Diff for /parser3/src/classes/void.C between versions 1.33 and 1.48

version 1.33, 2004/06/18 15:55:47 version 1.48, 2010/10/21 15:25:07
Line 1 Line 1
 /** @file  /** @file
         Parser: @b VOID parser class.          Parser: @b VOID parser class.
   
         Copyright (c) 2001-2004 ArtLebedev Group (http://www.artlebedev.com)          Copyright (c) 2001-2009 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 11  static const char * const IDENT_VOID_C=" Line 11  static const char * const IDENT_VOID_C="
 #include "pa_vmethod_frame.h"  #include "pa_vmethod_frame.h"
   
 #include "pa_request.h"  #include "pa_request.h"
 #include "pa_vint.h"  
 #include "pa_vdouble.h"  
 #include "pa_vvoid.h"  #include "pa_vvoid.h"
 #include "pa_sql_connection.h"  #include "pa_sql_connection.h"
   
Line 25  extern String sql_bind_name; Line 23  extern String sql_bind_name;
 class MVoid: public Methoded {  class MVoid: public Methoded {
 public:  public:
         MVoid();          MVoid();
 public: // Methoded  
         bool used_directly() { return true; }  
 };  };
   
 // global variable  // void is inherited from string, thus global variable declared in string.C
   
 DECLARE_CLASS_VAR(void, new MVoid, 0);  
   
 // methods  // methods
   
 static void _length(Request& r, MethodParams&) {  
         // always zero  
         r.write_no_lang(*new VInt(0));  
 }  
   
 static void _pos(Request& r, MethodParams& params) {  
         // just checking for consistency  
         params.as_no_junction(0, "substr must not be code");  
         // never found  
         r.write_no_lang(*new VInt(-1));  
 }  
   
 static void _int(Request& r, MethodParams& params) {  
         VVoid& vvoid=GET_SELF(r, VVoid);  
         r.write_no_lang(*new VInt(  
                 params.count()==0?vvoid.as_int():params.as_int(0, "default must be int", r)));  
 }  
   
 static void _double(Request& r, MethodParams& params) {  
         VVoid& vvoid=GET_SELF(r, VVoid);  
         r.write_no_lang(*new VDouble(  
                 params.count()==0?vvoid.as_double():params.as_double(0, "default must be double", r)));  
 }  
   
 #ifndef DOXYGEN  #ifndef DOXYGEN
 static void marshal_bind(  
                                                  HashStringValue::key_type aname,   
                                                  HashStringValue::value_type avalue,  
                                                  SQL_Driver::Placeholder** pptr)   
 {  
         SQL_Driver::Placeholder& ph=**pptr;  
         ph.name=aname.cstr();  
         ph.value=avalue->as_string().cstr();  
         ph.is_null=avalue->get_class()==void_class;  
         ph.were_updated=false;  
   
         *pptr++;  
 }  
   
 // not static, used elsewhere  
 int marshal_binds(HashStringValue& hash, SQL_Driver::Placeholder*& placeholders) {  
         int hash_count=hash.count();  
         placeholders=new(UseGC) SQL_Driver::Placeholder[hash_count];  
         SQL_Driver::Placeholder* ptr=placeholders;  
         hash.for_each(marshal_bind, &ptr);  
         return hash_count;  
 }  
   
 class Void_sql_event_handlers: public SQL_Driver_query_event_handlers {  class Void_sql_event_handlers: public SQL_Driver_query_event_handlers {
         const String& statement_string;          const String& statement_string;
 public:  public:
Line 90  public: Line 37  public:
         bool add_column(SQL_Error& /*error*/, const char* /*str*/, size_t /*length*/) { /* ignore */ return false; }          bool add_column(SQL_Error& /*error*/, const char* /*str*/, size_t /*length*/) { /* ignore */ return false; }
         bool before_rows(SQL_Error& error) {          bool before_rows(SQL_Error& error) {
                 // there are some result rows, which is wrong                  // there are some result rows, which is wrong
                 error=SQL_Error("parser.runtime",                  error=SQL_Error(PARSER_RUNTIME,
                         /*statement_string,*/                          /*statement_string,*/
                         "must return nothing");                          "must return nothing");
                 return true;                  return true;
Line 100  public: Line 47  public:
   
 };  };
 #endif  #endif
   
   extern int marshal_binds(HashStringValue& hash, SQL_Driver::Placeholder*& placeholders);
   extern void unmarshal_bind_updates(HashStringValue& hash, int placeholder_count, SQL_Driver::Placeholder* placeholders);
   
 static void _sql(Request& r, MethodParams& params) {  static void _sql(Request& r, MethodParams& params) {
         Value& statement=params.as_junction(0, "statement must be code");          Value& statement=params.as_junction(0, "statement must be code");
   
         HashStringValue* bind=0;          HashStringValue* bind=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(HashStringValue* options=voptions.get_hash()) {                          if(HashStringValue* options=voptions.get_hash()) {
                                 int valid_options=0;                                  int valid_options=0;
                                 if(Value* vbind=options->get(sql_bind_name)) {                                  if(Value* vbind=options->get(sql_bind_name)) {
Line 114  static void _sql(Request& r, MethodParam Line 65  static void _sql(Request& r, MethodParam
                                         bind=vbind->get_hash();                                          bind=vbind->get_hash();
                                 }                                  }
                                 if(valid_options!=options->count())                                  if(valid_options!=options->count())
                                         throw Exception("parser.runtime",                                          throw Exception(PARSER_RUNTIME, 0, CALLED_WITH_INVALID_OPTION);
                                                 0,  
                                                 "called with invalid option");  
                         } else                          } else
                                 throw Exception("parser.runtime",                                  throw Exception(PARSER_RUNTIME, 0, OPTIONS_MUST_BE_HASH);
                                         0,  
                                         "options must be hash");  
         }          }
   
         SQL_Driver::Placeholder* placeholders=0;          SQL_Driver::Placeholder* placeholders=0;
Line 130  static void _sql(Request& r, MethodParam Line 77  static void _sql(Request& r, MethodParam
   
         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.untaint_cstr(r.flang, r.connection());
                 statement_string.cstr(String::L_UNSPECIFIED, r.connection());  
         Void_sql_event_handlers handlers(statement_string);          Void_sql_event_handlers handlers(statement_string);
         r.connection()->query(          r.connection()->query(
                 statement_cstr,                   statement_cstr, 
                 placeholders_count, placeholders,                  placeholders_count, placeholders,
                 0, 0,                  0, SQL_NO_LIMIT,
                 handlers,                  handlers,
                 statement_string);                  statement_string);
 }  
   
 static void _left_right(Request& r, MethodParams& params) {  
         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);  
   
         // return nothing  
 }  
   
 static void _mid(Request& r, MethodParams& params) {          if(bind)
         ssize_t sbegin=params.as_int(0, "p must be int", r);                  unmarshal_bind_updates(*bind, placeholders_count, placeholders);
         if(sbegin<0)  
                 throw Exception("parser.runtime",  
                         0,   
                         "p(%d) must be >=0", sbegin);  
   
         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);  
         }  
   
         // return nothing  
 }  }
   
 // constructor  // constructor
   
 MVoid::MVoid(): Methoded("void") {  MVoid::MVoid(): Methoded("void", string_class) {
         // ^void.length[]           // ^void:sql{query}
         add_native_method("length", Method::CT_DYNAMIC, _length, 0, 0);  
   
         // ^void.pos[substr]  
         add_native_method("pos", Method::CT_DYNAMIC, _pos, 1, 1);  
   
         // ^void.int[]  
         // ^void.int(default)  
         add_native_method("int", Method::CT_DYNAMIC, _int, 0, 1);  
   
         // ^void.double[]  
         // ^void.double(default)  
         add_native_method("double", Method::CT_DYNAMIC, _double, 0, 1);  
   
         // ^sql[query]  
         add_native_method("sql", Method::CT_STATIC, _sql, 1, 2);          add_native_method("sql", Method::CT_STATIC, _sql, 1, 2);
   
         // ^void.left() ^void.right()          // all other methods are inherinted from empty string
         add_native_method("left", Method::CT_DYNAMIC, _left_right, 1, 1);  
         add_native_method("right", Method::CT_DYNAMIC, _left_right, 1, 1);  
   
         // ^void.mid(p;n)  
         add_native_method("mid", Method::CT_DYNAMIC, _mid, 1, 2);  
 }  }

Removed from v.1.33  
changed lines
  Added in v.1.48


E-mail: