1DROP TABLE IF EXISTS t1; 2create table t1 (a int primary key, msg varchar(255)) engine=rocksdb; 3SET GLOBAL ROCKSDB_ENABLE_2PC = ON; 4SET SESSION debug_dbug="d,crash_commit_after_prepare"; 5insert into t1 values (1, 'dogz'); 6select * from t1; 7a msg 8SET GLOBAL ROCKSDB_ENABLE_2PC = ON; 9SET SESSION debug_dbug="d,crash_commit_after_log"; 10insert into t1 values (2, 'catz'), (3, 'men'); 11select * from t1; 12a msg 132 catz 143 men 15SET GLOBAL ROCKSDB_ENABLE_2PC = ON; 16SET SESSION debug_dbug="d,crash_commit_after"; 17insert into t1 values (4, 'cars'), (5, 'foo'); 18select * from t1; 19a msg 202 catz 213 men 224 cars 235 foo 24SET GLOBAL ROCKSDB_ENABLE_2PC = OFF; 25SET SESSION debug_dbug="d,crash_commit_after_log"; 26insert into t1 values (6, 'shipz'), (7, 'tankz'); 27select * from t1; 28a msg 292 catz 303 men 314 cars 325 foo 33SET GLOBAL ROCKSDB_ENABLE_2PC = OFF; 34SET SESSION debug_dbug="d,crash_commit_after"; 35insert into t1 values (8, 'space'), (9, 'time'); 36select * from t1; 37a msg 382 catz 393 men 404 cars 415 foo 428 space 439 time 44drop table t1; 45