mirror of
				https://github.com/MariaDB/server.git
				synced 2025-11-03 20:36:16 +01:00 
			
		
		
		
	This patch adds support for SYS_REFCURSOR (a weakly typed cursor)
for both sql_mode=ORACLE and sql_mode=DEFAULT.
Works as a regular stored routine variable, parameter and return value:
- can be passed as an IN parameter to stored functions and procedures
- can be passed as an INOUT and OUT parameter to stored procedures
- can be returned from a stored function
Note, strongly typed REF CURSOR will be added separately.
Note, to maintain dependencies easier, some parts of sql_class.h
and item.h were moved to new header files:
- select_results.h:
  class select_result_sink
  class select_result
  class select_result_interceptor
- sp_cursor.h:
  class sp_cursor_statistics
  class sp_cursor
- sp_rcontext_handler.h
  class Sp_rcontext_handler and its descendants
The implementation consists of the following parts:
- A new class sp_cursor_array deriving from Dynamic_array
- A new class Statement_rcontext which contains data shared
  between sub-statements of a compound statement.
  It has a member m_statement_cursors of the sp_cursor_array data type,
  as well as open cursor counter. THD inherits from Statement_rcontext.
- A new data type handler Type_handler_sys_refcursor in plugins/type_cursor/
  It is designed to store uint16 references -
  positions of the cursor in THD::m_statement_cursors.
- Type_handler_sys_refcursor suppresses some derived numeric features.
  When a SYS_REFCURSOR variable is used as an integer an error is raised.
- A new abstract class sp_instr_fetch_cursor. It's needed to share
  the common code between "OPEN cur" (for static cursors) and
  "OPER cur FOR stmt" (for SYS_REFCURSORs).
- New sp_instr classes:
  * sp_instr_copen_by_ref      - OPEN sys_ref_curor FOR stmt;
  * sp_instr_cfetch_by_ref     - FETCH sys_ref_cursor INTO targets;
  * sp_instr_cclose_by_ref     - CLOSE sys_ref_cursor;
  * sp_instr_destruct_variable - to destruct SYS_REFCURSOR variables when
                                 the execution goes out of the BEGIN..END block
                                 where SYS_REFCURSOR variables are declared.
- New methods in LEX:
  * sp_open_cursor_for_stmt   - handles "OPEN sys_ref_cursor FOR stmt".
  * sp_add_instr_fetch_cursor - "FETCH cur INTO targets" for both
                                static cursors and SYS_REFCURSORs.
  * sp_close - handles "CLOSE cur" both for static cursors and SYS_REFCURSORs.
- Changes in cursor functions to handle both static cursors and SYS_REFCURSORs:
  * Item_func_cursor_isopen
  * Item_func_cursor_found
  * Item_func_cursor_notfound
  * Item_func_cursor_rowcount
- A new system variable @@max_open_cursors - to limit the number
  of cursors (static and SYS_REFCURSORs) opened at the same time.
  Its allowed range is [0-65536], with 50 by default.
- A new virtual method Type_handler::can_return_bool() telling
  if calling item->val_bool() is allowed for Items of this data type,
  or if otherwise the "Illegal parameter for operation" error should be raised
  at fix_fields() time.
- New methods in Sp_rcontext_handler:
  * get_cursor()
  * get_cursor_by_ref()
- A new class Sp_rcontext_handler_statement to handle top level statement
  wide cursors which are shared by all substatements.
- A new virtual method expr_event_handler() in classes Item and Field.
  It's needed to close (and make available for a new OPEN)
  unused THD::m_statement_cursors elements which do not have any references
  any more. It can happen in various moments in time, e.g.
  * after evaluation parameters of an SQL routine
  * after assigning a cursor expression into a SYS_REFCURSOR variable
  * when leaving a BEGIN..END block with SYS_REFCURSOR variables
  * after setting OUT/INOUT routine actual parameters from formal
    parameters.
		
	
			
		
			
				
	
	
		
			178 lines
		
	
	
	
		
			7.5 KiB
		
	
	
	
		
			Text
		
	
	
	
	
	
			
		
		
	
	
			178 lines
		
	
	
	
		
			7.5 KiB
		
	
	
	
		
			Text
		
	
	
	
	
	
# restart
 | 
						|
drop table if exists test.marker;
 | 
						|
create table test.marker(a int);
 | 
						|
update performance_schema.setup_consumers set enabled='NO';
 | 
						|
update performance_schema.setup_instruments set enabled='NO';
 | 
						|
update performance_schema.setup_instruments set enabled='YES'
 | 
						|
  where name like "wait/io/table/%";
 | 
						|
truncate table performance_schema.events_waits_history_long;
 | 
						|
flush global status;
 | 
						|
flush tables;
 | 
						|
# We are forced to suppress here the server response.
 | 
						|
optimize table mysql.user;
 | 
						|
optimize table mysql.db;
 | 
						|
optimize table mysql.proxies_priv;
 | 
						|
optimize table mysql.roles_mapping;
 | 
						|
optimize table mysql.tables_priv;
 | 
						|
optimize table mysql.procs_priv;
 | 
						|
optimize table mysql.servers;
 | 
						|
optimize table mysql.roles_mapping;
 | 
						|
update performance_schema.setup_consumers set enabled='YES';
 | 
						|
update performance_schema.setup_objects set enabled='YES'
 | 
						|
  where object_type='TABLE' and object_schema= 'mysql';
 | 
						|
flush privileges;
 | 
						|
insert into test.marker set a = 1;
 | 
						|
insert into test.marker set a = 1;
 | 
						|
insert into test.marker set a = 1;
 | 
						|
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	5000
 | 
						|
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	227
 | 
						|
performance_schema_max_statement_stack	10
 | 
						|
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 global status like "performance_schema%";
 | 
						|
Variable_name	Value
 | 
						|
Performance_schema_accounts_lost	0
 | 
						|
Performance_schema_cond_classes_lost	0
 | 
						|
Performance_schema_cond_instances_lost	0
 | 
						|
Performance_schema_digest_lost	0
 | 
						|
Performance_schema_file_classes_lost	0
 | 
						|
Performance_schema_file_handles_lost	0
 | 
						|
Performance_schema_file_instances_lost	0
 | 
						|
Performance_schema_hosts_lost	0
 | 
						|
Performance_schema_index_stat_lost	0
 | 
						|
Performance_schema_locker_lost	0
 | 
						|
Performance_schema_memory_classes_lost	0
 | 
						|
Performance_schema_metadata_lock_lost	0
 | 
						|
Performance_schema_mutex_classes_lost	0
 | 
						|
Performance_schema_mutex_instances_lost	0
 | 
						|
Performance_schema_nested_statement_lost	0
 | 
						|
Performance_schema_prepared_statements_lost	0
 | 
						|
Performance_schema_program_lost	0
 | 
						|
Performance_schema_rwlock_classes_lost	0
 | 
						|
Performance_schema_rwlock_instances_lost	0
 | 
						|
Performance_schema_session_connect_attrs_lost	0
 | 
						|
Performance_schema_socket_classes_lost	0
 | 
						|
Performance_schema_socket_instances_lost	0
 | 
						|
Performance_schema_stage_classes_lost	0
 | 
						|
Performance_schema_statement_classes_lost	0
 | 
						|
Performance_schema_table_handles_lost	0
 | 
						|
Performance_schema_table_instances_lost	0
 | 
						|
Performance_schema_table_lock_stat_lost	0
 | 
						|
Performance_schema_thread_classes_lost	0
 | 
						|
Performance_schema_thread_instances_lost	0
 | 
						|
Performance_schema_users_lost	0
 | 
						|
update performance_schema.setup_consumers set enabled='NO';
 | 
						|
select event_name,
 | 
						|
left(source, locate(":", source)) as short_source,
 | 
						|
object_type, object_schema,
 | 
						|
if (locate("#sql-", object_name), "#sql-XXXX", object_name)
 | 
						|
as pretty_name,
 | 
						|
operation, number_of_bytes
 | 
						|
from performance_schema.events_waits_history_long
 | 
						|
where event_name like 'wait/io/table/%'
 | 
						|
  and object_schema in ("test", "mysql")
 | 
						|
order by thread_id, event_id;
 | 
						|
event_name	short_source	object_type	object_schema	pretty_name	operation	number_of_bytes
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	global_priv	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	global_priv	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	global_priv	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	global_priv	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	global_priv	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	global_priv	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	db	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	proxies_priv	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	proxies_priv	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	proxies_priv	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	proxies_priv	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	proxies_priv	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	roles_mapping	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	tables_priv	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	tables_priv	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	procs_priv	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	servers	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	table_stats	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	mysql	column_stats	fetch	1
 | 
						|
wait/io/table/sql/handler		TABLE	test	marker	insert	1
 | 
						|
wait/io/table/sql/handler		TABLE	test	marker	insert	1
 | 
						|
wait/io/table/sql/handler		TABLE	test	marker	insert	1
 | 
						|
show global status like 'performance_schema_%';
 | 
						|
Variable_name	Value
 | 
						|
Performance_schema_accounts_lost	0
 | 
						|
Performance_schema_cond_classes_lost	0
 | 
						|
Performance_schema_cond_instances_lost	0
 | 
						|
Performance_schema_digest_lost	0
 | 
						|
Performance_schema_file_classes_lost	0
 | 
						|
Performance_schema_file_handles_lost	0
 | 
						|
Performance_schema_file_instances_lost	0
 | 
						|
Performance_schema_hosts_lost	0
 | 
						|
Performance_schema_index_stat_lost	0
 | 
						|
Performance_schema_locker_lost	0
 | 
						|
Performance_schema_memory_classes_lost	0
 | 
						|
Performance_schema_metadata_lock_lost	0
 | 
						|
Performance_schema_mutex_classes_lost	0
 | 
						|
Performance_schema_mutex_instances_lost	0
 | 
						|
Performance_schema_nested_statement_lost	0
 | 
						|
Performance_schema_prepared_statements_lost	0
 | 
						|
Performance_schema_program_lost	0
 | 
						|
Performance_schema_rwlock_classes_lost	0
 | 
						|
Performance_schema_rwlock_instances_lost	0
 | 
						|
Performance_schema_session_connect_attrs_lost	0
 | 
						|
Performance_schema_socket_classes_lost	0
 | 
						|
Performance_schema_socket_instances_lost	0
 | 
						|
Performance_schema_stage_classes_lost	0
 | 
						|
Performance_schema_statement_classes_lost	0
 | 
						|
Performance_schema_table_handles_lost	0
 | 
						|
Performance_schema_table_instances_lost	0
 | 
						|
Performance_schema_table_lock_stat_lost	0
 | 
						|
Performance_schema_thread_classes_lost	0
 | 
						|
Performance_schema_thread_instances_lost	0
 | 
						|
Performance_schema_users_lost	0
 | 
						|
truncate performance_schema.events_waits_history_long;
 | 
						|
flush global status;
 | 
						|
update performance_schema.setup_consumers set enabled='NO';
 | 
						|
truncate performance_schema.events_waits_history_long;
 | 
						|
drop table test.marker;
 | 
						|
flush global status;
 | 
						|
update performance_schema.setup_instruments set enabled='YES';
 | 
						|
update performance_schema.setup_consumers set enabled='YES';
 | 
						|
update performance_schema.setup_objects set enabled='NO'
 | 
						|
  where object_type='TABLE' and object_schema= 'mysql';
 |