创建函数库文件(增删改查)-2018年5月4日14:33:18

PHP函数库的封装

<?php
//链接数据库
if (!function_exists('connect')) {
    /**
     * @param $dbname
     * @param string $type
     * @param string $host
     * @param string $charset
     * @param int $port
     */
    function connect($dbname,$type='mysql',$host='127.0.0.0',$charset='utf8',$port=3306,$user='root',$pass='root'){
        $dsn = "{$type}:host={$host};dbname={$dbname};charset={$charset};port={$port}";
        $userName = $user;
        $password = $pass;
        try{
            $pdo = new PDO($dsn,$userName,$password);
            echo '连接成功';
        }catch (PDOException $e){
            print '连接错误'.$e->getMessage();
            die();

        }
        return $pdo;


    }
}
//新增数据
if (!function_exists('insert')){
    /**
     * @param $pdo
     * @param $table
     * @param array $data
     */
    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('条件不能为空');
         }
        $sql = rtrim(trim($sql), ',').';';
//        die($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('find')){
    /**
     * @param $pdo
     * @param $table
     * @param $fields
     * @param string $where
     * @return bool
     */
    function find($pdo,$table,$fields,$where=''){
        $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;
        }
        $sql .= ' LIMIT 1 ';
        $sql = rtrim(trim($sql), ',').';';

        $stmt = $pdo->prepare($sql);
        if ($stmt->execute()){
            if ($stmt->rowCount()>0){
                $stmt->setFetchMode(PDO::FETCH_ASSOC);
                return $stmt->fetch();
            }
        }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), ',').';';
//            die($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}  ";

        $sql = rtrim(trim($sql), ',');
        if (!empty($where)){
            $sql .= ' WHERE '.$where ;
        }else{
            exit('条件不能为空');
        }
        $sql = rtrim(trim($sql), ',').';';
//        die($sql);
        $stmt = $pdo->prepare($sql);

        if ($stmt->execute()){
            if ($stmt->rowCount()>0){
                return true;
            }
        }else{
            return false;
        }
    }
}

执行语句

<?php
/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2018/5/2
 * Time: 15:13
 */
require 'lib/func_pdo.php';
$type = 'mysql';
$host = '127.0.0.1';
$dbname = 'php';
$charset = 'utf8';
$port = '3306';
$user = 'root';
$pass = 'root';
$pdo = connect($dbname, $type, $host, $charset, $port, $user, $pass);
//2新增测试
//$table = 'staff';
//$data = ['name'=>'小王','sex'=>0,'age'=>32, 'salary' => 8800];
//insert($pdo, $table, $data);

//更新操作
//$table = 'staff';
//$data = ['name'=>'西门','sex'=>0,'age'=>42, 'salary' => 8990];
//$where = 'staff_id=26';
//update($pdo, $table, $data,$where);

//单条查询
//$table = 'staff';
//$fields = ['name','age','salary'];
//$fields = '*';
//$fields = 'name,salary';
//$where = 'age < 30 ';
//echo print_r(find($pdo, $table, $fields, $where),true);


//多语句查询
//$table = 'staff';
//$fields = ['name','age','salary'];
//$fields = '*';
//$fields = 'name,salary';
//$where = 'age < 26 ';
//$order = 'age ASC';
//echo '<pre>'. print_r(select($pdo, $table, $fields, $where,$order),true).'</pre>';


// 删除
$table = 'staff';
$where = 'staff_id = 21';
delete($pdo, $table, $where);

总结，使用PDO 进行函数库的封装，以后使用起来更方便

首先判断函数是否存在使用function_exists（）

调用connect（）函数执行连接数据库，代码测试使用die（）看看是否执行成功，或者到哪一步；