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