diff options
Diffstat (limited to 'storage/rocksdb/mysql-test/rocksdb/t/init_stats_procedure.inc')
-rw-r--r-- | storage/rocksdb/mysql-test/rocksdb/t/init_stats_procedure.inc | 40 |
1 files changed, 40 insertions, 0 deletions
diff --git a/storage/rocksdb/mysql-test/rocksdb/t/init_stats_procedure.inc b/storage/rocksdb/mysql-test/rocksdb/t/init_stats_procedure.inc new file mode 100644 index 00000000000..dda253bc346 --- /dev/null +++ b/storage/rocksdb/mysql-test/rocksdb/t/init_stats_procedure.inc @@ -0,0 +1,40 @@ +# This inc script creates two procedures -- save_read_stats() and +# get_read_stats(). get_read_stats() prints differential rocksdb_rows_read, +# rocksdb_rows_updated, and rocksdb_rows_deleted values since calling +# save_read_stats(). + +delimiter //; +create procedure save_read_stats() +begin + /*select rows_requested into @rq from information_schema.table_statistics + where table_schema=database() and table_name='t1';*/ + select rows_read into @rr_is from information_schema.table_statistics + where table_schema=database() and table_name='t1'; + select variable_value into @rr from information_schema.global_status + where variable_name='rocksdb_rows_read'; + select variable_value into @ru from information_schema.global_status + where variable_name='rocksdb_rows_updated'; + select variable_value into @rd from information_schema.global_status + where variable_name='rocksdb_rows_deleted'; +end// + +create procedure get_read_stats() +begin + /*select rows_requested - @rq as rows_requested from + information_schema.table_statistics + where table_schema=database() and table_name='t1';*/ + select rows_read - @rr_is as rows_read_userstat from + information_schema.table_statistics + where table_schema=database() and table_name='t1'; + select variable_value - @rr as rows_read from + information_schema.global_status + where variable_name='rocksdb_rows_read'; + select variable_value - @ru as rows_updated from + information_schema.global_status + where variable_name='rocksdb_rows_updated'; + select variable_value - @rd as rows_deleted from + information_schema.global_status + where variable_name='rocksdb_rows_deleted'; +end// +delimiter ;// + |