iLeichun

当前位置: 首页 > 个人日志

PHP数据库操作类

分类:个人日志   来源:原创   时间:2011-01-20 23:25:11

<?php

/**
 *
 * @name 数据库管理类
 * @author lession
 *
 */

class Database{

 var $host=¹localhost¹; //数据库地址
 var $database=¹mydb¹;   //数据库名称
 var $user=¹root¹;   //用户名
 var $password=¹mysql¹;   //密码

 /**
  * @name 构造函数
  */
  function Database(){

 }

 

 /**
  * @name 1.连接数据库
  * @return $conn
  */
  function connect(){
  $conn=mysql_connect($this->host,$this->user,$this->password) or die("<script>alert(¹数据库连接出错!¹);</script>");
  return $conn;
 }

 

 /**
  * @name 选择数据库
  * @param $conn
  * @return $result
  */
  function selectDb($conn){
  if($conn)
    $result=mysql_select_db($this->database) or die("<script>alert(¹数据库选择出错!¹);</script>");
  return $result;
 }

 

 /**
  * @name 数据添加
  * @param $table
  * @param $field
  * @param $value
  * @param $url
  * @return $result
  */
  function add($table,$field,$value,$url){
  $msg1="添加成功!";
  $msg2="添加失败!";
  $conn=$this->connect();
  $this->selectDb($conn);
  mysql_query("set names ¹utf8¹");

  $field=implode(",",$field);
  $value=implode(",",$value);
  $sql="insert into $table($field) values($value)";

  $result = mysql_query($sql) or die("<script>alert(¹新增数据出错!¹);</script>");
  $this->result($result,$msg1,$msg2,$url);
  $this->close($conn);
  return $result;
 }

 

 /**
  * @name 数据查询
  * @param $sql
  * @return $result
  */
  function select($sql){
  $conn=$this->connect();
  $this->selectDb($conn);
  mysql_query("set names ¹utf8¹");
//  echo $sql;
  $result=mysql_query($sql) or die("<script>alert(¹查询数据出错!¹);</script>");
  $this->close($conn);
  return $result;
 }

 

 /**
  * @name 数据修改1(显示修改结果)
  * @param $table
  * @param $field
  * @param $value
  * @param $id
  * @param $url
  * @return $result
  */
  function update($table,$condition,$id,$url){
  $msg1="修改成功!";
  $msg2="修改失败!";
  $conn=$this->connect();
  $this->selectDb($conn);
  mysql_query("set names ¹utf8¹");

  $condition=implode(",",$condition);
  $sql="update $table set $condition where id=$id";

  $result = mysql_query($sql) or die("<script>alert(¹修改数据出错!¹);</script>");
  $this->result($result,$msg1,$msg2,$url);
  $this->close($conn);
  return $result;
 }

 

 /**
  * @name 数据修改2(不显示修改结果)
  * @param $table
  * @param $field
  * @param $value
  * @param $id
  * @param $url
  */
  function update2($table,$condition,$id){
  $conn=$this->connect();
  $this->selectDb($conn);
  mysql_query("set names ¹utf8¹");

  $condition=implode(",",$condition);
  $sql="update $table set $condition where id=$id";

  $result = mysql_query($sql) or die("<script>alert(¹修改数据出错!¹);</script>");
  $this->close($conn);
  return $result;
 }

 

 /**
  * @name 数据删除
  * @param $table
  * @param $id
  * @param $url
  * @return $result
  */
  function del($table,$id,$url){
  $msg1="删除成功!";
  $msg2="删除失败!";
  $conn=$this->connect();
  $this->selectDb($conn);
  mysql_query("set names ¹utf8¹");

  $sql="delete from $table where id=$id";

  $result = mysql_query($sql) or die("<script>alert(¹删除数据出错!¹);</script>");
  $this->result($result,$msg1,$msg2,$url);
  $this->close($conn);
  return $result;
 }

 

 /**
  * @name 获取记录总数
  * @param $result
  * @return $count
  */
  function rows($result){
  $count=mysql_num_rows($result);
  return $count;
 }

 

 /**
  * @name 获取数据记录
  * @param $result
  * @return $fetch
  */
  function fetch($result){
  $fetch=mysql_fetch_array($result);
  return $fetch;
 }

 

 /**
  * @name 显示数据库操作结果
  * @param $result
  * @param $msg1
  * @param $msg2
  * @param $url
  */
  function result($result,$msg1,$msg2,$url){
  if($result>0)
     echo "<script>window.alert(¹$msg1¹);window.location.href=¹$url¹;</script>";
  else
     echo "<script>window.alert(¹$msg2¹);window.history.back();</script>";
 }

 

 /**
  * @name 关闭数据库连接
  * @param $conn
  */
  function close($conn){
  mysql_close($conn) or die("<script>alert(¹关闭数据库连接出错!¹);</script>");
 }

}

?>

更多