4.26 PDO常用操作函数封装 --28Day

1.数据库链接封装

实例

//1.数据库链接封装
function connect($url,$dbname,$root,$pass,$charset='utf8',$port='3306',$type='mysql'){

    $dsn="{$type}:host={$url};dbname={$dbname};charset={$charset};port={$port}";
    $userName = $root;
    $passWord = $pass;

    try{
        $pdo = new PDO($dsn,$userName,$passWord);
//        echo '数据库链接成功!';
        return $pdo;

    }catch (PDOException $e){
        print 'Connect ERROR!:'.$e->getMessage();
        die();
    }


}

函数调用>>>

实例

require 'lib/pdo_connect.php';

$pdo = connect('127.0.0.1','php','root','root');

2.数据插入操作

实例

//2.单条数据插入操作
//insert ignoe table set __=__
function insert_one($pdo,$table,$data=[]) {

    $sql = "insert ignore {$table} set ";

    if(!empty($data)){
        //1.SQL语句拼接
        //2.将data[]数组中的key作为参数以PDO预处理方式进行拼接

        foreach (array_keys($data) as $filed){
            $sql .= " {$filed} =:{$filed},";
        }

        //3.去除最后一个逗号
        $sql = substr($sql,0,strlen($sql)-1).';';


        $stmt = $pdo->prepare( $sql);

        foreach ($data as $key => $value) {
            $stmt->bindValue(":{$key}",$value);
        }

        //echo $stmt->queryString;

        //echo is_array($data);

        if($stmt->execute()){

            if($stmt->rowCount()>0){
                return true;
            }
        } else {
            echo 'STMT Error!:'.$pdo->errorInfo();
            return false;
        }

    }else{
        echo '无要新增的数据';
    }


}

函数调用

实例

//1.新增数据
$data = ['name'=>'虞姬','age'=>24,'address'=>'江东','iphone'=>'88889999'];
insert_one($pdo,'staff',$data);

3.更新操作

实例

//3.更新操作
//update table set ?=? where
function update($pdo,$table,$data=[],$where){

    $sql = "update {$table} set ";


    foreach (array_keys($data) as $key){
        $sql .= " {$key}=:{$key},";
    }

    $sql = substr($sql,0,strlen($sql)-1);

    if(!empty($where)){
        $sql .= " where {$where} ".';';
    }

    $stmt = $pdo->prepare($sql);

    foreach ($data as $key=>$value){
        $stmt->bindValue(":{$key}",$value);
    }

//    echo $stmt->queryString;
    if($stmt->execute()){
        echo '更新成功';
        return true;
    }else{
        echo '更新失败';
        return false;
    }



}

更新调用

实例

//2.更新数据
//$data1 = ['name'=>'刘邦','age'=>28];
//update($pdo,'staff',$data1,'staff_id=13');

4.删除操作

实例

//4.删除操作
function delete($pdo,$table,$data=[]){


    $sql = "delete from {$table} where  ";

    if(!empty($data)){

        if( count($data)==1 ){
            foreach (array_keys($data) as $key){
                $sql .= "{$key}=:$key ;";
            }
        }else{

            foreach (array_keys($data) as $key){
                $sql .= "{$key}=:$key and ";
            }
            $sql = substr($sql,0,strripos($sql,'and')-1);

        }

    }else{
        echo '查询条件不能为空';
        die();
    }



    $stmt = $pdo->prepare($sql);

    foreach ($data as $key=>$value){
        $stmt->bindValue(":{$key}",$value);
    }

    //echo $stmt->queryString;

    if($stmt->execute()){
        if($stmt->rowCount()>0) {
            echo '<br>删除成功';
            return true;
        }else{
            echo '<br>删除失败';
            return false;
        }
    }else{
        echo '<br>删除失败';
        return false;
    }







}

删除调用

实例

//3.删除数据
//$data2 = ['name'=>'虞姬','age'=>24,'address'=>'江东','iphone'=>'88889999'];
//delete($pdo,'staff',$data2);

5.查询

实例

//4.精准条件查询
function select($pdo,$col=[],$table,$data=[]){


    $sql = "select ";

    if(!empty($col)) {
        if(count($col)==1){
            foreach ($col as $value){
                $sql .= " {$value} ";
            }
        }else{
            foreach ($col as $value){
                $sql .= " {$value} ,";
            }
            $sql=substr($sql,0,strlen($sql)-1);
        }
    }else{
        echo '查询字段不能为空';
        die();
    }
    $sql .= " from {$table} where 1=1 ";




    if(!empty($data)) {

        foreach (array_keys($data) as $key){
            $sql .= " and {$key}=:{$key} ";
        }

    }else{
        $sql .= " and 1=1 ";
//        echo '查询条件不能为空';
//        die();
    }

    $stmt = $pdo->prepare($sql);

    foreach ($data as $key=>$value){
        $stmt->bindValue(":{$key}",$value);
    }

//    echo $sql;
//    die();

    if($stmt->execute()){
        $resall=[];
        while($res = $stmt->fetch(PDO::FETCH_ASSOC)){
           $resall[]=$res;
           //var_dump($res);
        }
        return $resall;

    }else{
        echo '<br>查询失败';
        return false;
    }

}

查询调用

实例

//4.精准条件查询
//4.1 模糊查询全部
$data2 = ['*'];
$data = [];

//4.1 指定字段查询
//$data2 = ['name','age','address'];
//$data = ['age'=>24];

$res = select($pdo,$data2,'staff',$data);

foreach($res as $key => $link)
{
    foreach($link as $key1 => $val)
    {
        echo $key1 . '-->'.$val." ";
    }
    echo '<br>';
}