search
HomeBackend DevelopmentPHP TutorialPHP database operation class based on pdo [can support mysql, sqlserver and oracle]

This article mainly introduces PHP's pdo-based database operation class, which can realize basic database connections, additions, deletions, modifications, and closing connections. It also supports operations on mysql, sqlserver, oracle and other databases. Friends who need it can Refer to the following

The example of this article describes the PHP database operation class based on pdo. Share it with everyone for your reference, the details are as follows:

This class is used when operating sqlserver and oracle at work. At that time, it was improved on the basis of others. Now I will share it

<?php
class Pdodb{
  protected $pdo;
  protected $res;
  protected $config;
  /*构造函数*/
  function __construct($config){
    $this->Config = $config;
    $this->connect();
  }
  /*数据库连接*/
  public function connect(){
    try {
       $this->pdo= new PDO($this->Config[&#39;dsn&#39;], $this->Config[&#39;username&#39;], $this->Config[&#39;password&#39;]);//$dbh = new PDO(&#39;mysql:host=localhost;dbname=test&#39;, $user, $pass);
       $this->pdo->query("set names utf8");
    }catch(Exception $e){
      echo &#39;数据库连接失败,详情: &#39; . $e->getMessage () . &#39; 请在配置文件中数据库连接信息&#39;;
      exit ();
    }
    /*
    if($this->Config[&#39;type&#39;]==&#39;oracle&#39;){
      $this->pdo->query("set names {$this->Config[&#39;charset&#39;]};");
    }else{
      $this->pdo->query("set names {$this->Config[&#39;charset&#39;]};");
    }
    */
    //把结果序列化成stdClass
    //$this->pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ);
    //自己写代码捕获Exception
    //$this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    $this->pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);//属性名 属性值 数组以关联数组返回
  }
  /*数据库关闭*/
  public function close(){
    $this->pdo = null;
  }
  //用于有记录结果返回的操作,特别是SELECT操作
  public function query($sql,$return=false){
    $res = $this->pdo->query($sql);
    if($res){
      $this->res = $res; // 未返回 return $this->res;
    }
    if($return){
      return $res;
    }
  }
  //主要是针对没有结果集合返回的操作,比如INSERT、UPDATE、DELETE等操作
  public function exec($sql,$return=false){
    $res = $this->pdo->exec($sql);
    if($res){
      $this->res = $res;
    }
    if($return){//返回操作是否成功 成功返回1 失败0
      return $res;
    }
  }
  //将$this->res以数组返回(全部返回)
  public function fetchAll(){
    return $this->res->fetchAll();
  }
  //将$this->res以数组返回(一条记录)
  public function fetch(){
    return $this->res->fetch();
  }
  //返回所有字段
  public function fetchColumn(){
    return $this->res->fetchColumn();
  }
  //返回最后插入的id
  public function lastInsertId(){
    return $this->res->lastInsertId();
  }
  //返回最后插入的id
  public function lastInsertId2(){
    return $this->pdo->lastInsertId();
  }
  /**
  * 参数说明
  * string/array $table 数据库表,两种传值模式
  * 普通模式:
  * &#39;tb_member, tb_money&#39;
  * 数组模式:
  * array(&#39;tb_member&#39;, &#39;tb_money&#39;)
  * string/array $fields 需要查询的数据库字段,允许为空,默认为查找全部,两种传值模式
  * 普通模式:
  * &#39;username, password&#39;
  * 数组模式:
  * array(&#39;username&#39;, &#39;password&#39;)
  * string/array $sqlwhere 查询条件,允许为空,两种传值模式
  * 普通模式(必须加上and,$sqlwhere为空 1=1 正常查询):
  * &#39;and type = 1 and username like "%os%"&#39;
  * 数组模式:
  * array(&#39;type = 1&#39;, &#39;username like "%os%"&#39;)
  * string $orderby 排序,默认为id倒序
  *int $debug 是否开启调试,开启则输出sql语句
  * 0 不开启
  * 1 开启
  * 2 开启并终止程序
  * int $mode 返回类型
  * 0 返回多条记录
  * 1 返回单条记录
  * 2 返回行数
  */
  public function select($table, $fields="*", $sqlwhere="", $orderby="", $debug=0, $mode=0){
    //参数处理
    if(is_array($table)){
      $table = implode(&#39;, &#39;, $table);
    }
    if(is_array($fields)){
      $fields = implode(&#39;,&#39;,$fields);
      /*
      if($this->Config[&#39;type&#39;]==&#39;oracle&#39;){
        //$fields = implode(&#39;,&#39;,$fields);//CUSTOMER_ID,FIRST_NAME,LAST_NAME,EMAIL
        //$fields = implode(",&#39;UTF8&#39;,&#39;ZHS16GBK&#39;) ,convert(",$fields);
        //$fields="convert(".$fields.",&#39;UTF8&#39;,&#39;ZHS16GBK&#39;)";
      }else{
        $fields = implode(&#39;,&#39;,$fields);
      }
      */
    }
    if(is_array($sqlwhere)){
      $sqlwhere = &#39; and &#39;.implode(&#39; and &#39;, $sqlwhere);
    }
    //数据库操作
    if($debug === 0){
      if($mode === 2){ //统计
        $this->query("select count(*) from $table where 1=1 $sqlwhere");
        $return = $this->fetchColumn();
      }else if($mode === 1){ //返回一条
        $this->query("select $fields from $table where 1=1 $sqlwhere $orderby");
        $return = $this->fetch();
      }else{
        $this->query("select $fields from $table where 1=1 $sqlwhere $orderby");
        $return = $this->fetchAll();//如果 $this->res为空即sql语句错误 会提示Call to a member function fetchAll() on a non-object
      }
      return $return;
    }else{
        if($mode === 2){
          echo "select count(*) from $table where 1=1 $sqlwhere";
        }else if($mode === 1){
          echo "select $fields from $table where 1=1 $sqlwhere $orderby";
        }else{
          echo "select $fields from $table where 1=1 $sqlwhere $orderby";
        }
        if($debug === 2){
          exit;
        }
    }
  }
  /**
  * 参数说明
  * string/array $table 数据库表,两种传值模式
  * 普通模式:
  * &#39;tb_member, tb_money&#39;
  * 数组模式:
  * array(&#39;tb_member&#39;, &#39;tb_money&#39;)
  * string/array $set 需要插入的字段及内容,两种传值模式
  * 普通模式:
  * &#39;username = "test", type = 1, dt = now()&#39;
  * 数组模式:
  * array(&#39;username = "test"&#39;, &#39;type = 1&#39;, &#39;dt = now()&#39;)
  * int $debug 是否开启调试,开启则输出sql语句
  * 0 不开启
  * 1 开启
  * 2 开启并终止程序
  * int $mode 返回类型
  * 0 无返回信息
  * 1 返回执行条目数
  * 2 返回最后一次插入记录的id
  */
  public function oic_insert($table, $set, $debug=0, $mode=0){
    //参数处理
    if(is_array($table)){
      $table = implode(&#39;, &#39;, $table);
    }
    if(is_array($set)){
      $s=&#39;&#39;;$i=0;
      foreach($set as $k=>$v){
        $i++;
        $s[$i]=$k;//,连接
        $val[$i]=$v;
      }
      $sarr=implode(",",$s);//去掉最后一个,
      //array_pop($sarr);
      $set=implode("&#39;,&#39;",$val);////15221579236&#39;,&#39;张三&#39;,&#39;&#39;,&#39;2001&#39;,&#39;8&#39;,&#39;4&#39;,&#39;女&#39;,&#39;是
      //$set = implode(&#39;, &#39;, $set);
    }
    //数据库操作
    if($debug === 0){
      if($mode === 2){
        $this->query("insert into $table ($sarr) values(&#39;".$set."&#39;)");
        //$return = $this->lastInsertId();
      }else if($mode === 1){
        $this->exec("insert into $table ($sarr) values(&#39;".$set."&#39;)");
        $return = $this->res;
      }else{
        $this->query("insert into $table ($sarr) values(&#39;".$set."&#39;)");
        $return = NULL;
      }
      return $return;
    }else{
      echo "insert into $table ($sarr) values(&#39;".$set."&#39;)";
      if($debug === 2){
        exit;
      }
    }
  }
  public function insert($table, $set, $debug=0, $mode=0){
    //参数处理
    if(is_array($table)){
      $table = implode(&#39;, &#39;, $table);
    }
    if(is_array($set)){
      $s=&#39;&#39;;
      foreach($set as $k=>$v){
        $s.=$k."=&#39;".$v."&#39;,";//,连接
      }
      $sarr=explode(&#39;,&#39;,$s);//去掉最后一个,
      array_pop($sarr);
      $set=implode(&#39;,&#39;,$sarr);
      //$set = implode(&#39;, &#39;, $set);
    }
    //数据库操作
    if($debug === 0){
      if($mode === 2){
        $this->query("insert into $table set $set");
        $return = $this->pdo->lastInsertId();
      }else if($mode === 1){
        $this->exec("insert into $table set $set");
        $return = $this->res;
      }else{
        $this->query("insert into $table set $set");
        $return = NULL;
      }
      return $return;
    }else{
      echo "insert into $table set $set";
      if($debug === 2){
        exit;
      }
    }
  }
  /**
  * 参数说明
  * string $table 数据库表,两种传值模式
  * 普通模式:
  * &#39;tb_member, tb_money&#39;
  * 数组模式:
  * array(&#39;tb_member&#39;, &#39;tb_money&#39;)
  * string/array $set 需要更新的字段及内容,两种传值模式
  * 普通模式:
  * &#39;username = "test", type = 1, dt = now()&#39;
  * 数组模式:
  * array(&#39;username = "test"&#39;, &#39;type = 1&#39;, &#39;dt = now()&#39;)
  * string/array $sqlwhere 修改条件,允许为空,两种传值模式
  * 普通模式:
  * &#39;and type = 1 and username like "%os%"&#39;
  * 数组模式:
  * array(&#39;type = 1&#39;, &#39;username like "%os%"&#39;)
  * int $debug 是否开启调试,开启则输出sql语句
  * 0 不开启
  * 1 开启
  * 2 开启并终止程序
  * int $mode 返回类型
  * 0 无返回信息
  * 1 返回执行条目数
  */
  public function update($table, $set, $sqlwhere="", $debug=0, $mode=0){
    //参数处理
    if(is_array($table)){
      $table = implode(&#39;, &#39;, $table);
    }
    if(is_array($set)){
      $s=&#39;&#39;;
      foreach($set as $k=>$v){
        $s.=$k."=&#39;".$v."&#39;,";
      }
      $sarr=explode(&#39;,&#39;,$s);//去掉最后一个,
      array_pop($sarr);
      $set=implode(&#39;,&#39;,$sarr);
      //$set = implode(&#39;, &#39;, $set);
    }
    if(is_array($sqlwhere)){
      $sqlwhere = &#39; and &#39;.implode(&#39; and &#39;, $sqlwhere);
    }
    //数据库操作
    if($debug === 0){
      if($mode === 1){
        $this->exec("update $table set $set where 1=1 $sqlwhere");
        $return = $this->res;
      }else{
        $this->query("update $table set $set where 1=1 $sqlwhere");
        $return = true;
      }
      return $return;
    }else{
      echo "update $table set $set where 1=1 $sqlwhere";
      if($debug === 2){
        exit;
      }
    }
  }
  /**
  * 参数说明
  * string $table 数据库表
  * string/array $sqlwhere 删除条件,允许为空,两种传值模式
  * 普通模式:
  * &#39;and type = 1 and username like "%os%"&#39;
  * 数组模式:
  * array(&#39;type = 1&#39;, &#39;username like "%os%"&#39;)
  * int $debug 是否开启调试,开启则输出sql语句
  * 0 不开启
  * 1 开启
  * 2 开启并终止程序
  * int $mode 返回类型
  * 0 无返回信息
  * 1 返回执行条目数
  */
  public function delete($table, $sqlwhere="", $debug=0, $mode=0){
    //参数处理
    if(is_array($sqlwhere)){
      $sqlwhere = &#39; and &#39;.implode(&#39; and &#39;, $sqlwhere); //是字符串需自己加上and
    }
    //数据库操作
    if($debug === 0){
      if($mode === 1){
        $this->exec("delete from $table where 1=1 $sqlwhere");
        $return = $this->res;
      }else{
        $this->query("delete from $table where 1=1 $sqlwhere");
        $return = NULL;
      }
      return $return;
    }else{
      echo "delete from $table where 1=1 $sqlwhere";
      if($debug === 2){
        exit;
      }
    }
  }
}
/*
sqlserver 配置 extension=php_pdo_mssql.dll和extension=php_pdo_sqlsrv.dll 安装对应的 ntwdblib.dll
http://msdn.microsoft.com/en-us/library/cc296170.aspx 下载php版本对应的sqlsrv扩展
sqlserver 配置 odbc连接需开启extension=php_pdo_odbc.dll
*/
$mssql2008_config=array(
  &#39;dsn&#39;=>&#39;odbc:Driver={SQL Server};Server=192.168.1.60;Database=his&#39;,//数据库服务器地址
  &#39;username&#39;=>&#39;sa&#39;,
  &#39;password&#39;=>&#39;xxxxx&#39;,
);
$mssql=new Pdodb($mssql2008_config);
$sql="select * from
(
  select row_number()over(order by tempcolumn)temprownumber,*
    from (
      select top 10 tempcolumn=0,a.*
      from DA_GR_HBFS a
      where 1=1
    ) t
) tt
where temprownumber>0";
$mssql->query($sql);
while($res=$mssql->fetch()){
  $data[]=$res;
}
print_r($data);exit;
//mysql 操作
$msyql_config=array(
  &#39;dsn&#39;=>&#39;mysql:host=localhost;dbname=talk&#39;,
  &#39;username&#39;=>&#39;root&#39;,
  &#39;password&#39;=>&#39;123456&#39;
);
$mysql=new PDO_DB($msyql_config);
$sql = &#39;SELECT user_id, user_name, nickname FROM et_users &#39;;
$mysql->query($sql);
$data=$mysql->fetchAll();
print_r($data);exit;
//oracle 操作
$oci_config=array(
  &#39;dsn&#39;=>&#39;oci:dbname=orcl&#39;,
  &#39;username&#39;=>&#39;BAOCRM&#39;,
  &#39;password&#39;=>&#39;BAOCRM&#39;
);
$oracle=new PDO_DB($oci_config);
//print_r($oracle);exit;//PDO_DB Object ( [pdo:protected] => PDO Object ( ) [res:protected] => [config:protected] => [Config] => Array ( [dsn] => oci:dbname=orcl [name] => PWACRM [password] => PWACRM ) )
$sql="select * from CUSTOMER_LEVEL t";
$oracle->query($sql);
$data=$oracle->fetchAll();
print_r($data);exit;
/*
Array
(
  [0] => Array
    (
      [LEVEL_ID] => 1
      [0] => 1
      [LEVEL_NAME] => 普通会员
      [1] => 普通会员
      [LEVEL_DETAIL] => 普通会员
      [2] => 普通会员
      [SORT_NUMBER] => 15
      [3] => 15
      [CREATE_TIME] => 12-7月 -12
      [4] => 12-7月 -12
      [CREATE_BY] => 1
      [5] => 1
      [UPDATE_TIME] => 12-7月 -12
      [6] => 12-7月 -12
      [UPDATE_BY] => 1
      [7] => 1
      [STATE] => 正常
      [8] => 正常
    )
)*/
?>

Related recommendations:

MySQL read-write separation operation implemented in PHP

PHP implements the function of preventing repeated form submission (based on token verification)

The above is the detailed content of PHP database operation class based on pdo [can support mysql, sqlserver and oracle]. For more information, please follow other related articles on the PHP Chinese website!

Statement
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
Explain the concept of session locking.Explain the concept of session locking.Apr 29, 2025 am 12:39 AM

Sessionlockingisatechniqueusedtoensureauser'ssessionremainsexclusivetooneuseratatime.Itiscrucialforpreventingdatacorruptionandsecuritybreachesinmulti-userapplications.Sessionlockingisimplementedusingserver-sidelockingmechanisms,suchasReentrantLockinJ

Are there any alternatives to PHP sessions?Are there any alternatives to PHP sessions?Apr 29, 2025 am 12:36 AM

Alternatives to PHP sessions include Cookies, Token-based Authentication, Database-based Sessions, and Redis/Memcached. 1.Cookies manage sessions by storing data on the client, which is simple but low in security. 2.Token-based Authentication uses tokens to verify users, which is highly secure but requires additional logic. 3.Database-basedSessions stores data in the database, which has good scalability but may affect performance. 4. Redis/Memcached uses distributed cache to improve performance and scalability, but requires additional matching

What is the full form of PHP?What is the full form of PHP?Apr 28, 2025 pm 04:58 PM

The article discusses PHP, detailing its full form, main uses in web development, comparison with Python and Java, and its ease of learning for beginners.

How does PHP handle form data?How does PHP handle form data?Apr 28, 2025 pm 04:57 PM

PHP handles form data using $\_POST and $\_GET superglobals, with security ensured through validation, sanitization, and secure database interactions.

What is the difference between PHP and ASP.NET?What is the difference between PHP and ASP.NET?Apr 28, 2025 pm 04:56 PM

The article compares PHP and ASP.NET, focusing on their suitability for large-scale web applications, performance differences, and security features. Both are viable for large projects, but PHP is open-source and platform-independent, while ASP.NET,

Is PHP a case-sensitive language?Is PHP a case-sensitive language?Apr 28, 2025 pm 04:55 PM

PHP's case sensitivity varies: functions are insensitive, while variables and classes are sensitive. Best practices include consistent naming and using case-insensitive functions for comparisons.

How do you redirect a page in PHP?How do you redirect a page in PHP?Apr 28, 2025 pm 04:54 PM

The article discusses various methods for page redirection in PHP, focusing on the header() function and addressing common issues like "headers already sent" errors.

Explain type hinting in PHPExplain type hinting in PHPApr 28, 2025 pm 04:52 PM

Article discusses type hinting in PHP, a feature for specifying expected data types in functions. Main issue is improving code quality and readability through type enforcement.

See all articles

Hot AI Tools

Undresser.AI Undress

Undresser.AI Undress

AI-powered app for creating realistic nude photos

AI Clothes Remover

AI Clothes Remover

Online AI tool for removing clothes from photos.

Undress AI Tool

Undress AI Tool

Undress images for free

Clothoff.io

Clothoff.io

AI clothes remover

Video Face Swap

Video Face Swap

Swap faces in any video effortlessly with our completely free AI face swap tool!

Hot Tools

MantisBT

MantisBT

Mantis is an easy-to-deploy web-based defect tracking tool designed to aid in product defect tracking. It requires PHP, MySQL and a web server. Check out our demo and hosting services.

EditPlus Chinese cracked version

EditPlus Chinese cracked version

Small size, syntax highlighting, does not support code prompt function

SublimeText3 Chinese version

SublimeText3 Chinese version

Chinese version, very easy to use

ZendStudio 13.5.1 Mac

ZendStudio 13.5.1 Mac

Powerful PHP integrated development environment

SecLists

SecLists

SecLists is the ultimate security tester's companion. It is a collection of various types of lists that are frequently used during security assessments, all in one place. SecLists helps make security testing more efficient and productive by conveniently providing all the lists a security tester might need. List types include usernames, passwords, URLs, fuzzing payloads, sensitive data patterns, web shells, and more. The tester can simply pull this repository onto a new test machine and he will have access to every type of list he needs.