File: //usr/lib/mysqlsh/plugins/debug/__pycache__/sql_collector.cpython-39.pyc
a
��kf� � @ s� d dl mZ d dlmZ d dlmZmZ d dlmZm Z m
Z
m Z d dl Z d dl
Z
d dlZd dlZddlmZmZ eejd�d d
�Zd d � Zd
d� Zdd� ZG dd� d�Zd�ejeeed�dd�Z g fdddg ddd�ejeeee e e e e
e e e e e ed� dd �Z dddd �ejeed �d d �Z ddd!�ejeee e e e e d"�d#d$�Z!dddd%�ejeeee e d&�d'd(�Z"ejeeed)�d*d+�Z#d,d-d.d/� d0d/� dd1fd2d3d4d5d/� dd1fd6d7d8d9d/� dd:fd;d7d8d<d/� dd:fd=d>d?d@d/� dd1fdAd7d8dBd/� ddCfdDd>d?dEd/� ddFfdGdHdIdJd/� dKdLfdMd>d?dNd/� dKdLfdOdPdQdRd/� ddSfdTd>d?dUd/� ddSfdVdWdXdYd/� dKdZfd[d>d?d\d/� dKd]fd^d_d`dad/� dKdbfdcd-ddded/� ddffdgd3d4dhd/� ddffdidjdkdld/� ddmfdndodpdqd/� ddmfdrd>d?dsd/� ddffdtdodpdud/� ddvfdwdxdydzd/� dd{fd|d>d?d}d/� dd{fd~d7d8dd/� dd�fd�dodpd�d/� dd�fd�d>d?d�d/� dd�fgZ$G d�d�� d��Z%G d�d�� d��Z&dg g fejeee'e(ee e e e e d�� d�d��Z)dg fejeee e e d��d�d��Z*ejeee
e d��d�d��Z+ed��d�d��Z,ejeee e d��d�d��Z-dd��ejeee d��d�d��Z.d�ejeed��d�d��Z/d�ejeed��d�d��Z0ejeeeed��d�d��Z1ejeeee d��d�d��Z2ejeeed��d�d��Z3dS )�� )� Condition)�Thread)�mysql�Error)�Callable�List�Optional�TupleN� )�
ShellExecutor� split_phases)�path�returnc C s t j| ttj�� �� �d�S )N)� date_time)�zipfile�ZipInfo�tuple�datetime�now� timetuple)r
� r �//usr/lib/mysqlsh/plugins/debug/sql_collector.py� make_zipinfo$ s
��r c C s$ | � dd�� dd�� dd�� dd�S )N� �_�:�\�/)�replace��sr r r �sanitize* s ���r! c C s~ | d u r d S | dk r"t | �� d�S | dk r:| d d�d�S | dk rR| d d�d�S | dk rj| d d�d �S | d d�d
�S d S ) Ni z bytesi �0.2fz KiBi @z MiBl z GiBz TiB)�int)�nr r r � format_bytes0 s r% c C s� | d u r d S | dkr$| d d�d�S | dkr<| d d�d�S | dkrT| d d�d�S | dkrl| d d�d �S | d
kr�| d
d�d �S | d kr�| d d�d
�S | dkr�| d d�d�S | dkr�| d d�d�S | � d�S d S )Nl P�9%Cr" z wl 09^Q� z dl b"�(f z hl @_-GZ z ml J)�z si ʚ;z msi@B z usi� z nsz psr )Z picosecondsr r r �format_pico_time? s& r& c @ sB e Zd Zdd� Zdd� Zeed�dd��Zg feed�d d
�Z d S ) �InstanceSessionc C s` || _ | �d��� \| _}d|v r0|�d�d }|�d�\}}}t|�d t|�d t|� | _dd� | �d ��� D �| _d
d� | �d ��� D �| _ d d� | �d
��� D �| _
dd� | �d��� D �| _ dd� | �d��� D �}d|v | _ d| jv | _
| j �d��� �rPd| _z| j �d��� d | _W n" | j �d��� d | _Y n0 n d| _d| _d S )Nz/select @@performance_schema <> 'OFF', @@version�-r �.i' �d c S s g | ] }|d �qS �r r ��.0�tr r r �
<listcomp>b s z,InstanceSession.__init__.<locals>.<listcomp>z!show tables in performance_schemac S s g | ] }|d �qS r+ r r, r r r r/ f s z!show tables in information_schemac S s g | ] }|d �qS r+ r �r- �rr r r r/ j s zshow tables in sysc S s g | ] }|d �qS r+ r r0 r r r r/ m s zshow tables in mysqlc S s g | ] }|d �qS r+ r r0 r r r r/ q s zAselect engine from information_schema.engines where support<>'NO'Z
NDBCluster� rpd_nodesz1show schemas like 'mysql_innodb_cluster_metadata'TzFselect instance_id from mysql_innodb_cluster_metadata.v2_this_instancez�select instance_id from mysql_innodb_cluster_metadata.instances where cast(mysql_server_uuid as binary)=cast(@@server_uuid as binary)F)�session�run_sql� fetch_one�has_pfs�splitr# �version� fetch_all�
pfs_tables� is_tablesZ
sys_tables� mysql_tables�has_ndb� has_rapid�has_innodbcluster� instance_id)�selfr3 r8 �a�b�cZsupported_enginesr r r �__init__X sb �"���� � ���
�
��
��zInstanceSession.__init__c C s | j jS �N�r3 �uri�rA r r r �__str__� s zInstanceSession.__str__)r c C s | j jS rF rG rI r r r rH � s zInstanceSession.uri)�sql�argsc
C sL z| j �||�W S tyF } z td|t|�� � W Y d }~n
d }~0 0 d S )NzERROR running query: )r3 r4 � Exception�print�str)rA rK rL �er r r r4 � s
zInstanceSession.run_sqlN)
�__name__�
__module__� __qualname__rE rJ �propertyrO rH �listr4 r r r r r' V s
1r' � )�zf�fn�tsv_out�headerc sN � �fdd�}| � t|d �d��}||� W d � n1 s@0 Y d S )Nc s< � r| � � �d�� �D ] }| � |�d�� | � d� qd S )N�utf-8�
)�write�encode)�f�line�rZ rY r r r] � s
zwrite_tsv.<locals>.writez.tsv�w)�openr )rW rX rY rZ r] r_ r ra r � write_tsv� s rd TF)�as_yaml�as_tsv�filter�
formatters�
ignore_errors�include_warnings) rW rX r3 �queryrL re rf rg rh ri rj r c
sD � ����fdd�} dd� dd� ��d�D �� d ��d7 ��dtj�� �� � d�7 �z|��|�} | �� }
W n, ty� } z| |�W Y d }~S d }~0 0 g }g }g }|r�g }| jD ]}|� |j
� q�|� d d
� |� � �zJt | j d �D �]6}g }|�r||�}|�sq�i }i }t
t|��D ]�}|| }||| j| j
< | j| j
|v �r\|| |�}|� |d u�rrt|�nd � t|�tk�r�d |v �r�d |�d d
� d }||| j| j
< nBt|�ttttd �tfv �r�||| j| j
< nt|�|| j| j
< �q"|�r|� d
� |�� |� |� |� |� q�W n. t�yX } z| |�W Y d }~S d }~0 0 |
�r�|�d��� }|�r�|� d|i� |�r�|� d� |D ] }|� d
� dd� |D ��� �q��d|
� d�7 �|�r�t�� |�d� |�r@��t� d �d��6}|���d�� |�t� |��d�� W d � n1 �s60 Y |S )Nc sr �rX�� t� d �d��,}|��� d| � d��d�� W d � n1 sJ0 Y g S td�� d| � �� � d S )Nz.errorrb z
# �
r[ zERROR: While executing "z": )rc r r] r^ rN )rP r_ �rX rZ ri rk rW r r � handle_error� s :z dump_query.<locals>.handle_error� # Query:
rl c S s g | ]}d |� ��qS �z# r �r- �lr r r r/ � � z dump_query.<locals>.<listcomp>z#
z # Started: �# � �NULL�"z\"z
SHOW WARNINGS�Warningsz
# Warningsc S s g | ] }t |��qS r )rO )r- r_ r r r r/ � rs �# Execution Time: z
#
)rZ �.yamlrb r[ ) �joinr7 r r � isoformatr4 �get_execution_timerM �columns�append� column_label�iterr5 �range�lenrO �typer r# �bool�floatr9 rd rc r r] r^ �yaml�dump_all) rW rX r3 rk rL re rf rg rh ri rj rn r1 Zexecution_timerP Zraw_outZyaml_outrY r` rD �row�entryZ raw_entry�i�field�warningsrb r_ r rm r �
dump_query� s�
��
6r� )re rg ri )rW rX r3 c C s t | ||d|� �|||d�S )Nzselect * from �rg re ri )r� )rW rX r3 �tablere rg ri r r r �
dump_table s �r� �re ri )rW �prefixr3 �tablesre ri r c C sF i }|D ]8}t d|� d�� t| |� t|�� �||||d�||< q|S )N�
- Gathering �...r� )rN r� r! )rW r� r3 r� re ri �infor� r r r �collect_tables s � r� )re ri rj )rW r� r3 �queriesri rj c
C s� i }|D ]�}t |�tu r>t|�dkr2|\} }
d } qN|\} }
} n||d } }
} td| � d�� z4t| |� t| �� �||
|||| d�|| �dd�< W q ty� } z | jt j
j fvr�� W Y d } ~ qd } ~ 0 0 q|S )N� r� r� )re ri rj rg r r ) r� r r� rN r� r! r r �coder � ErrorCodeZER_NO_BINARY_LOGGING)
rW r� r3 r� re ri rj r� �q�labelrk rg rP r r r �collect_queries' s0 � r� )rW rX r3 r� c
C s� | � t|�d���t}|D �]\}td|� d�� dd�dd� |�d�D �� d }|�|�d�� z�|�|�}|�d |�� � d
��d�� |�d � |�d d
�dd� |j D �� d �d�� g }t
|j d �D ]8} t t
| ��D ]&}
| |
} |�| d ur�t| �nd� q�q�d
�|�}|�|� d��d�� W q t�yt } z2|�d| � d��d�� td| � �� W Y d } ~ qd } ~ 0 0 qW d � n1 �s�0 Y d S )Nrb z
- Executing r� ro rl c S s g | ]}d |� ��qS rp r rq r r r r/ Q rs z/collect_queries_single_file.<locals>.<listcomp>r[ ry z
r\ rt ru c S s g | ]
}|j �qS r )r� )r- rD r r r r/ Z rs rv z # Error: zERROR: )rc r rN r{ r7 r] r^ r4 r} r~ r� r5 r� r� r rO r )
rW rX r3 r� r_ rk rZ �resr` r� r� r� rP r r r �collect_queries_single_fileJ sH
��
��
����
r� Z host_summaryz %{TABLE}.statement_latency DESCc C s |d | d pd S )NZstatement_latencyr r �r rP r r r �<lambda>m rs r� c C s |d | d pd dkS �NZ
statementsr r r� r r r r� n rs �hostZhost_summary_by_file_ioz%{TABLE}.io_latency DESCz+(e.io_latency-IFNULL(s.io_latency, 0)) DESCc C s |d | d pd dkS �NZiosr r r� r r r r� q rs Z host_summary_by_file_io_typez*%{TABLE}.host, %{TABLE}.total_latency DESCz9e.host, (e.total_latency-IFNULL(s.total_latency, 0)) DESCc C s |d | d pd dkS �N�totalr r r� r r r r� t rs zhost,event_nameZhost_summary_by_stagesc C s |d | d pd dkS r� r r� r r r r� w rs Z!host_summary_by_statement_latencyz%{TABLE}.total_latency DESCz1(e.total_latency-IFNULL(s.total_latency, 0)) DESCc C s |d | d pd dkS r� r r� r r r r� z rs Z host_summary_by_statement_typec C s |d | d pd dkS r� r r� r r r r� } rs zhost,statementZio_by_thread_by_latencyc C s |d | d pd dkS r� r r� r r r r� � rs z user,thread_id,processlist_id�io_global_by_file_by_bytesz%{TABLE}.total DESCz!(e.total-IFNULL(s.total, 0)) DESCc C s |d | d pd dkS r� r r� r r r r� � rs r* �fileZ io_global_by_file_by_latencyc C s |d | d pd dkS r� r r� r r r r� � rs �io_global_by_wait_by_bytesz %{TABLE}.total_requested DESCz5(e.total_requested-IFNULL(s.total_requested, 0)) DESCc C s |d | d pd dkS r� r r� r r r r� � rs Z
event_nameZ io_global_by_wait_by_latencyc C s |d | d pd dkS r� r r� r r r r� � rs Zschema_index_statisticszf(%{TABLE}.select_latency+%{TABLE}.insert_latency+%{TABLE}.update_latency+%{TABLE}.delete_latency) DESCz�((e.select_latency+e.insert_latency+e.update_latency+e.delete_latency)-IFNULL(s.select_latency+s.insert_latency+s.update_latency+s.delete_latency, 0)) DESCc C sH |d |d |d |d | d | d | d | d p@d dkS )NZ
rows_selectedZinsert_latencyZ rows_updatedZ rows_deletedZ
rows_insertedr r r� r r r r� � s "��z"table_schema,table_name,index_nameZschema_table_statisticsc C s |d | d pd dkS )N�
total_latencyr r r� r r r r� � rs ztable_schema,table_nameZ#schema_tables_with_full_table_scansz %{TABLE}.rows_full_scanned DESCz9(e.rows_full_scanned-IFNULL(s.rows_full_scanned, 0)) DESCc C s |d | d pd dkS )NZrows_full_scannedr r r� r r r r� � rs zobject_schema,object_nameZ user_summaryz9(e.statement_latency-IFNULL(s.statement_latency, 0)) DESCc C s |d | d pd dkS r� r r� r r r r� � rs �userZuser_summary_by_file_ioc C s |d | d pd dkS r� r r� r r r r� � rs Z user_summary_by_file_io_typez$%{TABLE}.user, %{TABLE}.latency DESCz-e.user, (e.latency-IFNULL(s.latency, 0)) DESCc C s |d | d pd dkS r� r r� r r r r� � rs zuser,event_nameZuser_summary_by_stagesz*%{TABLE}.user, %{TABLE}.total_latency DESCz9e.user, (e.total_latency-IFNULL(s.total_latency, 0)) DESCc C s |d | d pd dkS r� r r� r r r r� � rs Z!user_summary_by_statement_latencyc C s |d | d pd dkS r� r r� r r r r� � rs Z user_summary_by_statement_typec C s |d | d pd dkS r� r r� r r r r� � rs zuser,statementZ"wait_classes_global_by_avg_latencyzBIFNULL(%{TABLE}.total_latency / NULLIF(%{TABLE}.total, 0), 0) DESCzhIFNULL((e.total_latency-IFNULL(s.total_latency, 0)) / NULLIF((e.total - IFNULL(s.total, 0)), 0), 0) DESCc C s |d | d pd dkS r� r r� r r r r� � rs Z event_classZ wait_classes_global_by_latencyc C s |d | d pd dkS r� r r� r r r r� � rs Zwaits_by_host_by_latencyc C s |d | d pd dkS r� r r� r r r r� � rs z
host,eventZwaits_by_user_by_latencyc C s |d | d pd dkS r� r r� r r r r� � rs z
user,eventZwaits_global_by_latencyc C s |d | d pd dkS r� r r� r r r r� � rs �eventsc @ sr e Zd Zg dfeee ed�dd�Zej ed�dd�Z
ej ed�dd �Z ej ee d
�d d �Z
ej ed�d
d�ZdS )� SQLExecutorT)r3 �
custom_sql� allow_phasesc C sX || _ t|�}|s*|d s"|d r*td��g | _|D ] }| j�dd� t|�D �� q4d S )Nr
r� zFOption 'customSql' may not contain before:, during: or after: prefixesc S s g | ]\}}d |� �|f�qS )Zscript_r )r- r� rK r r r r/ � s �z(SQLExecutor.__init__.<locals>.<listcomp>)r3 r r r� r � enumerate)rA r3 r� r� Zphasesrr r r r rE � s � �zSQLExecutor.__init__�rW r� c C s4 | j d }|r0td� t||� d�| j|dd� d S )Nr z Executing custom sql scriptsz custom_sql-F�ri �r� rN r� r3 �rA rW r� rr r r r �execute� s
�zSQLExecutor.executec C s4 | j d }|r0td� t||� d�| j|dd� d S )Nr z%Executing custom 'before' sql scriptszcustom_sql-before-Fr� r� r� r r r �execute_before� s
�zSQLExecutor.execute_before�rW r� � iterationc C s: | j d }|r6td� t||� d|� d�| j|dd� d S )Nr
z/Executing custom 'during' iteration sql scriptszcustom_sql-iterationr( Fr� r� )rA rW r� r� rr r r r �execute_during� s
�zSQLExecutor.execute_duringc C s4 | j d }|r0td� t||� d�| j|dd� d S )Nr� z$Executing custom 'after' sql scriptszcustom_sql-after-Fr� r� r� r r r �
execute_after� s
�zSQLExecutor.execute_afterN)rQ rR rS r' r rO r� rE r �ZipFiler� r� r# r� r� r r r r r� � s ��
r� c @ s" e Zd Zeed�dd�Zejeed�dd�Z ejee
d�dd �Z e
ejee d
�d d �Z
d
d� Zejed�dd�Zejed�dd�Zdd� Zdd� Zeejed�dd�Zejed�dd �Zejeee
d�d d �Zejed�d d �Zejed�d!d"�Zejeee
d�d#d$�Zejed�d%d&�Zd'S )(�DiagnosticsSession)r3 � innodb_mutexc C s� || _ d | _i | _i | _i | _i | _d| _d| _|| _| j j rl| j �
d�� � d | _ | j �
d�� � d | _
n d| _ d| _
| j jr�dd� | j �
d��� D �| _ng | _| j �
d� | j �
d �� � \}}|r�|d
kr�| j j r�d | _| j �
d � nd| _d S )
NFzFselect sys.ps_is_consumer_enabled('events_waits_history_long') = 'YES'r zpselect EXISTS(SELECT 1 FROM performance_schema.setup_instruments WHERE NAME LIKE 'memory/%' AND ENABLED = 'YES')c S s g | ]}d |d �qS )zndbinfo.r r r, r r r r/ s z/DiagnosticsSession.__init__.<locals>.<listcomp>zshow tables in ndbinfoz%set session group_concat_max_len=2048z%select @@sql_log_bin, @@binlog_formatZROWTzSET SESSION sql_log_bin = 0)r3 �pfs_instrumentation�metrics� metrics_info� status_start�
status_end�pfs_instrumentation_changed�has_performance_analyzerr� r6 r4 r5 � pfs_events_wait_history_long�pfs_memory_instrumentedr= r9 �ndbinfo_tables�disabled_binlog)rA r3 r� Zlog_binZ
binlog_formatr r r rE � sJ ������
� zDiagnosticsSession.__init__)rW r� r� c
C s� |dv s J �| j jr8| �|� | �||� d|� d�� n|dkrHtd��| �d||�| _| �||d� | j jr�td� z d D ]}| j � |� q|d
| _
W nF t y� } z.td |� d |� �� td
� d| _
W Y d }~n
d }~0 0 d S )N)�current�medium�fullz -applied_r( r� zAperformance_schema is disabled, instrumentation cannot be changed�startr z. - Preparing statement performance analyzer...)�4DROP TEMPORARY TABLE IF EXISTS sys.tmp_digests_startzPCALL sys.statement_performance_analyzer('create_tmp', 'tmp_digests_start', NULL)z?CALL sys.statement_performance_analyzer('snapshot', NULL, NULL)zJCALL sys.statement_performance_analyzer('save', 'tmp_digests_start', NULL)TzError executing �: z Related checks will be skippedF) r3 r6 �enable_pfs_instruments�collect_pfs_configr � fetch_statusr� �collect_metricsrN r4 r� rM )rA rW r� r� r� rP r r r r� & s,
��
zDiagnosticsSession.startr� c C s | � |||� | �|||� d S rF )r� �collect_other_stats)rA rW r� r� r r r �iterateI s zDiagnosticsSession.iterate)�delayrW r� �iter_fnc sb � ����fdd�}d �_ t� }t||fd��_�j�� �j d u r^|�� |�� |�� q:d S )Nc s| | � � d�_| �� | �� d}�jsxtd� ����|d � �|� |d7 }t� �D ]}�j�d� �jrZ q"qZq"d S )NFr zCollecting metrics...r
zselect sleep(1)) �acquire�
end_thread�notify�releaserN r� r� r3 r4 )�condr� r �r� r� r� rA rW r r �runloopP s z4DiagnosticsSession.start_background.<locals>.runloop)�targetrL )r� r r �threadr� r� �waitr� )rA r� rW r� r� r� r� r r� r �start_backgroundM s
z#DiagnosticsSession.start_backgroundc C s d| _ | j�� d S )NT)r� r� r{ rI r r r �stop_backgroundn s z"DiagnosticsSession.stop_backgroundr� c C s� | j jr�td� | �||� | �d||�| _| �||� dD ]}| j �|� q<| jr�t ||� d�| j ddd� dD ]}| j �|� qr| �
||� d S ) Nz( - Writing delta of collected metrics...�end)z-CALL sys.ps_statement_avg_latency_histogram()z%-statement_performance_analyzer-deltaziCALL sys.statement_performance_analyzer('delta', 'tmp_digests_start', 'with_runtimes_in_95th_percentile')F�re )r� z>CALL sys.statement_performance_analyzer('cleanup', NULL, NULL)) r3 r6 rN �dump_metrics_deltar� r� �dump_status_deltar4 r� r� �cleanup)rA rW r� r� r r r �finishr s$ �zDiagnosticsSession.finishc C s& | j jr| �� | jr"| j �d� d S )NzSET sql_log_bin = 1)r3 r6 �restore_pfs_instrumentsr� r4 )rA rW r� r r r r� � s zDiagnosticsSession.cleanupc C s� || _ | j�d� |dkrp| j�d��� d }|dkr>td� | jjdkr�| j�d��� d }|dkr�td� nhtd � | j�d
� d | _|d kr�| j�d
� | j�d� n |dkr�| j�d� | j�d� | j�d� d S )Nz1CALL sys.ps_setup_disable_thread(CONNECTION_ID())r� zKselect count(*) from performance_schema.setup_consumers where enabled='YES'r zCWARNING: performance_schema.setup_consumers is completely disabled.i�8 zIselect count(*) from performance_schema.setup_threads where enabled='YES'zAWARNING: performance_schema.setup_threads is completely disabled.z.Configuring Performance Schema InstrumentationzCALL sys.ps_setup_save(0)Tr� z�UPDATE performance_schema.setup_consumers
SET ENABLED = 'YES'
WHERE NAME NOT LIKE '%\_history%'z�UPDATE performance_schema.setup_instruments
SET ENABLED = 'YES',
TIMED = 'YES'
WHERE NAME NOT LIKE 'wait/synch/%'r� zQUPDATE performance_schema.setup_consumers
SET ENABLED = 'YES'zzUPDATE performance_schema.setup_instruments
SET ENABLED = 'YES',
TIMED = 'YES'zzUPDATE performance_schema.threads
SET INSTRUMENTED = 'YES'
WHERE PROCESSLIST_ID <> CONNECTION_ID())r� r3 r4 r5 rN r8 r� )rA �levelrD r r r r� � sT ���� ��� ����z)DiagnosticsSession.enable_pfs_instrumentsc C s. | j dkr*| jr*td� | j�d� d| _d S )Nr� z+Restoring Performance Schema Configurationsz CALL sys.ps_setup_reload_saved()F)r� r� rN r3 r4 rI r r r r� � s z*DiagnosticsSession.restore_pfs_instruments)�stagerW r� c s� t tt d�� fdd� }i }tD ]~^}}}|s2J �d|�dd|� �� }d|� d|pVd � �} ||�}
td
|� d �� t||� d |� d
|� �� j| d|
d�||< q |S )N)r� r c s� � j �d| g��� }g }|D ]�\}|�� }| dkr:|dksJ| dkrV|dkrV|�t� q |�d�rl|�t� q |�d�s�|�d�s�|�d �s�|�d
�s�|�d �r�|�d �s�|�t� q |�d
d� � q |S )zb
Assemble a query on a sys view, formatting columns to be human readable.
�vselect column_name from information_schema.columns where table_schema='sys' and table_name=? order by ordinal_positionr� r� r� �total_requested�latency�_memory�_memory_allocated�_read�_written�_write�count_c S s | S rF r )r_ r r r r� � rs zODiagnosticsSession.fetch_status.<locals>.formatters_for_table.<locals>.<lambda>) r3 r4 r9 �lowerr r% �endswithr& �
startswith)r� r~ rh �column�lcolumnrI r r �formatters_for_table� s> �
���
����� z=DiagnosticsSession.fetch_status.<locals>.formatters_for_tablez
ORDER BY z%{TABLE}zx$zSELECT * FROM `sys`.`x$�`rV z - Gathering sys.r� z-raw/r) F)re rh )rO r r �k_sys_views_deltar rN r� r3 ) rA r� rW r� r� �status�
table_nameZorder_byr rk rh r rI r r� � s& �� z DiagnosticsSession.fetch_statusc
s� t t ttt tt f d�� fdd� }tD ]̐^}}}|||�\}}g } | �dd�|� � t� j| � j | �D ]l\}
} g } t
|�D ]<\}
}z| �||
| �� W q� t ||
|
| � � Y q�0 q�| �d�dd� | D ��� qrt ||� d|� �| � q*d S ) N)r �pkr c s& dd� �j �d| g��� D �}g }dd� �|D �]� � �� }d| d d| d v rh|�� fdd�� q.| d kr�|d
kr��fd d �}|�|� q.| |fd
v r�� �fdd �}|�|� q.|d d� dv r�|�d�r�|�� fdd�� q.|dk�r�fdd �}|�|� q.|�d��r8� d d� ���fdd �}|�|� q.� �d��rX|�� fdd�� q.� dv �r�|dk�rpd nd �|dk�r�d nd ����fd d �}|�|� q.|�d ��s�|�d!��s�|�d"��s�|�d#��s�|�d$��r� �d%��s� �fd&d �}|�|� q.� �fd'd �}|�|� q.||fS )(Nc S s g | ] }|d �qS r+ r r0 r r r r/ s zVDiagnosticsSession.dump_status_delta.<locals>.formatters_for_table.<locals>.<listcomp>r� c S s | d u r | S t | �S rF �r� r r r r �
float_or_none
s zYDiagnosticsSession.dump_status_delta.<locals>.formatters_for_table.<locals>.float_or_none�,c s
| � � S rF r r� �r� r r r� rs zTDiagnosticsSession.dump_status_delta.<locals>.formatters_for_table.<locals>.<lambda>r� Z write_pctc s� t |d p d�}� | d �}t |d p(d�}� | d �}|d u s\|d u s\|| || dkr`d S d|| || || d d�S )NZ
total_readr Z
total_writtenr* �.2fr )r rP Ze_readZs_readZ e_writtenZ s_written�r r r �fmt s ���zODiagnosticsSession.dump_status_delta.<locals>.formatters_for_table.<locals>.fmt))r� r� )r� r� c s4 �|� �}t | � pd�} |d u r(d S t|| �S �Nr �r� r% r� �r� r r r r + s
� )Zmax_Zmin_�_latencyc s |� d ur t t|� ��S d S rF �r& r� r� r r r r� 5 s
�
�Z avg_latencyc sl t |d p d�}� | d �}t |d p(d�}� | d �}|d u sT|d u sT|| dkrXd S t|| || �S )Nr� r r� �r� r& �r rP Ze_latZs_lat�e_total�s_totalr r r r 9 s �Z _avg_latencyi�c s� t |�� d� pd�}� | �� d� �}t |�� d� p:d�}� | �� d� �}|d u sl|d u sl|| dkrpd S t|| || �S )Nr
r r r r )r r� r r r G s �r� c s0 t |� d ur*t|� �t| � p$d� nd �S r r r� r r r r� S s
� �)�avg_readZ avg_writeZ avg_writtenr �readZwrittenr] c s� t | d�� � pd�}� | d�� � �}t |d�� � p:d�}� | d�� � �}|d ks`|d u rdd S || }|| }|dkr�d S t|| �S )NZtotal_r r� r
)r rP r r Ze_countZs_countr$ �d)r �suffix�suffix2r r r Z s r� r� r� r� r� r� c s4 �|� �}t | � pd�}|d u r(d S t|| �S r r
)r rP �e_�s_r r r r n s
c s2 t | � p d�}�|� �}|d u r(d S || � S r r )r rP r r r r r r z s
)r3 r4 r9 r� r r� r� )r r r~ Zfcolumnsr� r rI )r� r r� r r r r� sh ��
�
����� zBDiagnosticsSession.dump_status_delta.<locals>.formatters_for_tablert ru c S s g | ] }|pd �qS )r( r )r- r r r r r/ � rs z8DiagnosticsSession.dump_status_delta.<locals>.<listcomp>z-delta.)
rO r r r r� r r{ �zipr� r� r� rN rd )rA rW r� r� r r r r~ rh �linesZ start_rowZend_rowr� r� r r rI r r� s( �
�
z$DiagnosticsSession.dump_status_deltac C s� | j js d S |d u r |� d�}n|� d|� d�}t||| j dddd�}|D ]P}|d }|d }|d } |d
}
d | jvr�| |
g| j|< | j�|g ��|� qJd S ) Nr� �-raw/iteration-z.metricszkSELECT Variable_name, REPLACE(Variable_value, '
', '\\n') AS Variable_value, Type, Enabled FROM sys.metricsF�re rj �
Variable_nameZVariable_value�Type�Enabled�name)r3 r6 r� r� r� �
setdefaultr ) rA rW r� r� rX r� r� r! �valuer� Zenabledr r r r� � s* �
z"DiagnosticsSession.collect_metricsc s: ddg�dg� ddg��fdd�| j jD �}|� fdd�| j jD �7 }|�fd d�| j jD �7 }| j jrr|�d
� | j jr�d D ] }|| j jv r~|�d | � q~d
d� }| j jdkr�d}d}nd}d}dddd|� �dd|� d�dd|fd g}| j j�r|g d �7 }t||| j |d d � t ||| j |d d � | �
||� d S ) NZ
host_cacheZpersisted_variables�pluginsZaudit_log_userZaudit_log_filterc s( g | ] }|� d �s|� v rd|� ��qS )Z replication_�performance_schema.)r� r, )�other_pfs_tablesr r r/ � s �z@DiagnosticsSession.collect_configs_and_state.<locals>.<listcomp>c s g | ]}|� v rd |� ��qS )zinformation_schema.r r, )r; r r r/ � s �c s g | ]}|� v rd |� ��qS )zmysql.r r, )r< r r r/ � s �zndbinfo.threadblocks)r2 Zrpd_exec_statsZrpd_query_statsr% c S s t | �} d| d< | S )Nz*****� )rU �r� r r r �filter_slave_master_info� s zNDiagnosticsSession.collect_configs_and_state.<locals>.filter_slave_master_infoi�8 ZREPLICAZREPLICASZSLAVEz SLAVE HOSTS)zglobal variablesa SELECT g.variable_name name, g.variable_value value /*!80000, i.variable_source source*/
FROM performance_schema.global_variables g
/*!80000 JOIN performance_schema.variables_info i ON g.variable_name = i.variable_name */
ORDER BY namezXA RECOVER CONVERT xidzSHOW BINARY LOGSzSHOW zSHOW MASTER STATUSz STATUSzreplication master_infoz;SELECT * FROM mysql.slave_master_info ORDER BY Channel_name)zreplication relay_log_infoz{SELECT Channel_name, Sql_delay, Number_of_workers, Id
FROM mysql.slave_relay_log_info ORDER BY Channel_name))zrapid table statusa SELECT rpd_table_id.ID, rpd_table_id.Name, rpd_tables.*
FROM performance_schema.rpd_table_id, performance_schema.rpd_tables
WHERE rpd_tables.ID = rpd_table_id.ID
ORDER BY rpd_table_id.SCHEMA_NAME,rpd_table_id.TABLE_NAME)zrapid total table sizezCSELECT SUM(IFNULL(SIZE_BYTES,0)) FROM performance_schema.rpd_tables)zrapid avail_rnstate nodesz�SELECT IFNULL(SUM(memory_total), 0), IFNULL(SUM(memory_usage), 0), IFNULL(SUM(BASEREL_MEMORY_USAGE),0)
FROM performance_schema.rpd_nodes
WHERE status = 'AVAIL_RNSTATE'Tr� ) r3 r: r; r< r= r r> r8 r� r� r� ) rA rW r� r� r. r) Z
kw_replicaZ kw_replicasr� r )r; r< r& r �collect_configs_and_state� sR
� � �
��
z,DiagnosticsSession.collect_configs_and_statec C s g d�}t ||| j|dd� d S )N))z
pfs actorsz-SELECT * FROM performance_schema.setup_actors)z pfs objectsz.SELECT * FROM performance_schema.setup_objects)z
pfs consumersz�SELECT NAME AS Consumer, ENABLED, sys.ps_is_consumer_enabled(NAME) AS COLLECTS
FROM performance_schema.setup_consumers)zpfs instrumentsa SELECT SUBSTRING_INDEX(NAME, '/', 2) AS 'InstrumentClass',
ROUND(100*SUM(IF(ENABLED = 'YES', 1, 0))/COUNT(*), 2) AS 'EnabledPct',
ROUND(100*SUM(IF(TIMED = 'YES', 1, 0))/COUNT(*), 2) AS 'TimedPct'
FROM performance_schema.setup_instruments
GROUP BY SUBSTRING_INDEX(NAME, '/', 2)
ORDER BY SUBSTRING_INDEX(NAME, '/', 2))z pfs threadsz�SELECT `TYPE` AS ThreadType, COUNT(*) AS 'Total', ROUND(100*SUM(IF(INSTRUMENTED = 'YES', 1, 0))/COUNT(*), 2) AS 'InstrumentedPct'
FROM performance_schema.threads
GROUP BY TYPETr� )r� r3 )rA rW r� r� r r r r� s z%DiagnosticsSession.collect_pfs_configc C s� g d�}| j r|�d� | jr*|g d�7 }g d�}| jrB|dg7 }| jjrt|ddg7 }|dd � | jD �7 }|d
g7 }|d ur�|d |� d �7 }t||| j|d
d� t||| j|d
d� d S )N) z!performance_schema.metadata_lockszperformance_schema.threadszsys.schema_table_lock_waitszsys.session_ssl_statusz sys.sessionzsys.processlistz'performance_schema.events_waits_currentz information_schema.innodb_trxz!information_schema.innodb_metricszsys.latest_file_io)z#sys.memory_by_host_by_current_bytesz%sys.memory_by_thread_by_current_bytesz#sys.memory_by_user_by_current_bytesz"sys.memory_global_by_current_bytes)zSHOW GLOBAL STATUSzSHOW ENGINE INNODB STATUSz%SHOW ENGINE PERFORMANCE_SCHEMA STATUSzSHOW FULL PROCESSLISTzSHOW OPEN TABLESzSHOW ENGINE INNODB MUTEXz SHOW ENGINE NDBCLUSTER STATUS)zndb memoryusagez�SELECT node_id, memory_type, format_bytes(used) AS used, used_pages, format_bytes(total) AS total, total_pages,
ROUND(100*(used/total), 2) AS 'Used %'
FROM ndbinfo.memoryusagec S s g | ]}|d kr|�qS )zndbinfo.memoryusager r, r r r r/ > s z:DiagnosticsSession.collect_other_stats.<locals>.<listcomp>zinformation_schema.FILESr r) Tr� ) r� r r� r� r3 r= r� r� r� )rA rW r� r� r� r� r r r r� s*
��
z&DiagnosticsSession.collect_other_statsc
C s� | j js dS g d�}dd� }d}|�|� d�d����}d}| j�� D �]�\}} |r�d g}
td
t| �d
�D ]8} |
�d | � �� | d
krj|
�d | d
� d
| � d�� qj|
ddg7 }
|�d� |
�d �
d�� d}|g}
||v } d}
d}d}t | �D ]�\} }d}||�}|
�|d|� � | dk�r�| �s�|du�r�t | jd | �}t | jd | d
�}|du�r�|
du�r�||
k�r|d}n"||
� d||
|| d�d�}|
�|� |}
q�|
| j
| 7 }
|�d� |
�d �
d�� qDW d � n1 �s�0 Y dS ) z�
Format all collected metrics iterations and format into a human readable
form, also including delta values between each iteration.
N)Z innodb_buffer_pool_pages_total�innodb_page_sizeZlast_query_costZlast_query_partial_plansZqcache_total_blocksZslave_last_heartbeatZssl_ctx_verify_depthZssl_ctx_verify_modeZssl_session_cache_sizeZssl_verify_depthZssl_verify_mode� ssl_versionZbuffer_flush_lsn_avg_rateZbuffer_flush_pct_for_dirtyZbuffer_flush_pct_for_lsnZbuffer_pool_pages_totalZlock_row_lock_time_avgZlock_row_lock_time_maxr+ c S s z
t | �W S Y d S 0 d S rF r r r r r �asnum` s
z4DiagnosticsSession.dump_metrics_delta.<locals>.asnum�2 z-metrics.summary.tsvrb Tr r
zOutput zDelta (z -> �)r r ru rl r[ Fr rV zUNIX_TIMESTAMP()z 0 (0/sec)z (r z/sec))r3 r6 rc r� �itemsr� r� r r] r{ r^ r� r� r� )rA rW r� Zno_delta_namesr- Zmax_field_lengthr_ �firstr! �valuesr` r� Zno_delta�prevZ prev_timeZnvaluer# �delta�timer r r r� I sN �
"
z%DiagnosticsSession.dump_metrics_deltaN)rQ rR rS r' r� rE r r� rO r� r# r� r r� r� r� r� r� r� r� r� r r� r* r� r� r� r r r r r� � s2 ,� #� !80 � P� 2r� ) rW r� r3 �
iterationsr� �pfsInstrumentationr� r� � custom_shellc
C s~ t |dd�} t||d�}
�zDt||dd�} | �| |� | �| |� |
�| |� � |
�| |� d�|� t|�D ]�} td| d � d|� d�� |
�| |� d�| d � | � | || � | � | || � | d7 } | |d k�rtd |� d
�� z|�
d |g� W n t �y td � � Y n0 ql �q ql|d
k�r2td� |
� | |� d�� | �
| |� | �
| |� W n |
�| |� � Y n0 d S )NT�r� �r� � diagnosticsz+Collecting performance metrics (iteration #r
z of z)...z
Sleeping for zs...zselect sleep(?)z^C - aborting...r z#Performance metrics collection done)r r� r� r� r* r� r� rN r� r� r4 �KeyboardInterruptr� r� r� )
rW r� r3 r6 r� r7 r� r� r8 �shell�diag�customr� r r r �collect_diagnostics� s@ �
r@ )rW r� r3 r� r� c
C sr t ||d�}zRt||dd�}|�| |� |�| |� |�| |d � |�| |d � W |�| |� n|�| |� 0 d S )Nr: Fr9 )r� r� r� r* r� r� r� )rW r� r3 r� r� r> r? r r r �collect_diagnostics_once� s rA )rW r� r3 r c
C s� d }z|� d��� }W n� ty� } z�|jtjjksB|jtjjkrR|W Y d }~S |r�td|� �� | � t
|� d��d��0}|� d� |� |� d�� d�� W d � n1 s�0 Y |W Y d }~S � W Y d }~n
d }~0 0 d}d} td � |D ]t}
d
|
d k�rd }nd
|
d k�r d } |
d dk�r>|
d dv�r>q�|
d } t
| |� d| � �|d| � �d |d� q�d}|�s|| �r�|� d��� d } | dk�r�d}n.z |� d��� d } | �r�d}W n Y n0 |S )Nz1show full tables in mysql_innodb_cluster_metadataz0ERROR: Could not query InnoDB Cluster metadata: z#mysql_innodb_cluster_metadata.errorrb s2 show full tables in mysql_innodb_cluster_metadata
rl r[ Fz/Dumping mysql_innodb_cluster_metadata schema...Zasync_cluster_viewsr TZclusterset_viewsr
z
BASE TABLE)Zschema_versionz mysql_innodb_cluster_metadata.r� �grzGselect cluster_type from mysql_innodb_cluster_metadata.v2_this_instance�arzDselect count(*) from mysql_innodb_cluster_metadata.v2_cs_clustersets�cs)r4 r9 r r� r r� ZER_BAD_DB_ERRORZER_NO_SUCH_TABLErN rc r r] r^ r� r5 )
rW r� r3 ri � cluster_typer1 rP r_ Z rs_possibleZ cs_possibler� r� r. r r r �collect_cluster_metadata� sv � ��
4 � ��
��rF �r3 c C sD zdd� | � d��� D �W S dd� | � d��� D � Y S 0 d S )Nc S s g | ]}|d |d f�qS �r r
r r0 r r r r/ rs z(get_topology_members.<locals>.<listcomp>zLselect instance_id, endpoint from mysql_innodb_cluster_metadata.v2_instancesc S s g | ]}|d |d f�qS rH r r0 r r r r/ rs z]select instance_id, addresses->>'$.mysqlClassic' from mysql_innodb_cluster_metadata.instances)r4 r9 rG r r r �get_topology_members s
�
�rI )rW r
r3 ri r c C s< |j dkr4td� dd� }t| ||d|d|d� dS dS d S ) Ni�8 z - Gathering error_logc S s d| d v rd S | S )Nztemporary passwordr' r r( r r r �
filter_pwd! s z)collect_error_log_sql.<locals>.filter_pwdz performance_schema.error_logFr� T)r8 rN r� )rW r
r3 ri rJ r r r �collect_error_log_sql s
�rK r� )rW r� r3 ri c C s4 ddg}d|j v r |�d� t| |||d|d� d S )N)zslow queries in 95 pctilez=SELECT * FROM sys.statements_with_runtimes_in_95th_percentile)z%slow queries summary by rows examinedaG SELECT DIGEST, substr(DIGEST_TEXT, 1, 50), COUNT_STAR, SUM_ROWS_EXAMINED, SUM_ROWS_SENT, round(SUM_ROWS_SENT/SUM_ROWS_EXAMINED, 5) ratio FROM performance_schema.events_statements_summary_by_digest where DIGEST_TEXT like 'select%' and (SUM_ROWS_SENT/SUM_ROWS_EXAMINED) < .5 ORDER BY SUM_ROWS_EXAMINED/SUM_ROWS_SENT desc limit 20�slow_log)rL z SELECT * FROM mysql.slow_logTr� )r< r r� )rW r� r3 ri r� r r r �collect_slow_queries3 s �
�rM )rW r� r3 c C sZ t d� |�d��� }| �t|� d��d���}|D � ]�}|d |d }}|�d|� d|� d ��d
�� z8|jd ||gd ��� D ] } |�| d d �d
�� q�W n� t�y( }
zl|r�t d
|� d|� d|
� �� |�d|� d|� d|
� d ��d
�� n t d|� d|� d|
� �� � W Y d }
~
n
d }
~
0 0 |�d� q4W d � n1 �sL0 Y d S )Nz8Collecting InnoDB Cluster accounts and grant informationzAselect user,host from mysql.user where user like 'mysql_innodb_%'zcluster_accounts.tsvrb r r
z-- �@rl r[ zshow grants for ?@?)rL z"WARNING: Error getting grants for r� zCould not get grants for z ERROR: Error getting grants for r\ )rN r4 r9 rc r r] r^ rM ) rW r� r3 ri Zaccountsr_ r� r� r� r1 rP r r r � collect_innodb_cluster_accountsK s4 �
� � ��rO c C s> |r t d� g d�}|r$|g d�7 }t| |� ||d|d� d S )Nz,Collecting Schema Information and Statistics))zschema tables without a PKa� SELECT t.table_schema, t.table_name, t.table_rows, t.engine, t.data_length, t.index_length
FROM information_schema.tables t
LEFT JOIN information_schema.statistics s on t.table_schema=s.table_schema and t.table_name=s.table_name and s.index_name='PRIMARY'
WHERE s.index_name is NULL and t.table_type = 'BASE TABLE'
and t.table_schema not in ('performance_schema', 'sys', 'mysql', 'information_schema'))zschema routine sizezvSELECT ROUTINE_TYPE, COUNT(*), SUM(LENGTH(ROUTINE_DEFINITION)) FROM information_schema.ROUTINES GROUP BY ROUTINE_TYPE;)zschema table countz.SELECT count(*) FROM information_schema.tables)zschema unused indexesz'SELECT * FROM sys.schema_unused_indexes))zschema object overviewz(select * from sys.schema_object_overview)zschema top biggest tablesa� select t.table_schema, t.table_name, t.row_format, t.table_rows, t.avg_row_length, t.data_length, t.max_data_length, t.index_length, t.table_collation,
json_objectagg(idx.index_name, json_object('columns', idx.col, 'type', idx.index_type, 'cardinality', idx.cardinality)) indexes,
group_concat((select concat(c.column_name, ':', c.column_type)
from information_schema.columns c
where c.table_schema = t.table_schema and c.table_name = t.table_name and c.column_type in ('blob'))) blobs
from information_schema.tables t
join (select s.table_schema, s.table_name, s.index_name, s.index_type, s.cardinality, json_arrayagg(concat(c.column_name, ':', c.column_type)) col
from information_schema.statistics s left join information_schema.columns c on s.table_schema=c.table_schema and s.table_name=c.table_name and s.column_name=c.column_name
group by s.table_schema, s.table_name, s.index_name, s.index_type, s.cardinality
order by s.table_schema, s.table_name, s.index_name, s.index_type, s.cardinality) idx
on idx.table_schema=t.table_schema and idx.table_name = t.table_name
where t.table_type = 'BASE TABLE' and t.table_schema not in ('mysql', 'information_schema', 'performance_schema')
group by t.table_schema, t.table_name, t.engine, t.row_format, t.table_rows, t.avg_row_length, t.data_length, t.max_data_length, t.index_length, t.table_collation
order by t.data_length desc limit 20)zschema table enginesa> SELECT ENGINE, COUNT(*) AS NUM_TABLES,
sys.format_bytes(SUM(DATA_LENGTH)) AS DATA_LENGTH,
sys.format_bytes(SUM(INDEX_LENGTH)) AS INDEX_LENGTH,
sys.format_bytes(SUM(DATA_LENGTH+INDEX_LENGTH)) AS TOTAL
FROM information_schema.TABLES
GROUP BY ENGINE)zschema table infoz'SELECT * FROM information_schema.TABLESTr� )rN r� )rW r� r3 r� ri r� r r r �collect_schema_statsi s �rP )rW r� r3 �schemar� c
C s | � t|� dt|�� dt|�� d��d����}dd� }|�d||g��� }|sttd|� d |� d
�� W d � d S ||�}g }g } g }
g } |d d kr�|�d
t�|�� dt�|�� ���� d } �n|�dt�|�� dt�|�� ���� d } |�dt�|�� dt�|�� ��}
t |
jd �D ]}|�
||�� �q |�d||g�}
t |
jd �D ]}| �
||�� �qP|�d||g�}
t |
jd �D ]}|
�
||�� �q�|�d||g�}
t |
jd �D ]}|
�
||�� �q�|||| || |
| d�}|� t �
|��d�� W d � n1 �s 0 Y d S )Nzreferenced_table-r) rz rb c S s t �t| ��dd��S )Nrl z\n)�json�loadsrO r )r r r r � pythonize� s z%collect_table_info.<locals>.pythonizezMSELECT * FROM information_schema.tables WHERE table_schema=? AND table_name=?z WARNING: Could not find table `z`.`z.` referenced in query (try 'USE schema' first)Z
TABLE_TYPEZVIEWzSHOW CREATE VIEW r zSHOW CREATE TABLE r
zSHOW INDEX IN z^SELECT * FROM information_schema.triggers WHERE EVENT_OBJECT_SCHEMA=? AND EVENT_OBJECT_TABLE=?zMSELECT * FROM mysql.innodb_table_stats WHERE database_name=? AND table_name=?zMSELECT * FROM mysql.innodb_index_stats WHERE database_name=? AND table_name=?)z
Table Namez Table Schemaz Table StatusZDDLZIndexesZTriggerszInnoDB Table StatszInnoDB Index Statsr[ )rc r r! r4 �fetch_one_objectrN r �quote_identifierr5 r� r r] r� �dumpr^ )rW r� r3 rQ r� r_ rT Z table_statusZindexesZtriggersZ table_statsZ index_statsZddlr� r1 r� r r r �collect_table_info� s� ���� ��������� rX )rW r3 rk r� r c C s� g d�}|D ]}|� |� q t| |� d�|d|� �ddd� t| |� d�|ddd � d
g}|D ]}|� |� q^d d |� �fg}|jd
kr�|�dd|� �f� t| |||dd�S )N)�(SET SESSION optimizer_trace='enabled=on'z SET optimizer_trace_offset=-1zSET optimizer_trace_limit=1Zexplain�EXPLAIN FTr zexplain-optimizer_trace�0SELECT * FROM information_schema.optimizer_tracer� �)SET SESSION optimizer_trace='enabled=off'Z explain_jsonzEXPLAIN format=json i�8 Zexplain_analyzezEXPLAIN ANALYZE )rj )r4 r� r8 r r� )rW r3 rk r� �beforer� �afterr� r r r �
explain_query� s. ��
r_ )rW r3 rk r� c C s@ ddd|� �ddddd|� �ddd d
g }t | |� d �||� d S ) Nz#SET SESSION use_secondary_engine=ONz SELECT NOW()rZ z!SHOW SESSION STATUS LIKE 'rapid%'rY z SET optimizer_trace_offset=-2z~SELECT query, trace->'$**.Rapid_Offload_Fails', trace->'$**.secondary_engine_not_used' FROM information_schema.optimizer_tracer[ z$SET SESSION use_secondary_engine=OFFr\ zexplain-rapid.txt)r� )rW r3 rk r� r� r r r �explain_heatwave_query
s ��r` )rV )F)FF)4Zmultiprocessingr � threadingr �mysqlshr r �typingr r r r r� rR r r � host_infor r rO r r r! r% r& r' r� rU rd r� r� r� �dictr� r� r� r� r� r� r# r� r@ rA rF rI rK rM rO rP rX r_ r` r r r r �<module> s� B��� c�� �� �� #� "
�
�
�
�
�
�
�
�
�
�
��
�
�
�
�
�
�
�
�
�
�
�
�
��R< &�� 7�� � 7 � �� �� ! �� 9� I� �