本文对应博客地址单元测试没有提供对应的数据库, 请自行设计..
如有不足和需要改进的, 请不吝赐教....库文件: mysql_lib.php<?php
/**
 * author: selfimpr
 * mail: [email protected]
 * blog: http://blog.csdn.net/lgg201
 */#服务器配置信息key
define('DB_CFG_K_HOST', 'host');
define('DB_CFG_K_USERNAME', 'username');
define('DB_CFG_K_PASSWORD', 'password');
define('DB_CFG_K_PORT', 'port');#默认字符集
define('MYSQL_DEFAULT_CHARSET', 'UTF8');#分页SQL拆分相关宏
define('PAGINATE_COUNT_ALIAS', 'count');
define('PAGINATE_COUNT_SQL_PATTERN', '/(?<=(?<!`|\'|")SELECT).*(?=(?<!`|\'|")FROM)/i');
define('PAGINATE_COUNT_SQL_REPLACEMENT', ' count(*) AS ' . PAGINATE_COUNT_ALIAS . ' ');
#分页默认信息
define('PAGINATE_DEFAULT_PAGE', 1);
define('PAGINATE_DEFAULT_PAGESIZE', 10);#分页数据模型key
define('PAGEMODEL_KEY_PAGE_CURRENT', 'page_current');
define('PAGEMODEL_KEY_PAGE_PREV', 'page_prev');
define('PAGEMODEL_KEY_PAGE_NEXT', 'page_next');
define('PAGEMODEL_KEY_PAGE_SIZE', 'page_size');
define('PAGEMODEL_KEY_PAGE_TOTAL', 'page_total');
define('PAGEMODEL_KEY_RECORD_OFFSET', 'record_offset');
define('PAGEMODEL_KEY_RECORD_NUMBER', 'record_number');
define('PAGEMODEL_KEY_RECORD_TOTAL', 'record_total');
define('PAGEMODEL_KEY_DATA', 'data');/**
 * 获取数据库连接
 * @param mixed $cfg  数据库服务器配置, 数组, key为DB_CFG_K_*系列常量
 * @param mixed $dbname  数据库名
 * @param mixed $charset  字符集
 * @return void
 */
function mysql_get_connection($cfg, $dbname = NULL, $charset = MYSQL_DEFAULT_CHARSET) {
$host = $cfg[DB_CFG_K_HOST] . ':' . $cfg[DB_CFG_K_PORT];
$username = $cfg[DB_CFG_K_USERNAME];
$password = $cfg[DB_CFG_K_PASSWORD]; $connection = mysql_connect($host, $username, $password); mysql_switch_db($connection, $dbname);
mysql_switch_charset($connection, $charset); return $connection;
}
/**
 * 释放数据库连接
 * @param mixed $conn  数据库连接对象
 * @return void
 */
function mysql_free_connection($conn) {
if ( is_resource($conn) ) mysql_close($conn);
}
/**
 * 切换数据库
 * @param mixed $conn  数据库连接对象
 * @param mixed $dbname 数据库名
 * @return void
 */
function mysql_switch_db($connection, $dbname) {
if ( $dbname ) mysql_select_db($dbname, $connection);
}
/**
 * 切换字符集
 * @param mixed $conn  数据库连接对象
 * @param mixed $charset  字符集名
 * @return void
 */
function mysql_switch_charset($connection, $charset) {
if ( $charset ) mysql_set_charset($charset, $connection);
}
/**
 * 获取数据库中一行记录
 * @param mixed $conn  数据库连接对象
 * @param mixed $sql  查询语句
 * @return void
 */
function mysql_get_row($conn, $sql) {
$rs = mysql_query($sql, $conn);
$row = mysql_fetch_array($rs);
mysql_free_result($rs);
return $row;
}
/**
 * 获取数据库中多行记录
 * @param mixed $conn  数据库连接对象
 * @param mixed $sql  查询语句
 * @return void
 */
function mysql_get_rows($conn, $sql) {
$rows = array();
$rs = mysql_query($sql, $conn);
while ( $row = mysql_fetch_array($rs) ) $rows[] = $row;
mysql_free_result($rs);
return $rows;
}
/**
 * 向数据库插入数据
 * @param mixed $conn  数据库连接对象
 * @param mixed $sql  INSERT语句
 * @param mixed $id  最后一次插入ID
 * @return void
 */
function mysql_insert($conn, $sql, &$id = NULL) {
mysql_query($sql, $conn);
$id = mysql_insert_id($conn);
return mysql_affected_rows($conn);
}
/**
 * 从数据库删除记录
 * @param mixed $conn  数据库连接对象
 * @param mixed $sql  删除语句
 * @return void
 */
function mysql_delete($conn, $sql) {
mysql_query($sql, $conn);
return mysql_affected_rows($conn);
}
/**
 * 更新数据库记录
 * @param mixed $conn  数据库连接对象
 * @param mixed $sql  更新语句
 * @return void
 */
function mysql_update($conn, $sql) {
mysql_query($sql, $conn);
return mysql_affected_rows($conn);
}
/**
 * 分页查询接口
 * @param mixed $conn  数据库连接对象
 * @param mixed $sql  查询语句
 * @param mixed $page  要获取的当前页码
 * @param mixed $page_size  每页记录数
 * @return $pagemodel 分页模型, 数据, key为PAGEMODEL_KEY_*系列常量
 */
function mysql_paginate($conn, $sql, $page = PAGINATE_DEFAULT_PAGE, $page_size = PAGINATE_DEFAULT_PAGESIZE) {
$count_sql = preg_replace(PAGINATE_COUNT_SQL_PATTERN, PAGINATE_COUNT_SQL_REPLACEMENT, $sql);
$count_ret = mysql_get_row($conn, $count_sql); $record_total = $count_ret[PAGINATE_COUNT_ALIAS];
$page_model = pagemodel_create($page, $page_size, $record_total); $offset = $page_model[PAGEMODEL_KEY_RECORD_OFFSET];
$limit = $page_model[PAGEMODEL_KEY_RECORD_NUMBER];
$fetch_sql = $sql . " limit $offset, $limit"; $fetch_result = mysql_get_rows($conn, $fetch_sql);
pm_d($page_model, $fetch_result);
return $page_model;
}
/**
 * 创建分页模型
 * @param mixed $page_current  当前页码
 * @param mixed $page_size  每页记录数
 * @param mixed $record_total  总记录数
 * @param mixed $data  可选. 数据
 * @return $pagemodel 分页模型, 数据, key为PAGEMODEL_KEY_*系列常量
 */
function pagemodel_create($page_current, $page_size, $record_total, $data = NULL) {
$page_total = ceil($record_total / $page_size);
$page_current = max(1, min($page_current, $page_total));
$page_prev = max(1, $page_current - 1);
$page_next = min($page_total, $page_current + 1);
$record_offset = ($page_current - 1) * $page_size;
$record_number = $page_current == $page_total ? $record_total - $page_size * ($page_total - 1) : $page_size;
return array(
PAGEMODEL_KEY_PAGE_CURRENT => $page_current, 
PAGEMODEL_KEY_PAGE_PREV => $page_prev, 
PAGEMODEL_KEY_PAGE_NEXT => $page_next, 
PAGEMODEL_KEY_PAGE_SIZE => $page_size, 
PAGEMODEL_KEY_PAGE_TOTAL => $page_total, 
PAGEMODEL_KEY_RECORD_OFFSET => $record_offset, 
PAGEMODEL_KEY_RECORD_NUMBER => $record_number, 
PAGEMODEL_KEY_RECORD_TOTAL => $record_total, 
PAGEMODEL_KEY_DATA => $data, 
);
}
/**
 * 读取/设置分页模型中的当前页码
 * @param mixed $pagemodel  分页模型
 * @param mixed $page_current  可选. 如果传本参数, 则修改当前页码
 * @return void 当前页码
 */
function pm_pc(&$pagemodel, $page_current = NULL) {
if ( isset($page_current) ) $pagemodel[PAGEMODEL_KEY_PAGE_CURRENT] = $page_current;
return $pagemodel[PAGEMODEL_KEY_PAGE_CURRENT];
}
/**
 * 读取/设置分页模型中的前一页页码
 * @param mixed $pagemodel  分页模型
 * @param mixed $page_prev  可选. 如果传本参数, 则修改前一页页码
 * @return void 前一页页码
 */
function pm_pp(&$pagemodel, $page_prev = NULL) {
if ( isset($page_prev) ) $pagemodel[PAGEMODEL_KEY_PAGE_PREV] = $page_prev;
return $pagemodel[PAGEMODEL_KEY_PAGE_PREV];
}
/**
 * 读取/设置分页模型中后一页页码
 * @param mixed $pagemodel  分页模型
 * @param mixed $page_next  可选. 如果传本参数, 则修改后一页页码
 * @return void 后一页页码
 */
function pm_pn(&$pagemodel, $page_next = NULL) {
if ( isset($page_next) ) $pagemodel[PAGEMODEL_KEY_PAGE_NEXT] = $page_next;
return $pagemodel[PAGEMODEL_KEY_PAGE_NEXT];
}
/**
 * 获取/设置分页模型中每页记录数
 * @param mixed $pagemodel  分页模型
 * @param mixed $page_size  可选. 如果传本参数, 则修改每页记录数
 * @return void 每页记录数
 */
function pm_ps(&$pagemodel, $page_size = NULL) {
if ( isset($page_size) ) $pagemodel[PAGEMODEL_KEY_PAGE_SIZE] = $page_size;
return $pagemodel[PAGEMODEL_KEY_PAGE_SIZE];
}
/**
 * 获取/设置分页模型中总页数
 * @param mixed $pagemodel  分页模型
 * @param mixed $page_total  可选. 如果传本参数, 则修改总页数
 * @return void 总页数
 */
function pm_pt(&$pagemodel, $page_total = NULL) {
if ( isset($page_total) ) $pagemodel[PAGEMODEL_KEY_PAGE_TOTAL] = $page_total;
return $pagemodel[PAGEMODEL_KEY_PAGE_TOTAL];
}
/**
 * 获取/设置分页模型中的本页开始记录偏移量
 * @param mixed $pagemodel  分页模型
 * @param mixed $record_offset  可选. 如果传本参数, 则修改本页开始记录偏移量
 * @return void 本页开始记录偏移量
 */
function pm_ro(&$pagemodel, $record_offset = NULL) {
if ( isset($record_offset) ) $pagemodel[PAGEMODEL_KEY_RECORD_OFFSET] = $record_offset;
return $pagemodel[PAGEMODEL_KEY_RECORD_OFFSET];
}
/**
 * 获取/设置分页模型中本页记录数
 * @param mixed $pagemodel  分页模型
 * @param mixed $record_number  可选. 如果传本参数, 则修改本页记录数
 * @return void 本页记录数
 */
function pm_rn(&$pagemodel, $record_number = NULL) {
if ( isset($record_number) ) $pagemodel[PAGEMODEL_KEY_RECORD_NUMBER] = $record_number;
return $pagemodel[PAGEMODEL_KEY_RECORD_NUMBER];
}
/**
 * 获取/设置分页模型中总记录数
 * @param mixed $pagemodel  分页模型
 * @param mixed $record_total  可选. 如果传本参数, 则修改总记录数
 * @return void 总记录数
 */
function pm_rt(&$pagemodel, $record_total = NULL) {
if ( isset($record_total) ) $pagemodel[PAGEMODEL_KEY_RECORD_TOTAL] = $record_total;
return $pagemodel[PAGEMODEL_KEY_RECORD_TOTAL];
}
/**
 * 获取/设置分页模型中的数据
 * @param mixed $pagemodel  分页模型
 * @param mixed $data  可选. 如果传本参数, 则修改数据
 * @return void 数据
 */
function pm_d(&$pagemodel, $data = NULL) {
if ( isset($data) ) $pagemodel[PAGEMODEL_KEY_DATA] = $data;
return $pagemodel[PAGEMODEL_KEY_DATA];
}
单元测试: mysql_lib.test.php
<?php
/**
 * author: selfimpr
 * mail: [email protected]
 * blog: http://blog.csdn.net/lgg201
 */
require_once dirname(__FILE__) . '/mysql_lib.php';$mysql_cfg = array(
DB_CFG_K_HOST => '', 
DB_CFG_K_USERNAME => '', 
DB_CFG_K_PASSWORD => '', 
DB_CFG_K_PORT => '', 
);
function pm_print($pagemodel) {
printf("page_first: 1, page_prev: %d, page_current: %d, page_next: %d, page_last: %d, record: %d-%d(%d of %d)\n", 
pm_pp($pagemodel), pm_pc($pagemodel), pm_pn($pagemodel), pm_pt($pagemodel), pm_ro($pagemodel) + 1, pm_ro($pagemodel) + pm_rn($pagemodel), pm_rn($pagemodel), pm_rt($pagemodel));
}define('DB_NAME_EXAMPLE', 'example');$conn = mysql_get_connection($mysql_cfg, DB_NAME_EXAMPLE);$ret = mysql_paginate($conn, 'SELECT * FROM example WHERE id > 100 order by id desc', $argv[1], $argv[2]);pm_print($ret);

解决方案 »

  1.   


    子查询个人感觉没有问题, 因为我的理解是: 分页中获取记录数的sql我们只是将select的项换成count(*)就OK的
    不过, 目前的情况, 是有一些瑕疵和可优化空间的, 我已知的有:
    1. 对于查询语句中的ORDER BY等子句, 可以在获取记录数的sql中也给截掉, 用于优化速度
    2. 查询语句中已经有limit的情况, 这个是一个功能性增强..
      

  2.   

    对, 子查询应该会有问题, 默认贪婪可能导致from过界...
    刚想到还有一个问题, 这个要靠正则解决可能就太过复杂了, 例如下面语句
    SELECT concat(a.`t_from_k`, 'select * from a') FROM xxx;
      

  3.   

    我倒没想,字段拼接里的关键字,这个有点狠像这种还是常见的,贪婪会出错不过正则么,本来就是适用就行select * FROM (SELECT * FROM table_name) t
      

  4.   

    我不想一一剖析你的代码,只提几点建议
    1、你封装的是分立函数而不是类,这种封装并无必要,而且效率显然要比原生函数来的低
    2、分页的核心有二:
    1)查询的SQL串的创建与保存(动态查询时尤为必要),在你的代码中没有体现
    2)查询结果子集的产生,或是说 limit 参数的生成。在你的代码中虽有体现,但不明显
    如果是不支持 limit 子句的数据库,就没有解决方案了。当然这是题外话
    3、php 的 mysql 数据库操作中,默认只有一个连接。虽然可以强制创建多个连接,但这些连接间是不能沟通的。也就是说,你不可能在一个 mysql 指令中同时出现一个以上数据库连接中的库与表
    垮库操作的条件是被操作的库在同一 mysql 服务器中,且权限一致
    因此你的 
    mysql_switch_db($connection, $dbname) 
    mysql_switch_charset($connection, $charset) 
    显然是多余的
      

  5.   

    1. 你封装的是分立函数而不是类,这种封装并无必要,而且效率显然要比原生函数来的低
    答: 我们这边项目主要是过程化构建的, 就目前来看, 这种封装是有好处的..主要是一种接口规范, 具体实现可以灵活替换
    2.2 这个小工具目的就在于mysql, 所以不考虑其他, 如果考虑其他, 如果做成ORM, 无论从结构的复杂程度和性能上, 都不符合我们项目..
    3. 关于mysql_switch_db和mysql_switch_charset是有用途的, 因为在一个业务中如果想要操作两个数据库, 并且有可能两个库字符集不一致时, 我们需要有一个方便的接口取修改, 而不是调用get_connection, 虽然从计算机的角度理解行为是一致的, 但是, 对于coder来说, 这样的代码更容易理解, 可维护性更高..请唠叨哥多赐教..
      

  6.   

    曾经雄心勃勃的想抽象     “SQL串的创建与保存”,增删查修一天都没搞定,最后灰头土脸,可耻的放弃了那半成品能解决大部分问题,一直在用着