mirror of
https://github.com/MariaDB/server.git
synced 2026-01-08 12:35:44 +01:00
75142ff496
This change adds CURSOR declarations inside PACKAGE BODY.
PL/SQL mode:
SET sql_mode=ORACLE;
CREATE PACKAGE BODY pkg AS
CURSOR mc0 IS SELECT c0, c1 FROM t1;
PROCEDURE p1 AS
rec mc0%ROWTYPE;
BEGIN
OPEN mc0;
FETCH mc0 INTO rec;
CLOSE mc0
END;
END;
/
SQL/PSM mode:
SET sql_mode=DEFAULT;
CREATE PACKAGE BODY pkg
mc0 CURSOR FOR SELECT c0, c1 FROM t1;
PROCEDURE p1()
BEGIN
DECLARE rec ROW TYPE OF mc0;
OPEN mc0;
FETCH mc0 INTO rec;
CLOSE mc0
END;
END;
/
PACKAGE BODY cursors like local cursors
(declared inside a FUNCTION or a PROCEDURE) support:
- OPEN/FETCH/CLOSE
- FOR rec IN cur - an explicit cursor loop
- Using a cursor row as an anchored variable data type:
* DECLARE var cur%ROWTYPE; -- sql_mode=ORACLE
* DECLARE var ROW TYPE OF cur; -- sql_mode=DEFAULT
The patch details:
- Changing various class members and function/method parameters which
store a CURSOR run-time address from "uint" to sp_rcontext_addr.
A few classes now derive from sp_rcontext_addr instead of having
a "uint m_cursor;" member.
This change uses the same idea with what we did for SP variables,
when we implemented PACKAGE BODY variables a few years ago.
- Fixing the grammar in sql_yacc.yy to allow CURSOR declarations
inside PACKAGE BODY.
- Adding a new class sp_pcontext_top. It's used for the top level parse
context (of an sp_head). Note, its children contexts still use the old
class sp_pcontext.
sp_pcontext_top context additionally to sp_pcontext has:
const sp_head *m_sp; -- The pointer to the sp_head owning this context
Dynamic_array<sp_pcursor> m_member_cursors; -- PACKAGE BODY wide cursors
m_sp->m_parent->get_parse_context() is used to find the sp_pcontext
belonging to the parent PACKAGE BODY from a sp_pcontext_top instance
belonging to a PROCEDURE/FUNCTION sp_pcontext_top.
- Adding a new member in sp_rcontext:
Dynamic_array<sp_cursor*> m_member_cursors;
It's used to store run-time data of PACKAGE BODY wide cursors.
- Adding a new class sp_instr_copen2. It's used to open PACKAGE BODY cursors.
Unlike the usual cursors, PACKAGE BODY cursors:
* do not use the cursor stack (sp_rcontext::m_cstack)
* do not need a preceeding sp_instr_cpush
* do not need a following sp_instr_cpop
All cursor information such as "sp_lex_cursor" resides inside
sp_instr_copen2 itself (rather than inside sp_instr_cpush which is
used to store "sp_lex_cursor" in case of sp_instr_copen).
Note, the other cursor related instructions:
sp_instr_cfetch
sp_instr_cclose
sp_instr_cursor_copy_struct
do not need sp_instr_xxx2 counter-parts.
Thy just use sp_rcontext_addr to address cursors.
- Adding Sp_rcontext_handler_member
It's used to handle PACKAGE BODY members:
cursors and variables declared in the PACKAGE BODY,
when they are accessed from its executable initialization section:
CREATE PACKAGE BODY pkg AS
CURSOR mc0 IS SELECT c0, c1 FROM t1; -- A member (PACKAGE BODY cursor)
mv0 mc0%ROWTYPE; -- A member (PACKAGE BODY variable)
PROCEDURE p1 AS
BEGIN
-- Accessing members from here use sp_rcontext_handler_package_body
-- (members of the parent PACKAGE BODY)
OPEN mc0;
FETCH mc0 INTO mv0;
CLOSE mc0;
END;
BEGIN
-- NEW:
-- Accessing members from here use sp_rcontext_handler_member
-- (PACKAGE BODY own members)
OPEN mc0;
FETCH mc0 INTO mv0;
CLOSE mc0;
END;
/
Member variables and cursor are now marked with the "MEMBER." prefix
in the "SHOW PACKAGE BODY code" output.
Some old MTR tests have been re-recorded accordingly.
- Adding new virtual methods into Sp_rcontext_handler:
virtual const sp_variable *get_pvariable(const sp_pcontext *pctx,
uint offset) const;
virtual const sp_pcursor *get_pcursor(const sp_pcontext *pctx,
uint offset) const;
They're used from sp_instr::print() virtual implementations.
They internally calculate a proper sp_pcontext using as a parameter
the sp_pcontext pointed by sp_instr::m_ctx.
For example, Sp_handler_package_body::get_pvariable()/get_pcursor()
accesses to this sp_pcontext:
m_ctx->top_context()->m_sp->m_parent->get_parse_context(),
i.e. the parse context of the PACKAGE BODY which is the parent for
the current package PROCEDURE of FUNCTION an sp_instr belongs to.
- Adding a new method LEX::find_cursor(). It searches for a cursor in
this order:
1. Local cursors in the nearst surrounding BEGIN/END block.
2a. A member cursor of the current PACKAGE BODY
(used from the PACKAGE BODY initialization section)
OR
2b. A member cursor of the parrent PACKAGE BODY
(used from a package PROCEDURE or a package FUNCTION)
Adding a new method LEX::find_cursor_with_error().
In case when a cursor is not found, it automatically
raises the ER_SP_CURSOR_MISMATCH SQL condition into
the diagnostics area.
- Adding a new method sp_head::add_instr_copenX().
It creates sp_instr_copen for local cursors,
or sp_instr_copen2 for non-local cursors.
- Adding a new abstract class sp_lex_cursor_instr.
It's used a common parent class for a few sp_instr_xxx classes,
including the new sp_instr_copen2.
This change is needed to avoid code duplication.
- Adding a new protected method sp_instr::print_cmd_and_var(), to print
an instruction using this format: "command name@offset".
It's used from a few implementations of sp_instr_xxx::print(),
including sp_instr_copen2::print().
This change is also needed to avoid code duplication.
- Adding a new method sp_pcontext::frame_for_members_candidate(),
to distinguish easier between local cursors/variables and
PACKAGE BODY cursors/variables.
- Fixing "struct Lex_for_loop_st" to addionally store
a const pointer to Sp_rcontext_handler, to distinguish between:
* FOR rec IN local_cursor
* FOR rec IN package_body_cursor
308 lines
10 KiB
Text
308 lines
10 KiB
Text
show databases;
|
|
Database
|
|
information_schema
|
|
mtr
|
|
mysql
|
|
performance_schema
|
|
sys
|
|
test
|
|
select count(*) from performance_schema.performance_timers;
|
|
count(*)
|
|
4
|
|
select count(*) from performance_schema.setup_consumers;
|
|
count(*)
|
|
15
|
|
select count(*) > 4 from performance_schema.setup_instruments;
|
|
count(*) > 4
|
|
1
|
|
select * from performance_schema.accounts;
|
|
select * from performance_schema.cond_instances;
|
|
select * from performance_schema.events_stages_current;
|
|
select * from performance_schema.events_stages_history;
|
|
select * from performance_schema.events_stages_history_long;
|
|
select * from performance_schema.events_stages_summary_by_account_by_event_name;
|
|
select * from performance_schema.events_stages_summary_by_host_by_event_name;
|
|
select * from performance_schema.events_stages_summary_by_thread_by_event_name;
|
|
select * from performance_schema.events_stages_summary_by_user_by_event_name;
|
|
select * from performance_schema.events_stages_summary_global_by_event_name;
|
|
select * from performance_schema.events_statements_current;
|
|
select * from performance_schema.events_statements_history;
|
|
select * from performance_schema.events_statements_history_long;
|
|
select * from performance_schema.events_statements_summary_by_account_by_event_name;
|
|
select * from performance_schema.events_statements_summary_by_digest;
|
|
select * from performance_schema.events_statements_summary_by_host_by_event_name;
|
|
select * from performance_schema.events_statements_summary_by_thread_by_event_name;
|
|
select * from performance_schema.events_statements_summary_by_user_by_event_name;
|
|
select * from performance_schema.events_statements_summary_global_by_event_name;
|
|
select * from performance_schema.events_transactions_current;
|
|
select * from performance_schema.events_transactions_history;
|
|
select * from performance_schema.events_transactions_history_long;
|
|
select * from performance_schema.events_transactions_summary_by_account_by_event_name;
|
|
select * from performance_schema.events_transactions_summary_by_host_by_event_name;
|
|
select * from performance_schema.events_transactions_summary_by_thread_by_event_name;
|
|
select * from performance_schema.events_transactions_summary_by_user_by_event_name;
|
|
select * from performance_schema.events_transactions_summary_global_by_event_name;
|
|
select * from performance_schema.events_waits_current;
|
|
select * from performance_schema.events_waits_history;
|
|
select * from performance_schema.events_waits_history_long;
|
|
select * from performance_schema.events_waits_summary_by_account_by_event_name;
|
|
select * from performance_schema.events_waits_summary_by_host_by_event_name;
|
|
select * from performance_schema.events_waits_summary_by_instance;
|
|
select * from performance_schema.events_waits_summary_by_thread_by_event_name;
|
|
select * from performance_schema.events_waits_summary_by_user_by_event_name;
|
|
select * from performance_schema.events_waits_summary_global_by_event_name;
|
|
select * from performance_schema.memory_summary_by_account_by_event_name;
|
|
select * from performance_schema.memory_summary_by_host_by_event_name;
|
|
select * from performance_schema.memory_summary_by_thread_by_event_name;
|
|
select * from performance_schema.memory_summary_by_user_by_event_name;
|
|
select * from performance_schema.memory_summary_global_by_event_name;
|
|
select * from performance_schema.file_instances;
|
|
select * from performance_schema.file_summary_by_event_name;
|
|
select * from performance_schema.file_summary_by_instance;
|
|
select * from performance_schema.host_cache;
|
|
select * from performance_schema.hosts;
|
|
select * from performance_schema.memory_summary_by_account_by_event_name;
|
|
select * from performance_schema.memory_summary_by_host_by_event_name;
|
|
select * from performance_schema.memory_summary_by_thread_by_event_name;
|
|
select * from performance_schema.memory_summary_by_user_by_event_name;
|
|
select * from performance_schema.memory_summary_global_by_event_name;
|
|
select * from performance_schema.metadata_locks;
|
|
select * from performance_schema.mutex_instances;
|
|
select * from performance_schema.objects_summary_global_by_type;
|
|
select * from performance_schema.performance_timers;
|
|
select * from performance_schema.rwlock_instances;
|
|
select * from performance_schema.session_account_connect_attrs;
|
|
select * from performance_schema.session_connect_attrs;
|
|
select * from performance_schema.setup_actors;
|
|
select * from performance_schema.setup_consumers;
|
|
select * from performance_schema.setup_instruments;
|
|
select * from performance_schema.setup_objects;
|
|
select * from performance_schema.socket_instances;
|
|
select * from performance_schema.socket_summary_by_instance;
|
|
select * from performance_schema.socket_summary_by_event_name;
|
|
select * from performance_schema.table_handles;
|
|
select * from performance_schema.table_io_waits_summary_by_index_usage;
|
|
select * from performance_schema.table_io_waits_summary_by_table;
|
|
select * from performance_schema.table_lock_waits_summary_by_table;
|
|
select * from performance_schema.threads;
|
|
select * from performance_schema.users;
|
|
select * from performance_schema.replication_connection_configuration;
|
|
select * from performance_schema.replication_applier_configuration;
|
|
select * from performance_schema.replication_applier_status;
|
|
select * from performance_schema.replication_applier_status_by_coordinator;
|
|
select * from performance_schema.global_status;
|
|
select * from performance_schema.status_by_thread;
|
|
select * from performance_schema.status_by_user;
|
|
select * from performance_schema.status_by_host;
|
|
select * from performance_schema.status_by_account;
|
|
select * from performance_schema.session_status;
|
|
show global variables like "performance_schema%";
|
|
Variable_name Value
|
|
performance_schema ON
|
|
performance_schema_accounts_size 100
|
|
performance_schema_digests_size 200
|
|
performance_schema_events_stages_history_long_size 1000
|
|
performance_schema_events_stages_history_size 10
|
|
performance_schema_events_statements_history_long_size 1000
|
|
performance_schema_events_statements_history_size 10
|
|
performance_schema_events_transactions_history_long_size 1000
|
|
performance_schema_events_transactions_history_size 10
|
|
performance_schema_events_waits_history_long_size 10000
|
|
performance_schema_events_waits_history_size 10
|
|
performance_schema_hosts_size 100
|
|
performance_schema_max_cond_classes 90
|
|
performance_schema_max_cond_instances 1500
|
|
performance_schema_max_digest_length 1024
|
|
performance_schema_max_file_classes 80
|
|
performance_schema_max_file_handles 32768
|
|
performance_schema_max_file_instances 10000
|
|
performance_schema_max_index_stat 5000
|
|
performance_schema_max_memory_classes 320
|
|
performance_schema_max_metadata_locks 10000
|
|
performance_schema_max_mutex_classes 210
|
|
performance_schema_max_mutex_instances 5000
|
|
performance_schema_max_prepared_statements_instances 100
|
|
performance_schema_max_program_instances 0
|
|
performance_schema_max_rwlock_classes 50
|
|
performance_schema_max_rwlock_instances 5000
|
|
performance_schema_max_socket_classes 10
|
|
performance_schema_max_socket_instances 1000
|
|
performance_schema_max_sql_text_length 1024
|
|
performance_schema_max_stage_classes 160
|
|
performance_schema_max_statement_classes 228
|
|
performance_schema_max_statement_stack 1
|
|
performance_schema_max_table_handles 1000
|
|
performance_schema_max_table_instances 500
|
|
performance_schema_max_table_lock_stat 500
|
|
performance_schema_max_thread_classes 50
|
|
performance_schema_max_thread_instances 400
|
|
performance_schema_session_connect_attrs_size 2048
|
|
performance_schema_setup_actors_size 100
|
|
performance_schema_setup_objects_size 100
|
|
performance_schema_users_size 100
|
|
show engine PERFORMANCE_SCHEMA status;
|
|
show global status like "performance_schema%";
|
|
show global variables like "performance_schema_max_program_instances";
|
|
Variable_name Value
|
|
performance_schema_max_program_instances 0
|
|
show global variables like "performance_schema_max_statement_stack";
|
|
Variable_name Value
|
|
performance_schema_max_statement_stack 1
|
|
#####################
|
|
# Setup
|
|
#####################
|
|
# SET-UP
|
|
CREATE DATABASE nested_sp;
|
|
USE nested_sp;
|
|
CREATE TABLE t1(
|
|
id CHAR(16) NOT NULL DEFAULT '',
|
|
data INT NOT NULL
|
|
);
|
|
CREATE TABLE t2(
|
|
n INT UNSIGNED NOT NULL,
|
|
f BIGINT UNSIGNED
|
|
);
|
|
############################
|
|
# Creating Stored Programs #
|
|
############################
|
|
CREATE PROCEDURE c1(x INT)
|
|
CALL c2("c", x)|
|
|
CREATE PROCEDURE c2(s CHAR(16), x INT)
|
|
CALL c3(x, s)|
|
|
CREATE PROCEDURE c3(x INT, s CHAR(16))
|
|
CALL c4("level", x, s)|
|
|
CREATE PROCEDURE c4(l CHAR(8), x INT, s CHAR(16))
|
|
INSERT INTO t1 VALUES (concat(l,s), x)|
|
|
CREATE PROCEDURE iotest(x1 CHAR(16), x2 CHAR(16), y INT)
|
|
BEGIN
|
|
CALL inc2(x2, y);
|
|
INSERT INTO t1 VALUES (x1, y);
|
|
END|
|
|
CREATE PROCEDURE inc2(x CHAR(16), y INT)
|
|
BEGIN
|
|
CALL inc(y);
|
|
INSERT INTO t1 VALUES (x, y);
|
|
END|
|
|
CREATE PROCEDURE inc(inout io INT)
|
|
SET io = io + 1|
|
|
CREATE FUNCTION mul(x INT, y INT) RETURNS INT
|
|
RETURN x*y|
|
|
CREATE FUNCTION inc(i INT) RETURNS INT
|
|
RETURN i+1|
|
|
CREATE FUNCTION fac(n INT UNSIGNED) RETURNS BIGINT UNSIGNED
|
|
BEGIN
|
|
DECLARE f BIGINT UNSIGNED DEFAULT 1;
|
|
WHILE n > 1 DO
|
|
SET f = f * n;
|
|
SET n = n - 1;
|
|
END WHILE;
|
|
RETURN f;
|
|
END|
|
|
CREATE FUNCTION fun(i INT, u INT UNSIGNED) RETURNS DOUBLE
|
|
RETURN mul(inc(i), fac(u))|
|
|
CREATE PROCEDURE ifac(n INT UNSIGNED)
|
|
BEGIN
|
|
DECLARE i BIGINT UNSIGNED DEFAULT 1;
|
|
IF n > 20 THEN
|
|
SET n = 20; # bigint overflow otherwise
|
|
END IF;
|
|
WHILE i <= n DO
|
|
BEGIN
|
|
INSERT INTO t2 VALUES (i, fac(i));
|
|
SET i = i + 1;
|
|
END;
|
|
END WHILE;
|
|
END|
|
|
CREATE TRIGGER trg AFTER INSERT ON t1 FOR EACH ROW
|
|
CALL ifac(10)|
|
|
TRUNCATE performance_schema.events_statements_summary_by_program;
|
|
#####################
|
|
# Executing Queries
|
|
#####################
|
|
#####################
|
|
# Executing queries #
|
|
#####################
|
|
CALL c1(42);
|
|
SELECT * FROM t1;
|
|
id data
|
|
levelc 42
|
|
DELETE FROM t1;
|
|
CALL iotest("io1", "io2", 1);
|
|
SELECT * FROM t1 ORDER BY data DESC;
|
|
id data
|
|
io2 2
|
|
io1 1
|
|
DELETE FROM t1;
|
|
SELECT fun(6,10);
|
|
fun(6,10)
|
|
25401600
|
|
INSERT INTO t1 VALUES (20,13);
|
|
SELECT * FROM t2;
|
|
n f
|
|
1 1
|
|
2 2
|
|
3 6
|
|
4 24
|
|
5 120
|
|
6 720
|
|
7 5040
|
|
8 40320
|
|
9 362880
|
|
10 3628800
|
|
1 1
|
|
2 2
|
|
3 6
|
|
4 24
|
|
5 120
|
|
6 720
|
|
7 5040
|
|
8 40320
|
|
9 362880
|
|
10 3628800
|
|
1 1
|
|
2 2
|
|
3 6
|
|
4 24
|
|
5 120
|
|
6 720
|
|
7 5040
|
|
8 40320
|
|
9 362880
|
|
10 3628800
|
|
1 1
|
|
2 2
|
|
3 6
|
|
4 24
|
|
5 120
|
|
6 720
|
|
7 5040
|
|
8 40320
|
|
9 362880
|
|
10 3628800
|
|
###########################################
|
|
# Quering PS statement summary table #
|
|
###########################################
|
|
SELECT OBJECT_TYPE, OBJECT_NAME, OBJECT_SCHEMA
|
|
FROM performance_schema.events_statements_summary_by_program;
|
|
OBJECT_TYPE OBJECT_NAME OBJECT_SCHEMA
|
|
SELECT COUNT(*) FROM performance_schema.events_statements_summary_by_program;
|
|
COUNT(*)
|
|
0
|
|
#####################
|
|
# Cleanup
|
|
#####################
|
|
DROP PROCEDURE c4;
|
|
DROP PROCEDURE c3;
|
|
DROP PROCEDURE c2;
|
|
DROP PROCEDURE c1;
|
|
DROP PROCEDURE inc;
|
|
DROP PROCEDURE inc2;
|
|
DROP PROCEDURE iotest;
|
|
DROP FUNCTION mul;
|
|
DROP FUNCTION inc;
|
|
DROP FUNCTION fac;
|
|
DROP FUNCTION fun;
|
|
DROP PROCEDURE ifac;
|
|
DROP TRIGGER trg;
|
|
DROP TABLE t1,t2;
|
|
DROP DATABASE nested_sp;
|