1--source include/have_rocksdb.inc
2
3--disable_warnings
4DROP TABLE IF EXISTS t1;
5DROP TABLE IF EXISTS t2;
6--enable_warnings
7
8create table t1 (a int, primary key(a) comment 'lock_into_cf1') engine=rocksdb;
9insert into t1 values (1);
10insert into t1 values (2);
11
12create table t2 (a int, primary key(a) comment 'lock_info_cf2') engine=rocksdb;
13insert into t2 values (1);
14insert into t2 values (2);
15
16set autocommit=0;
17select * from t1 for update;
18select * from t2 for update;
19
20use information_schema;
21--replace_column 2 _txn_id_ 3 _key_
22select rocksdb_ddl.cf, rocksdb_locks.transaction_id, rocksdb_locks.key
23from rocksdb_locks
24left join rocksdb_ddl
25on rocksdb_locks.column_family_id=rocksdb_ddl.column_family
26order by rocksdb_ddl.cf;
27
28use test;
29
30DROP TABLE t1;
31DROP TABLE t2;
32