rpl_relayrotate.test
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:3k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. # When the relay log gets rotated while the I/O thread
  2. # is reading a transaction, the transaction spans on two or more
  3. # relay logs. If STOP SLAVE occurs while the SQL thread is
  4. # executing a part of the transaction in the non-first relay logs,
  5. # we test if START SLAVE will resume in the beginning of the
  6. # transaction (i.e., step back to the first relay log)
  7.   
  8. # The slave is started with max_binlog_size=16384 bytes,
  9. # to force many rotations (approximately 30 rotations)
  10. source include/have_innodb.inc;
  11. source include/master-slave.inc;
  12. connection slave;
  13. stop slave;
  14. connection master;
  15. --disable_warnings
  16. create table t1 (a int) engine=innodb;
  17. --enable_warnings
  18. let $1=8000;
  19. disable_query_log;
  20. begin;
  21. while ($1)
  22. {
  23. # eval means expand $ expressions
  24.  eval insert into t1 values( $1 );
  25.  dec $1;
  26. }
  27. commit;
  28. # This will generate a 500kB master's binlog,
  29. # which corresponds to 30 slave's relay logs.
  30. enable_query_log;
  31. save_master_pos;
  32. connection slave;
  33. reset slave;
  34. start slave;
  35. # We wait 1 sec for the SQL thread to be somewhere in
  36. # the middle of the transaction, hopefully not in
  37. # the first relay log, and hopefully before the COMMIT.
  38. # Usually it stops when the SQL thread is around the 15th relay log.
  39. # We cannot use MASTER_POS_WAIT() as master's position
  40. # increases only when the slave executes the COMMIT.
  41. # Note that except when using Valgrind, 1 second is enough for the I/O slave
  42. # thread to fetch the whole master's binlog.
  43. sleep 1;
  44. stop slave;
  45. # We suppose the SQL thread stopped before COMMIT.
  46. # If so the transaction was rolled back
  47. # and the table is now empty.
  48. # Now restart
  49. start slave;
  50. # And see if the table contains '8000'
  51. # which proves that the transaction restarted at
  52. # the right place.
  53. # We must wait for the transaction to commit before
  54. # reading, MASTER_POS_WAIT() will do it for sure
  55. # (the only statement with position>=3000 is COMMIT).
  56. select master_pos_wait('master-bin.001',3000)>=0;
  57. select * from t1 where a=8000;
  58. connection master;
  59. # The following DROP is a very important cleaning task:
  60. # imagine the next test is run with --skip-innodb: it will do
  61. # DROP TABLE IF EXISTS t1; but this will delete the frm and leave
  62. # some data in the InnoDB datafile (because at that time mysqld
  63. # does not know about InnoDB : --skip-innodb). So if later in the
  64. # test suite a test wants to create an InnoDB table called t1, it
  65. # will fail with 
  66. # InnoDB: Error: table t1 already exists in InnoDB internal
  67. # InnoDB: data dictionary. Have you deleted the .frm file etc
  68. drop table t1;
  69. # wait until this drop is executed on slave
  70. save_master_pos;
  71. connection slave;
  72. sync_with_master;
  73. # End of 4.1 tests