diff --git a/bin/pt-stalk b/bin/pt-stalk index a16b9a3a..7890d242 100755 --- a/bin/pt-stalk +++ b/bin/pt-stalk @@ -1162,20 +1162,19 @@ slave_status() { local outfile=$1 local mysql_version=$2 - if [ "${mysql_version}" '<' "5.7" ]; then - local sql="SHOW SLAVE STATUS\G" - echo -e "\n$sql\n" >> $outfile - $CMD_MYSQL $EXT_ARGV -e "$sql" >> $outfile - else + local sql="SHOW SLAVE STATUS\G" + echo -e "\n$sql\n" >> $outfile + $CMD_MYSQL $EXT_ARGV -e "$sql" >> $outfile + if [ "${mysql_version}" '>' "5.6" ]; then local sql="SELECT * FROM performance_schema.replication_connection_configuration JOIN performance_schema.replication_applier_configuration USING(channel_name)\G" echo -e "\n$sql\n" >> $outfile $CMD_MYSQL $EXT_ARGV -e "$sql" >> $outfile - sql="SELECT * FROM replication_connection_status\G" + sql="SELECT * FROM performance_schema.replication_connection_status\G" echo -e "\n$sql\n" >> $outfile $CMD_MYSQL $EXT_ARGV -e "$sql" >> $outfile - sql="SELECT * FROM replication_applier_status JOIN replication_applier_status_by_coordinator USING(channel_name)\G" + sql="SELECT * FROM performance_schema.replication_applier_status JOIN performance_schema.replication_applier_status_by_coordinator USING(channel_name)\G" echo -e "\n$sql\n" >> $outfile $CMD_MYSQL $EXT_ARGV -e "$sql" >> $outfile fi