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

 "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=&＃39;&＃39;", 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 &＃39;SQL Error&＃39;;
	}
	@self::rollback();
	exit;
}  
/////////////////////////////以下是扩展的sql方法.//////
/* 把数组按照 key value value 的对应关系插入数据表table中
table 要插入的数据表
要注意 这些扩展方法是没自己给表有加前缀的.
*/
static function insert($table,$array){
	$temp="";$temp2=&＃39;&＃39;;
	foreach($array as $key=>$value){
		if(self::$is_type_tight){
			if(is_string($value)){
				$temp .="$key,";$temp2 .="&＃39;$value&＃39;,";
			}elseif(is_int($value||is_null($value)||is_float($value))){
				$value+=0;
				$temp .="$key,";$temp2 .="&＃39;$value&＃39;,";
			}
		}else{
			$temp .="$key,";$temp2 .="&＃39;$value&＃39;,";
		}
	}
	$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=&＃39;$value&＃39;,";
	}
	$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(&＃39;rollback&＃39;);
	}
	/*开始事务*/
	static function begin(){
		self::query(&＃39;SET AUTOCOMMIT =0&＃39;); //停用自动提交;
		self::query(&＃39;BEGIN&＃39;) ;//开始一个事务;
	}
	
	/*提交事务*/
	static function commit(){
		self::query(&＃39;commit&＃39;);
	}


 	static function echoarray($array){
		foreach($array as $k=>$v ){
			if(is_array($v)){
				if(is_array($v)){
					echo "
--------------------------------
";
					self::echoarray($v);
				}
			}else{
				if($k===&＃39;line&＃39;)
				echo "$k -> " .$v."  ";
				else
				echo "$k -> " .$v."  ";
			}
		}
	}

	static function get_server_info(){
		return mysql_get_server_info();
	}
}  

?>

以上就是php编写的mysql 操作类 php5的 的内容，更多相关内容请关注PHP中文网（www.php1.cn）！