强大的php数据库操作类，支持mysql,mssql,pg

下面我们来分享一下我珍藏的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数据库操作类。

对于获得最后插入数据的记录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 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

 

PHPExcel导出excel对于这个插件来讲是非常的简单了，但在thinkphp中并不那么简单了，有不少的朋友不知道如何操作，下面小编就为大家介绍ThinkPHP中用PHPExcel导出excel文件的过程。 phpexcel可以让开发者方便快捷的来操作xls文件了，我们下文来整理几个关于phpexcel对数据导入与导出例子。

PHPExcel读取excel文件

实例代码：
 

代码如下

复制代码

require_once('include/common.inc.php');     require_once(ROOTPATH . 'include/phpExcel/PHPExcel/IOFactory.php');         $filePath = './file/xls/110713.xls';         $fileType = PHPExcel_IOFactory::identify($filePath); //文件名自动判断文件类型     $objReader = PHPExcel_IOFactory::createReader($fileType);     $objPHPExcel = $objReader->load($filePath);         $currentSheet = $objPHPExcel->getSheet(0); //第一个工作簿     $allRow = $currentSheet->getHighestRow(); //行数     $output = array();     $preType = '';         $qh = $currentSheet->getCell('A4')->getValue();     //按照文件格式从第7行开始循环读取数据     for($currentRow = 7;$currentRow<=$allRow;$currentRow++){         //判断每一行的B列是否为有效的序号，如果为空或者小于之前的序号则结束         $xh = (int)$currentSheet->getCell('B'.$currentRow)->getValue();         if(empty($xh))break;                 $tmpType = (string)$currentSheet->getCell('C'.$currentRow)->getValue(); //赛事类型         if(!empty($tmpType))$preType = $tmpType;         $output[$xh]['type'] = $preType;         $output[$xh]['master'] = $currentSheet->getCell('F'.$currentRow)->getValue(); //主队         $output[$xh]['guest'] = $currentSheet->getCell('H'.$currentRow)->getValue(); //客队        }         //从当前行开始往下循环，取出第一个不为空的行     for( ; ; $currentRow++){         $xh = (int)$currentSheet->getCell('B'.$currentRow)->getValue();         if(!empty($xh))break;     }         for( ; $currentRow <= $allRow; $currentRow++){         $xh = (int)$currentSheet->getCell('B'.$currentRow)->getValue();         if(empty($xh))break;                 $output[$xh]['rq'] = $currentSheet->getCell('I'.$currentRow)->getValue();     }     header("content-type:text/html; charset=utf-8");         echo '期号：' . $qh . "＼n＼n";     if(!empty($output)){         printf("%-5s＼t%-15s＼t%-40s＼t%-40s＼t%-5s＼n", '序号', '赛事类型', '主队', '客队', '让球值');         foreach($output as $key => $row){             $format = "%-5d＼t%-15s＼t%-40s＼t%-40s＼t%-5s＼n";             printf($format, $key, $row['type'], $row['master'], $row['guest'], $row['rq']);         }     } ?>

phpexcel导出excel数据

在服务器端生成静态文件

相比直接生成，这两种方法的主要区别是生成格式的不同，模板文件完全相同，下边是一个在上例基础上更改后的样子，注意与上例的区别。
 

代码如下

复制代码

<?php  // 包含class的基本头文件 include("./class/class.php"); // 生成excel的基本类定义(注意文件名的大小写) include("./class/phpexcel/PHPExcel.php"); // 包含写Excel5格式的文件，如果需要生成excel2007的文件，包含对应的Writer即可 include("./class/phpexcel/PHPExcel/Writer/Excel5.php"); // 包含写PDF格式文件 include("./class/phpexcel/PHPExcel/Writer/PDF.php"); // 创建phpexcel对象，此对象包含输出的内容及格式 $m_objPHPExcel = new PHPExcel(); // 模板文件，为了实现格式与内容分离，有关输出文件具体内容实现在模板文件中 // 模板文件将对象$m_objPHPExcel进行操作 include("./include/excel.php"); // 输出文件的类型，excel或pdf $m_exportType = "pdf"; $m_strOutputExcelFileName = date('Y-m-j_H_i_s').".xls"; // 输出EXCEL文件名 $m_strOutputPdfFileName = date('Y-m-j_H_i_s').".pdf"; // 输出PDF文件名 // 输出文件保存路径，此路径必须可写 $m_strOutputPath = "./output/"; // 如果需要输出EXCEL格式 if($m_exportType=="excel"){ $objWriter = new PHPExcel_Writer_Excel5($m_objPHPExcel); $objWriter->save($m_strOutputPath.$m_strOutputExcelFileName);  } // 如果需要输出PDF格式 if($m_exportType=="pdf"){ $objWriter = new PHPExcel_Writer_PDF($m_objPHPExcel); $objWriter->save($m_strOutputPath.$m_strOutputPdfFileName);  } ?>