浅谈PHP值MysqL操作类
rush:PHP;">
/**
-
Created by PhpStorm.
-
User: Administrator
-
Date: 2016/6/27
-
Time: 18:55
*/
Class Mysqls{
private $table; //表
private $opt;
public function __construct($host,$user,$pwd,$name,$table_names)
{
$this->db=new <a href="https://www.jb51.cc/tag/MysqL/" target="_blank" class="keywords">MysqL</a>i($host,$name); //<a href="https://www.jb51.cc/tag/shujuku/" target="_blank" class="keywords">数据库</a>连接
if(<a href="https://www.jb51.cc/tag/MysqL/" target="_blank" class="keywords">MysqL</a>i_connect_errno()){
echo "<a href="https://www.jb51.cc/tag/shujuku/" target="_blank" class="keywords">数据库</a>连接<a href="https://www.jb51.cc/tag/cuowu/" target="_blank" class="keywords">错误</a>".<a href="https://www.jb51.cc/tag/MysqL/" target="_blank" class="keywords">MysqL</a>i_connect_errno();
exit();
}
$this->db->query("set names utf8");
$this->table=$table_names;
$this->opt['field']="*";
$this->opt['where']=$this->opt['Order']=$this->opt['Limit']=$this->opt['Group']='';// var_dump($this->opt['where']);
//$this->M($table_names);}
//数据库连接
// protected function M($table_name){
// $this->db=new MysqLi(DBHOST,DBUSER,DBPWD,dbnAME);
//
// if(MysqLi_connect_errno()){
// echo "数据库连接错误".MysqLi_connect_errno();
// exit();
// }
// $this->db->query("set names utf8");
// $this->table=$table_name;
// }
//表中的字段
public function tbField(){
$desc=$this->db->query("DESC {$this->table}");
$fieldArr=array();
while(($row=$desc->fetch_assoc())!=false){
$fieldArr[]=$row['Field'];
}
// var_dump($fieldArr);
return $fieldArr;}
//查询字段
public function field($filed){
//拆分字段
$filedArr=is_string($filed)?explode(",",$filed):$filed;
if(is_array($filedArr)){
$filed='';
foreach($filedArr as $v){
$filed.="'".$v."'".",";
}
}
//var_dump($filed);
return rtrim($filed,");}
//判断字段是否存在
public function isfield($fileds)
{
$filedArr=is_string($fileds)?explode(",$fileds):$fileds;
$tbFiled=$this->tbField();
//var_dump( $tbFiled);
foreach($filedArr as $v){
if(!in_array($v,$tbFiled)){
echo "字段输入发错";
}
}}
//条件语句
public function where($where){
$this->opt['where']=is_string($where)?" WHERE {$where}":"不是字符串";
return $this;}
//Limit
public function Limit($limit){
$this->opt['Limit']=is_string($limit)?" Limit {$limit}":"不是字符串";
return $this;}
public function Order($order){
$this->opt['Order']=is_string($order)?" Order By {$order}":"不是字符串";
return $this;}
public function Group($group){
$this->opt['Group']=is_string($group)?" Group BY {$group}":"不是字符串";
return $this;}
// 查询字符串
public function select(){
$<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>="select * from {$this->table} {$this->opt['where']} {$this->opt['Group']} {$this->opt['Limit']} {$this->opt['Order']}";
return $this->fetch($<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>);}
//结果集查询
public function fetch($sql){
$result=$this->db->query($<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>);
$<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>arr=array();
while(($row=$result->fetch_assoc())!=false){
$<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>arr[]=$row;
}
// var_dump($<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>arr);
return $<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>arr;}
//无结果集查询
public function querys($sql){
$<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>s=$this->db->query($<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>);
return $this->db->affected_rows;}
//删除语句
public function delete($where=array()){
if($where=="" && empety($this->opt['where'])) die(" 不能为空");
if($where!=""){
if(is_array($where)){
$where=implode(",$where);
}
$this->opt['where']=" WHERE id IN({$where})";
}
$<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>="delete from {$this->table} {$this->opt['where']} {$this->opt['Limit']}";
var_dump($<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>);
//return $this->query($<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>);}
//数组键名
public function key($key){
if(!is_array($key))die("非法数组");
$keys="";
foreach($key as $v){
$keys.=$v.",";
}
return rtrim($keys,");}
//数组值
public function value($value){
if(!is_array($value))die("非法数组");
$strvalue="";
foreach($value as $v){
$strvalue.="'".$v."'".",";
}
return rtrim($strvalue,");}
//添加语句
public function add($filed){
if(!is_array($filed)) die("非法数组");
$fileds=$this->key(array_keys($filed)); //返回数组中的键名
//var_dump($fileds);
$values=$this->value(array_values($filed));
$<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>="insert into {$this->table}({$fileds})VALUES($values)";
//var_dump($<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>);
return $this->querys($<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>);}
//查找单条记录
public function find($field,$id){
$<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>="select {$this->opt['field']} from {$this->table} {$this->where($field.'='."'".$id."'")}";
var_dump($<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>);
return $this->fetch($<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>);}
//更新语句
public function save($arrs){
if(!is_array($arrs))die("非法的数组");
//if(empty($this->opt['where']))die("条件不能为空");
$str="";
while(list($k,$v)=each($arrs))
{
$str="{$k}="."'{$v}',";
}
$str=rtrim($str,");
$<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>="Update {$this->table} set {$str}{$this->opt['where']}";
return $this->querys($<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>);}
//获取总记录数
public function counts(){
$<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>="select 'id' from {$this->table}{$this->opt['where']}";
//var_dump($<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>);
return $this->querys($<a href="https://www.jb51.cc/tag/sql/" target="_blank" class="keywords">sql</a>);}
}
写的一部分有问题 参考了别人一部分。
