PyMySQL
diff --git a/‎pymysql/connections.py
Copy file name to clipboardExpand all lines: pymysql/connections.py
+7-7Lines changed: 7 additions & 7 deletions b/‎pymysql/connections.py
Copy file name to clipboardExpand all lines: pymysql/connections.py
+7-7Lines changed: 7 additions & 7 deletions
@@ -1021,10 +1021,13 @@ def _execute_command(self, command, sql):
 
         # If the last query was unbuffered, make sure it finishes before
         # sending new commands
-        if self._result is not None and self._result.unbuffered_active:
-            warnings.warn("Previous unbuffered result was left incomplete")
-            self._result._finish_unbuffered_query()
-        self._result = None
+        if self._result is not None:
+            if self._result.unbuffered_active:
+                warnings.warn("Previous unbuffered result was left incomplete")
+                self._result._finish_unbuffered_query()
+            while self._result.has_next:
+                self.next_result()
+            self._result = None
 
         if isinstance(sql, text_type):
             sql = sql.encode(self.encoding)
@@ -1113,9 +1116,6 @@ def _request_authentication(self):
                 self.write_packet(data)
                 auth_packet = self._read_packet()
 
-        #TODO: ok packet or error packet?
-
-
     def _process_auth(self, plugin_name, auth_packet):
         plugin_class = self._auth_plugin_map.get(plugin_name)
         if not plugin_class: