summaryrefslogtreecommitdiff
path: root/storage/rocksdb/mysql-test/rocksdb/t/trx_info_rpl.test
diff options
context:
space:
mode:
Diffstat (limited to 'storage/rocksdb/mysql-test/rocksdb/t/trx_info_rpl.test')
-rw-r--r--storage/rocksdb/mysql-test/rocksdb/t/trx_info_rpl.test42
1 files changed, 42 insertions, 0 deletions
diff --git a/storage/rocksdb/mysql-test/rocksdb/t/trx_info_rpl.test b/storage/rocksdb/mysql-test/rocksdb/t/trx_info_rpl.test
new file mode 100644
index 00000000000..19499765140
--- /dev/null
+++ b/storage/rocksdb/mysql-test/rocksdb/t/trx_info_rpl.test
@@ -0,0 +1,42 @@
+--source include/master-slave.inc
+
+--disable_warnings
+DROP TABLE IF EXISTS t1;
+connection slave;
+--source include/stop_slave.inc
+--enable_warnings
+
+connection master;
+create table t1 (a int) engine=rocksdb;
+--disable_query_log
+--let $aa= 0
+while ($aa < 1000) {
+ eval insert into t1 values ($aa);
+ --inc $aa
+}
+--enable_query_log
+
+connection slave;
+show variables like 'rocksdb_rpl_skip_tx_api';
+--source include/start_slave.inc
+
+--let $it=0
+--let $stop=0
+while ($stop != 1) {
+let $count= query_get_value(select count(*) as Value from information_schema.rocksdb_trx, Value, 1);
+ if ($count) {
+ --echo found
+ --let $stop=1
+ }
+
+ if ($it > 1000) {
+ --echo not found
+ --let $stop=1
+ }
+
+ --inc $it
+}
+
+connection master;
+DROP TABLE t1;
+--source include/rpl_end.inc