mysql操作类,v0.2,增加应对大数据量的一些解决方案 -PHP-Tutorial-php.cn

/*mysql 简单类 by joffe q89949401 围脖@狂code诗人; 本类全静态使用的时候直接include后用mysql::方法()名即可由于类在php5里面全局可视,所以不必担心变量范围的问题.如果有什么意见请围脖私信||qq邮件; 目前没有与存储过程有关的方法,当然存储过程一般是创建数据库的时候做的. config文件需要配置以下常量信息: LIB:类存放位置 DEBUG:是否开启debug(如果开启会输出错误信息跟踪) TB_EX:数据库表前缀;

增加了select del update insert big_select big_del函数

*/

/*mysql 简单类 by joffe q89949401 围脖@狂code诗人;
本类全静态使用的时候直接include后用mysql::方法()名即可由于类在php5里面全局可视,所以不必担心变量范围的问题.如果有什么意见请围脖私信||qq邮件;
目前没有与存储过程有关的方法,当然存储过程一般是创建数据库的时候做的.
config文件需要配置以下常量信息:
LIB:类存放位置
DEBUG:是否开启debug(如果开启会输出错误信息跟踪)
TB_EX:数据库表前缀;
*/
defined('LIB') or die('Missing config!!');
final class mysql {
/**
* 查询总次数
*
* @var int
*/
public static $querynum = 0;
/**
* 连接句柄
*
* @var object
*/
public static $link;
/*
表前缀
@var string 下面方法需要在配置文件中配置TB_EX 作为表的前缀
*/
static function add_ex($tb){
return TB_EX.$tb_ex.$tb;
}
/*mysql数据库是否使用严格的类型(mysql类型没开启自动转换)默认为false,表示mysql有开启类型转换,这个变量目前只要是用于insert函数的单引号在没有自动转换的mysql里面的问题,可能将来会增加相关函数
*/
public static $is_type_tight=false;
/**
* 构造函数
*
* @param string $dbhost 主机名
* @param string $dbuser 用户
* @param string $dbpw 密码
* @param string $dbname 数据库名
* @param int $pconnect 是否持续连接
*/
static function connent($dbhost, $dbuser, $dbpw, $dbname = "",$dbcharset, $pconnect = 0) {
if($pconnect) {
if(!self::$link = @mysql_pconnect($dbhost, $dbuser, $dbpw)) {
self::halt("Can not connect to MySQL server");
}
} else {
if(!self::$link = @mysql_connect($dbhost, $dbuser, $dbpw)) {
self::halt("Can not connect to MySQL server");
}
}
if(self::version() > "4.1") {
if($dbcharset) {
mysql_query("SET character_set_connection={$dbcharset}, character_set_results=$dbcharset, character_set_client=binary", self::$link);
}
if(self::version() > "5.0.1") {
mysql_query("SET sql_mode=''", self::$link);
}
}
if($dbname) {
mysql_select_db($dbname, self::$link);
}
}
/**
* 选择数据库
*
* @param string $dbname
* @return
*/
static function select_db($dbname) {
return mysql_select_db($dbname, self::$link);
}
/**
* 取出结果集中一条记录
*
* @param object $query
* @param int $result_type
* @return array
*/
static function fetch_array($query, $result_type = MYSQL_ASSOC) { //默认只取关联数组不取数字数组.
return mysql_fetch_array($query, $result_type);
}
/**
* 查询SQL
*
* @param string $sql
* @param string $type
* @return object
*/
static function query($sql, $type = "") {
$func = $type == "UNBUFFERED" && @function_exists("mysql_unbuffered_query") ?
"mysql_unbuffered_query" : "mysql_query";
if(!($query = $func($sql, self::$link)) && $type != "SILENT") {
self::halt("MySQL Query Error", $sql);
}
self::$querynum++;
return $query;
}
/**
* 取影响条数
*
* @return int
*/
static function affected_rows() {
return mysql_affected_rows(self::$link);
}
/**
* 返回错误信息
*
* @return array
*/
static function error() {
return ((self::$link) ? mysql_error(self::$link) : mysql_error());
}
/**
* 返回错误代码
*
* @return int
*/
static function errno() {
return intval((self::$link) ? mysql_errno(self::$link) : mysql_errno());
}
/**
* 返回查询结果
*
* @param object $query
* @param string $row
* @return mixed
*/
static function result($query, $row,$flname=0) {
$query = @mysql_result($query, $row,$flname);
return $query;
}
/**
* 结果条数
*
* @param object $query
* @return int
*/
static function num_rows($query) {
$query = mysql_num_rows($query);
return $query;
}
/**
* 取字段总数
*
* @param object $query
* @return int
*/
static function num_fields($query) {
return mysql_num_fields($query);
}
/**
* 释放结果集
*
* @param object $query
* @return bool
*/
static function free_result($query) {
return @mysql_free_result($query);
}
/**
* 返回自增ID
*
* @return int
*/
static function insert_id() {
return ($id = mysql_insert_id(self::$link)) >= 0 ? $id : self::$result(self::$query("SELECT last_insert_id()"), 0);
}
/**
* 从结果集中取得一行作为枚举数组
*
* @param object $query
* @return array
*/
static function fetch_row($query) {
$query = mysql_fetch_row($query);
return $query;
}
/**
* 从结果集中取得列信息并作为对象返回
*
* @param object $query
* @return object
*/
static function fetch_fields($query) {
return mysql_fetch_field($query);
}
static function select_affectedt_rows($rs){
return mysql_affected_rows($rs,self::$link);
}
/**
* 返回mysql版本
*
* @return string
*/
static function version() {
return mysql_get_server_info(self::$link);
}
/**
* 关闭连接
*
* @return bool
*/
static function close() {
return mysql_close(self::$link);
}
/**
* 输出错误信息
*
* @param string $message
* @param string $sql
*/
static function halt($message = "", $sql = "") {
@header("Content-type: text/html; charset=utf-8");
if (DEBUG==1){
$debug = debug_backtrace();
echo $message . "\r\n
SQL--> " . $sql."\r\n
ERROR_MESSAGE-->".self::error().
"\r\n
--------------debug--------------\r\n
";
self::echoarray($debug);
echo "\r\n
-------------debug end----------------";
}else{
echo 'SQL Error';
}
@self::rollback();
exit;
}
/////////////////////////////以下是扩展的sql方法.//////
/* 把数组按照 key value value 的对应关系插入数据表table中
table 要插入的数据表
要注意这些扩展方法是没自己给表有加前缀的.
*/
static function insert($table,$array){
$temp="";$temp2='';
foreach($array as $key=>$value){
if(self::$is_type_tight){
if(is_string($value)){
$temp .="$key,";$temp2 .="'$value',";
}elseif(is_int($value||is_null($value)||is_float($value))){
$value+=0;
$temp .="$key,";$temp2 .="'$value',";
}
}else{
$temp .="$key,";$temp2 .="'$value',";
}
}
$temp = substr($temp,0,strlen($temp)-1);
$temp2 = substr($temp2,0,strlen($temp2)-1);
$sql = "INSERT INTO $table ($temp) VALUE($temp2)";
return self::query($sql);
}
static function del($table,$where){
$sql = "DELETE FROM {$table} where {$where}";
return self::query($sql);
}
static function update($table,$array,$where){
foreach ($array as $key=>$value){
$temp .= "$key='$value',";
}
$temp = substr($temp,0,strlen($temp)-1);
$sql = "update {$table} set ($temp) where {$where} ";
return self::query($sql);
}
/*进行数据库查询select 参数不定
参数说明:所有参数必须是string
第一个参数必须是表名;
从第二个参数起,
如果是写上 "where:XXX" 则认为是where条件;
如果写上 "xxx" 则认为是键值
如果写上 "by:XXX" 则认为是排序
如果写上 "limit:xxx,xxx" 则认为是分页
#参数不正确则返回false; 成功查询返回查询后的数组;
*/
static function select(){
$numargs = func_num_args();//获取参数个数;
$where = "";$key="";$limit="";$by="";
if($numargs==0){return false;}
//echo $numargs;
if($numargs>=2){
$arg_list = func_get_args();
$table = $arg_list[0];
unset($arg_list[0]);
// print_r($arg_list);
foreach($arg_list as $k=>$value){
if(preg_match("#^(where:)\w#",$value)){
$temp = explode(":",$value);
$where = "WHERE {$temp[1]} " ;
}elseif(preg_match("#^by:\w#",$value)){
$temp = explode(":",$value);
$by = "order by {$temp[1]}" ;
}elseif(preg_match("#^limit:\w#",$value)){
$temp = explode(":",$value);
$limit = "limit {$temp[1]}";
}else{
$key .= "$value,";
}
}
if($key==""){
$key = "*";
}else{
$key =substr($key,0,strlen($key)-1);
}
$sql_base="SELECT $key FROM $table";
}
if(!empty($where)){
$sql_base .= " $where";
}
if(!empty($by)){
$sql_base .= " $by";
}
if(!empty($limit)){
$sql_base .= " $limit";
}
//echo $sql_base;
//echo $by ;
$rs = self::query($sql_base);
$re=array();
if(self::num_rows($rs)>=1){
while($info = self::fetch_array($rs)){
$re[]=$info;
}
}
self::free_result($rs);
return $re;
}
/*回滚事务*/
static function rollback(){
self::query('rollback');
}
/*开始事务*/
static function begin(){
self::query('SET AUTOCOMMIT =0'); //停用自动提交;
self::query('BEGIN') ;//开始一个事务;
}
/*提交事务*/
static function commit(){
self::query('commit');
}
static function echoarray($array){
foreach($array as $k=>$v ){
if(is_array($v)){
if(is_array($v)){
echo "
--------------------------------
";
self::echoarray($v);
}
}else{
if($k==='line')
echo "$k -> " .$v." ";
else
echo "$k -> " .$v." ";
}
}
}
function get_server_info(){
return mysql_get_server_info();
}
//下面是应付大数据的表的优化查询
/*
big_select 适合用于大规模的查询,利用覆盖索引实现大幅度的偏移活动窗口,令查询在覆盖索引上偏移而不是在所有数据上,减少msql在数据上检查,再把其他数据join进来这样更效率.但对于小规模数据,这种查询反而增加复杂度,增加优化器压力.说个例子,如果你是limit 10000,20;mysql会先查出10020条数据再丢弃10000 这种操作代价非常大,利用这个函数可以有效提升效率,但如果是 limit 20,那就会稍微比直接select 慢了一些
@table string要查询的表如"table1"
@keys string 要查询的键值,多个键值用","分割如"key1,key2,key3"结束不含","尽量少用"*"且一些关键词请加上`;
@Index string主索引键或者唯一索引键名,只需要一个如"id";
@pagesize int 分页大小,必须,你不会想这么多数据全部出来吧
@pageNo 页码,从0开始
@orderby string 排序如"id desc";可空,但不建议空
@where string 条件如 "date>122424533"可空
#返回数组
*/
static function big_select($table,$keys,$index,$pagesize,$pageNo,$orderby=NULL,$where=NULL){
$start=$pageNo*$pagesize;
if($where){
$sqlIndex="SELEECT {$index} from {$table} where {$where}";
}else{
$sqlIndex="SELEECT {$index} from {$table}";
}
if($orderby){
$sqlIndex .=" ORDER BY {$orderby} Limit $start,$pagesize";
}else{
$sqlIndex .=" ORDER BY Limit $start,$pagesize";
}
$sql = "SELECT $keys FROM {$table} INNER JOIN({$sqlIndex}) AS lim USING({$index})";
$rs = self::query($sql);
$re=array();
if(self::num_rows($rs)>=1){
while($info = self::fetch_array($rs)){
$re[]=$info;
}
}
self::free_result($rs);
return $re;
}
/* 如果一个很大的数据(预计大于万行)删除它的工作周期会比较长,会长时间锁住不应该锁住的表或行,令一些不该打断的数据被打断以下方法是把一个大的sql任务分小(分为一次5000行)但次操作可能会造成删除空隙期间插入了新的数据,而新的数据可能因满足条件而被删除.本方法容易因为超时而失败.
@table string 要删除数据的表名
@where string 条件可省略
#int 删除掉的行数
*/
static function big_del($table,$where){
set_time_limit(0);
$sql="delete from {$table} where {$where} Limit 5000";
$rows = 0;
$eff=0;
do{
self::query($sql);
$rows=self::affected_rows();
$eff += $rows;
}while($rows>0);
return $eff;
}
}
?>

复制代码