php 操作数据类库 模拟Thinkphp操作方法实现

Posted 2022-12-16 哈尔滨洛弘科技有限公司

请在php>=5.6版本使用

类库 支持方法

类库支持链式操作，和thinkphp Db操作类类似

使用方法

1. 第一步在入口文件引入数据配置信息
2. Db::name(‘指定表’)切入指定表

where方法解读（where，whereIn，whereLike）

支持 在where里直接写入 mysql where条件,支持数组查询比如[‘id’=>1]
whereIn (‘字段’,‘in的内容’) 支持 数组和字符串
whereLike(‘字段’,‘%like内容%’)

可支持操作

field order limit group update insert delete count和thinkphp使用一致

数据库分页方法(paginate)

参数 1 每页显示数量 2接收请求的page字段

代码引入

Db.php

/**
 * Class Db
 * @package Db
 * @author Mr.taochuang <[e-mail]>
 * @date 2022/6/1 11:35
 * 数据库类
 *
* @method \\taochuang\\DbQuery name($table) static 操作表
 *
 */
class Db

    private static $connect = [
        'hostname' => '172.17.0.7',
        // 数据库名
        'database' => 'u1001349',
        // 用户名
        'username' => 'sql_sfzd',
        // 密码
        'password' => '!@#sfsdfsd739u^',
        // 端口
        'hostport' => '3306',
        //字符集
        'charset' => 'utf8mb4'
    ];
    public static function __callstatic($name, $arguments)
    
        $connect = self::$connect;
        //链接数据库并且加载DbQuery类 执行数据库操作
        return (new \\ReflectionClass(DbQuery::class))->newInstanceArgs([new \\PDO("mysql:host=$connect['hostname'];dbname=$connect['database'];charset=$connect['charset']", $connect['username'], $connect['password'])])->$name($arguments[0]);
    

DbQuery.php

/**
 * Class DbQuery
 * @package DbQuery
 * @author Mr.taochuang <[e-mail]>
 * @date 2022/6/1 11:35
 * 数据库执行类
 *
 * @method \\taochuang\\DbQuery name($table) table
 * @method \\taochuang\\DbQuery limit($limit) limit
 * @method \\taochuang\\DbQuery field($where) field
 * @method \\taochuang\\DbQuery where($where) where
 * @method \\taochuang\\DbQuery order($where) order
 * @method \\taochuang\\DbQuery group($where) group
 */
class DbQuery

    /**
     * @var \\PDO
     */
    public $query;
    public $name = '';
    public $field = '';
    public $order= '';
    public $group='';
    public $where = [];
    public $limit = 0;
    public $page_num=15;
    public $page=1;
    public $is_empty = 1;
    public $error;

    public function __construct($query)
    
        $this->query = $query;
    

    public function queryWhere($where)
    
        array_push($this->where, $where);
        return $this;
    

    public function __call($name, $arguments)
    
        $fnc = 'query' . ucwords($name);
        if (method_exists($this, $fnc)) $this->$fnc($arguments);
        $this->$name = $arguments[0];
        return $this;
    
    public function whereIn($field,$storm)
        if(is_array($storm)) $storm=implode(',',$storm);
        $this->where[$field]=' in ('.$storm.')';
        return $this;
    
    public function whereLike($field,$storm)
        $this->where[$field]=' like "'.$storm.'"';
        return $this;
    
    public function select()
    
        $this->query = $this->query->prepare($this->querySql(__FUNCTION__));
        return $this->fetch();
    
    public function insert($data)
        if(empty($data)) exit('请输入数据');
        $query=$this->query;
        $sql=$this->querySql(__FUNCTION__,$data);
        $this->query = $this->query->prepare($sql);
        $this->query->execute();
        $this->error=$this->query->errorInfo();
        return $query->lastInsertId();
    
    public function update($data)
        if(empty($data)) exit('请输入数据');
        $this->query = $this->query->prepare($this->querySql(__FUNCTION__,$data));
        $res=$this->query->execute();
        $this->error=$this->query->errorInfo();
        return $res;
    
    public function delete()

        $this->query = $this->query->prepare($this->querySql(__FUNCTION__));
        $res=$this->query->execute();
        $this->error=$this->query->errorInfo();
        return $res;
    
    public function find()
    
        $data = $this->select();
        return $this->is_empty == 1 ? $data[0] : [];
    

    public function fetch()
    
        $this->query->execute();
        $data = $this->query->fetchAll(\\PDO::FETCH_ASSOC);
        $this->is_empty = 1;
        if (empty($data[0])) $this->is_empty = 0;
        return $data;
    
    public function paginate($page_num=15,$page='page')
        $page=$_POST[$page];
        $this->page=empty($page)?1:$page;
        $this->page_num=$page_num;
        $query=$this->query;
        $this->query = $this->query->prepare($this->querySql(__FUNCTION__));
        $data= $this->fetch();
        $total=$this->count('id',$query);
        $last_page=(string)ceil($total/$page_num);
        return ['total'=>$total,'per_page'=>$page_num,'current_page'=>$this->page,'last_page'=>$last_page,'data'=>$data];
    
    public function count($count_field='id',$query=null)
        $query=empty($query)?$this->query:$query;
        $query=$query->prepare($this->querySql('count',[],$count_field));
        $query->execute();
        $total=$query->fetch(\\PDO::FETCH_ASSOC)['total'];
        return $total;
    
    public function value($field)
        $data=$this->find();
        return empty($data[$field])?'':$data[$field];
    
    public function querySql($sql_type,$up_data=[],$count_field='id')
        list($where,$key,$value,$up,$paginate)=['',[],[],'',''];
        if (!empty($this->where) && is_array($this->where)) 
            $wh = '';
            foreach ($this->where as $k => $v) 
                if(strpos($v,'like')!==false || strpos($v,'in')!==false)
                    $wh.=$k.$v;
                else
                    $wh .= $k . '="' . $v . '" and ';
                
            
            $wh = trim($wh, ' and ');
            $where = ' where ' . $wh;
        
        if (!empty($this->where) && is_string($this->where)) $where = ' where ' . $this->where;
        $field = empty($this->field) ? '*' : $this->field;
        $order=empty($this->order)?'':' order by '.$this->order;
        $limit = empty($this->limit) ? '' : ' limit '.$this->limit;
        $group =empty($this->group) ?'':' group by '.$this->group;
        if(!empty($up_data)) 
            if($sql_type=='insert')
                foreach ($up_data as $k => $v) 
                    array_push($key, $k);
                    array_push($value, '"' . $v . '"');
                
                $key = implode(',', $key);
                $value = implode(',', $value);
            
            if($sql_type=='update')
                foreach($up_data as $k=>$v)
                    $up.=$k.'="'.$v.'",';
                
            
        
        if($sql_type=='paginate')
            $paginate=' limit '.($this->page-1)*$this->page_num.','.$this->page_num;
        
        if(empty($key))
            $key='';$value='';
        
        $up=trim($up,',');
        $sql_storm =[
            'select'=>'SELECT ' . $field . ' FROM ' . $this->name,
            'insert'=>'INSERT '.'INTO '.$this->name.' ('.$key.') values ('.$value.')',
            'update'=>'UPDATE '.$this->name.' SET '.$up,
            'delete'=>'DELETE '.'FROM '.$this->name,
            'paginate'=>'SELECT ' . $field . ' FROM ' . $this->name,
            'count'=>'SELECT '.'COUNT('.$count_field.') total'.' FROM ' . $this->name,
        ];
        $sql=$sql_storm[$sql_type];
        if(!empty($where)) $sql.=$where;
        if(!empty($order)) $sql.=$order;
        if(!empty($limit) && $sql_type!='paginate') $sql.=$limit;
        if(!empty($group)) $sql.=$group;
        if($sql_type=='paginate') $sql.=$paginate;
        return $sql;
    
    public function exec($sql)
        return  $this->query->prepare($sql)->execute();