mysqlbinlog提取sql_如何通过binlog获取我们想要的MySql语
句？
前⾔
MySql的binlog⼀般⽤于我们对数据的恢复，以及从数据库对主数据库的复制和更新。
假设此时我们有⼀个需要查询和读取Mysql最近操作DDL的信息，我们需要怎么处理？
聪明的你可能已经想到了，我们可以使⽤mysqlbinlog⼯具读取啊！的确，mysqlbinlog对于statement或者mixed格式的binlog⽂件确实会很⽅便读取，但是你要知道，从Mysql5.7.7开始，row就是默认的binlog_format，此时我们再要去直接通过⾁眼去看，恐怕就不是那么容易了。
即使我们在通过mysqlbinlog解析时加上-v参数，也只能显⽰出这样的效果:
于是，我写了⼀个binlog2sql的初级版本，来实现sql语句的转换。
实现
实现过程不是很复杂，主要是通过mysqlbinlog来提取我们需要的DDL语句，然后我们再通过我们的⽅法来把这些语句转化为我们可以识别的sql语句。
核⼼代码:
/**
* @return $this
*/
protected function selectFromBinLog()
{
$fillFile = Util::getFile(__DIR__ . '/data/file.sql');
file_put_contents($fillFile, "");
exec("mysqlbinlog -v --database='" . Conf::__DATABASE__ . "' $this->_binlog_basename/$this->_binlog_file | grep -E -i
'###|UPDATE|INSERT|DELETE' >> $fillFile");
return $this;
}
/**
* @return $this
*/
protected function parseSql()
{
$fillFileHandler = fopen(__DIR__ . '/data/file.sql', 'r');
$sqlArr = [];
if ($this->_type == 'ROW') {
$match = NULL;
$sqlStr = "";
while (($sql = fgets($fillFileHandler)) !== false) {
if (($match = preg_match('/UPDATE|INSERT|DELETE/', $sql)) || strrpos($sql, 'end_log_pos') !== false) {
# 如果有指定表
if ($match && $this->_table && strpos($sql, $this->_table) === false) continue;
$sqlStr == '' || array_push($sqlArr, $sqlStr);
$sqlStr = $match ? trim(substr($sql, 3, -1)) . " " : "";
} elseif (strpos($sql, '@') !== false || strpos($sql, 'SET')) {
$sqlStr .= trim(substr($sql, 3, -1)) . " ";
}
}
$sqlStr == '' || array_push($sqlArr, $sqlStr);
} else {
# statement 和 mixed格式⼀样
while (($sql = fgets($fillFileHandler)) !== false) {
$sql = trim($sql);
function怎么记忆
if (preg_match('/(UPDATE|INSERT|DELETE)\s+/', $sql)) {
array_push($sqlArr, $sql);
}
}
}
$sqlArr = array_map(function ($value) {
return preg_replace_callback('/(@(\d+))/', function ($matches) use ($value) {
$parts = explode('.', $value);
return $this->getTableColumns(explode('`', array_pop($parts))[1])[$matches[2] - 1]; }, $value);
}, $sqlArr);
$mysqlFile = Util::getFile(__DIR__ . '/data/mysql.sql');
array_map(function ($value) use ($mysqlFile) {
file_put_contents($mysqlFile, $value . PHP_EOL, FILE_APPEND);
}, $sqlArr);
fclose($fillFileHandler);
return $this;
}
/**
* @param $table
* @return array
*/
protected function getTableColumns($table)
{
if (array_key_exists($table, $this->_tableColumns))
return $this->_tableColumns[$table];
$tableInfo = $this->select("show full columns from $table");
if (empty($tableInfo)) Util::dd("$table 不存在");
return $this->_tableColumns[$table] = array_column($tableInfo, 'Field');
}
其中有三个主要的⽅法，selectFromBinLog⽤于执⾏mysqlbinlog，⽤于提取我们所需要的DDL，pars
eSql⽤于解析我们提取出来的sql，getTableColumns⽤于获取表的字段(主要是针对row模式下的@1,@2之类)。
当我们执⾏Binlog.php的start⽅法之后，就可以把DDL写⼊到'./data/mysql.sql'中了，⾮常⽅便。

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。