PHP使用mysqlnd驱动的配置详解

Mysql Native驱动(Mysql Native Driver 简称:mysqlnd )在PHP5.3.0版本中被引入。PHP5.4之后的版本mysqlnd被作为默认配置选项,下面我们就一起来看看mysqlnd驱动的例子吧．

我的PHP环境是5.4，使用mysql时突然出现以下错误：

mysql_connect(): Headers and client library minor version mismatch. Headers:50508 Library:50166

索性换成mysqlnd扩展，下面简单介绍mysqlnd：

mysqlnd(MySQL native driver for PHP)是php5.3后php自带的mysql驱动，官方推荐使用，优势如下：
A.libmysql驱动是由mysql AB公司(现在是oracle公司)编写, 并按mysql license许可协议发布,所以在PHP中默认是被禁用的.

而mysqlnd是由php官方开发的驱动,以php license许可协议发布,故就规避了许可协议和版权的问题

B.因为mysqlnd内置于PHP源代码,故你在编译安装php时就不需要预先安装mysql server也可以提供mysql client API (mysql_connect, pdo , mysqli), 这将减化一些工作量.

C. mysqlnd是专门为php优化编写的驱动,它使用了PHP本身的特性,在内存管理,性能上比libmysql更有优势. php官方的测试是:libmysql将每条记录在内存中保存了两份,而mysqlnd只保存了一份

D. 一些新的或增强的功能

增强的持久连接

引入特有的函数mysqli_fetch_all()

引入一些性能统计函数 mysqli_get_cache_stats(), mysqli_get_client_stats(),

mysqli_get_connection_stats(),

使用上述函数,可很容易分析mysql查询的性能瓶颈!

SSL支持(从php 5.3.3开始有效)

压缩协议支持

命名管道支持(php 5.4.0开始有效)

如何使用mysqlnd驱动？
传统的编译php时带如下参数：
--with-mysql=/usr/local/mysql

--with-pdo-mysql=/usr/local/mysql

查看编译参数：

[root@localhost php54]#./configure --help | grep mysql
  --with-mysql=DIR      Include MySQL support.  DIR is the MySQL base
                          mysqlnd the MySQL native driver will be used
  --with-mysql-sock=SOCKPATH   MySQL/MySQLi/PDO_MYSQL: Location of the MySQL unix socket pointer.
  --with-mysqli=FILE    Include MySQLi support.  FILE is the path
                          to mysql_config.  If no value or mysqlnd is passed
  --enable-embedded-mysqli  MYSQLi: Enable embedded support
  --with-pdo-mysql=DIR    PDO: MySQL support. DIR is the MySQL base directory
                                 If no value or mysqlnd is passed as DIR, the
  --enable-mysqlnd        Enable mysqlnd explicitly, will be done implicitly
  --disable-mysqlnd-compression-support
                            Disable support for the MySQL compressed protocol in mysqlnd
  --with-zlib-dir=DIR       mysqlnd: Set the path to libz install prefix

可以看到只要不指定，默认就是mysqlnd。于是重新编译PHP：

./configure --prefix=/usr/local/php54 --with-config-file-path=/usr/local/php54/etc --with-zlib --enable-xml --disable-rpath --enable-bcmath --enable-shmop --enable-sysvsem --with-curl --with-curlwrappers --enable-fpm --with-mcrypt --with-gd --with-openssl --with-mhash --enable-sockets --with-ldap --with-ldap-sasl --with-xmlrpc -enable-zip --enable-soap--with-mysql --with-pdo-mysql --with-mysqli

mysql数据库或数据只给专业人士看了，如果我们要做数据报表这种就需要转换成excel文件了，下面我们来看一个简单的由PHP导出MySQL数据到Excel的方法

经常会碰到需要从数据库中导出数据到Excel文件，用一些开源的类库，比如 PHPExcel，确实比较容易实现，但对大量数据的支持很不好，很容易到达PHP内存使用上限。这里的方法是利用fputcsv写CSV文件的方法，直接向浏览器输出Excel文件。

<?php
// 输出Excel文件头，可把user.csv换成你要的文件名
header('Content-Type: application/vnd.ms-excel');
header('Content-Disposition: attachment;filename=&quot;user.csv&quot;');
header('Cache-Control: max-age=0');</p>

<p>// 从数据库中获取数据，为了节省内存，不要把数据一次性读到内存，从句柄中一行一行读即可
$sql = 'select * from tbl where ……';
$stmt = $db-&gt;query($sql);</p>

<p>// 打开PHP文件句柄，php://output 表示直接输出到浏览器
$fp = fopen('php://output', 'a');</p>

<p>// 输出Excel列名信息
$head = array('姓名', '性别', '年龄', 'Email', '电话', '……');
foreach ($head as $i =&gt; $v) {
    // CSV的Excel支持GBK编码，一定要转换，否则乱码
    $head[$i] = iconv('utf-8', 'gbk', $v);
}</p>

<p>// 将数据通过fputcsv写到文件句柄
fputcsv($fp, $head);</p>

<p>// 计数器
$cnt = 0;
// 每隔$limit行，刷新一下输出buffer，不要太大，也不要太小
$limit = 100000;</p>

<p>// 逐行取出数据，不浪费内存
while ($row = $stmt-&gt;fetch(Zend<em>Db::FETCH</em>NUM)) {</p>

<pre><code>$cnt ++;
if ($limit == $cnt) { //刷新一下输出buffer，防止由于数据过多造成问题
    ob_flush();
    flush();
    $cnt = 0;
}

foreach ($row as $i =&amp;gt; $v) {
    $row[$i] = iconv('utf-8', 'gbk', $v);
}
fputcsv($fp, $row);
</code></pre>

<p>}

简单易用，非常节省内存，不依赖第三方类库。

对于获得最后插入数据的记录ID号我们通常会用到mysql_insert_id()或select max(id)来操作了，下面一起来看看小编对于这两个函数的一些理解。

这个问题以前绝壁遇到过，太久没写不记得（貌似当时是CI框架直接有相关函数的），然后这次又遇到了，再次滚去查了一下，这里说的并非是PDO之类的情况，而是用过时的连接和执行方式之后怎么进行操作。

有什么SQL语句实现的，但明显不合适，当收到多人操作时，顿时就混乱不堪。

所以在此，用mysql_insert_id()函数搞定，他会返回AUTO_INCRESEMENT的值。

代码如下	复制代码
<?php $link = mysql_connect('localhost', 'mysql_user', 'mysql_password'); if (!$link) {     die('Could not connect: ' . mysql_error()); } mysql_select_db('mydb'); mysql_query("INSERT INTO mytable (product) values ('kossu')"); printf("Last inserted record has id %d ", mysql_insert_id()); ?>

刚开始我还在想这个函数不会遇到相同的问题么，然后小新告诉我是基于当前数据库连接的，顿时不怕不怕啦。

当然还有

代码如下	复制代码
mysql_query("select max(id) from t1",$link);

当然，现在这种连接方式已经out的可以了，

这里也有说明：

Warning

This extension is deprecated as of PHP 5.5.0, and will be removed in the future. Instead, the MySQLi or PDO_MySQL extension should be used. See also MySQL: choosing an API guide and related FAQ for more information. Alternatives to this function include:

mysqli_insert_id()
PDO::lastInsertId()

下面我们来分享一下我珍藏的php数据库操作类，他的强大之处是可支持mysql,mssql,pg三大主流数据库，你只要修改一下数据库的类型就可以直接应用。

本文实例讲述了可用mysql,mssql,pg三种数据库的数据库操作类,你只要作任何修改就可以方便的改变你数据库的类型.分享给大家供大家参考。具体分析如下：


函数清单,索引:

Open:打开数据库连接 Line:71
Close:关闭数据库连接 Line:107
SelectDB:选择数据库 Line:129
Query:创建查询 Line:151
DataSeek:移动记录指针 Line:175
FieldName:获取字段名称 Line:198
FieldType:获取字段类型 Line:220
FieldLenght:获取字段长度 Line:242
FetchRow:获取数据并保存到数组（数字索引） Line:264
FetchArray:获取数据并保存进数组（数字和关联） Line:289
FetchObject:获取数据并保存到对象（对象方式） Line:315
Result:获取结果数据 Line:341
FreeResult:刷新记录集 Line:363
RowsNumber:获取记录数量 Line:385
FieldsNumber:获取字段数量 Line:407
CurRecNumber:获取当前记录号（从0开始） Line:429
RecordNumber:获取当前行号（从1开始） Line:438
MoveFirstRec:移动到第一条记录 Line:447
MoveLastRec:移动到最后一条记录 Line:469
MovePreviousRec:移动到前一条记录 Line:495
MoveNextRec:移动到下一条记录 Line:521
MoveToRec:移动到一个特定的记录（从1开始） Line:548

php数据库操作类代码如下:

代码如下

复制代码

<?PHP /********************************************************************************** 此类将数据库操作封装，具有良好的可移植性,针对数据库：mysql,mssql,pg ************************************************************************************ // -函数清单 索引： // - Open: 打开数据库连接 Line:71 // - Close: 关闭数据库连接 Line:107 // - SelectDB: 选择数据库 Line:129 // - Query: 创建查询 Line:151 // - DataSeek: 移动记录指针 Line:175 // - FieldName: 获取字段名称 Line:198 // - FieldType: 获取字段类型 Line:220 // - FieldLenght: 获取字段长度 Line:242 // - FetchRow: 获取数据并保存到数组（数字索引） Line:264 // - FetchArray: 获取数据并保存进数组（数字和关联） Line:289 // - FetchObject: 获取数据并保存到对象（对象方式） Line:315 // - Result: 获取结果数据 Line:341 // - FreeResult: 刷新记录集 Line:363 // - RowsNumber: 获取记录数量 Line:385 // - FieldsNumber: 获取字段数量 Line:407 // - CurRecNumber: 获取当前记录号（从0开始） Line:429 // - RecordNumber: 获取当前行号（从1开始） Line:438 // - MoveFirstRec: 移动到第一条记录 Line:447 // - MoveLastRec: 移动到最后一条记录 Line:469 // - MovePreviousRec: 移动到前一条记录 Line:495 // - MoveNextRec: 移动到下一条记录 Line:521 // - MoveToRec: 移动到一个特定的记录（从1开始） Line:548 ************************************************************************************ //Inputs: // - dbType: databases type: mssql, mysql, pg // - connectType: connection type: c - common connection, // p - open persistent connection // - connect: for MS SQL Server - server name, // for MySQL - hostname [:port] [:/path/to/socket] , // for PostgreSQL - host, port, tty, options, // dbname (without username and password) // - username // - password // - dbName: database name // - query: SQL query // - result: result set identifier // - RowNumber: // - offset: field identifier // - ResultType: a constant and can take the following values: PGSQL_ASSOC, PGSQL_NUM, and PGSQL_BOTH // - FieldName // //Returns: // - result: result set identifier // - connect link identifier // - record number (starting at 0: CurrRecNumber or starting at 1: RecordNumber) // - number of fields in the specified result set // - number of rows in the specified result set *************************************************************************************/ Class mDatabase { /***********************************成员变量定义***************************************/ var $dbType; // 数据库类型: mssql, mysql, pg var $connectType; // 连接类型: c - common connection, p - open persistent connection var $idCon; // 连接号 var $curRow; // current row number of data from the result // associated with the specified result identifier array var $seek; // current row number of data from DataSeek function array   /***********************************成员方法实现***************************************/ /************************************************************************************ *连接数据库的函数 *************************************************************************************/ Function Open($dbType, $c, $connect, $username = "", $password = "") { $this->dbType = $dbType; Switch ($dbType) { Case "mssql": If ($connectType == "c") { $idCon = mssql_connect($connect, $username, $password); } Else { $idCon = mssql_pconnect($connect, $username, $password); } Break; Case "mysql": If ($connectType == "c") { $idCon = mysql_connect($connect, $username, $password); } Else { $idCon = mysql_pconnect($connect, $username, $password); } Break; Case "pg": If ($connectType == "c") { $idCon = pg_connect($connect . " user=" . $username . " password=" . $password); } Else { $idCon = pg_pconnect($connect . " user=" . $username . " password=" . $password); } Break; Default: $idCon = 0; Break; } $this->idCon = $idCon; Return $idCon; } /************************************************************************************ *关闭数据库连接 *************************************************************************************/ Function Close() { Switch ($this->dbType) { Case "mssql": $r = mssql_close($this->idCon); Break; Case "mysql": $r = mysql_close($this->idCon); Break; Case "pg": $r = pg_close($this->idCon); Break; Default: $r = False; Break; } Return $r; } /************************************************************************************ *选择数据库 *************************************************************************************/ Function SelectDb($dbName) { Switch ($this->dbType) { Case "mssql": $r = mssql_select_db($dbName); Break; Case "mysql": $r = mysql_select_db($dbName); Break; Case "pg": $r = False; Break; Default: $r = False; Break; } Return $r; } /************************************************************************************ *创建查询 *************************************************************************************/ Function Query($query) { Switch ($this->dbType) { Case "mssql": $r = mssql_query($query, $this->idCon); Break; Case "mysql": $r = mysql_query($query, $this->idCon); Break; Case "pg": $r = pg_exec($this->idCon, $query); Break; Default: $r = False; Break; } $this->curRow[$r] = 0; $this->seek[$r] = 0; Return $r; } /************************************************************************************ *移动记录指针 *************************************************************************************/ Function DataSeek($result, $RowNumber) { Switch ($this->dbType) { Case "mssql": $r = mssql_data_seek($result, $RowNumber); Break; Case "mysql": $r = mysql_data_seek($result, $RowNumber); Break; Case "pg": $r = False; Break; Default: $r = False; Break; } $this->seek[$result] = (int) $RowNumber; Return $r; } /************************************************************************************ *获取字段名 *************************************************************************************/ Function FieldName($result, $offset) { Switch ($this->dbType) { Case "mssql": $r = mssql_field_name($result, $offset); Break; Case "mysql": $r = mysql_field_name($result, $offset); Break; Case "pg": $r = pg_fieldname($result, $offset); Break; Default: $r = False; Break; } Return $r; } /************************************************************************************ *获取字段类型 *************************************************************************************/ Function FieldType($result, $offset) { Switch ($this->dbType) { Case "mssql": $r = mssql_field_type($result, $offset); Break; Case "mysql": $r = mysql_field_type($result, $offset); Break; Case "pg": $r = pg_fieldtype($result, $offset); Break; Default: $r = False; Break; } Return $r; } /************************************************************************************ *获取字段长度 *************************************************************************************/ Function FieldLength($result, $offset) { Switch ($this->dbType) { Case "mssql": $r = mssql_field_length($result, $offset); Break; Case "mysql": $r = mysql_field_len($result, $offset); Break; Case "pg": $r = pg_fieldsize($result, $offset); Break; Default: $r = False; Break; } Return $r; } /************************************************************************************ *获取数据并保存到数组，可以用数字索引方式访问数组 *************************************************************************************/ Function FetchRow($result, $RowNumber = 0) { Switch ($this->dbType) { Case "mssql": $r = mssql_fetch_row($result); Break; Case "mysql": $r = mysql_fetch_row($result); Break; Case "pg": $r = pg_fetch_row($result, $RowNumber); If ($r) { $this->curRow[$result] = $RowNumber; $this->seek[$result] = $RowNumber; } Break; Default: $r = False; Break; } Return $r; }   /************************************************************************************ *获取数据并保存到数组，可以用数字索引和关联索引的方式访问 *************************************************************************************/ Function FetchArray($result, $RowNumber = 0, $ResultType = 2) { Switch ($this->dbType) { Case "mssql": $r = mssql_fetch_array($result); Break; Case "mysql": $r = mysql_fetch_array($result); Break; Case "pg": $r = pg_fetch_array($result, $RowNumber, $ResultType); If ($r) { $this->curRow[$result] = $RowNumber; $this->seek[$result] = $RowNumber; } Break; Default: $r = False; Break; } Return $r; } /************************************************************************************ *获取数据并保存到对象 *************************************************************************************/ Function FetchObject($result, $RowNumber = 0, $ResultType = 2) { Switch ($this->dbType) { Case "mssql": $r = mssql_fetch_object($result); Break; Case "mysql": $r = mysql_fetch_object($result); Break; Case "pg": $r = pg_fetch_object($result, $RowNumber, $ResultType); If ($r) { $this->curRow[$result] = $RowNumber; $this->seek[$result] = $RowNumber; } Break; Default: $r = False; Break; } Return $r; } /************************************************************************************ *获取结果数据 *************************************************************************************/ Function Result($result, $RowNumber, $FieldName) { Switch ($this->dbType) { Case "mssql": $r = mssql_result($result, $RowNumber, $FieldName); Break; Case "mysql": $r = mysql_result($result, $RowNumber, $FieldName); Break; Case "pg": $r = pg_result($result, $RowNumber, $FieldName); Break; Default: $r = False; Break; } Return $r; } /************************************************************************************ *释放结果数据 *************************************************************************************/ Function FreeResult($result) { Switch ($this->dbType) { Case "mssql": $r = mssql_free_result($result); Break; Case "mysql": $r = mysql_free_result($result); Break; Case "pg": $r = pg_freeresult($result); Break; Default: $r = False; Break; } Return $r; } /************************************************************************************ *获取记录数量 *************************************************************************************/ Function RowsNumber($result) { Switch ($this->dbType) { Case "mssql": $r = mssql_num_rows($result); Break; Case "mysql": $r = mysql_num_rows($result); Break; Case "pg": $r = pg_numrows($result); Break; Default: $r = False; Break; } Return $r; } /************************************************************************************ *获取字段数量 *************************************************************************************/ Function FieldsNumber($result) { Switch ($this->dbType) { Case "mssql": $r = mssql_num_fields($result); Break; Case "mysql": $r = mysql_num_fields($result); Break; Case "pg": $r = pg_numfields($result); Break; Default: $r = False; Break; } Return $r; } /************************************************************************************ *获取当前记录号（从0开始） *************************************************************************************/ Function CurRecNumber($result) { $r = $this->curRow[$result]; Return $r; } /************************************************************************************ *获取当前行号（从1开始） *************************************************************************************/ Function RecordNumber($result) { $cr = $this->CurRecNumber($result) + 1; Return $cr; } /************************************************************************************ *移动到第一条记录 *************************************************************************************/ Function MoveFirstRec($result) { Switch ($this->dbType) { Case "pg": $r = $this->FetchRow($result, 0); Break; Default: $rn = $this->DataSeek($result, 0); If ($rn) { $r = $this->FetchRow($result); If ($r) $this->curRow[$result] = $this->seek[$result]; } Else { $r = False; } Break; } Return $r; } /************************************************************************************ *移动到最后一条记录 *************************************************************************************/ Function MoveLastRec($result) { $rs = $this->RowsNumber($result); If ($rs) { $rs--; Switch ($this->dbType) { Case "pg": $r = $this->FetchRow($result, $rs); Break; Default: $rn = $this->DataSeek($result, $rs); If ($rn) { $r = $this->FetchRow($result); If ($r) $this->curRow[$result] = $this->seek[$result]; } Else { $r = False; } Break; } } Return $r; } /************************************************************************************ *移动到前一条记录 *************************************************************************************/ Function MovePreviousRec($result) { $rs = $this->CurRecNumber($result); If ($rs) { $rs--; Switch ($this->dbType) { Case "pg": $r = $this->FetchRow($result, $rs); Break; Default: $rn = $this->DataSeek($result, $rs); If ($rn) { $r = $this->FetchRow($result); If ($r) $this->curRow[$result] = $this->seek[$result]; } Else { $r = False; } Break; } } Return $r; } /************************************************************************************ *移动到下一条记录 *************************************************************************************/ Function MoveNextRec($result) { $rs = $this->CurRecNumber($result); $rn = $this->RowsNumber($result); $rs++; If ($rs != $rn) { Switch ($this->dbType) { Case "pg": $r = $this->FetchRow($result, $rs); Break; Default: $re = $this->FetchRow($result); If ($re) { $r = $re; $this->curRow[$result]++; $this->seek[$result] = $this->curRow[$result]; } Else { $r = False; } Break; } } Return $r; } /************************************************************************************ *移动到指定记录（编号从0开始） *************************************************************************************/ Function MoveToRec($result, $RowNumber) { $rn = $this->RowsNumber($result); If ($RowNumber > 0 And $RowNumber < $rn) { $RowNumber--; Switch ($this->dbType) { Case "pg": $r = $this->FetchRow($result, $RowNumber); Break; Default: $rn = $this->DataSeek($result, $RowNumber); If ($rn) { $r = $this->FetchRow($result); If ($r) $this->curRow[$result] = $this->seek[$result]; } Else { $r = False; } Break; } } Return $r; } } //********************************方法实现完毕****************************************// ?>

我没有骗你吧，真的是我见过最强大的php数据库操作类。

下面我们来看看php pdo_mysql连接报错Connection failed: SQLSTATE[HY000] [2002] No such file or directory问题的解决办法。

错误

Connection failed: SQLSTATE[HY000] [2002] No such file or directory

环境概述：

MacOS
xampp 搭建的开发环境 apache mysql php
xampp 已支持mysql oracle 测试ok，且 phpinfo已上显示支持pdo_mysql pdo_pgsql pdo_sqlite
其中mysql我用的是brew包管理安装到机器里面的，而非xampp自带的mysql

php pdo 连接报错 Connection failed: SQLSTATE[HY000] [2002] No such file or directory
开始以为找不到文件是因为 url rewrite导致的，（因为从nginx切换到apache）结果跟踪程序发现是 new pdo 报错

经过搜索一些资料研究发现：

这个是php.ini配置文件中pdo_mysql.default_socket指定的mysql.sock路径不对
我的mysql.sock文件在 /private/tmp/mysql.sock
所以要设置：

pdo_mysql.default_socket=/private/tmp/mysql.sock

如果不知道自己的mysql.sock在哪里可以搜索（因为编译安装，和yum、apt-get、或者brew等包管理工具安装的位置不一样）

sudo find / -name ‘mysql.sock’

下面是官方给出bug修复

1. Open up php.ini (mine was in /private/etc/)
2. locate this line: pdo_mysql.default_socket=/var/mysql/mysql.sock
3. Change the line to: pdo_mysql.default_socket=/tmp/mysql.sock
4. Restart apache

1、我这里需要补充下，如果是新系统或者刚玩php的同志，在Mac的系统中php.ini 文件不存在，

2、需要在/private/etc/目录下cp  php.ini.default
php.ini ,然后再做修改下，

3、但是如果使用的xampp mysql作为数据库，那么就不需要使用官方的step2，直接写下面方式就可以了。

pdo_mysql.default_socket=/Applications/XAMPP/xamppfiles/var/mysql/mysql.sock

 
解决方法三

sudo vim /etc/php.ini

把以下三个原来空白的值都设置为 /tmp/mysql.sock

mysql.default_socket = /tmp/mysql.sock
pdo_mysql.default_socket= /tmp/mysql.sock
mysqli.default_socket =/tmp/mysql.sock
 
都修改了
修改完成后使用
sudo /usr/sbin/apachectl restart