php封装一个class类,实现mysql数据库的增删改查怎么操做?

发布网友 发布时间：2022-04-25 15:42

我来回答

共3个回答

懂视网 时间：2022-04-29 10:26

php增删改查封装

首先创建一个名为“DB”的类；然后在“DB”类的构造方法中去连接数据库；再根据连接实例进行编写增删改查操作；最后将“DB”类进行实例化并设置为全局变量即可。

封装代码：

<?php
/**
 * 数据库配置信息
 */
define('DB_HOST','127.0.0.1');  //服务器
define('DB_USER','root');   //数据库用户名
define('DB_PASSWORD','123456');  //数据库密码
define('DB_NAME','TEST');   //默认数据库
define('DB_CHARSET','utf8');  //数据库字符集
define('TIMEZONE',"PRC");   //时区设置
date_default_timezone_set(TIMEZONE);
/**
 * 类名：DB
 * 说明：数据库操作类
 */
class DB
{
 public $host;  //服务器

 public $conn;  //数据库连接变量
 /**
 * DB类构造函数
 */
 public function DB($host=DB_HOST ,$username=DB_USER,$password=DB_PASSWORD,$db_name=DB_NAME)
 {
 $this->host = $host;
 $this->username = $username;
 $this->password = $password;
 $this->db_name = $db_name;

 $this->conn = mysql_connect($host,$username,$password) or die ('数据库连接失败！错误原因：'.mysql_error());

 mysql_select_db($db_name)or die('数据库选定失败！错误原因：'.mysql_error());
 
 mysql_query("SET CHARACTER SET utf8");
 }

 /**
 * 关闭数据连接
 */
 public function close()
 {
 mysql_close($this->conn);
 }

 /**
 * @description调用方法用
 * @param $sql
 * @return array
 */
 public function QueryAll($sql)
 {
 $this->open();
 $rs = mysql_query($sql,$this->conn);
 $objList = array();
 while($obj = mysql_fetch_object($rs))
 {
  if($obj)
  {
  $objList[] = $obj;
  }
 }
 $this->close();
 return $objList;
 }
 /**
 * description查询全部返回Json格式，通讯用
 * @param $sql
 * @return string
 */
 public function QueryAllJson($sql)
 {
 echo $sql;
 $this->open();
 $rs = mysql_query($sql,$this->conn);
 $objList = array();
 $i=0;
 while($obj = mysql_fetch_object($rs))
 {
  $objList[$i]=$obj;
  $i++;
 }
 $this->close();
 return json_encode(array("result"=>"success",'data'=>$objList));
 }
 /**
 * @description 插入数据到数据库中
 * @param $tableName 表名
 * @param array $columns 包含表中所有字段名的数组。默认空数组，则是全部有序字段名
 * @param array $values 包含对应所有字段的属性值的数组
 * @return int
 */
 public function insertData($tableName,$columns=array(),$values=array())
 {
 $sql = 'insert into '.$tableName .'( ';
 for($i = 0; $i < sizeof($columns);$i ++)
 {
  $sql .= $columns[$i];
  if($i < sizeof($columns) - 1)
  {
  $sql .= ',';
  }
 }
 $sql .= ') values ( ';
 for($i = 0; $i < sizeof($values);$i ++)
 {
  $sql .= "'".$values[$i]."'";
  if($i < sizeof($values) - 1)
  {
  $sql .= ',';
  }
 }
 $sql .= ' )';
 $this->open();
 mysql_query($sql,$this->conn);
 return true;
// $id = mysql_insert_id($this->conn);//取得上一步操作产生的ID(2)
// $this->close();(2)
// return $id;//(2)
 }
 /**
 * 通过表中的某一属性获取数据
 */
 public function getDataByAtr($tableName,$atrName,$atrValue){
 @$data = $this->QueryAll("SELECT * FROM ".$tableName." WHERE $atrName = '$atrValue'");
 if(count($data)!=0)return $data;
 return NULL;
 }
 /**
 * description_
 * 通过表中的"id"，删除记录
 */
 public function delete($tableName,$atrName,$atrValue){
 echo $tableName;
 $this->open();
 $deleteResult = false;
 if(mysql_query("DELETE FROM ".$tableName." WHERE $atrName = '$atrValue'")) $deleteResult = true;
 $this->close();
 if($deleteResult) return true;
 else return false;
 }
 /**
 * 更新表中的属性值
 */
 public function updateParamById($tableName,$atrName,$atrValue,$key,$value){
 $db = new DB();
 $db->open();
 if(mysql_query("UPDATE ".$tableName." SET $key = '$value' WHERE $atrName = '$atrValue' ")){ //$key不要单引号
  $db->close();
  return true;
 }
 else{
  $db->close();
  return false;
 }
 }
 /*
 * @description: 取得一个table的所有属性名
 * @param: $tbName 表名
 * @return：字符串数组
 */
 public function fieldName($tableName){
 $resultName=array();
 $i=0;
 $this->open();
 $result = mysql_query("SELECT * FROM ".$tableName);
 while ($property = mysql_fetch_field($result)){
  $resultName[$i++]=$property->name;
 }
 $this->close();
 return $resultName;
 }

}

推荐教程：《PHP教程》

热心网友 时间：2022-04-29 07:34

class sqlHelper{
public $conn;
public $dbname="数据库名称";
public $username="数据库用户名";
public $password="数据库密码";
public $host="localhost";
//连接数据库
public function __construct(){
$this->conn=mysql_connect($this->host,$this->username,$this->password);
if(!$this->conn){
die("连接失败".mysql_error());
}
mysql_select_db($this->dbname,$this->conn);
}
//执行查询语句
public function execute_dql($sql){
$res=mysql_query($sql,$this->conn);
return $res;
}
//执行增填改语句
public function execute_dml($sql){
$b=mysql_query($sql,$this->conn);
if(!$b){
return 3;
}else{
if(mysql_affected_rows($this->conn)){
return 1;//表示OK
}else{
return 2;//表示没有行收到影响
}
}
}
}

热心网友 时间：2022-04-29 08:52

class
sqlHelper{
public
$conn;
public
$dbname="数据库名称";
public
$username="数据库用户名";
public
$password="数据库密码";
public
$host="localhost";
//连接数据库
public
function
__construct(){
$this->conn=mysql_connect($this->host,$this->username,$this->password);
if(!$this->conn){
die("连接失败".mysql_error());
}
mysql_select_db($this->dbname,$this->conn);
}
//执行查询语句
public
function
execute_dql($sql){
$res=mysql_query($sql,$this->conn);
return
$res;
}
//执行增填改语句
public
function
execute_dml($sql){
$b=mysql_query($sql,$this->conn);
if(!$b){
return
3;
}else{
if(mysql_affected_rows($this->conn)){
return
1;//表示OK
}else{
return
2;//表示没有行收到影响
}
}
}
}