mirror of
https://github.com/MariaDB/server.git
synced 2025-10-31 02:46:29 +01:00
231 lines
9.9 KiB
SQL
231 lines
9.9 KiB
SQL
# Tests for the performance schema
|
|
|
|
# ==========================================
|
|
# HELPER include/transaction_setup.inc
|
|
# ==========================================
|
|
|
|
#
|
|
# UTILITY QUERIES
|
|
#
|
|
let $get_thread_id=
|
|
SELECT thread_id INTO @my_thread_id
|
|
FROM performance_schema.threads
|
|
WHERE processlist_id = connection_id();
|
|
|
|
let $disable_instruments=
|
|
UPDATE performance_schema.setup_instruments
|
|
SET enabled='no', timed='no'
|
|
WHERE name IN ('transaction');
|
|
|
|
let $enable_instruments=
|
|
UPDATE performance_schema.setup_instruments
|
|
SET enabled='yes', timed='yes'
|
|
WHERE name IN ('transaction');
|
|
|
|
let $def_count = -1;
|
|
|
|
--disable_warnings
|
|
DROP PROCEDURE IF EXISTS clear_transaction_tables;
|
|
--enable_warnings
|
|
|
|
--disable_result_log
|
|
|
|
DELIMITER $$;
|
|
CREATE PROCEDURE clear_transaction_tables()
|
|
BEGIN
|
|
truncate table performance_schema.events_transactions_current;
|
|
truncate table performance_schema.events_transactions_history;
|
|
truncate table performance_schema.events_transactions_history_long;
|
|
truncate table performance_schema.events_transactions_summary_by_thread_by_event_name;
|
|
truncate table performance_schema.events_transactions_summary_by_account_by_event_name;
|
|
truncate table performance_schema.events_transactions_summary_by_host_by_event_name;
|
|
truncate table performance_schema.events_transactions_summary_by_user_by_event_name;
|
|
truncate table performance_schema.events_transactions_summary_global_by_event_name;
|
|
END$$
|
|
|
|
CREATE PROCEDURE clear_transaction_history()
|
|
BEGIN
|
|
truncate table performance_schema.events_transactions_current;
|
|
truncate table performance_schema.events_transactions_history;
|
|
truncate table performance_schema.events_transactions_history_long;
|
|
END$$
|
|
|
|
CREATE PROCEDURE clear_statement_history()
|
|
BEGIN
|
|
truncate table performance_schema.events_statements_current;
|
|
truncate table performance_schema.events_statements_history;
|
|
truncate table performance_schema.events_statements_history_long;
|
|
END$$
|
|
|
|
CREATE PROCEDURE clear_history()
|
|
BEGIN
|
|
truncate table performance_schema.events_statements_current;
|
|
truncate table performance_schema.events_statements_history;
|
|
truncate table performance_schema.events_statements_history_long;
|
|
truncate table performance_schema.events_transactions_current;
|
|
truncate table performance_schema.events_transactions_history;
|
|
truncate table performance_schema.events_transactions_history_long;
|
|
END$$
|
|
|
|
CREATE PROCEDURE transaction_verifier(IN i_table INT,
|
|
IN i_thread_id INT,
|
|
IN i_event_name VARCHAR(64),
|
|
IN i_state VARCHAR(32),
|
|
IN i_xid_format_id INT,
|
|
IN i_xid_gtrid VARCHAR(130),
|
|
IN i_xid_bqual VARCHAR(130),
|
|
IN i_xa_state VARCHAR(64),
|
|
IN i_gtid VARCHAR(64),
|
|
IN i_access_mode VARCHAR(32),
|
|
IN i_isolation_level VARCHAR(64),
|
|
IN i_autocommit VARCHAR(16),
|
|
IN i_savepoints INT,
|
|
IN i_rb_savepoint INT,
|
|
IN i_rel_savepoint INT,
|
|
IN i_expected INT)
|
|
BEGIN
|
|
DECLARE table_name VARCHAR(64);
|
|
SET @thread_id = i_thread_id;
|
|
SET @event_id = 0;
|
|
SET @event_name = i_event_name;
|
|
SET @state = i_state;
|
|
SET @xid_format_id = i_xid_format_id;
|
|
SET @xid_gtrid = i_xid_gtrid;
|
|
SET @xid_bqual = i_xid_bqual;
|
|
SET @xa_state = i_xa_state;
|
|
SET @gtid = i_gtid;
|
|
SET @access_mode = i_access_mode;
|
|
SET @isolation_level = i_isolation_level;
|
|
SET @autocommit = i_autocommit;
|
|
SET @savepoints = i_savepoints;
|
|
SET @rb_savepoint = i_rb_savepoint;
|
|
SET @rel_savepoint = i_rel_savepoint;
|
|
SET @expected = i_expected;
|
|
|
|
#
|
|
# Build verification query based upon input parameters
|
|
#
|
|
|
|
IF i_table = 0 THEN
|
|
SET table_name = 'performance_schema.events_transactions_current';
|
|
ELSEIF i_table = 1 THEN
|
|
SET table_name = 'performance_schema.events_transactions_history';
|
|
ELSEIF i_table = 2 THEN
|
|
SET table_name = 'performance_schema.events_transactions_history_long';
|
|
ELSE
|
|
SET table_name = 'performance_schema.events_transactions_history';
|
|
END IF;
|
|
|
|
SET @query = CONCAT('SELECT COUNT(*) INTO @actual FROM ', table_name, ' WHERE');
|
|
|
|
IF i_thread_id != 0 THEN
|
|
SET @query = CONCAT(@query, ' (thread_id = @thread_id)');
|
|
END IF;
|
|
IF i_event_name != '' THEN
|
|
SET @query = CONCAT(@query, ' AND (event_name = @event_name)');
|
|
END IF;
|
|
IF i_state != '' THEN
|
|
SET @query = CONCAT(@query, ' AND (state = @state)');
|
|
END IF;
|
|
IF i_xid_format_id != '' THEN
|
|
SET @query = CONCAT(@query, ' AND (xid_format_id = @xid_format_id)');
|
|
END IF;
|
|
IF i_xid_gtrid != '' THEN
|
|
SET @query = CONCAT(@query, ' AND (xid_gtrid = @xid_gtrid)');
|
|
END IF;
|
|
IF i_xid_bqual != '' THEN
|
|
SET @query = CONCAT(@query, ' AND (xid_bqual = @xid_bqual)');
|
|
END IF;
|
|
IF i_xa_state != '' THEN
|
|
SET @query = CONCAT(@query, ' AND (xa_state = @xa_state)');
|
|
END IF;
|
|
IF i_gtid = 'NULL' THEN
|
|
SET @query = CONCAT(@query, ' AND (gtid IS NULL)');
|
|
ELSEIF i_gtid != '' THEN
|
|
SET @query = CONCAT(@query, ' AND (gtid = @gtid)');
|
|
END IF;
|
|
IF i_access_mode != '' THEN
|
|
SET @query = CONCAT(@query, ' AND (access_mode = @access_mode)');
|
|
END IF;
|
|
IF i_isolation_level != '' THEN
|
|
SET @query = CONCAT(@query, ' AND (isolation_level = @isolation_level)');
|
|
END IF;
|
|
IF i_autocommit != '' THEN
|
|
SET @query = CONCAT(@query, ' AND (autocommit = @autocommit)');
|
|
END IF;
|
|
IF i_savepoints != 0 THEN
|
|
SET @query = CONCAT(@query, ' AND (number_of_savepoints = @savepoints)');
|
|
END IF;
|
|
IF i_rb_savepoint != 0 THEN
|
|
SET @query = CONCAT(@query, ' AND (number_of_rollback_to_savepoint = @rb_savepoint)');
|
|
END IF;
|
|
IF i_rel_savepoint != 0 THEN
|
|
SET @query = CONCAT(@query, ' AND (number_of_release_savepoint = @rel_savepoint)');
|
|
END IF;
|
|
|
|
SET @query = CONCAT(@query, ' ORDER BY event_id;');
|
|
|
|
## DEBUG ## SELECT * FROM performance_schema.events_transactions_history ORDER BY event_id;
|
|
## SELECT @query AS "QUERY";
|
|
PREPARE stmt1 FROM @query;
|
|
EXECUTE stmt1;
|
|
DEALLOCATE PREPARE stmt1;
|
|
|
|
SELECT LPAD(@actual, 6, ' ') AS "ACTUAL", LPAD(@expected, 8, ' ') AS "EXPECTED";
|
|
|
|
IF @actual != @expected THEN
|
|
SELECT "" AS "ERROR: Row count mismatch";
|
|
SELECT @query AS "VERIFIER QUERY:";
|
|
SELECT "";
|
|
|
|
SET @columns = ' LPAD(@thread_id, 9, " ") AS thread_id,';
|
|
SET @columns = CONCAT(@columns, ' LPAD(@event_id, 10, " ") AS "..event_id",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(@event_name, 11, " ") AS "event_name ",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(@state, 11, " ") AS "state ",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(@xid_format_id, 15, " ") AS "xid_format_id ",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(@xid_gtrid, 15, " ") AS "xid_gtrid ",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(@xid_bqual, 15, " ") AS "xid_bqual ",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(@xa_state, 12, " ") AS "xa_state ",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(@gtid, 38, " ") AS "gtid ",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(@access_mode, 11, " ") AS access_mode,');
|
|
SET @columns = CONCAT(@columns, ' RPAD(@isolation_level, 16, " ") AS "isolation_level ",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(@autocommit, 10, " ") AS autocommit,');
|
|
SET @columns = CONCAT(@columns, ' LPAD(@savepoints, 10, " ") AS savepoints,');
|
|
SET @columns = CONCAT(@columns, ' LPAD(@rb_savepoint, 21, " ") AS rollback_to_savepoint,');
|
|
SET @columns = CONCAT(@columns, ' LPAD(@rel_savepoint, 17, " ") AS release_savepoint');
|
|
SET @query2 = CONCAT('SELECT', ' LPAD(@expected, 13, " ") AS ROWS_EXPECTED, ', @columns, ';');
|
|
# SET @query2 = CONCAT('SELECT " " AS EXPECTED, ', @columns, ';');
|
|
PREPARE stmt2 FROM @query2;
|
|
EXECUTE stmt2;
|
|
DEALLOCATE PREPARE stmt2;
|
|
|
|
SET @columns = ' LPAD(thread_id, 9, " ") AS thread_id,';
|
|
SET @columns = CONCAT(@columns, ' LPAD(event_id, 10, " ") AS "..event_id",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(event_name, 11, " ") AS "event_name ",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(state, 11, " ") AS "state ",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(IFNULL(xid_format_id, "NULL"), 15, " ") AS "xid_format_id ",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(IFNULL(xid_gtrid, "NULL"), 15, " ") AS "xid_gtrid ",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(IFNULL(xid_bqual, "NULL"), 15, " ") AS "xid_bqual ",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(IFNULL(xa_state, "NULL"), 12, " ") AS "xa_state ",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(IFNULL(gtid, "NULL"), 38, " ") AS "gtid ",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(access_mode, 11, " ") AS access_mode,');
|
|
SET @columns = CONCAT(@columns, ' RPAD(isolation_level, 16, " ") AS "isolation_level ",');
|
|
SET @columns = CONCAT(@columns, ' RPAD(autocommit, 10, " ") AS autocommit,');
|
|
SET @columns = CONCAT(@columns, ' LPAD(number_of_savepoints, 10, " ") AS savepoints,');
|
|
SET @columns = CONCAT(@columns, ' LPAD(number_of_rollback_to_savepoint, 21, " ") AS rollback_to_savepoint,');
|
|
SET @columns = CONCAT(@columns, ' LPAD(number_of_release_savepoint, 17, " ") AS release_savepoint');
|
|
# SET @query3 = CONCAT('SELECT " " AS "ACTUAL ", ', @columns, ' FROM ', table_name, ' ORDER BY event_id;');
|
|
SET @query3 = CONCAT('SELECT', ' LPAD(@actual, 13, " ") AS "ROWS_ACTUAL ",', @columns, ' FROM ', table_name, ' ORDER BY event_id;');
|
|
PREPARE stmt3 FROM @query3;
|
|
EXECUTE stmt3;
|
|
DEALLOCATE PREPARE stmt3;
|
|
|
|
END IF;
|
|
END$$
|
|
|
|
DELIMITER ;$$
|
|
|
|
--enable_result_log
|
|
|
|
|
|
|