最近发现数据库同步总是出问题,最诡异的时,主从数据库写入的数据不一样,我勒个去。程浩同学看了半天终于找到原因,原来是PDO的一个大坑,加上binlog的一个大坑。
首先声明,这篇文章有很强的攻击性,如果你利用这里面写的东西攻击,所造成的一切后果,自负!
2010/12/15 我的领导,突然要求我们开始折腾一下机器。主要的目的是,没做备份的,做一下备份,单个的数据库做主从,线上的机器要做一个能快速恢复的热备份。经过检查发现机器若干台需要整理,于是开始一一处理,其他的还算顺利,但发现了一个 数据库的同步经常有问题,主要问题表现在做好主从同步以后,经过一段时间就会发现重复的插入,引起同步失效。
1、首先考虑数据本身就不一致,造成的同步失效。
处理方法:
2、本以为问题解决,结果在周一,再次发现数据同步失败。
实在没办法了,只好吧这个库挪到另外的单独的一台机器上,单独观察,其他剩余的库做了同步。
5、 在那个库挪走以后同步竟然神奇的好了,观察了一周。
依次查找用到的 apache ,php ,zend,pdo 等。这真是不看不知道,一看吓一跳!我发现这做运维的网管和程序员那就是一对天敌。看这些东西那叫一个郁闷。
首先查看 apache ,发现是使用 apache 的 proxy 模块代理到另一个机器。
到了那个机器我怎么也找不到访问的那个路径,我不懂 php 但配置 apache 不菜啊,咋就没有呢,这一通折腾才发现人家在那个目录下写了一个 .htaccess 又重定向了 !~
这次总算找到那个 php 了,一搜索光 Insert 函数就有 4、5 个。这玩意太多,还是找 mysql_query() 。找了半天没有~~,仔细一看用的是 PDO
你用 PDO 你就 $var = new PDO(‘mysql:host=xx;dbname=xx;charset=gbk’,'xx’,”); 用吧,一找 new PDO 还没有。
一点点的找下去发现 人家用的是 Zend_Db::factory(),还搞了一个超复杂的对象。 $config->db->adapter,$config->db->config->toArray() 这里咬牙、跺脚若干次。
总算找到正主了,找这个可真不容易: 访问不直接访问,用 proxy 弄跑了,弄到另一个机器上也不老老实实的访问,整一个 302 跳转了,php 链接 mysql 有现成的 mysql_query() 不用,非要调用 PDO ,PDO还不直接调用,要用 Zend 的框架调用。
接下来的事情就是跟踪 PDO Zend 调用过程,抓包查看交互的数据,根据许许多多的调试信息来看,终于发现了,这个 PDO 处理数据的方式比较特别。
访问 mysql server 的方式有两种。
1、 直接访问模式
2、 预处理模式
先说说这两个结构的区别,直接访问就像我们用客户端连接进数据那样,标准的 sql 语句插入、更新、删除和查询。这个要求就是每个命令里面都要指明 表、字段、等信息。
预处理就是:先告诉 mysql 一个表的结构,然后,后面的全都按照这个表结构来,这样就不用每次都发送 表、字段等信息了。这样的优势是大量的插入会快一点。特点是只在第一次发送表结构。而不是每次都发送一遍,问题是 mysql binlog 里面不支持这种格式。
这两种方式比较起来,第一种 安全,第二种 快速 。第二种因为没有表结构,所以当任何一个字段出现问题,就会造成所有的数据问题,而不像第一种,只影响那一句。那个 PDO 使用的就是第二种方式,而且他错误的认为一切都是字符串,把所有的数据都转换成 16 进制了。
在第一次插入的时候 mysql 使用第二种方式插入数据,但 binlog 里面因为没有这种结构,所以他自己把语句转换成了 第一种模式,加上了表、及字段信息,但 mysql 不会对 int 形做相应的转换,(这个在字符串表示中是没有错误的),造成了记录的日志是按照字符串的方式记录的。这样在吧一个字符串插入 int 形就出现了插入的数据和日志不一致的情况。要解决这个问题只有 1、给mysql 写一个补丁,解决这个问题。(现在功力不够还写不出来) 2、在我们公司禁用 预处理结构体方式的数据写入。看来目前我们只能使用第二种方法了。
总的来说,pdo 写的有问题,mysql 的 log 记录转换的方式也存在问题。下面是我写的一个能够触发这个 bug 的代码。
|
测试过程如下:
|
以上转自:http://blog.chinaunix.net/uid-8746761-id-2015321.html
下面是我们的php测试代码:
<?php $dsn = "mysql:host=localhost;dbname=wanke"; $db = new PDO($dsn, 'wanke', 'wanke'); $db->setAttribute(PDO::ATTR_EMULATE_PREPARES,false); //必须加 $db->exec('SET NAMES gbk'); //必须加 //$sth = $db->prepare("DELETE FROM `atest` WHERE t2=:t1"); //$sth = $db->prepare("INSERT INTO atest (`t1`,`t2`) VALUES(?,?)"); $sth = $db->prepare("INSERT INTO atest (`t1`,`t2`) VALUES(:a,:b)"); //必须是这种形式,不能是问号的 //$sth->bindValue(':t1','666777',PDO::PARAM_STR); //$sth->bindValue(1,67890); //$sth->bindValue(2,'ttttttasdfasttttt'); $sth->bindValue(':a','6784444'); $sth->bindValue(':b','ttttttasdfasttttt'); $count = $sth->execute(); echo $count; $db = null; ?>
另外一种解决方案
主库使用:binlog_format="ROW" 模式可以避免这种情况的发生,不用修改PDO属性。mysql 默认的binlog 使用的是 Statement 模式