lib/oculus/connection/mysql2.rb in oculus-0.8.0 vs lib/oculus/connection/mysql2.rb in oculus-0.9.0

@@ -12,9 +12,13 @@
         [results.fields] + results.map(&:values) if results
       rescue ::Mysql2::Error => e
         raise Connection::Error.new(e.message)
       end
 
+      def kill(id)
+        execute("KILL QUERY #{id}")
+      end
+
       def thread_id
         @connection.thread_id
       end
     end
   end