Return to void.C CVS log

Up to [parser3project] / parser3 / src / classes

Annotation of parser3/src/classes/void.C, revision 1.56

1.1       parser      1: /** @file
                      2:        Parser: @b VOID parser class.
                      3: 
1.55      moko        4:        Copyright (c) 2001-2017 Art. Lebedev Studio (http://www.artlebedev.com)
1.16      paf         5:        Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)
1.20      paf         6: */
1.1       parser      7: 
                      8: #include "classes.h"
1.29      paf         9: #include "pa_vmethod_frame.h"
                     10: 
1.1       parser     11: #include "pa_request.h"
                     12: #include "pa_vvoid.h"
                     13: #include "pa_sql_connection.h"
                     14: 
1.56    ! moko       15: volatile const char * IDENT_VOID_C="$Id: void.C,v 1.55 2017/02/07 22:00:30 moko Exp $";
1.33      paf        16: 
1.1       parser     17: // class
                     18: 
1.29      paf        19: class MVoid: public Methoded {
1.1       parser     20: public:
1.29      paf        21:        MVoid();
1.1       parser     22: };
                     23: 
1.48      moko       24: // void is inherited from string, thus global variable declared in string.C
1.29      paf        25: 
1.1       parser     26: // methods
                     27: 
1.5       parser     28: #ifndef DOXYGEN
1.26      paf        29: class Void_sql_event_handlers: public SQL_Driver_query_event_handlers {
1.29      paf        30:        const String& statement_string;
1.5       parser     31: public:
1.29      paf        32:        Void_sql_event_handlers(const String& astatement_string): statement_string(astatement_string) {}
                     33:        bool add_column(SQL_Error& /*error*/, const char* /*str*/, size_t /*length*/) { /* ignore */ return false; }
1.27      paf        34:        bool before_rows(SQL_Error& error) {
1.5       parser     35:                // there are some result rows, which is wrong
1.38      misha      36:                error=SQL_Error(PARSER_RUNTIME,
1.29      paf        37:                        /*statement_string,*/
1.5       parser     38:                        "must return nothing");
1.27      paf        39:                return true;
1.5       parser     40:        }
1.27      paf        41:        bool add_row(SQL_Error& /*error*/) { /* never */ return false; }
1.29      paf        42:        bool add_row_cell(SQL_Error& /*error*/, const char* /*str*/, size_t /*length*/) { /* never */ return false; }
1.5       parser     43: 
                     44: };
                     45: #endif
1.34      paf        46: 
                     47: extern int marshal_binds(HashStringValue& hash, SQL_Driver::Placeholder*& placeholders);
                     48: extern void unmarshal_bind_updates(HashStringValue& hash, int placeholder_count, SQL_Driver::Placeholder* placeholders);
                     49: 
1.29      paf        50: static void _sql(Request& r, MethodParams& params) {
                     51:        Value& statement=params.as_junction(0, "statement must be code");
1.1       parser     52: 
1.33      paf        53:        HashStringValue* bind=0;
1.49      misha      54:        if(params.count()>1)
1.51      misha      55:                if(HashStringValue* options=params.as_hash(1, "sql options")) {
1.49      misha      56:                        int valid_options=0;
                     57:                        if(Value* vbind=options->get(sql_bind_name)) {
                     58:                                valid_options++;
                     59:                                bind=vbind->get_hash();
                     60:                        }
                     61:                        if(valid_options!=options->count())
                     62:                                throw Exception(PARSER_RUNTIME, 0, CALLED_WITH_INVALID_OPTION);
                     63:                }
1.33      paf        64: 
                     65:        SQL_Driver::Placeholder* placeholders=0;
                     66:        uint placeholders_count=0;
                     67:        if(bind)
                     68:                placeholders_count=marshal_binds(*bind, placeholders);
                     69: 
1.18      paf        70:        const String& statement_string=r.process_to_string(statement);
1.54      moko       71:        const char* statement_cstr=statement_string.untaint_cstr(String::L_SQL, r.connection());
1.43      misha      72: 
1.29      paf        73:        Void_sql_event_handlers handlers(statement_string);
                     74:        r.connection()->query(
1.33      paf        75:                statement_cstr, 
                     76:                placeholders_count, placeholders,
1.39      misha      77:                0, SQL_NO_LIMIT,
1.22      paf        78:                handlers,
                     79:                statement_string);
1.34      paf        80: 
                     81:        if(bind)
                     82:                unmarshal_bind_updates(*bind, placeholders_count, placeholders);
1.1       parser     83: }
                     84: 
                     85: // constructor
                     86: 
1.53      moko       87: MVoid::MVoid(): Methoded("void") {
                     88:        set_base(string_class);
                     89: 
1.41      misha      90:        // ^void:sql{query}
1.33      paf        91:        add_native_method("sql", Method::CT_STATIC, _sql, 1, 2);
1.32      paf        92: 
1.48      moko       93:        // all other methods are inherinted from empty string
1.1       parser     94: }