创建函数库文件

代码如下

<?php
/**
 * 操作函数库
 */
if (!function_exists('connect')){
//    数据库连接

    function connect($dbname,$type='mysql',$host='127.0.0.1', $charset='utf8',$user='root',$password='root'){
        $dsn = "{$type}:host={$host}; dbname={$dbname}; charset={$charset}";
        $userName = 'root';
        $password = 'root';
        $options = [
            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
            PDO::ATTR_CASE => PDO::CASE_NATURAL,
            PDO::ATTR_EMULATE_PREPARES => true,];
        try {
            $pdo = new PDO($dsn, $userName, $password, $options);
        }catch (PDOException $e) {
            die('Connect ERROR!:'.$e->getMessage());
        }
        return $pdo;

    }
}
//新增数据
if (!function_exists('insert')){
    function insert($pdo, $table, $data=[])
    {
        $sql = "INSERT IGNORE {$table} SET ";
        foreach (array_keys($data) as $field) {
            $sql .= $field . '=:' . $field . ', ';
        }
        $sql = rtrim(trim($sql), ',') . ';';
        $stmt = $pdo->prepare($sql);
        foreach ($data as $field => $value) {
            $stmt->bindValue(":{$field}", $value);
        }
        if ($stmt->execute()) {
            if ($stmt->rowCount() > 0) {
                return true;
            }

        }else {
            return false;
        }
    }
}
//更新数据
if (!function_exists('update')){
    function update($pdo,$table,$data=[], $where=''){
        $sql = "UPDATE {$table} SET ";
        foreach (array_keys($data) as $field) {
            $sql .= $field.'=:'.$field.', ';
        }
        $sql = rtrim(trim($sql),',');
        if(!empty($where)) {
            $sql .= ' WHERE '. $where;
        }else{
            exit('不能为空');
        }
        $stmt = $pdo->prepare($sql);
        foreach ($data as $field => $value) {
            $stmt->bindValue(":{$field}",$value);
        }
        if($stmt->execute()){
            if($stmt->rowCount()>0){
                return true;
            }
        } else {
            return false;}
    }

}
//查询数据
if (!function_exists('select')) {
    function select($pdo,$table,$fields, $where='', $order='') {
        $sql = 'SELECT ';
        if (is_array($fields)) {
            foreach ($fields as $field) {
                $sql .= $field.', ';
            }
        } else {
            $sql .= $fields;
        }

        $sql = rtrim(trim($sql),',');
        $sql .= '  FROM '.$table;
        if(!empty($where)) {
            $sql .= '  WHERE '. $where;
        }
        if(!empty($order)) {
            $sql .= ' order by '.$order;
        }
        $sql = rtrim(trim($sql),',').';';
        $stmt = $pdo->prepare($sql);
        if($stmt->execute()){
            if($stmt->rowCount()>0){
                $stmt->setFetchMode(PDO::FETCH_ASSOC);
                //返回一个二维数组
                return $stmt->fetchAll();
            }
        } else {
            return false;
        }
    }
}
//删除数据
if (!function_exists('delete')) {
    function delete($pdo,$table, $where='') {
        $sql = "DELETE FROM {$table}  ";
        if(!empty($where)) {
            $sql .= 'WHERE '. $where;
        }else{
            exit('条件不能为空');
        }
        $sql = rtrim(trim($sql),',').';';
        $stmt = $pdo->prepare($sql);
        if($stmt->execute()){
            if($stmt->rowCount()>0){
                return true;
            }
        } else {
            return false;
        }
    }
}

手写如下