1--source include/have_rocksdb.inc 2 3SET GLOBAL rocksdb_write_disable_wal=false; 4SET GLOBAL rocksdb_write_ignore_missing_column_families=true; 5 6create table aaa (id int primary key, i int) engine rocksdb; 7set @save_rocksdb_flush_log_at_trx_commit=@@global.rocksdb_flush_log_at_trx_commit; 8SET GLOBAL rocksdb_flush_log_at_trx_commit=1; 9insert aaa(id, i) values(0,1); 10 11select variable_value into @a from information_schema.global_status where variable_name='rocksdb_wal_synced'; 12insert aaa(id, i) values(1,1); 13select variable_value-@a from information_schema.global_status where variable_name='rocksdb_wal_synced'; 14insert aaa(id, i) values(2,1); 15select variable_value-@a from information_schema.global_status where variable_name='rocksdb_wal_synced'; 16insert aaa(id, i) values(3,1); 17select variable_value-@a from information_schema.global_status where variable_name='rocksdb_wal_synced'; 18 19select variable_value into @a from information_schema.global_status where variable_name='rocksdb_wal_synced'; 20SET GLOBAL rocksdb_flush_log_at_trx_commit=0; 21insert aaa(id, i) values(4,1); 22 23let $status_var=rocksdb_wal_synced; 24let $status_var_value=`select @a+1`; 25source include/wait_for_status_var.inc; 26 27select variable_value into @a from information_schema.global_status where variable_name='rocksdb_wal_synced'; 28SET GLOBAL rocksdb_flush_log_at_trx_commit=2; 29insert aaa(id, i) values(5,1); 30 31let $status_var=rocksdb_wal_synced; 32let $status_var_value=`select @a+1`; 33source include/wait_for_status_var.inc; 34 35truncate table aaa; 36 37# Cleanup 38drop table aaa; 39set @@global.rocksdb_flush_log_at_trx_commit=@save_rocksdb_flush_log_at_trx_commit; 40SET GLOBAL rocksdb_write_disable_wal=false; 41SET GLOBAL rocksdb_write_ignore_missing_column_families=false; 42