--- parser3/src/classes/void.C	2001/06/28 07:41:59	1.2
+++ parser3/src/classes/void.C	2020/12/15 17:10:29	1.58
@@ -1,111 +1,85 @@
 /** @file
 	Parser: @b VOID parser class.
 
-	Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com)
-
-	Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf)
-
-	$Id: void.C,v 1.2 2001/06/28 07:41:59 parser Exp $
+	Copyright (c) 2001-2020 Art. Lebedev Studio (http://www.artlebedev.com)
+	Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)
 */
-static char *RCSId="$Id: void.C,v 1.2 2001/06/28 07:41:59 parser Exp $"; 
 
 #include "classes.h"
+#include "pa_vmethod_frame.h"
+
 #include "pa_request.h"
-#include "pa_vint.h"
-#include "pa_vdouble.h"
 #include "pa_vvoid.h"
 #include "pa_sql_connection.h"
 
-// defines
-
-#define VOID_CLASS_NAME "void"
+volatile const char * IDENT_VOID_C="$Id: void.C,v 1.58 2020/12/15 17:10:29 moko Exp $";
 
 // class
 
-class MVoid : public Methoded {
+class MVoid: public Methoded {
 public:
-	MVoid(Pool& pool);
-public: // Methoded
-	bool used_directly() { return true; }
+	MVoid();
 };
 
-// methods
-
-static void _int(Request& r, const String&, MethodParams *) {
-	Pool& pool=r.pool();
-	VInt *vunknown=static_cast<VInt *>(r.self);
-	Value& value=*new(pool) VInt(pool, vunknown->as_int());
-	r.write_no_lang(value);
-}
-
-static void _double(Request& r, const String&, MethodParams *) {
-	Pool& pool=r.pool();
-	VInt *vunknown=static_cast<VInt *>(r.self);
-	Value& value=*new(pool) VDouble(pool, vunknown->as_double());
-	r.write_no_lang(value);
-}
+// void is inherited from string, thus global variable declared in string.C
 
-static void _sql(Request& r, const String& method_name, MethodParams *params) {
-	Pool& pool=r.pool();
+// methods
 
-	if(!r.connection)
-		PTHROW(0, 0,
-			&method_name,
-			"without connect");
-
-	Value& statement=params->get_junction(0, "statement must be code");
-
-	Temp_lang temp_lang(r, String::UL_SQL);
-	const String& statement_string=r.process(statement).as_string();
-	const char *statement_cstr=
-		statement_string.cstr(String::UL_UNSPECIFIED, r.connection);
-	unsigned int sql_column_count; SQL_Driver::Cell *sql_columns;
-	unsigned long sql_row_count; SQL_Driver::Cell **sql_rows;
-	bool need_rethrow=false; Exception rethrow_me;
-	PTRY {
-		r.connection->query(
-			statement_cstr, 0, 0,
-			&sql_column_count, &sql_columns,
-			&sql_row_count, &sql_rows);
-	}
-	PCATCH(e) { // connect/process problem
-		rethrow_me=e;  need_rethrow=true;
+#ifndef DOXYGEN
+class Void_sql_event_handlers: public SQL_Driver_query_event_handlers {
+public:
+	bool add_column(SQL_Error& /*error*/, const char* /*str*/, size_t /*length*/) { /* ignore */ return false; }
+	bool before_rows(SQL_Error& error) {
+		// there are some result rows, which is wrong
+		error=SQL_Error("must return nothing");
+		return true;
 	}
-	PEND_CATCH
-	if(need_rethrow)
-		PTHROW(rethrow_me.type(), rethrow_me.code(),
-			&statement_string, // setting more specific source [were url]
-			rethrow_me.comment());
-
-	// there are some result rows, which is wrong
-	if(sql_row_count)
-		PTHROW(0, 0,
-			&statement_string,
-			"must not return result");
-}
+	bool add_row(SQL_Error& /*error*/) { /* never */ return false; }
+	bool add_row_cell(SQL_Error& /*error*/, const char* /*str*/, size_t /*length*/) { /* never */ return false; }
 
-// constructor
+};
+#endif
 
-MVoid::MVoid(Pool& apool) : Methoded(apool) {
-	set_name(*NEW String(pool(), VOID_CLASS_NAME));
+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) {
+	Value& statement=params.as_junction(0, "statement must be code");
 
-	// ^VOID.int[]
-	add_native_method("int", Method::CT_DYNAMIC, _int, 0, 0);
+	HashStringValue* bind=0;
+	if(params.count()>1)
+		if(HashStringValue* options=params.as_hash(1, "sql options")) {
+			int valid_options=0;
+			if(Value* vbind=options->get(sql_bind_name)) {
+				valid_options++;
+				bind=vbind->get_hash();
+			}
+			if(valid_options!=options->count())
+				throw Exception(PARSER_RUNTIME, 0, CALLED_WITH_INVALID_OPTION);
+		}
+
+	SQL_Driver::Placeholder* placeholders=0;
+	uint placeholders_count=0;
+	if(bind)
+		placeholders_count=marshal_binds(*bind, placeholders);
 
-	// ^VOID.double[]
-	add_native_method("double", Method::CT_DYNAMIC, _double, 0, 0);
+	const String& statement_string=r.process_to_string(statement);
+	const char* statement_cstr=statement_string.untaint_cstr(String::L_SQL, r.connection());
 
-	// ^sql[query]
-	add_native_method("sql", Method::CT_STATIC, _sql, 1, 1);
+	Void_sql_event_handlers handlers;
+	r.connection()->query(statement_cstr, placeholders_count, placeholders, 0, SQL_NO_LIMIT, handlers, statement_string);
+
+	if(bind)
+		unmarshal_bind_updates(*bind, placeholders_count, placeholders);
 }
 
-// global variable
+// constructor
 
-Methoded *void_class;
+MVoid::MVoid(): Methoded("void") {
+	set_base(string_class);
 
-// creator
+	// ^void:sql{query}
+	add_native_method("sql", Method::CT_STATIC, _sql, 1, 2);
 
-Methoded *MVoid_create(Pool& pool) {
-	return void_class=new(pool) MVoid(pool);
+	// all other methods are inherinted from empty string
 }