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

1.1       parser      1: /** @file
                      2:        Parser: @b VOID parser class.
                      3: 
1.42      misha       4:        Copyright (c) 2001-2009 ArtLebedev Group (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: 
1.47    ! moko        8: static const char * const IDENT_VOID_C="$Date: 2010-07-05 05:54:46 $";
1.1       parser      9: 
                     10: #include "classes.h"
1.29      paf        11: #include "pa_vmethod_frame.h"
                     12: 
1.1       parser     13: #include "pa_request.h"
                     14: #include "pa_vint.h"
                     15: #include "pa_vdouble.h"
                     16: #include "pa_vvoid.h"
1.37      misha      17: #include "pa_vbool.h"
1.1       parser     18: #include "pa_sql_connection.h"
                     19: 
1.33      paf        20: // externs
                     21: 
                     22: extern String sql_bind_name;
                     23: 
1.1       parser     24: // class
                     25: 
1.29      paf        26: class MVoid: public Methoded {
1.1       parser     27: public:
1.29      paf        28:        MVoid();
1.1       parser     29: };
                     30: 
1.29      paf        31: // global variable
                     32: 
                     33: DECLARE_CLASS_VAR(void, new MVoid, 0);
                     34: 
1.1       parser     35: // methods
                     36: 
1.29      paf        37: static void _length(Request& r, MethodParams&) {
1.24      paf        38:        // always zero
1.29      paf        39:        r.write_no_lang(*new VInt(0));
1.23      paf        40: }
                     41: 
1.29      paf        42: static void _pos(Request& r, MethodParams& params) {
                     43:        // just checking for consistency
                     44:        params.as_no_junction(0, "substr must not be code");
1.40      misha      45:        if(params.count()>1){
                     46:                ssize_t offset=params.as_int(1, "n must be int", r);
                     47:                if(offset<0)
                     48:                        throw Exception(PARSER_RUNTIME,
                     49:                                0, 
                     50:                                "n(%d) must be >=0", offset);
                     51:        }
1.24      paf        52:        // never found
1.29      paf        53:        r.write_no_lang(*new VInt(-1));
1.24      paf        54: }
                     55: 
1.29      paf        56: static void _int(Request& r, MethodParams& params) {
                     57:        VVoid& vvoid=GET_SELF(r, VVoid);
                     58:        r.write_no_lang(*new VInt(
                     59:                params.count()==0?vvoid.as_int():params.as_int(0, "default must be int", r)));
1.1       parser     60: }
                     61: 
1.29      paf        62: static void _double(Request& r, MethodParams& params) {
                     63:        VVoid& vvoid=GET_SELF(r, VVoid);
                     64:        r.write_no_lang(*new VDouble(
                     65:                params.count()==0?vvoid.as_double():params.as_double(0, "default must be double", r)));
1.1       parser     66: }
                     67: 
1.37      misha      68: static void _bool(Request& r, MethodParams& params) {
                     69:        VVoid& vvoid=GET_SELF(r, VVoid);
1.42      misha      70:        r.write_no_lang(VBool::get(params.count()==0?vvoid.as_bool():params.as_bool(0, "default must be bool", r)));
1.37      misha      71: }
                     72: 
1.5       parser     73: #ifndef DOXYGEN
1.26      paf        74: class Void_sql_event_handlers: public SQL_Driver_query_event_handlers {
1.29      paf        75:        const String& statement_string;
1.5       parser     76: public:
1.29      paf        77:        Void_sql_event_handlers(const String& astatement_string): statement_string(astatement_string) {}
                     78:        bool add_column(SQL_Error& /*error*/, const char* /*str*/, size_t /*length*/) { /* ignore */ return false; }
1.27      paf        79:        bool before_rows(SQL_Error& error) {
1.5       parser     80:                // there are some result rows, which is wrong
1.38      misha      81:                error=SQL_Error(PARSER_RUNTIME,
1.29      paf        82:                        /*statement_string,*/
1.5       parser     83:                        "must return nothing");
1.27      paf        84:                return true;
1.5       parser     85:        }
1.27      paf        86:        bool add_row(SQL_Error& /*error*/) { /* never */ return false; }
1.29      paf        87:        bool add_row_cell(SQL_Error& /*error*/, const char* /*str*/, size_t /*length*/) { /* never */ return false; }
1.5       parser     88: 
                     89: };
                     90: #endif
1.34      paf        91: 
                     92: extern int marshal_binds(HashStringValue& hash, SQL_Driver::Placeholder*& placeholders);
                     93: extern void unmarshal_bind_updates(HashStringValue& hash, int placeholder_count, SQL_Driver::Placeholder* placeholders);
                     94: 
1.29      paf        95: static void _sql(Request& r, MethodParams& params) {
                     96:        Value& statement=params.as_junction(0, "statement must be code");
1.1       parser     97: 
1.33      paf        98:        HashStringValue* bind=0;
                     99:        if(params.count()>1) {
                    100:                Value& voptions=params.as_no_junction(1, "options must be hash, not code");
1.36      paf       101:                if(voptions.is_defined() && !voptions.is_string())
1.33      paf       102:                        if(HashStringValue* options=voptions.get_hash()) {
                    103:                                int valid_options=0;
                    104:                                if(Value* vbind=options->get(sql_bind_name)) {
                    105:                                        valid_options++;
                    106:                                        bind=vbind->get_hash();
                    107:                                }
                    108:                                if(valid_options!=options->count())
1.46      misha     109:                                        throw Exception(PARSER_RUNTIME, 0, CALLED_WITH_INVALID_OPTION);
1.33      paf       110:                        } else
1.46      misha     111:                                throw Exception(PARSER_RUNTIME, 0, OPTIONS_MUST_BE_HASH);
1.33      paf       112:        }
                    113: 
                    114:        SQL_Driver::Placeholder* placeholders=0;
                    115:        uint placeholders_count=0;
                    116:        if(bind)
                    117:                placeholders_count=marshal_binds(*bind, placeholders);
                    118: 
1.29      paf       119:        Temp_lang temp_lang(r, String::L_SQL);
1.18      paf       120:        const String& statement_string=r.process_to_string(statement);
1.45      misha     121:        const char* statement_cstr=statement_string.untaint_cstr(r.flang, r.connection());
1.43      misha     122: 
1.29      paf       123:        Void_sql_event_handlers handlers(statement_string);
                    124:        r.connection()->query(
1.33      paf       125:                statement_cstr, 
                    126:                placeholders_count, placeholders,
1.39      misha     127:                0, SQL_NO_LIMIT,
1.22      paf       128:                handlers,
                    129:                statement_string);
1.34      paf       130: 
                    131:        if(bind)
                    132:                unmarshal_bind_updates(*bind, placeholders_count, placeholders);
1.1       parser    133: }
                    134: 
1.32      paf       135: static void _left_right(Request& r, MethodParams& params) {
                    136:        ssize_t sn=params.as_int(0, "n must be int", r);
                    137:        if(sn<0)
1.38      misha     138:                throw Exception(PARSER_RUNTIME,
1.32      paf       139:                        0, 
                    140:                        "n(%d) must be >=0", sn);
                    141: 
                    142:        // return nothing
                    143: }
                    144: 
                    145: static void _mid(Request& r, MethodParams& params) {
                    146:        ssize_t sbegin=params.as_int(0, "p must be int", r);
                    147:        if(sbegin<0)
1.38      misha     148:                throw Exception(PARSER_RUNTIME,
1.32      paf       149:                        0, 
                    150:                        "p(%d) must be >=0", sbegin);
                    151: 
                    152:        if(params.count()>1) {
                    153:                ssize_t sn=params.as_int(1, "n must be int", r);
                    154:                if(sn<0)
1.38      misha     155:                        throw Exception(PARSER_RUNTIME,
1.32      paf       156:                                0, 
                    157:                                "n(%d) must be >=0", sn);
                    158:        }
                    159: 
                    160:        // return nothing
                    161: }
                    162: 
1.1       parser    163: // constructor
                    164: 
1.29      paf       165: MVoid::MVoid(): Methoded("void") {
1.23      paf       166:        // ^void.length[] 
                    167:        add_native_method("length", Method::CT_DYNAMIC, _length, 0, 0);
1.24      paf       168: 
                    169:        // ^void.pos[substr]
1.41      misha     170:        // ^void.pos[substr](n)
1.40      misha     171:        add_native_method("pos", Method::CT_DYNAMIC, _pos, 1, 2);
1.23      paf       172: 
1.32      paf       173:        // ^void.int[]
1.9       parser    174:        // ^void.int(default)
1.8       parser    175:        add_native_method("int", Method::CT_DYNAMIC, _int, 0, 1);
1.1       parser    176: 
1.32      paf       177:        // ^void.double[]
1.9       parser    178:        // ^void.double(default)
1.8       parser    179:        add_native_method("double", Method::CT_DYNAMIC, _double, 0, 1);
1.1       parser    180: 
1.37      misha     181:        // ^void.bool[]
                    182:        // ^void.bool(default)
                    183:        add_native_method("bool", Method::CT_DYNAMIC, _bool, 0, 1);
                    184: 
1.41      misha     185:        // ^void:sql{query}
1.33      paf       186:        add_native_method("sql", Method::CT_STATIC, _sql, 1, 2);
1.32      paf       187: 
                    188:        // ^void.left() ^void.right()
                    189:        add_native_method("left", Method::CT_DYNAMIC, _left_right, 1, 1);
                    190:        add_native_method("right", Method::CT_DYNAMIC, _left_right, 1, 1);
                    191: 
                    192:        // ^void.mid(p;n)
                    193:        add_native_method("mid", Method::CT_DYNAMIC, _mid, 1, 2);
1.1       parser    194: }

E-mail: