PHP头条
热点:

php编写的mysql操作类php5的-PHP源码


php编写的mysql 操作类 php5的

 "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." "; } } } static function get_server_info(){ return mysql_get_server_info(); } } ?>

以上就是php编写的mysql 操作类 php5的 的内容,更多相关内容请关注PHP中文网(www.php1.cn)!

www.phpzy.comtrue/php/34597.htmlTechArticlephp编写的mysql操作类php5的-PHP源码 php编写的mysql 操作类 php5的 "4.1") { if($dbcharset) { mysql_query("SET character_set_connection={$dbcharset}, character_set_results=$dbcharset, character_set_client=binary", self::$link);...

相关文章

PHP之友评论

今天推荐