test/reconnected_test.rb @@ -851,6 +851,14 @@ static VALUE interrupted( VALUE obj ) return ( vio_was_interrupted( m->net.vio ) == 1 ? Qtrue : Qfalse ); } +/* reconnected */ +static VALUE reconnected( VALUE obj ){ + MYSQL* m = GetHandler(obj); + int current_connection_id = mysql_thread_id( m ); + mysql_ping(m); + return ( current_connection_id == mysql_thread_id( m ) ) ? Qfalse : Qtrue; +} + static void validate_async_query( VALUE obj ) { MYSQL* m = GetHandler(obj); @@ -2240,6 +2248,7 @@ void Init_mysql(void) rb_define_method(cMysql, "async_in_progress=", async_in_progress_set, 1); rb_define_method(cMysql, "send_query", send_query, 1); rb_define_method(cMysql, "simulate_disconnect", simulate_disconnect, 0); + rb_define_method(cMysql, "reconnected?", reconnected, 0); rb_define_method(cMysql, "get_result", get_result, 0); rb_define_method(cMysql, "readable?", readable, -1); rb_define_method(cMysql, "retry?", retry, 0); ext/mysql.c @@ -1,7 +1,7 @@ require File.dirname(__FILE__) + '/test_helper' -m = Mysql.real_connect('localhost','root') +m = Mysql.real_connect('localhost','root','','mysql') -m.c_async_query( 'SELECT SLEEP(1)' ) do |result| +m.c_async_query( 'SELECT * FROM user' ) do |result| puts result.inspect end \ No newline at end of file test/async_query_with_block_test.rb f57c2a65761cb2cbf5cccca231fed86c9ad0cbfc Lourens Naude lourens@methodmissing.com http://github.com/oldmoe/mysqlplus/commit/8e6f300f9db75f07c03049efd00a6b91fe16538d 8e6f300f9db75f07c03049efd00a6b91fe16538d 2008-10-08T09:09:47-07:00 2008-10-08T09:09:47-07:00 Introduce Mysql#reconnected? 514630a791cfe8e057acc62571a000b9f1a4fc3a Lourens Naude lourens@methodmissing.com