前言：
mysql中提供了一个慢查询的日志记录功能(有点类似 oracle的v$session_longops )，可以把查询sql语句时间大于多少秒的语句写入慢查询日志，日常维护中可以通过慢查询日志的记录信息快速准确地判断问题所在；
可以通过mysqldumpslow、mysqlsla、pt-query-digest ..等工具进行分析慢日志, mysqldumpslow、mysqlsla文本查看，而pt-query-digest工具可导入数据库，方便查看；
本文主要通过pt-query-digest工具将所需内容导入到数据库(sql按照发起sql者区分),最终将各个用户下所有信息导入到一张总表.再进行分析..
<b>脚本内容：</b>
#!/bin/bash
# descirption:mysql slow_log statistics
# date: 2015年7月1日
# author: 毛海晴
#脚本目的：
#每天将慢查询sql及信息导入到mysql数据库表作分析（需要信息：执行sql用户{database}、sql文本、执行次数、总执行时间、平均时间、查询行数、返回行数）
#脚本编写思路
#pt-query-digest未发现直接按照database过滤自带参数（问题 当提供慢sql时需要知道sql在哪个库执行的 的情况该怎么办）
#不过可以考虑使用pt-query-digest自带用户限制参数--filter '($event->{user} || "") =~ m/^用户/i' 可以简单用用户充当database再结合mysql.user再分析')
#通过pt-query-digest user 限制后导入数据库，但导入后并没有某字段记录database_name信息
#所以考虑循环限制并导入database+date命名数据表后手动加database_name字段，默认值为 相应sql执行的用户名
#最终会生成多表（例如：slow_log_his_2015_07_01_retail_uc、slow_log_his_2015_07_01_retail_pms...）第一个字段是database_name和相应的执行sql用户名
#表整理：将多表追加到一张slow_log_his_2015_07_01表，再通过mysql sql 取出我们需要字段。
# *********************************************步骤********************************************
## 变量设置 （注释：变量定义=等号前后不能出现空格，否则会被系统理解成命令）
#登陆名
user='root'
#登陆密码
slow_root='root'
slow_password=123456
slow_host=写入远程库ip
slow_port='3306'
slow_dbname='test'
#日期设置， 生成慢查询表命令yyyy_mm_dd 'train_public'后缀名避免多库导入同一远程数据库表名重复，数据覆盖问题。
pt_table=slow_log_his_`date +%y_%m_%d`_train_public
#ip获取
# ip=`ifconfig |grep "bcast"|awk -f ':' '{print $2}'|awk -f ' ' '{print $1}'`
echo '------------- '`date +%y-%m-%d' '%h:%m:%s`' 开始 "'`hostname`'"(ip...) 慢查询统计 -------------'
slow_name=`mysql -u$slow_root -p$slow_password -e "show variables like 'slow_query_log_file'"|grep log|awk '{print $2}'`
#--> 一、整合表'slow_log_his_'$date配置配置
# 表数据要保证为空，避免“error 1062 (23000) at line 1: duplicate entry 'xx' for key 'primary'”
#--》1 本次伪例限制--filter '($event->{user} || "") =~ m/^mhq/i'导入空表 mhq用户并不存在
#--》或2 方案，在insert之前先 delete from 表；
#（1）删除已有并创建
mysql -h${slow_host} -u${slow_root} -p${slow_password} -d${slow_dbname} -b -n -e " drop table if exists ${pt_table};"
pt-query-digest --user=${slow_root} --password=${slow_password} --no-report --history h=${slow_host},d=${slow_dbname},t=${pt_table} --create-history-table --filter '($event->{user} || "") =~ m/^mhq/i' $slow_name.`date +%y%m%d`
#（2）加database_name 字段，保证各个表结构相同
mysql -h${slow_host} -u${slow_root} -p${slow_password} -d${slow_dbname} -b -n -e "alter table ${pt_table} add column database_name varchar(255) not null first ; "
#--> 二、查找database_name，开始循环导入database_name+date命名 数据库表
#（1）查找所有database_name
for username in `mysql -uroot -hlocalhost -p123456 -n -b -e "select distinct user from mysql.user;"`
do
#（2）使用pt工具将通过--filter 过滤database_name循环导入database_name+date命名 数据库表(存在先删除..)
mysql -h${slow_host} -u${slow_root} -p${slow_password} -d${slow_dbname} -b -n -e "drop table if exists ${pt_table}_${f};"
pt-query-digest --user=${slow_root} --password=${slow_password} --filter '($event->{user} || "") =~ m/^'$username'/i' --no-report --history h=${slow_host},d=${slow_dbname},t=${pt_table}_${f} --create-history-table $slow_name.`date +%y%m%d`
# 由于后续sql过滤只用到history表，所以未加“--review h=$host,d=$dbname,t='slow_log_'$date'_'$username --create-review-table”参数
#--> 三、处理循环导入的database_name+date命名表
mysql -h${slow_host} -u${slow_root} -p${slow_password} -d${slow_dbname} -b -n -e "
#（1）向每张表加字段，默认值为database_name，用来查询使用
alter table ${pt_table}_${f} add column database_name varchar(255) not null default '$username' first ;
#（2）循环将database_name+date命名表数据读到'slow_log_his_'$date表.
insert into ${pt_table} select * from ${pt_table}_${f};
#（3）清理database_name+date命名表
drop table ${pt_table}_${f};
"
## -e " 冒号需要写在同一行，否则会提示“mysql: option '-e' requires an argument”
#结束循环
done
echo '------------- '`date +%y-%m-%d' '%h:%m:%s`' 结束 "'`hostname`'"(ip...) 慢查询统计 -------------'
# pt-query-digest用到的参数注释：
# --user mysql用户名
#--password mysql用户密码
#--history 将分析结果保存到表中，分析结果比较详细，下次再使用--history时，如果存在相同的语句，且查询所在的时间区间和历史表中的不同,则会记录到数据表中，可以通过查询同一checksum来比较某类型查询的历史变化
# --no-report 不打印分析log
# --host mysql服务器地址
# h 要导入mysql服务器地址
# d 要导入到的database
# t 要导入到的table
#--create-history-table 当使用--history参数把分析结果输出到表中时，如果没有表就自动创建。
# --filter 对输入的慢查询按指定的字符串进行匹配过滤后再进行分析
#--limit限制输出结果百分比或数量，默认值是20,即将最慢的20条语句输出，如果是50%则按总响应时间占比从大到小排序，输出到总和达到50%位置截止。
# 其他参数
#--since 从什么时间开始分析，值为字符串，可以是指定的某个”yyyy-mm-dd [hh:mm:ss]”格式的时间点，也可以是简单的一个时间值：s(秒)、h(小时)、m(分钟)、d(天)，如12h就表示从12小时前开始统计。
#--until 截止时间，配合—since可以分析一段时间内的慢查询。
<b># 查询sql </b>
#未使用表自带字段“*_*_pct_95”平均值，是因为 sum / ts_cnt 并不相等于*_pct_95字段
select
his.*
from
( select
database_name as "sql发起者",
sample sql_text,
ts_cnt as "执行次数",
round(query_time_sum, 2) as "执行时间(总)",
round(query_time_sum / ts_cnt, 2) as "执行时间(每)",
round(lock_time_sum, 3) as "锁时间(总)",
round(lock_time_sum / ts_cnt, 3) as "锁时间 (每)",
round(rows_examined_min / ts_cnt) as "参加运算的记录平均行数",
round(rows_sent_sum / ts_cnt) as "平均返回记录数"
from
slow_log_his_2015_07_03_train_public t
#where database_name like 'retail_%' #database_name not like 'retail_%'
order by
4 desc
) his
limit 10;
<b>显示结果:</b>
<b>注意:</b>
1、需要在慢启动日志切割后执行。
2、/*!40001 sql_no_cache */ 表示: 不把查询结果存储在查询缓存中 (类似oracle 的direct path read) ...本环境是由mysqldump引起/*!40001 sql_no_cache */
3、pt-query- digest小瑕疵：
选中部分sql select /*!40001 sql_no_cache */ * from `item_sku` 执行次数 =9 ；
而实际上是select * from 三个分别三次不同的表 ... (review和history 表都记录到一条数据，执行次数为 9)
而mysqldumpslow 工具结果如下：
count: 3 time=9.89s (29s) lock=0.00s (0s) rows=2453000.0 (7359000), root[root]@localhost
select /*!n sql_no_cache */ * from `item_sku`
count: 3 time=6.68s (20s) lock=0.00s (0s) rows=1545142.0 (4635426), root[root]@localhost
select /*!n sql_no_cache */ * from `item_extension`
count: 3 time=4.01s (12s) lock=0.00s (0s) rows=328886.0 (986658), root[root]@localhost
select /*!n sql_no_cache */ * from `item`
<b>mysql慢日志分析参数的涵义 </b>
` ts_min ` datetime not null default '0000-00-00 00:00:00' comment '最早执行时间' ,
` ts_max` datetime not null default '0000-00-00 00:00:00' comment '最晚执行时间' ,
` ts_cnt` float default null comment '总共执行次数' ,
` query_time_sum` float default null comment '总查询时间' ,
` query_time_min` float default null comment '最小查询时间' ,
` query_time_max` float default null comment '最大查询时间' ,
` query_time_pct_95` float default null comment '平均查询时间' ,
` query_time_stddev` float default null comment '查询时间标准差' ,
` query_time_median` float default null comment '查询时间中位数' ,
` lock_time_sum` float default null comment '总锁定时间' ,,
` lock_time_min` float default null comment '最小锁定时间' ,
` lock_time_max` float default null comment '最大锁定时间' ,
` lock_time_pct_95` float default null comment '平均锁定时间' ,
` lock_time_stddev` float default null comment '锁定时间标准差' ,
` lock_time_median` float default null comment '锁定时间中位数' ,
` rows_sent_sum` float default null comment '总返回记录行数' ,
` rows_sent_min` float default null comment '最小返回记录数' ,
` rows_sent_max` float default null comment '最大返回记录数' ,
` rows_sent_pct_95` float default null comment '平均返回记录数' ,
` rows_sent_stddev` float default null comment '发送返回数标准差' ,
` rows_sent_median` float default null comment '返回记录数中位数' ,
` rows_examined_sum` float default null comment '参加运算的记录总行数' ,
` rows_examined_min` float default null comment '最少参加运算的记录行数' ,
` rows_examined_max` float default null comment '最多参加运算的记录行数' ,
` rows_examined_pct_95` float default null comment '平均参加运算的记录行数' ,
` rows_examined_stddev` float default null comment '参加运算的记录行数标准差' ,
` rows_examined_median` float default null comment '参加运算的记录行数中位数' ,
` rows_affected_sum` float default null comment '受影响记录总行数' ,
` rows_affected_min` float default null comment '最少受影响记录行数' ,
` rows_affected_max` float default null comment '最大受影响记录行数' ,
` rows_affected_pct_95` float default null comment '平均受影响记录行数' ,
` rows_affected_stddev` float default null comment '受影响记录行数标准差' ,
` rows_affected_median` float default null comment '受影响记录行数中位数' ,
` rows_read_sum` float default null comment '读入记录行总数' ,
` rows_read_min` float default null comment '读入记录行最小数' ,
` rows_read_max` float default null comment '读入记录行最大数' ,
` rows_read_pct_95` float default null comment '读入记录行平均数' ,
` rows_read_stddev` float default null comment '读入记录行数标准差' ,
` rows_read_median` float default null comment '读入记录行数中位数' ,
` merge_passes_sum` float default null comment '数据表合并总数' ,
` merge_passes_min` float default null comment '数据表合并最小数' ,
` merge_passes_max` float default null comment '数据表合并最大数' ,
` merge_passes_pct_95` float default null comment '数据表合并平均数' ,
` merge_passes_stddev` float default null comment '数据表合并数标准差' ,
` merge_passes_median` float default null comment '数据表合并数中位数' ,
` innodb_io_r_ops_min` float default null comment '统计计划需要读取的最小页数' ,
` innodb_io_r_ops_max` float default null comment '统计计划需要读取的最大页数' ,
` innodb_io_r_ops_pct_95` float default null comment '统计计划需要读取的平均页数' ,
` innodb_io_r_ops_stddev` float default null comment '统计计划需要读取的页数标准差' ,
` innodb_io_r_ops_median` float default null comment '统计计划需要读取的页数中位数' ,
` innodb_io_r_bytes_min` float default null comment '统计计划需要读取的最小字节数' ,
` innodb_io_r_bytes_max` float default null comment '统计计划需要读取的最大字节数' ,
` innodb_io_r_bytes_pct_95` float default null comment '统计计划需要读取的平均字节数' ,
` innodb_io_r_bytes_stddev` float default null comment '统计计划需要读取的字节数标准差' ,
` innodb_io_r_bytes_median` float default null comment '统计计划需要读取的字节数中位数' ,
` innodb_io_r_wait_min` float default null comment '读取记录时产生锁等待的最小时间' ,
` innodb_io_r_wait_max` float default null comment '读取记录时产生锁等待的最大时间' ,
` innodb_io_r_wait_pct_95` float default null comment '读取记录时产生锁等待的平均时间' ,
` innodb_io_r_wait_stddev` float default null comment '读取记录时产生锁等待时间标准差' ,
` innodb_io_r_wait_median` float default null comment '读取记录时产生锁等待时间中位数' ,
` innodb_rec_lock_wait_min` float default null comment '读取记录时产生行锁等待的最小时间' ,
` innodb_rec_lock_wait_max` float default null comment '读取记录时产生行锁等待的最大时间' ,
` innodb_rec_lock_wait_pct_95` float default null comment '读取记录时产生行锁等待的平均时间' ,
` innodb_rec_lock_wait_stddev` float default null comment '读取记录时产生行锁等待时间标准差' ,
` innodb_rec_lock_wait_median` float default null comment '读取记录时产生行锁等待时间中位数' ,
` innodb_queue_wait_min` float default null comment '等待进入 innodb 队列或在队列中等待执行所消耗的最小时间' ,
` innodb_queue_wait_max` float default null comment '等待进入 innodb 队列或在队列中等待执行所消耗的最大时间' ,
` innodb_queue_wait_pct_95` float default null comment '等待进入 innodb 队列或在队列中等待执行所消耗的平均时间' ,
` innodb_queue_wait_stddev` float default null comment '等待进入 innodb 队列或在队列中等待执行所消耗时间标准差' ,
` innodb_queue_wait_median` float default null comment '等待进入 innodb 队列或在队列中等待执行所消耗时间中位数' ,
` innodb_pages_distinct_min` float default null comment '读取的独立页最小个数' ,
` innodb_pages_distinct_max` float default null comment '读取的独立页最大个数' ,
` innodb_pages_distinct_pct_95` float default null comment '读取的独立页平均个数' ,
` innodb_pages_distinct_stddev` float default null comment '读取的独立页个数标准差' ,
` innodb_pages_distinct_median` float default null comment '读取的独立页个数中位数' ,
` qc_hit_cnt` float default null comment 'query缓冲区的命中次数' ,
` qc_hit_sum` float default null comment 'query缓冲区的命中总数' ,
` full_scan_cnt` float default null comment '全表扫描次数' ,
` full_scan_sum` float default null comment '全表扫描总数' ,
` full_join_cnt` float default null comment '数据表全连接次数' ,
` full_join_sum` float default null comment '数据表全连接总数' ,
` tmp_table_cnt` float default null comment '内存中使用临时表次数' ,
` tmp_table_sum` float default null comment '内存中使用临时表总数' ,
` disk_tmp_table_cnt` float default null comment '磁盘上使用临时表总数' ,
` disk_tmp_table_sum` float default null comment '磁盘上使用临时表总数' ,
` filesort_cnt` float default null comment '内存排序次数' ,
` filesort_sum` float default null comment '内存排序总数' ,
` disk_filesort_cnt` float default null comment '磁盘排序次数' ,
` disk_filesort_sum` float default null comment '磁盘排序总数'
<b> mysql version = 5.6.19 字段差异</b>
-->增加：
checksum => 校验值
sample => sql 样本
-->差异：
原字段 改后字段
disk_tmp_table_cnt => tmp_table_on_disk_cnt
disk_tmp_table_sum => tmp_table_on_disk_sum
disk_filesort_cnt => filesort_on_disk_cnt
disk_filesort_sum => filesort_on_disk_sum
【源于本人笔记】 若有书写错误，表达错误，请指正...