gistfile1.diff

diff --git a/ext/mysql.c b/ext/mysql.c
index b804723..d957978 100644
--- a/ext/mysql.c
+++ b/ext/mysql.c
@@ -798,13 +798,16 @@ static VALUE send_query(VALUE obj, VALUE sql)
 {
     MYSQL* m = GetHandler(obj);
 
+    free_old_query(m);
+
     Check_Type(sql, T_STRING);
     if (GetMysqlStruct(obj)->connection == Qfalse) {
         rb_raise(eMysql, "query: not connected");
     }
-         if (mysql_send_query(m, RSTRING_PTR(sql), RSTRING_LEN(sql)) != 0)
-             mysql_raise(m);
-         return Qnil;
+       if (mysql_send_query(m, RSTRING_PTR(sql), RSTRING_LEN(sql)) != 0)
+          mysql_raise(m);
+       GetMysqlStruct(obj)->query_with_result = Qtrue;
+       return Qnil;
 }
 
 /* get_result */
@@ -814,8 +817,8 @@ static VALUE get_result(VALUE obj)
     if (GetMysqlStruct(obj)->connection == Qfalse) {
         rb_raise(eMysql, "query: not connected");
     }
-         if (mysql_read_query_result(m) != 0)
-             mysql_raise(m);
+       if (mysql_read_query_result(m) != 0)
+           mysql_raise(m);
     if (GetMysqlStruct(obj)->query_with_result == Qfalse)
        return obj;
     if (mysql_field_count(m) == 0)