前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >php实现Mysql简易操作类

php实现Mysql简易操作类

原创
作者头像
用户1685462
修改2021-08-27 17:54:05
1.2K0
修改2021-08-27 17:54:05
举报
文章被收录于专栏:网站教程

自己封装的Mysql简易操作类,已塞在Ben框架中,基于PDO来写的,代码风格上有些无厘头。。。

mysql.class.php

代码语言:javascript
复制
<?php

class mysql extends PDO{

  public $server;

  public $database;

  public $user;

  public $password;

  public $sql;

  public function __construct($server,$database,$user,$password,$port=3306){

    $this->server = $server;

    $this->database = $database;

    $this->user = $user;

    $this->password = $password;

    parent::__construct("mysql:host=$server;port=$port;dbname=$database",$user,$password);

    $this->query('SET NAMES utf8');

  }

  public function drop($table){

    $sql = 'DROP TABLE '.$table.';';

    $re = $this->query($sql);

    if($re){

      return true;

    }else{

      return false;

    }

  }

  public function INSERT($table,$name,$value=null){

    $sql = "INSERT INTO ".$table.'(';

    if($value == null){

    $arrname = array_keys($name);

    $arrvalue = array_values($name);

    }else{

    $arrname = explode('|', $name);

    $arrvalue = explode('|', $value);

    }

    for($i=0;$i<count($arrname);$i++){

      if($i==count($arrname)-1){

        $sql = $sql.$arrname[$i];

      }else{

        $sql = $sql.$arrname[$i].",";

      }

    }

    $sql = $sql.")VALUES(";

    for($i=0;$i<count($arrvalue);$i++){

      if($i==count($arrvalue)-1){

        $sql = $sql."'".$arrvalue[$i]."'";

      }else{

        $sql = $sql."'".$arrvalue[$i]."',";

      }

    }

    $sql .=");";

    $re = $this->query($sql);

    if($re){

      return true;

    }else{

      return false;

    }

  }

  public function DELETE($table,$Conditionsname,$Conditionsvalue=null){

    if($Conditionsvalue!=null){

      $sql = "DELETE FROM ".$table." WHERE ".$Conditionsname."='".$Conditionsvalue."';";

    }else{

      $sql = "DELETE FROM ".$table." WHERE ";

      $arrname = array_keys($Conditionsname);

      $arrvalue = array_values($Conditionsname);

      for($i=0;$i<count($arrname);$i++){

        if($i==count($arrname)-1){

          $sql.=$arrname[$i].'='."'".$arrvalue[$i]."'";

        }else{

          $sql.=$arrname[$i].'='."'".$arrvalue[$i]."',";

        }

      }

      $sql.=';';

    }

    $re = $this->query($sql);

    if($re){

      return true;

    }else{

      return false;

    }

  }

  public function SELECT($table,$name,$Conditionsname,$Conditionsvalue=null){

    if($Conditionsvalue!=null){

      $sql = "SELECT ".$name." FROM ".$table." WHERE ".$Conditionsname."='".$Conditionsvalue."';";

    }else{

      $sql = "SELECT ".$name." FROM ".$table." WHERE ";

      $arrname = array_keys($Conditionsname);

      $arrvalue = array_values($Conditionsname);

      for($i=0;$i<count($arrname);$i++){

        if($i==count($arrname)-1){

          $sql.=$arrname[$i].'='."'".$arrvalue[$i]."'";

        }else{

          $sql.=$arrname[$i].'='."'".$arrvalue[$i]."' and ";

        }

      }

      $sql.=';';

    }

    $re = $this->query($sql);

    $row = $re->fetch();

    return $row[$name];

  }

  public function UPDATE($table,$name,$value,$Conditionsname,$Conditionsvalue=null){

    if($Conditionsvalue!=null){

      $sql = "UPDATE ".$table." SET ".$name."= '".$value."' WHERE ".$Conditionsname."='".$Conditionsvalue."';";

    }else{

      $sql = "UPDATE ".$table." SET ".$name."= '".$value."' WHERE ";

      $arrname = array_keys($Conditionsname);

      $arrvalue = array_values($Conditionsname);

      for($i=0;$i<count($arrname);$i++){

        if($i==count($arrname)-1){

          $sql.=$arrname[$i].'='."'".$arrvalue[$i]."'";

        }else{

          $sql.=$arrname[$i].'='."'".$arrvalue[$i]."' and ";

        }

      }

      $sql.=';';

    }

    $re = $this->query($sql);

    if($re){

      return true;

    }else{

      return false;

    }

  }

  public function group($table,$name){

    $sql = "SELECT ".$name." FROM ".$table.";";

    $return = array();

    $re = $this->query($sql);

    while($row = $re->fetch(PDO::FETCH_ASSOC)){

      array_push($return,$row[$name]);

    }

    return $return;

  }

  public function fetchall($sql){

    $return = array();

    $re = $this->query($sql);

    while($row = $re->fetch(PDO::FETCH_ASSOC)){

      array_push($return,$row);

    }

    return $return;

  }

}

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
云数据库 SQL Server
腾讯云数据库 SQL Server (TencentDB for SQL Server)是业界最常用的商用数据库之一,对基于 Windows 架构的应用程序具有完美的支持。TencentDB for SQL Server 拥有微软正版授权,可持续为用户提供最新的功能,避免未授权使用软件的风险。具有即开即用、稳定可靠、安全运行、弹性扩缩等特点。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档