diff --git a/src/modules/mysql/mysql.c b/src/modules/mysql/mysql.c
index dde5e1ab1b2062f1e9e535b20a90c0b0af3c5f59..44798c4ce754dc8d5d834bb222ca778845f87b10 100644
--- a/src/modules/mysql/mysql.c
+++ b/src/modules/mysql/mysql.c
@@ -1,5 +1,5 @@
 /*
- * $Id: mysql.c,v 1.11 1997/01/16 05:04:18 hubbe Exp $
+ * $Id: mysql.c,v 1.12 1997/01/30 23:45:22 grubba Exp $
  *
  * SQL database functionality for Pike
  *
@@ -59,7 +59,7 @@ typedef struct dynamic_buffer_s dynamic_buffer;
  * Globals
  */
 
-RCSID("$Id: mysql.c,v 1.11 1997/01/16 05:04:18 hubbe Exp $");
+RCSID("$Id: mysql.c,v 1.12 1997/01/30 23:45:22 grubba Exp $");
 
 struct program *mysql_program = NULL;
 
@@ -237,6 +237,7 @@ static void f_big_query(INT32 args)
   MYSQL *socket = PIKE_MYSQL->socket;
   MYSQL_RES *result;
   char *query;
+  int qlen;
   int tmp;
 
   if (!args) {
@@ -247,6 +248,7 @@ static void f_big_query(INT32 args)
   }
 
   query = sp[-args].u.string->str;
+  qlen = sp[-args].u.string->len;
 
   THREADS_ALLOW();
 
@@ -254,7 +256,11 @@ static void f_big_query(INT32 args)
    * which is closed at THREADS_DISALLOW()
    */
 
+#ifdef HAVE_MYSQL_REAL_QUERY
+  tmp = mysql_real_query(socket, query, qlen);
+#else
   tmp = mysql_query(socket, query);
+#endif /* HAVE_MYSQL_REAL_QUERY */
 
   THREADS_DISALLOW();