Also expose #send_query && #get_result to the connection

Author: methodmissing

lib/active_record/connection_adapters/mysqlplus_adapter.rb

@@ -32,6 +32,24 @@ def socket
         @connection.socket
       end
 
+      # Send a query in an async non-blocking manner
+      #
+      def send_query( sql, name = nil, skip_logging = false )
+        if skip_logging
+          @connection.send_query( sql )
+        else  
+          log("(Socket #{socket.to_s}, Thread #{Thread.current.object_id.to_s}) #{sql}",name) do 
+            @connection.send_query( sql )
+          end
+        end
+      end
+      
+      # Retrieve a #send_query result set
+      #
+      def get_result
+        @connection.get_result
+      end
+      
       def execute(sql, name = nil, skip_logging = false) #:nodoc:
         if skip_logging
           @connection.c_async_query( sql )

test/mysqlplus_adapter_test.rb

@@ -0,0 +1,12 @@
+require "#{File.dirname(__FILE__)}/helper"
+
+Mysqlplus::Test.prepare!
+
+class MysqlPlusAdapterTest < ActiveSupport::TestCase
+    
+  test "should be able to execute queries in an async manner" do
+    MysqlUser.connection.send_query( "SELECT * FROM mysql.user WHERE User = 'root'" )
+    assert_instance_of Mysql::Result, MysqlUser.connection.get_result
+  end
+  
+end